METHOD_0 ( ) { org . apache . hadoop . fs . IDENT_0 fs = org . apache . hadoop . fs . IDENT_0 . get ( IDENT_1 . METHOD_1 ( ) ) ; org . apache . hadoop . fs . Path IDENT_2 = IDENT_1 . getPath ( STRING_0 ) ; org . apache . hadoop . fs . Path IDENT_3 = IDENT_1 . getPath ( STRING_1 ) ; java . io . IDENT_4 IDENT_5 = fs . create ( IDENT_2 , true ) ; java . io . IDENT_4 IDENT_6 = fs . create ( IDENT_3 , true ) ; for ( int i = 0 ; i < 4 ; i ++ ) { byte [ ] value = ( ( "value" + i ) + "\n" ) . getBytes ( java . nio . IDENT_7 . IDENT_8 . METHOD_2 ( STRING_2 ) ) ; IDENT_5 . write ( value ) ; IDENT_6 . write ( value ) ; } IDENT_5 . METHOD_3 ( ) ; IDENT_5 . close ( ) ; IDENT_6 . METHOD_3 ( ) ; IDENT_6 . close ( ) ; final org . apache . IDENT_9 . impl . IDENT_10 . IDENT_11 pipeline = new org . apache . IDENT_9 . impl . IDENT_10 . METHOD_4 ( org . apache . IDENT_9 . lib . join . IDENT_12 . class , IDENT_1 . METHOD_1 ( ) ) ; final org . apache . IDENT_9 . IDENT_13 < java . lang . String > IDENT_14 = pipeline . METHOD_5 ( IDENT_2 . toString ( ) ) ; final org . apache . IDENT_9 . IDENT_13 < java . lang . String > IDENT_15 = pipeline . METHOD_5 ( IDENT_3 . toString ( ) ) ; final org . apache . IDENT_9 . IDENT_16 < org . apache . hadoop . io . IDENT_17 , org . apache . hadoop . io . IDENT_17 > IDENT_18 = org . apache . IDENT_9 . lib . join . IDENT_12 . METHOD_6 ( IDENT_14 ) ; final org . apache . IDENT_9 . IDENT_16 < org . apache . hadoop . io . IDENT_17 , org . apache . hadoop . io . IDENT_17 > IDENT_19 = org . apache . IDENT_9 . lib . join . IDENT_12 . METHOD_6 ( IDENT_15 ) ; final org . apache . IDENT_9 . lib . join . IDENT_20 < org . apache . hadoop . io . IDENT_17 , org . apache . hadoop . io . IDENT_17 , org . apache . hadoop . io . IDENT_17 > IDENT_21 = org . apache . IDENT_9 . lib . join . IDENT_20 . < org . apache . hadoop . io . IDENT_17 , org . apache . hadoop . io . IDENT_17 , org . apache . hadoop . io . IDENT_17 > create ( ) ; final org . apache . IDENT_9 . IDENT_16 < org . apache . hadoop . io . IDENT_17 , org . apache . IDENT_9 . IDENT_22 < org . apache . hadoop . io . IDENT_17 , org . apache . hadoop . io . IDENT_17 > > IDENT_23 = IDENT_21 . join ( IDENT_18 , IDENT_19 , IDENT_24 . IDENT_25 ) ; pipeline . run ( ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( ) { return new org . apache . IDENT_9 . IDENT_26 . IDENT_27 < IDENT_28 , IDENT_29 > ( this . METHOD_8 ( ) ) ; }
org . junit . Assert . assertEquals ( 4 , IDENT_23 . METHOD_7 ( ) . size ( ) )