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

Packages that use FlinkSourceBuilder

Package	Description
org.apache.paimon.flink.source

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

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

Modifier and Type	Method and Description
FlinkSourceBuilder	FlinkSourceBuilder.dynamicPartitionFilteringFields(List<String> dynamicPartitionFilteringFields)
FlinkSourceBuilder	FlinkSourceBuilder.env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
FlinkSourceBuilder	FlinkSourceBuilder.limit(Long limit)
FlinkSourceBuilder	FlinkSourceBuilder.predicate(Predicate predicate)
FlinkSourceBuilder	FlinkSourceBuilder.projection(int[] projectedFields)
FlinkSourceBuilder	FlinkSourceBuilder.projection(int[][] projectedFields)
FlinkSourceBuilder	FlinkSourceBuilder.sourceBounded(boolean bounded)
FlinkSourceBuilder	FlinkSourceBuilder.sourceName(String name)
FlinkSourceBuilder	FlinkSourceBuilder.sourceParallelism(Integer parallelism)
FlinkSourceBuilder	FlinkSourceBuilder.watermarkStrategy(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy)