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

useSnapshotId

public IcebergSource.Builder<T> useSnapshotId(java.lang.Long newSnapshotId)

streamingStartingStrategy

public IcebergSource.Builder<T> streamingStartingStrategy(StreamingStartingStrategy newStartingStrategy)

startSnapshotTimestamp

public IcebergSource.Builder<T> startSnapshotTimestamp(java.lang.Long newStartSnapshotTimestamp)

startSnapshotId

public IcebergSource.Builder<T> startSnapshotId(java.lang.Long newStartSnapshotId)

endSnapshotId

public IcebergSource.Builder<T> endSnapshotId(java.lang.Long newEndSnapshotId)

asOfTimestamp

public IcebergSource.Builder<T> asOfTimestamp(java.lang.Long newAsOfTimestamp)

splitSize

public IcebergSource.Builder<T> splitSize(java.lang.Long newSplitSize)

splitLookback

public IcebergSource.Builder<T> splitLookback(java.lang.Integer newSplitLookback)

splitOpenFileCost

public IcebergSource.Builder<T> splitOpenFileCost(java.lang.Long newSplitOpenFileCost)

streaming

public IcebergSource.Builder<T> streaming(boolean streaming)

monitorInterval

public IcebergSource.Builder<T> monitorInterval(java.time.Duration newMonitorInterval)

nameMapping

public IcebergSource.Builder<T> nameMapping(java.lang.String newNameMapping)

project

public IcebergSource.Builder<T> project(Schema newProjectedSchema)

project

public IcebergSource.Builder<T> project(org.apache.flink.table.api.TableSchema newProjectedFlinkSchema)

filters

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

limit

public IcebergSource.Builder<T> limit(long newLimit)

includeColumnStats

public IcebergSource.Builder<T> includeColumnStats(boolean newIncludeColumnStats)

planParallelism

public IcebergSource.Builder<T> planParallelism(int planParallelism)

exposeLocality

public IcebergSource.Builder<T> exposeLocality(boolean newExposeLocality)

properties

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

build

public IcebergSource<T> build()