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