Class GroupedMultiReducerExecutor
- java.lang.Object
-
- org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor
-
- All Implemented Interfaces:
Serializable,MultiReducer<Map<TridentTuple,Object>>
public class GroupedMultiReducerExecutor extends Object implements MultiReducer<Map<TridentTuple,Object>>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description GroupedMultiReducerExecutor(GroupedMultiReducer reducer, List<Fields> groupFields, List<Fields> inputFields)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcleanup()voidcomplete(Map<TridentTuple,Object> state, TridentCollector collector)voidexecute(Map<TridentTuple,Object> state, int streamIndex, TridentTuple full, TridentCollector collector)Map<TridentTuple,Object>init(TridentCollector collector)voidprepare(Map<String,Object> conf, TridentMultiReducerContext context)
-
-
-
Constructor Detail
-
GroupedMultiReducerExecutor
public GroupedMultiReducerExecutor(GroupedMultiReducer reducer, List<Fields> groupFields, List<Fields> inputFields)
-
-
Method Detail
-
prepare
public void prepare(Map<String,Object> conf, TridentMultiReducerContext context)
- Specified by:
preparein interfaceMultiReducer<Map<TridentTuple,Object>>
-
init
public Map<TridentTuple,Object> init(TridentCollector collector)
- Specified by:
initin interfaceMultiReducer<Map<TridentTuple,Object>>
-
execute
public void execute(Map<TridentTuple,Object> state, int streamIndex, TridentTuple full, TridentCollector collector)
- Specified by:
executein interfaceMultiReducer<Map<TridentTuple,Object>>
-
complete
public void complete(Map<TridentTuple,Object> state, TridentCollector collector)
- Specified by:
completein interfaceMultiReducer<Map<TridentTuple,Object>>
-
cleanup
public void cleanup()
- Specified by:
cleanupin interfaceMultiReducer<Map<TridentTuple,Object>>
-
-