| Interface | Description |
|---|---|
| StateHandle<T> |
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| StateHandleProvider<T> |
Stateful streaming operators use a StateHandleProvider to create new
StateHandles to store each checkpoint in a persistent storage layer. |
| Class | Description |
|---|---|
| ByteStreamStateHandle |
Statehandle that writes/reads the contents of the serializable checkpointed
state to the provided input and outputstreams using default java
serialization.
|
| FileStateHandle |
Statehandle that writes the checkpointed state to a random file in the
provided checkpoint directory.
|
| LocalStateHandle |
A StateHandle that includes the operator states directly.
|
| StateUtils |
A collection of utility methods for dealing with operator state.
|
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.