storm.trident.operation
Class BaseMultiReducer<T>

java.lang.Object
  extended by storm.trident.operation.BaseMultiReducer<T>
All Implemented Interfaces:
java.io.Serializable, MultiReducer<T>

public abstract class BaseMultiReducer<T>
extends java.lang.Object
implements MultiReducer<T>

See Also:
Serialized Form

Constructor Summary
BaseMultiReducer()
           
 
Method Summary
 void cleanup()
           
 void prepare(java.util.Map conf, TridentMultiReducerContext context)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface storm.trident.operation.MultiReducer
complete, execute, init
 

Constructor Detail

BaseMultiReducer

public BaseMultiReducer()
Method Detail

prepare

public void prepare(java.util.Map conf,
                    TridentMultiReducerContext context)
Specified by:
prepare in interface MultiReducer<T>

cleanup

public void cleanup()
Specified by:
cleanup in interface MultiReducer<T>