METHOD_0 ( ) { final com . streamsets . pipeline . api . IDENT_0 IDENT_1 = com . streamsets . pipeline . api . IDENT_0 . IDENT_2 ; com . streamsets . pipeline . IDENT_3 . processor . spark . IDENT_4 IDENT_5 = METHOD_1 ( ) ; IDENT_5 . IDENT_6 = com . streamsets . pipeline . IDENT_3 . processor . spark . IDENT_7 . class . METHOD_2 ( ) ; com . streamsets . pipeline . IDENT_3 . processor . spark . IDENT_8 processor = new com . streamsets . pipeline . IDENT_3 . processor . spark . METHOD_3 ( IDENT_5 ) ; com . streamsets . pipeline . sdk . IDENT_9 runner = new com . streamsets . pipeline . sdk . IDENT_9 . Builder ( IDENT_10 , processor ) . METHOD_4 ( com . streamsets . pipeline . IDENT_3 . processor . spark . IDENT_11 . IDENT_12 ) . METHOD_5 ( IDENT_1 ) . build ( ) ; java . util . IDENT_13 random = new java . util . METHOD_6 ( ) ; java . util . List < com . streamsets . pipeline . api . IDENT_14 > records = new java . util . ArrayList ( 100 ) ; for ( int i = 0 ; i < 100 ; i ++ ) { com . streamsets . pipeline . api . IDENT_14 r = com . streamsets . pipeline . sdk . IDENT_15 . create ( ) ; records . add ( r ) ; r . set ( com . streamsets . pipeline . api . Field . create ( new java . util . HashMap < java . lang . String , com . streamsets . pipeline . api . Field > ( ) ) ) ; r . set ( IDENT_7 . IDENT_16 , com . streamsets . pipeline . api . Field . create ( java . lang . String . valueOf ( random . METHOD_7 ( ) ) ) ) ; } try { runner . METHOD_8 ( ) ; runner . METHOD_9 ( records ) ; java . util . List < com . streamsets . pipeline . api . IDENT_14 > errors = runner . METHOD_10 ( ) ; for ( int i = 0 ; i < 100 ; i ++ ) { "<AssertPlaceHolder>" ; METHOD_11 ( records . get ( i ) . METHOD_12 ( ) , errors . get ( i ) . METHOD_12 ( ) ) ; } } finally { runner . METHOD_13 ( ) ; } } get ( java . lang . String ) { return null ; }
org . junit . Assert . assertEquals ( records . get ( i ) . get ( ) , errors . get ( i ) . get ( ) )