Package | Description |
---|---|
org.apache.flink.runtime.state |
Modifier and Type | Interface and Description |
---|---|
interface |
OperatorStateBackend
Interface that combines both, the user facing
OperatorStateStore interface and the system interface
Snapshotable |
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 |
---|---|
OperatorStateStore |
ManagedInitializationContext.getOperatorStateStore()
Returns an interface that allows for registering operator state with the backend.
|
OperatorStateStore |
StateInitializationContextImpl.getOperatorStateStore() |
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyedStateHandle> keyedStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.