Class AggregateProcessor
java.lang.Object
org.apache.storm.trident.planner.processor.AggregateProcessor
- All Implemented Interfaces:
Serializable
,TridentProcessor
,TupleReceiver
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
cleanup()
void
execute
(ProcessorContext processorContext, String streamId, TridentTuple tuple) void
finishBatch
(ProcessorContext processorContext) void
flush()
void
prepare
(Map<String, Object> conf, TopologyContext context, TridentContext tridentContext) void
startBatch
(ProcessorContext processorContext)
-
Constructor Details
-
AggregateProcessor
-
-
Method Details
-
prepare
public void prepare(Map<String, Object> conf, TopologyContext context, TridentContext tridentContext) - Specified by:
prepare
in interfaceTridentProcessor
-
cleanup
public void cleanup()- Specified by:
cleanup
in interfaceTridentProcessor
-
startBatch
- Specified by:
startBatch
in interfaceTridentProcessor
-
execute
- Specified by:
execute
in interfaceTupleReceiver
-
flush
public void flush()- Specified by:
flush
in interfaceTupleReceiver
-
finishBatch
- Specified by:
finishBatch
in interfaceTridentProcessor
-
getOutputFactory
- Specified by:
getOutputFactory
in interfaceTridentProcessor
-