METHOD_0 ( ) { final org . apache . kafka . streams . state . IDENT_0 < org . apache . kafka . common . utils . IDENT_1 , byte [ ] > IDENT_2 = new org . apache . kafka . streams . state . IDENT_3 . METHOD_1 ( STRING_0 ) ; final org . apache . kafka . streams . state . IDENT_3 . IDENT_4 cache = new org . apache . kafka . streams . state . IDENT_3 . METHOD_2 ( new org . apache . kafka . common . utils . METHOD_3 ( STRING_1 ) , INT_0 , new org . apache . kafka . streams . processor . IDENT_3 . METHOD_4 ( new org . apache . kafka . common . metrics . METHOD_5 ( ) ) ) ; final byte [ ] [ ] bytes = new byte [ ] [ ] { new byte [ ] { 0 } , new byte [ ] { 1 } , new byte [ ] { 2 } , new byte [ ] { 3 } , new byte [ ] { 4 } , new byte [ ] { 5 } , new byte [ ] { 6 } , new byte [ ] { 7 } , new byte [ ] { 8 } , new byte [ ] { 9 } , new byte [ ] { 10 } } ; for ( int i = 0 ; i < ( ( bytes . length ) - 1 ) ; i += 2 ) { IDENT_2 . put ( org . apache . kafka . common . utils . IDENT_1 . METHOD_6 ( bytes [ i ] ) , bytes [ i ] ) ; cache . put ( IDENT_5 , org . apache . kafka . common . utils . IDENT_1 . METHOD_6 ( bytes [ ( i + 1 ) ] ) , new org . apache . kafka . streams . state . IDENT_3 . METHOD_7 ( bytes [ ( i + 1 ) ] ) ) ; } final org . apache . kafka . common . utils . IDENT_1 from = org . apache . kafka . common . utils . IDENT_1 . METHOD_6 ( new byte [ ] { 2 } ) ; final org . apache . kafka . common . utils . IDENT_1 to = org . apache . kafka . common . utils . IDENT_1 . METHOD_6 ( new byte [ ] { 9 } ) ; final org . apache . kafka . streams . state . IDENT_6 < org . apache . kafka . common . utils . IDENT_1 , byte [ ] > IDENT_7 = IDENT_2 . range ( from , to ) ; final org . apache . kafka . streams . state . IDENT_3 . METHOD_2 . IDENT_8 IDENT_9 = cache . range ( IDENT_5 , from , to ) ; final org . apache . kafka . streams . state . IDENT_3 . IDENT_10 iterator = new org . apache . kafka . streams . state . IDENT_3 . METHOD_8 ( IDENT_9 , IDENT_7 ) ; final byte [ ] [ ] values = new byte [ 8 ] [ ] ; int index = 0 ; int IDENT_11 = 2 ; while ( iterator . hasNext ( ) ) { final byte [ ] keys = iterator . METHOD_9 ( ) . get ( ) ; values [ ( index ++ ) ] = keys ; "<AssertPlaceHolder>" ; iterator . next ( ) ; } iterator . close ( ) ; } get ( ) { this . result . METHOD_10 ( ) ; if ( ( IDENT_12 ) != null ) return IDENT_12 . get ( ) ; return METHOD_11 ( ) ; }
org . junit . Assert . assertArrayEquals ( bytes [ ( IDENT_11 ++ ) ] , keys )