Package org.apache.iceberg.flink.source

Class 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

    • Method Detail

      • caseSensitive

        public boolean caseSensitive()

      • snapshotId

        public java.lang.Long snapshotId()

      • 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)