METHOD_0 ( ) { 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 } , new byte [ ] { INT_0 } } ; for ( int i = 0 ; i < ( bytes . length ) ; i += 2 ) { store . put ( org . apache . kafka . common . utils . IDENT_0 . METHOD_1 ( bytes [ i ] ) , bytes [ i ] ) ; cache . put ( IDENT_1 , org . apache . kafka . common . utils . IDENT_0 . METHOD_1 ( bytes [ ( i + 1 ) ] ) , new org . apache . kafka . streams . state . IDENT_2 . METHOD_2 ( bytes [ ( i + 1 ) ] ) ) ; } final org . apache . kafka . common . utils . IDENT_0 from = org . apache . kafka . common . utils . IDENT_0 . METHOD_1 ( new byte [ ] { 2 } ) ; final org . apache . kafka . common . utils . IDENT_0 to = org . apache . kafka . common . utils . IDENT_0 . METHOD_1 ( new byte [ ] { 9 } ) ; final org . apache . kafka . streams . state . IDENT_3 < org . apache . kafka . common . utils . IDENT_0 , byte [ ] > IDENT_4 = new org . apache . kafka . streams . state . IDENT_2 . METHOD_3 ( STRING_0 , store . range ( from , to ) ) ; final org . apache . kafka . streams . state . IDENT_2 . IDENT_5 . IDENT_6 IDENT_7 = cache . range ( IDENT_1 , from , to ) ; final org . apache . kafka . streams . state . IDENT_2 . IDENT_8 iterator = new org . apache . kafka . streams . state . IDENT_2 . METHOD_4 ( IDENT_7 , IDENT_4 ) ; final byte [ ] [ ] values = new byte [ 8 ] [ ] ; int index = 0 ; int IDENT_9 = 2 ; while ( iterator . hasNext ( ) ) { final byte [ ] value = iterator . next ( ) . value ; values [ ( index ++ ) ] = value ; "<AssertPlaceHolder>" ; } iterator . close ( ) ; } next ( ) { throw new java . util . METHOD_5 ( ) ; }
org . junit . Assert . assertArrayEquals ( bytes [ ( IDENT_9 ++ ) ] , value )