org.apache.storm.hdfs.spout

Class SequenceFileReader<Key extends org.apache.hadoop.io.Writable,Value extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.storm.hdfs.spout.SequenceFileReader<Key,Value>

public class SequenceFileReader<Key extends org.apache.hadoop.io.Writable,Value extends org.apache.hadoop.io.Writable>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SequenceFileReader.Offset

Field Summary

Fields

Modifier and Type	Field and Description
static String	BUFFER_SIZE
static String[]	defaultFields

Constructor Summary

Constructors

Constructor and Description
SequenceFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map conf)
SequenceFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map conf, String offset)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	equals(Object o)
SequenceFileReader.Offset	getFileOffset()
org.apache.hadoop.fs.Path	getFilePath()
int	hashCode()
List<Object>	next()

Methods inherited from class java.lang.Object

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

Field Detail

defaultFields

public static final String[] defaultFields

BUFFER_SIZE

public static final String BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

SequenceFileReader

public SequenceFileReader(org.apache.hadoop.fs.FileSystem fs,
                          org.apache.hadoop.fs.Path file,
                          Map conf)
                   throws IOException

Throws:

IOException

SequenceFileReader

public SequenceFileReader(org.apache.hadoop.fs.FileSystem fs,
                          org.apache.hadoop.fs.Path file,
                          Map conf,
                          String offset)
                   throws IOException

Throws:

IOException

Method Detail

next

public List<Object> next()
                  throws IOException,
                         ParseException

Throws:

IOException

ParseException

close

public void close()

getFileOffset

public SequenceFileReader.Offset getFileOffset()

getFilePath

public org.apache.hadoop.fs.Path getFilePath()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object