public class FlinkSourceBuilder extends Object
StaticFileStoreSource
or ContinuousFileStoreSource
. This is for normal read/write jobs.Constructor and Description |
---|
FlinkSourceBuilder(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
FileStoreTable table) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.api.datastream.DataStreamSource<org.apache.flink.table.data.RowData> |
build() |
FlinkSourceBuilder |
withContinuousMode(boolean isContinuous) |
FlinkSourceBuilder |
withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env) |
FlinkSourceBuilder |
withLimit(Long limit) |
FlinkSourceBuilder |
withLogSourceProvider(LogSourceProvider logSourceProvider) |
FlinkSourceBuilder |
withParallelism(Integer parallelism) |
FlinkSourceBuilder |
withPredicate(Predicate predicate) |
FlinkSourceBuilder |
withProjection(int[][] projectedFields) |
FlinkSourceBuilder |
withWatermarkStrategy(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy) |
public FlinkSourceBuilder(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, FileStoreTable table)
public FlinkSourceBuilder withContinuousMode(boolean isContinuous)
public FlinkSourceBuilder withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
public FlinkSourceBuilder withProjection(int[][] projectedFields)
public FlinkSourceBuilder withPredicate(Predicate predicate)
public FlinkSourceBuilder withLimit(@Nullable Long limit)
public FlinkSourceBuilder withLogSourceProvider(LogSourceProvider logSourceProvider)
public FlinkSourceBuilder withParallelism(@Nullable Integer parallelism)
public FlinkSourceBuilder withWatermarkStrategy(@Nullable org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy)
public org.apache.flink.streaming.api.datastream.DataStreamSource<org.apache.flink.table.data.RowData> build()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.