question: computes the min ts across all streams . concode_field_sep Map<GlobalStreamId,Long> streamToTs concode_elem_sep long lastWaterMarkTs concode_elem_sep ScheduledExecutorService executorService concode_elem_sep Set<GlobalStreamId> inputStreams concode_elem_sep int eventTsLag concode_elem_sep Logger LOG concode_elem_sep int interval concode_elem_sep WindowManager<T> windowManager concode_elem_sep ScheduledFuture<?> executorFuture concode_field_sep void checkFailures concode_elem_sep void start concode_elem_sep void run concode_elem_sep boolean track
target: long function ( ) { long loc0 = 0 ; if ( streamToTs . size ( ) >= inputStreams . size ( ) ) { loc0 = Long . MAX_VALUE ; for ( Map . Entry < GlobalStreamId , Long > loc1 : streamToTs . entrySet ( ) ) { loc0 = Math . min ( loc0 , loc1 . getValue ( ) ) ; } } return loc0 - eventTsLag ; }