private long calExpirationTime ( long operatorTime , long relativeSize ) { if ( operatorTime < Long . MAX_VALUE ) { return operatorTime - relativeSize - allowedLateness - 1 ; } else { // When operatorTime = Long.MaxValue, it means the stream has reached the end. return Long . MAX_VALUE ; } }
Calculate the expiration time with the given operator time and relative window size .