Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
RocksDBStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultOperatorStateBackend
Default implementation of OperatorStateStore that provides the ability to make snapshots.
|
Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
StateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry)
Creates a new
OperatorStateBackend that can be used for storing operator state. |
abstract OperatorStateBackend |
AbstractStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
FsStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
MemoryStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
protected Iterable<OT> |
UnionStateInputFormat.getElements(OperatorStateBackend restoredBackend) |
protected Iterable<OT> |
ListStateInputFormat.getElements(OperatorStateBackend restoredBackend) |
protected Iterable<Tuple2<K,V>> |
BroadcastStateInputFormat.getElements(OperatorStateBackend restoredBackend) |
Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
AbstractStreamOperator.getOperatorStateBackend() |
OperatorStateBackend |
StreamOperatorStateContext.operatorStateBackend()
Returns the operator state backend for the stream operator.
|
protected OperatorStateBackend |
StreamTaskStateInitializerImpl.operatorStateBackend(String operatorIdentifierText,
PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskStates,
CloseableRegistry backendCloseableRegistry) |
Modifier and Type | Method and Description |
---|---|
static void |
StreamingFunctionUtils.snapshotFunctionState(StateSnapshotContext context,
OperatorStateBackend backend,
Function userFunction) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.