cascading.flow
Class FlowReducer

java.lang.Object
  MapReduceBase
      cascading.flow.FlowReducer

public class FlowReducer
extends MapReduceBase

Class FlowReducer ...

Constructor Summary

FlowReducer()
Constructor FlowReducer creates a new FlowReducer instance.

Method Summary

void	close()
void	configure(JobConf jobConf)
void	reduce(Object key, Iterator values, OutputCollector output, Reporter reporter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowReducer

public FlowReducer()

Constructor FlowReducer creates a new FlowReducer instance.

Method Detail

configure

public void configure(JobConf jobConf)

reduce

public void reduce(Object key,
                   Iterator values,
                   OutputCollector output,
                   Reporter reporter)
            throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException