org.apache.paimon.flink.source

Class FileStoreSourceSplitReader

java.lang.Object

org.apache.paimon.flink.source.FileStoreSourceSplitReader

All Implemented Interfaces:

org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>

public class FileStoreSourceSplitReader
extends Object
implements org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>

The SplitReader implementation for the file store source.

Constructor Summary

Constructors

Constructor and Description
FileStoreSourceSplitReader(TableRead tableRead, RecordLimiter limiter, FileStoreSourceReaderMetrics metrics)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>	fetch()
void	handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<FileStoreSourceSplit> splitsChange)
void	pauseOrResumeSplits(Collection<FileStoreSourceSplit> splitsToPause, Collection<FileStoreSourceSplit> splitsToResume) Do not annotate with @override here to maintain compatibility with Flink 1.7-.
void	wakeUp()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileStoreSourceSplitReader

public FileStoreSourceSplitReader(TableRead tableRead,
                                  @Nullable
                                  RecordLimiter limiter,
                                  FileStoreSourceReaderMetrics metrics)

Method Detail

fetch

public org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>> fetch()
                                                                                                                                                                                   throws IOException

Specified by:

fetch in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>

Throws:

IOException

handleSplitsChanges

public void handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<FileStoreSourceSplit> splitsChange)

Specified by:

handleSplitsChanges in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>

pauseOrResumeSplits

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

Do not annotate with @override here to maintain compatibility with Flink 1.7-.

Specified by:

pauseOrResumeSplits in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>

wakeUp

public void wakeUp()

Specified by:

wakeUp in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>

close

public void close()
           throws Exception

Specified by:

close in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>

Throws:

Exception