METHOD_0 ( ) { java . util . HashSet < java . lang . String > IDENT_0 = new java . util . HashSet < java . lang . String > ( ) ; for ( int i = 1 ; i <= 100 ; i ++ ) IDENT_0 . add ( ( i + "" ) ) ; IDENT_1 . METHOD_1 ( IDENT_2 , IDENT_0 ) ; org . apache . spark . streaming . api . java . IDENT_3 < java . lang . String , java . lang . String > stream = org . apache . spark . streaming . IDENT_4 . IDENT_5 . METHOD_2 ( IDENT_6 , IDENT_1 . METHOD_3 ( ) , IDENT_1 . METHOD_4 ( ) , new java . util . HashSet < java . lang . String > ( ) { { add ( IDENT_2 ) ; } } ) ; final java . util . Set < java . lang . String > result = java . util . Collections . METHOD_5 ( new java . util . HashSet < java . lang . String > ( ) ) ; stream . METHOD_6 ( new org . apache . spark . api . java . function . IDENT_7 < org . apache . spark . api . java . IDENT_8 < java . lang . String , java . lang . String > , java . lang . IDENT_9 > ( ) { public org . apache . spark . streaming . IDENT_4 . IDENT_9 call ( org . apache . spark . api . java . IDENT_8 < java . lang . String , java . lang . String > IDENT_10 ) throws org . apache . spark . streaming . IDENT_4 . Exception { java . util . Iterator < IDENT_11 . IDENT_12 < java . lang . String , java . lang . String > > iterator = IDENT_10 . collect ( ) . iterator ( ) ; while ( iterator . hasNext ( ) ) { result . add ( iterator . next ( ) . IDENT_13 ) ; } return null ; } } ) ; IDENT_6 . start ( ) ; long IDENT_14 = java . lang . System . currentTimeMillis ( ) ; boolean matches = false ; while ( ( ! matches ) && ( ( ( java . lang . System . currentTimeMillis ( ) ) - IDENT_14 ) < INT_0 ) ) { matches = ( IDENT_0 . size ( ) ) == ( result . size ( ) ) ; java . lang . Thread . sleep ( 50 ) ; } "<AssertPlaceHolder>" ; IDENT_6 . METHOD_7 ( ) ; } start ( ) { com . IDENT_15 . IDENT_16 . IDENT_17 . IDENT_4 . IDENT_18 . IDENT_19 = new com . IDENT_15 . IDENT_16 . IDENT_20 . IDENT_4 . IDENT_21 . METHOD_8 ( IDENT_22 , METHOD_4 , IDENT_23 , new com . IDENT_15 . IDENT_16 . IDENT_20 . IDENT_4 . client . METHOD_9 ( ) , new com . IDENT_15 . IDENT_16 . IDENT_17 . IDENT_4 . IDENT_18 . METHOD_10 ( ) ) ; java . util . List < com . IDENT_15 . IDENT_16 . IDENT_20 . IDENT_4 . IDENT_24 . Message > IDENT_25 = new java . util . ArrayList < com . IDENT_15 . IDENT_16 . IDENT_20 . IDENT_4 . IDENT_24 . Message > ( ) ; while ( true ) { for ( int i = 0 ; i < ( com . IDENT_15 . IDENT_16 . IDENT_17 . IDENT_4 . IDENT_18 . IDENT_26 ) ; ++ i ) { java . lang . String IDENT_27 = ( STRING_0 + i ) + STRING_1 ; com . IDENT_15 . IDENT_16 . IDENT_20 . IDENT_4 . IDENT_24 . Message message = new com . IDENT_15 . IDENT_16 . IDENT_20 . IDENT_4 . IDENT_24 . Message ( java . nio . ByteBuffer . METHOD_11 ( IDENT_27 . getBytes ( ) ) ) ; IDENT_25 . add ( message ) ; } com . IDENT_15 . IDENT_16 . IDENT_17 . IDENT_4 . IDENT_18 . IDENT_19 . METHOD_12 ( IDENT_25 ) ; try { java . lang . Thread . sleep ( INT_1 ) ; } catch ( java . lang . IDENT_28 e ) { e . printStackTrace ( ) ; } }
org . junit . Assert . assertEquals ( IDENT_0 , result )