Class FlinkReadOptions


  • public class FlinkReadOptions
    extends java.lang.Object
    Flink source read options
    • Field Detail

      • SNAPSHOT_ID

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> SNAPSHOT_ID
      • TAG

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> TAG
      • BRANCH

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> BRANCH
      • START_TAG

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> START_TAG
      • END_TAG

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> END_TAG
      • CASE_SENSITIVE_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> CASE_SENSITIVE_OPTION
      • AS_OF_TIMESTAMP

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> AS_OF_TIMESTAMP
      • STARTING_STRATEGY

        public static final java.lang.String STARTING_STRATEGY
        See Also:
        Constant Field Values
      • STARTING_STRATEGY_OPTION

        public static final org.apache.flink.configuration.ConfigOption<StreamingStartingStrategy> STARTING_STRATEGY_OPTION
      • START_SNAPSHOT_TIMESTAMP

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> START_SNAPSHOT_TIMESTAMP
      • START_SNAPSHOT_ID

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> START_SNAPSHOT_ID
      • END_SNAPSHOT_ID

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> END_SNAPSHOT_ID
      • SPLIT_SIZE_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> SPLIT_SIZE_OPTION
      • SPLIT_LOOKBACK_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> SPLIT_LOOKBACK_OPTION
      • SPLIT_FILE_OPEN_COST

        public static final java.lang.String SPLIT_FILE_OPEN_COST
        See Also:
        Constant Field Values
      • SPLIT_FILE_OPEN_COST_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> SPLIT_FILE_OPEN_COST_OPTION
      • STREAMING_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> STREAMING_OPTION
      • MONITOR_INTERVAL

        public static final java.lang.String MONITOR_INTERVAL
        See Also:
        Constant Field Values
      • MONITOR_INTERVAL_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> MONITOR_INTERVAL_OPTION
      • INCLUDE_COLUMN_STATS

        public static final java.lang.String INCLUDE_COLUMN_STATS
        See Also:
        Constant Field Values
      • INCLUDE_COLUMN_STATS_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> INCLUDE_COLUMN_STATS_OPTION
      • MAX_PLANNING_SNAPSHOT_COUNT

        public static final java.lang.String MAX_PLANNING_SNAPSHOT_COUNT
        See Also:
        Constant Field Values
      • MAX_PLANNING_SNAPSHOT_COUNT_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> MAX_PLANNING_SNAPSHOT_COUNT_OPTION
      • LIMIT_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> LIMIT_OPTION
      • MAX_ALLOWED_PLANNING_FAILURES

        public static final java.lang.String MAX_ALLOWED_PLANNING_FAILURES
        See Also:
        Constant Field Values
      • MAX_ALLOWED_PLANNING_FAILURES_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> MAX_ALLOWED_PLANNING_FAILURES_OPTION
      • WATERMARK_COLUMN

        public static final java.lang.String WATERMARK_COLUMN
        See Also:
        Constant Field Values
      • WATERMARK_COLUMN_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> WATERMARK_COLUMN_OPTION
      • WATERMARK_COLUMN_TIME_UNIT

        public static final java.lang.String WATERMARK_COLUMN_TIME_UNIT
        See Also:
        Constant Field Values
      • WATERMARK_COLUMN_TIME_UNIT_OPTION

        public static final org.apache.flink.configuration.ConfigOption<java.util.concurrent.TimeUnit> WATERMARK_COLUMN_TIME_UNIT_OPTION