METHOD_0 ( ) { final java . util . List < java . lang . String > errors = new java . util . ArrayList < java . lang . String > ( ) ; java . lang . System . setProperty ( IDENT_0 . IDENT_1 , "1" ) ; org . pentaho . di . core . row . IDENT_2 IDENT_3 = new org . pentaho . di . core . row . METHOD_1 ( ) ; IDENT_3 . METHOD_2 ( new org . pentaho . di . core . row . value . METHOD_3 ( STRING_0 ) ) ; org . pentaho . di . core . Result IDENT_4 = new org . pentaho . di . core . Result ( ) ; IDENT_4 . METHOD_4 ( java . util . Arrays . asList ( new org . pentaho . di . core . METHOD_5 ( IDENT_3 , STRING_1 ) , new org . pentaho . di . core . METHOD_5 ( IDENT_3 , STRING_2 ) ) ) ; org . pentaho . di . IDENT_5 . streaming . common . IDENT_6 < java . util . List > IDENT_7 = new org . pentaho . di . IDENT_5 . streaming . common . METHOD_6 ( IDENT_8 , IDENT_3 , 0 , 10 , 10 ) ; org . pentaho . di . IDENT_5 . streaming . common . METHOD_6 < java . util . List > IDENT_9 = new org . pentaho . di . IDENT_5 . streaming . common . METHOD_6 ( IDENT_8 , IDENT_3 , 0 , 10 , 10 ) ; io . IDENT_10 . IDENT_11 IDENT_12 = io . IDENT_10 . IDENT_11 . METHOD_7 ( singletonList ( asList ( STRING_3 , STRING_4 ) ) ) ; java . lang . reflect . Field field = IDENT_7 . getClass ( ) . METHOD_8 ( STRING_5 ) ; field . METHOD_9 ( true ) ; java . util . concurrent . IDENT_13 IDENT_14 = ( ( java . util . concurrent . IDENT_13 ) ( field . get ( IDENT_7 ) ) ) ; when ( IDENT_8 . execute ( any ( ) ) ) . METHOD_10 ( ( org . mockito . IDENT_15 . IDENT_16 IDENT_15 ) -> { if ( ( IDENT_14 . METHOD_11 ( ) ) != 1 ) { errors . add ( ( STRING_6 + ( IDENT_14 . METHOD_11 ( ) ) ) ) ; } return java . util . Optional . of ( IDENT_4 ) ; } ) ; java . lang . Thread IDENT_17 = new java . lang . Thread ( new org . pentaho . di . IDENT_5 . streaming . common . IDENT_18 . METHOD_12 ( IDENT_7 , IDENT_12 , IDENT_4 ) ) ; IDENT_17 . start ( ) ; java . lang . Thread IDENT_19 = new java . lang . Thread ( new org . pentaho . di . IDENT_5 . streaming . common . IDENT_18 . METHOD_12 ( IDENT_9 , IDENT_12 , IDENT_4 ) ) ; IDENT_19 . start ( ) ; java . lang . Thread . sleep ( INT_0 ) ; "<AssertPlaceHolder>" ; } size ( ) { return ( IDENT_20 . length ) + ( IDENT_21 . length ) ; }
org . junit . Assert . assertEquals ( 0 , errors . size ( ) )