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 Deprecated Methods Modifier and Type Method Description FlinkSource.Builder
asOfTimestamp(java.lang.Long asOfTimestamp)
FlinkSource.Builder
branch(java.lang.String branch)
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
endTag(java.lang.String endTag)
FlinkSource.Builder
env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment newEnv)
FlinkSource.Builder
exposeLocality(boolean newExposeLocality)
FlinkSource.Builder
filters(java.util.List<Expression> filters)
FlinkSource.Builder
flinkConf(org.apache.flink.configuration.ReadableConfig config)
FlinkSource.Builder
limit(java.lang.Long newLimit)
FlinkSource.Builder
maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount)
FlinkSource.Builder
monitorInterval(java.time.Duration interval)
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)
Deprecated.FlinkSource.Builder
set(java.lang.String property, java.lang.String value)
FlinkSource.Builder
setAll(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
startTag(java.lang.String startTag)
FlinkSource.Builder
streaming(boolean streaming)
FlinkSource.Builder
table(Table newTable)
FlinkSource.Builder
tableLoader(TableLoader newLoader)
FlinkSource.Builder
tag(java.lang.String tag)
-
-
-
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(java.lang.Long newLimit)
-
set
public FlinkSource.Builder set(java.lang.String property, java.lang.String value)
-
setAll
public FlinkSource.Builder setAll(java.util.Map<java.lang.String,java.lang.String> properties)
-
properties
@Deprecated public FlinkSource.Builder properties(java.util.Map<java.lang.String,java.lang.String> properties)
Deprecated.
-
caseSensitive
public FlinkSource.Builder caseSensitive(boolean caseSensitive)
-
snapshotId
public FlinkSource.Builder snapshotId(java.lang.Long snapshotId)
-
branch
public FlinkSource.Builder branch(java.lang.String branch)
-
tag
public FlinkSource.Builder tag(java.lang.String tag)
-
startSnapshotId
public FlinkSource.Builder startSnapshotId(java.lang.Long startSnapshotId)
-
endSnapshotId
public FlinkSource.Builder endSnapshotId(java.lang.Long endSnapshotId)
-
startTag
public FlinkSource.Builder startTag(java.lang.String startTag)
-
endTag
public FlinkSource.Builder endTag(java.lang.String endTag)
-
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)
-
exposeLocality
public FlinkSource.Builder exposeLocality(boolean newExposeLocality)
-
nameMapping
public FlinkSource.Builder nameMapping(java.lang.String nameMapping)
-
monitorInterval
public FlinkSource.Builder monitorInterval(java.time.Duration interval)
-
maxPlanningSnapshotCount
public FlinkSource.Builder maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount)
-
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()
-
-