[
https://issues.apache.org/jira/browse/SOLR-8550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Bernstein updated SOLR-8550:
---------------------------------
Attachment: SOLR-8550.patch
Added a simple test that iterates 10 times over a rollup. The data doesn't
change underneath so the values are the same each time. This tests the internal
thread and queue setup of the DaemonStream. It also demonstrates how a
DaemonStream.read() blocks until there is new data in the queue populated by
the underlying Stream.
The RollupStream needed to be changed that so that it resets it's state upon
closing to support calling open() and close() multiple times on the same
stream. Any Stream wrapped by the DaemonStream will need to do the same.
> Add asynchronous DaemonStreams to the Streaming API
> ---------------------------------------------------
>
> Key: SOLR-8550
> URL: https://issues.apache.org/jira/browse/SOLR-8550
> Project: Solr
> Issue Type: New Feature
> Reporter: Joel Bernstein
> Attachments: SOLR-8550.patch, SOLR-8550.patch, SOLR-8550.patch,
> SOLR-8550.patch, SOLR-8550.patch, SOLR-8550.patch, SOLR-8550.patch,
> SOLR-8550.patch, SOLR-8550.patch, SOLR-8550.patch, SOLR-8550.patch,
> SOLR-8550.patch
>
>
> Currently all streams in the Streaming API are synchronously *pulled* by a
> client.
> It would be great to add the capability to have asyncronous *DaemonStreams*
> that live within Solr that can *push* content as well. This would facilite
> large scale alerting and background aggregation use cases.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@lucene.apache.org
For additional commands, e-mail: dev-h...@lucene.apache.org
