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<String,Object> conf)
SequenceFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String,Object> 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<String,Object> conf)
                   throws IOException

Throws:

IOException

SequenceFileReader

public SequenceFileReader(org.apache.hadoop.fs.FileSystem fs,
                          org.apache.hadoop.fs.Path file,
                          Map<String,Object> 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