Package | Description |
---|---|
com.dsf.dbxtract.cdc | |
com.dsf.dbxtract.cdc.journal |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
Config.getAffinity()
Get a list of datasources enabled for this node (parameter
affinity ). |
Sources |
Config.getDataSources()
Data sources are a list of database connections and its associated
handler's class names.
|
java.util.Collection<JournalHandler> |
Config.getHandlers()
Retrieves all handlers defined in the configuration properties.
|
Source |
Config.getSourceByHandler(JournalHandler handler)
Retrieves the data source associated to a given handler.
|
int |
Config.getThreadPoolSize()
Retrieves the
thread.pool.size parameter. |
java.lang.String |
Config.getZooKeeper()
Retrieves the zookeeper connection string.
|
void |
Config.listAll()
Print out configuration data.
|
void |
App.start()
Starts scanning services.
|
Constructor and Description |
---|
Config(java.lang.String path)
Constructs the object loading configuration properties from a given file.
|
Constructor and Description |
---|
SimpleJournalHandler(java.lang.String journalTable,
java.lang.String query,
int batchSize,
Publisher publisher,
JournalStrategy strategy) |