public class FileStoreSourceSplitReader extends Object implements org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>
SplitReader
implementation for the file store source.Constructor and Description |
---|
FileStoreSourceSplitReader(TableRead tableRead,
Long limit) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>> |
fetch() |
void |
handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<FileStoreSourceSplit> splitsChange) |
void |
wakeUp() |
public org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>> fetch() throws IOException
fetch
in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>
IOException
public void handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<FileStoreSourceSplit> splitsChange)
handleSplitsChanges
in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>
public void wakeUp()
wakeUp
in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>
public void close() throws Exception
close
in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.flink.connector.file.src.util.RecordAndPosition<org.apache.flink.table.data.RowData>,FileStoreSourceSplit>
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.