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

Constructor Details

ZkLockConfig

public ZkLockConfig()