PARALLEL DATA STREAM PROCESSING SYSTEM
First Claim
Patent Images
1. A log processing system, comprising:
- a processor-implemented log module configured to receive and organize a stream of data into a sequential and nested data structure;
a processor-implemented query language operator module configured to define operators that operate on the sequential and nested data structure; and
a processor-implemented query processing module configured to process in parallel across a plurality of nodes a query based on an operator on the stream of data.
1 Assignment
0 Petitions
Accused Products
Abstract
A method and a system process a stream of data in parallel across a plurality of nodes. The log processing system has a log module, a query language module, and a query processing module. The log module receives and organizes the stream of data into a sequential and nested data structure. The query language operator module defines operators that operate on the sequential and nested data structure. The query processing module processes in parallel across a plurality of nodes a query based on an operator on the stream of data.
-
Citations
21 Claims
-
1. A log processing system, comprising:
-
a processor-implemented log module configured to receive and organize a stream of data into a sequential and nested data structure; a processor-implemented query language operator module configured to define operators that operate on the sequential and nested data structure; and a processor-implemented query processing module configured to process in parallel across a plurality of nodes a query based on an operator on the stream of data. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A computer-implemented method, comprising:
-
receiving a stream of data; organizing the stream of data in a sequential and nested data structure; defining operators to operate on the sequential and nested data structure; and processing in parallel across a plurality of nodes a query based on an operator on the stream of data. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. A non-transitory computer-readable storage medium storing a set of instructions that, when executed by a processor, cause the processor to perform operations, comprising:
-
receiving a stream of data; organizing the stream of data in a sequential and nested data structure; defining operators to operate on the sequential and nested data structures; and processing in parallel across a plurality of nodes a query based on an operator on the stream of data. - View Dependent Claims (16, 17, 18, 19, 20, 21)
-
Specification