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

Class PostgresScanFetchTask

java.lang.Object

org.apache.flink.cdc.connectors.base.source.reader.external.AbstractScanFetchTask

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

All Implemented Interfaces:

FetchTask

public class PostgresScanFetchTask
extends AbstractScanFetchTask

A FetchTask implementation for Postgres to read snapshot split.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PostgresScanFetchTask.PostgresSnapshotSplitReadTask	A SnapshotChangeEventSource implementation for Postgres to read snapshot split.

Nested classes/interfaces inherited from interface org.apache.flink.cdc.connectors.base.source.reader.external.FetchTask

FetchTask.Context

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.base.source.reader.external.AbstractScanFetchTask

snapshotSplit, taskRunning

Constructor Summary

Constructors

Constructor	Description
PostgresScanFetchTask(SnapshotSplit split)

Method Summary

Modifier and Type	Method	Description
void	execute(FetchTask.Context context)	Execute current task.
protected void	executeBackfillTask(FetchTask.Context context, StreamSplit backfillStreamSplit)
protected void	executeDataSnapshot(FetchTask.Context context)

Methods inherited from class org.apache.flink.cdc.connectors.base.source.reader.external.AbstractScanFetchTask

close, createBackfillStreamSplit, dispatchEndWaterMarkEvent, dispatchHighWaterMarkEvent, dispatchLowWaterMarkEvent, getSplit, isRunning, setSnapshotPhaseHooks

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresScanFetchTask

public PostgresScanFetchTask(SnapshotSplit split)

Method Detail

execute

public void execute(FetchTask.Context context)
             throws Exception

Description copied from interface: FetchTask

Execute current task.

Specified by:

execute in interface FetchTask

Overrides:

execute in class AbstractScanFetchTask

Throws:

Exception

executeDataSnapshot

protected void executeDataSnapshot(FetchTask.Context context)
                            throws Exception

Specified by:

executeDataSnapshot in class AbstractScanFetchTask

Throws:

Exception

executeBackfillTask

protected void executeBackfillTask(FetchTask.Context context,
                                   StreamSplit backfillStreamSplit)
                            throws Exception

Specified by:

executeBackfillTask in class AbstractScanFetchTask

Throws:

Exception