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(Object key, Iterator values, OutputCollector output, Reporter reporter) throws IOException
reduce
in interface Reducer
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class MapReduceBase
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.