public class RCFileBlockMergeRecordReader
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
Constructor and Description |
---|
RCFileBlockMergeRecordReader(Configuration conf,
FileSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
RCFileKeyBufferWrapper |
createKey() |
RCFileValueBufferWrapper |
createValue() |
java.lang.Class<?> |
getKeyClass() |
long |
getPos() |
float |
getProgress()
Return the progress within the input split.
|
long |
getStart() |
java.lang.Class<?> |
getValueClass() |
boolean |
next(RCFileKeyBufferWrapper key,
RCFileValueBufferWrapper value) |
protected boolean |
nextBlock(RCFileKeyBufferWrapper keyWrapper,
RCFileValueBufferWrapper valueWrapper) |
protected void |
seek(long pos) |
public RCFileBlockMergeRecordReader(Configuration conf, FileSplit split) throws java.io.IOException
java.io.IOException
public java.lang.Class<?> getKeyClass()
public java.lang.Class<?> getValueClass()
public RCFileKeyBufferWrapper createKey()
public RCFileValueBufferWrapper createValue()
public boolean next(RCFileKeyBufferWrapper key, RCFileValueBufferWrapper value) throws java.io.IOException
java.io.IOException
protected boolean nextBlock(RCFileKeyBufferWrapper keyWrapper, RCFileValueBufferWrapper valueWrapper) 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
protected void seek(long pos) throws java.io.IOException
java.io.IOException
public long getStart()
public void close() throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation