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 Object

Source builder to build DataStream.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
FlinkSource.Builder	asOfTimestamp(Long asOfTimestamp)
FlinkSource.Builder	branch(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(Long endSnapshotId)
FlinkSource.Builder	endTag(String endTag)
FlinkSource.Builder	env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment newEnv)
FlinkSource.Builder	exposeLocality(boolean newExposeLocality)
FlinkSource.Builder	filters(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(Duration interval)
FlinkSource.Builder	nameMapping(String nameMapping)
FlinkSource.Builder	project(org.apache.flink.table.legacy.api.TableSchema schema)
FlinkSource.Builder	properties(Map<String,String> properties)	Deprecated. Use setAll(java.util.Map<java.lang.String, java.lang.String>) instead.
FlinkSource.Builder	set(String property, String value)
FlinkSource.Builder	setAll(Map<String,String> properties)
FlinkSource.Builder	snapshotId(Long snapshotId)
FlinkSource.Builder	splitLookback(Integer splitLookback)
FlinkSource.Builder	splitOpenFileCost(Long splitOpenFileCost)
FlinkSource.Builder	splitSize(Long splitSize)
FlinkSource.Builder	startSnapshotId(Long startSnapshotId)
FlinkSource.Builder	startTag(String startTag)
FlinkSource.Builder	streaming(boolean streaming)
FlinkSource.Builder	table(Table newTable)
FlinkSource.Builder	tableLoader(TableLoader newLoader)
FlinkSource.Builder	tag(String tag)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

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(List<Expression> filters)

project

public FlinkSource.Builder project(org.apache.flink.table.legacy.api.TableSchema schema)

limit

public FlinkSource.Builder limit(Long newLimit)

set

public FlinkSource.Builder set(String property,
 String value)

setAll

public FlinkSource.Builder setAll(Map<String,String> properties)

properties

@Deprecated
public FlinkSource.Builder properties(Map<String,String> properties)

Deprecated.

Use setAll(java.util.Map<java.lang.String, java.lang.String>) instead.

caseSensitive

public FlinkSource.Builder caseSensitive(boolean caseSensitive)

snapshotId

public FlinkSource.Builder snapshotId(Long snapshotId)

branch

public FlinkSource.Builder branch(String branch)

tag

public FlinkSource.Builder tag(String tag)

startSnapshotId

public FlinkSource.Builder startSnapshotId(Long startSnapshotId)

endSnapshotId

public FlinkSource.Builder endSnapshotId(Long endSnapshotId)

startTag

public FlinkSource.Builder startTag(String startTag)

endTag

public FlinkSource.Builder endTag(String endTag)

asOfTimestamp

public FlinkSource.Builder asOfTimestamp(Long asOfTimestamp)

splitSize

public FlinkSource.Builder splitSize(Long splitSize)

splitLookback

public FlinkSource.Builder splitLookback(Integer splitLookback)

splitOpenFileCost

public FlinkSource.Builder splitOpenFileCost(Long splitOpenFileCost)

streaming

public FlinkSource.Builder streaming(boolean streaming)

exposeLocality

public FlinkSource.Builder exposeLocality(boolean newExposeLocality)

nameMapping

public FlinkSource.Builder nameMapping(String nameMapping)

monitorInterval

public FlinkSource.Builder monitorInterval(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()