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

Class Db2ScanFetchTask

java.lang.Object

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

org.apache.flink.cdc.connectors.db2.source.fetch.Db2ScanFetchTask

All Implemented Interfaces:

FetchTask

public class Db2ScanFetchTask
extends AbstractScanFetchTask

The task to work for fetching data of Db2 table snapshot split.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Db2ScanFetchTask.Db2SnapshotSplitChangeEventSourceContext	The ChangeEventSource.ChangeEventSourceContext implementation for bounded stream task of a snapshot split task.
static class	Db2ScanFetchTask.Db2SnapshotSplitReadTask	A wrapped task to fetch snapshot split of table.

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
Db2ScanFetchTask(SnapshotSplit split)

Method Summary

Modifier and Type	Method	Description
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, execute, getSplit, isRunning, setSnapshotPhaseHooks

Methods inherited from class java.lang.Object

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

Constructor Detail

Db2ScanFetchTask

public Db2ScanFetchTask(SnapshotSplit split)

Method Detail

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