Hi, Alexander,
Very glad that you figured it out! Thanks!
-Yi
On Tue, Nov 17, 2015 at 1:41 PM, Alexander Filipchik
wrote:
> Just want to update you on this one. After some time spent in debugging I
> found that the actual problem was a piece of our code that was calling
> next() on a range ite
Just want to update you on this one. After some time spent in debugging I
found that the actual problem was a piece of our code that was calling
next() on a range iterator twice :(.
After removing the duplicate call everything works as expected.
Thank you!
Alex
On Mon, Nov 16, 2015 at 10:45 PM,
Hi, Alexander,
Sorry to reply late on this one. I embedded my questions and comments
in-between the lines:
On Sun, Nov 15, 2015 at 7:07 PM, Alexander Filipchik
wrote:
>
> nodeIterator = store.range(
> String.join(".", nodeId, String.valueOf(Character.MIN_VALUE)),
> String.join("
Hello Samza community!
I'm currently building a graph processing POC with Samza as an engine and
faced an interesting problem.
What I'm trying to do is to cache a graph in KV storage(RocksDbK) using
simple notation:
key: node1_id.node2_id (or nodeIds separated by a dot)
value: empty string for no
