| Package | Description |
|---|---|
| org.apache.flink.runtime.state |
| Modifier and Type | Field and Description |
|---|---|
OperatorState<T> |
StateCheckpoint.checkpointedState |
| Modifier and Type | Method and Description |
|---|---|
OperatorState<T> |
StateCheckpoint.restore() |
| Modifier and Type | Method and Description |
|---|---|
Map<String,OperatorState<?>> |
StateHandle.getState(ClassLoader userClassloader)
getState should retrieve and return the state managed the handle.
|
Map<String,OperatorState<?>> |
LocalStateHandle.getState(ClassLoader usercodeClassloader) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
OperatorState.stateEquals(OperatorState<T> other) |
| Constructor and Description |
|---|
StateCheckpoint(OperatorState<T> operatorState)
Creates a state checkpoint from the given
OperatorState |
| Constructor and Description |
|---|
LocalStateHandle(Map<String,OperatorState<?>> state) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.