Package com.zendesk.maxwell.schema

Class ReadOnlyMysqlPositionStore

java.lang.Object

com.zendesk.maxwell.schema.MysqlPositionStore

com.zendesk.maxwell.schema.ReadOnlyMysqlPositionStore

public class ReadOnlyMysqlPositionStore
extends MysqlPositionStore

a schema position object that doesn't write its position out. useful for "replay" mode.

Constructor Summary

Constructors

Constructor	Description
ReadOnlyMysqlPositionStore(ConnectionPool pool, Long serverID, String clientID, boolean gtidMode)

Method Summary

Modifier and Type	Method	Description
long	heartbeat()
void	set(Position p)

Methods inherited from class com.zendesk.maxwell.schema.MysqlPositionStore

cleanupOldRecoveryInfos, formatRecoveryFailure, get, getAllRecoveryInfos, getAllRecoveryInfos, getLastHeartbeatSent, getLatestFromAnyClient, getRecoveryInfo, getRecoveryInfo, heartbeat, positionFromResultSet

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadOnlyMysqlPositionStore

public ReadOnlyMysqlPositionStore(ConnectionPool pool,
                                  Long serverID,
                                  String clientID,
                                  boolean gtidMode)

Method Detail

set

public void set(Position p)

Overrides:

set in class MysqlPositionStore

heartbeat

public long heartbeat()
               throws Exception

Overrides:

heartbeat in class MysqlPositionStore

Throws:

Exception