Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
我有一个 KeyValueStore> 类型的 KeyValueStore。我不知道键的范围。有什么方法可以遍历 samza 中的整个 keyvaluestore 吗?谢谢
当然。在 KeyValueStore 实例上使用 all() 方法。这将返回一个迭代器,您可以使用它来扫描整个商店。
http://samza.apache.org/learn/documentation/0.12/api/javadocs/org/apache/samza/storage/kv/KeyValueStore.html#all--