Package org.apache.flink.cdc.connectors.postgres.source.fetch

Class CDCPostgresDispatcher

java.lang.Object

io.debezium.pipeline.EventDispatcher<io.debezium.connector.postgresql.PostgresPartition,T>

io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId>

org.apache.flink.cdc.connectors.postgres.source.fetch.CDCPostgresDispatcher

All Implemented Interfaces:

AutoCloseable, WatermarkDispatcher, SchemaDispatcher

public class CDCPostgresDispatcher
extends io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId>
implements WatermarkDispatcher, SchemaDispatcher

Postgres Dispatcher for cdc source with watermark.

Nested Class Summary

Nested classes/interfaces inherited from class io.debezium.pipeline.EventDispatcher

io.debezium.pipeline.EventDispatcher.InconsistentSchemaHandler<P extends io.debezium.pipeline.spi.Partition,T extends io.debezium.schema.DataCollectionId>, io.debezium.pipeline.EventDispatcher.SnapshotReceiver<P extends io.debezium.pipeline.spi.Partition>

Constructor Summary

Constructors

Constructor

Description

CDCPostgresDispatcher(io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.schema.TopicSelector topicSelector, io.debezium.schema.DatabaseSchema schema, io.debezium.connector.base.ChangeEventQueue queue, io.debezium.schema.DataCollectionFilters.DataCollectionFilter filter, io.debezium.pipeline.spi.ChangeEventCreator changeEventCreator, io.debezium.pipeline.source.spi.EventMetadataProvider metadataProvider, io.debezium.heartbeat.HeartbeatFactory heartbeatFactory, io.debezium.util.SchemaNameAdjuster schemaNameAdjuster)

Method Summary

Modifier and Type	Method	Description
void	dispatch(io.debezium.relational.Table table)
void	dispatchWatermarkEvent(Map<String,?> sourcePartition, SourceSplitBase sourceSplit, Offset watermark, WatermarkKind watermarkKind)

Methods inherited from class io.debezium.connector.postgresql.PostgresEventDispatcher

dispatchLogicalDecodingMessage

Methods inherited from class io.debezium.pipeline.EventDispatcher

alwaysDispatchHeartbeatEvent, close, dispatchConnectorEvent, dispatchDataChangeEvent, dispatchFilteredEvent, dispatchHeartbeatEvent, dispatchSchemaChangeEvent, dispatchSchemaChangeEvent, dispatchServerHeartbeatEvent, dispatchSnapshotEvent, dispatchTransactionCommittedEvent, dispatchTransactionStartedEvent, errorOnMissingSchema, getHistorizedSchema, getIncrementalSnapshotChangeEventReceiver, getIncrementalSnapshotChangeEventSource, getSchema, getSnapshotChangeEventReceiver, heartbeatsEnabled, ignoreMissingSchema, setEventListener, setIncrementalSnapshotChangeEventSource

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CDCPostgresDispatcher

public CDCPostgresDispatcher(io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig,
                             io.debezium.schema.TopicSelector topicSelector,
                             io.debezium.schema.DatabaseSchema schema,
                             io.debezium.connector.base.ChangeEventQueue queue,
                             io.debezium.schema.DataCollectionFilters.DataCollectionFilter filter,
                             io.debezium.pipeline.spi.ChangeEventCreator changeEventCreator,
                             io.debezium.pipeline.source.spi.EventMetadataProvider metadataProvider,
                             io.debezium.heartbeat.HeartbeatFactory heartbeatFactory,
                             io.debezium.util.SchemaNameAdjuster schemaNameAdjuster)

Method Detail

dispatchWatermarkEvent

public void dispatchWatermarkEvent(Map<String,?> sourcePartition,
                                   SourceSplitBase sourceSplit,
                                   Offset watermark,
                                   WatermarkKind watermarkKind)
                            throws InterruptedException

Specified by:

dispatchWatermarkEvent in interface WatermarkDispatcher

Throws:

InterruptedException

dispatch

public void dispatch(io.debezium.relational.Table table)

Specified by:

dispatch in interface SchemaDispatcher