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 = com . streamsets . pipeline . lib . util . IDENT_5 . IDENT_6 ; IDENT_3 . IDENT_7 = IDENT_8 ; IDENT_3 . IDENT_9 = true ; IDENT_3 . IDENT_10 = com . streamsets . pipeline . config . IDENT_11 . IDENT_12 ; com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_13 . IDENT_14 IDENT_15 = com . streamsets . pipeline . lib . IDENT_16 . METHOD_2 ( com . streamsets . pipeline . lib . IDENT_16 . METHOD_3 ( port , false ) , IDENT_17 . IDENT_18 , IDENT_3 ) ; com . streamsets . pipeline . sdk . IDENT_19 IDENT_20 = new com . streamsets . pipeline . sdk . IDENT_19 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_13 . IDENT_21 . class , IDENT_15 ) . build ( ) ; IDENT_20 . METHOD_4 ( ) ; java . util . List < com . streamsets . pipeline . api . IDENT_22 > records = com . streamsets . pipeline . lib . util . IDENT_5 . METHOD_5 ( ) ; IDENT_20 . METHOD_6 ( records ) ; IDENT_20 . METHOD_7 ( ) ; java . util . List < org . apache . avro . IDENT_23 . IDENT_24 > IDENT_25 = new java . util . ArrayList ( ) ; org . apache . avro . io . IDENT_26 < org . apache . avro . IDENT_23 . IDENT_24 > IDENT_27 = new org . apache . avro . IDENT_23 . METHOD_8 ( ) ; org . apache . IDENT_13 . IDENT_28 transaction = ch . METHOD_9 ( ) ; transaction . METHOD_10 ( ) ; org . apache . IDENT_13 . IDENT_29 event = ch . METHOD_11 ( ) ; while ( event != null ) { org . apache . avro . file . IDENT_30 < org . apache . avro . IDENT_23 . IDENT_24 > IDENT_31 = new org . apache . avro . file . METHOD_12 ( new org . apache . avro . file . METHOD_13 ( event . METHOD_14 ( ) ) , IDENT_27 ) ; while ( IDENT_31 . hasNext ( ) ) { IDENT_25 . add ( IDENT_31 . next ( ) ) ; } event = ch . METHOD_11 ( ) ; } transaction . commit ( ) ; transaction . close ( ) ; "<AssertPlaceHolder>" ; com . streamsets . pipeline . lib . util . IDENT_5 . METHOD_15 ( IDENT_25 ) ; } size ( ) { return delegate . size ( ) ; }
org . junit . Assert . assertEquals ( 3 , IDENT_25 . size ( ) )