com.ververica.cdc.connectors.mysql

Class SeekBinlogToTimestampFilter<T>

java.lang.Object

com.ververica.cdc.connectors.mysql.SeekBinlogToTimestampFilter<T>

All Implemented Interfaces:

com.ververica.cdc.debezium.DebeziumDeserializationSchema<T>, Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>

public class SeekBinlogToTimestampFilter<T>
extends Object
implements com.ververica.cdc.debezium.DebeziumDeserializationSchema<T>

A DebeziumDeserializationSchema which wraps a real DebeziumDeserializationSchema to seek binlog to the specific timestamp.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
SeekBinlogToTimestampFilter(long startupTimestampMillis, com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> serializer)

Method Summary

Modifier and Type	Method and Description
void	deserialize(org.apache.kafka.connect.source.SourceRecord record, org.apache.flink.util.Collector<T> out)
org.apache.flink.api.common.typeinfo.TypeInformation<T>	getProducedType()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

SeekBinlogToTimestampFilter

public SeekBinlogToTimestampFilter(long startupTimestampMillis,
                                   com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> serializer)

Method Detail

deserialize

public void deserialize(org.apache.kafka.connect.source.SourceRecord record,
                        org.apache.flink.util.Collector<T> out)
                 throws Exception

Specified by:

deserialize in interface com.ververica.cdc.debezium.DebeziumDeserializationSchema<T>

Throws:

Exception

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<T> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>