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

Class Db2StreamFetchTask

java.lang.Object

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

All Implemented Interfaces:

FetchTask<SourceSplitBase>

public class Db2StreamFetchTask
extends Object
implements FetchTask<SourceSplitBase>

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Db2StreamFetchTask.StreamSplitReadTask	A wrapped task to read all redo logs for table and also supports read bounded (from lowWatermark to highWatermark) redo logs.

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

FetchTask.Context

Constructor Summary

Constructors

Constructor	Description
Db2StreamFetchTask(StreamSplit split)

Method Summary

Modifier and Type	Method	Description
void	close()	Close current task.
void	execute(FetchTask.Context context)	Execute current task.
StreamSplit	getSplit()	Returns the split that the task used.
boolean	isRunning()	Returns current task is running or not.

Methods inherited from class java.lang.Object

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

Constructor Detail

Db2StreamFetchTask

public Db2StreamFetchTask(StreamSplit 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<SourceSplitBase>

Throws:

Exception

isRunning

public boolean isRunning()

Description copied from interface: FetchTask

Returns current task is running or not.

Specified by:

isRunning in interface FetchTask<SourceSplitBase>

getSplit

public StreamSplit getSplit()

Description copied from interface: FetchTask

Returns the split that the task used.

Specified by:

getSplit in interface FetchTask<SourceSplitBase>

close

public void close()

Description copied from interface: FetchTask

Close current task. *

Specified by:

close in interface FetchTask<SourceSplitBase>