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