public class RCFileMapReduceRecordReader<K extends LongWritable,V extends BytesRefArrayWritable>
extends <any>
Constructor and Description |
---|
RCFileMapReduceRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
LongWritable |
getCurrentKey() |
BytesRefArrayWritable |
getCurrentValue() |
float |
getProgress() |
void |
initialize(InputSplit split,
TaskAttemptContext context) |
boolean |
nextKeyValue() |
public void close() throws java.io.IOException
java.io.IOException
public LongWritable getCurrentKey() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public BytesRefArrayWritable getCurrentValue() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public float getProgress() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public boolean nextKeyValue() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void initialize(InputSplit split, TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
Copyright © 2012 The Apache Software Foundation