public class TypedBytesRecordReader extends Object implements RecordReader
Constructor and Description |
---|
TypedBytesRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.Writable |
createRow() |
static Type |
getType(int code) |
void |
initialize(InputStream in,
org.apache.hadoop.conf.Configuration conf,
Properties tbl) |
int |
next(org.apache.hadoop.io.Writable data)
Returns the number of bytes that we consumed.
|
public void initialize(InputStream in, org.apache.hadoop.conf.Configuration conf, Properties tbl) throws IOException
initialize
in interface RecordReader
IOException
public org.apache.hadoop.io.Writable createRow() throws IOException
createRow
in interface RecordReader
IOException
public int next(org.apache.hadoop.io.Writable data) throws IOException
RecordReader
next
in interface RecordReader
IOException
public void close() throws IOException
close
in interface RecordReader
IOException
public static Type getType(int code)
Copyright © 2016 The Apache Software Foundation. All rights reserved.