公开(公告)号：US11016971B2

公开(公告)日：2021-05-25

申请号：US15881376

申请日：2018-01-26

Applicant: VMware, Inc.

Inventor： Sundeep Tiyyagura ,  Mirza Mohsin Beg ,  A. Christer Sabelstrom

IPC: G06F16/2453 ,  G06F9/455

Abstract: Techniques for splitting a time-range query into sub-queries for parallel execution are provided. In one embodiment, a user query requesting items from a database is received. A total number of items in the database that correspond to a time range of the user query is determined. Based on the total number of items, target values are determined. Each target value represents a target number of items in the database to be assigned to a respective sub-query. Based on the target values, a plurality of time periods within the time range are determined. Each time period corresponds to a respective set of items in the database platform, and a total number of items in the respective set of items corresponds to a respective target value. Sub-queries defining respective time periods of the plurality of time periods are then generated from the user query and executed in parallel.

公开(公告)号：US11012500B2

公开(公告)日：2021-05-18

申请号：US16047968

申请日：2018-07-27

Applicant: VMware, Inc.

Inventor： Sufian A. Dar ,  Tyler J. Curtis ,  James W. Cooley ,  Mirza Mohsin Beg

IPC: H04L29/08 ,  H04L12/721 ,  H04L12/66

Abstract: Techniques for ingesting data streams to a distributed-computing system using a multi-directional data ingestion pipeline are provided. In one embodiment, a method for ingesting data streams includes, at a client gateway, receiving a plurality of messages; assigning the plurality of messages to one or more data streams; obtaining stream routing configurations; and identifying one or more receivers. The method further includes determining whether at least one of the one or more data streams is to be delivered to one or more receivers operating in the first computing environment; and if so, delivering the at least one of the one or more data streams to the one or more receivers operating in the first computing environment. The method further includes delivering the one or more data streams to a data ingress gateway operating in a second computing environment.

公开(公告)号：US10860576B2

公开(公告)日：2020-12-08

申请号：US15881364

申请日：2018-01-26

Applicant: VMware, Inc.

Inventor： Sundeep Tiyyagura ,  Mirza Mohsin Beg ,  A. Christer Sabelstrom

IPC: G06F16/242 ,  G06F16/27 ,  G06F16/2455

Abstract: Techniques for splitting a query into native query operations and post-processing operations are provided. In one embodiment, a user query including a plurality of search parameters is received. Expressions representing the plurality of search parameters in the user query are determined. A first subset and a second subset of the expressions are identified. Each expression of the first subset corresponds to one of a plurality of native query operations executable by a database platform, and each expression of the second subset corresponds to one of a plurality of predefined post-processing operations not executable by the database platform. A database query is generated based on one or more expressions of the first subset, and a post-processing query is generated based on each expression in the second subset. The database query is executed by the database platform, then the post-processing query is executed on the results from database platform.

公开(公告)号：US11741124B2

公开(公告)日：2023-08-29

申请号：US17498504

申请日：2021-10-11

Applicant: VMware, Inc.

Inventor： Sai Samrat Karlapudi ,  Mirza Mohsin Beg

IPC: G06F16/27 ,  G06F11/14 ,  G06F9/455 ,  G06F11/20

CPC classification number: G06F16/27 ,  G06F9/45558 ,  G06F11/1456 ,  G06F11/1464 ,  G06F11/2048 ,  G06F2009/4557 ,  G06F2009/45595 ,  G06F2201/805

Abstract: Techniques for data ingestion by a distributed-computing system are provided. In one embodiment, data received from one or more data sources is processed at a management node of the distributed-computing system. The data is generated by one or more components of an information processing system external to the distributed-computing system. The data is stored at the management plane. The management plane selects, from a plurality of data cores, a data core to ingest the data. The plurality of data cores are stored across one or more data plane containers of a data plane of the distributed-computing system. The management plane processes the data to generate one or more event records corresponding to the data. The one or more event records are sent to the selected data core, which causes the data plane to store the one or more event records in the selected data core.

公开(公告)号：US11593365B2

公开(公告)日：2023-02-28

申请号：US17328098

申请日：2021-05-24

Applicant: VMware, Inc.

Inventor： Sundeep Tiyyagura ,  Mirza Mohsin Beg ,  A. Christer Sabelstrom

IPC: G06F16/2453 ,  G06F16/248 ,  G06F16/242 ,  G06F16/2458

Abstract: Techniques for splitting a time-range query into sub-queries for serial execution are provided. In one embodiment, a user query is received requesting items within a time range from a database. The time range is divided into a plurality of time periods within the time range. Sub-queries defining respective time periods of the plurality of time periods are generated from the user query, and a first sub-query is executed. The first sub-query defines a first time period of the plurality of time periods, where the first time period is a most-recent time period or a least-recent time period among the plurality of time periods. If it is determined that a number of items obtained from executing the first sub-query is greater than or equal to a predetermined result target, then the items obtained from executing the first sub-query are provided and subsequent sub-queries are not executed.

公开(公告)号：US11200100B2

公开(公告)日：2021-12-14

申请号：US16715236

申请日：2019-12-16

Applicant: VMware, Inc.

Inventor： Mirza Mohsin Beg ,  Venkat Gujjula ,  Sai Samrat Karlapudi ,  Shefali Dubey ,  Anshu Bansal

IPC: G06F9/54 ,  G06F16/17 ,  G06F9/48

Abstract: In a computer-implemented method for performing alert notification on streaming textual data, streaming textual data is received. A plurality of copies of the streaming textual data is generated, wherein a first copy of the streaming textual data is transmitted to an ingestion service for persistent storage at a data plane and a second copy of the streaming textual data is transmitted to an alert evaluation service for performing alert evaluation on the streaming textual data, such that the ingestion service and the alert evaluation service are performed independently. The streaming textual data is evaluated by the alert evaluation service to detect an alert. Responsive to detecting an alert at the alert evaluation service, a notification of the alert is generated.

公开(公告)号：US20210182127A1

公开(公告)日：2021-06-17

申请号：US16715236

申请日：2019-12-16

Applicant: VMware, Inc.

Inventor： Mirza Mohsin Beg ,  Venkat Gujjula ,  Sai Samrat Karlapudi ,  Shefali Dubey ,  Anshu Bansal

IPC: G06F9/54 ,  G06F9/48 ,  G06F16/17

Abstract: In a computer-implemented method for performing alert notification on streaming textual data, streaming textual data is received. A plurality of copies of the streaming textual data is generated, wherein a first copy of the streaming textual data is transmitted to an ingestion service for persistent storage at a data plane and a second copy of the streaming textual data is transmitted to an alert evaluation service for performing alert evaluation on the streaming textual data, such that the ingestion service and the alert evaluation service are performed independently. The streaming textual data is evaluated by the alert evaluation service to detect an alert. Responsive to detecting an alert at the alert evaluation service, a notification of the alert is generated.