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

Class FlinkMaintenanceConfig

java.lang.Object

org.apache.iceberg.flink.maintenance.api.FlinkMaintenanceConfig

public class FlinkMaintenanceConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LOCK_CHECK_DELAY
static final org.apache.flink.configuration.ConfigOption<Long>	LOCK_CHECK_DELAY_OPTION
static final String	PARALLELISM
static final org.apache.flink.configuration.ConfigOption<Integer>	PARALLELISM_OPTION
static final String	PREFIX
static final String	RATE_LIMIT
static final org.apache.flink.configuration.ConfigOption<Long>	RATE_LIMIT_OPTION
static final String	SLOT_SHARING_GROUP
static final org.apache.flink.configuration.ConfigOption<String>	SLOT_SHARING_GROUP_OPTION

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
LockConfig	createLockConfig()
RewriteDataFilesConfig	createRewriteDataFilesConfig()
long	lockCheckDelay()	Gets the lock check delay value (in seconds).
int	parallelism()	Gets the parallelism value for maintenance tasks.
long	rateLimit()	Gets the rate limit value (in seconds) for maintenance operations.
String	slotSharingGroup()	Gets the slot sharing group value for maintenance tasks.

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

LOCK_CHECK_DELAY

public static final String LOCK_CHECK_DELAY

See Also:

• Constant Field Values

LOCK_CHECK_DELAY_OPTION

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

PARALLELISM

public static final String PARALLELISM

See Also:

• Constant Field Values

PARALLELISM_OPTION

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

RATE_LIMIT

public static final String RATE_LIMIT

See Also:

• Constant Field Values

RATE_LIMIT_OPTION

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

SLOT_SHARING_GROUP

public static final String SLOT_SHARING_GROUP

See Also:

• Constant Field Values

SLOT_SHARING_GROUP_OPTION

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

Constructor Details

FlinkMaintenanceConfig

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

Method Details

rateLimit

public long rateLimit()

Gets the rate limit value (in seconds) for maintenance operations.

parallelism

public int parallelism()

Gets the parallelism value for maintenance tasks.

lockCheckDelay

public long lockCheckDelay()

Gets the lock check delay value (in seconds).

slotSharingGroup

public String slotSharingGroup()

Gets the slot sharing group value for maintenance tasks.

createRewriteDataFilesConfig

public RewriteDataFilesConfig createRewriteDataFilesConfig()

createLockConfig

public LockConfig createLockConfig()