METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . IDENT_1 . mapreduce . IDENT_2 executor = METHOD_1 ( com . google . common . collect . ImmutableMap . < java . lang . String , java . lang . String > builder ( ) . put ( STRING_0 , com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_3 . class . METHOD_2 ( ) ) . put ( STRING_1 , METHOD_3 ( ) ) . put ( IDENT_3 . IDENT_4 , STRING_2 ) . build ( ) ) ; com . streamsets . pipeline . sdk . IDENT_5 runner = new com . streamsets . pipeline . sdk . IDENT_5 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . mapreduce . IDENT_6 . class , executor ) . METHOD_4 ( IDENT_7 . IDENT_8 ) . build ( ) ; runner . METHOD_5 ( ) ; com . streamsets . pipeline . api . IDENT_9 record = com . streamsets . pipeline . sdk . IDENT_10 . create ( ) ; record . set ( com . streamsets . pipeline . api . Field . create ( com . google . common . collect . ImmutableMap . of ( STRING_3 , com . streamsets . pipeline . api . Field . create ( "value" ) ) ) ) ; runner . METHOD_6 ( com . google . common . collect . ImmutableList . of ( record ) ) ; "<AssertPlaceHolder>" ; runner . METHOD_7 ( ) ; } METHOD_8 ( ) { return IDENT_11 ; }
org . junit . Assert . assertEquals ( 1 , runner . METHOD_8 ( ) . size ( ) )