Uses of Interface
org.apache.storm.windowing.Event
Packages that use Event
Package
Description
-
Uses of Event in org.apache.storm.topology
Method parameters in org.apache.storm.topology with type arguments of type EventModifier and TypeMethodDescriptionprotected voidWindowedBoltExecutor.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 EventModifier and TypeClassDescriptionclassEventImpl<T>classWatermark event used for tracking progress of time when processing event based ts.Fields in org.apache.storm.windowing with type parameters of type EventMethods in org.apache.storm.windowing with parameters of type EventModifier and TypeMethodDescriptionvoidTracks a window event.Decides if an event should be expired from the window, processed in the current window or kept for later processing.Decides if an event should be expired from the window, processed in the current window or kept for later processing.Decides if an event should be expired from the window, processed in the current window or kept for later processing.voidvoidvoidTracks the event to later decide whetherEvictionPolicy.evict(Event)should evict it or not.voidvoidvoidTracks the event and could use this to invoke the trigger.voidvoidvoidConstructor parameters in org.apache.storm.windowing with type arguments of type EventModifierConstructorDescriptionStatefulWindowManager(WindowLifecycleListener<T> lifecycleListener, Collection<Event<T>> queue) Constructs aStatefulWindowManager.WindowManager(WindowLifecycleListener<T> lifecycleListener, Collection<Event<T>> queue) Constructs aWindowManager. -
Uses of Event in org.apache.storm.windowing.persistence
Methods in org.apache.storm.windowing.persistence that return types with arguments of type EventModifier and TypeMethodDescriptionCollection<Event<T>>WindowState.WindowPartition.getEvents()WindowState.iterator()WindowState.WindowPartition.iterator()Methods in org.apache.storm.windowing.persistence with parameters of type Event