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 build DataStream.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and 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	exposeLocality(boolean newExposeLocality)
FlinkSource.Builder	filters(java.util.List<Expression> filters)
FlinkSource.Builder	flinkConf(org.apache.flink.configuration.ReadableConfig config)
FlinkSource.Builder	limit(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)
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

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)

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()