org.apache.paimon.flink.source

Class CombinedTableCompactorSourceBuilder

java.lang.Object

org.apache.paimon.flink.source.CombinedTableCompactorSourceBuilder

public class CombinedTableCompactorSourceBuilder
extends Object

source builder to build a Flink compactor source for multi-tables. This is for dedicated compactor jobs in combined mode.

Constructor Summary

Constructors

Constructor and Description
CombinedTableCompactorSourceBuilder(Catalog.Loader catalogLoader, Pattern databasePattern, Pattern includingPattern, Pattern excludingPattern, long monitorInterval)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	buildAwareBucketTableSource()
org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask>	buildForUnawareBucketsTableSource()
CombinedTableCompactorSourceBuilder	withContinuousMode(boolean isContinuous)
CombinedTableCompactorSourceBuilder	withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
CombinedTableCompactorSourceBuilder	withPartitionIdleTime(java.time.Duration partitionIdleTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

CombinedTableCompactorSourceBuilder

public CombinedTableCompactorSourceBuilder(Catalog.Loader catalogLoader,
                                           Pattern databasePattern,
                                           Pattern includingPattern,
                                           Pattern excludingPattern,
                                           long monitorInterval)

Method Detail

withContinuousMode

public CombinedTableCompactorSourceBuilder withContinuousMode(boolean isContinuous)

withEnv

public CombinedTableCompactorSourceBuilder withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

withPartitionIdleTime

public CombinedTableCompactorSourceBuilder withPartitionIdleTime(@Nullable
                                                                 java.time.Duration partitionIdleTime)

buildAwareBucketTableSource

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> buildAwareBucketTableSource()

buildForUnawareBucketsTableSource

public org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask> buildForUnawareBucketsTableSource()