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