datafu.hourglass.jobs

Class FileCleaner

java.lang.Object

datafu.hourglass.jobs.FileCleaner

public class FileCleaner
extends java.lang.Object

Used to remove files from the file system when they are no longer needed.

Constructor Summary

Constructors

Constructor and Description
FileCleaner(org.apache.hadoop.fs.FileSystem fs)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.fs.Path	add(org.apache.hadoop.fs.Path path) Add a path to be removed later.
java.lang.String	add(java.lang.String path) Add a path to be removed later.
void	clean() Removes added paths from the file system.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileCleaner

public FileCleaner(org.apache.hadoop.fs.FileSystem fs)

Method Detail

add

public org.apache.hadoop.fs.Path add(org.apache.hadoop.fs.Path path)

Add a path to be removed later.

Parameters:

path - path to be removed later

Returns:

added path

add

public java.lang.String add(java.lang.String path)

Add a path to be removed later.

Parameters:

path - path to be removed later

Returns:

added path

clean

public void clean()
           throws java.io.IOException

Removes added paths from the file system.

Throws:

java.io.IOException - IOException