public class FlowMapper extends Object implements MapRunnable
Constructor and Description |
---|
FlowMapper()
Constructor FlowMapper creates a new FlowMapper instance.
|
Modifier and Type | Method and Description |
---|---|
void |
configure(JobConf jobConf) |
void |
run(RecordReader input,
OutputCollector output,
Reporter reporter) |
public FlowMapper()
public void configure(JobConf jobConf)
configure
in interface JobConfigurable
public void run(RecordReader input, OutputCollector output, Reporter reporter) throws IOException
run
in interface MapRunnable
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.