Uses of Class
org.apache.paimon.flink.source.CompactorSourceBuilder

Packages that use CompactorSourceBuilder

Package	Description
org.apache.paimon.flink.source

Uses of CompactorSourceBuilder in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return CompactorSourceBuilder

Modifier and Type	Method and Description
CompactorSourceBuilder	CompactorSourceBuilder.withContinuousMode(boolean isContinuous)
CompactorSourceBuilder	CompactorSourceBuilder.withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
CompactorSourceBuilder	CompactorSourceBuilder.withPartitionIdleTime(java.time.Duration partitionIdleTime)
CompactorSourceBuilder	CompactorSourceBuilder.withPartitionPredicate(Predicate partitionPredicate)