public class MultiAwareBucketTableScan extends MultiTableScanBase<org.apache.flink.api.java.tuple.Tuple2<Split,String>>
MultiTableScanBase
for the
table with multi bucket such as dynamic or fixed bucket table.MultiTableScanBase.ScanResult
Modifier and Type | Field and Description |
---|---|
protected Map<Identifier,StreamTableScan> |
scansMap |
protected Map<Identifier,CompactBucketsTable> |
tablesMap |
catalog, databasePattern, excludingPattern, includingPattern, isRunning, isStreaming
Constructor and Description |
---|
MultiAwareBucketTableScan(Catalog.Loader catalogLoader,
Pattern includingPattern,
Pattern excludingPattern,
Pattern databasePattern,
boolean isStreaming,
AtomicBoolean isRunning) |
Modifier and Type | Method and Description |
---|---|
void |
addScanTable(FileStoreTable fileStoreTable,
Identifier identifier)
Add the scan table to the table map.
|
boolean |
checkTableScanned(Identifier identifier)
Check if table has been scanned.
|
close, scanTable, updateTableMap
protected transient Map<Identifier,CompactBucketsTable> tablesMap
protected transient Map<Identifier,StreamTableScan> scansMap
public MultiAwareBucketTableScan(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming, AtomicBoolean isRunning)
public boolean checkTableScanned(Identifier identifier)
MultiTableScanBase
public void addScanTable(FileStoreTable fileStoreTable, Identifier identifier)
MultiTableScanBase
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.