Uses of Class
org.apache.flink.cdc.debezium.internal.DebeziumOffset

Packages that use DebeziumOffset

Package	Description
org.apache.flink.cdc.debezium
org.apache.flink.cdc.debezium.internal

Uses of DebeziumOffset in org.apache.flink.cdc.debezium

Constructors in org.apache.flink.cdc.debezium with parameters of type DebeziumOffset

Constructor	Description
DebeziumSourceFunction(DebeziumDeserializationSchema<T> deserializer, Properties properties, DebeziumOffset specificOffset, Validator validator)

Uses of DebeziumOffset in org.apache.flink.cdc.debezium.internal

Methods in org.apache.flink.cdc.debezium.internal that return DebeziumOffset

Modifier and Type	Method	Description
DebeziumOffset	DebeziumOffsetSerializer.deserialize(byte[] bytes)

Methods in org.apache.flink.cdc.debezium.internal with parameters of type DebeziumOffset

Modifier and Type	Method	Description
void	DebeziumChangeConsumer.commitOffset(DebeziumOffset offset)
byte[]	DebeziumOffsetSerializer.serialize(DebeziumOffset debeziumOffset)