Interface ITridentWindowManager

All Known Implementing Classes:
AbstractTridentWindowManager, InMemoryTridentWindowManager, StoreBasedTridentWindowManager

public interface ITridentWindowManager
Window manager to handle trident tuple events.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Add received batch of tuples to cache/store and add them to WindowManager.
    Queue<org.apache.storm.trident.windowing.AbstractTridentWindowManager.TriggerResult>
    Returns pending triggers to be emitted.
    void
    This is invoked from org.apache.storm.trident.planner.TridentProcessor's prepare method.
    void
    This is invoked when from org.apache.storm.trident.planner.TridentProcessor's cleanup method.
  • Method Details

    • prepare

      void prepare()
      This is invoked from org.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 from org.apache.storm.trident.planner.TridentProcessor's cleanup method. So, any cleanup operations like clearing cache or close store connection etc can be done.
    • addTuplesBatch

      void addTuplesBatch(Object batchId, List<TridentTuple> tuples)
      Add received batch of tuples to cache/store and add them to WindowManager.
    • getPendingTriggers

      Queue<org.apache.storm.trident.windowing.AbstractTridentWindowManager.TriggerResult> getPendingTriggers()
      Returns pending triggers to be emitted.