Package | Description |
---|---|
org.apache.flink.table.store.table.source |
Modifier and Type | Class and Description |
---|---|
class |
AppendOnlySplitGenerator
Append only implementation of
SplitGenerator . |
class |
MergeTreeSplitGenerator
Merge tree implementation of
SplitGenerator . |
Modifier and Type | Method and Description |
---|---|
protected abstract SplitGenerator |
AbstractDataTableScan.splitGenerator(FileStorePathFactory pathFactory) |
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) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.