org.apache.flink.changelog.fs

Class FsStateChangelogOptions

java.lang.Object

org.apache.flink.changelog.fs.FsStateChangelogOptions

@Experimental
public class FsStateChangelogOptions
extends Object

ConfigOptions for FsStateChangelogStorage.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	BASE_PATH
static ConfigOption<java.time.Duration>	CACHE_IDLE_TIMEOUT
static ConfigOption<Boolean>	COMPRESSION_ENABLED
static ConfigOption<MemorySize>	IN_FLIGHT_DATA_LIMIT
static ConfigOption<Integer>	NUM_DISCARD_THREADS
static ConfigOption<Integer>	NUM_UPLOAD_THREADS
static ConfigOption<java.time.Duration>	PERSIST_DELAY
static ConfigOption<MemorySize>	PERSIST_SIZE_THRESHOLD
static ConfigOption<MemorySize>	PREEMPTIVE_PERSIST_THRESHOLD
static ConfigOption<java.time.Duration>	RETRY_DELAY_AFTER_FAILURE
static ConfigOption<Integer>	RETRY_MAX_ATTEMPTS
static ConfigOption<String>	RETRY_POLICY
static ConfigOption<MemorySize>	UPLOAD_BUFFER_SIZE
static ConfigOption<java.time.Duration>	UPLOAD_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
FsStateChangelogOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

BASE_PATH

public static final ConfigOption<String> BASE_PATH

COMPRESSION_ENABLED

public static final ConfigOption<Boolean> COMPRESSION_ENABLED

PREEMPTIVE_PERSIST_THRESHOLD

public static final ConfigOption<MemorySize> PREEMPTIVE_PERSIST_THRESHOLD

PERSIST_DELAY

public static final ConfigOption<java.time.Duration> PERSIST_DELAY

PERSIST_SIZE_THRESHOLD

public static final ConfigOption<MemorySize> PERSIST_SIZE_THRESHOLD

UPLOAD_BUFFER_SIZE

public static final ConfigOption<MemorySize> UPLOAD_BUFFER_SIZE

NUM_UPLOAD_THREADS

public static final ConfigOption<Integer> NUM_UPLOAD_THREADS

NUM_DISCARD_THREADS

public static final ConfigOption<Integer> NUM_DISCARD_THREADS

IN_FLIGHT_DATA_LIMIT

public static final ConfigOption<MemorySize> IN_FLIGHT_DATA_LIMIT

RETRY_POLICY

public static final ConfigOption<String> RETRY_POLICY

UPLOAD_TIMEOUT

public static final ConfigOption<java.time.Duration> UPLOAD_TIMEOUT

RETRY_MAX_ATTEMPTS

public static final ConfigOption<Integer> RETRY_MAX_ATTEMPTS

RETRY_DELAY_AFTER_FAILURE

public static final ConfigOption<java.time.Duration> RETRY_DELAY_AFTER_FAILURE

CACHE_IDLE_TIMEOUT

public static final ConfigOption<java.time.Duration> CACHE_IDLE_TIMEOUT

Constructor Detail

FsStateChangelogOptions

public FsStateChangelogOptions()