Package org.apache.storm.hdfs.spout
Class TextFileReader
java.lang.Object
org.apache.storm.hdfs.spout.TextFileReader
- 
Nested Class SummaryNested Classes
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionTextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf) TextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf, String startOffset) 
- 
Method Summary
- 
Field Details- 
defaultFields
- 
CHARSET- See Also:
 
- 
BUFFER_SIZE- See Also:
 
 
- 
- 
Constructor Details- 
TextFileReaderpublic TextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf) throws IOException- Throws:
- IOException
 
- 
TextFileReaderpublic TextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf, String startOffset) throws IOException- Throws:
- IOException
 
 
- 
- 
Method Details- 
getFileOffset
- 
next- Throws:
- IOException
- ParseException
 
- 
closepublic void close()
- 
getFilePathpublic org.apache.hadoop.fs.Path getFilePath()
- 
equals
- 
hashCodepublic int hashCode()
 
-