lucene-dev mailing list archives

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


Joel Bernstein updated SOLR-8588:
    Attachment: SOLR-8588.patch

First pass at the TopicStream implementation. Tests to follow.

> Add TopicStream to the streaming API
> ------------------------------------
>                 Key: SOLR-8588
>                 URL:
>             Project: Solr
>          Issue Type: New Feature
>            Reporter: Joel Bernstein
>            Assignee: Joel Bernstein
>         Attachments: 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

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message