| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
TaskDeploymentDescriptor.getExecutionId() |
| 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)
Constructs a task deployment descriptor.
|
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 |
|---|---|
void |
LibraryCacheManager.registerTask(JobID id,
ExecutionAttemptID execution,
Collection<BlobKey> requiredJarFiles)
Registers a job task execution with its required jar files.
|
void |
FallbackLibraryCacheManager.registerTask(JobID id,
ExecutionAttemptID execution,
Collection<BlobKey> requiredJarFiles) |
void |
BlobLibraryCacheManager.registerTask(JobID jobId,
ExecutionAttemptID task,
Collection<BlobKey> requiredJarFiles) |
void |
LibraryCacheManager.unregisterTask(JobID id,
ExecutionAttemptID execution)
Unregisters a job from the library cache manager.
|
void |
FallbackLibraryCacheManager.unregisterTask(JobID id,
ExecutionAttemptID execution) |
void |
BlobLibraryCacheManager.unregisterTask(JobID jobId,
ExecutionAttemptID task) |
| 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 | 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) |
| Constructor and Description |
|---|
ResultPartitionID(IntermediateResultPartitionID partitionId,
ExecutionAttemptID producerId) |
| Modifier and Type | Method and Description |
|---|---|
void |
TaskManagerProfiler.unregisterTask(ExecutionAttemptID id)
Unregisters all previously registered
Task
objects for the vertex identified by the given ID. |
| Constructor and Description |
|---|
EnvironmentThreadSet(ThreadMXBean tmx,
Thread mainThread,
JobVertexID vertexId,
int subtask,
ExecutionAttemptID executionId) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
InternalExecutionVertexProfilingData.getExecutionAttemptId() |
| Constructor and Description |
|---|
InternalExecutionVertexProfilingData(JobID jobId,
JobVertexID vertexId,
int subtask,
ExecutionAttemptID executionId) |
InternalExecutionVertexThreadProfilingData(JobID jobID,
JobVertexID vertexId,
int subtask,
ExecutionAttemptID executionId,
int profilingInterval,
int userTime,
int systemTime,
int blockedTime,
int waitedTime) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
VertexProfilingEvent.getExecutionId() |
| Constructor and Description |
|---|
ThreadProfilingEvent(int userTime,
int systemTime,
int blockedTime,
int waitedTime,
JobVertexID vertexId,
int subtask,
ExecutionAttemptID executionId,
int profilingInterval,
JobID jobID,
long timestamp,
long profilingTimestamp) |
VertexProfilingEvent(JobVertexID vertexId,
int subtask,
ExecutionAttemptID executionId,
int profilingInterval,
JobID jobID,
long timestamp,
long profilingTimestamp) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttemptID |
Task.getExecutionId()
Gets the ID of the execution attempt.
|
ExecutionAttemptID |
TaskExecutionState.getID()
Returns the ID of the task this result belongs to
|
| Constructor and Description |
|---|
Task(JobID jobId,
JobVertexID vertexId,
int taskIndex,
int parallelism,
ExecutionAttemptID executionId,
String taskName,
akka.actor.ActorRef taskManager) |
TaskExecutionState(JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState)
Creates a new task execution state update, with no attached exception.
|
TaskExecutionState(JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error)
Creates a new task execution state update, with an attached exception.
|
TaskInputSplitProvider(akka.actor.ActorRef jobManager,
JobID jobId,
JobVertexID vertexId,
ExecutionAttemptID executionID,
ClassLoader userCodeClassLoader,
akka.util.Timeout timeout) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.