METHOD_0 ( ) { org . apache . IDENT_0 . catalog . Schema schema = org . apache . IDENT_0 . catalog . IDENT_1 . builder ( ) . add ( STRING_0 , Type . IDENT_2 ) . add ( STRING_1 , Type . IDENT_3 ) . add ( STRING_2 , Type . IDENT_4 ) . build ( ) ; org . apache . IDENT_0 . catalog . IDENT_5 meta = org . apache . IDENT_0 . catalog . IDENT_6 . METHOD_1 ( IDENT_7 , conf ) ; if ( IDENT_7 . equalsIgnoreCase ( IDENT_8 . IDENT_9 ) ) { meta . METHOD_2 ( IDENT_10 . IDENT_11 , org . apache . IDENT_0 . storage . IDENT_12 . IDENT_13 ) ; } org . apache . hadoop . fs . Path IDENT_14 = new org . apache . hadoop . fs . Path ( IDENT_15 , STRING_3 ) ; org . apache . IDENT_0 . storage . IDENT_16 IDENT_17 = org . apache . IDENT_0 . storage . IDENT_18 . METHOD_3 ( ) ; org . apache . IDENT_0 . storage . IDENT_19 IDENT_20 = IDENT_17 . METHOD_4 ( meta , schema , IDENT_14 ) ; IDENT_20 . init ( ) ; int IDENT_21 = INT_0 ; org . apache . IDENT_0 . storage . IDENT_22 IDENT_23 ; for ( int i = 0 ; i < IDENT_21 ; i ++ ) { IDENT_23 = new org . apache . IDENT_0 . storage . METHOD_5 ( 3 ) ; IDENT_23 . put ( 0 , org . apache . IDENT_0 . IDENT_24 . IDENT_25 . METHOD_6 ( ( i + 1 ) ) ) ; IDENT_23 . put ( 1 , org . apache . IDENT_0 . IDENT_24 . IDENT_25 . METHOD_7 ( ( i + 2 ) ) ) ; IDENT_23 . put ( 2 , org . apache . IDENT_0 . IDENT_24 . IDENT_25 . METHOD_8 ( ( i + 3 ) ) ) ; IDENT_20 . METHOD_9 ( IDENT_23 ) ; } IDENT_20 . close ( ) ; org . apache . hadoop . fs . IDENT_26 status = fs . METHOD_10 ( IDENT_14 ) ; org . apache . IDENT_0 . storage . IDENT_27 . IDENT_28 IDENT_27 = new org . apache . IDENT_0 . storage . IDENT_27 . METHOD_11 ( STRING_4 , IDENT_14 , 0 , status . METHOD_12 ( ) ) ; org . apache . IDENT_0 . catalog . Schema target = org . apache . IDENT_0 . catalog . IDENT_1 . builder ( ) . add ( STRING_1 , Type . IDENT_3 ) . add ( STRING_2 , Type . IDENT_4 ) . build ( ) ; org . apache . IDENT_0 . storage . IDENT_29 IDENT_30 = IDENT_17 . METHOD_13 ( meta , schema , IDENT_27 , target ) ; IDENT_30 . init ( ) ; int IDENT_31 = 0 ; org . apache . IDENT_0 . storage . IDENT_32 tuple ; while ( ( tuple = IDENT_30 . next ( ) ) != null ) { METHOD_14 ( IDENT_30 . METHOD_15 ( ) , tuple , IDENT_31 ) ; IDENT_31 ++ ; } IDENT_30 . close ( ) ; "<AssertPlaceHolder>" ; } close ( ) { if ( ( IDENT_33 ) != null ) { IDENT_33 . close ( ) ; } IDENT_33 = null ; IDENT_34 = true ; }
org . junit . Assert . assertEquals ( IDENT_21 , IDENT_31 )