METHOD_0 ( ) { java . lang . String IDENT_0 = STRING_0 4 + ( java . util . UUID . METHOD_1 ( ) . toString ( ) ) ; java . lang . String IDENT_1 = STRING_1 + ( java . util . UUID . METHOD_1 ( ) . toString ( ) ) ; org . apache . spark . sql . IDENT_2 < org . apache . spark . sql . IDENT_3 > IDENT_4 = org . apache . IDENT_5 . spark . sql . IDENT_6 . spark . METHOD_2 ( ) . format ( org . apache . IDENT_5 . spark . sql . IDENT_6 . IDENT_7 ) . METHOD_3 ( STRING_2 , org . apache . IDENT_5 . spark . sql . IDENT_6 . IDENT_8 . METHOD_4 ( ) ) . METHOD_3 ( STRING_3 , IDENT_0 ) . METHOD_3 ( STRING_4 , STRING_0 0 ) . METHOD_3 ( STRING_0 2 , STRING_5 ) . METHOD_3 ( STRING_0 , STRING_6 ) . METHOD_3 ( STRING_0 1 , STRING_7 ) . load ( ) ; org . apache . spark . sql . IDENT_2 < org . apache . spark . sql . IDENT_3 > IDENT_9 = IDENT_4 . select ( STRING_0 3 ) ; org . apache . spark . sql . streaming . IDENT_10 query = IDENT_9 . METHOD_5 ( ) . METHOD_6 ( STRING_8 ) . format ( org . apache . IDENT_5 . spark . sql . IDENT_6 . IDENT_7 ) . METHOD_3 ( STRING_2 , org . apache . IDENT_5 . spark . sql . IDENT_6 . IDENT_8 . METHOD_4 ( ) ) . METHOD_3 ( STRING_3 , IDENT_1 ) . METHOD_7 ( org . apache . spark . sql . streaming . IDENT_11 . METHOD_8 ( STRING_9 ) ) . start ( ) ; for ( int batch = 0 ; batch < 10 ; batch ++ ) { org . apache . IDENT_5 . spark . sql . IDENT_6 . IDENT_8 . METHOD_9 ( IDENT_0 , 10 ) ; java . lang . Thread . sleep ( INT_0 ) ; } java . lang . Thread . sleep ( INT_1 ) ; query . METHOD_10 ( ) ; int IDENT_12 = org . apache . IDENT_5 . spark . sql . IDENT_6 . METHOD_11 ( IDENT_1 ) ; "<AssertPlaceHolder>" ; } METHOD_11 ( java . lang . String ) { org . apache . IDENT_5 . client . consumer . IDENT_13 consumer = new org . apache . IDENT_5 . client . consumer . METHOD_12 ( STRING_10 ) ; consumer . start ( ) ; int IDENT_12 = 0 ; java . util . Set < org . apache . IDENT_5 . common . message . IDENT_14 > IDENT_15 = consumer . METHOD_13 ( IDENT_16 ) ; for ( org . apache . IDENT_5 . common . message . IDENT_14 IDENT_17 : IDENT_15 ) { org . apache . IDENT_5 . client . consumer . IDENT_18 IDENT_19 = consumer . METHOD_14 ( IDENT_17 , null , 0 , 1000 ) ; if ( ( IDENT_19 . METHOD_15 ( ) ) == ( org . apache . IDENT_5 . client . consumer . IDENT_20 . IDENT_21 ) ) { for ( int i = 0 ; i < ( IDENT_19 . METHOD_16 ( ) . size ( ) ) ; i ++ ) { java . lang . String IDENT_22 = new java . lang . String ( IDENT_19 . METHOD_16 ( ) . get ( i ) . METHOD_17 ( ) ) ; org . apache . IDENT_5 . spark . sql . IDENT_6 . logger . info ( ( STRING_11 + IDENT_22 ) ) ; org . junit . Assert . assertEquals ( STRING_12 , IDENT_22 . substring ( 0 , INT_2 ) ) ; IDENT_12 ++ ; } } } consumer . METHOD_18 ( ) ; return IDENT_12 ; }
org . junit . Assert . assertEquals ( 100 , IDENT_12 )