public class StageInputMapper
extends org.apache.hadoop.mapreduce.Mapper
Mapper
for dispatching multiple Map operations.Constructor and Description |
---|
StageInputMapper() |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
run(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
setup
in class org.apache.hadoop.mapreduce.Mapper
IOException
InterruptedException
public void run(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
run
in class org.apache.hadoop.mapreduce.Mapper
IOException
InterruptedException
protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
cleanup
in class org.apache.hadoop.mapreduce.Mapper
IOException
InterruptedException
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.