Distributed processing of partitioned and ordered data

A method, comprising:

• creating a workflow to process time-series data responsive to receipt of a request comprising a partitioning definition and an ordering definition;
• receiving a time-series datum for processing by the workflow;
• routing the time-series datum to a queue of a plurality of queues according to the partitioning definition;
• identifying that the time-series datum has been routed to the queue out of order according to the ordering definition;
• and
• blocking processing of the time-series datum until satisfaction of an unblocking condition is determined.

One or more non-transitory computer-accessible storage media storing program instructions that when executed on or across one or more computing devices cause the one or more computing devices to implement a scheduling service to perform:

• creating an execution pipeline to process time-series data responsive to receipt of a request comprising a sharding definition and an ordering definition;
• receiving a time-series data sample for processing by the workflow;
• routing the time-series data sample to a queue of a plurality of queues according to the sharding definition;
• identifying that the time-series data sample has been routed to the queue out of order according to the ordering definition;
• and
• blocking execution of the time-series data sample until satisfaction of an unblocking condition is determined.