Interface ITridentWindowManager
- All Known Implementing Classes:
- AbstractTridentWindowManager,- InMemoryTridentWindowManager,- StoreBasedTridentWindowManager
public interface ITridentWindowManager
Window manager to handle trident tuple events.
- 
Method SummaryModifier and TypeMethodDescriptionvoidaddTuplesBatch(Object batchId, List<TridentTuple> tuples) Add received batch of tuples to cache/store and add them toWindowManager.Queue<org.apache.storm.trident.windowing.AbstractTridentWindowManager.TriggerResult>Returns pending triggers to be emitted.voidprepare()This is invoked fromorg.apache.storm.trident.planner.TridentProcessor's prepare method.voidshutdown()This is invoked when fromorg.apache.storm.trident.planner.TridentProcessor's cleanup method.
- 
Method Details- 
preparevoid prepare()This is invoked fromorg.apache.storm.trident.planner.TridentProcessor's prepare method. So any initialization tasks can be done before the topology starts accepting tuples. For ex: initialize window manager with any earlier stored tuples/triggers and start WindowManager.
- 
shutdownvoid shutdown()This is invoked when fromorg.apache.storm.trident.planner.TridentProcessor's cleanup method. So, any cleanup operations like clearing cache or close store connection etc can be done.
- 
addTuplesBatchAdd received batch of tuples to cache/store and add them toWindowManager.
- 
getPendingTriggersQueue<org.apache.storm.trident.windowing.AbstractTridentWindowManager.TriggerResult> getPendingTriggers()Returns pending triggers to be emitted.
 
-