public final class FileStoreSourceReader extends org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,org.apache.flink.table.data.RowData,FileStoreSourceSplit,FileStoreSourceSplitState>
SourceReader
that read records from FileStoreSourceSplit
.Constructor and Description |
---|
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext,
TableRead tableRead,
Long limit) |
Modifier and Type | Method and Description |
---|---|
protected FileStoreSourceSplitState |
initializedState(FileStoreSourceSplit split) |
protected void |
onSplitFinished(Map<String,FileStoreSourceSplitState> finishedSplitIds) |
void |
start() |
protected FileStoreSourceSplit |
toSplitType(String splitId,
FileStoreSourceSplitState splitState) |
addSplits, close, getNumberOfCurrentlyAssignedSplits, handleSourceEvents, isAvailable, notifyNoMoreSplits, pollNext, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public void start()
start
in interface org.apache.flink.api.connector.source.SourceReader<org.apache.flink.table.data.RowData,FileStoreSourceSplit>
start
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,org.apache.flink.table.data.RowData,FileStoreSourceSplit,FileStoreSourceSplitState>
protected void onSplitFinished(Map<String,FileStoreSourceSplitState> finishedSplitIds)
onSplitFinished
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,org.apache.flink.table.data.RowData,FileStoreSourceSplit,FileStoreSourceSplitState>
protected FileStoreSourceSplitState initializedState(FileStoreSourceSplit split)
initializedState
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,org.apache.flink.table.data.RowData,FileStoreSourceSplit,FileStoreSourceSplitState>
protected FileStoreSourceSplit toSplitType(String splitId, FileStoreSourceSplitState splitState)
toSplitType
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,org.apache.flink.table.data.RowData,FileStoreSourceSplit,FileStoreSourceSplitState>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.