Parallel data stream processing system
AssigneeeBay Inc.
InventorsGyanit Singh, Chi-Hsien Chiu, Neelakantan Sundaresan
Life of this patent
Estimating the term…
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.
Claims21
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.
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.
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.
Dependencies are inferred from the claim text.