METHOD_0 ( ) { org . apache . beam . sdk . options . IDENT_0 options = org . apache . beam . sdk . options . IDENT_1 . create ( ) ; org . apache . beam . model . pipeline . v1 . IDENT_2 . IDENT_3 IDENT_4 = METHOD_1 ( ) ; org . apache . beam . runners . IDENT_5 . IDENT_6 . IDENT_7 . IDENT_8 service = new org . apache . beam . runners . IDENT_5 . IDENT_6 . IDENT_7 . METHOD_2 ( IDENT_4 , org . apache . beam . runners . IDENT_5 . IDENT_6 . IDENT_7 . stream . IDENT_9 . METHOD_3 ( options ) :: from , org . apache . beam . runners . IDENT_10 . IDENT_11 . METHOD_4 ( ) ) ; org . apache . beam . IDENT_12 . grpc . IDENT_13 . io . grpc . IDENT_14 server = org . apache . beam . runners . IDENT_10 . IDENT_15 . METHOD_5 ( ) . create ( org . apache . beam . IDENT_12 . IDENT_16 . IDENT_17 . com . google . common . collect . ImmutableList . of ( service ) , IDENT_4 ) ; java . lang . String url = service . METHOD_6 ( ) . METHOD_7 ( ) ; org . apache . beam . model . IDENT_10 . v1 . IDENT_18 . IDENT_19 IDENT_20 = org . apache . beam . model . IDENT_10 . v1 . IDENT_18 . METHOD_8 ( org . apache . beam . IDENT_12 . grpc . IDENT_13 . io . grpc . IDENT_21 . METHOD_9 ( url ) . METHOD_10 ( true ) . build ( ) ) ; IDENT_20 . control ( IDENT_22 ) ; try ( org . apache . beam . runners . IDENT_10 . control . IDENT_23 client = service . get ( ) ) { "<AssertPlaceHolder>" ; } server . METHOD_11 ( ) ; server . METHOD_12 ( 1 , TimeUnit . IDENT_24 ) ; server . METHOD_13 ( ) ; java . lang . Thread . sleep ( 1000 ) ; verify ( IDENT_22 ) . METHOD_14 ( ) ; METHOD_15 ( IDENT_22 ) ; } get ( ) { org . apache . beam . runners . core . IDENT_25 . IDENT_26 . IDENT_27 . IDENT_28 IDENT_29 = new org . apache . beam . runners . core . IDENT_25 . IDENT_26 . IDENT_27 . METHOD_16 ( ) ; org . apache . beam . IDENT_12 . grpc . IDENT_13 . io . grpc . IDENT_30 . IDENT_31 < org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_34 > IDENT_22 = IDENT_30 . METHOD_17 ( IDENT_29 ) ; org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_35 metadata = org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_35 . METHOD_18 ( ) . setName ( file . METHOD_19 ( ) ) . build ( ) ; org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_36 IDENT_37 = org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_36 . METHOD_18 ( ) . METHOD_20 ( metadata ) . METHOD_21 ( IDENT_38 ) . build ( ) ; IDENT_22 . METHOD_22 ( org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_34 . METHOD_18 ( ) . METHOD_20 ( IDENT_37 ) . build ( ) ) ; org . apache . beam . IDENT_12 . IDENT_16 . IDENT_17 . com . google . common . hash . IDENT_39 IDENT_40 = org . apache . beam . IDENT_12 . IDENT_16 . IDENT_17 . com . google . common . hash . IDENT_41 . METHOD_23 ( ) . METHOD_24 ( ) ; java . nio . IDENT_42 . IDENT_43 channel = new java . io . METHOD_25 ( file . METHOD_26 ( ) ) . METHOD_27 ( ) ; java . nio . ByteBuffer IDENT_44 = java . nio . ByteBuffer . METHOD_28 ( IDENT_45 ) ; while ( ( ! ( IDENT_29 . METHOD_29 ( ) ) ) && ( ( channel . position ( ) ) < ( channel . size ( ) ) ) ) { IDENT_44 . METHOD_30 ( ) ; channel . read ( IDENT_44 ) ; IDENT_44 . METHOD_31 ( ) ; org . apache . beam . IDENT_12 . grpc . IDENT_13 . com . google . IDENT_46 . IDENT_47 IDENT_48 = org . apache . beam . IDENT_12 . grpc . IDENT_13 . com . google . IDENT_46 . IDENT_47 . METHOD_32 ( IDENT_44 ) ; IDENT_40 . METHOD_33 ( IDENT_48 . toByteArray ( ) ) ; IDENT_44 . METHOD_34 ( ) ; org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_34 request = org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_34 . METHOD_18 ( ) . METHOD_35 ( org . apache . beam . model . IDENT_32 . v1 . IDENT_33 . IDENT_49 . METHOD_18 ( ) . METHOD_35 ( IDENT_48 ) . build ( ) ) . build ( ) ; IDENT_22 . METHOD_22 ( request ) ; } IDENT_22 . METHOD_14 ( ) ; IDENT_29 . METHOD_12 ( ) ; if ( ( IDENT_29 . err . get ( ) ) != null ) { throw new java . lang . RuntimeException ( IDENT_29 . err . get ( ) ) ; } return metadata . METHOD_36 ( ) . METHOD_37 ( IDENT_40 . hash ( ) . toString ( ) ) . build ( ) ; }
org . junit . Assert . assertNotNull ( client )