Package org.apache.storm.trident.planner
Interface TridentProcessor
- All Superinterfaces:
- Serializable,- TupleReceiver
- All Known Implementing Classes:
- AggregateProcessor,- EachProcessor,- MapProcessor,- MultiReducerProcessor,- PartitionPersistProcessor,- ProjectedProcessor,- StateQueryProcessor,- WindowTridentProcessor
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()voidfinishBatch(ProcessorContext processorContext) voidprepare(Map<String, Object> conf, TopologyContext context, TridentContext tridentContext) voidstartBatch(ProcessorContext processorContext) Methods inherited from interface org.apache.storm.trident.planner.TupleReceiverexecute, flush
- 
Method Details- 
prepare
- 
cleanupvoid cleanup()
- 
startBatch
- 
finishBatch
- 
getOutputFactoryTridentTuple.Factory getOutputFactory()
 
-