-
公开(公告)号:US11144570B2
公开(公告)日:2021-10-12
申请号:US15881396
申请日:2018-01-26
Applicant: VMware, Inc.
Inventor: Sai Samrat Karlapudi , Mirza Mohsin Beg
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.
-
公开(公告)号:US20250030699A1
公开(公告)日:2025-01-23
申请号:US18376007
申请日:2023-10-03
Applicant: VMWARE, Inc.
Inventor: LALITH SURESH PUTHALATH , Pooja Khandelwal , Mirza Mohsin Beg
IPC: H04L9/40
Abstract: The disclosure provides a method for configuring rate limiting policies for microservices in a request execution chain of a distributed system. The method generally includes receiving global rate limit(s), where each global rate limit is associated with a tag and a microservice of a plurality of microservices, and each global rate limit indicates a rate of requests tagged with the tag associated with the global rate limit allowed to be processed by the microservice associated with the global rate limit; and configuring, for each global rate limit: each of the local rate limiter(s) associated with microservice instance(s) associated with the global rate limit with a local rate limit indicating a rate of requests tagged with the tag associated with the global rate limit allowed to be processed by the microservice instance, wherein the local rate limit of each of the local rate limiter(s) is based on the global rate limit.
-
公开(公告)号:US11848981B2
公开(公告)日:2023-12-19
申请号:US17322817
申请日:2021-05-17
Applicant: VMware, Inc.
Inventor: Sufian A. Dar , Tyler J. Curtis , James W. Cooley , Mirza Mohsin Beg
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.
-
公开(公告)号:US11693717B2
公开(公告)日:2023-07-04
申请号:US17549310
申请日:2021-12-13
Applicant: VMware, Inc.
Inventor: Mirza Mohsin Beg , Venkat Gujjula , Sai Samrat Karlapudi , Shefali Dubey , Anshu Bansal
CPC classification number: G06F9/542 , G06F9/4837 , G06F9/546 , G06F16/1734
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.
-
公开(公告)号:US11514032B2
公开(公告)日:2022-11-29
申请号:US17113478
申请日:2020-12-07
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.
-
公开(公告)号:US20220100589A1
公开(公告)日:2022-03-31
申请号:US17549310
申请日:2021-12-13
Applicant: VMware, Inc.
Inventor: Mirza Mohsin Beg , Venkat Gujjula , Sai Samrat Karlapudi , Shefali Dubey , Anshu Bansal
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.
-
公开(公告)号:US11016972B2
公开(公告)日:2021-05-25
申请号:US15881382
申请日:2018-01-26
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.
-
公开(公告)号:US10949390B2
公开(公告)日:2021-03-16
申请号:US15925464
申请日:2018-03-19
Applicant: VMware Inc.
Inventor: Ramsés V. Morales , Mirza Mohsin Beg , Shashank Pedamallu
IPC: G06F17/00 , G06F16/14 , G06F3/06 , G06F9/455 , G06F16/182
Abstract: The present disclosure relates generally to techniques for processing asynchronous queries across multiple data cores including secondary data cores stored in the secondary storage system in a distributed computing system. Secondary data cores are recovered in the data plane from secondary storage in order to be accessible for searching. Using this technique, asynchronous queries are run in parallel allowing the client to dynamically manage the queries and receive notifications when results are available.
-
公开(公告)号:US11755356B2
公开(公告)日:2023-09-12
申请号:US17202125
申请日:2021-03-15
Applicant: VMware Inc.
Inventor: Ramsés V. Morales , Mirza Mohsin Beg , Shashank Pedamallu
CPC classification number: G06F9/45558 , G06F3/0608 , G06F3/0647 , G06F2009/45583 , G06F2009/45595
Abstract: The present disclosure relates generally to techniques for processing asynchronous queries across multiple data cores including secondary data cores stored in the secondary storage system in a distributed computing system. Secondary data cores are recovered in the data plane from secondary storage in order to be accessible for searching. Using this technique, asynchronous queries are run in parallel allowing the client to dynamically manage the queries and receive notifications when results are available.
-
公开(公告)号:US20230031872A1
公开(公告)日:2023-02-02
申请号:US17512716
申请日:2021-10-28
Applicant: VMWARE, INC.
Inventor: Alex Bewley , Mirza Mohsin Beg , Nikolay Filipov , Nikolay Ivanov , Leonid Ryzhyk , Ahmed Sadak , Michael Hu , Pushkar Mishra , Shradha Sangtani
Abstract: A computer-implemented method of receiving and incrementally processing hierarchical data in a computing environment. Receiving hierarchical data within a computing environment. The computing environment including a plurality of interrelated components. Incrementally processing the hierarchical data to obtain processed portions. The incremental processing of the portions of hierarchical data able to be initiated with requiring receipt of the entirety of the hierarchical data. Maintaining an indexed representation of previously processed portions of the hierarchical data to prevent unnecessarily processing a same portion of the hierarchical data.
-
-
-
-
-
-
-
-
-