Package org.apache.iceberg.flink

Class FlinkReadOptions

java.lang.Object

org.apache.iceberg.flink.FlinkReadOptions

public class FlinkReadOptions
extends Object

Flink source read options

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.flink.configuration.ConfigOption<Long>	AS_OF_TIMESTAMP
static final org.apache.flink.configuration.ConfigOption<String>	BRANCH
static final String	CASE_SENSITIVE
static final org.apache.flink.configuration.ConfigOption<Boolean>	CASE_SENSITIVE_OPTION
static final org.apache.flink.configuration.ConfigOption<Long>	END_SNAPSHOT_ID
static final org.apache.flink.configuration.ConfigOption<String>	END_TAG
static final String	INCLUDE_COLUMN_STATS
static final org.apache.flink.configuration.ConfigOption<Boolean>	INCLUDE_COLUMN_STATS_OPTION
static final String	LIMIT
static final org.apache.flink.configuration.ConfigOption<Long>	LIMIT_OPTION
static final String	MAX_ALLOWED_PLANNING_FAILURES
static final org.apache.flink.configuration.ConfigOption<Integer>	MAX_ALLOWED_PLANNING_FAILURES_OPTION
static final String	MAX_PLANNING_SNAPSHOT_COUNT
static final org.apache.flink.configuration.ConfigOption<Integer>	MAX_PLANNING_SNAPSHOT_COUNT_OPTION
static final String	MONITOR_INTERVAL
static final org.apache.flink.configuration.ConfigOption<String>	MONITOR_INTERVAL_OPTION
static final org.apache.flink.configuration.ConfigOption<Long>	SNAPSHOT_ID
static final String	SPLIT_FILE_OPEN_COST
static final org.apache.flink.configuration.ConfigOption<Long>	SPLIT_FILE_OPEN_COST_OPTION
static final String	SPLIT_LOOKBACK
static final org.apache.flink.configuration.ConfigOption<Integer>	SPLIT_LOOKBACK_OPTION
static final String	SPLIT_SIZE
static final org.apache.flink.configuration.ConfigOption<Long>	SPLIT_SIZE_OPTION
static final org.apache.flink.configuration.ConfigOption<Long>	START_SNAPSHOT_ID
static final org.apache.flink.configuration.ConfigOption<Long>	START_SNAPSHOT_TIMESTAMP
static final org.apache.flink.configuration.ConfigOption<String>	START_TAG
static final String	STARTING_STRATEGY
static final org.apache.flink.configuration.ConfigOption<StreamingStartingStrategy>	STARTING_STRATEGY_OPTION
static final String	STREAMING
static final org.apache.flink.configuration.ConfigOption<Boolean>	STREAMING_OPTION
static final org.apache.flink.configuration.ConfigOption<String>	TAG
static final String	WATERMARK_COLUMN
static final org.apache.flink.configuration.ConfigOption<String>	WATERMARK_COLUMN_OPTION
static final String	WATERMARK_COLUMN_TIME_UNIT
static final org.apache.flink.configuration.ConfigOption<TimeUnit>	WATERMARK_COLUMN_TIME_UNIT_OPTION

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

SNAPSHOT_ID

public static final org.apache.flink.configuration.ConfigOption<Long> SNAPSHOT_ID

TAG

public static final org.apache.flink.configuration.ConfigOption<String> TAG

BRANCH

public static final org.apache.flink.configuration.ConfigOption<String> BRANCH

START_TAG

public static final org.apache.flink.configuration.ConfigOption<String> START_TAG

END_TAG

public static final org.apache.flink.configuration.ConfigOption<String> END_TAG

CASE_SENSITIVE

public static final String CASE_SENSITIVE

See Also:

• Constant Field Values

CASE_SENSITIVE_OPTION

public static final org.apache.flink.configuration.ConfigOption<Boolean> CASE_SENSITIVE_OPTION

AS_OF_TIMESTAMP

public static final org.apache.flink.configuration.ConfigOption<Long> AS_OF_TIMESTAMP

STARTING_STRATEGY

public static final 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<Long> START_SNAPSHOT_TIMESTAMP

START_SNAPSHOT_ID

public static final org.apache.flink.configuration.ConfigOption<Long> START_SNAPSHOT_ID

END_SNAPSHOT_ID

public static final org.apache.flink.configuration.ConfigOption<Long> END_SNAPSHOT_ID

SPLIT_SIZE

public static final String SPLIT_SIZE

See Also:

• Constant Field Values

SPLIT_SIZE_OPTION

public static final org.apache.flink.configuration.ConfigOption<Long> SPLIT_SIZE_OPTION

SPLIT_LOOKBACK

public static final String SPLIT_LOOKBACK

See Also:

• Constant Field Values

SPLIT_LOOKBACK_OPTION

public static final org.apache.flink.configuration.ConfigOption<Integer> SPLIT_LOOKBACK_OPTION

SPLIT_FILE_OPEN_COST

public static final String SPLIT_FILE_OPEN_COST

See Also:

• Constant Field Values

SPLIT_FILE_OPEN_COST_OPTION

public static final org.apache.flink.configuration.ConfigOption<Long> SPLIT_FILE_OPEN_COST_OPTION

STREAMING

public static final String STREAMING

See Also:

• Constant Field Values

STREAMING_OPTION

public static final org.apache.flink.configuration.ConfigOption<Boolean> STREAMING_OPTION

MONITOR_INTERVAL

public static final String MONITOR_INTERVAL

See Also:

• Constant Field Values

MONITOR_INTERVAL_OPTION

public static final org.apache.flink.configuration.ConfigOption<String> MONITOR_INTERVAL_OPTION

INCLUDE_COLUMN_STATS

public static final String INCLUDE_COLUMN_STATS

See Also:

• Constant Field Values

INCLUDE_COLUMN_STATS_OPTION

public static final org.apache.flink.configuration.ConfigOption<Boolean> INCLUDE_COLUMN_STATS_OPTION

MAX_PLANNING_SNAPSHOT_COUNT

public static final String MAX_PLANNING_SNAPSHOT_COUNT

See Also:

• Constant Field Values

MAX_PLANNING_SNAPSHOT_COUNT_OPTION

public static final org.apache.flink.configuration.ConfigOption<Integer> MAX_PLANNING_SNAPSHOT_COUNT_OPTION

LIMIT

public static final String LIMIT

See Also:

• Constant Field Values

LIMIT_OPTION

public static final org.apache.flink.configuration.ConfigOption<Long> LIMIT_OPTION

MAX_ALLOWED_PLANNING_FAILURES

public static final String MAX_ALLOWED_PLANNING_FAILURES

See Also:

• Constant Field Values

MAX_ALLOWED_PLANNING_FAILURES_OPTION

public static final org.apache.flink.configuration.ConfigOption<Integer> MAX_ALLOWED_PLANNING_FAILURES_OPTION

WATERMARK_COLUMN

public static final String WATERMARK_COLUMN

See Also:

• Constant Field Values

WATERMARK_COLUMN_OPTION

public static final org.apache.flink.configuration.ConfigOption<String> WATERMARK_COLUMN_OPTION

WATERMARK_COLUMN_TIME_UNIT

public static final String WATERMARK_COLUMN_TIME_UNIT

See Also:

• Constant Field Values

WATERMARK_COLUMN_TIME_UNIT_OPTION

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