public static class PerformanceEvaluation.PeInputFormat.PeRecordReader
extends <any>
Constructor and Description |
---|
PeRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
NullWritable |
getCurrentKey() |
PerformanceEvaluation.PeInputSplit |
getCurrentValue() |
float |
getProgress() |
void |
initialize(InputSplit split,
TaskAttemptContext context) |
boolean |
nextKeyValue() |
public void initialize(InputSplit split, TaskAttemptContext context) 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 NullWritable getCurrentKey() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public PerformanceEvaluation.PeInputSplit 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 void close() throws java.io.IOException
java.io.IOException