@PublicEvolving public class CoreOptions extends Object
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
ALWAYS_PARENT_FIRST_LOADER |
static ConfigOption<String> |
CHECKPOINTS_DIRECTORY
The default directory used for persistent checkpoints.
|
static ConfigOption<String> |
CLASSLOADER_RESOLVE_ORDER |
static ConfigOption<String> |
DEFAULT_FILESYSTEM_SCHEME
The default filesystem scheme, used for paths that do not declare a scheme explicitly.
|
static ConfigOption<Integer> |
DEFAULT_PARALLELISM_KEY |
static ConfigOption<String> |
FLINK_JM_JVM_OPTIONS |
static ConfigOption<String> |
FLINK_JVM_OPTIONS |
static ConfigOption<String> |
FLINK_TM_JVM_OPTIONS |
static ConfigOption<Integer> |
MAX_RETAINED_CHECKPOINTS
The maximum number of completed checkpoint instances to retain.
|
static ConfigOption<String> |
SAVEPOINT_DIRECTORY
The default directory for savepoints.
|
static ConfigOption<String> |
STATE_BACKEND |
Constructor and Description |
---|
CoreOptions() |
Modifier and Type | Method and Description |
---|---|
static ConfigOption<Integer> |
fileSystemConnectionLimit(String scheme)
The total number of input plus output connections that a file system for the given scheme may open.
|
static ConfigOption<Integer> |
fileSystemConnectionLimitIn(String scheme)
The total number of input connections that a file system for the given scheme may open.
|
static ConfigOption<Integer> |
fileSystemConnectionLimitOut(String scheme)
The total number of output connections that a file system for the given scheme may open.
|
static ConfigOption<Long> |
fileSystemConnectionLimitStreamInactivityTimeout(String scheme)
If any connection limit is configured, this option can be optionally set to define after
which time (in milliseconds) inactive streams are reclaimed.
|
static ConfigOption<Long> |
fileSystemConnectionLimitTimeout(String scheme)
If any connection limit is configured, this option can be optionally set to define after
which time (in milliseconds) stream opening fails with a timeout exception, if no stream
connection becomes available.
|
public static final ConfigOption<String> CLASSLOADER_RESOLVE_ORDER
public static final ConfigOption<String> ALWAYS_PARENT_FIRST_LOADER
public static final ConfigOption<String> FLINK_JVM_OPTIONS
public static final ConfigOption<String> FLINK_JM_JVM_OPTIONS
public static final ConfigOption<String> FLINK_TM_JVM_OPTIONS
public static final ConfigOption<Integer> DEFAULT_PARALLELISM_KEY
public static final ConfigOption<String> STATE_BACKEND
public static final ConfigOption<Integer> MAX_RETAINED_CHECKPOINTS
public static final ConfigOption<String> SAVEPOINT_DIRECTORY
public static final ConfigOption<String> CHECKPOINTS_DIRECTORY
public static final ConfigOption<String> DEFAULT_FILESYSTEM_SCHEME
public static ConfigOption<Integer> fileSystemConnectionLimit(String scheme)
public static ConfigOption<Integer> fileSystemConnectionLimitIn(String scheme)
public static ConfigOption<Integer> fileSystemConnectionLimitOut(String scheme)
public static ConfigOption<Long> fileSystemConnectionLimitTimeout(String scheme)
public static ConfigOption<Long> fileSystemConnectionLimitStreamInactivityTimeout(String scheme)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.