METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 IDENT_4 = METHOD_1 ( STRING_0 ) ; IDENT_4 . IDENT_5 = true ; com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_6 IDENT_7 = METHOD_2 ( IDENT_4 ) ; com . streamsets . pipeline . sdk . IDENT_8 IDENT_9 = new com . streamsets . pipeline . sdk . IDENT_8 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_10 . class , IDENT_7 ) . METHOD_3 ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_12 ) . build ( ) ; com . streamsets . pipeline . sdk . IDENT_13 . IDENT_14 IDENT_15 = null ; try { IDENT_9 . METHOD_4 ( ) ; IDENT_15 = IDENT_9 . METHOD_5 ( null , com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_16 ) ; while ( ! ( IDENT_15 . METHOD_6 ( ) . get ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_12 ) . isEmpty ( ) ) ) { IDENT_15 = IDENT_9 . METHOD_5 ( IDENT_15 . METHOD_7 ( ) , com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_16 ) ; } } finally { IDENT_9 . METHOD_8 ( ) ; } final java . lang . String IDENT_17 = IDENT_15 . METHOD_7 ( ) ; execute ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_18 , STRING_1 ) ; java . util . List < com . streamsets . pipeline . api . IDENT_19 > records = new java . util . METHOD_9 ( ) ; java . util . List < java . lang . String > IDENT_20 = java . util . Arrays . asList ( "1" , "2" ) ; java . util . List < com . streamsets . pipeline . sdk . IDENT_8 > runners = new java . util . ArrayList ( ) ; for ( java . lang . String IDENT_21 : IDENT_20 ) { com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 config = METHOD_1 ( STRING_0 ) ; config . IDENT_5 = false ; config . IDENT_21 = IDENT_21 ; com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_6 source = METHOD_2 ( config ) ; runner = new com . streamsets . pipeline . sdk . IDENT_8 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_10 . class , source ) . METHOD_3 ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_12 ) . build ( ) ; runner . METHOD_4 ( ) ; runners . add ( runner ) ; } java . util . concurrent . IDENT_22 IDENT_23 = java . util . concurrent . IDENT_24 . METHOD_10 ( 2 ) ; java . util . concurrent . IDENT_25 IDENT_26 = new java . util . concurrent . METHOD_11 ( 2 ) ; for ( final com . streamsets . pipeline . sdk . IDENT_8 runner : runners ) { IDENT_23 . METHOD_12 ( new java . lang . METHOD_13 ( ) { @ com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . Override public void run ( ) { try { com . streamsets . pipeline . sdk . IDENT_13 . IDENT_14 output = runner . METHOD_5 ( IDENT_17 , com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_16 ) ; while ( ! ( output . METHOD_6 ( ) . get ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_12 ) . isEmpty ( ) ) ) { records . addAll ( output . METHOD_6 ( ) . get ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_12 ) ) ; output = runner . METHOD_5 ( output . METHOD_7 ( ) , com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_11 . IDENT_16 ) ; } } catch ( java . lang . Exception e ) { throw com . google . common . base . IDENT_27 . METHOD_14 ( e ) ; } finally { IDENT_26 . METHOD_15 ( ) ; try { runner . METHOD_8 ( ) ; } catch ( com . streamsets . pipeline . api . IDENT_28 e ) { e . printStackTrace ( ) ; } } } } ) ; } IDENT_26 . METHOD_16 ( ) ; int count = 0 ; for ( com . streamsets . pipeline . api . IDENT_19 record : records ) { if ( record . get ( STRING_2 ) . METHOD_17 ( ) . equals ( "foo" ) ) { count += 1 ; } } "<AssertPlaceHolder>" ; } equals ( java . lang . Object ) { if ( ( this ) == o ) return true ; if ( ( o == null ) || ( ( getClass ( ) ) != ( o . getClass ( ) ) ) ) return false ; com . streamsets . pipeline . lib . jdbc . IDENT_29 . IDENT_30 that = ( ( com . streamsets . pipeline . lib . jdbc . IDENT_29 . IDENT_30 ) ( o ) ) ; return ( IDENT_31 ) == ( that . IDENT_31 ) ; }
org . junit . Assert . assertThat ( count , org . hamcrest . Matchers . is ( 2 ) )