Uses of Package
org.apache.flink.cdc.debezium.internal
-
Packages that use org.apache.flink.cdc.debezium.internal Package Description org.apache.flink.cdc.debezium org.apache.flink.cdc.debezium.internal org.apache.flink.cdc.debezium.utils -
Classes in org.apache.flink.cdc.debezium.internal used by org.apache.flink.cdc.debezium Class Description DebeziumOffset The state that the Flink Debezium Consumer holds for each instance.Handover The Handover is a utility to hand over data (a buffer of records) and exception from a producer thread to a consumer thread. -
Classes in org.apache.flink.cdc.debezium.internal used by org.apache.flink.cdc.debezium.internal Class Description DebeziumOffset The state that the Flink Debezium Consumer holds for each instance.DebeziumOffsetSerializer Serializer implementation for aDebeziumOffset.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 oneHistoryRecordorTableChanges.TableChange. -
Classes in org.apache.flink.cdc.debezium.internal used by org.apache.flink.cdc.debezium.utils Class Description SchemaRecord The Record represents a schema change event, it contains either oneHistoryRecordorTableChanges.TableChange.