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
SnapshotStrategy |
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,
Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStateInputs,
Iterable<StatePartitionStreamProvider> rawOperatorStateInputs) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.