Systems and methods of block computation
First Claim
Patent Images
1. A method of block computation, the method implemented by program code stored on a non-transient computer-readable medium and executable by a processor, the method comprising:
- buffering, via the processor, a chunk having a plurality of tuples received in a pipeline manner in a build phase;
after buffering a last of the plurality of tuples of the chunk, applying, via the processor, a block computation to all of the buffered tuples in the chunk during a compute phase; and
returning, via the processor, results of the block computation on the chunk, the results returned one tuple at a time to a query processing pipeline in a stream-out phase.
8 Assignments
0 Petitions
Accused Products
Abstract
Systems and methods of block computation are disclosed. An example of a method includes buffering a plurality of tuples in a build phase. The method also includes, after buffering a last of the plurality of tuples, applying a computation to all of the buffered tuples in a compute phase. The method also includes returning results of the computation one tuple at a time to a query processing pipeline in a stream-out phase.
-
Citations
20 Claims
-
1. A method of block computation, the method implemented by program code stored on a non-transient computer-readable medium and executable by a processor, the method comprising:
-
buffering, via the processor, a chunk having a plurality of tuples received in a pipeline manner in a build phase; after buffering a last of the plurality of tuples of the chunk, applying, via the processor, a block computation to all of the buffered tuples in the chunk during a compute phase; and returning, via the processor, results of the block computation on the chunk, the results returned one tuple at a time to a query processing pipeline in a stream-out phase. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9)
-
-
10. A system of block computation implemented by program code stored on a non-transient computer-readable medium and executable by a processor, the system, comprising:
-
a buffer for holding a chunk having a plurality of tuples received in a pipeline manner during a build phase; a computation engine for applying a block computation to all of the chunk during a compute phase after the build phase finishes; and a query processing pipeline for returning results from the block computation on the chunk, the results returned one tuple at a time during a stream-out phase. - View Dependent Claims (11, 12, 13, 14, 15, 16, 17)
-
-
18. A system of block computation implemented by program code stored on a non-transient computer-readable medium and executable by a processor, the system comprising:
-
a computation engine for buffering a chunk having a plurality of tuples received in a pipeline manner, and for, after buffering a last of the plurality of tuples in the chunk, applying a block computation to all of the buffered tuples in the chunk; a user defined function (UDF) defining the block computation for the computation engine, the UDF defining operations for a tuple-set corresponding to a single time window; and a query processing pipeline for receiving results from the computation engine one tuple at a time. - View Dependent Claims (19, 20)
-
Specification