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 Summary
Modifier 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.TupleReceiver
execute, flush
-
Method Details
-
prepare
-
cleanup
void cleanup() -
startBatch
-
finishBatch
-
getOutputFactory
TridentTuple.Factory getOutputFactory()
-