lucene-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Joel Bernstein (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (SOLR-9684) Add priority Streaming Expression
Date Mon, 02 Jan 2017 16:21:58 GMT

     [ https://issues.apache.org/jira/browse/SOLR-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Joel Bernstein updated SOLR-9684:
---------------------------------
    Description: 
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 priority() function wraps two streams, a high priority stream and a low priority stream.
The priority function emits tuples from the high priority stream first, and then the low priority
stream.

The executor() function can then wrap the priority function to see tasks in priority order.

Pseudo syntax:
{code}
daemon(executor(priority(topic(tasks, q="priority:high"), topic(tasks, q="priority:low"))))
{code}








  was:
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}









> Add priority 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 priority() function wraps two streams, a high priority stream and a low priority
stream. The priority function emits tuples from the high priority stream first, and then the
low priority stream.
> The executor() function can then wrap the priority function to see tasks in priority
order.
> Pseudo syntax:
> {code}
> daemon(executor(priority(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


Mime
View raw message