METHOD_0 ( ) { com . IDENT_0 . api . IDENT_1 IDENT_2 = com . IDENT_0 . api . IDENT_1 . newInstance ( ) ; org . apache . hadoop . conf . Configuration conf = new org . apache . hadoop . conf . Configuration ( false ) ; conf . set ( STRING_0 , STRING_1 ) ; org . apache . IDENT_3 . IDENT_4 . stream . IDENT_5 . IDENT_6 . IDENT_7 app = new org . apache . IDENT_3 . IDENT_4 . stream . IDENT_5 . IDENT_6 . METHOD_1 ( ) ; IDENT_2 . METHOD_2 ( app , conf ) ; com . IDENT_0 . api . IDENT_1 . IDENT_8 IDENT_9 = IDENT_2 . METHOD_3 ( ) ; ( ( com . IDENT_0 . IDENT_10 . IDENT_11 ) ( IDENT_9 ) ) . METHOD_4 ( new java . util . concurrent . IDENT_12 < java . lang . Boolean > ( ) { @ org . apache . IDENT_3 . IDENT_4 . stream . IDENT_5 . IDENT_6 . Override public org . apache . IDENT_3 . IDENT_4 . stream . IDENT_5 . IDENT_6 . Boolean call ( ) throws org . apache . IDENT_3 . IDENT_4 . stream . IDENT_5 . IDENT_6 . Exception { return METHOD_1 . IDENT_13 . METHOD_5 ( ) ; } } ) ; IDENT_9 . run ( INT_0 ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( ) { return result ; }
org . junit . Assert . assertEquals ( 9 , METHOD_1 . IDENT_13 . METHOD_6 ( ) . getValue ( ) . size ( ) )