0

我有一个 KeyValueStore> 类型的 KeyValueStore。我不知道键的范围。有什么方法可以遍历 samza 中的整个 keyvaluestore 吗?谢谢

4

1 回答 1

3

当然。在 KeyValueStore 实例上使用 all() 方法。这将返回一个迭代器,您可以使用它来扫描整个商店。

http://samza.apache.org/learn/documentation/0.12/api/javadocs/org/apache/samza/storage/kv/KeyValueStore.html#all--

于 2017-05-03T18:47:56.077 回答