[ https://issues.apache.org/jira/browse/SOLR-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Joel Bernstein updated SOLR-8878: --------------------------------- Attachment: SOLR-8878.patch > 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 > Attachments: SOLR-8878.patch > > > 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: dev-unsubscr...@lucene.apache.org For additional commands, e-mail: dev-h...@lucene.apache.org