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	exposeLocality(boolean newExposeLocality)
ScanContext.Builder	filters(java.util.List<Expression> newFilters)
ScanContext.Builder	fromProperties(java.util.Map<java.lang.String,java.lang.String> properties)
ScanContext.Builder	includeColumnStats(boolean newIncludeColumnStats)
ScanContext.Builder	limit(long newLimit)
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	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	streaming(boolean streaming)
ScanContext.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

caseSensitive

public ScanContext.Builder caseSensitive(boolean newCaseSensitive)

useSnapshotId

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

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)

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)

exposeLocality

public ScanContext.Builder exposeLocality(boolean newExposeLocality)

planParallelism

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

maxPlanningSnapshotCount

public ScanContext.Builder maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount)

fromProperties

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

build

public ScanContext build()