K
- V
- public class RCFileRecordReader<K extends LongWritable,V extends BytesRefArrayWritable>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
Constructor and Description |
---|
RCFileRecordReader(Configuration conf,
FileSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
LongWritable |
createKey() |
BytesRefArrayWritable |
createValue() |
RCFile.KeyBuffer |
getKeyBuffer() |
java.lang.Class<?> |
getKeyClass() |
long |
getPos() |
float |
getProgress()
Return the progress within the input split.
|
long |
getStart() |
java.lang.Class<?> |
getValueClass() |
protected boolean |
next(LongWritable key) |
boolean |
next(LongWritable key,
BytesRefArrayWritable value) |
boolean |
nextBlock() |
void |
resetBuffer() |
protected void |
seek(long pos) |
void |
sync(long pos) |
public RCFileRecordReader(Configuration conf, FileSplit split) throws java.io.IOException
java.io.IOException
public java.lang.Class<?> getKeyClass()
public java.lang.Class<?> getValueClass()
public LongWritable createKey()
public BytesRefArrayWritable createValue()
public boolean nextBlock() throws java.io.IOException
java.io.IOException
public boolean next(LongWritable key, BytesRefArrayWritable value) throws java.io.IOException
java.io.IOException
protected boolean next(LongWritable key) throws java.io.IOException
java.io.IOException
public float getProgress() throws java.io.IOException
java.io.IOException
public long getPos() throws java.io.IOException
java.io.IOException
public RCFile.KeyBuffer getKeyBuffer()
protected void seek(long pos) throws java.io.IOException
java.io.IOException
public void sync(long pos) throws java.io.IOException
java.io.IOException
public void resetBuffer()
public long getStart()
public void close() throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation