[ https://issues.apache.org/jira/browse/SOLR-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788328#comment-15788328 ]
Joel Bernstein commented on SOLR-9684: -------------------------------------- We can think about the naming of this some more. The reason why I called it 'schedule' is that it *schedules* higher priority tasks ahead of lower priority tasks. Possibly more scheduling features could be added in the future. > Add schedule 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 > Fix For: master (7.0), 6.4 > > 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-unsubscr...@lucene.apache.org For additional commands, e-mail: dev-h...@lucene.apache.org