Package org.apache.storm.hdfs.spout
Class SequenceFileReader<KeyT extends org.apache.hadoop.io.Writable,ValueT extends org.apache.hadoop.io.Writable> 
java.lang.Object
org.apache.storm.hdfs.spout.SequenceFileReader<KeyT,ValueT> 
public class SequenceFileReader<KeyT extends org.apache.hadoop.io.Writable,ValueT extends org.apache.hadoop.io.Writable> 
extends Object
- 
Nested Class SummaryNested Classes
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionSequenceFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf) SequenceFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf, String offset) 
- 
Method Summary
- 
Field Details- 
defaultFields
- 
BUFFER_SIZE- See Also:
 
 
- 
- 
Constructor Details- 
SequenceFileReaderpublic SequenceFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf) throws IOException- Throws:
- IOException
 
- 
SequenceFileReaderpublic SequenceFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String, Object> conf, String offset) throws IOException- Throws:
- IOException
 
 
- 
- 
Method Details- 
next- Throws:
- IOException
- ParseException
 
- 
closepublic void close()
- 
getFileOffset
- 
getFilePathpublic org.apache.hadoop.fs.Path getFilePath()
- 
equals
- 
hashCodepublic int hashCode()
 
-