ITridentWindowManager (Storm 2.7.1 API)

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