Package org.apache.storm.hdfs.common
Class HdfsUtils
java.lang.Object
org.apache.storm.hdfs.common.HdfsUtils
- 
Nested Class SummaryNested Classes
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic 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.FSDataOutputStreamtryCreateFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file) Returns null if file already exists.
- 
Constructor Details- 
HdfsUtilspublic HdfsUtils()
 
- 
- 
Method Details- 
listFilesByModificationTimepublic 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
 
- 
tryCreateFilepublic 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
 
 
-