Yes, that was the missing piece. Thanks a lot!
On Thu, Jun 22, 2017 at 5:20 PM, Joel Bernstein wrote:
> Here is the psuedo code:
>
> rollup(sort(fetch(gatherNodes(
>
> Joel Bernstein
> http://joelsolr.blogspot.com/
>
> On Thu, Jun 22, 2017 at 5:19 PM, Joel Bernstein
> wrote:
>
> > You'll ne
Here is the psuedo code:
rollup(sort(fetch(gatherNodes(
Joel Bernstein
http://joelsolr.blogspot.com/
On Thu, Jun 22, 2017 at 5:19 PM, Joel Bernstein wrote:
> You'll need to use the sort expression to sort the nodes by schemaType
> first. The rollup expression is doing a MapReduce rollup th
You'll need to use the sort expression to sort the nodes by schemaType
first. The rollup expression is doing a MapReduce rollup that requires the
the records to be sorted by the "over" fields.
Joel Bernstein
http://joelsolr.blogspot.com/
On Thu, Jun 22, 2017 at 2:49 PM, Pratik Patel wrote:
> Hi
Hi,
I have a streaming expression which uses rollup function. My understanding
is that rollup takes an incoming stream and aggregates over given buckets.
However, with following query the result contains duplicate tuples.
Following is the streaming expression.
rollup(
fetch(
collecti
