org.apache.paimon.flink.source

Class BucketUnawareCompactSource.BucketUnawareCompactSourceReader

java.lang.Object

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

org.apache.paimon.flink.source.BucketUnawareCompactSource.BucketUnawareCompactSourceReader

All Implemented Interfaces:

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

Enclosing class:

BucketUnawareCompactSource

public static class BucketUnawareCompactSource.BucketUnawareCompactSourceReader
extends AbstractNonCoordinatedSourceReader<UnawareAppendCompactionTask>

BucketUnawareCompactSourceReader.

Constructor Summary

Constructors

Constructor and Description
BucketUnawareCompactSourceReader(FileStoreTable table, boolean streaming, Predicate filter, long scanInterval)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.core.io.InputStatus	pollNext(org.apache.flink.api.connector.source.ReaderOutput<UnawareAppendCompactionTask> readerOutput)

Methods inherited from class org.apache.paimon.flink.source.AbstractNonCoordinatedSourceReader

addSplits, close, isAvailable, notifyNoMoreSplits, snapshotState, 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

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

notifyCheckpointAborted

Constructor Detail

BucketUnawareCompactSourceReader

public BucketUnawareCompactSourceReader(FileStoreTable table,
                                        boolean streaming,
                                        Predicate filter,
                                        long scanInterval)

Method Detail

pollNext

public org.apache.flink.core.io.InputStatus pollNext(org.apache.flink.api.connector.source.ReaderOutput<UnawareAppendCompactionTask> readerOutput)
                                              throws Exception

Throws:

Exception