public class FlowReducer extends MapReduceBase implements Reducer
Constructor and Description |
---|
FlowReducer()
Constructor FlowReducer creates a new FlowReducer instance.
|
public FlowReducer()
public void configure(JobConf jobConf)
configure
in interface JobConfigurable
configure
in class MapReduceBase
public void reduce(java.lang.Object key, java.util.Iterator values, OutputCollector output, Reporter reporter) throws java.io.IOException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class MapReduceBase
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.