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)