Interface MultiReducer<T>
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
BaseMultiReducer,GroupedMultiReducerExecutor,IdentityMultiReducer,ReturnResultsReducer
-
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()voidcomplete(T state, TridentCollector collector) voidexecute(T state, int streamIndex, TridentTuple input, TridentCollector collector) init(TridentCollector collector) voidprepare(Map<String, Object> conf, TridentMultiReducerContext context)
-
Method Details
-
prepare
-
init
-
execute
-
complete
-
cleanup
void cleanup()
-