org.apache.paimon.flink.compact

Class MultiUnawareBucketTableScan

java.lang.Object

org.apache.paimon.flink.compact.MultiTableScanBase<MultiTableUnawareAppendCompactionTask>

org.apache.paimon.flink.compact.MultiUnawareBucketTableScan

All Implemented Interfaces:

AutoCloseable

public class MultiUnawareBucketTableScan
extends MultiTableScanBase<MultiTableUnawareAppendCompactionTask>

This class is responsible for implementing the scanning logic MultiTableScanBase for the table with fix single bucket such as unaware 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,UnawareAppendTableCompactionCoordinator>	tablesMap

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

catalog, databasePattern, excludingPattern, includingPattern, isStreaming, tableOptions

Constructor Summary

Constructors

Constructor and Description
MultiUnawareBucketTableScan(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming, Map<String,String> tableOptions)

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,UnawareAppendTableCompactionCoordinator> tablesMap

Constructor Detail

MultiUnawareBucketTableScan

public MultiUnawareBucketTableScan(CatalogLoader catalogLoader,
                                   Pattern includingPattern,
                                   Pattern excludingPattern,
                                   Pattern databasePattern,
                                   boolean isStreaming,
                                   Map<String,String> tableOptions)

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.