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 IOException, InterruptedException
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
IOException
InterruptedException
public NullWritable getCurrentKey() throws IOException, InterruptedException
IOException
InterruptedException
public PerformanceEvaluation.PeInputSplit getCurrentValue() throws IOException, InterruptedException
IOException
InterruptedException
public float getProgress() throws IOException, InterruptedException
IOException
InterruptedException
public void close() throws IOException
IOException