Transforming time series data points from concurrent processes
First Claim
1. A system for a transforming time series data points from concurrent processes, the system comprising:
- one or more processors; and
a non-transitory computer readable medium storing a plurality of instructions, which when executed, cause the one or more processors to;
write to a queue a first time series data point received from a first process associated with a first computer amongst a cluster of computers;
write to the queue a second time series data point received from a second process associated with a second computer amongst the cluster of computers, the second process executing concurrently with the first process;
move the first time series data point and the second time series data point from the queue to a first data buffer of a non-persistent storage, the first time series data point and the second time series data point moved in response to determining the queue has stored a predetermined amount of time series data from the cluster of computers for a time period corresponding to the first time series data point and the second time series data point;
create transformed time series data by applying a transformation to the moved first time series data point and the moved second time series data point of the first data buffer, and writing the transformed time series data to a second data buffer of the non-persistent storage;
write the transformed time series data, the first time series data point, and the second time series data point to a persistent storage after applying the transformation to create the transformed time series data; and
output the transformed time series data to a user device.
1 Assignment
0 Petitions
Accused Products
Abstract
Transforming time series data points from concurrent processes is described. A time series database system writes, to a queue, a first time series data point received from a first process. The time series database system writes, to the queue, a second time series data point received from a second process that executes concurrently with the first process. The time series database system removes the first time series data point and the second time series data point from the queue. The time series database system creates transformed time series data by applying a transformation to the first time series data point and the second time series data point. The time series database system outputs the transformed time series data to a user device.
-
Citations
17 Claims
-
1. A system for a transforming time series data points from concurrent processes, the system comprising:
-
one or more processors; and a non-transitory computer readable medium storing a plurality of instructions, which when executed, cause the one or more processors to; write to a queue a first time series data point received from a first process associated with a first computer amongst a cluster of computers; write to the queue a second time series data point received from a second process associated with a second computer amongst the cluster of computers, the second process executing concurrently with the first process; move the first time series data point and the second time series data point from the queue to a first data buffer of a non-persistent storage, the first time series data point and the second time series data point moved in response to determining the queue has stored a predetermined amount of time series data from the cluster of computers for a time period corresponding to the first time series data point and the second time series data point; create transformed time series data by applying a transformation to the moved first time series data point and the moved second time series data point of the first data buffer, and writing the transformed time series data to a second data buffer of the non-persistent storage; write the transformed time series data, the first time series data point, and the second time series data point to a persistent storage after applying the transformation to create the transformed time series data; and output the transformed time series data to a user device. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A computer program product comprising computer-readable program code to be executed by one or more processors when retrieved from a non-transitory computer-readable medium, the program code including instructions to:
-
write to a queue, by a time series database system, a first time series data point received from a first process associated with a first computer amongst a cluster of computers; write to the queue, by the time series database system, a second time series data point received from a second process associated with a second computer amongst the cluster of computers, the second process executing concurrently with the first process; move, by the time series database system, the first time series data point and the second time series data point from the queue to a first data buffer of a non-persistent storage, the first time series data point and the second time series data point moved in response to determining the queue has stored a predetermined amount of time series data from the cluster of computers for a time period corresponding to the first time series data point and the second time series data point; create, by the time series database system, transformed time series data by applying a transformation to the moved first time series data point and the moved second time series data point of the first data buffer, and write the transformed time series data to a second data buffer of the non-persistent storage;
write the transformed time series data, the first time series data point, and the second time series data point to a persistent storage after applying the transformation to create the transformed time series data; andoutput, by the time series database system, the transformed time series data to a user device. - View Dependent Claims (8, 9, 10, 11, 12)
-
-
13. A method for transforming time series data points from concurrent processes, the method comprising:
-
writing to a queue, by a time series database system, a first time series data point received from a first process associated with a first computer amongst a cluster of computers; writing to the queue, by the time series database system, a second time series data point received from a second process associated with a second computer amongst the cluster of computers, the second process executing concurrently with the first process; moving, by the time series database system, the first time series data point and the second time series data point from the queue to a first data buffer of a non-persistent storage, the first time series data point and the second time series data point moved in response to determining the queue has stored a predetermined amount of time series data from the cluster of computers for a time period corresponding to the first time series data point and the second time series data point; creating, by the time series database system, transformed time series data by applying a transformation to the moved first time series data point and the moved second time series data point of the first data buffer, and writing the transformed time series data to a second data buffer of the non-persistent storage;
writing the transformed time series data, the first time series data point, and the second time series data point to a persistent storage after applying the transformation to create the transformed time series data; andoutputting, by the time series database system, the transformed time series data to a user device. - View Dependent Claims (14, 15, 16, 17)
-
Specification