Uses of Class
com.zendesk.maxwell.replication.Position

Packages that use Position

Package	Description
com.zendesk.maxwell	top level classes concerned with instantiating and running a Maxwell replicator.
com.zendesk.maxwell.producer	producers write to streams and sinks of various types.
com.zendesk.maxwell.recovery	allows users to continue a stream after changing masters
com.zendesk.maxwell.replication	concerns the operation of the binlog replicator
com.zendesk.maxwell.row	Maxwell's representation of a row from the binlog
com.zendesk.maxwell.schema	stores and updates (via SQL parsing) a view of the mysql schema
com.zendesk.maxwell.schema.ddl	the mysql DDL schema parser lives here.

Uses of Position in com.zendesk.maxwell

Fields in com.zendesk.maxwell declared as Position

Modifier and Type	Field	Description
Position	MaxwellConfig.initPosition	Override Maxwell's stored starting position

Methods in com.zendesk.maxwell that return Position

Modifier and Type	Method	Description
protected Position	Maxwell.getInitialPosition()	Determines initial replication position Retrieve stored position from `maxwell`.`positons` Attempt master recovery Use previous client_id's position.
Position	MaxwellContext.getInitialPosition()	Retrieve Maxwell's starting position from the metadata database
Position	MaxwellContext.getOtherClientPosition()	Finds the most recent position any client has reached on the server
Position	MaxwellContext.getPosition()	Get the last stored binlog position

Methods in com.zendesk.maxwell with parameters of type Position

Modifier and Type	Method	Description
void	MaxwellContext.setPosition(Position position)	Set Maxwell's next binlog position

Uses of Position in com.zendesk.maxwell.producer

Methods in com.zendesk.maxwell.producer with parameters of type Position

Modifier and Type	Method	Description
void	InflightMessageList.addMessage(Position p, long eventTimestampMillis, long messageID)
com.zendesk.maxwell.producer.InflightMessageList.InflightMessage	InflightMessageList.completeMessage(Position p)

Constructors in com.zendesk.maxwell.producer with parameters of type Position

Constructor	Description
CallbackCompleter(InflightMessageList inflightMessages, Position position, boolean isTXCommit, MaxwellContext context, long messageID)

Uses of Position in com.zendesk.maxwell.recovery

Fields in com.zendesk.maxwell.recovery declared as Position

Modifier and Type	Field	Description
Position	RecoveryInfo.position

Methods in com.zendesk.maxwell.recovery with parameters of type Position

Modifier and Type	Method	Description
List<ResolvedSchemaChange>	RecoverySchemaStore.processSQL(String sql, String currentDatabase, Position position)

Constructors in com.zendesk.maxwell.recovery with parameters of type Position

Constructor	Description
RecoveryInfo(Position position, Long serverID, String clientID)

Uses of Position in com.zendesk.maxwell.replication

Methods in com.zendesk.maxwell.replication that return Position

Modifier and Type	Method	Description
Position	Position.addGtid(String gtid, long offset, String file)
static Position	Position.capture(Connection c, boolean gtidMode)
static Position	Position.valueOf(BinlogPosition binlogPosition, Long lastHeartbeatRead)
Position	Position.withHeartbeat(long lastHeartbeatRead)

Methods in com.zendesk.maxwell.replication with parameters of type Position

Modifier and Type	Method	Description
boolean	Position.newerThan(Position other)

Constructors in com.zendesk.maxwell.replication with parameters of type Position

Constructor	Description
BinlogConnectorReplicator(SchemaStore schemaStore, AbstractProducer producer, BootstrapController bootstrapper, MaxwellMysqlConfig mysqlConfig, Long replicaServerID, String maxwellSchemaDatabaseName, Metrics metrics, Position start, boolean stopOnEOF, String clientID, HeartbeatNotifier heartbeatNotifier, Scripting scripting, Filter filter, boolean ignoreMissingSchema, MaxwellOutputConfig outputConfig, float bufferMemoryUsage, int replicationReconnectionRetries, int binlogEventQueueSize)
BinlogConnectorReplicator(SchemaStore schemaStore, AbstractProducer producer, BootstrapController bootstrapper, MaxwellMysqlConfig mysqlConfig, Long replicaServerID, String maxwellSchemaDatabaseName, Metrics metrics, Position start, boolean stopOnEOF, String clientID, HeartbeatNotifier heartbeatNotifier, Scripting scripting, Filter filter, MaxwellOutputConfig outputConfig, float bufferMemoryUsage, int replicationReconnectionRetries)

Uses of Position in com.zendesk.maxwell.row

Methods in com.zendesk.maxwell.row that return Position

Modifier and Type	Method	Description
Position	RowMap.getNextPosition()
Position	RowMap.getPosition()

Methods in com.zendesk.maxwell.row with parameters of type Position

Modifier and Type	Method	Description
static HeartbeatRowMap	HeartbeatRowMap.valueOf(String database, Position position, Position nextPosition)

Constructors in com.zendesk.maxwell.row with parameters of type Position

Constructor	Description
HeartbeatRowMap(String database, Position position, Position nextPosition)
RowMap(String type, String database, String table, Long timestampMillis, List<String> pkColumns, Position nextPosition)
RowMap(String type, String database, String table, Long timestampMillis, List<String> pkColumns, Position position, Position nextPosition, String rowQuery)
RowMap(String type, String database, String table, Long timestampMillis, List<String> pkColumns, Position nextPosition, String rowQuery)

Uses of Position in com.zendesk.maxwell.schema

Methods in com.zendesk.maxwell.schema that return Position

Modifier and Type	Method	Description
Position	MysqlPositionStore.get()
Position	MysqlPositionStore.getLatestFromAnyClient()
Position	MysqlSavedSchema.getPosition()
Position	PositionStoreThread.getPosition()
static Position	MysqlPositionStore.positionFromResultSet(ResultSet rs, boolean gtidMode)

Methods in com.zendesk.maxwell.schema with parameters of type Position

Modifier and Type	Method	Description
void	MysqlSchemaStore.clone(Long serverID, Position position)
MysqlSavedSchema	MysqlSavedSchema.createDerivedSchema(Schema newSchema, Position position, List<ResolvedSchemaChange> deltas)
static String	MysqlSavedSchema.getSchemaPositionSHA(Long serverID, Position position)
List<ResolvedSchemaChange>	MysqlSchemaStore.processSQL(String sql, String currentDatabase, Position position)
List<ResolvedSchemaChange>	SchemaStore.processSQL(String sql, String currentDatabase, Position position)	Process a DDL statement Parse the given SQL, applying the changes to the schema.
static MysqlSavedSchema	MysqlSavedSchema.restore(MaxwellContext context, Position targetPosition)
static MysqlSavedSchema	MysqlSavedSchema.restore(ConnectionPool pool, Long serverID, CaseSensitivity caseSensitivity, Position targetPosition)
void	MysqlPositionStore.set(Position newPosition)
void	ReadOnlyMysqlPositionStore.set(Position p)
void	PositionStoreThread.setPosition(Position p)

Constructors in com.zendesk.maxwell.schema with parameters of type Position

Constructor	Description
MysqlSavedSchema(MaxwellContext context, Schema schema, Position position)
MysqlSavedSchema(Long serverID, CaseSensitivity sensitivity, Schema schema, Position position)
MysqlSavedSchema(Long serverID, CaseSensitivity sensitivity, Schema schema, Position position, long baseSchemaID, List<ResolvedSchemaChange> deltas)
MysqlSchemaStore(MaxwellContext context, Position initialPosition)
MysqlSchemaStore(ConnectionPool maxwellConnectionPool, ConnectionPool replicationConnectionPool, ConnectionPool schemaConnectionPool, Long serverID, Position initialPosition, CaseSensitivity caseSensitivity, Filter filter, boolean readOnly)

Uses of Position in com.zendesk.maxwell.schema.ddl

Constructors in com.zendesk.maxwell.schema.ddl with parameters of type Position

Constructor	Description
DDLMap(ResolvedSchemaChange change, Long timestamp, String sql, Position position, Position nextPosition, Long schemaId)