Package org.apache.iceberg.flink.source

Class ScanContext.Builder

java.lang.Object

org.apache.iceberg.flink.source.ScanContext.Builder

Enclosing class:

ScanContext

public static class ScanContext.Builder
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
ScanContext.Builder	asOfTimestamp(java.lang.Long newAsOfTimestamp)
ScanContext	build()
ScanContext.Builder	caseSensitive(boolean newCaseSensitive)
ScanContext.Builder	endSnapshotId(java.lang.Long newEndSnapshotId)
ScanContext.Builder	endTag(java.lang.String newEndTag)
ScanContext.Builder	exposeLocality(boolean newExposeLocality)
ScanContext.Builder	filters(java.util.List<Expression> newFilters)
ScanContext.Builder	includeColumnStats(boolean newIncludeColumnStats)
ScanContext.Builder	includeColumnStats(java.util.Collection<java.lang.String> newIncludeStatsForColumns)
ScanContext.Builder	limit(long newLimit)
ScanContext.Builder	maxAllowedPlanningFailures(int newMaxAllowedPlanningFailures)
ScanContext.Builder	maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount)
ScanContext.Builder	monitorInterval(java.time.Duration newMonitorInterval)
ScanContext.Builder	nameMapping(java.lang.String newNameMapping)
ScanContext.Builder	planParallelism(java.lang.Integer parallelism)
ScanContext.Builder	project(Schema newProjectedSchema)
ScanContext.Builder	resolveConfig(Table table, java.util.Map<java.lang.String,java.lang.String> readOptions, org.apache.flink.configuration.ReadableConfig readableConfig)
ScanContext.Builder	splitLookback(java.lang.Integer newSplitLookback)
ScanContext.Builder	splitOpenFileCost(java.lang.Long newSplitOpenFileCost)
ScanContext.Builder	splitSize(java.lang.Long newSplitSize)
ScanContext.Builder	startingStrategy(StreamingStartingStrategy newStartingStrategy)
ScanContext.Builder	startSnapshotId(java.lang.Long newStartSnapshotId)
ScanContext.Builder	startSnapshotTimestamp(java.lang.Long newStartSnapshotTimestamp)
ScanContext.Builder	startTag(java.lang.String newStartTag)
ScanContext.Builder	streaming(boolean streaming)
ScanContext.Builder	useBranch(java.lang.String newBranch)
ScanContext.Builder	useSnapshotId(java.lang.Long newSnapshotId)
ScanContext.Builder	useTag(java.lang.String newTag)
ScanContext.Builder	watermarkColumn(java.lang.String newWatermarkColumn)
ScanContext.Builder	watermarkColumnTimeUnit(java.util.concurrent.TimeUnit newWatermarkTimeUnit)

Methods inherited from class java.lang.Object

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

Method Detail

caseSensitive

public ScanContext.Builder caseSensitive(boolean newCaseSensitive)

useSnapshotId

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

useTag

public ScanContext.Builder useTag(java.lang.String newTag)

useBranch

public ScanContext.Builder useBranch(java.lang.String newBranch)

startingStrategy

public ScanContext.Builder startingStrategy(StreamingStartingStrategy newStartingStrategy)

startSnapshotTimestamp

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

startSnapshotId

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

endSnapshotId

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

startTag

public ScanContext.Builder startTag(java.lang.String newStartTag)

endTag

public ScanContext.Builder endTag(java.lang.String newEndTag)

asOfTimestamp

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

splitSize

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

splitLookback

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

splitOpenFileCost

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

streaming

public ScanContext.Builder streaming(boolean streaming)

monitorInterval

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

nameMapping

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

project

public ScanContext.Builder project(Schema newProjectedSchema)

filters

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

limit

public ScanContext.Builder limit(long newLimit)

includeColumnStats

public ScanContext.Builder includeColumnStats(boolean newIncludeColumnStats)

includeColumnStats

public ScanContext.Builder includeColumnStats(java.util.Collection<java.lang.String> newIncludeStatsForColumns)

exposeLocality

public ScanContext.Builder exposeLocality(boolean newExposeLocality)

planParallelism

public ScanContext.Builder planParallelism(java.lang.Integer parallelism)

maxPlanningSnapshotCount

public ScanContext.Builder maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount)

maxAllowedPlanningFailures

public ScanContext.Builder maxAllowedPlanningFailures(int newMaxAllowedPlanningFailures)

watermarkColumn

public ScanContext.Builder watermarkColumn(java.lang.String newWatermarkColumn)

watermarkColumnTimeUnit

public ScanContext.Builder watermarkColumnTimeUnit(java.util.concurrent.TimeUnit newWatermarkTimeUnit)

resolveConfig

public ScanContext.Builder resolveConfig(Table table,
                                         java.util.Map<java.lang.String,java.lang.String> readOptions,
                                         org.apache.flink.configuration.ReadableConfig readableConfig)

build

public ScanContext build()