Data stream processing apparatus and method using query partitioning
AssigneeElectronics and Telecommunications Research Institute
InventorYong-Ju LEE
Life of this patent
Estimating the term…
Abstract
Disclosed herein is a data stream processing apparatus and method using query partitioning, which allow data stream processing apparatuses to perform partitioned processing/parallel processing on partitioned sub-queries. The proposed data stream processing apparatus using query partitioning receives a query from a user, partitions the query into a plurality of sub-queries, transmits the partitioned sub-queries to another data stream processing apparatus or a sub-query processing unit, integrates the results of the processing of sub-queries processed by the other data stream processing apparatus and the sub-query processing unit with each other, generates a response to the query, and transmits the generated response to the user.
Claims20
A data stream processing apparatus using query partitioning, comprising:
- a query reception unit for receiving a query required to process a data stream from a user;
- a query partitioning unit for partitioning the query received from the query reception unit into a plurality of sub-queries;
- a sub-query transmission unit for transmitting at least one of the plurality of sub-queries to another data stream processing apparatus;
- a sub-query processing unit for processing a sub-query received from the sub-query transmission unit;
- a query integration unit for integrating results of sub-queries received from the other data stream processing apparatus and the sub-query processing unit and generating a response to the query;
- and
- a query response unit for transmitting the response received from the query integration unit to the user.
A data stream processing method using query partitioning, comprising:
- receiving, by a query reception unit, a query required to process a data stream from a user;
- partitioning, by a query partitioning unit, the received query into a plurality of sub-queries;
- transmitting, by a sub-query transmission unit, at least one of the plurality of sub-queries to another data stream processing apparatus;
- processing, by a sub-query processing unit, a sub-query received from the sub-query transmission unit;
- integrating, by a query integration unit, results of sub-queries received from the other data stream processing apparatus and the sub-query processing unit and generating a response to the query;
- and
- transmitting, by a query response unit, the generated response to the user.
Dependencies are inferred from the claim text.