| Package | Description |
|---|---|
| org.apache.flink.runtime.accumulators | |
| org.apache.flink.runtime.checkpoint | |
| org.apache.flink.runtime.client | |
| org.apache.flink.runtime.deployment | |
| org.apache.flink.runtime.executiongraph | |
| org.apache.flink.runtime.jobmanager.accumulators | |
| 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. |
| Modifier and Type | Class and Description |
|---|---|
class |
AccumulatorEvent
This class encapsulates a map of accumulators for a single job.
|
| Modifier and Type | Method and Description |
|---|---|
SerializedValue<StateHandle<?>> |
StateForTask.getState() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
PendingCheckpoint.acknowledgeTask(ExecutionAttemptID attemptID,
SerializedValue<StateHandle<?>> state) |
| Constructor and Description |
|---|
StateForTask(SerializedValue<StateHandle<?>> state,
JobVertexID operatorId,
int subtask) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,SerializedValue<Object>> |
SerializedJobExecutionResult.getSerializedAccumulatorResults() |
| Constructor and Description |
|---|
SerializedJobExecutionResult(org.apache.flink.api.common.JobID jobID,
long netRuntime,
Map<String,SerializedValue<Object>> accumulators)
Creates a new SerializedJobExecutionResult.
|
| Modifier and Type | Method and Description |
|---|---|
SerializedValue<StateHandle<?>> |
TaskDeploymentDescriptor.getOperatorState() |
| Constructor and Description |
|---|
TaskDeploymentDescriptor(org.apache.flink.api.common.JobID jobID,
JobVertexID vertexID,
ExecutionAttemptID executionId,
String taskName,
int indexInSubtaskGroup,
int numberOfSubtasks,
org.apache.flink.configuration.Configuration jobConfiguration,
org.apache.flink.configuration.Configuration taskConfiguration,
String invokableClassName,
List<ResultPartitionDeploymentDescriptor> producedPartitions,
List<InputGateDeploymentDescriptor> inputGates,
List<BlobKey> requiredJarFiles,
int targetSlotNumber,
SerializedValue<StateHandle<?>> operatorState)
Constructs a task deployment descriptor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Execution.setInitialState(SerializedValue<StateHandle<?>> initialState) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,SerializedValue<Object>> |
AccumulatorManager.getJobAccumulatorResultsSerialized(org.apache.flink.api.common.JobID jobID) |
| Modifier and Type | Method and Description |
|---|---|
SerializedValue<StateHandle<?>> |
AcknowledgeCheckpoint.getState() |
| Constructor and Description |
|---|
AcknowledgeCheckpoint(org.apache.flink.api.common.JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
SerializedValue<StateHandle<?>> state) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.