org.apache.storm.windowing

Interface WindowLifecycleListener<T>

public interface WindowLifecycleListener<T>

A callback for expiry, activation of events tracked by the WindowManager

Method Summary

Modifier and Type	Method and Description
void	onActivation(List<T> events, List<T> newEvents, List<T> expired) Called on activation of the window due to the TriggerPolicy
void	onExpiry(List<T> events) Called on expiry of events from the window due to EvictionPolicy

Method Detail

onExpiry

void onExpiry(List<T> events)

Called on expiry of events from the window due to EvictionPolicy

Parameters:

events - the expired events

onActivation

void onActivation(List<T> events,
                  List<T> newEvents,
                  List<T> expired)

Called on activation of the window due to the TriggerPolicy

Parameters:

events - the list of current events in the window.

newEvents - the newly added events since last activation.

expired - the expired events since last activation.