lucene-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (SOLR-8878) Allow the DaemonStream run rate be controlled by the internal stream
Date Mon, 21 Mar 2016 16:44:25 GMT

    [ https://issues.apache.org/jira/browse/SOLR-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204573#comment-15204573
] 

ASF subversion and git services commented on SOLR-8878:
-------------------------------------------------------

Commit 5c074dac28adb51ed681f254cae61324ac5c9a6a in lucene-solr's branch refs/heads/branch_6x
from jbernste
[ https://git-wip-us.apache.org/repos/asf?p=lucene-solr.git;h=5c074da ]

SOLR-8878: Allow the DaemonStream run rate 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
>             Fix For: master, 6.0
>
>         Attachments: SOLR-8878.patch, 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-unsubscribe@lucene.apache.org
For additional commands, e-mail: dev-help@lucene.apache.org


Mime
View raw message