METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( false ) ; com . streamsets . pipeline . lib . io . IDENT_2 . IDENT_3 < java . io . InputStream > stream = null ; final com . streamsets . pipeline . lib . generator . IDENT_4 IDENT_5 = new com . streamsets . pipeline . lib . generator . IDENT_4 < java . util . Map < java . lang . String , java . lang . Object > > ( ) { @ com . streamsets . pipeline . lib . io . IDENT_2 . Override public void METHOD_2 ( java . util . Map < java . lang . String , java . lang . Object > IDENT_6 ) { IDENT_1 . METHOD_3 ( false , true ) ; } } ; try { stream = new com . streamsets . pipeline . lib . io . IDENT_2 . IDENT_3 < java . io . InputStream > ( new java . io . ByteArrayInputStream ( IDENT_7 . IDENT_8 . getBytes ( ) ) , IDENT_9 . IDENT_10 . IDENT_11 , IDENT_5 ) ; stream . read ( new byte [ IDENT_7 . IDENT_8 . length ( ) ] ) ; } finally { if ( stream != null ) { stream . close ( ) ; } } "<AssertPlaceHolder>" ; } get ( ) { return this . root ; }
org . junit . Assert . assertTrue ( IDENT_1 . get ( ) )