3

Samza KeyValueStoreインターフェイスを使用して、共通のキー プレフィックスを持つすべてのドキュメントを取得するにはどうすればよいですか? キーは文字列であり、RocksDb が基になるストアになります。

range メソッドを使用した以下のアプローチに問題はありますか?

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)
4

1 に答える 1

0

これは機能しますが、範囲の終了値は排他的であるため、 store.range("aaa.", "b") を実行することもできます

于 2015-08-06T22:03:02.033 に答える