METHOD_0 ( ) { org . apache . hadoop . fs . Path IDENT_0 = new org . apache . hadoop . fs . Path ( ( STRING_0 + ( IDENT_1 ) ) ) ; org . apache . hadoop . fs . IDENT_2 IDENT_3 = com . IDENT_4 . IDENT_5 . common . util . IDENT_6 . METHOD_1 ( IDENT_0 . toString ( ) , com . IDENT_4 . IDENT_5 . common . model . IDENT_7 . METHOD_2 ( ) ) ; org . apache . hadoop . fs . Path IDENT_8 = new org . apache . hadoop . fs . Path ( IDENT_0 , STRING_1 ) ; IDENT_3 . METHOD_3 ( IDENT_8 ) ; java . util . List < org . apache . avro . IDENT_9 . IDENT_10 > records = com . IDENT_4 . IDENT_5 . common . util . IDENT_11 . METHOD_4 ( 0 , 100 ) ; java . util . Map < com . IDENT_4 . IDENT_5 . common . table . log . block . IDENT_12 . IDENT_13 , java . lang . String > header = com . google . common . collect . IDENT_14 . METHOD_5 ( ) ; header . put ( IDENT_12 . IDENT_13 . IDENT_15 , STRING_2 ) ; header . put ( IDENT_12 . IDENT_13 . IDENT_16 , METHOD_6 ( ) . toString ( ) ) ; com . IDENT_4 . IDENT_5 . common . table . log . block . IDENT_17 IDENT_18 = new com . IDENT_4 . IDENT_5 . common . table . log . block . METHOD_7 ( records , header ) ; for ( int i = 0 ; i < 2 ; i ++ ) { com . IDENT_4 . IDENT_5 . common . table . log . IDENT_19 . METHOD_8 ( ) . METHOD_9 ( IDENT_8 ) . METHOD_10 ( IDENT_20 . IDENT_21 ) . METHOD_11 ( STRING_3 ) . METHOD_12 ( "" ) . METHOD_13 ( IDENT_3 ) . build ( ) . METHOD_14 ( IDENT_18 ) . close ( ) ; } org . apache . hadoop . fs . IDENT_22 [ ] IDENT_23 = IDENT_3 . METHOD_15 ( IDENT_8 ) ; "<AssertPlaceHolder>" ; } METHOD_15 ( org . apache . hadoop . IDENT_24 . IDENT_25 ) { org . apache . hadoop . fs . IDENT_22 [ ] IDENT_26 = super . METHOD_15 ( job ) ; java . util . Map < com . IDENT_4 . IDENT_5 . common . table . IDENT_27 , java . util . List < org . apache . hadoop . fs . IDENT_22 > > IDENT_28 = METHOD_16 ( IDENT_26 ) ; com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . info ( ( ( STRING_4 + ( IDENT_28 . size ( ) ) ) + STRING_5 ) ) ; java . util . List < org . apache . hadoop . fs . IDENT_22 > IDENT_30 = new java . util . ArrayList ( ) ; for ( Map . Entry < com . IDENT_4 . IDENT_5 . common . table . IDENT_27 , java . util . List < org . apache . hadoop . fs . IDENT_22 > > entry : IDENT_28 . entrySet ( ) ) { com . IDENT_4 . IDENT_5 . common . table . IDENT_27 metadata = entry . getKey ( ) ; if ( metadata == null ) { IDENT_30 . addAll ( entry . getValue ( ) ) ; continue ; } org . apache . hadoop . fs . IDENT_22 [ ] IDENT_23 = entry . getValue ( ) . toArray ( new org . apache . hadoop . fs . IDENT_22 [ entry . getValue ( ) . size ( ) ] ) ; if ( com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . METHOD_17 ( ) ) { com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . debug ( ( STRING_6 + metadata ) ) ; } java . lang . String tableName = metadata . METHOD_18 ( ) . METHOD_19 ( ) ; java . lang . String IDENT_31 = com . IDENT_4 . IDENT_5 . hadoop . IDENT_32 . METHOD_20 ( org . apache . hadoop . mapreduce . IDENT_33 . getInstance ( job ) , tableName ) ; com . IDENT_4 . IDENT_5 . common . table . IDENT_34 IDENT_35 = metadata . METHOD_21 ( ) . METHOD_22 ( ) . METHOD_23 ( ) ; com . IDENT_4 . IDENT_5 . common . table . IDENT_36 . IDENT_37 IDENT_38 = new com . IDENT_4 . IDENT_5 . common . table . view . METHOD_24 ( metadata , IDENT_35 , IDENT_23 ) ; if ( IDENT_32 . IDENT_39 . equals ( IDENT_31 ) ) { java . lang . String IDENT_40 = com . IDENT_4 . IDENT_5 . hadoop . IDENT_32 . METHOD_25 ( org . apache . hadoop . mapreduce . IDENT_33 . getInstance ( job ) , tableName ) ; java . lang . Integer IDENT_41 = com . IDENT_4 . IDENT_5 . hadoop . IDENT_32 . METHOD_26 ( org . apache . hadoop . mapreduce . IDENT_33 . getInstance ( job ) , tableName ) ; com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . info ( ( STRING_7 + IDENT_40 ) ) ; java . util . List < java . lang . String > IDENT_42 = IDENT_35 . METHOD_27 ( IDENT_40 , IDENT_41 ) . METHOD_28 ( ) . map ( IDENT_43 :: IDENT_44 ) . collect ( java . util . stream . IDENT_45 . toList ( ) ) ; java . util . List < com . IDENT_4 . IDENT_5 . common . model . IDENT_46 > IDENT_47 = IDENT_38 . METHOD_29 ( IDENT_42 ) . collect ( java . util . stream . IDENT_45 . toList ( ) ) ; for ( com . IDENT_4 . IDENT_5 . common . model . IDENT_46 IDENT_48 : IDENT_47 ) { com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . info ( ( STRING_8 + ( IDENT_48 . getPath ( ) ) ) ) ; IDENT_48 = METHOD_30 ( IDENT_48 ) ; IDENT_30 . add ( IDENT_48 . METHOD_31 ( ) ) ; } com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . info ( ( STRING_9 + ( IDENT_47 . size ( ) ) ) ) ; } else { java . util . List < com . IDENT_4 . IDENT_5 . common . model . IDENT_46 > IDENT_47 = IDENT_38 . METHOD_32 ( ) . collect ( java . util . stream . IDENT_45 . toList ( ) ) ; com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . info ( ( STRING_10 + ( IDENT_47 . size ( ) ) ) ) ; for ( com . IDENT_4 . IDENT_5 . common . model . IDENT_46 IDENT_48 : IDENT_47 ) { if ( com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . METHOD_17 ( ) ) { com . IDENT_4 . IDENT_5 . hadoop . IDENT_29 . LOG . debug ( ( STRING_11 + ( IDENT_48 . getPath ( ) ) ) ) ; } IDENT_48 = METHOD_30 ( IDENT_48 ) ; IDENT_30 . add ( IDENT_48 . METHOD_31 ( ) ) ; } } } return IDENT_30 . toArray ( new org . apache . hadoop . fs . IDENT_22 [ IDENT_30 . size ( ) ] ) ; }
org . junit . Assert . assertEquals ( 2 , IDENT_23 . length )