Package org.apache.iceberg.flink.maintenance.api

Class ExpireSnapshotsConfig

java.lang.Object

org.apache.iceberg.flink.maintenance.api.ExpireSnapshotsConfig

public class ExpireSnapshotsConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLEAN_EXPIRED_METADATA
static final org.apache.flink.configuration.ConfigOption<Boolean>	CLEAN_EXPIRED_METADATA_OPTION
static final String	DELETE_BATCH_SIZE
static final org.apache.flink.configuration.ConfigOption<Integer>	DELETE_BATCH_SIZE_OPTION
static final String	MAX_SNAPSHOT_AGE_SECONDS
static final org.apache.flink.configuration.ConfigOption<Long>	MAX_SNAPSHOT_AGE_SECONDS_OPTION
static final String	PLANNING_WORKER_POOL_SIZE
static final org.apache.flink.configuration.ConfigOption<Integer>	PLANNING_WORKER_POOL_SIZE_OPTION
static final String	PREFIX
static final String	RETAIN_LAST
static final org.apache.flink.configuration.ConfigOption<Integer>	RETAIN_LAST_OPTION
static final String	SCHEDULE_ON_COMMIT_COUNT
static final org.apache.flink.configuration.ConfigOption<Integer>	SCHEDULE_ON_COMMIT_COUNT_OPTION
static final String	SCHEDULE_ON_INTERVAL_SECOND
static final org.apache.flink.configuration.ConfigOption<Long>	SCHEDULE_ON_INTERVAL_SECOND_OPTION

Constructor Summary

Constructors

Constructor	Description
ExpireSnapshotsConfig(Table table, Map<String,String> writeOptions, org.apache.flink.configuration.ReadableConfig readableConfig)

Method Summary

Modifier and Type	Method	Description
Boolean	cleanExpiredMetadata()
int	deleteBatchSize()
Long	maxSnapshotAgeSeconds()
Integer	planningWorkerPoolSize()
Integer	retainLast()
int	scheduleOnCommitCount()
long	scheduleOnIntervalSecond()

Methods inherited from class java.lang.Object

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

Field Details

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

SCHEDULE_ON_COMMIT_COUNT

public static final String SCHEDULE_ON_COMMIT_COUNT

See Also:

• Constant Field Values

SCHEDULE_ON_COMMIT_COUNT_OPTION

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

SCHEDULE_ON_INTERVAL_SECOND

public static final String SCHEDULE_ON_INTERVAL_SECOND

See Also:

• Constant Field Values

SCHEDULE_ON_INTERVAL_SECOND_OPTION

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

MAX_SNAPSHOT_AGE_SECONDS

public static final String MAX_SNAPSHOT_AGE_SECONDS

See Also:

• Constant Field Values

MAX_SNAPSHOT_AGE_SECONDS_OPTION

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

RETAIN_LAST

public static final String RETAIN_LAST

See Also:

• Constant Field Values

RETAIN_LAST_OPTION

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

DELETE_BATCH_SIZE

public static final String DELETE_BATCH_SIZE

See Also:

• Constant Field Values

DELETE_BATCH_SIZE_OPTION

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

CLEAN_EXPIRED_METADATA

public static final String CLEAN_EXPIRED_METADATA

See Also:

• Constant Field Values

CLEAN_EXPIRED_METADATA_OPTION

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

PLANNING_WORKER_POOL_SIZE

public static final String PLANNING_WORKER_POOL_SIZE

See Also:

• Constant Field Values

PLANNING_WORKER_POOL_SIZE_OPTION

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

Constructor Details

ExpireSnapshotsConfig

public ExpireSnapshotsConfig(Table table,
 Map<String,String> writeOptions,
 org.apache.flink.configuration.ReadableConfig readableConfig)

Method Details

scheduleOnCommitCount

public int scheduleOnCommitCount()

scheduleOnIntervalSecond

public long scheduleOnIntervalSecond()

maxSnapshotAgeSeconds

public Long maxSnapshotAgeSeconds()

retainLast

public Integer retainLast()

deleteBatchSize

public int deleteBatchSize()

cleanExpiredMetadata

public Boolean cleanExpiredMetadata()

planningWorkerPoolSize

public Integer planningWorkerPoolSize()