如何通过键前缀查询 Samza KeyValueStore？

Question

使用 Samza KeyValueStore 界面，我如何检索具有公共键前缀的所有文档？键是字符串，RocksDb 将是底层存储。

下面使用范围方法的方法是否有任何问题？

KeyValueStore<String,String> store = (KeyValueStore<String, String>) context.getStore("foo")
store.put("aaa.xxx", "foo");
store.put("aaa.yyy", "bar");
store.put("bbb.zzz", "qux");

// get all docs starting with "aaa."
KeyValueIterator<String, String> it = store.range("aaa.", "aaa." + Character.MAX_VALUE)

Answer 1

这可行，但由于范围结束值是唯一的，您也可以只执行 store.range("aaa.", "b")

如何通过键前缀查询 Samza KeyValueStore？

How to query Samza KeyValueStore by key prefix?

java

apache-samza