Uses of Package
org.apache.storm.windowing
Package
Description
-
ClassDescriptionInterface to be implemented for extracting timestamp from a tuple.
-
-
-
-
ClassDescriptionAn event is a wrapper object that gets stored in the window.Interface to be implemented for extracting timestamp from a tuple.A callback for expiry, activation of events tracked by the
WindowManager
. -
ClassDescriptionInterface to be implemented for extracting timestamp from a tuple.
-
ClassDescriptionTracks a window of events and fires
WindowLifecycleListener
callbacks on expiry of events or activation of the window due toTriggerPolicy
. -
ClassDescriptionEviction policy tracks events and decides whether an event should be evicted from the window or not.The callback fired by
TriggerPolicy
when the trigger condition is satisfied.Triggers the window calculations based on the policy. -
ClassDescriptionAn event is a wrapper object that gets stored in the window.Context information that can be used by the eviction policy.Eviction policy tracks events and decides whether an event should be evicted from the window or not.The action to be taken when
EvictionPolicy.evict(Event)
is invoked.Eviction policy that evicts events based on time duration.The callback fired byTriggerPolicy
when the trigger condition is satisfied.Triggers the window calculations based on the policy.A view of events in a sliding window.A callback for expiry, activation of events tracked by theWindowManager
.Tracks a window of events and firesWindowLifecycleListener
callbacks on expiry of events or activation of the window due toTriggerPolicy
. -