The patent badge is an abbreviated version of the USPTO patent document. The patent badge does contain a link to the full patent document.

The patent badge is an abbreviated version of the USPTO patent document. The patent badge covers the following: Patent number, Date patent was issued, Date patent was filed, Title of the patent, Applicant, Inventor, Assignee, Attorney firm, Primary examiner, Assistant examiner, CPCs, and Abstract. The patent badge does contain a link to the full patent document (in Adobe Acrobat format, aka pdf). To download or print any patent click here.

Date of Patent:
Feb. 03, 2026

Filed:

Mar. 31, 2023
Applicant:

Amazon Technologies, Inc., Seattle, WA (US);

Inventors:

Sayantan Bhowmik, Seattle, WA (US);

Matthew Jonathan Narksusook, Auburn, WA (US);

Adam Charles Siefker, Des Moines, WA (US);

Francesco Maria Rizzi, Seattle, WA (US);

Assignee:

Amazon Technologies, Inc., Seattle, WA (US);

Attorneys:
Primary Examiner:
Int. Cl.
CPC ...
G06F 9/48 (2006.01); G06F 9/52 (2006.01); G06F 16/14 (2019.01); G06F 16/27 (2019.01); G06F 16/903 (2019.01); G06F 16/907 (2019.01); G06F 16/9032 (2019.01);
U.S. Cl.
CPC ...
G06F 9/4881 (2013.01); G06F 9/52 (2013.01); G06F 9/522 (2013.01); G06F 16/14 (2019.01); G06F 16/278 (2019.01); G06F 16/90348 (2019.01); G06F 16/907 (2019.01); G06F 16/144 (2019.01); G06F 16/9032 (2019.01);
Abstract

Scheduling of time-series data samples for processing according to client-specified criteria is performed. A client may submit a request to establish an execution pipeline to process time-series data, the request including a partitioning definition and an ordering definition. Responsive to this request, a scheduler may receive a time-series data sample and generate a partitioning key according to the partitioning definition to direct the sample to one of multiple partition queues. After enqueuing, the schedular may determine that the sample should be blocked from processing until satisfaction of an unblocking condition is achieved. This satisfaction may include processing of one or more other samples according to the ordering definition or a time period has elapsed. Blocking criteria may also include limitations in a number of simultaneously executing sample processes. Processing of samples of different queues may occur independently.


Find Patent Forward Citations

Loading…