Liking cljdoc? Tell your friends :D

hive-milvus.relocate.enumerate

Every id in a collection.

A drain can read the head repeatedly because moved rows leave the source. A COPY leaves them, so it needs the full id set up front — and Milvus caps a query at max-page rows and returns them in no particular order, so a single page is not the collection.

The id space is therefore split into disjoint prefix buckets, each fetched whole. A bucket that comes back full may have been truncated, so it is split again. Nothing is ever assumed about ordering, and a bucket that cannot be split further raises rather than returning a short answer.

Every id in a collection.

A drain can read the head repeatedly because moved rows leave the source.
A COPY leaves them, so it needs the full id set up front — and Milvus caps a
query at `max-page` rows and returns them in no particular order, so a single
page is not the collection.

The id space is therefore split into disjoint prefix buckets, each fetched
whole. A bucket that comes back full may have been truncated, so it is split
again. Nothing is ever assumed about ordering, and a bucket that cannot be
split further raises rather than returning a short answer.
raw docstring

all-idsclj

(all-ids coll)

Every id in coll, as a vector. Raises rather than truncating.

Every id in `coll`, as a vector. Raises rather than truncating.
sourceraw docstring

max-pageclj

Milvus caps a query's limit here.

Milvus caps a query's limit here.
sourceraw docstring

rows-matchingclj

(rows-matching fetch filter-expr limit)

Up to limit rows satisfying filter-expr, read through FETCH ((fn [filter-expr limit] rows)), which is never asked for more than max-page. Within the cap this is one fetch; above it the matching rows are gathered from disjoint id-prefix buckets, stopping once limit are held. Raises rather than truncating.

Up to `limit` rows satisfying `filter-expr`, read through FETCH
(`(fn [filter-expr limit] rows)`), which is never asked for more than
`max-page`. Within the cap this is one fetch; above it the matching rows are
gathered from disjoint id-prefix buckets, stopping once `limit` are held.
Raises rather than truncating.
sourceraw docstring

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
Move to previous article
Move to next article
Ctrl+/Jump to the search field
× close