METHOD_0 ( ) { io . cdap . cdap . api . data . schema . Schema schema = io . cdap . cdap . api . data . schema . Schema . METHOD_1 ( STRING_0 4 , Schema . Field . of ( STRING_0 2 , io . cdap . cdap . api . data . schema . Schema . of ( Schema . Type . IDENT_0 ) ) , Schema . Field . of ( STRING_0 1 , io . cdap . cdap . api . data . schema . Schema . METHOD_2 ( io . cdap . cdap . api . data . schema . Schema . of ( Schema . Type . IDENT_1 ) ) ) , Schema . Field . of ( STRING_0 9 , io . cdap . cdap . api . data . schema . Schema . METHOD_2 ( io . cdap . cdap . api . data . schema . Schema . of ( Schema . Type . IDENT_1 ) ) ) ) ; java . util . Map < java . lang . String , java . lang . String > IDENT_2 = new ImmutableMap . Builder < java . lang . String , java . lang . String > ( ) . put ( Constants . IDENT_3 . IDENT_4 , STRING_0 0 ) . put ( Properties . File . IDENT_5 , STRING_1 ) . put ( Properties . File . IDENT_6 , STRING_2 ) . put ( Properties . File . IDENT_7 , STRING_3 ) . put ( Properties . File . IDENT_8 , STRING_4 ) . put ( STRING_0 7 , STRING_0 9 ) . put ( STRING_0 3 , STRING_4 ) . put ( Properties . File . IDENT_9 , schema . toString ( ) ) . build ( ) ; io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . IDENT_12 source = new io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . METHOD_3 ( STRING_5 , new io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . METHOD_4 ( STRING_6 , io . cdap . cdap . IDENT_10 . api . batch . IDENT_13 . IDENT_14 , IDENT_2 , null ) ) ; java . lang . String IDENT_15 = STRING_0 6 ; io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . METHOD_3 IDENT_16 = new io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . METHOD_3 ( STRING_7 , io . cdap . cdap . IDENT_10 . mock . batch . IDENT_17 . METHOD_5 ( IDENT_15 ) ) ; io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . IDENT_18 IDENT_19 = io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . IDENT_18 . builder ( ) . METHOD_6 ( source ) . METHOD_6 ( IDENT_16 ) . METHOD_7 ( source . getName ( ) , IDENT_16 . getName ( ) ) . build ( ) ; io . cdap . cdap . IDENT_11 . IDENT_20 . IDENT_21 < io . cdap . cdap . IDENT_10 . IDENT_11 . v2 . IDENT_18 > IDENT_22 = new io . cdap . cdap . IDENT_11 . IDENT_20 . METHOD_8 ( IDENT_23 , IDENT_19 ) ; io . cdap . cdap . IDENT_11 . id . IDENT_24 IDENT_25 = IDENT_26 . IDENT_27 . app ( STRING_0 ) ; io . cdap . cdap . test . IDENT_28 IDENT_29 = METHOD_9 ( IDENT_25 , IDENT_22 ) ; io . cdap . cdap . test . IDENT_30 IDENT_31 = IDENT_29 . METHOD_10 ( IDENT_32 . IDENT_33 ) ; IDENT_31 . start ( ) ; IDENT_31 . METHOD_11 ( IDENT_34 . IDENT_35 , 5 , TimeUnit . IDENT_36 ) ; io . cdap . cdap . test . IDENT_37 < io . cdap . cdap . api . dataset . table . IDENT_38 > IDENT_39 = METHOD_12 ( IDENT_15 ) ; java . util . Set < io . cdap . cdap . api . data . format . IDENT_40 > expected = com . google . common . collect . IDENT_41 . of ( io . cdap . cdap . api . data . format . IDENT_40 . builder ( schema ) . set ( STRING_0 2 , 0L ) . set ( STRING_0 1 , STRING_0 8 ) . set ( STRING_0 9 , STRING_0 5 ) . build ( ) , io . cdap . cdap . api . data . format . IDENT_40 . builder ( schema ) . set ( STRING_0 2 , 0L ) . set ( STRING_0 1 , STRING_8 ) . set ( STRING_0 9 , STRING_9 ) . build ( ) ) ; java . util . Set < io . cdap . cdap . api . data . format . IDENT_40 > actual = new java . util . HashSet ( io . cdap . cdap . IDENT_10 . mock . batch . IDENT_17 . METHOD_13 ( IDENT_39 ) ) ; "<AssertPlaceHolder>" ; } METHOD_13 ( org . apache . IDENT_42 . IDENT_43 . IDENT_44 ) { org . apache . avro . Schema IDENT_45 = new org . apache . avro . Schema . METHOD_14 ( ) . parse ( io . cdap . plugin . batch . IDENT_46 . IDENT_9 . toString ( ) ) ; java . util . Map < java . lang . String , java . lang . Integer > IDENT_47 = new java . util . HashMap ( ) ; for ( org . apache . IDENT_42 . IDENT_43 . IDENT_44 file : IDENT_48 . list ( ) ) { java . lang . String IDENT_49 = file . getName ( ) ; if ( IDENT_49 . METHOD_15 ( STRING_10 ) ) { org . apache . avro . io . IDENT_50 < org . apache . avro . IDENT_51 . IDENT_52 > IDENT_53 = new org . apache . avro . IDENT_51 . METHOD_16 ( IDENT_45 ) ; org . apache . avro . file . IDENT_54 < org . apache . avro . IDENT_51 . IDENT_52 > IDENT_55 = new org . apache . avro . file . METHOD_17 ( file . METHOD_18 ( ) , IDENT_53 ) ; for ( org . apache . avro . IDENT_51 . IDENT_52 record : IDENT_55 ) { IDENT_47 . put ( record . get ( STRING_11 ) . toString ( ) , ( ( java . lang . Integer ) ( record . get ( STRING_12 ) ) ) ) ; } IDENT_55 . close ( ) ; } else if ( IDENT_49 . METHOD_15 ( STRING_13 ) ) { org . apache . hadoop . fs . Path IDENT_56 = new org . apache . hadoop . fs . Path ( file . toString ( ) ) ; org . apache . IDENT_57 . avro . IDENT_58 . Builder < org . apache . avro . IDENT_51 . IDENT_52 > IDENT_59 = org . apache . IDENT_57 . avro . IDENT_58 . builder ( IDENT_56 ) ; org . apache . IDENT_57 . hadoop . IDENT_60 < org . apache . avro . IDENT_51 . IDENT_52 > reader = IDENT_59 . build ( ) ; org . apache . avro . IDENT_51 . IDENT_52 record = reader . read ( ) ; while ( record != null ) { IDENT_47 . put ( record . get ( STRING_11 ) . toString ( ) , ( ( java . lang . Integer ) ( record . get ( STRING_12 ) ) ) ) ; record = reader . read ( ) ; } } } return IDENT_47 ; }
org . junit . Assert . assertEquals ( expected , actual )