storm.trident.operation

Class BaseMultiReducer<T>

java.lang.Object

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 and Description
BaseMultiReducer()

Method Summary

Modifier and Type	Method and Description
void	cleanup()
void	prepare(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(Map conf,
                    TridentMultiReducerContext context)

Specified by:

prepare in interface MultiReducer<T>

cleanup

public void cleanup()

Specified by:

cleanup in interface MultiReducer<T>