com.dsf.dbxtract.cdc.journal

Interface JournalHandler

All Known Implementing Classes:

SimpleJournalHandler, TestHandler, TestWindowHandler

public interface JournalHandler

Interface to be implemented by capture executors.

Version:

0.1

Author:

fabio de santi

Method Summary

Modifier and Type	Method and Description
int	getBatchSize()
java.lang.String	getJournalTable()
JournalStrategy	getStrategy() Establish the journal strategy: DELETE - removes imported rows from journal table WINDOW - memorizes
java.lang.String	getTargetQuery() The query to retrieve changed data can references columns from journal table as named parameters:
void	publish(Data data) Publishes captured data (like writing a file or publishing to a kafka queue).

Method Detail

getJournalTable

java.lang.String getJournalTable()

Returns:

journal table's name

getBatchSize

int getBatchSize()

Returns:

number of rows to be imported for each execution

getTargetQuery

java.lang.String getTargetQuery()

The query to retrieve changed data can references columns from journal table as named parameters:

select * from mytable where pk = :pk

Returns:

data retrieval query

publish

void publish(Data data)
      throws PublishException

Publishes captured data (like writing a file or publishing to a kafka queue).

Parameters:

data - object Data for captured data

Throws:

PublishException - failed to publish retrieved data

getStrategy

JournalStrategy getStrategy()

Establish the journal strategy:

• DELETE - removes imported rows from journal table
• WINDOW - memorizes

Returns:

the handler's journal strategy