[jira] [Commented] (SOLR-9684) Add scheduler Streaming Expression

["David Smiley (JIRA)" <ji...@apache.org>]

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

David Smiley commented on SOLR-9684:
------------------------------------

When I saw the title of this issue, I thought this was something quite different than what it was -- I thought this was about executing something (or emitting tuples) at a certain time or in a periodic fashion.  

We've already got a {{merge()}} streaming expression that seems remarkably close to this... the only difference here is favoring one stream's tuples over another.  Maybe you could call the feature here mergePrioritized or something like that?

> Add scheduler Streaming Expression
> ----------------------------------
>
>                 Key: SOLR-9684
>                 URL: https://issues.apache.org/jira/browse/SOLR-9684
>             Project: Solr
>          Issue Type: New Feature
>      Security Level: Public(Default Security Level. Issues are Public) 
>            Reporter: Joel Bernstein
>            Assignee: Joel Bernstein
>         Attachments: SOLR-9684.patch, SOLR-9684.patch, SOLR-9684.patch
>
>
> SOLR-9559 adds a general purpose *parallel task executor* for streaming expressions. The executor() function executes a stream of tasks and doesn't have any concept of task priority.
> The scheduler() function wraps two streams, a high priority stream and a low priority stream. The scheduler function emits tuples from the high priority stream first, and then the low priority stream.
> The executor() function can then wrap the scheduler function to see tasks in priority order.
> Pseudo syntax:
> {code}
> daemon(executor(schedule(topic(tasks, q="priority:high"), topic(tasks, q="priority:low"))))
> {code}



--
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