public interface MultiReducer<T> extends Serializable
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
void |
complete(T state,
TridentCollector collector) |
void |
execute(T state,
int streamIndex,
TridentTuple input,
TridentCollector collector) |
T |
init(TridentCollector collector) |
void |
prepare(Map<String,Object> conf,
TridentMultiReducerContext context) |
void prepare(Map<String,Object> conf, TridentMultiReducerContext context)
T init(TridentCollector collector)
void execute(T state, int streamIndex, TridentTuple input, TridentCollector collector)
void complete(T state, TridentCollector collector)
void cleanup()
Copyright © 2022 The Apache Software Foundation. All rights reserved.