Uses of Class
org.apache.flink.cdc.debezium.internal.Handover
-
Packages that use Handover Package Description org.apache.flink.cdc.debezium org.apache.flink.cdc.debezium.internal -
-
Uses of Handover in org.apache.flink.cdc.debezium
Methods in org.apache.flink.cdc.debezium that return Handover Modifier and Type Method Description HandoverDebeziumSourceFunction. getHandover() -
Uses of Handover in org.apache.flink.cdc.debezium.internal
Constructors in org.apache.flink.cdc.debezium.internal with parameters of type Handover Constructor Description DebeziumChangeConsumer(Handover handover)DebeziumChangeFetcher(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T> sourceContext, DebeziumDeserializationSchema<T> deserialization, boolean isInDbSnapshotPhase, String heartbeatTopicPrefix, Handover handover)
-