APPARATUS AND METHOD FOR PROCESSING A DATA STREAM

• US 20110145221A1
• Filed: 06/29/2010
• Published: 06/16/2011
• Est. Priority Date: 12/11/2009
• Status: Active Grant

• Current Assignee: Samsung Electronics Co. Ltd.
• Original Assignee: Samsung Electronics Co. Ltd.
• Inventors: Kim, Jeong-Ja, Jin, Yeong-Ho, Noh, Ye-Jin
• Granted Patent: US 9,378,244 B2
• Time in Patent Office: Days
• US Class Current: 707/718
• CPC Class Codes: G06F 16/24539 using cached or materialised query results
• CPC Class Codes: G06F 16/2454 Optimisation of common expressions
• CPC Class Codes: G06F 16/24542 Plan optimisation
• CPC Class Codes: G06F 16/2471 Distributed queries

Abstract

An apparatus and method for processing data stream are provided. A query execution plan for processing data stream is shared between the server and the terminal. The server builds a query execution plan and determines a part of the built query execution plan to be executed in the terminal. The terminal executes the part of the built query execution plan and transfers a result of the execution. The server executes the remaining part of the built query execution plan based on the execution result transferred by the terminal. The part of the query execution plan to be executed in the terminal is determined depending on the performance of the terminal.

Claims

1. An apparatus for processing a data stream, the apparatus comprising:

a determination unit configured to determine a first part and a second part of a query execution plan on queries, the first part comprising a part to be executed in a terminal, the second part comprising a part to be executed in a server;

a providing unit configured to provide the terminal with the first part; and

a combining unit configured to combine a query execution result with the second part, the query execution result corresponding to the first part and being received from the terminal.

2. The apparatus of claim 1, wherein the determination unit is further configured to:

estimate an operation cost, the operation cost being used to execute a query operator included in the query execution plan in the terminal; and

determine the first part based on the estimated operation cost.

3. The apparatus of claim 2, further comprising a terminal information storage unit configured to store terminal-related information comprising at least one of:

identification information of the terminal, a Central Processing Unit (CPU) performance information of the terminal, a memory size of the terminal, and an access speed of the terminal to a network.

4. The apparatus of claim 3, wherein the operation cost is estimated based on the terminal-related information.

5. The apparatus of claim 3, wherein the combining unit is further configured to combine the query execution result corresponding to the first part with the second part based on the terminal-related information.

6. The apparatus of claim 1, wherein the query execution plan comprises:

at least one query operator; and

an execution order of the query operator.

7. An apparatus for processing a data stream, the apparatus comprising:

a receiving unit configured to receive a first part of a query execution plan on queries, the first part being determined as a part to be executed in a terminal; and

a partial query execution part configured to;

execute the first part of the query execution plan; and

transmit a result of the execution to a server.

8. The apparatus of claim 7, wherein the partial query execution unit is further configured to transmit identification information of the terminal, together with the execution result, to the server.

9. The apparatus of claim 7, wherein the query execution plan comprises:

at least one query operator; and

an execution order of the query operator.

10. An apparatus for processing a data stream based on a query execution plan for queries, the apparatus comprising:

a data sensing terminal configured to execute a part of the query execution plan; and

a data stream management server configured to;

receive a result of the part of query execution plan from the data sensing terminal; and

execute another part of the query execution plan based on the received result.

11. The apparatus of claim 10, wherein the data stream management server is configured to:

estimate an operation cost of the data sensing terminal for executing query operators included in the query execution plan; and

determine a part of the query execution plan based on the estimated operation cost, the part of the query execution plan to be executed in the data sensing terminal.

12. A method of processing a data stream, the method comprising:

at a server, determining a first part and a second part of a query execution plan on queries, the first part comprising a part to be executed in a terminal, the second part comprising a part to be executed in the server;

at the server, providing the terminal with the first part;

at the terminal;

executing the first part; and

transmitting a result of the execution to the server; and

at the server, combining the result of execution with the second part.

15. The method of claim 12, wherein, in the combining, the execution result of the first part is combined with the second part based on an identification information of the terminal.

13. The method of claim 13, wherein the determining of the first part and the second part comprises:

estimating an operation cost of the terminal for executing query operators included in the query execution plan; and

determining the first part based on the estimated operation cost.

14. The method of claim 13, wherein the operation cost is estimated based on at least one of:

identification information of the terminal, Central Processing Unit (CPU) performance information of the terminal, a memory size of the terminal, and an access speed of the terminal to a network.