lucene-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Joel Bernstein (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (SOLR-8588) Add TopicStream to the streaming API
Date Sun, 14 Feb 2016 16:12:18 GMT

     [ https://issues.apache.org/jira/browse/SOLR-8588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Joel Bernstein updated SOLR-8588:
---------------------------------
    Description: 
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")
{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.

  was:
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")
{code}

The checkpoint collection will be used to persist the topic checkpoints.

Example combined with the DaemonStream:

{code}
daemon(topic(...)...)
{code}


> 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
>
> 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")
> {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


Mime
View raw message