CombinedTableCompactorSourceBuilder |
CombinedTableCompactorSourceBuilder.withContinuousMode(boolean isContinuous) |
CombinedTableCompactorSourceBuilder |
CombinedTableCompactorSourceBuilder.withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env) |
CombinedTableCompactorSourceBuilder |
CombinedTableCompactorSourceBuilder.withPartitionIdleTime(java.time.Duration partitionIdleTime) |
CombinedTableCompactorSourceBuilder |
CombinedTableCompactorSourceBuilder.withTableOptions(Map<String,String> tableOptions) |