METHOD_0 ( ) { org . apache . beam . sdk . IDENT_0 . sql . impl . IDENT_1 IDENT_2 = org . apache . beam . sdk . IDENT_0 . sql . impl . IDENT_1 . METHOD_1 ( new org . apache . beam . sdk . IDENT_0 . sql . meta . provider . IDENT_3 . METHOD_2 ( ) ) ; java . lang . String IDENT_4 = ( ( STRING_0 3 + ( ( ( ( ( ( ( ( ( ( ( ( ( STRING_0 5 + STRING_1 ) + STRING_0 8 ) + STRING_0 2 ) + STRING_2 8 ) + STRING_0 ) + STRING_3 ) + STRING_1 1 ) + STRING_4 ) + STRING_1 0 ) + STRING_5 ) + STRING_6 ) + STRING_7 ) + STRING_2 2 ) ) + ( IDENT_5 . METHOD_3 ( ) ) ) + STRING_0 9 ; IDENT_2 . METHOD_4 ( IDENT_4 ) ; java . lang . String IDENT_6 = STRING_0 6 + ( ( ( ( ( ( ( ( ( ( ( STRING_1 3 + STRING_2 4 ) + STRING_2 7 ) + STRING_2 5 ) + STRING_2 0 ) + STRING_2 0 ) + STRING_1 2 ) + STRING_8 ) + STRING_0 0 ) + STRING_2 1 ) + STRING_2 6 ) + STRING_2 9 ) ; IDENT_2 . METHOD_5 ( IDENT_6 ) ; org . apache . beam . sdk . IDENT_0 . sql . impl . IDENT_7 . IDENT_8 . METHOD_6 ( pipeline , IDENT_2 . METHOD_5 ( IDENT_6 ) ) ; pipeline . run ( ) . METHOD_7 ( org . joda . time . IDENT_9 . METHOD_8 ( 5 ) ) ; java . lang . String IDENT_10 = STRING_0 4 ; org . apache . beam . sdk . values . IDENT_11 < org . apache . beam . sdk . values . IDENT_12 > output = org . apache . beam . sdk . IDENT_0 . sql . impl . IDENT_7 . IDENT_8 . METHOD_6 ( IDENT_13 , IDENT_2 . METHOD_5 ( IDENT_10 ) ) ; org . apache . beam . sdk . testing . IDENT_14 . that ( output ) . METHOD_9 ( row ( org . apache . beam . sdk . IDENT_0 . sql . meta . provider . IDENT_3 . IDENT_15 . IDENT_16 , INT_0 , ( ( byte ) ( INT_1 ) ) , ( ( short ) ( INT_2 ) ) , INT_3 , ( ( float ) ( 1.0 ) ) , 1.0 , true , METHOD_10 ( STRING_0 7 ) , STRING_2 3 , STRING_0 1 , java . util . Arrays . asList ( STRING_9 , STRING_2 ) ) ) ; org . apache . beam . sdk . IDENT_17 . IDENT_18 state = IDENT_13 . run ( ) . METHOD_7 ( org . joda . time . IDENT_9 . METHOD_8 ( 5 ) ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( org . joda . time . IDENT_9 ) { long IDENT_19 = ( ( IDENT_20 == null ) || ( ( IDENT_20 . METHOD_11 ( ) ) < 1 ) ) ? Long . MAX_VALUE : ( java . lang . System . currentTimeMillis ( ) ) + ( IDENT_20 . METHOD_11 ( ) ) ; try { while ( ( ! ( IDENT_21 . METHOD_12 ( ) ) ) && ( ( java . lang . System . currentTimeMillis ( ) ) < IDENT_19 ) ) { if ( ( IDENT_22 . IDENT_23 . get ( ) ) != null ) { throw IDENT_22 . IDENT_23 . get ( ) ; } java . lang . Thread . sleep ( INT_4 ) ; } if ( IDENT_21 . METHOD_12 ( ) ) { METHOD_13 ( ) ; return IDENT_18 . IDENT_24 ; } return null ; } catch ( java . lang . IDENT_25 e ) { throw new java . lang . RuntimeException ( e ) ; } }
org . junit . Assert . assertEquals ( state , IDENT_18 . IDENT_24 )