public class DeletionService
extends org.apache.hadoop.service.AbstractService
Modifier and Type | Class and Description |
---|---|
static class |
DeletionService.FileDeletionTask |
Constructor and Description |
---|
DeletionService(ContainerExecutor exec) |
DeletionService(ContainerExecutor exec,
NMStateStoreService stateStore) |
Modifier and Type | Method and Description |
---|---|
DeletionService.FileDeletionTask |
createFileDeletionTask(String user,
org.apache.hadoop.fs.Path subDir,
org.apache.hadoop.fs.Path[] baseDirs)
Helper method to create file deletion task.
|
void |
delete(String user,
org.apache.hadoop.fs.Path subDir,
org.apache.hadoop.fs.Path... baseDirs)
Delete the path(s) as this user.
|
boolean |
isTerminated()
Determine if the service has completely stopped.
|
void |
scheduleFileDeletionTask(DeletionService.FileDeletionTask fileDeletionTask) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStop() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceStart, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public DeletionService(ContainerExecutor exec)
public DeletionService(ContainerExecutor exec, NMStateStoreService stateStore)
public void delete(String user, org.apache.hadoop.fs.Path subDir, org.apache.hadoop.fs.Path... baseDirs)
user
- The user to delete as, or the JVM user if nullsubDir
- the sub directory namebaseDirs
- the base directories which contains the subDir'spublic void scheduleFileDeletionTask(DeletionService.FileDeletionTask fileDeletionTask)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
@InterfaceAudience.Private public boolean isTerminated()
public DeletionService.FileDeletionTask createFileDeletionTask(String user, org.apache.hadoop.fs.Path subDir, org.apache.hadoop.fs.Path[] baseDirs)
user
- user on whose behalf this task is suppose to runsubDir
- sub directory as required in
delete(String, Path, Path...)
baseDirs
- base directories as required in
delete(String, Path, Path...)
Copyright © 2018 Apache Software Foundation. All Rights Reserved.