METHOD_0 ( ) { METHOD_1 ( ) ; final java . lang . String key = STRING_0 ; int count = 5 ; java . util . concurrent . IDENT_0 exec = java . util . concurrent . IDENT_1 . METHOD_2 ( count ) ; java . util . List < java . util . concurrent . IDENT_2 < java . lang . String > > IDENT_3 = new java . util . ArrayList < java . util . concurrent . IDENT_2 < java . lang . String > > ( count ) ; final java . util . concurrent . IDENT_4 start = new java . util . concurrent . METHOD_3 ( 1 ) ; for ( int i = 0 ; i < count ; i ++ ) { final java . lang . String IDENT_5 = ( STRING_1 + i ) + STRING_2 ; java . util . concurrent . IDENT_6 < java . lang . String > task = new java . util . concurrent . IDENT_6 < java . lang . String > ( ) { public java . lang . String call ( ) throws org . apache . hadoop . yarn . server . IDENT_7 . store . Exception { start . METHOD_4 ( ) ; java . lang . String result = store . METHOD_5 ( key , IDENT_5 ) ; System . out . println ( ( ( ( STRING_3 + IDENT_5 ) + STRING_4 ) + result ) ) ; return result ; } } ; IDENT_3 . add ( exec . METHOD_6 ( task ) ) ; } start . METHOD_7 ( ) ; java . util . Set < java . lang . String > results = new java . util . HashSet < java . lang . String > ( ) ; for ( java . util . concurrent . IDENT_2 < java . lang . String > future : IDENT_3 ) { results . add ( future . get ( ) ) ; } "<AssertPlaceHolder>" ; exec . METHOD_8 ( ) ; } size ( ) { return ( ( java . lang . Integer ) ( new io . IDENT_8 . transaction . handler . METHOD_9 ( io . IDENT_8 . transaction . handler . IDENT_9 . IDENT_10 ) { @ io . IDENT_8 . metadata . IDENT_11 . Override public java . lang . Object METHOD_10 ( ) throws java . io . IOException { io . IDENT_8 . metadata . hdfs . dal . IDENT_12 IDENT_13 = ( ( io . IDENT_8 . metadata . hdfs . dal . IDENT_12 ) ( io . IDENT_8 . metadata . IDENT_14 . METHOD_11 ( io . IDENT_8 . metadata . hdfs . dal . IDENT_12 . class ) ) ) ; return IDENT_13 . METHOD_12 ( ) ; } } . METHOD_13 ( ) ) ) ; }
org . junit . Assert . assertSame ( 1 , results . size ( ) )