protected boolean isElementLate ( StreamRecord < IN > element ) { return ( windowAssigner . isEventTime ( ) ) && ( element . getTimestamp ( ) + allowedLateness <= internalTimerService . currentWatermark ( ) ) ; }
Decide if a record is currently late based on current watermark and allowed lateness .