org.apache.paimon.flink.source

Class FlinkSourceBuilder

java.lang.Object

org.apache.paimon.flink.source.FlinkSourceBuilder

public class FlinkSourceBuilder
extends Object

DataStream API for building Flink Source.

Since:

0.8

Constructor Summary

Constructors

Constructor and Description
FlinkSourceBuilder(Table table)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkSourceBuilder

public FlinkSourceBuilder(Table table)

Method Detail

env

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

sourceName

public FlinkSourceBuilder sourceName(String name)

sourceBounded

public FlinkSourceBuilder sourceBounded(boolean bounded)

projection

public FlinkSourceBuilder projection(int[] projectedFields)

projection

public FlinkSourceBuilder projection(int[][] projectedFields)

predicate

public FlinkSourceBuilder predicate(Predicate predicate)

limit

public FlinkSourceBuilder limit(@Nullable
                                Long limit)

sourceParallelism

public FlinkSourceBuilder sourceParallelism(@Nullable
                                            Integer parallelism)

watermarkStrategy

public FlinkSourceBuilder watermarkStrategy(@Nullable
                                            org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy)

dynamicPartitionFilteringFields

public FlinkSourceBuilder dynamicPartitionFilteringFields(List<String> dynamicPartitionFilteringFields)

buildForRow

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> buildForRow()

Build source DataStream with RowData.

build

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

Build source DataStream with RowData.