Package org.apache.iceberg.flink.source
Class FlinkSource.Builder
- java.lang.Object
-
- org.apache.iceberg.flink.source.FlinkSource.Builder
-
- Enclosing class:
- FlinkSource
public static class FlinkSource.Builder extends java.lang.Object
Source builder to buildDataStream
.
-
-
Constructor Summary
Constructors Constructor Description Builder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FlinkSource.Builder
asOfTimestamp(java.lang.Long asOfTimestamp)
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>
build()
FlinkInputFormat
buildFormat()
FlinkSource.Builder
caseSensitive(boolean caseSensitive)
FlinkSource.Builder
endSnapshotId(java.lang.Long endSnapshotId)
FlinkSource.Builder
env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment newEnv)
FlinkSource.Builder
filters(java.util.List<Expression> filters)
FlinkSource.Builder
flinkConf(org.apache.flink.configuration.ReadableConfig config)
FlinkSource.Builder
limit(long newLimit)
FlinkSource.Builder
nameMapping(java.lang.String nameMapping)
FlinkSource.Builder
project(org.apache.flink.table.api.TableSchema schema)
FlinkSource.Builder
properties(java.util.Map<java.lang.String,java.lang.String> properties)
FlinkSource.Builder
snapshotId(java.lang.Long snapshotId)
FlinkSource.Builder
splitLookback(java.lang.Integer splitLookback)
FlinkSource.Builder
splitOpenFileCost(java.lang.Long splitOpenFileCost)
FlinkSource.Builder
splitSize(java.lang.Long splitSize)
FlinkSource.Builder
startSnapshotId(java.lang.Long startSnapshotId)
FlinkSource.Builder
streaming(boolean streaming)
FlinkSource.Builder
table(Table newTable)
FlinkSource.Builder
tableLoader(TableLoader newLoader)
-
-
-
Method Detail
-
tableLoader
public FlinkSource.Builder tableLoader(TableLoader newLoader)
-
table
public FlinkSource.Builder table(Table newTable)
-
env
public FlinkSource.Builder env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment newEnv)
-
filters
public FlinkSource.Builder filters(java.util.List<Expression> filters)
-
project
public FlinkSource.Builder project(org.apache.flink.table.api.TableSchema schema)
-
limit
public FlinkSource.Builder limit(long newLimit)
-
properties
public FlinkSource.Builder properties(java.util.Map<java.lang.String,java.lang.String> properties)
-
caseSensitive
public FlinkSource.Builder caseSensitive(boolean caseSensitive)
-
snapshotId
public FlinkSource.Builder snapshotId(java.lang.Long snapshotId)
-
startSnapshotId
public FlinkSource.Builder startSnapshotId(java.lang.Long startSnapshotId)
-
endSnapshotId
public FlinkSource.Builder endSnapshotId(java.lang.Long endSnapshotId)
-
asOfTimestamp
public FlinkSource.Builder asOfTimestamp(java.lang.Long asOfTimestamp)
-
splitSize
public FlinkSource.Builder splitSize(java.lang.Long splitSize)
-
splitLookback
public FlinkSource.Builder splitLookback(java.lang.Integer splitLookback)
-
splitOpenFileCost
public FlinkSource.Builder splitOpenFileCost(java.lang.Long splitOpenFileCost)
-
streaming
public FlinkSource.Builder streaming(boolean streaming)
-
nameMapping
public FlinkSource.Builder nameMapping(java.lang.String nameMapping)
-
flinkConf
public FlinkSource.Builder flinkConf(org.apache.flink.configuration.ReadableConfig config)
-
buildFormat
public FlinkInputFormat buildFormat()
-
build
public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> build()
-
-