METHOD_0 ( ) { org . apache . beam . sdk . IDENT_0 . Schema schema = org . apache . beam . sdk . IDENT_0 . Schema . of ( Schema . Field . METHOD_1 ( STRING_0 , IDENT_1 . IDENT_2 ) ) ; org . apache . beam . sdk . values . IDENT_3 IDENT_4 = org . apache . beam . sdk . values . IDENT_3 . METHOD_2 ( schema ) . METHOD_3 ( 1L ) . build ( ) ; org . apache . beam . sdk . values . IDENT_3 IDENT_5 = org . apache . beam . sdk . values . IDENT_3 . METHOD_2 ( schema ) . METHOD_3 ( null ) . build ( ) ; org . apache . beam . sdk . values . IDENT_3 IDENT_6 = org . apache . beam . sdk . values . IDENT_3 . METHOD_2 ( schema ) . METHOD_3 ( INT_0 ) . build ( ) ; METHOD_4 ( STRING_1 ) ; pipeline . apply ( org . apache . beam . sdk . IDENT_7 . IDENT_8 . of ( IDENT_4 , IDENT_5 , IDENT_6 ) . METHOD_5 ( schema ) ) . apply ( write ( STRING_2 ) ) ; pipeline . run ( ) . METHOD_6 ( ) ; long IDENT_9 = METHOD_7 ( STRING_3 ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( java . lang . String ) { java . sql . ResultSet rs = METHOD_8 ( sql ) ; rs . next ( ) ; return rs . METHOD_9 ( 1 ) ; }
org . junit . Assert . assertEquals ( INT_0 , IDENT_9 )