public abstract class AbstractDataTableScan extends Object implements DataTableScan
FileStoreScan
to provide input split generation.DataTableScan.DataFilePlan
TableScan.Plan
Modifier | Constructor and Description |
---|---|
protected |
AbstractDataTableScan(FileStoreScan scan,
TableSchema tableSchema,
FileStorePathFactory pathFactory,
CoreOptions options) |
Modifier and Type | Method and Description |
---|---|
static List<DataSplit> |
generateSplits(long snapshotId,
boolean isIncremental,
SplitGenerator splitGenerator,
Map<org.apache.flink.table.data.binary.BinaryRowData,Map<Integer,List<DataFileMeta>>> groupedDataFiles) |
CoreOptions |
options() |
DataTableScan.DataFilePlan |
plan() |
SnapshotManager |
snapshotManager() |
protected abstract SplitGenerator |
splitGenerator(FileStorePathFactory pathFactory) |
AbstractDataTableScan |
withBucket(int bucket) |
AbstractDataTableScan |
withFilter(Predicate predicate) |
AbstractDataTableScan |
withKind(ScanKind scanKind) |
AbstractDataTableScan |
withLevel(int level) |
protected abstract void |
withNonPartitionFilter(Predicate predicate) |
AbstractDataTableScan |
withSnapshot(long snapshotId) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
withFilter
protected AbstractDataTableScan(FileStoreScan scan, TableSchema tableSchema, FileStorePathFactory pathFactory, CoreOptions options)
public AbstractDataTableScan withSnapshot(long snapshotId)
withSnapshot
in interface DataTableScan
public AbstractDataTableScan withFilter(Predicate predicate)
withFilter
in interface DataTableScan
withFilter
in interface TableScan
public AbstractDataTableScan withKind(ScanKind scanKind)
withKind
in interface DataTableScan
public AbstractDataTableScan withLevel(int level)
withLevel
in interface DataTableScan
@VisibleForTesting public AbstractDataTableScan withBucket(int bucket)
public DataTableScan.DataFilePlan plan()
plan
in interface DataTableScan
plan
in interface TableScan
@VisibleForTesting public static List<DataSplit> generateSplits(long snapshotId, boolean isIncremental, SplitGenerator splitGenerator, Map<org.apache.flink.table.data.binary.BinaryRowData,Map<Integer,List<DataFileMeta>>> groupedDataFiles)
protected abstract SplitGenerator splitGenerator(FileStorePathFactory pathFactory)
protected abstract void withNonPartitionFilter(Predicate predicate)
public CoreOptions options()
public SnapshotManager snapshotManager()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.