METHOD_0 ( ) { java . lang . String tableName = org . apache . beam . sdk . io . common . IDENT_0 . METHOD_1 ( STRING_0 0 ) ; org . apache . beam . sdk . io . common . IDENT_0 . METHOD_2 ( org . apache . beam . sdk . io . jdbc . IDENT_1 . IDENT_2 , tableName ) ; java . sql . IDENT_3 connection = org . apache . beam . sdk . io . jdbc . IDENT_1 . IDENT_2 . METHOD_3 ( ) ; java . sql . IDENT_4 IDENT_5 = connection . METHOD_4 ( ) ; IDENT_5 . execute ( ( ( STRING_0 1 + tableName ) + STRING_1 ) ) ; IDENT_5 . execute ( ( ( STRING_2 + tableName ) + STRING_3 ) ) ; connection . METHOD_5 ( false ) ; java . sql . IDENT_6 IDENT_7 = connection . METHOD_6 ( ( ( STRING_0 3 + tableName ) + STRING_4 ) ) ; IDENT_7 . METHOD_7 ( 1 , 1 ) ; IDENT_7 . METHOD_8 ( 2 , STRING_5 ) ; IDENT_7 . execute ( ) ; pipeline . apply ( org . apache . beam . sdk . IDENT_8 . IDENT_9 . of ( java . util . Collections . singletonList ( org . apache . beam . sdk . values . IDENT_10 . of ( 1 , STRING_5 ) ) ) ) . apply ( org . apache . beam . sdk . io . jdbc . IDENT_11 . < org . apache . beam . sdk . values . IDENT_10 < java . lang . Integer , java . lang . String > > write ( ) . METHOD_9 ( IDENT_11 . IDENT_12 . create ( STRING_0 , ( ( STRING_6 + ( org . apache . beam . sdk . io . jdbc . IDENT_1 . port ) ) + STRING_0 4 ) ) ) . METHOD_10 ( java . lang . String . format ( STRING_0 2 , tableName ) ) . METHOD_11 ( ( ( org . apache . beam . sdk . io . jdbc . IDENT_11 . IDENT_13 ) ( ( e ) -> { return STRING_7 . equals ( e . METHOD_12 ( ) ) ; } ) ) ) . METHOD_13 ( ( element , statement ) -> { statement . METHOD_7 ( 1 , element . getKey ( ) ) ; statement . METHOD_8 ( 2 , element . getValue ( ) ) ; } ) ) ; java . lang . Thread IDENT_14 = new java . lang . Thread ( ( ) -> { try { java . lang . Thread . sleep ( INT_0 ) ; connection . commit ( ) ; } catch ( e ) { } } ) ; IDENT_14 . start ( ) ; pipeline . run ( ) ; IDENT_14 . join ( ) ; IDENT_15 . METHOD_14 ( STRING_8 ) ; try ( java . sql . IDENT_3 IDENT_16 = org . apache . beam . sdk . io . jdbc . IDENT_1 . IDENT_2 . METHOD_3 ( ) ) { try ( java . sql . IDENT_4 statement = IDENT_16 . METHOD_4 ( ) ) { try ( java . sql . ResultSet IDENT_17 = statement . METHOD_15 ( ( STRING_9 + tableName ) ) ) { IDENT_17 . next ( ) ; int count = IDENT_17 . METHOD_16 ( 1 ) ; "<AssertPlaceHolder>" ; } } } } next ( ) { return METHOD_17 ( ) ; }
org . junit . Assert . assertEquals ( 2 , count )