public class StageInputRecordReader
extends org.apache.hadoop.mapreduce.RecordReader
RecordReader
for handling multiple Map operations.Constructor and Description |
---|
StageInputRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Object |
getCurrentKey() |
Object |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) |
boolean |
nextKeyValue() |
public void initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext taskContext) throws IOException, InterruptedException
initialize
in class org.apache.hadoop.mapreduce.RecordReader
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class org.apache.hadoop.mapreduce.RecordReader
IOException
InterruptedException
public Object getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader
IOException
InterruptedException
public Object getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader
IOException
InterruptedException
public float getProgress() throws IOException, InterruptedException
getProgress
in class org.apache.hadoop.mapreduce.RecordReader
IOException
InterruptedException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.hadoop.mapreduce.RecordReader
IOException
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.