| Package | Description |
|---|---|
| org.apache.flink.runtime.checkpoint | |
| org.apache.flink.runtime.deployment | |
| org.apache.flink.runtime.execution | |
| org.apache.flink.runtime.executiongraph | |
| org.apache.flink.runtime.jobgraph.tasks | |
| org.apache.flink.runtime.messages.checkpoint |
This package contains the messages that are sent between
JobManager
and TaskManager to coordinate the checkpoint snapshots of the
distributed dataflow. |
| org.apache.flink.runtime.state | |
| org.apache.flink.runtime.taskmanager |
| Class and Description |
|---|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| Class and Description |
|---|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| Class and Description |
|---|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| Class and Description |
|---|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| Class and Description |
|---|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| Class and Description |
|---|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| Class and Description |
|---|
| ByteStreamStateHandle
Statehandle that writes/reads the contents of the serializable checkpointed
state to the provided input and outputstreams using default java
serialization.
|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
| StateHandleProvider
Stateful streaming operators use a StateHandleProvider to create new
StateHandles to store each checkpoint in a persistent storage layer. |
| Class and Description |
|---|
| StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.