METHOD_0 ( ) { java . io . File IDENT_0 = new java . io . File ( METHOD_1 ( ) , STRING_0 ) ; java . io . File IDENT_1 = new java . io . File ( METHOD_2 ( ) , STRING_1 ) ; long IDENT_2 = java . lang . Long . valueOf ( java . lang . System . getProperty ( com . streamsets . pipeline . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . IDENT_8 , com . streamsets . pipeline . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . IDENT_9 ) ) ; org . apache . commons . lang . time . IDENT_10 IDENT_11 = new org . apache . commons . lang . time . METHOD_3 ( ) ; IDENT_11 . start ( ) ; METHOD_4 ( com . streamsets . pipeline . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . IDENT_12 , IDENT_0 , IDENT_2 ) ; IDENT_11 . METHOD_5 ( ) ; com . streamsets . pipeline . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . LOG . info ( STRING_2 , IDENT_11 . toString ( ) , IDENT_2 , com . streamsets . pipeline . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . METHOD_6 ( IDENT_0 . length ( ) ) ) ; com . streamsets . pipeline . IDENT_3 . IDENT_4 . mapreduce . IDENT_5 . IDENT_13 . IDENT_14 IDENT_15 = new com . streamsets . pipeline . IDENT_3 . IDENT_4 . mapreduce . IDENT_5 . IDENT_13 . METHOD_7 ( ) ; com . streamsets . pipeline . lib . converter . IDENT_16 conf = new com . streamsets . pipeline . lib . converter . METHOD_8 ( ) ; IDENT_15 . IDENT_0 = IDENT_0 . getAbsolutePath ( ) ; IDENT_15 . IDENT_17 = METHOD_2 ( ) ; com . streamsets . pipeline . IDENT_3 . IDENT_4 . mapreduce . IDENT_18 executor = METHOD_9 ( IDENT_15 , conf , java . util . Collections . METHOD_10 ( ) ) ; com . streamsets . pipeline . sdk . IDENT_19 runner = new com . streamsets . pipeline . sdk . IDENT_19 . Builder ( com . streamsets . pipeline . IDENT_3 . IDENT_4 . mapreduce . IDENT_20 . class , executor ) . METHOD_11 ( IDENT_21 . IDENT_22 ) . build ( ) ; runner . METHOD_12 ( ) ; com . streamsets . pipeline . api . IDENT_23 record = com . streamsets . pipeline . sdk . IDENT_24 . create ( ) ; record . set ( com . streamsets . pipeline . api . Field . create ( java . util . Collections . < java . lang . String , com . streamsets . pipeline . api . Field > METHOD_10 ( ) ) ) ; IDENT_11 . METHOD_13 ( ) ; IDENT_11 . start ( ) ; runner . METHOD_14 ( com . google . common . collect . ImmutableList . of ( record ) ) ; IDENT_11 . METHOD_5 ( ) ; com . streamsets . pipeline . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . LOG . info ( STRING_3 , IDENT_11 . toString ( ) , com . streamsets . pipeline . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . IDENT_7 . METHOD_6 ( IDENT_1 . length ( ) ) ) ; "<AssertPlaceHolder>" ; runner . METHOD_15 ( ) ; METHOD_16 ( new org . apache . hadoop . fs . Path ( IDENT_1 . getAbsolutePath ( ) ) , IDENT_2 ) ; } METHOD_17 ( ) { return IDENT_25 ; }
org . junit . Assert . assertEquals ( 0 , runner . METHOD_17 ( ) . size ( ) )