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 scheduler Streaming Expression
Date Mon, 24 Oct 2016 02:42: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 scheduler() function wraps a list of streams and *prioritizes* the iteration of the streams.
This allows there to be different task queues with different priorities.

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

Pseudo syntax:
{code}
daemon(executor(scheduler(topic(), topic(), topic())))
{code}








  was:
SOLR-9559 adds a general purpose *parallel task executor* for streaming expressions. The executor()
function simply executes a stream of tasks and doesn't have any concept of task priority.

The scheduler() function wraps a list of streams and *prioritizes* the iteration of the streams.
This allows there to be different task queues with different priorities.

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

Pseudo syntax:
{code}
daemon(executor(scheduler(topic(), topic(), topic())))
{code}









> 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
>
> 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 a list of streams and *prioritizes* the iteration of the
streams. This allows there to be different task queues with different priorities.
> The executor() function can then wrap the scheduler function to see tasks in priority
order.
> Pseudo syntax:
> {code}
> daemon(executor(scheduler(topic(), topic(), topic())))
> {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