Package com.zendesk.maxwell.replication
Interface Replicator
-
- All Superinterfaces:
StoppableTask
- All Known Implementing Classes:
BinlogConnectorReplicator
public interface Replicator extends StoppableTask
Created by ben on 10/23/16.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Long
getLastHeartbeatRead()
RowMap
getRow()
Schema
getSchema()
Long
getSchemaId()
void
runLoop()
void
startReplicator()
void
stopAtHeartbeat(long heartbeat)
-
Methods inherited from interface com.zendesk.maxwell.util.StoppableTask
awaitStop, requestStop
-
-
-
-
Method Detail
-
getLastHeartbeatRead
Long getLastHeartbeatRead()
-
getSchema
Schema getSchema() throws SchemaStoreException
- Throws:
SchemaStoreException
-
getSchemaId
Long getSchemaId() throws SchemaStoreException
- Throws:
SchemaStoreException
-
stopAtHeartbeat
void stopAtHeartbeat(long heartbeat)
-
-