-
公开(公告)号:US11687535B2
公开(公告)日:2023-06-27
申请号:US16918373
申请日:2020-07-01
申请人: Elastic Flash Inc.
IPC分类号: G06F16/24 , G06F16/2455 , G06F16/242 , G06F16/22 , G06F9/48 , G06F9/50 , G06F9/451
CPC分类号: G06F16/24568 , G06F9/451 , G06F9/4881 , G06F9/505 , G06F16/2219 , G06F16/244 , G06F2209/508 , G06F2209/5022
摘要: Implementations described herein relate to methods, systems, and computer-readable media to automatically compute features from a data stream. In some implementations, a method includes receiving a data stream comprising a plurality of data fields. The method further includes storing at least three copies of data in the data stream in a database, wherein each copy is stored on a corresponding hardware storage device. The method further includes performing, one or more rollup operations on a first copy of the data to compute one or more aggregate features and storing the one or more aggregate features on each of the hardware storage devices. The method further includes receiving a request for a particular aggregate feature and providing the particular aggregate feature in response to the request.
-
公开(公告)号:US20230054341A1
公开(公告)日:2023-02-23
申请号:US17979936
申请日:2022-11-03
申请人: Elastic Flash Inc.
摘要: In some implementations, a computer-implemented method includes receiving a state update command. The method further includes, in response to the state update command, sending a command to perform a state update in a first server of a plurality of servers and queueing incoming requests for access to the plurality of servers. The method further includes receiving confirmation from the first server that the state update was successful. The method further includes, after receiving the confirmation, sending a respective command to the plurality of servers to perform the state update and a scheduled update time associated with the state update. The method further includes receiving a respective state update message from a subset of the plurality of servers that the state update was successful and after receiving the state update message, transmitting the queued incoming requests to the subset of the plurality of servers.
-
公开(公告)号:US20200159714A1
公开(公告)日:2020-05-21
申请号:US16688063
申请日:2019-11-19
申请人: Elastic Flash Inc.
摘要: In some implementations, a computer-implemented method includes receiving a state update command. The method further includes, in response to the state update command, sending a command to perform a state update in a first server of a plurality of servers and queueing incoming requests for access to the plurality of servers. The method further includes receiving confirmation from the first server that the state update was successful. The method further includes, after receiving the confirmation, sending a respective command to the plurality of servers to perform the state update and a scheduled update time associated with the state update. The method further includes receiving a respective state update message from a subset of the plurality of servers that the state update was successful and after receiving the state update message, transmitting the queued incoming requests to the subset of the plurality of servers.
-
公开(公告)号:US11520794B2
公开(公告)日:2022-12-06
申请号:US17144054
申请日:2021-01-07
申请人: Elastic Flash Inc.
IPC分类号: G06F7/02 , G06F16/00 , G06F16/2455 , G06F16/22 , G06F16/28
摘要: Implementations described herein relate to methods, systems, and computer-readable media to write data records. In some implementations, a method may include calculating a data rate of a data stream that includes a plurality of data records and determining if the data rate of the data stream is less than an ingest threshold. The method may further include, if the data rate of the data stream is less than the ingest threshold, calculating a number of write requests per time unit based on the data stream; determining a storage capacity per storage bucket; determining a read interval for the data stream; based on the number of write requests per time unit, the storage capacity, and the read interval, selecting a size of time window per storage bucket; and writing the plurality of data records to a particular storage bucket.
-
公开(公告)号:US12072892B2
公开(公告)日:2024-08-27
申请号:US17983755
申请日:2022-11-09
申请人: Elastic Flash Inc.
IPC分类号: G06F7/02 , G06F16/00 , G06F16/22 , G06F16/2455 , G06F16/28
CPC分类号: G06F16/24568 , G06F16/2219 , G06F16/285
摘要: Implementations described herein relate to methods, systems, and computer-readable media to write data records. In some implementations, a method may include calculating a data rate of a data stream that includes a plurality of data records and determining if the data rate of the data stream is less than an ingest threshold. The method may further include, if the data rate of the data stream is less than the ingest threshold, calculating a number of write requests per time unit based on the data stream; determining a storage capacity per storage bucket; determining a read interval for the data stream; based on the number of write requests per time unit, the storage capacity, and the read interval, selecting a size of time window per storage bucket; and writing the plurality of data records to a particular storage bucket.
-
公开(公告)号:US20220197513A1
公开(公告)日:2022-06-23
申请号:US17491178
申请日:2021-09-30
申请人: Elastic Flash Inc.
IPC分类号: G06F3/06 , G06F12/0891
摘要: Technologies are described to perform workload based device access. An input-output (IO) request received from an application. An application profile for the application is determined. Based on the application profile, one or more IO parameter values to access a device are set. The device is accessed based on the one or more IO parameter values to fulfill the IO request.
-
公开(公告)号:US11163452B2
公开(公告)日:2021-11-02
申请号:US16579771
申请日:2019-09-23
申请人: Elastic Flash Inc.
IPC分类号: G06F3/06 , G06F12/0891
摘要: Technologies are described to perform workload based device access. An input-output (IO) request received from an application. An application profile for the application is determined. Based on the application profile, one or more IO parameter values to access a device are set. The device is accessed based on the one or more IO parameter values to fulfill the IO request.
-
公开(公告)号:US11537554B2
公开(公告)日:2022-12-27
申请号:US16918294
申请日:2020-07-01
申请人: Elastic Flash Inc.
IPC分类号: G06F16/30 , G06F16/11 , G06F16/23 , G06F16/174 , G06F16/17
摘要: Implementations described herein relate to methods, systems, and computer-readable media to obtain snapshots used for analysis of streaming data. In some implementations, a computer-implemented method includes receiving initial data that includes a plurality of identifiers and corresponding timestamps, generating and storing a snapshot based on the initial data, wherein the snapshot includes the identifiers and a corresponding status, receiving a data stream that includes a subset of the identifiers, activity information for each identifier in the subset, and corresponding timestamps. The method further includes periodically analyzing the data stream to obtain a delta that includes an updated status for each identifier in the subset, storing the delta separate from the snapshot. The method further includes receiving a request for identifiers that are active in a particular time period, and based on the particular time period, retrieving active identifiers from the data stream, the delta, or the snapshot.
-
公开(公告)号:US20210209115A1
公开(公告)日:2021-07-08
申请号:US17144054
申请日:2021-01-07
申请人: Elastic Flash Inc.
IPC分类号: G06F16/2455 , G06F16/28 , G06F16/22
摘要: Implementations described herein relate to methods, systems, and computer-readable media to write data records. In some implementations, a method may include calculating a data rate of a data stream that includes a plurality of data records and determining if the data rate of the data stream is less than an ingest threshold. The method may further include, if the data rate of the data stream is less than the ingest threshold, calculating a number of write requests per time unit based on the data stream; determining a storage capacity per storage bucket; determining a read interval for the data stream; based on the number of write requests per time unit, the storage capacity, and the read interval, selecting a size of time window per storage bucket; and writing the plurality of data records to a particular storage bucket.
-
公开(公告)号:US20210004376A1
公开(公告)日:2021-01-07
申请号:US16918373
申请日:2020-07-01
申请人: Elastic Flash Inc.
IPC分类号: G06F16/2455 , G06F16/242 , G06F16/22 , G06F9/451 , G06F9/48 , G06F9/50
摘要: Implementations described herein relate to methods, systems, and computer-readable media to automatically compute features from a data stream. In some implementations, a method includes receiving a data stream comprising a plurality of data fields. The method further includes storing at least three copies of data in the data stream in a database, wherein each copy is stored on a corresponding hardware storage device. The method further includes performing, one or more rollup operations on a first copy of the data to compute one or more aggregate features and storing the one or more aggregate features on each of the hardware storage devices. The method further includes receiving a request for a particular aggregate feature and providing the particular aggregate feature in response to the request.
-
-
-
-
-
-
-
-
-