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

Class LockConfig

java.lang.Object

org.apache.iceberg.flink.maintenance.api.LockConfig

public class LockConfig
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LockConfig.JdbcLockConfig
static class	LockConfig.ZkLockConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.flink.configuration.ConfigOption<String>	LOCK_ID_OPTION
static final org.apache.flink.configuration.ConfigOption<String>	LOCK_TYPE_OPTION
static final String	PREFIX

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
String	jdbcInitTable()	Gets the configuration value for initializing the JDBC lock table.
String	jdbcUri()	Gets the JDBC URI configuration value.
String	lockId(String defaultValue)	Gets the lock ID configuration value.
String	lockType()	Gets the lock type configuration value (e.g., jdbc or zookeeper).
Map<String,String>	properties()
int	zkBaseSleepMs()	Gets the Zookeeper base sleep time configuration (in milliseconds).
int	zkConnectionTimeoutMs()	Gets the Zookeeper connection timeout configuration (in milliseconds).
int	zkMaxRetries()	Gets the Zookeeper maximum retry count configuration.
int	zkSessionTimeoutMs()	Gets the Zookeeper session timeout configuration (in milliseconds).
String	zkUri()	Gets the Zookeeper URI configuration value.

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_TYPE_OPTION

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

LOCK_ID_OPTION

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

Constructor Details

LockConfig

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

Method Details

lockType

public String lockType()

Gets the lock type configuration value (e.g., jdbc or zookeeper).

lockId

public String lockId(String defaultValue)

Gets the lock ID configuration value. If blank, returns the provided default value.

jdbcUri

public String jdbcUri()

Gets the JDBC URI configuration value.

jdbcInitTable

public String jdbcInitTable()

Gets the configuration value for initializing the JDBC lock table.

zkUri

public String zkUri()

Gets the Zookeeper URI configuration value.

zkSessionTimeoutMs

public int zkSessionTimeoutMs()

Gets the Zookeeper session timeout configuration (in milliseconds).

zkConnectionTimeoutMs

public int zkConnectionTimeoutMs()

Gets the Zookeeper connection timeout configuration (in milliseconds).

zkBaseSleepMs

public int zkBaseSleepMs()

Gets the Zookeeper base sleep time configuration (in milliseconds).

zkMaxRetries

public int zkMaxRetries()

Gets the Zookeeper maximum retry count configuration.

properties

public Map<String,String> properties()