public class RCFileBlockMergeRecordReader extends Object implements org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
conf |
Constructor and Description |
---|
RCFileBlockMergeRecordReader(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapred.FileSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
RCFileKeyBufferWrapper |
createKey() |
RCFileValueBufferWrapper |
createValue() |
Class<?> |
getKeyClass() |
long |
getPos() |
float |
getProgress()
Return the progress within the input split.
|
long |
getStart() |
Class<?> |
getValueClass() |
boolean |
next(RCFileKeyBufferWrapper key,
RCFileValueBufferWrapper value) |
protected boolean |
nextBlock(RCFileKeyBufferWrapper keyWrapper,
RCFileValueBufferWrapper valueWrapper) |
protected void |
seek(long pos) |
public RCFileBlockMergeRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split) throws IOException
IOException
public Class<?> getKeyClass()
public Class<?> getValueClass()
public RCFileKeyBufferWrapper createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>
public RCFileValueBufferWrapper createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>
public boolean next(RCFileKeyBufferWrapper key, RCFileValueBufferWrapper value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>
IOException
protected boolean nextBlock(RCFileKeyBufferWrapper keyWrapper, RCFileValueBufferWrapper valueWrapper) throws IOException
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>
IOException
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>
IOException
protected void seek(long pos) throws IOException
IOException
public long getStart()
public void close() throws IOException
close
in interface org.apache.hadoop.mapred.RecordReader<RCFileKeyBufferWrapper,RCFileValueBufferWrapper>
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.