org.apache.iceberg.flink.source

Class ScanContext

java.lang.Object

org.apache.iceberg.flink.source.ScanContext

All Implemented Interfaces:

java.io.Serializable

@Internal
public class ScanContext
extends java.lang.Object
implements java.io.Serializable

Context object with optional arguments for a Flink Scan.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ScanContext.Builder

Method Summary

Modifier and Type	Method and Description
java.lang.Long	asOfTimestamp()
static ScanContext.Builder	builder()
boolean	caseSensitive()
ScanContext	copyWithAppendsBetween(java.lang.Long newStartSnapshotId, long newEndSnapshotId)
ScanContext	copyWithSnapshotId(long newSnapshotId)
java.lang.Long	endSnapshotId()
boolean	exposeLocality()
java.util.List<Expression>	filters()
boolean	includeColumnStats()
boolean	isStreaming()
long	limit()
int	maxPlanningSnapshotCount()
java.time.Duration	monitorInterval()
java.lang.String	nameMapping()
java.lang.Integer	planParallelism()
Schema	project()
java.lang.Long	snapshotId()
java.lang.Integer	splitLookback()
java.lang.Long	splitOpenFileCost()
java.lang.Long	splitSize()
java.lang.Long	startSnapshotId()
java.lang.Long	startSnapshotTimestamp()
StreamingStartingStrategy	streamingStartingStrategy()

Methods inherited from class java.lang.Object

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

Method Detail

caseSensitive

public boolean caseSensitive()

snapshotId

public java.lang.Long snapshotId()

streamingStartingStrategy

public StreamingStartingStrategy streamingStartingStrategy()

startSnapshotTimestamp

public java.lang.Long startSnapshotTimestamp()

startSnapshotId

public java.lang.Long startSnapshotId()

endSnapshotId

public java.lang.Long endSnapshotId()

asOfTimestamp

public java.lang.Long asOfTimestamp()

splitSize

public java.lang.Long splitSize()

splitLookback

public java.lang.Integer splitLookback()

splitOpenFileCost

public java.lang.Long splitOpenFileCost()

isStreaming

public boolean isStreaming()

monitorInterval

public java.time.Duration monitorInterval()

nameMapping

public java.lang.String nameMapping()

project

public Schema project()

filters

public java.util.List<Expression> filters()

limit

public long limit()

includeColumnStats

public boolean includeColumnStats()

exposeLocality

public boolean exposeLocality()

planParallelism

public java.lang.Integer planParallelism()

maxPlanningSnapshotCount

public int maxPlanningSnapshotCount()

copyWithAppendsBetween

public ScanContext copyWithAppendsBetween(java.lang.Long newStartSnapshotId,
                                          long newEndSnapshotId)

copyWithSnapshotId

public ScanContext copyWithSnapshotId(long newSnapshotId)

builder

public static ScanContext.Builder builder()