Package org.apache.storm.trident.operation

Class BaseMultiReducer<T>

java.lang.Object

org.apache.storm.trident.operation.BaseMultiReducer<T>

All Implemented Interfaces:

Serializable, MultiReducer<T>

public abstract class BaseMultiReducer<T>
extends Object
implements MultiReducer<T>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
BaseMultiReducer()

Method Summary

Modifier and Type	Method	Description
void	cleanup()
void	prepare(Map<String,Object> 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 org.apache.storm.trident.operation.MultiReducer

complete, execute, init

Constructor Details

BaseMultiReducer

public BaseMultiReducer()

Method Details

prepare

public void prepare(Map<String,Object> conf,
 TridentMultiReducerContext context)

Specified by:

prepare in interface MultiReducer<T>

cleanup

public void cleanup()

Specified by:

cleanup in interface MultiReducer<T>