Package 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	Description
static org.apache.flink.configuration.ConfigOption<String>	BASE_PATH
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	CACHE_IDLE_TIMEOUT
static org.apache.flink.configuration.ConfigOption<Boolean>	COMPRESSION_ENABLED
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	IN_FLIGHT_DATA_LIMIT
static org.apache.flink.configuration.ConfigOption<Integer>	NUM_DISCARD_THREADS
static org.apache.flink.configuration.ConfigOption<Integer>	NUM_UPLOAD_THREADS
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	PERSIST_DELAY
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	PERSIST_SIZE_THRESHOLD
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	PREEMPTIVE_PERSIST_THRESHOLD
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	RETRY_DELAY_AFTER_FAILURE
static org.apache.flink.configuration.ConfigOption<Integer>	RETRY_MAX_ATTEMPTS
static org.apache.flink.configuration.ConfigOption<String>	RETRY_POLICY
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	UPLOAD_BUFFER_SIZE
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	UPLOAD_TIMEOUT

Constructor Summary

Constructors

Constructor	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 org.apache.flink.configuration.ConfigOption<String> BASE_PATH

COMPRESSION_ENABLED

public static final org.apache.flink.configuration.ConfigOption<Boolean> COMPRESSION_ENABLED

PREEMPTIVE_PERSIST_THRESHOLD

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> PREEMPTIVE_PERSIST_THRESHOLD

PERSIST_DELAY

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> PERSIST_DELAY

PERSIST_SIZE_THRESHOLD

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> PERSIST_SIZE_THRESHOLD

UPLOAD_BUFFER_SIZE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> UPLOAD_BUFFER_SIZE

NUM_UPLOAD_THREADS

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

NUM_DISCARD_THREADS

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

IN_FLIGHT_DATA_LIMIT

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> IN_FLIGHT_DATA_LIMIT

RETRY_POLICY

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

UPLOAD_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> UPLOAD_TIMEOUT

RETRY_MAX_ATTEMPTS

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

RETRY_DELAY_AFTER_FAILURE

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> RETRY_DELAY_AFTER_FAILURE

CACHE_IDLE_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CACHE_IDLE_TIMEOUT

Constructor Detail

FsStateChangelogOptions

public FsStateChangelogOptions()