Uses of Interface
org.apache.storm.windowing.Event

Packages that use Event

Package	Description
org.apache.storm.topology
org.apache.storm.windowing
org.apache.storm.windowing.persistence

Uses of Event in org.apache.storm.topology

Method parameters in org.apache.storm.topology with type arguments of type Event

Modifier and Type	Method	Description
protected void	WindowedBoltExecutor.doPrepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector, Collection<Event<Tuple>> queue, boolean stateful)

Uses of Event in org.apache.storm.windowing

Classes in org.apache.storm.windowing that implement Event

Modifier and Type	Class	Description
class	EventImpl<T>
class	WaterMarkEvent<T>	Watermark event used for tracking progress of time when processing event based ts.

Fields in org.apache.storm.windowing with type parameters of type Event

Modifier and Type	Field	Description
protected Collection<Event<T>>	WindowManager.queue

Methods in org.apache.storm.windowing with parameters of type Event

Modifier and Type	Method	Description
void	WindowManager.add(Event<T> windowEvent)	Tracks a window event.
EvictionPolicy.Action	CountEvictionPolicy.evict(Event<T> event)
EvictionPolicy.Action	EvictionPolicy.evict(Event<T> event)	Decides if an event should be expired from the window, processed in the current window or kept for later processing.
EvictionPolicy.Action	TimeEvictionPolicy.evict(Event<T> event)	Decides if an event should be expired from the window, processed in the current window or kept for later processing.
EvictionPolicy.Action	WatermarkCountEvictionPolicy.evict(Event<T> event)
EvictionPolicy.Action	WatermarkTimeEvictionPolicy.evict(Event<T> event)	Decides if an event should be expired from the window, processed in the current window or kept for later processing.
void	CountEvictionPolicy.track(Event<T> event)
void	CountTriggerPolicy.track(Event<T> event)
void	EvictionPolicy.track(Event<T> event)	Tracks the event to later decide whether EvictionPolicy.evict(Event) should evict it or not.
void	TimeEvictionPolicy.track(Event<T> event)
void	TimeTriggerPolicy.track(Event<T> event)
void	TriggerPolicy.track(Event<T> event)	Tracks the event and could use this to invoke the trigger.
void	WatermarkCountEvictionPolicy.track(Event<T> event)
void	WatermarkCountTriggerPolicy.track(Event<T> event)
void	WatermarkTimeTriggerPolicy.track(Event<T> event)

Constructor parameters in org.apache.storm.windowing with type arguments of type Event

Constructor	Description
StatefulWindowManager(WindowLifecycleListener<T> lifecycleListener, Collection<Event<T>> queue)	Constructs a StatefulWindowManager.
WindowManager(WindowLifecycleListener<T> lifecycleListener, Collection<Event<T>> queue)	Constructs a WindowManager.

Uses of Event in org.apache.storm.windowing.persistence

Methods in org.apache.storm.windowing.persistence that return types with arguments of type Event

Modifier and Type	Method	Description
Collection<Event<T>>	WindowState.WindowPartition.getEvents()
Iterator<Event<T>>	WindowState.iterator()
Iterator<Event<T>>	WindowState.WindowPartition.iterator()

Methods in org.apache.storm.windowing.persistence with parameters of type Event

Modifier and Type	Method	Description
boolean	WindowState.add(Event<T> event)