com.ververica.cdc.connectors.mysql.debezium.task.context

Class StatefulTaskContext

java.lang.Object

com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext

public class StatefulTaskContext
extends Object

A stateful task context that contains entries the debezium mysql connector task required.

The offset change and schema change should record to MySqlSplitState when emit the record, thus the Flink's state mechanism can help to store/restore when failover happens.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StatefulTaskContext.MySqlEventMetadataProvider Copied from debezium for accessing here.

Constructor Summary

Constructors

Constructor and Description
StatefulTaskContext(MySqlSourceConfig sourceConfig, com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient, io.debezium.connector.mysql.MySqlConnection connection)

Method Summary

Modifier and Type	Method and Description
void	configure(MySqlSplit mySqlSplit)
com.github.shyiko.mysql.binlog.BinaryLogClient	getBinaryLogClient()
static io.debezium.util.Clock	getClock()
io.debezium.connector.mysql.MySqlConnection	getConnection()
io.debezium.connector.mysql.MySqlConnectorConfig	getConnectorConfig()
io.debezium.connector.mysql.MySqlDatabaseSchema	getDatabaseSchema()
EventDispatcherImpl<io.debezium.relational.TableId>	getDispatcher()
io.debezium.pipeline.ErrorHandler	getErrorHandler()
io.debezium.connector.mysql.MySqlOffsetContext	getOffsetContext()
io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent>	getQueue()
io.debezium.util.SchemaNameAdjuster	getSchemaNameAdjuster()
io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics	getSnapshotChangeEventSourceMetrics()
MySqlSourceConfig	getSourceConfig()
io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics	getStreamingChangeEventSourceMetrics()
MySqlTaskContextImpl	getTaskContext()
io.debezium.schema.TopicSelector<io.debezium.relational.TableId>	getTopicSelector()

Methods inherited from class java.lang.Object

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

Constructor Detail

StatefulTaskContext

public StatefulTaskContext(MySqlSourceConfig sourceConfig,
                           com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient,
                           io.debezium.connector.mysql.MySqlConnection connection)

Method Detail

configure

public void configure(MySqlSplit mySqlSplit)

getClock

public static io.debezium.util.Clock getClock()

getSourceConfig

public MySqlSourceConfig getSourceConfig()

getConnectorConfig

public io.debezium.connector.mysql.MySqlConnectorConfig getConnectorConfig()

getConnection

public io.debezium.connector.mysql.MySqlConnection getConnection()

getBinaryLogClient

public com.github.shyiko.mysql.binlog.BinaryLogClient getBinaryLogClient()

getDatabaseSchema

public io.debezium.connector.mysql.MySqlDatabaseSchema getDatabaseSchema()

getTaskContext

public MySqlTaskContextImpl getTaskContext()

getDispatcher

public EventDispatcherImpl<io.debezium.relational.TableId> getDispatcher()

getQueue

public io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> getQueue()

getErrorHandler

public io.debezium.pipeline.ErrorHandler getErrorHandler()

getOffsetContext

public io.debezium.connector.mysql.MySqlOffsetContext getOffsetContext()

getTopicSelector

public io.debezium.schema.TopicSelector<io.debezium.relational.TableId> getTopicSelector()

getSnapshotChangeEventSourceMetrics

public io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics getSnapshotChangeEventSourceMetrics()

getStreamingChangeEventSourceMetrics

public io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics getStreamingChangeEventSourceMetrics()

getSchemaNameAdjuster

public io.debezium.util.SchemaNameAdjuster getSchemaNameAdjuster()