公开(公告)号：US11553046B1

公开(公告)日：2023-01-10

申请号：US15717789

申请日：2017-09-27

Applicant: Amazon Technologies, Inc.

Inventor： Alexey Kuznetsov ,  Sandor Loren Maurice ,  Alok Nandan Nikhil ,  Joseph Andrew Tucek ,  Alexandre Olegovich Verbitski ,  Lawrence Webley ,  Tengiz Kharatishvili ,  Bohan Liu ,  Mushahid Alam ,  Kamal Kant Gupta ,  Debanjan Saha ,  Anurag Windlass Gupta ,  Saileshwar Krishnamurthy

IPC: H04L29/08 ,  H04L12/751 ,  H04L67/148 ,  H04L67/141 ,  H04L45/02 ,  H04L9/40 ,  H04L67/01

Abstract: A service provider network implements seamless scaling via proxy replay of session state. Upon a trigger, such as a determination to scale a server, a scaled server may be spun up and an identifier of the scaled server provided to a first (existing) server. The first server sends the identification of the second server, and session state information for each of the connections between the first server and the request router, to the request router. For each of the connections, the request router establishes a new connection between the request router and the second (scaled) server, and replays the session state information for the connection to the second server. The request router then routes traffic between each existing client connection (e.g., the same existing client connection which carried traffic delivered to the first server) and the corresponding new connection to the second server.

公开(公告)号：US11449796B2

公开(公告)日：2022-09-20

申请号：US16578060

申请日：2019-09-20

Applicant: Amazon Technologies, Inc.

Inventor： Sangil Song ,  Yongsik Yoon ,  Kamal Kant Gupta ,  Saileshwar Krishnamurthy ,  Stefano Stefani ,  Sudipta Sengupta ,  Jaeyun Noh

IPC: G06F7/00 ,  G06N20/00 ,  G06F16/242 ,  G06F16/2453 ,  G06N5/04

Abstract: Techniques for making machine learning inference calls for database query processing are described. In some embodiments, a method of making machine learning inference calls for database query processing may include generating a first batch of machine learning requests based at least on a query to be performed on data stored in a database service, wherein the query identifies a machine learning service, sending the first batch of machine learning requests to an input buffer of an asynchronous request handler, the asynchronous request handler to generate a second batch of machine learning requests based on the first batch of machine learning requests, and obtaining a plurality of machine learning responses from an output buffer of the asynchronous request handler, the machine learning responses generated by the machine learning service using a machine learning model in response to receiving the second batch of machine learning requests.

公开(公告)号：US11366802B1

公开(公告)日：2022-06-21

申请号：US16586355

申请日：2019-09-27

Applicant: Amazon Technologies, Inc.

Inventor： Tengiz Kharatishvili ,  Alexandre Olegovich Vebitski ,  Justin Levandoski ,  Niket Goel ,  Xiang Peng ,  Kamal Kant Gupta ,  Xiaofeng Bao

IPC: G06F16/23 ,  G06F16/18

Abstract: Batch processing of undo log records may be performed for rolling back a database transaction. When a rollback operation for a database transaction is performed, undo log records from an undo log to rollback the database transaction are divided into different groups of undo log records. Different requests for the different undo log records are sent to a storage system to be performed. If a conflict is detected for an undo log record in a group, an indication of the conflicting undo log record may be provided to indicate the conflict. The group of undo log records may be resent with a request to reapply the undo log records in the group. When all groups have been identified as successfully completed, then the rollback operation may be considered completed.

公开(公告)号：US11080253B1

公开(公告)日：2021-08-03

申请号：US14977439

申请日：2015-12-21

Applicant: Amazon Technologies, Inc.

Inventor： Yan Valerie Leshinsky ,  Kamal Kant Gupta ,  Tengiz Kharatishvili ,  Alexandre Olegovich Verbitski ,  Stefano Stefani ,  Anurag Windlass Gupta

IPC: G06F16/22 ,  G06F3/06 ,  G06F16/28

Abstract: A storage engine may implement dynamic splitting of contentious data pages. Data pages may store data for a table of a data store as part of an indexing structure for the table. Access to the table may be provided by locating the corresponding data pages via the indexing structure. Access contention for different data pages may be monitored. Data pages may be identified for splitting based on the monitoring. A split operation for an identified data page may be formed to store the data on the identified data page on two different data pages so that subsequent access requests for the data are divided between the two data pages. Monitoring of access contention may also be performed to identify data pages for merging in order to consolidate access requests to a single data page.

公开(公告)号：US12229094B2

公开(公告)日：2025-02-18

申请号：US17814463

申请日：2022-07-22

Applicant: Amazon Technologies, Inc.

Inventor： Saileshwar Krishnamurthy ,  Alexey Kuznetsov ,  Mushahid Alam ,  Anurag Windlass Gupta ,  Kamal Kant Gupta ,  Tengiz Kharatishvili ,  Bohan Liu ,  Sandor Loren Maurice ,  Alok Nandan Nikhil ,  Nicholas Piers O'Shea ,  Debanjan Saha ,  Yoni Shalom ,  Jagdeep Singh Sidhu ,  Hongbo Song ,  Alexandre Olegovich Verbitski ,  Lawrence Douglas Webley ,  Siyuan Xing ,  Yuhui Yuan ,  Yibo Zhu

IPC: G06F16/21 ,  G06F16/27 ,  H04L67/56

Abstract: Proxy-based scaling may be performed for databases. A proxy may be implemented for a database that can establish a connection between the proxy and a database engine to perform a database queries received from a client at the proxy. A scaling event may be detected for the database responsive to which the proxy may establish a connection with a new database engine which may, in some embodiments, have different capabilities or resources that address the features or criteria that triggered the scaling event. Session state may be copied from the database engine to the new database engine so that the new database engine may be able to provide access to the database on behalf of requests received from the client through the proxy.

公开(公告)号：US11886439B1

公开(公告)日：2024-01-30

申请号：US16552776

申请日：2019-08-27

Applicant: Amazon Technologies, Inc.

Inventor： Sangyong Hwang ,  Aakash Ashwin Shah ,  Yongsik Yoon ,  Kamal Kant Gupta ,  Saileshwar Krishnamurthy

IPC: G06F16/2455 ,  G06F16/23 ,  G06F16/27

CPC classification number: G06F16/24568 ,  G06F16/2358 ,  G06F16/2379 ,  G06F16/24552 ,  G06F16/273

Abstract: Change data capture is performed asynchronously for direct transfer to a stream processor. When updates to a database as part of database transactions are performed, a transaction log is generated that describes the database transactions. The transaction log may be evaluated to determine indications of changes included in the database transactions. The indications of the changes may be stored in memory according to the database transactions that include the indications of the changes. When a database transaction is determined to be committed to the database, the change indications may be sent directly from the memory to the stream processor.

公开(公告)号：US11816103B1

公开(公告)日：2023-11-14

申请号：US15909886

申请日：2018-03-01

Applicant: Amazon Technologies, Inc.

Inventor： Niket Goel ,  Gopi Krishna Attaluri ,  Kamal Kant Gupta ,  Tengiz Kharatishvili ,  Stefano Stefani ,  Alexandre Olegovich Verbitski

IPC: G06F16/245 ,  G06F16/2453 ,  G06F16/22

CPC classification number: G06F16/24534 ,  G06F16/2246

Abstract: Methods, systems, and computer-readable media for dynamic prefetching for database queries are disclosed. A query of a database is started according to a first prefetch policy. Before completing the query, the first prefetch policy is changed to a second prefetch policy. A portion of the query is performed according to the second prefetch policy.

公开(公告)号：US11455305B1

公开(公告)日：2022-09-27

申请号：US16457122

申请日：2019-06-28

Applicant: Amazon Technologies, Inc.

Inventor： Sangyong Hwang ,  Yongsik Yoon ,  Kamal Kant Gupta ,  Saileshwar Krishnamurthy

IPC: G06F16/00 ,  G06F16/2453 ,  G06F16/248 ,  G06F16/23 ,  G06F16/22

Abstract: Alternative portions of a query plan to perform a query may be selected for processing partial results of a query. A query engine may generate a plan to perform a query that includes an operation that selects between different portions of the plan according to input data. The input data may be a partial result of the query generated by the data store instead of the query engine and provided to the query engine. The input data may be an individual item of the data set that is modified to a different version within a consistent view of the data set for the query.

公开(公告)号：US11341163B1

公开(公告)日：2022-05-24

申请号：US16835055

申请日：2020-03-30

Applicant: Amazon Technologies, Inc.

Inventor： Shriram Sridharan ,  Eric Boutin ,  Damien Katz ,  Kamal Kant Gupta ,  Alexandre Olegovich Verbitski ,  Pallavi Maheshwara Kakunje

IPC: G06F16/20 ,  G06F16/27 ,  G06F16/23 ,  G06F11/14 ,  G06F16/901 ,  G06F16/22

Abstract: This application relates to multi-level replication filtering for a distributed database. A primary node of the database can generate log records that describe write requests performed to the database. The primary node can, in some embodiments, identify a portion of the data of the database that is stored at a second node, such as data stored by a read replica node that can be used in responding to read requests from clients. The primary node can select log records that are applicable to this identified portion of the data to send to the second node. Log records are not selected based on a determination that those unselected log records are not applicable to the identified portion of the data. The primary node can then send the selected log records to the second node, for the second node to apply the log records to its stored database data.

公开(公告)号：US11106667B1

公开(公告)日：2021-08-31

申请号：US15871868

申请日：2018-01-15

Applicant: Amazon Technologies, Inc.

Inventor： Yongsik Yoon ,  Gopi Krishna Attaluri ,  Kamal Kant Gupta ,  Yingjie He ,  Saileshwar Krishnamurthy

IPC: G06F7/00 ,  G06F16/2453 ,  G06F3/06 ,  G06F16/22 ,  G06F16/23

Abstract: Transactional scans of portions of a database may be performed. When a query is received that causes a scan of a database, different portions of the database may be scanned within separate transactions. Operations applicable to perform the scan the records of the different portions of the database may be invoked once within the transactions instead of invoking the operations individually for each of the records in the different portions. Results of the query based on the scanned portions may then be provided in response to the query.