METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 config = METHOD_1 ( ) ; com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_4 target = new com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_2 ( config , new com . streamsets . pipeline . IDENT_0 . IDENT_1 . lib . METHOD_3 ( ) ) ; com . streamsets . pipeline . sdk . IDENT_5 IDENT_6 = new com . streamsets . pipeline . sdk . IDENT_5 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_7 . class , target ) . METHOD_4 ( IDENT_8 . IDENT_9 ) . build ( ) ; com . streamsets . pipeline . IDENT_0 . lib . IDENT_2 . IDENT_10 . METHOD_5 ( 1 ) ; com . amazonaws . services . IDENT_2 . IDENT_11 . IDENT_12 IDENT_11 = mock ( com . amazonaws . services . IDENT_2 . IDENT_11 . IDENT_12 . class ) ; org . mockito . internal . util . IDENT_13 . IDENT_14 . METHOD_6 ( target , STRING_0 , IDENT_11 ) ; IDENT_6 . METHOD_7 ( ) ; com . google . common . util . concurrent . IDENT_15 < com . amazonaws . services . IDENT_2 . IDENT_11 . IDENT_16 > future = mock ( com . google . common . util . concurrent . IDENT_15 . class ) ; com . amazonaws . services . IDENT_2 . IDENT_11 . IDENT_16 result = mock ( com . amazonaws . services . IDENT_2 . IDENT_11 . IDENT_16 . class ) ; when ( result . METHOD_8 ( ) ) . thenReturn ( true ) ; when ( future . get ( ) ) . thenReturn ( result ) ; when ( IDENT_11 . METHOD_9 ( any ( java . lang . String . class ) , any ( java . lang . String . class ) , any ( java . nio . ByteBuffer . class ) ) ) . thenReturn ( future ) ; java . util . List < com . streamsets . pipeline . api . IDENT_17 > records = new java . util . ArrayList ( 4 ) ; records . add ( com . streamsets . pipeline . IDENT_0 . lib . IDENT_2 . IDENT_10 . METHOD_10 ( ) ) ; records . addAll ( com . streamsets . pipeline . IDENT_0 . lib . IDENT_2 . IDENT_10 . METHOD_11 ( 3 ) ) ; IDENT_6 . METHOD_12 ( records ) ; verify ( IDENT_11 , times ( 3 ) ) . METHOD_9 ( eq ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_18 . IDENT_19 ) , any ( java . lang . String . class ) , any ( java . nio . ByteBuffer . class ) ) ; "<AssertPlaceHolder>" ; IDENT_6 . METHOD_13 ( ) ; } METHOD_14 ( ) { return IDENT_20 ; }
org . junit . Assert . assertEquals ( 1 , IDENT_6 . METHOD_14 ( ) . size ( ) )