Package org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task

Class DockerContainerDeletionTask

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task.DeletionTask

org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task.DockerContainerDeletionTask

All Implemented Interfaces:

Runnable

public class DockerContainerDeletionTask
extends DeletionTask
implements Runnable

DeletionTask handling the removal of Docker containers.

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task.DeletionTask

INVALID_TASK_ID

Constructor Summary

Constructors

Constructor	Description
DockerContainerDeletionTask(int taskId, DeletionService deletionService, String user, String containerId)
DockerContainerDeletionTask(DeletionService deletionService, String user, String containerId)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task.DeletionTask

addDeletionTaskDependency, decrementAndGetPendingPredecessorTasks, getDeletionService, getDeletionTaskType, getSuccessorTasks, getSucess, getTaskId, getUser, incrementAndGetPendingPredecessorTasks, setSuccess, setTaskId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DockerContainerDeletionTask

public DockerContainerDeletionTask(DeletionService deletionService,
 String user,
 String containerId)

DockerContainerDeletionTask

public DockerContainerDeletionTask(int taskId,
 DeletionService deletionService,
 String user,
 String containerId)

Method Details

getContainerId

public String getContainerId()

Get the id of the container to delete.

Returns:

the id of the container to delete.

run

public void run()

Delete the specified Docker container.

Specified by:

run in interface Runnable

toString

public String toString()

Convert the DockerContainerDeletionTask to a String representation.

Overrides:

toString in class Object

Returns:

String representation of the DockerContainerDeletionTask.

convertDeletionTaskToProto

public org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto convertDeletionTaskToProto()

Convert the DockerContainerDeletionTask to the Protobuf representation for storing in the state store and recovery.

Specified by:

convertDeletionTaskToProto in class DeletionTask

Returns:

the protobuf representation of the DockerContainerDeletionTask.