Uses of Interface
org.apache.flink.cdc.connectors.base.WatermarkDispatcher

Packages that use WatermarkDispatcher

Package	Description
org.apache.flink.cdc.connectors.base.relational
org.apache.flink.cdc.connectors.base.source.reader.external
org.apache.flink.cdc.connectors.db2.source.fetch
org.apache.flink.cdc.connectors.oracle.source.reader.fetch
org.apache.flink.cdc.connectors.postgres.source.fetch
org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch

Uses of WatermarkDispatcher in org.apache.flink.cdc.connectors.base.relational

Classes in org.apache.flink.cdc.connectors.base.relational that implement WatermarkDispatcher

Modifier and Type	Class	Description
class	JdbcSourceEventDispatcher<P extends io.debezium.pipeline.spi.Partition>	A subclass implementation of EventDispatcher.

Uses of WatermarkDispatcher in org.apache.flink.cdc.connectors.base.source.reader.external

Methods in org.apache.flink.cdc.connectors.base.source.reader.external that return WatermarkDispatcher

Modifier and Type	Method	Description
abstract WatermarkDispatcher	JdbcSourceFetchTaskContext.getWaterMarkDispatcher()

Uses of WatermarkDispatcher in org.apache.flink.cdc.connectors.db2.source.fetch

Methods in org.apache.flink.cdc.connectors.db2.source.fetch that return WatermarkDispatcher

Modifier and Type	Method	Description
WatermarkDispatcher	Db2SourceFetchTaskContext.getWaterMarkDispatcher()

Constructors in org.apache.flink.cdc.connectors.db2.source.fetch with parameters of type WatermarkDispatcher

Constructor

Description

StreamSplitReadTask(io.debezium.connector.db2.Db2ConnectorConfig connectorConfig, Db2Connection connection, Db2Connection metadataConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.db2.Db2Partition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.connector.db2.Db2DatabaseSchema schema, StreamSplit lsnSplit)

Uses of WatermarkDispatcher in org.apache.flink.cdc.connectors.oracle.source.reader.fetch

Methods in org.apache.flink.cdc.connectors.oracle.source.reader.fetch that return WatermarkDispatcher

Modifier and Type	Method	Description
WatermarkDispatcher	OracleSourceFetchTaskContext.getWaterMarkDispatcher()

Methods in org.apache.flink.cdc.connectors.oracle.source.reader.fetch with parameters of type WatermarkDispatcher

Modifier and Type	Method	Description
static io.debezium.connector.oracle.logminer.processor.LogMinerEventProcessor	EventProcessorFactory.createProcessor(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.connector.oracle.OracleConnection jdbcConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.oracle.OraclePartition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.connector.oracle.OraclePartition partition, io.debezium.connector.oracle.OracleOffsetContext offsetContext, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.connector.oracle.OracleStreamingChangeEventSourceMetrics metrics, io.debezium.pipeline.ErrorHandler errorHandler, StreamSplit redoLogSplit)
static boolean	EventProcessorFactory.reachEndingOffset(io.debezium.connector.oracle.OraclePartition partition, io.debezium.connector.oracle.logminer.events.LogMinerEventRow row, StreamSplit redoLogSplit, io.debezium.pipeline.ErrorHandler errorHandler, WatermarkDispatcher dispatcher, io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context)

Constructors in org.apache.flink.cdc.connectors.oracle.source.reader.fetch with parameters of type WatermarkDispatcher

Constructor	Description
CDCEmbeddedInfinispanLogMinerEventProcessor(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.connector.oracle.OracleConnection jdbcConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.oracle.OraclePartition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.connector.oracle.OraclePartition partition, io.debezium.connector.oracle.OracleOffsetContext offsetContext, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.connector.oracle.OracleStreamingChangeEventSourceMetrics metrics, io.debezium.pipeline.ErrorHandler errorHandler, StreamSplit redoLogSplit)
CDCMemoryLogMinerEventProcessor(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.connector.oracle.OracleConnection jdbcConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.oracle.OraclePartition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.connector.oracle.OraclePartition partition, io.debezium.connector.oracle.OracleOffsetContext offsetContext, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.connector.oracle.OracleStreamingChangeEventSourceMetrics metrics, io.debezium.pipeline.ErrorHandler errorHandler, StreamSplit redoLogSplit)
CDCRemoteInfinispanLogMinerEventProcessor(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.connector.oracle.OracleConnection jdbcConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.oracle.OraclePartition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.connector.oracle.OraclePartition partition, io.debezium.connector.oracle.OracleOffsetContext offsetContext, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.connector.oracle.OracleStreamingChangeEventSourceMetrics metrics, io.debezium.pipeline.ErrorHandler errorHandler, StreamSplit redoLogSplit)
RedoLogSplitReadTask(io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.connector.oracle.OracleConnection connection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.oracle.OraclePartition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.config.Configuration jdbcConfig, io.debezium.connector.oracle.OracleStreamingChangeEventSourceMetrics metrics, StreamSplit redoLogSplit)

Uses of WatermarkDispatcher in org.apache.flink.cdc.connectors.postgres.source.fetch

Classes in org.apache.flink.cdc.connectors.postgres.source.fetch that implement WatermarkDispatcher

Modifier and Type	Class	Description
class	CDCPostgresDispatcher	Postgres Dispatcher for cdc source with watermark.

Methods in org.apache.flink.cdc.connectors.postgres.source.fetch that return WatermarkDispatcher

Modifier and Type	Method	Description
WatermarkDispatcher	PostgresSourceFetchTaskContext.getWaterMarkDispatcher()

Constructors in org.apache.flink.cdc.connectors.postgres.source.fetch with parameters of type WatermarkDispatcher

Constructor

Description

StreamSplitReadTask(io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.connector.postgresql.spi.Snapshotter snapshotter, PostgresConnection connection, io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.postgresql.PostgresSchema schema, io.debezium.connector.postgresql.PostgresTaskContext taskContext, io.debezium.connector.postgresql.connection.ReplicationConnection replicationConnection, StreamSplit streamSplit)

Uses of WatermarkDispatcher in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch

Methods in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch that return WatermarkDispatcher

Modifier and Type	Method	Description
WatermarkDispatcher	SqlServerSourceFetchTaskContext.getWaterMarkDispatcher()

Constructors in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch with parameters of type WatermarkDispatcher

Constructor

Description

StreamSplitReadTask(io.debezium.connector.sqlserver.SqlServerConnectorConfig connectorConfig, io.debezium.connector.sqlserver.SqlServerConnection connection, io.debezium.connector.sqlserver.SqlServerConnection metadataConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.sqlserver.SqlServerPartition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.connector.sqlserver.SqlServerDatabaseSchema schema, StreamSplit lsnSplit)