Class FlinkReadConf


  • public class FlinkReadConf
    extends java.lang.Object
    • Constructor Detail

      • FlinkReadConf

        public FlinkReadConf​(Table table,
                             java.util.Map<java.lang.String,​java.lang.String> readOptions,
                             org.apache.flink.configuration.ReadableConfig readableConfig)
    • Method Detail

      • snapshotId

        public java.lang.Long snapshotId()
      • tag

        public java.lang.String tag()
      • startTag

        public java.lang.String startTag()
      • endTag

        public java.lang.String endTag()
      • branch

        public java.lang.String branch()
      • caseSensitive

        public boolean caseSensitive()
      • asOfTimestamp

        public java.lang.Long asOfTimestamp()
      • startSnapshotTimestamp

        public java.lang.Long startSnapshotTimestamp()
      • startSnapshotId

        public java.lang.Long startSnapshotId()
      • endSnapshotId

        public java.lang.Long endSnapshotId()
      • splitSize

        public long splitSize()
      • splitLookback

        public int splitLookback()
      • splitFileOpenCost

        public long splitFileOpenCost()
      • streaming

        public boolean streaming()
      • monitorInterval

        public java.time.Duration monitorInterval()
      • includeColumnStats

        public boolean includeColumnStats()
      • maxPlanningSnapshotCount

        public int maxPlanningSnapshotCount()
      • nameMapping

        public java.lang.String nameMapping()
      • limit

        public long limit()
      • workerPoolSize

        public int workerPoolSize()
      • maxAllowedPlanningFailures

        public int maxAllowedPlanningFailures()
      • watermarkColumn

        public java.lang.String watermarkColumn()
      • watermarkColumnTimeUnit

        public java.util.concurrent.TimeUnit watermarkColumnTimeUnit()