Providing strong ordering in multi-stage streaming processing

A system, comprising:

• a memory;
• and
• at least one processor coupled to the memory and configured to:
• maintain current batch stage information comprising current batch units and downstream batch units that depend on completion of the current batch units at a grid scheduler;
• determine a batch unit pending dispatch from the downstream batch units for a current batch stage identified in the current batch stage information;
• identify one or more physical threads in a computing grid that processed batch units for the current batch stage on which the batch unit pending dispatch depends and have registered pending tasks for the current batch stage;
• and
• cause a dispatch of the batch unit pending dispatch to the one or more identified physical threads subsequent to complete processing of the batch units for the current batch stage.

A non-transitory computer-readable device having instructions stored thereon that, when executed by at least one computing device, causes the at least one computing device to perform operations comprising:

• maintaining current batch stage information comprising current batch units and downstream batch units that depend on completion of the current batch units at a grid scheduler;
• determining a batch unit pending dispatch from the downstream batch units for a current batch stage identified in the current batch stage information;
• identifying one or more physical threads in a computing grid that processed batch units for the current batch stage on which the batch unit pending dispatch depends and have registered pending tasks for the current batch stage;
• and
• causing a dispatch of the batch unit pending dispatch to the one or more identified physical threads subsequent to complete processing of the batch units for the current batch stage.