Amazon Technologies, Inc.

Douglas Baldwin Dance

Yu Liu

Victoria Wong

Ryan Schwartz

Desmond Zhou

Mark Hjelm

Yiu Pong Lam

Jean-Christophe Libbrecht

Yuan Bian

Vivek Mehta

Nicholas Leong

Abhishek Sahay

Rong Wang

Boyang Tom Jin

Hyun Jung Cho

Methods, systems, and computer-readable media for batch processing with random access for transaction history are disclosed. A batch processing system receives a batch comprising records of events, including a first record of a first event and a second record of a second event. The system assigns the first and second records to a group based (at least in part) on determining that the events are related. The system determines that the group is related to a match set comprising one or more prior events. The system updates one or more values in the match set based (at least in part) on the first and second records. The system stores the updated match set and one or more additional match sets using a storage object. The system retrieves the match set and not the one or more additional match sets from the storage object using an index.

Batch processing with random access for transaction history

Methods, systems, and computer-readable media for data aggregation with schema enforcement are disclosed. A plurality of validated transactions are determined from a set of transactions associated with a first interval. The validated transactions are determined using enforcement of one or more schema definitions associated with the set of transactions. The validated transactions are stored using a data object associated with the first interval. An aggregation for a longer duration is generated based at least in part on an aggregation definition. The aggregation definition is associated with one or more of the schema definitions and comprises one or more attributes. The aggregation represents transactions in the first interval and in one or more additional intervals, and the transactions represented in the aggregation are validated for the one or more of the schema definitions and comprise the one or more attributes.

Data aggregation with schema enforcement

A system tasked with processing inputs and generating outputs, such as a transaction processor, might have many users. Updates to a particular user's use case can require an update to the code of the system. Examples of this disclosure provide a mechanism by which configuration can be employed to update output logic rather than code, which can facilitate updating and roll-out.

Input processing logic to produce outputs for downstream systems using configurations

Growing community of inventors

Kent, WA, United States of America

Douglas Baldwin Dance