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

Class StatefulTaskContext.MySqlEventMetadataProvider

java.lang.Object

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

All Implemented Interfaces:

io.debezium.pipeline.source.spi.EventMetadataProvider

Enclosing class:

StatefulTaskContext

public static class StatefulTaskContext.MySqlEventMetadataProvider
extends Object
implements io.debezium.pipeline.source.spi.EventMetadataProvider

Copied from debezium for accessing here.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BINLOG_FILENAME_OFFSET_KEY
static String	BINLOG_POSITION_OFFSET_KEY
static String	BINLOG_ROW_IN_EVENT_OFFSET_KEY
static String	GTID_KEY
static String	QUERY_KEY
static String	SERVER_ID_KEY
static String	THREAD_KEY

Constructor Summary

Constructors

Constructor and Description
MySqlEventMetadataProvider()

Method Summary

Modifier and Type	Method and Description
Map<String,String>	getEventSourcePosition(io.debezium.schema.DataCollectionId source, io.debezium.pipeline.spi.OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)
java.time.Instant	getEventTimestamp(io.debezium.schema.DataCollectionId source, io.debezium.pipeline.spi.OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)
String	getTransactionId(io.debezium.schema.DataCollectionId source, io.debezium.pipeline.spi.OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.source.spi.EventMetadataProvider

toSummaryString

Field Detail

SERVER_ID_KEY

public static final String SERVER_ID_KEY

See Also:

Constant Field Values

GTID_KEY

public static final String GTID_KEY

See Also:

Constant Field Values

BINLOG_FILENAME_OFFSET_KEY

public static final String BINLOG_FILENAME_OFFSET_KEY

See Also:

Constant Field Values

BINLOG_POSITION_OFFSET_KEY

public static final String BINLOG_POSITION_OFFSET_KEY

See Also:

Constant Field Values

BINLOG_ROW_IN_EVENT_OFFSET_KEY

public static final String BINLOG_ROW_IN_EVENT_OFFSET_KEY

See Also:

Constant Field Values

THREAD_KEY

public static final String THREAD_KEY

See Also:

Constant Field Values

QUERY_KEY

public static final String QUERY_KEY

See Also:

Constant Field Values

Constructor Detail

MySqlEventMetadataProvider

public MySqlEventMetadataProvider()

Method Detail

getEventTimestamp

public java.time.Instant getEventTimestamp(io.debezium.schema.DataCollectionId source,
                                           io.debezium.pipeline.spi.OffsetContext offset,
                                           Object key,
                                           org.apache.kafka.connect.data.Struct value)

Specified by:

getEventTimestamp in interface io.debezium.pipeline.source.spi.EventMetadataProvider

getEventSourcePosition

public Map<String,String> getEventSourcePosition(io.debezium.schema.DataCollectionId source,
                                                 io.debezium.pipeline.spi.OffsetContext offset,
                                                 Object key,
                                                 org.apache.kafka.connect.data.Struct value)

Specified by:

getEventSourcePosition in interface io.debezium.pipeline.source.spi.EventMetadataProvider

getTransactionId

public String getTransactionId(io.debezium.schema.DataCollectionId source,
                               io.debezium.pipeline.spi.OffsetContext offset,
                               Object key,
                               org.apache.kafka.connect.data.Struct value)

Specified by:

getTransactionId in interface io.debezium.pipeline.source.spi.EventMetadataProvider