Package com.illumon.iris.replication.mssql

Class CDCTableReplicator

java.lang.Object

com.illumon.iris.replication.mssql.CDCTableReplicator

public class CDCTableReplicator
extends Object

Contains all the stuff needed to log changes from a single CDC table/"capture instance" to an Illumon table. Given an Iris table name and metadata, it dynamically finds the Illumon logger and initializes it.

Constructor Summary

Constructors

Constructor	Description
CDCTableReplicator(String connectionUrl, CDCReplicatorConfiguration.CDCTableConfiguration cfg, com.fishlib.io.logger.Logger log)

Method Summary

Modifier and Type	Method	Description
void	close()
String	getCaptureInstance()
int	getErrorCount()
boolean	isClosed()
void	replicateChanges()

Methods inherited from class java.lang.Object

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

Constructor Details

CDCTableReplicator

public CDCTableReplicator(String connectionUrl, CDCReplicatorConfiguration.CDCTableConfiguration cfg, com.fishlib.io.logger.Logger log) throws Exception

Throws:

Exception

Method Details

replicateChanges

public void replicateChanges()

getErrorCount

public int getErrorCount()

isClosed

public boolean isClosed()

getCaptureInstance

public String getCaptureInstance()

close

public void close() throws IOException

Throws:

IOException