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

Class PostgresScanFetchTask.PostgresSnapshotSplitReadTask

java.lang.Object

io.debezium.pipeline.source.AbstractSnapshotChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresScanFetchTask.PostgresSnapshotSplitReadTask

All Implemented Interfaces:

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

Enclosing class:

PostgresScanFetchTask

public static class PostgresScanFetchTask.PostgresSnapshotSplitReadTask
extends io.debezium.pipeline.source.AbstractSnapshotChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

A SnapshotChangeEventSource implementation for Postgres to read snapshot split.

Nested Class Summary

Nested classes/interfaces inherited from class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext<P extends io.debezium.pipeline.spi.Partition,O extends io.debezium.pipeline.spi.OffsetContext>, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask

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

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

Field Summary

Fields inherited from class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

LOG_INTERVAL

Constructor Summary

Constructors

Constructor

Description

PostgresSnapshotSplitReadTask(PostgresSourceConfig sourceConfig, PostgresConnection jdbcConnection, io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.connector.postgresql.PostgresSchema databaseSchema, io.debezium.connector.postgresql.PostgresOffsetContext previousOffset, io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> eventDispatcher, io.debezium.pipeline.source.spi.SnapshotProgressListener snapshotProgressListener, SnapshotSplit snapshotSplit)

Method Summary

Modifier and Type	Method	Description
protected io.debezium.pipeline.spi.SnapshotResult<io.debezium.connector.postgresql.PostgresOffsetContext>	doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.postgresql.PostgresOffsetContext previousOffset, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext> snapshotContext, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)
protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask	getSnapshottingTask(io.debezium.connector.postgresql.PostgresPartition partition, io.debezium.connector.postgresql.PostgresOffsetContext previousOffset)
protected org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresScanFetchTask.PostgresSnapshotSplitReadTask.PostgresSnapshotContext	prepare(io.debezium.connector.postgresql.PostgresPartition partition)

Methods inherited from class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

complete, delaySnapshotIfNeeded, determineDataCollectionsToBeSnapshotted, execute

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresSnapshotSplitReadTask

public PostgresSnapshotSplitReadTask(PostgresSourceConfig sourceConfig,
                                     PostgresConnection jdbcConnection,
                                     io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig,
                                     io.debezium.connector.postgresql.PostgresSchema databaseSchema,
                                     io.debezium.connector.postgresql.PostgresOffsetContext previousOffset,
                                     io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> eventDispatcher,
                                     io.debezium.pipeline.source.spi.SnapshotProgressListener snapshotProgressListener,
                                     SnapshotSplit snapshotSplit)

Method Detail

doExecute

protected io.debezium.pipeline.spi.SnapshotResult<io.debezium.connector.postgresql.PostgresOffsetContext> doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
                                                                                                                    io.debezium.connector.postgresql.PostgresOffsetContext previousOffset,
                                                                                                                    io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext> snapshotContext,
                                                                                                                    io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)
                                                                                                             throws Exception

Specified by:

doExecute in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

Throws:

Exception

getSnapshottingTask

protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask getSnapshottingTask(io.debezium.connector.postgresql.PostgresPartition partition,
                                                                                                             io.debezium.connector.postgresql.PostgresOffsetContext previousOffset)

Specified by:

getSnapshottingTask in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

prepare

protected org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresScanFetchTask.PostgresSnapshotSplitReadTask.PostgresSnapshotContext prepare(io.debezium.connector.postgresql.PostgresPartition partition)
                                                                                                                                             throws Exception

Specified by:

prepare in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

Throws:

Exception