Interface GroupedMultiReducer<T>
-
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
JoinerMultiReducer,PreservingFieldsOrderJoinerMultiReducer
public interface GroupedMultiReducer<T> extends Serializable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcleanup()voidcomplete(T state, TridentTuple group, TridentCollector collector)voidexecute(T state, int streamIndex, TridentTuple group, TridentTuple input, TridentCollector collector)Tinit(TridentCollector collector, TridentTuple group)voidprepare(Map<String,Object> conf, TridentMultiReducerContext context)
-
-
-
Method Detail
-
prepare
void prepare(Map<String,Object> 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()
-
-