public static class SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader extends java.lang.Object implements RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
Constructor and Description |
---|
SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader(org.apache.hadoop.conf.Configuration conf,
FileSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this
InputSplit to future operations. |
org.apache.hadoop.io.BytesWritable |
createKey()
Create an object of the appropriate type to be used as a key.
|
org.apache.hadoop.io.BytesWritable |
createValue()
Create an object of the appropriate type to be used as a value.
|
java.lang.String |
getKeyClassName()
Retrieve the name of the key class for this SequenceFile.
|
long |
getPos()
Returns the current position in the input.
|
float |
getProgress()
Return the progress within the input split
|
java.lang.String |
getValueClassName()
Retrieve the name of the value class for this SequenceFile.
|
boolean |
next(org.apache.hadoop.io.BytesWritable key,
org.apache.hadoop.io.BytesWritable val)
Read raw bytes from a SequenceFile.
|
public SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader(org.apache.hadoop.conf.Configuration conf, FileSplit split) throws java.io.IOException
java.io.IOException
public org.apache.hadoop.io.BytesWritable createKey()
RecordReader
createKey
in interface RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
public org.apache.hadoop.io.BytesWritable createValue()
RecordReader
createValue
in interface RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
public java.lang.String getKeyClassName()
SequenceFile.Reader.getKeyClassName()
public java.lang.String getValueClassName()
SequenceFile.Reader.getValueClassName()
public boolean next(org.apache.hadoop.io.BytesWritable key, org.apache.hadoop.io.BytesWritable val) throws java.io.IOException
next
in interface RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
key
- the key to read data intoval
- the value to read data intojava.io.IOException
public long getPos() throws java.io.IOException
RecordReader
getPos
in interface RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public void close() throws java.io.IOException
RecordReader
InputSplit
to future operations.close
in interface RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public float getProgress() throws java.io.IOException
getProgress
in interface RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
java.io.IOException
Copyright © 2009 The Apache Software Foundation