METHOD_0 ( ) { org . apache . beam . runners . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 state = new org . apache . beam . runners . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_1 ( org . apache . beam . runners . IDENT_0 . IDENT_1 . IDENT_4 . METHOD_2 ( ) , STRING_0 , null , org . apache . beam . runners . IDENT_0 . IDENT_1 . IDENT_5 . IDENT_6 . IDENT_7 . IDENT_8 , null ) ; org . apache . beam . runners . core . metrics . IDENT_9 IDENT_10 = org . apache . beam . runners . core . metrics . IDENT_9 . METHOD_3 ( ) ; try { IDENT_10 . start ( ) ; org . apache . beam . runners . core . metrics . IDENT_11 IDENT_12 = new org . apache . beam . runners . core . metrics . METHOD_4 ( IDENT_10 ) ; java . lang . Thread IDENT_13 = new java . lang . Thread ( ) ; IDENT_13 . setName ( STRING_1 ) ; IDENT_12 . METHOD_5 ( IDENT_13 ) ; IDENT_12 . METHOD_6 ( state ) ; for ( int i = 0 ; i < 3 ; i ++ ) { com . google . api . services . IDENT_0 . model . IDENT_14 update = null ; while ( update == null ) { update = state . METHOD_7 ( false ) ; } long IDENT_15 = METHOD_8 ( update . METHOD_9 ( ) ) ; "<AssertPlaceHolder>" ; } } finally { IDENT_10 . METHOD_10 ( ) ; } } METHOD_11 ( T extends org . apache . beam . sdk . IDENT_16 . IDENT_17 ) { return org . apache . beam . sdk . IDENT_16 . IDENT_18 . METHOD_12 ( ( ( org . apache . beam . sdk . IDENT_16 . IDENT_19 < T , java . lang . Boolean > ) ( ( input ) -> ( input . compareTo ( value ) ) > 0 ) ) ) . METHOD_13 ( java . lang . String . format ( STRING_2 , value ) ) ; }
org . junit . Assert . assertThat ( IDENT_15 , org . hamcrest . Matchers . METHOD_11 ( 0L ) )