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

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

Parameters:

batchId -

tuples -

getPendingTriggers

Queue<org.apache.storm.trident.windowing.AbstractTridentWindowManager.TriggerResult> getPendingTriggers()

Returns pending triggers to be emitted.

Returns: