Apparatus and method for processing a data stream

摘要

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.

主权项

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 shared between a server and a terminal, the first part comprising a part to be executed by the terminal served by the server, and the second part comprising a part to be executed by the server,estimate an operation cost, the operation cost corresponding to a computing capacity of the terminal enabling execution of a query operator of the query execution plan by the terminal,set a respective execution threshold for execution of the query operator by the terminal, corresponding to a maximum computing capacity enabling execution of the query operator by the terminal and being based on the estimating of the operation cost at the terminal; anddetermine the first part based on the estimated operation cost; a transmitter configured to transmit the first part to the terminal; and a combining unit configured to receive a query execution result of the first part from the terminal and to combine the received query execution result with the second part,
wherein execution of the second part is based on an actual operation cost of executing the query operator at the terminal compared to the estimated operation cost.