Package org.apache.iceberg.flink

Class FlinkReadConf

java.lang.Object
org.apache.iceberg.flink.FlinkReadConf
public class FlinkReadConf extends Object

  • Constructor Details

    • FlinkReadConf

      public FlinkReadConf(Table table, Map<String,String> readOptions, org.apache.flink.configuration.ReadableConfig readableConfig)

  • Method Details

    • snapshotId

      public Long snapshotId()

    • tag

      public String tag()

    • startTag

      public String startTag()

    • endTag

      public String endTag()

    • branch

      public String branch()

    • caseSensitive

      public boolean caseSensitive()

    • asOfTimestamp

      public Long asOfTimestamp()

    • startingStrategy

      public StreamingStartingStrategy startingStrategy()

    • startSnapshotTimestamp

      public Long startSnapshotTimestamp()

    • startSnapshotId

      public Long startSnapshotId()

    • endSnapshotId

      public Long endSnapshotId()

    • splitSize

      public long splitSize()

    • splitLookback

      public int splitLookback()

    • splitFileOpenCost

      public long splitFileOpenCost()

    • streaming

      public boolean streaming()

    • monitorInterval

      public Duration monitorInterval()

    • includeColumnStats

      public boolean includeColumnStats()

    • maxPlanningSnapshotCount

      public int maxPlanningSnapshotCount()

    • nameMapping

      public String nameMapping()

    • limit

      public long limit()

    • workerPoolSize

      public int workerPoolSize()

    • maxAllowedPlanningFailures

      public int maxAllowedPlanningFailures()

    • watermarkColumn

      public String watermarkColumn()

    • watermarkColumnTimeUnit

      public TimeUnit watermarkColumnTimeUnit()