METHOD_0 ( ) { com . streamsets . pipeline . api . IDENT_0 source = new com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_3 . METHOD_1 ( ) ; com . streamsets . IDENT_1 . runner . IDENT_4 . METHOD_2 ( source ) ; com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_3 . IDENT_5 executor = new com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_3 . METHOD_3 ( ) ; com . streamsets . IDENT_1 . runner . IDENT_4 . METHOD_4 ( executor ) ; com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_3 . IDENT_6 IDENT_7 = new com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_3 . METHOD_5 ( ) ; com . streamsets . IDENT_1 . runner . IDENT_4 . METHOD_6 ( IDENT_7 ) ; com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_8 pipeline = METHOD_7 ( IDENT_9 . IDENT_10 , true , com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_3 . IDENT_11 . IDENT_12 ) ; pipeline . METHOD_8 ( new com . streamsets . IDENT_1 . IDENT_2 . runner . common . IDENT_3 . METHOD_9 ( ) ) ; pipeline . run ( ) ; "<AssertPlaceHolder>" ; } size ( ) { return delegate . size ( ) ; }
org . junit . Assert . assertEquals ( 1 , IDENT_7 . records . size ( ) )