[jira] [Created] (SOLR-8281) Add RollupMergeStream to Streaming API

["Joel Bernstein (JIRA)" <ji...@apache.org>]

Joel Bernstein created SOLR-8281:
------------------------------------

             Summary: Add RollupMergeStream to Streaming API
                 Key: SOLR-8281
                 URL: https://issues.apache.org/jira/browse/SOLR-8281
             Project: Solr
          Issue Type: Bug
            Reporter: Joel Bernstein


The RollupMergeStream merges the aggregate results emitted by the RollupStream on *worker* nodes.

This is designed to be used in conjunction with the HashJoinStream to perform rollup Aggregations on the joined Tuples. The HashJoinStream will require the tuples to be partitioned on the Join keys. To avoid needing to repartition on the *group by* fields for the RollupStream, we can perform a merge of the rolled up Tuples coming from the workers.

The construct would like this:
{code}
mergeRollup (...
                      parallel (...
                                    hashJoin (
                                                     search(...),
                                                     search(...),
                                                     on="fieldA" 
                                     )
                         )
)
{code}


 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@lucene.apache.org
For additional commands, e-mail: dev-help@lucene.apache.org