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

Class Summary

Class	Description
DebeziumChangeConsumer	Consume debezium change events.
DebeziumChangeFetcher<T>	A Handler that convert change messages from DebeziumEngine to data in Flink.
DebeziumOffset	The state that the Flink Debezium Consumer holds for each instance.
DebeziumOffsetSerializer	Serializer implementation for a DebeziumOffset.
FlinkDatabaseHistory	Inspired from MemoryDatabaseHistory but we will store the HistoryRecords in Flink's state for persistence.
FlinkDatabaseSchemaHistory	The FlinkDatabaseSchemaHistory only stores the latest schema of the monitored tables.
FlinkOffsetBackingStore	A implementation of OffsetBackingStore backed on Flink's state mechanism.
Handover	The Handover is a utility to hand over data (a buffer of records) and exception from a producer thread to a consumer thread.
SchemaRecord	The Record represents a schema change event, it contains either one HistoryRecord or TableChanges.TableChange.

Exception Summary

Exception	Description
Handover.ClosedException	An exception thrown by the Handover in the Handover.pollNext() or Handover.produce(List) method, after the Handover was closed via Handover.close().