METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 source = new com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_1 ( METHOD_2 ( IDENT_4 . IDENT_5 , java . util . Collections . emptyList ( ) ) ) ; com . streamsets . pipeline . sdk . IDENT_6 runner = new com . streamsets . pipeline . sdk . IDENT_6 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_7 . class , source ) . METHOD_3 ( "a" ) . build ( ) ; runner . METHOD_4 ( ) ; try { java . util . List < com . streamsets . pipeline . api . IDENT_8 > records = new java . util . ArrayList ( ) ; runner . METHOD_5 ( java . util . Collections . < java . lang . String , java . lang . String > METHOD_6 ( ) , 1 , new com . streamsets . pipeline . sdk . IDENT_6 . METHOD_7 ( ) { @ com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . Override public void METHOD_8 ( com . streamsets . pipeline . sdk . IDENT_9 . IDENT_10 output ) { records . METHOD_9 ( ) ; records . addAll ( output . METHOD_10 ( ) . get ( "a" ) ) ; runner . METHOD_11 ( ) ; } } ) ; runner . METHOD_12 ( ) ; "<AssertPlaceHolder>" ; } finally { runner . METHOD_13 ( ) ; } } size ( ) { return delegate . size ( ) ; }
org . junit . Assert . assertEquals ( 1 , records . size ( ) )