public class CompactorSourceBuilder extends Object
StaticFileStoreSource
or ContinuousFileStoreSource
. This is for dedicated compactor jobs.Constructor and Description |
---|
CompactorSourceBuilder(String tableIdentifier,
FileStoreTable table) |
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) |
public CompactorSourceBuilder(String tableIdentifier, FileStoreTable table)
public CompactorSourceBuilder withContinuousMode(boolean isContinuous)
public CompactorSourceBuilder withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
public CompactorSourceBuilder withPartitionIdleTime(@Nullable java.time.Duration partitionIdleTime)
public org.apache.flink.streaming.api.datastream.DataStreamSource<org.apache.flink.table.data.RowData> build()
public CompactorSourceBuilder withPartitionPredicate(@Nullable Predicate partitionPredicate)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.