public class ActorTaskManagerGateway extends Object implements TaskManagerGateway
TaskManagerGateway
for ActorGateway
.Constructor and Description |
---|
ActorTaskManagerGateway(ActorGateway actorGateway) |
Modifier and Type | Method and Description |
---|---|
Future<Acknowledge> |
cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
void |
disconnectFromJobManager(InstanceID instanceId,
Exception cause)
Disconnect the task manager from the job manager.
|
void |
failPartition(ExecutionAttemptID executionAttemptID)
Fail all intermediate result partitions of the given task.
|
ActorGateway |
getActorGateway() |
String |
getAddress()
Return the address of the task manager with which the gateway is associated.
|
void |
notifyCheckpointComplete(ExecutionAttemptID executionAttemptID,
JobID jobId,
long checkpointId,
long timestamp)
Notify the given task about a completed checkpoint.
|
Future<StackTrace> |
requestStackTrace(Time timeout)
Request the stack trace from the task manager.
|
Future<StackTraceSampleResponse> |
requestStackTraceSample(ExecutionAttemptID executionAttemptID,
int sampleId,
int numSamples,
Time delayBetweenSamples,
int maxStackTraceDepth,
Time timeout)
Request a stack trace sample from the given task.
|
Future<BlobKey> |
requestTaskManagerLog(Time timeout)
Request the task manager log from the task manager.
|
Future<BlobKey> |
requestTaskManagerStdout(Time timeout)
Request the task manager stdout from the task manager.
|
void |
stopCluster(ApplicationStatus applicationStatus,
String message)
Stop the cluster.
|
Future<Acknowledge> |
stopTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Stop the given task.
|
Future<Acknowledge> |
submitTask(TaskDeploymentDescriptor tdd,
Time timeout)
Submit a task to the task manager.
|
void |
triggerCheckpoint(ExecutionAttemptID executionAttemptID,
JobID jobId,
long checkpointId,
long timestamp,
CheckpointOptions checkpointOptions)
Trigger for the given task a checkpoint.
|
Future<Acknowledge> |
updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
public ActorTaskManagerGateway(ActorGateway actorGateway)
public ActorGateway getActorGateway()
public String getAddress()
TaskManagerGateway
getAddress
in interface TaskManagerGateway
public void disconnectFromJobManager(InstanceID instanceId, Exception cause)
TaskManagerGateway
disconnectFromJobManager
in interface TaskManagerGateway
instanceId
- identifying the task managercause
- of the disconnectionpublic void stopCluster(ApplicationStatus applicationStatus, String message)
TaskManagerGateway
stopCluster
in interface TaskManagerGateway
applicationStatus
- to stop the cluster withmessage
- to deliverpublic Future<StackTrace> requestStackTrace(Time timeout)
TaskManagerGateway
requestStackTrace
in interface TaskManagerGateway
timeout
- for the stack trace requestpublic Future<StackTraceSampleResponse> requestStackTraceSample(ExecutionAttemptID executionAttemptID, int sampleId, int numSamples, Time delayBetweenSamples, int maxStackTraceDepth, Time timeout)
TaskManagerGateway
requestStackTraceSample
in interface TaskManagerGateway
executionAttemptID
- identifying the task to samplesampleId
- of the samplenumSamples
- to take from the given taskdelayBetweenSamples
- to wait formaxStackTraceDepth
- of the returned sampletimeout
- of the requestpublic Future<Acknowledge> submitTask(TaskDeploymentDescriptor tdd, Time timeout)
TaskManagerGateway
submitTask
in interface TaskManagerGateway
tdd
- describing the task to submittimeout
- of the submit operationpublic Future<Acknowledge> stopTask(ExecutionAttemptID executionAttemptID, Time timeout)
TaskManagerGateway
stopTask
in interface TaskManagerGateway
executionAttemptID
- identifying the tasktimeout
- of the submit operationpublic Future<Acknowledge> cancelTask(ExecutionAttemptID executionAttemptID, Time timeout)
TaskManagerGateway
cancelTask
in interface TaskManagerGateway
executionAttemptID
- identifying the tasktimeout
- of the submit operationpublic Future<Acknowledge> updatePartitions(ExecutionAttemptID executionAttemptID, Iterable<PartitionInfo> partitionInfos, Time timeout)
TaskManagerGateway
updatePartitions
in interface TaskManagerGateway
executionAttemptID
- identifying the taskpartitionInfos
- telling where the partition can be retrieved fromtimeout
- of the submit operationpublic void failPartition(ExecutionAttemptID executionAttemptID)
TaskManagerGateway
failPartition
in interface TaskManagerGateway
executionAttemptID
- identifying the taskpublic void notifyCheckpointComplete(ExecutionAttemptID executionAttemptID, JobID jobId, long checkpointId, long timestamp)
TaskManagerGateway
notifyCheckpointComplete
in interface TaskManagerGateway
executionAttemptID
- identifying the taskjobId
- identifying the job to which the task belongscheckpointId
- of the completed checkpointtimestamp
- of the completed checkpointpublic void triggerCheckpoint(ExecutionAttemptID executionAttemptID, JobID jobId, long checkpointId, long timestamp, CheckpointOptions checkpointOptions)
TaskManagerGateway
triggerCheckpoint
in interface TaskManagerGateway
executionAttemptID
- identifying the taskjobId
- identifying the job to which the task belongscheckpointId
- of the checkpoint to triggertimestamp
- of the checkpoint to triggercheckpointOptions
- of the checkpoint to triggerpublic Future<BlobKey> requestTaskManagerLog(Time timeout)
TaskManagerGateway
requestTaskManagerLog
in interface TaskManagerGateway
timeout
- for the requestpublic Future<BlobKey> requestTaskManagerStdout(Time timeout)
TaskManagerGateway
requestTaskManagerStdout
in interface TaskManagerGateway
timeout
- for the requestCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.