我有一个类型为KeyValueStore>的KeyValueStore。我不知道键的范围。有什么办法可以遍历samza中的整个keyvaluestore?谢谢
最佳答案
当然。在KeyValueStore实例上使用all()方法。这将返回一个迭代器,可用于扫描整个商店。
http://samza.apache.org/learn/documentation/0.12/api/javadocs/org/apache/samza/storage/kv/KeyValueStore.html#all--