METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( false ) ; org . apache . beam . sdk . IDENT_2 . IDENT_3 . IDENT_4 < java . lang . Integer , java . lang . Integer , java . lang . Integer > IDENT_5 = new org . apache . beam . sdk . IDENT_2 . IDENT_3 . IDENT_4 < java . lang . Integer , java . lang . Integer , java . lang . Integer > ( ) { @ org . apache . beam . sdk . testing . Override public org . apache . beam . sdk . testing . Integer METHOD_2 ( ) { return 0 ; } @ org . apache . beam . sdk . testing . Override public org . apache . beam . sdk . testing . Integer METHOD_3 ( java . lang . Integer IDENT_6 , java . lang . Integer input ) { return IDENT_6 + input ; } @ org . apache . beam . sdk . testing . Override public org . apache . beam . sdk . testing . Integer METHOD_4 ( java . lang . IDENT_7 < java . lang . Integer > IDENT_8 ) { int result = 0 ; for ( int IDENT_9 : IDENT_8 ) { if ( IDENT_9 == 0 ) { IDENT_1 . set ( true ) ; } result += IDENT_9 ; } return result ; } @ org . apache . beam . sdk . testing . Override public org . apache . beam . sdk . testing . Integer METHOD_5 ( java . lang . Integer IDENT_6 ) { return IDENT_6 ; } } ; org . apache . beam . sdk . testing . IDENT_10 . METHOD_6 ( IDENT_5 , java . util . Arrays . asList ( 1 , 2 , 3 , 4 , 5 ) , 15 ) ; "<AssertPlaceHolder>" ; } get ( ) { org . apache . beam . runners . core . IDENT_11 . IDENT_12 . IDENT_13 . IDENT_14 IDENT_15 = new org . apache . beam . runners . core . IDENT_11 . IDENT_12 . IDENT_13 . METHOD_7 ( ) ; org . apache . beam . IDENT_16 . grpc . IDENT_17 . io . grpc . IDENT_18 . IDENT_19 < org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_22 > IDENT_23 = IDENT_18 . METHOD_8 ( IDENT_15 ) ; org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_24 metadata = org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_24 . METHOD_9 ( ) . setName ( file . METHOD_10 ( ) ) . build ( ) ; org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_25 IDENT_26 = org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_25 . METHOD_9 ( ) . METHOD_11 ( metadata ) . METHOD_12 ( IDENT_27 ) . build ( ) ; IDENT_23 . METHOD_13 ( org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_22 . METHOD_9 ( ) . METHOD_11 ( IDENT_26 ) . build ( ) ) ; org . apache . beam . IDENT_16 . IDENT_28 . IDENT_29 . com . google . common . hash . IDENT_30 IDENT_31 = org . apache . beam . IDENT_16 . IDENT_28 . IDENT_29 . com . google . common . hash . IDENT_32 . METHOD_14 ( ) . METHOD_15 ( ) ; java . nio . IDENT_33 . IDENT_34 channel = new java . io . METHOD_16 ( file . METHOD_17 ( ) ) . METHOD_18 ( ) ; java . nio . ByteBuffer IDENT_35 = java . nio . ByteBuffer . METHOD_19 ( IDENT_36 ) ; while ( ( ! ( IDENT_15 . METHOD_20 ( ) ) ) && ( ( channel . position ( ) ) < ( channel . size ( ) ) ) ) { IDENT_35 . METHOD_21 ( ) ; channel . read ( IDENT_35 ) ; IDENT_35 . METHOD_22 ( ) ; org . apache . beam . IDENT_16 . grpc . IDENT_17 . com . google . IDENT_37 . IDENT_38 IDENT_39 = org . apache . beam . IDENT_16 . grpc . IDENT_17 . com . google . IDENT_37 . IDENT_38 . METHOD_23 ( IDENT_35 ) ; IDENT_31 . METHOD_24 ( IDENT_39 . toByteArray ( ) ) ; IDENT_35 . METHOD_25 ( ) ; org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_22 request = org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_22 . METHOD_9 ( ) . METHOD_26 ( org . apache . beam . model . IDENT_20 . v1 . IDENT_21 . IDENT_40 . METHOD_9 ( ) . METHOD_26 ( IDENT_39 ) . build ( ) ) . build ( ) ; IDENT_23 . METHOD_13 ( request ) ; } IDENT_23 . METHOD_27 ( ) ; IDENT_15 . METHOD_28 ( ) ; if ( ( IDENT_15 . err . get ( ) ) != null ) { throw new java . lang . RuntimeException ( IDENT_15 . err . get ( ) ) ; } return metadata . METHOD_29 ( ) . METHOD_30 ( IDENT_31 . hash ( ) . toString ( ) ) . build ( ) ; }
org . junit . Assert . assertThat ( IDENT_1 . get ( ) , org . hamcrest . Matchers . is ( true ) )