METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . executor . IDENT_1 . IDENT_2 conf = new com . streamsets . pipeline . IDENT_0 . executor . IDENT_1 . METHOD_1 ( ) ; conf . IDENT_3 = com . google . common . collect . ImmutableList . of ( STRING_0 ) ; conf . condition = STRING_1 ; conf . subject = STRING_2 ; conf . body = STRING_3 ; com . streamsets . pipeline . api . ext . IDENT_4 IDENT_5 = mock ( com . streamsets . pipeline . api . ext . IDENT_4 . class ) ; com . streamsets . pipeline . IDENT_0 . executor . IDENT_1 . IDENT_6 target = METHOD_2 ( new com . streamsets . pipeline . IDENT_0 . executor . IDENT_1 . METHOD_3 ( com . google . common . collect . ImmutableList . of ( conf ) ) ) ; when ( target . METHOD_4 ( ) ) . thenReturn ( IDENT_5 ) ; com . streamsets . pipeline . sdk . IDENT_7 exec = new com . streamsets . pipeline . sdk . IDENT_7 . Builder ( com . streamsets . pipeline . IDENT_0 . executor . IDENT_1 . IDENT_8 . class , target ) . METHOD_5 ( IDENT_9 . IDENT_10 ) . build ( ) ; java . util . Map < java . lang . String , com . streamsets . pipeline . api . Field > root = com . google . common . collect . ImmutableMap . of ( STRING_4 , com . streamsets . pipeline . api . Field . create ( STRING_5 ) , STRING_6 , com . streamsets . pipeline . api . Field . create ( STRING_7 ) , STRING_8 , com . streamsets . pipeline . api . Field . create ( 1 ) ) ; com . streamsets . pipeline . api . IDENT_11 IDENT_12 = com . streamsets . pipeline . sdk . IDENT_13 . create ( ) ; IDENT_12 . set ( com . streamsets . pipeline . api . Field . create ( root ) ) ; java . util . Map < java . lang . String , com . streamsets . pipeline . api . Field > IDENT_14 = com . google . common . collect . ImmutableMap . of ( STRING_4 , com . streamsets . pipeline . api . Field . create ( STRING_5 ) , STRING_6 , com . streamsets . pipeline . api . Field . create ( STRING_7 ) , STRING_8 , com . streamsets . pipeline . api . Field . create ( 2 ) ) ; com . streamsets . pipeline . api . IDENT_11 IDENT_15 = com . streamsets . pipeline . sdk . IDENT_13 . create ( ) ; IDENT_15 . set ( com . streamsets . pipeline . api . Field . create ( IDENT_14 ) ) ; java . util . Map < java . lang . String , com . streamsets . pipeline . api . Field > IDENT_16 = com . google . common . collect . ImmutableMap . of ( STRING_4 , com . streamsets . pipeline . api . Field . create ( STRING_5 ) , STRING_6 , com . streamsets . pipeline . api . Field . create ( STRING_7 ) , STRING_8 , com . streamsets . pipeline . api . Field . create ( STRING_9 ) ) ; com . streamsets . pipeline . api . IDENT_11 IDENT_17 = com . streamsets . pipeline . sdk . IDENT_13 . create ( ) ; IDENT_17 . set ( com . streamsets . pipeline . api . Field . create ( IDENT_16 ) ) ; java . util . List < com . streamsets . pipeline . api . IDENT_11 > records = com . google . common . collect . ImmutableList . of ( IDENT_12 , IDENT_15 , IDENT_17 ) ; exec . METHOD_6 ( ) ; exec . METHOD_7 ( records ) ; java . util . List < com . streamsets . pipeline . api . IDENT_11 > errors = exec . METHOD_8 ( ) ; "<AssertPlaceHolder>" ; } size ( ) { return delegate . size ( ) ; }
org . junit . Assert . assertEquals ( 1 , errors . size ( ) )