public static class CleanupQueue.PathDeletionContext
extends java.lang.Object
Constructor and Description |
---|
CleanupQueue.PathDeletionContext(org.apache.hadoop.fs.Path fullPath,
org.apache.hadoop.conf.Configuration conf) |
CleanupQueue.PathDeletionContext(org.apache.hadoop.fs.Path fullPath,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.security.UserGroupInformation ugi,
JobID jobIdTokenRenewalToCancel,
org.apache.hadoop.fs.FileSystem fs)
PathDeletionContext ctor which also allows for a job-delegation token
renewal to be cancelled.
|
Modifier and Type | Method and Description |
---|---|
protected void |
deletePath()
Deletes the path (and its subdirectories recursively)
|
protected org.apache.hadoop.fs.Path |
getPathForCleanup() |
java.lang.String |
toString() |
public CleanupQueue.PathDeletionContext(org.apache.hadoop.fs.Path fullPath, org.apache.hadoop.conf.Configuration conf)
public CleanupQueue.PathDeletionContext(org.apache.hadoop.fs.Path fullPath, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.UserGroupInformation ugi, JobID jobIdTokenRenewalToCancel, org.apache.hadoop.fs.FileSystem fs)
fullPath
- path to be deletedconf
- job configurationugi
- ugi of the job to be used to delete the pathjobIdTokenRenewalToCancel
- jobId of the job whose job-delegation
token renewal should be cancelled. No
cancellation is attempted if this is
null
protected org.apache.hadoop.fs.Path getPathForCleanup()
protected void deletePath() throws java.io.IOException, java.lang.InterruptedException
IOException,
- InterruptedExceptionjava.io.IOException
java.lang.InterruptedException
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2009 The Apache Software Foundation