storm.trident.operation
Interface GroupedMultiReducer<T>
- All Superinterfaces:
- java.io.Serializable
- All Known Implementing Classes:
- JoinerMultiReducer
public interface GroupedMultiReducer<T>
- extends java.io.Serializable
prepare
void prepare(java.util.Map conf,
TridentMultiReducerContext context)
init
T init(TridentCollector collector,
TridentTuple group)
execute
void execute(T state,
int streamIndex,
TridentTuple group,
TridentTuple input,
TridentCollector collector)
complete
void complete(T state,
TridentTuple group,
TridentCollector collector)
cleanup
void cleanup()