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 and 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

Method Summary

Methods inherited from class java.lang.Object

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

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