Interface ITridentWindowManager
- All Known Implementing Classes:
AbstractTridentWindowManager,InMemoryTridentWindowManager,StoreBasedTridentWindowManager
public interface ITridentWindowManager
Window manager to handle trident tuple events.
-
Method Summary
Modifier 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
-
prepare
void 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. -
shutdown
void 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. -
addTuplesBatch
Add received batch of tuples to cache/store and add them toWindowManager. -
getPendingTriggers
Queue<org.apache.storm.trident.windowing.AbstractTridentWindowManager.TriggerResult> getPendingTriggers()Returns pending triggers to be emitted.
-