METHOD_0 ( ) { java . lang . String IDENT_0 = STRING_0 + STRING_1 ; java . lang . String IDENT_1 = STRING_2 ; java . lang . String IDENT_2 = STRING_3 ; io . cdap . cdap . IDENT_3 . IDENT_4 . v2 . IDENT_5 IDENT_6 = new io . cdap . cdap . IDENT_3 . IDENT_4 . v2 . METHOD_1 ( STRING_4 1 , io . cdap . cdap . IDENT_3 . api . batch . IDENT_7 . IDENT_8 , com . google . common . collect . ImmutableMap . < java . lang . String , java . lang . String > builder ( ) . put ( IDENT_9 . IDENT_10 , METHOD_2 ( ) ) . put ( IDENT_11 . IDENT_12 . IDENT_13 , IDENT_0 ) . put ( IDENT_11 . IDENT_12 . IDENT_14 , IDENT_1 ) . put ( IDENT_11 . IDENT_12 . IDENT_15 , IDENT_2 ) . put ( IDENT_9 . IDENT_16 , STRING_5 ) . put ( Constants . IDENT_17 . IDENT_18 , STRING_4 0 ) . build ( ) , null ) ; io . cdap . cdap . IDENT_3 . IDENT_4 . v2 . METHOD_1 IDENT_19 = io . cdap . cdap . IDENT_3 . mock . batch . IDENT_20 . METHOD_3 ( STRING_6 ) ; io . cdap . cdap . test . IDENT_21 IDENT_22 = METHOD_4 ( IDENT_6 , IDENT_19 , STRING_7 ) ; METHOD_5 ( IDENT_22 , com . google . common . collect . ImmutableMap . of ( STRING_8 , java . lang . String . valueOf ( io . cdap . plugin . db . batch . IDENT_23 . IDENT_24 ) ) ) ; io . cdap . cdap . test . IDENT_25 < io . cdap . cdap . api . dataset . table . IDENT_26 > IDENT_27 = METHOD_6 ( STRING_6 ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( org . apache . IDENT_28 . IDENT_29 . IDENT_30 ) { org . apache . avro . Schema IDENT_31 = new org . apache . avro . Schema . METHOD_8 ( ) . parse ( io . cdap . plugin . batch . IDENT_32 . IDENT_33 . toString ( ) ) ; java . util . Map < java . lang . String , java . lang . Integer > IDENT_34 = new java . util . HashMap ( ) ; for ( org . apache . IDENT_28 . IDENT_29 . IDENT_30 file : IDENT_35 . list ( ) ) { java . lang . String IDENT_36 = file . getName ( ) ; if ( IDENT_36 . METHOD_9 ( STRING_9 ) ) { org . apache . avro . io . IDENT_37 < org . apache . avro . IDENT_38 . IDENT_39 > IDENT_40 = new org . apache . avro . IDENT_38 . METHOD_10 ( IDENT_31 ) ; org . apache . avro . file . IDENT_41 < org . apache . avro . IDENT_38 . IDENT_39 > IDENT_42 = new org . apache . avro . file . METHOD_11 ( file . METHOD_12 ( ) , IDENT_40 ) ; for ( org . apache . avro . IDENT_38 . IDENT_39 record : IDENT_42 ) { IDENT_34 . put ( record . get ( STRING_10 ) . toString ( ) , ( ( java . lang . Integer ) ( record . get ( STRING_11 ) ) ) ) ; } IDENT_42 . close ( ) ; } else if ( IDENT_36 . METHOD_9 ( STRING_12 ) ) { org . apache . hadoop . fs . Path IDENT_43 = new org . apache . hadoop . fs . Path ( file . toString ( ) ) ; org . apache . IDENT_44 . avro . IDENT_45 . Builder < org . apache . avro . IDENT_38 . IDENT_39 > IDENT_46 = org . apache . IDENT_44 . avro . IDENT_45 . builder ( IDENT_43 ) ; org . apache . IDENT_44 . hadoop . IDENT_47 < org . apache . avro . IDENT_38 . IDENT_39 > reader = IDENT_46 . build ( ) ; org . apache . avro . IDENT_38 . IDENT_39 record = reader . read ( ) ; while ( record != null ) { IDENT_34 . put ( record . get ( STRING_10 ) . toString ( ) , ( ( java . lang . Integer ) ( record . get ( STRING_11 ) ) ) ) ; record = reader . read ( ) ; } } } return IDENT_34 ; }
org . junit . Assert . assertTrue ( io . cdap . cdap . IDENT_3 . mock . batch . IDENT_20 . METHOD_7 ( IDENT_27 ) . isEmpty ( ) )