Back to results
US 2022/0327099 A1Published application
Segmented Streaming Data Processing
AssigneeFluency Corp.
InventorsChristopher Jordan, Kun Luo
Life of this patent
Estimating the term…
Abstract
The disclosure relates generally to a method, device, and system for creating a searchable data store with an infinite retention period for streaming documents. In an embodiment, a method of storing data includes receiving an incoming stream of time-series data; storing the time-series data of the incoming data stream in a first segment; and closing the first segment in response to a resource consumption limit of the first segment being reached.
Claims20
A method of storing data, the method comprising:
- receiving an incoming stream of time-series data;
- storing the time-series data of the incoming data stream in a first segment;
- and
- closing the first segment in response to a resource consumption limit of the first segment being reached.
1 more element
A method of storing data, the method comprising:
- receiving an incoming stream of data, the incoming stream of data comprising a plurality of events;
- detecting whether each event of the plurality of events comprises an original timestamp;
- attaching a supplemental timestamp to each event of the plurality of events when the respective event is detected without the original timestamp, wherein the supplemental timestamp is based on a time at which the respective event is received;
- storing the events of the plurality of events in a first segment;
- and
- closing the first segment in response to a resource consumption limit of the first segment being reached.
3 more elements
A method of storing data, the method comprising:
- receiving an incoming stream of time-series data;
- storing the time-series data of the incoming data stream in a first segment, wherein two or more active shards process the time-series data, wherein the two or more active shards process the time-series data in parallel, and wherein the number of the two or more active shards processing the time-series data is dependent on an input rate of the time-series data;
- and
- closing the first segment in response to a resource consumption limit of the first segment being reached.
1 more element
Dependencies are inferred from the claim text.