Application US20190188238

METHOD AND SYSTEM FOR PERFORMING REAL-TIME ANALYTICS ON A PLURALITY OF DATA STREAMS
[+] Show Details

US20190188238

1. A method for performing real-time analytics on a plurality of data streams, the method comprising: (12) (8)

obtaining a plurality of data streams using a digital computer;

accumulating, using the digital computer, real-time changes of the obtained plurality of data streams in a buffer unit to provide a buffered data portion;

monitoring, using the digital computer, the buffered data portion for determining a calculation event, wherein the calculation event is based on a strategy based on observing given features in the buffered data portion;

upon detection of the calculation event, generating, using the digital computer, an optimization problem indicative of the real-time analytics to be performed on one of given data portions of the plurality of data streams and a data structure generated using given data portions of the plurality of data streams;

transforming, using the digital computer, the generated optimization problem into an optimization problem suitable for an optimization oracle;

solving the transformed generated optimization problem using the optimization oracle to provide at least one solution,

translating, using the digital computer, the at least one solution; and

providing, using the digital computer, the translated at least one solution to thereby provide the real-time analytics on the plurality of data streams.

2. The method as claimed in claim 1, wherein the optimization oracle comprises a quantum annealer. (0)

3. The method as claimed in claim 1, wherein the optimization oracle comprises a digital annealer. (0)

4. The method as claimed in claim 1, wherein the optimization oracle comprises a coherent Ising machine. (0)

5. The method as claimed in claim 1, wherein the plurality of data streams obtained comprise time series signals. (0)

6. The method as claimed in claim 1, wherein the plurality of data streams is obtained from a corresponding plurality of data sources. (1) (0)

10. The method as claimed in claim 1, wherein the buffer unit is located in the digital computer. (0)

11. The method as claimed in claim 1, wherein the optimization problem indicative of the real-time analytics to be performed is generated on a data structure; further wherein the data structure comprises a graph generated using the given data portions of the plurality of data streams, wherein each node of the generated graph is associated with a data stream and each edge of the generated graph is representative of a similarity and distance measure between two respective given data portions of the data streams, further wherein the graph is generated in real-time using computations performed for previous data portions of the plurality of data streams. (2) (0)

12. The method as claimed in claim 11, wherein the plurality of data streams are real-valued data streams. (2) (0)

13. The method as claimed in claim 12, wherein the similarity and distance measure is selected from a group consisting of a Pearson correlation, a Cross correlation similarity calculated in time or frequency domain, a Correlation distance, a Pearson distance, a Covariance similarity, a Cosine similarity, an Angular semi-metric, an Orloci distance, a Similarity ratio, a Morisita-Horn similarity, a Spearman rank correlation, a Spearman footrule distance, a Kendal τ rank correlation, a Kendal τ distance, a Cook distance, a Fross correlation, an Euclidean distance, a L2 norm, a Binary Euclidean distance, a Mean censored Euclidean distance, a Manhattan distance, a L1 norm, a Penrose size distance, a Penrose shape distance, a Lorentzian distance, a Chebyshev distance, a L∞ norm, a power(p, r) distance, a weighted power(p, r) distance, a LP distance, a Normalized Lp distance, a Clark distance, a Meehl distance, a Hellinger distance, a Symmetric x²measure, a Symmetric x²distance, a Mahalanobis distance, a Minkowski distance, a Peak signal delay measure, a Time delay of arrival measure, an Absolute value of difference of peak of data, a Correlation of envelope of data, a Ruzicka similarity, a Roberts similarity, an Ellenberg similarity, a Gleason similarity, an Intersection distance, a Bray-Curtis distance, a Canberra distance, a Kulczynski similarities (1,2) and a Baroni-Urbani-Buser similarity. (0)

16. The method as claimed in claim 12, further comprising using at least one selected threshold on each edge of the generated graph for providing a binarized graph; further wherein the optimization problem is generated using the binarized graph. (1) (0)

14. The method as claimed in claim 11, wherein the plurality of data streams are binary-valued data streams. (1) (0)

18. The method as claimed in claim 1, wherein the generated optimization problem is transformed into a quadratic unconstrained binary optimization problem. (0)

19. The method as claimed in claim 1, wherein the solving of the transformed optimization problem is performed using the optimization oracle and at least one previous solution. (0)

20. The method as claimed in claim 1, wherein the real-time analytics to be performed is selected from a group consisting of a graph coloring problem, a vertex cover problem, a maximum clique problem, a graph partitioning problem, a maximum independent set and a clique cover. (0)

21. The method as claimed in claim 1, wherein the providing of the translated at least one solution comprises displaying the at least one translated solution to a user. (0)

22. The method as claimed in claim 1, wherein the providing of the translated at least one solution comprises providing the at least one translated solution to a remote processing unit operatively coupled to the digital computer. (0)

23. A digital computer comprising: (0) (13)

a central processing unit;

a display device;

a communication port for operatively connecting the digital computer to an optimization oracle comprising a quantum processor;

a memory unit comprising an application for performing real-time analytics on a plurality of data streams, the application comprising:

instructions for obtaining a plurality of data streams;

instructions for accumulating real-time changes of the obtained plurality of data streams in a buffer unit to provide a buffered data portion;

instructions for monitoring the buffered data portion for determining a calculation event, wherein the calculation event is based on a strategy based on observing given features in the buffered data portion;

instructions for generating, upon detection of the calculation event, an optimization problem indicative of the real-time analytics to be performed on one of given data portions of the plurality of data streams and a data structure generated using given data portions of the plurality of data streams;

instructions for transforming the generated optimization problem into an optimization problem suitable for an optimization oracle;

instructions for transmitting the transformed generated optimization problem to the optimization oracle;

instructions for obtaining from the optimization oracle at least one solution of the transformed optimization problem;

instructions for translating the at least one solution; and

instructions for providing the translated at least one solution to thereby provide the real-time analytics on the plurality of data streams.

24. A non-transitory computer readable storage medium for storing computer-executable instructions which, when executed, cause a digital computer to perform a method for performing real-time analytics on a plurality of data streams, the method comprising: (0) (9)

obtaining a plurality of data streams;

accumulating real-time changes of the obtained plurality of data streams in a buffer unit to provide a buffered data portion;

monitoring the buffered data portion for determining a calculation event, wherein the calculation event is based on a strategy based on observing given features in the buffered data portion;

upon detection of the calculation event, generating an optimization problem indicative of the real-time analytics to be performed on one of given data portions of the plurality of data streams and a data structure generated using given data portions of the plurality of data streams;

transforming the generated optimization problem into an optimization problem suitable for an optimization oracle;

transmitting the transformed generated optimization problem to the optimization oracle;

obtaining from the optimization oracle at least one solution of the transformed generated optimization problem;

translating the at least one solution; and

providing the translated at least one solution to thereby provide the real-time analytics on the plurality of data streams.

25. A method for performing real-time analytics on a plurality of data streams, the method comprising: (0) (9)

obtaining a plurality of data streams;

accumulating real-time changes of the obtained plurality of data streams in a buffer unit to provide a buffered data portion;

monitoring the buffered data portion for determining a calculation event, wherein the calculation event is based on a strategy based on observing given features in the buffered data portion;

transforming the generated optimization problem into an optimization problem suitable for an optimization oracle;

providing the transformed generated optimization problem to the optimization oracle;

obtaining at least one solution from the optimization oracle;

translating the at least one solution; and

providing the translated at least one solution to thereby provide the real-time analytics on the plurality of data streams.

View Abstract and Specification Size

PDF with Images and Document Face >

Full Text Publication >

Application US20190188238

METHOD AND SYSTEM FOR PERFORMING REAL-TIME ANALYTICS ON A PLURALITY OF DATA STREAMS

Patent Matrix® Search