METHOD_0 ( ) { java . io . IDENT_0 IDENT_1 = new java . io . METHOD_1 ( IDENT_2 ) ; java . io . ByteArrayOutputStream out = new java . io . ByteArrayOutputStream ( ) ; int IDENT_3 ; byte [ ] buf = new byte [ INT_0 ] ; while ( ( IDENT_3 = IDENT_1 . read ( buf ) ) > 0 ) { out . write ( buf , 0 , IDENT_3 ) ; } out . close ( ) ; java . util . Map < java . lang . String , java . lang . String > attributes = new java . util . HashMap < java . lang . String , java . lang . String > ( ) { { put ( IDENT_4 . IDENT_5 . key ( ) , STRING_0 ) ; } } ; runner . METHOD_2 ( out . toByteArray ( ) , attributes ) ; runner . run ( ) ; org . apache . nifi . util . IDENT_6 IDENT_7 = runner . METHOD_3 ( IDENT_8 . IDENT_9 ) . get ( 0 ) ; byte [ ] IDENT_10 = runner . METHOD_4 ( IDENT_7 ) ; java . io . IDENT_11 IDENT_12 = new java . io . METHOD_5 ( IDENT_13 ) ; IDENT_12 . write ( IDENT_10 ) ; IDENT_12 . METHOD_6 ( ) ; IDENT_12 . close ( ) ; org . apache . hadoop . conf . Configuration conf = new org . apache . hadoop . conf . Configuration ( ) ; org . apache . hadoop . fs . IDENT_14 fs = org . apache . hadoop . fs . IDENT_14 . METHOD_7 ( conf ) ; org . apache . IDENT_15 . hadoop . metadata . IDENT_16 IDENT_17 ; IDENT_17 = org . apache . IDENT_15 . hadoop . IDENT_18 . METHOD_8 ( conf , new org . apache . hadoop . fs . Path ( IDENT_13 . getAbsolutePath ( ) ) , org . apache . nifi . IDENT_19 . IDENT_15 . IDENT_20 ) ; long IDENT_21 = 0 ; for ( org . apache . IDENT_15 . hadoop . metadata . IDENT_22 meta : IDENT_17 . METHOD_9 ( ) ) { IDENT_21 += meta . METHOD_10 ( ) ; } long IDENT_23 = records . size ( ) ; "<AssertPlaceHolder>" ; } size ( ) { return bytes . length ; }
org . junit . Assert . assertEquals ( IDENT_21 , IDENT_23 )