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 and 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 and 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 and Description
protected Collection<Event<T>>	WindowManager.queue

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

Modifier and Type	Method and Description
void	WindowManager.add(Event<T> windowEvent) Tracks a window event.
EvictionPolicy.Action	WatermarkCountEvictionPolicy.evict(Event<T> event)
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	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.
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.
void	WatermarkTimeTriggerPolicy.track(Event<T> event)
void	WatermarkCountEvictionPolicy.track(Event<T> event)
void	TimeEvictionPolicy.track(Event<T> event)
void	CountEvictionPolicy.track(Event<T> event)
void	TimeTriggerPolicy.track(Event<T> event)
void	WatermarkCountTriggerPolicy.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	TriggerPolicy.track(Event<T> event) Tracks the event and could use this to invoke the trigger.
void	CountTriggerPolicy.track(Event<T> event)

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

Constructor and 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 and 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 and Description
boolean	WindowState.add(Event<T> event)