cascading.flow.stack
Class FlowReducerStack

java.lang.Object
  extended by cascading.flow.stack.FlowReducerStack

public class FlowReducerStack
extends Object


Constructor Summary
FlowReducerStack(JobConf jobConf)
           
 
Method Summary
 void close()
           
 void reduce(Object key, Iterator values, OutputCollector output)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FlowReducerStack

public FlowReducerStack(JobConf jobConf)
                 throws IOException
Throws:
IOException
Method Detail

reduce

public void reduce(Object key,
                   Iterator values,
                   OutputCollector output)

close

public void close()
           throws IOException
Throws:
IOException


Copyright © 2007-2008 Concurrent, Inc. All Rights Reserved.