Package org.apache.hadoop.yarn.server.nodemanager.api.impl.pb

Class NMProtoUtils

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.api.impl.pb.NMProtoUtils

public final class NMProtoUtils
extends Object

Utilities for converting from PB representations.

Method Summary

Modifier and Type	Method	Description
static DeletionTask	convertProtoToDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService)	Convert the Protobuf representation into a DeletionTask.
static DeletionTaskRecoveryInfo	convertProtoToDeletionTaskRecoveryInfo(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService)	Convert the Protobuf representation to the DeletionTaskRecoveryInfo representation.
static DockerContainerDeletionTask	convertProtoToDockerContainerDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService, int taskId)	Convert the Protobuf format into the DockerContainerDeletionTask.
static FileDeletionTask	convertProtoToFileDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService, int taskId)	Convert the Protobuf representation into the FileDeletionTask.

Methods inherited from class java.lang.Object

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

Method Details

convertProtoToDeletionTask

public static DeletionTask convertProtoToDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto,
 DeletionService deletionService)

Convert the Protobuf representation into a DeletionTask.

Parameters:

proto - the Protobuf representation for the DeletionTask

deletionService - the DeletionService

Returns:

the converted DeletionTask

convertProtoToFileDeletionTask

public static FileDeletionTask convertProtoToFileDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto,
 DeletionService deletionService,
 int taskId)

Convert the Protobuf representation into the FileDeletionTask.

Parameters:

proto - the Protobuf representation of the FileDeletionTask.

deletionService - the DeletionService.

taskId - the ID of the DeletionTask.

Returns:

the populated FileDeletionTask.

convertProtoToDockerContainerDeletionTask

public static DockerContainerDeletionTask convertProtoToDockerContainerDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto,
 DeletionService deletionService,
 int taskId)

Convert the Protobuf format into the DockerContainerDeletionTask.

Parameters:

proto - Protobuf format of the DockerContainerDeletionTask.

deletionService - the DeletionService.

taskId - the ID of the DeletionTask.

Returns:

the populated DockerContainerDeletionTask.

convertProtoToDeletionTaskRecoveryInfo

public static DeletionTaskRecoveryInfo convertProtoToDeletionTaskRecoveryInfo(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto,
 DeletionService deletionService)

Convert the Protobuf representation to the DeletionTaskRecoveryInfo representation.

Parameters:

proto - the Protobuf representation of the DeletionTask

deletionService - the DeletionService

Returns:

the populated DeletionTaskRecoveryInfo