Interface GroupedMultiReducer<T>
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
JoinerMultiReducer
,PreservingFieldsOrderJoinerMultiReducer
-
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
void
complete
(T state, TridentTuple group, TridentCollector collector) void
execute
(T state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector) init
(TridentCollector collector, TridentTuple group) void
prepare
(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()
-