- get(CuratorFramework, String) - Method in class com.dsf.dbxtract.cdc.mon.Statistics
-
- getAffinity() - Method in class com.dsf.dbxtract.cdc.Config
-
Get a list of datasources enabled for this node (parameter
affinity).
- getAgentName() - Method in class com.dsf.dbxtract.cdc.Config
-
Retrieves a 'unofficial' agent name based.
- getAttribute(String) - Method in class com.dsf.dbxtract.cdc.mon.InfoMBean
-
- getAttributes(String[]) - Method in class com.dsf.dbxtract.cdc.mon.InfoMBean
-
- getBatchSize() - Method in interface com.dsf.dbxtract.cdc.journal.JournalHandler
-
- getBatchSize() - Method in class com.dsf.dbxtract.cdc.journal.SimpleJournalHandler
-
- getBatchSize() - Method in class com.dsf.dbxtract.cdc.sample.TestHandler
-
- getBatchSize() - Method in class com.dsf.dbxtract.cdc.sample.TestWindowHandler
-
- getById(int) - Method in enum com.dsf.dbxtract.cdc.journal.JournalStrategy
-
Retrieve a strategy based on its identifier
- getColumnNames() - Method in class com.dsf.dbxtract.cdc.Data
-
Retrieve the column names.
- getConfig() - Method in class com.dsf.dbxtract.cdc.App
-
Gets configuration data
- getConnection() - Method in class com.dsf.dbxtract.cdc.Source
-
- getDataSources() - Method in class com.dsf.dbxtract.cdc.Config
-
Data sources are a list of database connections and its associated
handler's class names.
- getDriver() - Method in class com.dsf.dbxtract.cdc.Source
-
- getHandlers() - Method in class com.dsf.dbxtract.cdc.Config
-
Retrieves all handlers defined in the configuration properties.
- getHandlers() - Method in class com.dsf.dbxtract.cdc.Source
-
- getInstance(Config) - Static method in class com.dsf.dbxtract.cdc.mon.Monitor
-
- getInstance() - Static method in class com.dsf.dbxtract.cdc.mon.Monitor
-
- getInterval() - Method in class com.dsf.dbxtract.cdc.Sources
-
- getJournalTable() - Method in interface com.dsf.dbxtract.cdc.journal.JournalHandler
-
- getJournalTable() - Method in class com.dsf.dbxtract.cdc.journal.SimpleJournalHandler
-
- getJournalTable() - Method in class com.dsf.dbxtract.cdc.sample.TestHandler
-
- getJournalTable() - Method in class com.dsf.dbxtract.cdc.sample.TestWindowHandler
-
- getLastRead() - Method in class com.dsf.dbxtract.cdc.mon.Statistics.StatEntry
-
This value is updated every time a successful capture occurs.
- getLastSeek() - Method in class com.dsf.dbxtract.cdc.mon.Statistics.StatEntry
-
This value is updated every time a capture to datasource is
performed.
- getMBeanInfo() - Method in class com.dsf.dbxtract.cdc.mon.InfoMBean
-
- getName() - Method in class com.dsf.dbxtract.cdc.mon.Statistics.StatEntry
-
- getName() - Method in class com.dsf.dbxtract.cdc.Source
-
- getPassword() - Method in class com.dsf.dbxtract.cdc.Source
-
- getReadCount() - Method in class com.dsf.dbxtract.cdc.mon.Statistics.StatEntry
-
- getRows() - Method in class com.dsf.dbxtract.cdc.Data
-
Retrieve the list of data rows.
- getSourceByHandler(JournalHandler) - Method in class com.dsf.dbxtract.cdc.Config
-
Retrieves the data source associated to a given handler.
- getSources() - Method in class com.dsf.dbxtract.cdc.Sources
-
- getStatement() - Method in class com.dsf.utils.sql.NamedParameterStatement
-
Returns the underlying statement.
- getStrategy() - Method in interface com.dsf.dbxtract.cdc.journal.JournalHandler
-
Establish the journal strategy:
DELETE - removes imported rows from journal table
WINDOW - memorizes
- getStrategy() - Method in class com.dsf.dbxtract.cdc.journal.SimpleJournalHandler
-
- getStrategy() - Method in class com.dsf.dbxtract.cdc.sample.TestHandler
-
- getStrategy() - Method in class com.dsf.dbxtract.cdc.sample.TestWindowHandler
-
- getTargetQuery() - Method in interface com.dsf.dbxtract.cdc.journal.JournalHandler
-
The query to retrieve changed data can references columns from journal
table as named parameters:
- getTargetQuery() - Method in class com.dsf.dbxtract.cdc.journal.SimpleJournalHandler
-
- getTargetQuery() - Method in class com.dsf.dbxtract.cdc.sample.TestHandler
-
Query parameters must be referenced just like in JPA's NamedQueries.
- getTargetQuery() - Method in class com.dsf.dbxtract.cdc.sample.TestWindowHandler
-
Query parameters must be referenced just like in JPA's NamedQueries.
- getThreadPoolSize() - Method in class com.dsf.dbxtract.cdc.Config
-
Retrieves the thread.pool.size parameter.
- getUser() - Method in class com.dsf.dbxtract.cdc.Source
-
- getZooKeeper() - Method in class com.dsf.dbxtract.cdc.Config
-
Retrieves the zookeeper connection string.