public interface TaskManagerGateway
Modifier and Type | Method and Description |
---|---|
CompletableFuture<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.
|
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.
|
CompletableFuture<StackTrace> |
requestStackTrace(Time timeout)
Request the stack trace from the task manager.
|
CompletableFuture<StackTraceSampleResponse> |
requestStackTraceSample(ExecutionAttemptID executionAttemptID,
int sampleId,
int numSamples,
Time delayBetweenSamples,
int maxStackTraceDepth,
Time timeout)
Request a stack trace sample from the given task.
|
CompletableFuture<TransientBlobKey> |
requestTaskManagerLog(Time timeout)
Request the task manager log from the task manager.
|
CompletableFuture<TransientBlobKey> |
requestTaskManagerStdout(Time timeout)
Request the task manager stdout from the task manager.
|
void |
stopCluster(ApplicationStatus applicationStatus,
String message)
Stop the cluster.
|
CompletableFuture<Acknowledge> |
stopTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Stop the given task.
|
CompletableFuture<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.
|
CompletableFuture<Acknowledge> |
updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
String getAddress()
void disconnectFromJobManager(InstanceID instanceId, Exception cause)
instanceId
- identifying the task managercause
- of the disconnectionvoid stopCluster(ApplicationStatus applicationStatus, String message)
applicationStatus
- to stop the cluster withmessage
- to deliverCompletableFuture<StackTrace> requestStackTrace(Time timeout)
timeout
- for the stack trace requestCompletableFuture<StackTraceSampleResponse> requestStackTraceSample(ExecutionAttemptID executionAttemptID, int sampleId, int numSamples, Time delayBetweenSamples, int maxStackTraceDepth, Time timeout)
executionAttemptID
- identifying the task to samplesampleId
- of the samplenumSamples
- to take from the given taskdelayBetweenSamples
- to wait formaxStackTraceDepth
- of the returned sampletimeout
- of the requestCompletableFuture<Acknowledge> submitTask(TaskDeploymentDescriptor tdd, Time timeout)
tdd
- describing the task to submittimeout
- of the submit operationCompletableFuture<Acknowledge> stopTask(ExecutionAttemptID executionAttemptID, Time timeout)
executionAttemptID
- identifying the tasktimeout
- of the submit operationCompletableFuture<Acknowledge> cancelTask(ExecutionAttemptID executionAttemptID, Time timeout)
executionAttemptID
- identifying the tasktimeout
- of the submit operationCompletableFuture<Acknowledge> updatePartitions(ExecutionAttemptID executionAttemptID, Iterable<PartitionInfo> partitionInfos, Time timeout)
executionAttemptID
- identifying the taskpartitionInfos
- telling where the partition can be retrieved fromtimeout
- of the submit operationvoid failPartition(ExecutionAttemptID executionAttemptID)
executionAttemptID
- identifying the taskvoid notifyCheckpointComplete(ExecutionAttemptID executionAttemptID, JobID jobId, long checkpointId, long timestamp)
executionAttemptID
- identifying the taskjobId
- identifying the job to which the task belongscheckpointId
- of the completed checkpointtimestamp
- of the completed checkpointvoid triggerCheckpoint(ExecutionAttemptID executionAttemptID, JobID jobId, long checkpointId, long timestamp, CheckpointOptions checkpointOptions)
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 triggerCompletableFuture<TransientBlobKey> requestTaskManagerLog(Time timeout)
timeout
- for the requestCompletableFuture<TransientBlobKey> requestTaskManagerStdout(Time timeout)
timeout
- for the requestCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.