Class AggregateProcessor
java.lang.Object
org.apache.storm.trident.planner.processor.AggregateProcessor
- All Implemented Interfaces:
Serializable,TridentProcessor,TupleReceiver
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()voidexecute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidfinishBatch(ProcessorContext processorContext) voidflush()voidprepare(Map<String, Object> conf, TopologyContext context, TridentContext tridentContext) voidstartBatch(ProcessorContext processorContext)
-
Constructor Details
-
AggregateProcessor
-
-
Method Details
-
prepare
public void prepare(Map<String, Object> conf, TopologyContext context, TridentContext tridentContext) - Specified by:
preparein interfaceTridentProcessor
-
cleanup
public void cleanup()- Specified by:
cleanupin interfaceTridentProcessor
-
startBatch
- Specified by:
startBatchin interfaceTridentProcessor
-
execute
- Specified by:
executein interfaceTupleReceiver
-
flush
public void flush()- Specified by:
flushin interfaceTupleReceiver
-
finishBatch
- Specified by:
finishBatchin interfaceTridentProcessor
-
getOutputFactory
- Specified by:
getOutputFactoryin interfaceTridentProcessor
-