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

Class PostgresStreamFetchTask.StreamSplitReadTask

java.lang.Object

io.debezium.connector.postgresql.PostgresStreamingChangeEventSource

org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresStreamFetchTask.StreamSplitReadTask

All Implemented Interfaces:

io.debezium.pipeline.source.spi.ChangeEventSource, io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

Enclosing class:

PostgresStreamFetchTask

public static class PostgresStreamFetchTask.StreamSplitReadTask
extends PostgresStreamingChangeEventSource

A ChangeEventSource implementation for Postgres to read streaming changes.

Nested Class Summary

Nested classes/interfaces inherited from class io.debezium.connector.postgresql.PostgresStreamingChangeEventSource

PostgresStreamingChangeEventSource.PgConnectionSupplier

Nested classes/interfaces inherited from interface io.debezium.pipeline.source.spi.ChangeEventSource

io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext

Field Summary

Fields

Modifier and Type	Field	Description
io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext	context
io.debezium.connector.postgresql.PostgresOffsetContext	offsetContext

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method	Description
void	execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.postgresql.PostgresPartition partition, io.debezium.connector.postgresql.PostgresOffsetContext offsetContext)

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

commitOffset, init

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.source.spi.StreamingChangeEventSource

executeIteration

Field Detail

context

public io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context

offsetContext

public io.debezium.connector.postgresql.PostgresOffsetContext offsetContext

Constructor Detail

StreamSplitReadTask

public 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)

Method Detail

execute

public void execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
                    io.debezium.connector.postgresql.PostgresPartition partition,
                    io.debezium.connector.postgresql.PostgresOffsetContext offsetContext)
             throws InterruptedException

Specified by:

execute in interface io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

Overrides:

execute in class PostgresStreamingChangeEventSource

Throws:

InterruptedException