Package | Description |
---|---|
org.apache.flink.table.store.file.operation | |
org.apache.flink.table.store.mapred | |
org.apache.flink.table.store.table.source |
Modifier and Type | Method and Description |
---|---|
RecordReader<KeyValue> |
KeyValueFileStoreRead.createReader(DataSplit split) |
RecordReader<T> |
FileStoreRead.createReader(DataSplit split)
Create a
RecordReader from split. |
RecordReader<org.apache.flink.table.data.RowData> |
AppendOnlyFileStoreRead.createReader(DataSplit split) |
Modifier and Type | Method and Description |
---|---|
DataSplit |
TableStoreInputSplit.split() |
Constructor and Description |
---|
TableStoreInputSplit(String path,
DataSplit split) |
Modifier and Type | Field and Description |
---|---|
List<DataSplit> |
DataTableScan.DataFilePlan.splits |
Modifier and Type | Method and Description |
---|---|
static DataSplit |
DataSplit.deserialize(org.apache.flink.core.memory.DataInputView in) |
Modifier and Type | Method and Description |
---|---|
static List<DataSplit> |
AbstractDataTableScan.generateSplits(long snapshotId,
boolean isIncremental,
SplitGenerator splitGenerator,
Map<org.apache.flink.table.data.binary.BinaryRowData,Map<Integer,List<DataFileMeta>>> groupedDataFiles) |
Constructor and Description |
---|
DataFilePlan(Long snapshotId,
List<DataSplit> splits) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.