int function ( long arg0 ) { int loc0 = 0 ; for ( Event < T > loc1 : queue ) { if ( loc1 . getTimestamp ( ) <= arg0 ) { ++ loc0 ; } } return loc0 ; }
scans the event queue and returns number of events having timestamp less than or equal to the reference time . concode_field_sep WindowLifecycleListener<T> windowLifecycleListener concode_elem_sep TriggerPolicy<T> triggerPolicy concode_elem_sep ReentrantLock lock concode_elem_sep int EXPIRE_EVENTS_THRESHOLD concode_elem_sep Set<Event<T>> prevWindowEvents concode_elem_sep AtomicInteger eventsSinceLastExpiry concode_elem_sep Logger LOG concode_elem_sep ConcurrentLinkedQueue<Event<T>> queue concode_elem_sep List<T> expiredEvents concode_elem_sep EvictionPolicy<T> evictionPolicy concode_field_sep void add concode_elem_sep void add concode_elem_sep void add concode_elem_sep boolean onTrigger concode_elem_sep long getEarliestEventTs concode_elem_sep List<Event<T>> scanEvents concode_elem_sep void setTriggerPolicy concode_elem_sep void compactWindow concode_elem_sep String toString concode_elem_sep void track concode_elem_sep List<Long> getSlidingCountTimestamps concode_elem_sep void shutdown concode_elem_sep void setEvictionPolicy