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
All Methods Instance Methods Concrete Methods 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
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
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)
-
-
-
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)
-
exposeLocality
public ScanContext.Builder exposeLocality(boolean newExposeLocality)
-
planParallelism
public ScanContext.Builder planParallelism(java.lang.Integer parallelism)
-
maxPlanningSnapshotCount
public ScanContext.Builder maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount)
-
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()
-
-