org.apache.paimon.flink.source

Class CompactorSourceBuilder

java.lang.Object

org.apache.paimon.flink.source.CompactorSourceBuilder

public class CompactorSourceBuilder
extends Object

Source builder to build a Flink StaticFileStoreSource or ContinuousFileStoreSource. This is for dedicated compactor jobs.

Constructor Summary

Constructors

Constructor and Description
CompactorSourceBuilder(String tableIdentifier, FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSource<org.apache.flink.table.data.RowData>	build()
CompactorSourceBuilder	withContinuousMode(boolean isContinuous)
CompactorSourceBuilder	withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
CompactorSourceBuilder	withPartitionIdleTime(java.time.Duration partitionIdleTime)
CompactorSourceBuilder	withPartitionPredicate(Predicate partitionPredicate)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompactorSourceBuilder

public CompactorSourceBuilder(String tableIdentifier,
                              FileStoreTable table)

Method Detail

withContinuousMode

public CompactorSourceBuilder withContinuousMode(boolean isContinuous)

withEnv

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

withPartitionIdleTime

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

build

public org.apache.flink.streaming.api.datastream.DataStreamSource<org.apache.flink.table.data.RowData> build()

withPartitionPredicate

public CompactorSourceBuilder withPartitionPredicate(@Nullable
                                                     Predicate partitionPredicate)