METHOD_0 ( ) { final org . apache . nifi . IDENT_0 . IDENT_1 config = org . apache . nifi . IDENT_0 . IDENT_2 . METHOD_1 ( ) ; config . METHOD_2 ( ( ( INT_0 * INT_0 ) * INT_1 ) ) ; config . METHOD_3 ( 20 , TimeUnit . IDENT_3 ) ; config . METHOD_4 ( false ) ; config . METHOD_5 ( 10 ) ; config . METHOD_6 ( 10 ) ; repo = new org . apache . nifi . IDENT_0 . METHOD_7 ( config , org . apache . nifi . IDENT_0 . IDENT_2 . IDENT_4 ) ; repo . METHOD_8 ( METHOD_9 ( ) , null , null , IDENT_5 . IDENT_6 ) ; final java . util . Map < java . lang . String , java . lang . String > attributes = new java . util . HashMap ( ) ; attributes . put ( STRING_0 , STRING_1 ) ; attributes . put ( STRING_1 , STRING_0 ) ; attributes . put ( STRING_2 , java . util . UUID . METHOD_10 ( ) . toString ( ) ) ; final org . apache . nifi . IDENT_0 . IDENT_7 builder = new org . apache . nifi . IDENT_0 . IDENT_8 . Builder ( ) ; builder . METHOD_11 ( java . lang . System . currentTimeMillis ( ) ) ; builder . METHOD_12 ( IDENT_9 . IDENT_10 ) ; builder . METHOD_13 ( STRING_3 ) ; builder . METHOD_14 ( org . apache . nifi . IDENT_0 . IDENT_11 . METHOD_15 ( INT_2 , INT_3 , attributes ) ) ; builder . METHOD_16 ( STRING_4 ) ; builder . METHOD_17 ( STRING_5 ) ; final org . apache . nifi . IDENT_0 . IDENT_12 record = builder . build ( ) ; final java . lang . IDENT_13 r = new java . lang . METHOD_18 ( ) { @ org . apache . nifi . IDENT_0 . Override public void run ( ) { for ( int i = 0 ; i < INT_4 ; i ++ ) { repo . METHOD_19 ( record ) ; } } } ; final java . lang . Thread [ ] IDENT_14 = new java . lang . Thread [ 10 ] ; for ( int i = 0 ; i < ( IDENT_14 . length ) ; i ++ ) { IDENT_14 [ i ] = new java . lang . Thread ( r ) ; } final long start = java . lang . System . METHOD_20 ( ) ; for ( final java . lang . Thread t : IDENT_14 ) { t . start ( ) ; } for ( final java . lang . Thread t : IDENT_14 ) { t . join ( ) ; } final long IDENT_15 = ( java . lang . System . METHOD_20 ( ) ) - start ; final long IDENT_16 = TimeUnit . IDENT_17 . METHOD_21 ( IDENT_15 ) ; final long IDENT_18 = INT_5 / IDENT_16 ; final long IDENT_19 = IDENT_18 * 1000 ; System . out . println ( ( ( ( IDENT_16 + STRING_6 ) + IDENT_19 ) + STRING_7 ) ) ; System . out . println ( STRING_8 ) ; repo . close ( ) ; repo = new org . apache . nifi . IDENT_0 . METHOD_7 ( config , org . apache . nifi . IDENT_0 . IDENT_2 . IDENT_4 ) ; repo . METHOD_8 ( METHOD_9 ( ) , null , null , IDENT_5 . IDENT_6 ) ; System . out . println ( STRING_9 ) ; final long IDENT_20 = java . lang . System . METHOD_20 ( ) ; final java . util . List < org . apache . nifi . IDENT_0 . IDENT_12 > records = repo . METHOD_22 ( 0L , INT_5 ) ; final long IDENT_21 = TimeUnit . IDENT_17 . METHOD_21 ( ( ( java . lang . System . METHOD_20 ( ) ) - IDENT_20 ) ) ; "<AssertPlaceHolder>" ; final long IDENT_22 = INT_5 / IDENT_21 ; final long IDENT_23 = IDENT_22 * INT_6 ; System . out . println ( ( ( ( IDENT_21 + STRING_2 0 ) + IDENT_23 ) + STRING_7 ) ) ; repo . close ( ) ; } size ( ) { return bytes . length ; }
org . junit . Assert . assertEquals ( INT_5 , records . size ( ) )