Joel Bernstein created SOLR-8878:
------------------------------------
Summary: Allow the DaemonStream run rate to 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]
