org.apache.storm.trident.windowing

## Interface ITridentWindowManager

- All Known Implementing Classes:
    AbstractTridentWindowManager, InMemoryTridentWindowManager, StoreBasedTridentWindowManager

      public interface ITridentWindowManager

  Window manager to handle trident tuple events.

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method and Description
    --- | ---
    `void` | `addTuplesBatch(Object batchId, List<TridentTuple> tuples)` Add received batch of tuples to cache/store and add them to `WindowManager`.
    `Queue<org.apache.storm.trident.windowing.AbstractTridentWindowManager.TriggerResult>` | `getPendingTriggers()` Returns pending triggers to be emitted.
    `void` | `prepare()` This is invoked from `org.apache.storm.trident.planner.TridentProcessor`’s prepare method.
    `void` | `shutdown()` This is invoked when from `org.apache.storm.trident.planner.TridentProcessor`’s cleanup method.

- - ### Method Detail

    - #### 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.

Copyright © 2021 The Apache Software Foundation. All rights reserved.