org.apache.paimon.flink.source

Class AppendTableCompactSource.CompactSourceReader

java.lang.Object

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

org.apache.paimon.flink.source.AppendTableCompactSource.CompactSourceReader

All Implemented Interfaces:

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

Enclosing class:

AppendTableCompactSource

public static class AppendTableCompactSource.CompactSourceReader
extends AbstractNonCoordinatedSourceReader<AppendCompactTask>

BucketUnawareCompactSourceReader.

Constructor Summary

Constructors

Constructor and Description
CompactSourceReader(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<AppendCompactTask> 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

CompactSourceReader

public CompactSourceReader(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<AppendCompactTask> readerOutput)
                                              throws Exception

Throws:

Exception