Package org.apache.iceberg.flink.source

Class IcebergSource.Builder<T>

java.lang.Object

org.apache.iceberg.flink.source.IcebergSource.Builder<T>

Enclosing class:

IcebergSource<T>

public static class IcebergSource.Builder<T>
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
IcebergSource.Builder	asOfTimestamp(java.lang.Long newAsOfTimestamp)
IcebergSource.Builder<T>	assignerFactory(SplitAssignerFactory assignerFactory)
IcebergSource<T>	build()
IcebergSource.Builder	caseSensitive(boolean newCaseSensitive)
IcebergSource.Builder	endSnapshotId(java.lang.Long newEndSnapshotId)
IcebergSource.Builder	filters(java.util.List<Expression> newFilters)
IcebergSource.Builder<T>	flinkConfig(org.apache.flink.configuration.ReadableConfig config)
IcebergSource.Builder	includeColumnStats(boolean newIncludeColumnStats)
IcebergSource.Builder	limit(long newLimit)
IcebergSource.Builder	monitorInterval(java.time.Duration newMonitorInterval)
IcebergSource.Builder	nameMapping(java.lang.String newNameMapping)
IcebergSource.Builder	planParallelism(int planParallelism)
IcebergSource.Builder	project(Schema newProjectedSchema)
IcebergSource.Builder	properties(java.util.Map<java.lang.String,java.lang.String> properties)
IcebergSource.Builder<T>	readerFunction(ReaderFunction<T> newReaderFunction)
IcebergSource.Builder	splitLookback(java.lang.Integer newSplitLookback)
IcebergSource.Builder	splitOpenFileCost(java.lang.Long newSplitOpenFileCost)
IcebergSource.Builder	splitSize(java.lang.Long newSplitSize)
IcebergSource.Builder	startSnapshotId(java.lang.Long newStartSnapshotId)
IcebergSource.Builder	startSnapshotTimestamp(java.lang.Long newStartSnapshotTimestamp)
IcebergSource.Builder	streaming(boolean streaming)
IcebergSource.Builder	streamingStartingStrategy(StreamingStartingStrategy newStartingStrategy)
IcebergSource.Builder<T>	tableLoader(TableLoader loader)
IcebergSource.Builder	useSnapshotId(java.lang.Long newSnapshotId)

Methods inherited from class java.lang.Object

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

Method Detail

tableLoader

public IcebergSource.Builder<T> tableLoader(TableLoader loader)

assignerFactory

public IcebergSource.Builder<T> assignerFactory(SplitAssignerFactory assignerFactory)

readerFunction

public IcebergSource.Builder<T> readerFunction(ReaderFunction<T> newReaderFunction)

flinkConfig

public IcebergSource.Builder<T> flinkConfig(org.apache.flink.configuration.ReadableConfig config)

caseSensitive

public IcebergSource.Builder caseSensitive(boolean newCaseSensitive)

useSnapshotId

public IcebergSource.Builder useSnapshotId(java.lang.Long newSnapshotId)

streamingStartingStrategy

public IcebergSource.Builder streamingStartingStrategy(StreamingStartingStrategy newStartingStrategy)

startSnapshotTimestamp

public IcebergSource.Builder startSnapshotTimestamp(java.lang.Long newStartSnapshotTimestamp)

startSnapshotId

public IcebergSource.Builder startSnapshotId(java.lang.Long newStartSnapshotId)

endSnapshotId

public IcebergSource.Builder endSnapshotId(java.lang.Long newEndSnapshotId)

asOfTimestamp

public IcebergSource.Builder asOfTimestamp(java.lang.Long newAsOfTimestamp)

splitSize

public IcebergSource.Builder splitSize(java.lang.Long newSplitSize)

splitLookback

public IcebergSource.Builder splitLookback(java.lang.Integer newSplitLookback)

splitOpenFileCost

public IcebergSource.Builder splitOpenFileCost(java.lang.Long newSplitOpenFileCost)

streaming

public IcebergSource.Builder streaming(boolean streaming)

monitorInterval

public IcebergSource.Builder monitorInterval(java.time.Duration newMonitorInterval)

nameMapping

public IcebergSource.Builder nameMapping(java.lang.String newNameMapping)

project

public IcebergSource.Builder project(Schema newProjectedSchema)

filters

public IcebergSource.Builder filters(java.util.List<Expression> newFilters)

limit

public IcebergSource.Builder limit(long newLimit)

includeColumnStats

public IcebergSource.Builder includeColumnStats(boolean newIncludeColumnStats)

planParallelism

public IcebergSource.Builder planParallelism(int planParallelism)

properties

public IcebergSource.Builder properties(java.util.Map<java.lang.String,java.lang.String> properties)

build

public IcebergSource<T> build()