org.apache.flink.connector.base.source.reader.fetcher

Class SplitFetcher<E,SplitT extends SourceSplit>

java.lang.Object

org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher<E,SplitT>

All Implemented Interfaces:

Runnable

@Internal
public class SplitFetcher<E,SplitT extends SourceSplit>
extends Object
implements Runnable

The internal fetcher runnable responsible for polling message from the external system.

Method Summary

Modifier and Type	Method and Description
void	addSplits(List<SplitT> splitsToAdd) Add splits to the split fetcher.
void	enqueueTask(SplitFetcherTask task)
int	fetcherId()
SplitReader<E,SplitT>	getSplitReader()
void	pause()
void	pauseOrResumeSplits(Collection<SplitT> splitsToPause, Collection<SplitT> splitsToResume) Called when some splits of this source instance progressed too much beyond the global watermark of all subtasks.
void	resume()
void	run()
void	shutdown() Shutdown the split fetcher.

Methods inherited from class java.lang.Object

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

Method Detail

run

public void run()

Specified by:

run in interface Runnable

addSplits

public void addSplits(List<SplitT> splitsToAdd)

Add splits to the split fetcher. This operation is asynchronous.

Parameters:

splitsToAdd - the splits to add.

pauseOrResumeSplits

public void pauseOrResumeSplits(Collection<SplitT> splitsToPause,
                                Collection<SplitT> splitsToResume)

Called when some splits of this source instance progressed too much beyond the global watermark of all subtasks. If the split reader implements SplitReader, it will relay the information asynchronously through the split fetcher thread.

Parameters:

splitsToPause - the splits to pause

splitsToResume - the splits to resume

enqueueTask

public void enqueueTask(SplitFetcherTask task)

getSplitReader

public SplitReader<E,SplitT> getSplitReader()

fetcherId

public int fetcherId()

shutdown

public void shutdown()

Shutdown the split fetcher.

pause

public void pause()

resume

public void resume()