public class FlinkRecordsWithSplitIds extends Object implements org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>
RecordsWithSplitIds
which contains only one iterator record. This can ensure that there
will be no checkpoint segmentation in iterator consumption.Modifier and Type | Method and Description |
---|---|
static void |
emitRecord(org.apache.flink.api.connector.source.SourceReaderContext context,
org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> element,
org.apache.flink.api.connector.source.SourceOutput<org.apache.flink.table.data.RowData> output,
FileStoreSourceSplitState state,
FileStoreSourceReaderMetrics metrics) |
static FlinkRecordsWithSplitIds |
finishedSplit(String splitId) |
Set<String> |
finishedSplits() |
static FlinkRecordsWithSplitIds |
forRecords(String splitId,
org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> recordsForSplit) |
org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> |
nextRecordFromSplit() |
String |
nextSplit() |
void |
recycle() |
@Nullable public String nextSplit()
nextSplit
in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>
@Nullable public org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> nextRecordFromSplit()
nextRecordFromSplit
in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>
public Set<String> finishedSplits()
finishedSplits
in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>
public void recycle()
recycle
in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>
public static FlinkRecordsWithSplitIds forRecords(String splitId, org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> recordsForSplit)
public static FlinkRecordsWithSplitIds finishedSplit(String splitId)
public static void emitRecord(org.apache.flink.api.connector.source.SourceReaderContext context, org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> element, org.apache.flink.api.connector.source.SourceOutput<org.apache.flink.table.data.RowData> output, FileStoreSourceSplitState state, FileStoreSourceReaderMetrics metrics)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.