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

Class LockConfig.ZkLockConfig

java.lang.Object

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

Enclosing class:

LockConfig

public static class LockConfig.ZkLockConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ZK
static final org.apache.flink.configuration.ConfigOption<Integer>	ZK_BASE_SLEEP_MS_OPTION
static final org.apache.flink.configuration.ConfigOption<Integer>	ZK_CONNECTION_TIMEOUT_MS_OPTION
static final org.apache.flink.configuration.ConfigOption<Integer>	ZK_MAX_RETRIES_OPTION
static final org.apache.flink.configuration.ConfigOption<Integer>	ZK_MAX_SLEEP_MS_OPTION	The maximum sleep time (in milliseconds) between retries for the Zookeeper client.
static final org.apache.flink.configuration.ConfigOption<ZKRetryPolicies>	ZK_RETRY_POLICY_OPTION	The retry policy name for the Zookeeper client.
static final org.apache.flink.configuration.ConfigOption<Integer>	ZK_SESSION_TIMEOUT_MS_OPTION
static final org.apache.flink.configuration.ConfigOption<String>	ZK_URI_OPTION

Constructor Summary

Constructors

Constructor	Description
ZkLockConfig()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

ZK

public static final String ZK

See Also:

• Constant Field Values

ZK_URI_OPTION

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

ZK_SESSION_TIMEOUT_MS_OPTION

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

ZK_CONNECTION_TIMEOUT_MS_OPTION

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

ZK_BASE_SLEEP_MS_OPTION

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

ZK_MAX_RETRIES_OPTION

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

ZK_MAX_SLEEP_MS_OPTION

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

The maximum sleep time (in milliseconds) between retries for the Zookeeper client. Default: 10000 ms

ZK_RETRY_POLICY_OPTION

public static final org.apache.flink.configuration.ConfigOption<ZKRetryPolicies> ZK_RETRY_POLICY_OPTION

The retry policy name for the Zookeeper client. Supported values might include: "exponential-backoff", "fixed", etc. Default: "exponential-backoff"

Constructor Details

ZkLockConfig

public ZkLockConfig()