Package org.apache.storm.trident.drpc
Class ReturnResultsReducer
- java.lang.Object
-
- org.apache.storm.trident.drpc.ReturnResultsReducer
-
- All Implemented Interfaces:
Serializable,MultiReducer<ReturnResultsReducer.ReturnResultsState>
public class ReturnResultsReducer extends Object implements MultiReducer<ReturnResultsReducer.ReturnResultsState>
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classReturnResultsReducer.ReturnResultsState
-
Constructor Summary
Constructors Constructor Description ReturnResultsReducer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcleanup()voidcomplete(ReturnResultsReducer.ReturnResultsState state, TridentCollector collector)voidexecute(ReturnResultsReducer.ReturnResultsState state, int streamIndex, TridentTuple input, TridentCollector collector)ReturnResultsReducer.ReturnResultsStateinit(TridentCollector collector)voidprepare(Map<String,Object> conf, TridentMultiReducerContext context)
-
-
-
Method Detail
-
prepare
public void prepare(Map<String,Object> conf, TridentMultiReducerContext context)
- Specified by:
preparein interfaceMultiReducer<ReturnResultsReducer.ReturnResultsState>
-
init
public ReturnResultsReducer.ReturnResultsState init(TridentCollector collector)
- Specified by:
initin interfaceMultiReducer<ReturnResultsReducer.ReturnResultsState>
-
execute
public void execute(ReturnResultsReducer.ReturnResultsState state, int streamIndex, TridentTuple input, TridentCollector collector)
- Specified by:
executein interfaceMultiReducer<ReturnResultsReducer.ReturnResultsState>
-
complete
public void complete(ReturnResultsReducer.ReturnResultsState state, TridentCollector collector)
- Specified by:
completein interfaceMultiReducer<ReturnResultsReducer.ReturnResultsState>
-
cleanup
public void cleanup()
- Specified by:
cleanupin interfaceMultiReducer<ReturnResultsReducer.ReturnResultsState>
-
-