METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . IDENT_2 IDENT_3 = com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . IDENT_4 . METHOD_1 ( com . google . common . collect . ImmutableList . of ( STRING_0 ) , IDENT_5 ) ; com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . IDENT_6 processor = new com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . METHOD_2 ( IDENT_3 , com . streamsets . pipeline . config . IDENT_7 . IDENT_8 ) ; com . streamsets . pipeline . sdk . IDENT_9 runner = new com . streamsets . pipeline . sdk . IDENT_9 . Builder ( com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . IDENT_10 . class , processor ) . METHOD_3 ( IDENT_11 . IDENT_8 ) . METHOD_4 ( "a" ) . build ( ) ; runner . METHOD_5 ( ) ; try { java . util . Map < java . lang . String , com . streamsets . pipeline . api . Field > map = new java . util . METHOD_6 ( ) ; com . streamsets . pipeline . api . IDENT_12 record = com . streamsets . pipeline . sdk . IDENT_13 . create ( STRING_1 , STRING_2 ) ; record . set ( com . streamsets . pipeline . api . Field . create ( map ) ) ; runner . METHOD_7 ( com . google . common . collect . ImmutableList . of ( record ) ) ; "<AssertPlaceHolder>" ; } finally { runner . METHOD_8 ( ) ; } } METHOD_9 ( ) { return IDENT_14 ; }
org . junit . Assert . assertEquals ( 1 , runner . METHOD_9 ( ) . size ( ) )