[
https://issues.apache.org/jira/browse/SOLR-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Bernstein updated SOLR-8878:
---------------------------------
Summary: Allow the DaemonStream run rate be controlled by the internal
stream (was: Allow the DaemonStream run rate to be controlled by the internal
stream)
> Allow the DaemonStream run rate be controlled by the internal stream
> --------------------------------------------------------------------
>
> Key: SOLR-8878
> URL: https://issues.apache.org/jira/browse/SOLR-8878
> Project: Solr
> Issue Type: Improvement
> Reporter: Joel Bernstein
>
> Currently the DaemonStream sleeps for one second and then checks the
> runInterval param to determine if it needs to rerun the internal stream.
> This setup will work fine if the runInterval is longer then one second and if
> it never changes. But with the TopicStream, you want a variable run rate. For
> example if the TopicStream's latest run has returned documents, the next run
> should be immediate. But if the TopicStream's latest run returned zero
> documents then you'd want to sleep for a period of time before starting the
> next run.
> This ticket allows the internal stream to control the DaemonStream run rate
> by adding a *sleepMillis* key-pair to the EOF Tuple. After each run the
> DaemonStream will check the EOF Tuple from the internal stream and if the
> sleepMillis key-pair is present it will adjust it's run rate accordingly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
