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