com.dsf.dbxtract.cdc.journal

Class JournalExecutor

java.lang.Object

com.dsf.dbxtract.cdc.journal.JournalExecutor

All Implemented Interfaces:

java.lang.Runnable

public class JournalExecutor
extends java.lang.Object
implements java.lang.Runnable

This class is specialized on journal-based change-data-capture.

Author:

fabio de santi

Constructor Summary

Constructors

Constructor and Description
JournalExecutor(java.lang.String agentName, java.lang.String zookeeper, JournalHandler handler, Source source)

Method Summary

Modifier and Type	Method and Description
void	run() Gets from journal table any update, executes the query to retrieve data, publishes to somewhere and removes imported data from journal.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JournalExecutor

public JournalExecutor(java.lang.String agentName,
                       java.lang.String zookeeper,
                       JournalHandler handler,
                       Source source)

Parameters:

agentName - cdc agent's assigned name

zookeeper - connection string to ZooKeeper server

handler - JournalHandler

source - Source

Method Detail

run

public void run()

Gets from journal table any update, executes the query to retrieve data, publishes to somewhere and removes imported data from journal. This routine is controlled by ZooKeeper that ensures only one node will try to import a specific table's data at time.

Specified by:

run in interface java.lang.Runnable