Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory | |
org.apache.flink.util |
Constructor and Description |
---|
RocksDBStateBackend(StateBackend checkpointStreamBackend,
TernaryBoolean enableIncrementalCheckpointing)
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
Constructor and Description |
---|
FsStateBackend(URI checkpointDirectory,
URI defaultSavepointDirectory,
int fileStateSizeThreshold,
TernaryBoolean asynchronousSnapshots)
Creates a new state backend that stores its checkpoint data in the file system and location
defined by the given URI.
|
Constructor and Description |
---|
MemoryStateBackend(String checkpointPath,
String savepointPath,
int maxStateSize,
TernaryBoolean asynchronousSnapshots)
Creates a new MemoryStateBackend, setting optionally the paths to persist checkpoint metadata
and savepoints to, as well as configuring state thresholds and asynchronous operations.
|
Modifier and Type | Method and Description |
---|---|
static TernaryBoolean |
TernaryBoolean.fromBoolean(boolean bool)
|
static TernaryBoolean |
TernaryBoolean.fromBoxedBoolean(Boolean bool)
Converts the given boxed Boolean to a TernaryBoolean.
|
TernaryBoolean |
TernaryBoolean.resolveUndefined(boolean valueForUndefined)
Gets the boolean value corresponding to this value.
|
static TernaryBoolean |
TernaryBoolean.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TernaryBoolean[] |
TernaryBoolean.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.