METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . IDENT_1 . lib . IDENT_2 IDENT_3 = new com . streamsets . pipeline . IDENT_0 . IDENT_1 . lib . METHOD_1 ( ) ; IDENT_3 . IDENT_4 = "/" ; IDENT_3 . IDENT_5 = false ; com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_6 . IDENT_7 IDENT_8 = com . streamsets . pipeline . lib . IDENT_9 . METHOD_2 ( com . streamsets . pipeline . lib . IDENT_9 . METHOD_3 ( false , 100 , IDENT_10 . IDENT_11 , INT_0 , com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_6 . IDENT_12 . IDENT_13 , IDENT_14 . IDENT_15 , ( - 1 ) , 1 , INT_0 , false , 0 ) , IDENT_16 . IDENT_17 , IDENT_3 ) ; com . streamsets . pipeline . sdk . IDENT_18 IDENT_19 = new com . streamsets . pipeline . sdk . IDENT_18 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_6 . IDENT_20 . class , IDENT_8 ) . build ( ) ; IDENT_19 . METHOD_4 ( ) ; java . util . List < java . util . List < com . streamsets . pipeline . api . IDENT_21 > > IDENT_22 = new java . util . ArrayList ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_6 . IDENT_12 . IDENT_23 ) ; for ( int i = 0 ; i < ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_6 . IDENT_12 . IDENT_23 ) ; i ++ ) { IDENT_22 . add ( com . streamsets . pipeline . lib . IDENT_9 . METHOD_5 ( ) ) ; } int IDENT_24 = 0 ; for ( int i = 0 ; i < ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_6 . IDENT_12 . IDENT_23 ) ; i ++ ) { IDENT_19 . METHOD_6 ( IDENT_22 . get ( i ) ) ; IDENT_24 += IDENT_22 . get ( i ) . size ( ) ; } IDENT_19 . METHOD_7 ( ) ; int IDENT_25 = 0 ; for ( org . apache . IDENT_6 . IDENT_26 channel : IDENT_27 ) { org . apache . IDENT_6 . IDENT_28 transaction = channel . METHOD_8 ( ) ; transaction . METHOD_9 ( ) ; while ( ( channel . METHOD_10 ( ) ) != null ) { IDENT_25 ++ ; } transaction . commit ( ) ; transaction . close ( ) ; } "<AssertPlaceHolder>" ; } close ( ) { generator . close ( ) ; }
org . junit . Assert . assertEquals ( IDENT_24 , IDENT_25 )