METHOD_0 ( ) { java . util . concurrent . atomic . IDENT_0 result = new java . util . concurrent . atomic . METHOD_1 ( 0 ) ; java . util . concurrent . IDENT_1 < java . lang . IDENT_2 > IDENT_3 = org . apache . beam . sdk . util . IDENT_4 . METHOD_2 ( ( ) -> { result . set ( INT_0 ) ; } ) ; org . apache . beam . sdk . util . IDENT_4 . get ( IDENT_3 ) ; "<AssertPlaceHolder>" ; } get ( ) { org . apache . beam . runners . core . IDENT_5 . IDENT_6 . IDENT_7 . IDENT_8 IDENT_9 = new org . apache . beam . runners . core . IDENT_5 . IDENT_6 . IDENT_7 . METHOD_3 ( ) ; org . apache . beam . IDENT_10 . grpc . IDENT_11 . io . grpc . IDENT_12 . IDENT_13 < org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_16 > IDENT_17 = IDENT_12 . METHOD_4 ( IDENT_9 ) ; org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_18 metadata = org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_18 . METHOD_5 ( ) . setName ( file . METHOD_6 ( ) ) . build ( ) ; org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_19 IDENT_20 = org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_19 . METHOD_5 ( ) . METHOD_7 ( metadata ) . METHOD_8 ( IDENT_21 ) . build ( ) ; IDENT_17 . METHOD_9 ( org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_16 . METHOD_5 ( ) . METHOD_7 ( IDENT_20 ) . build ( ) ) ; org . apache . beam . IDENT_10 . IDENT_22 . IDENT_23 . com . google . common . hash . IDENT_24 IDENT_25 = org . apache . beam . IDENT_10 . IDENT_22 . IDENT_23 . com . google . common . hash . IDENT_26 . METHOD_10 ( ) . METHOD_11 ( ) ; java . nio . IDENT_27 . IDENT_28 channel = new java . io . METHOD_12 ( file . METHOD_13 ( ) ) . METHOD_14 ( ) ; java . nio . ByteBuffer IDENT_29 = java . nio . ByteBuffer . METHOD_15 ( IDENT_30 ) ; while ( ( ! ( IDENT_9 . METHOD_16 ( ) ) ) && ( ( channel . position ( ) ) < ( channel . size ( ) ) ) ) { IDENT_29 . METHOD_17 ( ) ; channel . read ( IDENT_29 ) ; IDENT_29 . METHOD_18 ( ) ; org . apache . beam . IDENT_10 . grpc . IDENT_11 . com . google . IDENT_31 . IDENT_32 IDENT_33 = org . apache . beam . IDENT_10 . grpc . IDENT_11 . com . google . IDENT_31 . IDENT_32 . METHOD_19 ( IDENT_29 ) ; IDENT_25 . METHOD_20 ( IDENT_33 . toByteArray ( ) ) ; IDENT_29 . METHOD_21 ( ) ; org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_16 request = org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_16 . METHOD_5 ( ) . METHOD_22 ( org . apache . beam . model . IDENT_14 . v1 . IDENT_15 . IDENT_34 . METHOD_5 ( ) . METHOD_22 ( IDENT_33 ) . build ( ) ) . build ( ) ; IDENT_17 . METHOD_9 ( request ) ; } IDENT_17 . METHOD_23 ( ) ; IDENT_9 . METHOD_24 ( ) ; if ( ( IDENT_9 . err . get ( ) ) != null ) { throw new java . lang . RuntimeException ( IDENT_9 . err . get ( ) ) ; } return metadata . METHOD_25 ( ) . METHOD_26 ( IDENT_25 . hash ( ) . toString ( ) ) . build ( ) ; }
org . junit . Assert . assertThat ( result . get ( ) , org . hamcrest . Matchers . equalTo ( INT_0 ) )