Joe Wood created KAFKA-5243:
-------------------------------
Summary: Request to add row limit in ReadOnlyKeyValueStore range
function
Key: KAFKA-5243
URL: https://issues.apache.org/jira/browse/KAFKA-5243
Project: Kafka
Issue Type: Improvement
Components: streams
Affects Versions: 0.10.1.1
Reporter: Joe Wood
When using distributed queries across a cluster of stream stores it's quite
common to use query pagination to limit the number of rows returned. The
{{range}} function on {{ReadOnlyKeyValueStore}} only accepts the {{to}} and
{{from}} keys. This means that the query created either unncessarily retrieves
the entire range and manually limits the rows, or estimates the range based on
the key values. Neither options are ideal for processing distributed queries.
This suggestion is to add an overload to the {{range}} function by adding a
third (or replacement second) argument as a suggested row limit count. This
means that the range of keys returned will not exceed the supplied count.
{code:java}
// Get an iterator over a given range of keys, limiting to limit elements.
KeyValueIterator<K,V> range(K from, K to, int limit)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
