Uploaded image for project: 'Solr'
  1. Solr
  2. SOLR-9684

Add priority Streaming Expression

    Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Resolved
    • Affects Version/s: None
    • Fix Version/s: 6.4, 7.0
    • Component/s: None
    • Security Level: Public (Default Security Level. Issues are Public)
    • Labels:
      None

      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:

      daemon(executor(priority(topic(tasks, q="priority:high"), topic(tasks, q="priority:low"))))
      

        Attachments

        1. SOLR-9684.patch
          6 kB
          Joel Bernstein
        2. SOLR-9684.patch
          6 kB
          Joel Bernstein
        3. SOLR-9684.patch
          15 kB
          Joel Bernstein

          Issue Links

            Activity

              People

              • Assignee:
                joel.bernstein Joel Bernstein
                Reporter:
                joel.bernstein Joel Bernstein
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: