| Package | Description |
|---|---|
| org.apache.flink.runtime.deployment | |
| org.apache.flink.runtime.executiongraph | |
| org.apache.flink.runtime.jobgraph.tasks | |
| org.apache.flink.runtime.state |
| Modifier and Type | Method and Description |
|---|---|
StateHandle |
TaskDeploymentDescriptor.getOperatorStates() |
| Modifier and Type | Method and Description |
|---|---|
void |
TaskDeploymentDescriptor.setOperatorState(StateHandle operatorStates) |
| Constructor and Description |
|---|
TaskDeploymentDescriptor(JobID jobID,
JobVertexID vertexID,
ExecutionAttemptID executionId,
String taskName,
int indexInSubtaskGroup,
int numberOfSubtasks,
Configuration jobConfiguration,
Configuration taskConfiguration,
String invokableClassName,
List<ResultPartitionDeploymentDescriptor> producedPartitions,
List<InputGateDeploymentDescriptor> inputGates,
List<BlobKey> requiredJarFiles,
int targetSlotNumber,
StateHandle operatorStates) |
| Modifier and Type | Method and Description |
|---|---|
StateHandle |
ExecutionVertex.getOperatorState() |
StateHandle |
Execution.getOperatorState() |
| Modifier and Type | Method and Description |
|---|---|
void |
ExecutionVertex.setOperatorState(StateHandle operatorState) |
void |
Execution.setOperatorState(StateHandle operatorStates) |
| Modifier and Type | Method and Description |
|---|---|
void |
ExecutionGraph.loadOperatorStates(Map<scala.Tuple3<JobVertexID,Integer,Long>,StateHandle> states) |
| Modifier and Type | Method and Description |
|---|---|
void |
OperatorStateCarrier.injectState(StateHandle stateHandle) |
| Modifier and Type | Class and Description |
|---|---|
class |
LocalStateHandle
A StateHandle that includes a copy of the state itself.
|
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.