Package org.apache.iceberg.flink
Class FlinkReadOptions
- java.lang.Object
-
- org.apache.iceberg.flink.FlinkReadOptions
-
public class FlinkReadOptions extends java.lang.Object
Flink source read options
-
-
Field Summary
Fields Modifier and Type Field Description static org.apache.flink.configuration.ConfigOption<java.lang.Long>
AS_OF_TIMESTAMP
static org.apache.flink.configuration.ConfigOption<java.lang.String>
BRANCH
static java.lang.String
CASE_SENSITIVE
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>
CASE_SENSITIVE_OPTION
static org.apache.flink.configuration.ConfigOption<java.lang.Long>
END_SNAPSHOT_ID
static org.apache.flink.configuration.ConfigOption<java.lang.String>
END_TAG
static java.lang.String
INCLUDE_COLUMN_STATS
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>
INCLUDE_COLUMN_STATS_OPTION
static java.lang.String
LIMIT
static org.apache.flink.configuration.ConfigOption<java.lang.Long>
LIMIT_OPTION
static java.lang.String
MAX_ALLOWED_PLANNING_FAILURES
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>
MAX_ALLOWED_PLANNING_FAILURES_OPTION
static java.lang.String
MAX_PLANNING_SNAPSHOT_COUNT
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>
MAX_PLANNING_SNAPSHOT_COUNT_OPTION
static java.lang.String
MONITOR_INTERVAL
static org.apache.flink.configuration.ConfigOption<java.lang.String>
MONITOR_INTERVAL_OPTION
static org.apache.flink.configuration.ConfigOption<java.lang.Long>
SNAPSHOT_ID
static java.lang.String
SPLIT_FILE_OPEN_COST
static org.apache.flink.configuration.ConfigOption<java.lang.Long>
SPLIT_FILE_OPEN_COST_OPTION
static java.lang.String
SPLIT_LOOKBACK
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>
SPLIT_LOOKBACK_OPTION
static java.lang.String
SPLIT_SIZE
static org.apache.flink.configuration.ConfigOption<java.lang.Long>
SPLIT_SIZE_OPTION
static org.apache.flink.configuration.ConfigOption<java.lang.Long>
START_SNAPSHOT_ID
static org.apache.flink.configuration.ConfigOption<java.lang.Long>
START_SNAPSHOT_TIMESTAMP
static org.apache.flink.configuration.ConfigOption<java.lang.String>
START_TAG
static java.lang.String
STARTING_STRATEGY
static org.apache.flink.configuration.ConfigOption<StreamingStartingStrategy>
STARTING_STRATEGY_OPTION
static java.lang.String
STREAMING
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>
STREAMING_OPTION
static org.apache.flink.configuration.ConfigOption<java.lang.String>
TAG
static java.lang.String
WATERMARK_COLUMN
static org.apache.flink.configuration.ConfigOption<java.lang.String>
WATERMARK_COLUMN_OPTION
static java.lang.String
WATERMARK_COLUMN_TIME_UNIT
static org.apache.flink.configuration.ConfigOption<java.util.concurrent.TimeUnit>
WATERMARK_COLUMN_TIME_UNIT_OPTION
-
-
-
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
public static final java.lang.String CASE_SENSITIVE
- See Also:
- Constant Field Values
-
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
public static final java.lang.String SPLIT_SIZE
- See Also:
- Constant Field Values
-
SPLIT_SIZE_OPTION
public static final org.apache.flink.configuration.ConfigOption<java.lang.Long> SPLIT_SIZE_OPTION
-
SPLIT_LOOKBACK
public static final java.lang.String SPLIT_LOOKBACK
- See Also:
- Constant Field Values
-
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
public static final java.lang.String STREAMING
- See Also:
- Constant Field Values
-
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
public static final java.lang.String LIMIT
- See Also:
- Constant Field Values
-
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
-
-