T
- the result of scanning file :
Split
,String> for the table with multi buckets, such as dynamic or fixed
bucket table.
MultiTableUnawareAppendCompactionTask
for the table witch fixed single bucket
,such as unaware bucket table.
public abstract class MultiTableScanBase<T> extends Object implements AutoCloseable
Modifier and Type | Class and Description |
---|---|
static class |
MultiTableScanBase.ScanResult
the result of table scanning.
|
Modifier and Type | Field and Description |
---|---|
protected Catalog |
catalog |
protected Pattern |
databasePattern |
protected Pattern |
excludingPattern |
protected Pattern |
includingPattern |
protected AtomicBoolean |
isRunning |
protected boolean |
isStreaming |
Constructor and Description |
---|
MultiTableScanBase(Catalog.Loader catalogLoader,
Pattern includingPattern,
Pattern excludingPattern,
Pattern databasePattern,
boolean isStreaming,
AtomicBoolean isRunning) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
MultiTableScanBase.ScanResult |
scanTable(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T> ctx) |
protected void |
updateTableMap() |
protected final Pattern includingPattern
protected final Pattern excludingPattern
protected final Pattern databasePattern
protected transient Catalog catalog
protected AtomicBoolean isRunning
protected boolean isStreaming
public MultiTableScanBase(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming, AtomicBoolean isRunning)
protected void updateTableMap() throws Catalog.DatabaseNotExistException, Catalog.TableNotExistException
public MultiTableScanBase.ScanResult scanTable(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T> ctx) throws Catalog.TableNotExistException, Catalog.DatabaseNotExistException
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.