[jira] [Commented] (SOLR-8588) Add TopicStream to the streaming API

["Kevin Risden (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/SOLR-8588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147718#comment-15147718 ] 

Kevin Risden commented on SOLR-8588:
------------------------------------

This code could be cleaner I think:

{code}
Collections.shuffle(shuffler, new Random());
Replica rep = shuffler.get(0);
{code}

replace with something like:

{code}
Random random = new Random();
Replica rep = shuffler.get(random.nextInt(shuffler.size()));
{code}

The initialization of random could be done once I think.


> Add TopicStream to the streaming API
> ------------------------------------
>
>                 Key: SOLR-8588
>                 URL: https://issues.apache.org/jira/browse/SOLR-8588
>             Project: Solr
>          Issue Type: New Feature
>            Reporter: Joel Bernstein
>            Assignee: Joel Bernstein
>         Attachments: SOLR-8588.patch, SOLR-8588.patch
>
>
> The TopicStream is a *publish/subscribe messaging service* built on top of SolrCloud.  The TopicStream returns all *new* documents for a specific query. Version numbers will be used as checkpoints for Topics to ensure single delivery of each document. When combined with the DaemonStream (SOLR-8550), Topics can provide continuous streaming. Sample syntax:
> {code}
> topic(checkpointCollection, dataCollection, id="topicA",  q="awesome stuff" checkpointEvery="1000")
> {code}
> The checkpoint collection will be used to persist the topic checkpoints.
> Example combined with the DaemonStream:
> {code}
> daemon(topic(...)...)
> {code}
> When combined with SOLR-7739 this allows for messaging based on *machine learned* classifications.



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