public class DockerContainerDeletionTask extends DeletionTask implements Runnable
DeletionTask
handling the removal of Docker containers.INVALID_TASK_ID
Constructor and Description |
---|
DockerContainerDeletionTask(DeletionService deletionService,
String user,
String containerId) |
DockerContainerDeletionTask(int taskId,
DeletionService deletionService,
String user,
String containerId) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto |
convertDeletionTaskToProto()
Convert the DockerContainerDeletionTask to the Protobuf representation for
storing in the state store and recovery.
|
String |
getContainerId()
Get the id of the container to delete.
|
void |
run()
Delete the specified Docker container.
|
String |
toString()
Convert the DockerContainerDeletionTask to a String representation.
|
addDeletionTaskDependency, decrementAndGetPendingPredecessorTasks, getDeletionService, getDeletionTaskType, getSuccessorTasks, getSucess, getTaskId, getUser, incrementAndGetPendingPredecessorTasks, setSuccess, setTaskId
public DockerContainerDeletionTask(DeletionService deletionService, String user, String containerId)
public DockerContainerDeletionTask(int taskId, DeletionService deletionService, String user, String containerId)
public String getContainerId()
public void run()
public String toString()
public org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto convertDeletionTaskToProto()
convertDeletionTaskToProto
in class DeletionTask
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.