lucene-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Joel Bernstein (JIRA)" <>
Subject [jira] [Updated] (SOLR-9559) Add ExecutorStream to execute stored Streaming Expressions
Date Sun, 16 Oct 2016 01:24:20 GMT


Joel Bernstein updated SOLR-9559:
    Fix Version/s: 6.3

> Add ExecutorStream to execute stored Streaming Expressions
> ----------------------------------------------------------
>                 Key: SOLR-9559
>                 URL:
>             Project: Solr
>          Issue Type: New Feature
>      Security Level: Public(Default Security Level. Issues are Public) 
>            Reporter: Joel Bernstein
>            Assignee: Joel Bernstein
>             Fix For: 6.3
> The *ExecutorStream* will wrap a stream which contains Tuples with Streaming Expressions
to execute. By default the ExecutorStream will look for the expression in the *expr* field
in the Tuples.
> The ExecutorStream will have an internal thread pool so expressions can be executed in
parallel on a single worker. The ExecutorStream can also be wrapped by the parallel function
to partition the Streaming Expressions that need to be executed across a cluster of worker
> *Sample syntax*:
> {code}
> daemon(executor(threads=10, topic(storedExpressions, fl="expr", ...)))
> {code}
> In the example above a *daemon* wraps an *executor* which wraps a *topic* that is reading
stored Streaming Expressions. The daemon will call the executor at intervals which will execute
all the expressions retrieved by the topic.

This message was sent by Atlassian JIRA

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message