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.

Author:

"Matthew Hayes"

Constructor Summary

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

Method Summary

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 -

Returns:

added path

add

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

Add a path to be removed later.

Parameters:

path -

Returns:

added path

clean

public void clean()
           throws java.io.IOException

Removes added paths from the file system.

Throws:

java.io.IOException