Package org.apache.storm.hdfs.common

Class HdfsUtils

java.lang.Object

org.apache.storm.hdfs.common.HdfsUtils

public class HdfsUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HdfsUtils.Pair<K,V>

Constructor Summary

Constructors

Constructor	Description
HdfsUtils()

Method Summary

Modifier and Type	Method	Description
static ArrayList<org.apache.hadoop.fs.Path>	listFilesByModificationTime(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path directory, long olderThan)	list files sorted by modification time that have not been modified since 'olderThan'.
static org.apache.hadoop.fs.FSDataOutputStream	tryCreateFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file)	Returns null if file already exists.

Methods inherited from class java.lang.Object

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

Constructor Details

HdfsUtils

public HdfsUtils()

Method Details

listFilesByModificationTime

public static ArrayList<org.apache.hadoop.fs.Path> listFilesByModificationTime(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path directory,
 long olderThan)
                                                                        throws IOException

list files sorted by modification time that have not been modified since 'olderThan'. if 'olderThan' is <= 0 then the filtering is disabled

Throws:

IOException

tryCreateFile

public static org.apache.hadoop.fs.FSDataOutputStream tryCreateFile(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path file)
                                                             throws IOException

Returns null if file already exists. throws if there was unexpected problem

Throws:

IOException