如何通过键前缀查询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")