| Package | Description |
|---|---|
| org.apache.flink.runtime.checkpoint | |
| org.apache.flink.runtime.deployment | |
| org.apache.flink.runtime.execution | |
| org.apache.flink.runtime.execution.librarycache | |
| org.apache.flink.runtime.executiongraph | |
| org.apache.flink.runtime.io.network.netty | |
| org.apache.flink.runtime.io.network.partition | |
| org.apache.flink.runtime.io.network.partition.consumer | |
| 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.taskmanager |
| Modifier and Type | Method and Description |
|---|---|
boolean |
PendingCheckpoint.acknowledgeTask(ExecutionAttemptID attemptID,
SerializedValue<StateHandle<?>> state) |
| Constructor and Description |
|---|
PendingCheckpoint(org.apache.flink.api.common.JobID jobId,
long checkpointId,
long checkpointTimestamp,
Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
TaskDeploymentDescriptor.getExecutionId() |
| 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) |
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 |
|---|---|
ExecutionAttemptID |
Environment.getExecutionId()
Gets the ID of the task execution attempt.
|
| Modifier and Type | Method and Description |
|---|---|
void |
BlobLibraryCacheManager.registerTask(org.apache.flink.api.common.JobID jobId,
ExecutionAttemptID task,
Collection<BlobKey> requiredJarFiles) |
void |
FallbackLibraryCacheManager.registerTask(org.apache.flink.api.common.JobID id,
ExecutionAttemptID execution,
Collection<BlobKey> requiredJarFiles) |
void |
LibraryCacheManager.registerTask(org.apache.flink.api.common.JobID id,
ExecutionAttemptID execution,
Collection<BlobKey> requiredJarFiles)
Registers a job task execution with its required jar files.
|
void |
BlobLibraryCacheManager.unregisterTask(org.apache.flink.api.common.JobID jobId,
ExecutionAttemptID task) |
void |
FallbackLibraryCacheManager.unregisterTask(org.apache.flink.api.common.JobID id,
ExecutionAttemptID execution) |
void |
LibraryCacheManager.unregisterTask(org.apache.flink.api.common.JobID id,
ExecutionAttemptID execution)
Unregisters a job from the library cache manager.
|
| Modifier and Type | Method and Description |
|---|---|
static ExecutionAttemptID |
ExecutionAttemptID.fromByteBuf(io.netty.buffer.ByteBuf buf) |
ExecutionAttemptID |
Execution.getAttemptId() |
| Modifier and Type | Method and Description |
|---|---|
Map<ExecutionAttemptID,Execution> |
ExecutionGraph.getRegisteredExecutions() |
| Modifier and Type | Method and Description |
|---|---|
void |
ExecutionVertex.sendMessageToCurrentExecution(Serializable message,
ExecutionAttemptID attemptID) |
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionStateChecker.triggerPartitionStateCheck(org.apache.flink.api.common.JobID jobId,
ExecutionAttemptID executionId,
IntermediateDataSetID resultId,
ResultPartitionID partitionId) |
| Modifier and Type | Field and Description |
|---|---|
com.google.common.collect.Table<ExecutionAttemptID,IntermediateResultPartitionID,ResultPartition> |
ResultPartitionManager.registeredPartitions |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
ResultPartitionID.getProducerId() |
| Modifier and Type | Method and Description |
|---|---|
void |
ResultPartitionManager.releasePartitionsProducedBy(ExecutionAttemptID executionId) |
void |
ResultPartitionManager.releasePartitionsProducedBy(ExecutionAttemptID executionId,
Throwable cause) |
| Constructor and Description |
|---|
ResultPartitionID(IntermediateResultPartitionID partitionId,
ExecutionAttemptID producerId) |
| Modifier and Type | Method and Description |
|---|---|
static SingleInputGate |
SingleInputGate.create(String owningTaskName,
org.apache.flink.api.common.JobID jobId,
ExecutionAttemptID executionId,
InputGateDeploymentDescriptor igdd,
NetworkEnvironment networkEnvironment)
Creates an input gate and all of its input channels.
|
| Constructor and Description |
|---|
SingleInputGate(String owningTaskName,
org.apache.flink.api.common.JobID jobId,
ExecutionAttemptID executionId,
IntermediateDataSetID consumedResultId,
int consumedSubpartitionIndex,
int numberOfInputChannels,
PartitionStateChecker partitionStateChecker) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
AbstractCheckpointMessage.getTaskExecutionId() |
| Constructor and Description |
|---|
AbstractCheckpointMessage(org.apache.flink.api.common.JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId) |
AcknowledgeCheckpoint(org.apache.flink.api.common.JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId) |
AcknowledgeCheckpoint(org.apache.flink.api.common.JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
SerializedValue<StateHandle<?>> state) |
ConfirmCheckpoint(org.apache.flink.api.common.JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
long timestamp) |
TriggerCheckpoint(org.apache.flink.api.common.JobID job,
ExecutionAttemptID taskExecutionId,
long checkpointId,
long timestamp) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
Task.getExecutionId() |
ExecutionAttemptID |
RuntimeEnvironment.getExecutionId() |
ExecutionAttemptID |
TaskExecutionState.getID()
Returns the ID of the task this result belongs to
|
| Modifier and Type | Method and Description |
|---|---|
static String |
Task.getTaskNameWithSubtaskAndID(String name,
int subtask,
int numSubtasks,
ExecutionAttemptID id) |
| Constructor and Description |
|---|
RuntimeEnvironment(org.apache.flink.api.common.JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
String taskName,
String taskNameWithSubtasks,
int subtaskIndex,
int parallelism,
org.apache.flink.configuration.Configuration jobConfiguration,
org.apache.flink.configuration.Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
InputSplitProvider splitProvider,
Map<String,Future<org.apache.flink.core.fs.Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
akka.actor.ActorRef jobManagerActor) |
TaskExecutionState(org.apache.flink.api.common.JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState)
Creates a new task execution state update, with no attached exception.
|
TaskExecutionState(org.apache.flink.api.common.JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error)
Creates a new task execution state update, with an attached exception.
|
TaskInputSplitProvider(akka.actor.ActorRef jobManager,
org.apache.flink.api.common.JobID jobId,
JobVertexID vertexId,
ExecutionAttemptID executionID,
ClassLoader userCodeClassLoader,
akka.util.Timeout timeout) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.