org.apache.paimon.flink.source

Class AbstractNonCoordinatedSourceReader<T>

java.lang.Object

org.apache.paimon.flink.source.AbstractNonCoordinatedSourceReader<T>

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SourceReader<T,SimpleSourceSplit>

Direct Known Subclasses:

BucketUnawareCompactSource.BucketUnawareCompactSourceReader

public abstract class AbstractNonCoordinatedSourceReader<T>
extends Object
implements org.apache.flink.api.connector.source.SourceReader<T,SimpleSourceSplit>

Abstract SourceReader for AbstractNonCoordinatedSource.

Constructor Summary

Constructors

Constructor and Description
AbstractNonCoordinatedSourceReader()

Method Summary

Modifier and Type	Method and Description
void	addSplits(List<SimpleSourceSplit> list)
void	close()
CompletableFuture<Void>	isAvailable()
void	notifyNoMoreSplits()
List<SimpleSourceSplit>	snapshotState(long l)
void	start()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.connector.source.SourceReader

handleSourceEvents, notifyCheckpointComplete, pauseOrResumeSplits, pollNext

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Constructor Detail

AbstractNonCoordinatedSourceReader

public AbstractNonCoordinatedSourceReader()

Method Detail

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SourceReader<T,SimpleSourceSplit>

snapshotState

public List<SimpleSourceSplit> snapshotState(long l)

Specified by:

snapshotState in interface org.apache.flink.api.connector.source.SourceReader<T,SimpleSourceSplit>

isAvailable

public CompletableFuture<Void> isAvailable()

Specified by:

isAvailable in interface org.apache.flink.api.connector.source.SourceReader<T,SimpleSourceSplit>

addSplits

public void addSplits(List<SimpleSourceSplit> list)

Specified by:

addSplits in interface org.apache.flink.api.connector.source.SourceReader<T,SimpleSourceSplit>

notifyNoMoreSplits

public void notifyNoMoreSplits()

Specified by:

notifyNoMoreSplits in interface org.apache.flink.api.connector.source.SourceReader<T,SimpleSourceSplit>

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception