Class ExecutorStream

  • All Implemented Interfaces:
    Closeable, Serializable, AutoCloseable, Expressible, org.apache.solr.common.MapSerializable, org.apache.solr.common.MapWriter, org.apache.solr.common.NavigableObject, org.noggit.JSONWriter.Writable

    public class ExecutorStream
    extends TupleStream
    implements Expressible
    The executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel. Sample syntax:

    executor(thread=10, topic(storedExpressions, q="*:*", fl="expr_s, id", id="topic1"))

    The Streaming Expression to execute is taken from the expr field in the Tuples.

    Since:
    6.3.0
    See Also:
    Serialized Form