Search All Applications in Quantum Computing
Application US20190188238
Published 2019-06-20
Method And System For Performing Real-time Analytics On A Plurality Of Data Streams
A method and system are disclosed for performing real-time analytics on a plurality of data streams, the method comprising 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; 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.
Much More than Average Length Specification
View the Patent Matrix® Diagram to Explore the Claim Relationships
USPTO Full Text Publication >
- 1. A method for performing real-time analytics on a plurality of data streams, the method comprising:
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.
- 23. A digital computer comprising:
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:
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:
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; 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.