org.apache.paimon.flink.compact

Class MultiAwareBucketTableScan

java.lang.Object

org.apache.paimon.flink.compact.MultiTableScanBase<org.apache.flink.api.java.tuple.Tuple2<Split,String>>

org.apache.paimon.flink.compact.MultiAwareBucketTableScan

All Implemented Interfaces:

AutoCloseable

public class MultiAwareBucketTableScan
extends MultiTableScanBase<org.apache.flink.api.java.tuple.Tuple2<Split,String>>

This class is responsible for implementing the scanning logic MultiTableScanBase for the table with multi bucket such as dynamic or fixed bucket table.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.flink.compact.MultiTableScanBase

MultiTableScanBase.ScanResult

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Identifier,StreamTableScan>	scansMap
protected Map<Identifier,CompactBucketsTable>	tablesMap

Fields inherited from class org.apache.paimon.flink.compact.MultiTableScanBase

catalog, databasePattern, excludingPattern, includingPattern, isRunning, isStreaming

Constructor Summary

Constructors

Constructor and Description
MultiAwareBucketTableScan(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming, AtomicBoolean isRunning)

Method Summary

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.

Methods inherited from class org.apache.paimon.flink.compact.MultiTableScanBase

close, scanTable, updateTableMap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

tablesMap

protected transient Map<Identifier,CompactBucketsTable> tablesMap

scansMap

protected transient Map<Identifier,StreamTableScan> scansMap

Constructor Detail

MultiAwareBucketTableScan

public MultiAwareBucketTableScan(Catalog.Loader catalogLoader,
                                 Pattern includingPattern,
                                 Pattern excludingPattern,
                                 Pattern databasePattern,
                                 boolean isStreaming,
                                 AtomicBoolean isRunning)

Method Detail

checkTableScanned

public boolean checkTableScanned(Identifier identifier)

Description copied from class: MultiTableScanBase

Check if table has been scanned.

addScanTable

public void addScanTable(FileStoreTable fileStoreTable,
                         Identifier identifier)

Description copied from class: MultiTableScanBase

Add the scan table to the table map.