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

Class PostgresStreamFetchTask

java.lang.Object

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

All Implemented Interfaces:

FetchTask<SourceSplitBase>

public class PostgresStreamFetchTask
extends Object
implements FetchTask<SourceSplitBase>

A FetchTask implementation for Postgres to read streaming changes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PostgresStreamFetchTask.StreamSplitReadTask	A ChangeEventSource implementation for Postgres to read streaming changes.

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

FetchTask.Context

Constructor Summary

Constructors

Constructor	Description
PostgresStreamFetchTask(StreamSplit streamSplit)

Method Summary

Modifier and Type	Method	Description
void	close()	Close current task.
void	commitCurrentOffset(Offset offsetToCommit)
void	execute(FetchTask.Context context)	Execute current task.
SourceSplitBase	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

PostgresStreamFetchTask

public PostgresStreamFetchTask(StreamSplit streamSplit)

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

close

public void close()

Description copied from interface: FetchTask

Close current task. *

Specified by:

close in interface FetchTask<SourceSplitBase>

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 SourceSplitBase getSplit()

Description copied from interface: FetchTask

Returns the split that the task used.

Specified by:

getSplit in interface FetchTask<SourceSplitBase>

commitCurrentOffset

public void commitCurrentOffset(@Nullable
                                Offset offsetToCommit)