Uses of Class
org.apache.hadoop.yarn.server.nodemanager.DeletionService
Packages that use DeletionService
Package
Description
Package containing classes for working with Protobuf.
Package containing DeletionTasks for use with the DeletionService.
-
Uses of DeletionService in org.apache.hadoop.yarn.server.nodemanager
Methods in org.apache.hadoop.yarn.server.nodemanager that return DeletionServiceModifier and TypeMethodDescriptionprotected DeletionServiceNodeManager.createDeletionService(ContainerExecutor exec) Context.getDeletionService()Get theDeletionServiceassociated with the NM.NodeManager.NMContext.getDeletionService()Return the NM'sDeletionService.Methods in org.apache.hadoop.yarn.server.nodemanager with parameters of type DeletionServiceModifier and TypeMethodDescriptionprotected ContainerManagerImplNodeManager.createContainerManager(Context context, ContainerExecutor exec, DeletionService del, NodeStatusUpdater nodeStatusUpdater, org.apache.hadoop.yarn.server.security.ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler) voidNodeManager.NMContext.setDeletionService(DeletionService deletionService) Set the NM'sDeletionService. -
Uses of DeletionService in org.apache.hadoop.yarn.server.nodemanager.api.impl.pb
Methods in org.apache.hadoop.yarn.server.nodemanager.api.impl.pb with parameters of type DeletionServiceModifier and TypeMethodDescriptionstatic DeletionTaskNMProtoUtils.convertProtoToDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService) Convert the Protobuf representation into aDeletionTask.static DeletionTaskRecoveryInfoNMProtoUtils.convertProtoToDeletionTaskRecoveryInfo(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService) Convert the Protobuf representation to theDeletionTaskRecoveryInforepresentation.static DockerContainerDeletionTaskNMProtoUtils.convertProtoToDockerContainerDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService, int taskId) Convert the Protobuf format into theDockerContainerDeletionTask.static FileDeletionTaskNMProtoUtils.convertProtoToFileDeletionTask(org.apache.hadoop.yarn.proto.YarnServerNodemanagerRecoveryProtos.DeletionServiceDeleteTaskProto proto, DeletionService deletionService, int taskId) Convert the Protobuf representation into theFileDeletionTask. -
Uses of DeletionService in org.apache.hadoop.yarn.server.nodemanager.containermanager
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager with parameters of type DeletionServiceModifier and TypeMethodDescriptionprotected LogHandlerContainerManagerImpl.createLogHandler(org.apache.hadoop.conf.Configuration conf, Context context, DeletionService deletionService) protected ResourceLocalizationServiceContainerManagerImpl.createResourceLocalizationService(ContainerExecutor exec, DeletionService deletionContext, Context nmContext, NodeManagerMetrics nmMetrics) Constructors in org.apache.hadoop.yarn.server.nodemanager.containermanager with parameters of type DeletionServiceModifierConstructorDescriptionContainerManagerImpl(Context context, ContainerExecutor exec, DeletionService deletionContext, NodeStatusUpdater nodeStatusUpdater, NodeManagerMetrics metrics, LocalDirsHandlerService dirsHandler) -
Uses of DeletionService in org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task that return DeletionServiceModifier and TypeMethodDescriptionDeletionTask.getDeletionService()Get theDeletionServicefor this DeletionTask.Constructors in org.apache.hadoop.yarn.server.nodemanager.containermanager.deletion.task with parameters of type DeletionServiceModifierConstructorDescriptionDeletionTask(int taskId, DeletionService deletionService, String user, AtomicInteger numberOfPendingPredecessorTasks, Set<DeletionTask> successorTaskSet, DeletionTaskType deletionTaskType) Deletion task with taskId and user supplied values.DeletionTask(int taskId, DeletionService deletionService, String user, DeletionTaskType deletionTaskType) Deletion task with taskId and default values.DockerContainerDeletionTask(int taskId, DeletionService deletionService, String user, String containerId) DockerContainerDeletionTask(DeletionService deletionService, String user, String containerId) FileDeletionTask(int taskId, DeletionService deletionService, String user, org.apache.hadoop.fs.Path subDir, List<org.apache.hadoop.fs.Path> baseDirs) Construct a FileDeletionTask with the default INVALID_TASK_ID.FileDeletionTask(DeletionService deletionService, String user, org.apache.hadoop.fs.Path subDir, List<org.apache.hadoop.fs.Path> baseDirs) Construct a FileDeletionTask with the default INVALID_TASK_ID. -
Uses of DeletionService in org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer
Constructors in org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer with parameters of type DeletionServiceModifierConstructorDescriptionResourceLocalizationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher, ContainerExecutor exec, DeletionService delService, LocalDirsHandlerService dirsHandler, Context context, NodeManagerMetrics metrics) -
Uses of DeletionService in org.apache.hadoop.yarn.server.nodemanager.containermanager.logaggregation
Constructors in org.apache.hadoop.yarn.server.nodemanager.containermanager.logaggregation with parameters of type DeletionServiceModifierConstructorDescriptionAppLogAggregatorImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher, DeletionService deletionService, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.UserGroupInformation userUgi, org.apache.hadoop.yarn.api.records.NodeId nodeId, LocalDirsHandlerService dirsHandler, org.apache.hadoop.fs.Path remoteNodeLogFileForApp, Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType, String> appAcls, org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext, Context context, org.apache.hadoop.fs.FileContext lfs, long rollingMonitorInterval) AppLogAggregatorImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher, DeletionService deletionService, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.UserGroupInformation userUgi, org.apache.hadoop.yarn.api.records.NodeId nodeId, LocalDirsHandlerService dirsHandler, org.apache.hadoop.fs.Path remoteNodeLogFileForApp, Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType, String> appAcls, org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext, Context context, org.apache.hadoop.fs.FileContext lfs, long rollingMonitorInterval, long recoveredLogInitedTime) AppLogAggregatorImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher, DeletionService deletionService, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.UserGroupInformation userUgi, org.apache.hadoop.yarn.api.records.NodeId nodeId, LocalDirsHandlerService dirsHandler, org.apache.hadoop.fs.Path remoteNodeLogFileForApp, Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType, String> appAcls, org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext, Context context, org.apache.hadoop.fs.FileContext lfs, long rollingMonitorInterval, long recoveredLogInitedTime, org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileController logAggregationFileController) LogAggregationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher, Context context, DeletionService deletionService, LocalDirsHandlerService dirsHandler) -
Uses of DeletionService in org.apache.hadoop.yarn.server.nodemanager.containermanager.loghandler
Constructors in org.apache.hadoop.yarn.server.nodemanager.containermanager.loghandler with parameters of type DeletionServiceModifierConstructorDescriptionNonAggregatingLogHandler(org.apache.hadoop.yarn.event.Dispatcher dispatcher, DeletionService delService, LocalDirsHandlerService dirsHandler, NMStateStoreService stateStore)