METHOD_0 ( ) { java . io . ByteArrayOutputStream out = new java . io . ByteArrayOutputStream ( 255 ) ; com . streamsets . pipeline . lib . generator . IDENT_0 gen = new com . streamsets . pipeline . lib . generator . IDENT_1 . METHOD_1 ( out , STRING_0 ) ; com . streamsets . pipeline . api . IDENT_2 record = com . streamsets . pipeline . sdk . IDENT_3 . create ( ) ; java . util . Map < java . lang . String , com . streamsets . pipeline . api . Field > map = new java . util . HashMap ( ) ; map . put ( STRING_1 , com . streamsets . pipeline . api . Field . create ( com . streamsets . pipeline . lib . generator . IDENT_1 . IDENT_4 . IDENT_5 . getBytes ( ) ) ) ; record . set ( com . streamsets . pipeline . api . Field . create ( map ) ) ; gen . write ( record ) ; gen . METHOD_2 ( ) ; "<AssertPlaceHolder>" ; gen . close ( ) ; } METHOD_2 ( ) { if ( IDENT_6 ) { throw new java . io . IOException ( STRING_2 ) ; } IDENT_7 . METHOD_2 ( ) ; }
org . junit . Assert . assertTrue ( java . util . Arrays . equals ( com . streamsets . pipeline . lib . generator . IDENT_1 . IDENT_4 . IDENT_5 . getBytes ( ) , out . toByteArray ( ) ) )