public class BinaryRecordReader extends java.lang.Object implements RecordReader
Constructor and Description |
---|
BinaryRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Writable |
createRow() |
void |
initialize(java.io.InputStream in,
Configuration conf,
java.util.Properties tbl) |
int |
next(Writable row)
Returns the number of bytes that we consumed.
|
public void initialize(java.io.InputStream in, Configuration conf, java.util.Properties tbl) throws java.io.IOException
initialize
in interface RecordReader
java.io.IOException
public Writable createRow() throws java.io.IOException
createRow
in interface RecordReader
java.io.IOException
public int next(Writable row) throws java.io.IOException
RecordReader
next
in interface RecordReader
java.io.IOException
public void close() throws java.io.IOException
close
in interface RecordReader
java.io.IOException
Copyright © 2012 The Apache Software Foundation