STREAMING QUERY DEPLOYMENT OPTIMIZATION
First Claim
1. An apparatus, comprising:
- a processor and a memory communicatively connected to the processor, the processor configured to;
determine a centralized query plan configured to provide a centralized deployment of the streaming query;
determine a tree representing a distributed environment in which the streaming query is to be deployed; and
determine, based on the centralized query plan and the tree representing the distributed environment in which the streaming query is to be deployed, a distributed query plan configured to provide a distributed deployment of the streaming query within the distributed environment.
3 Assignments
0 Petitions
Accused Products
Abstract
A streaming query control capability is presented herein. The streaming query control capability may support improvement or optimization of various aspects of streaming queries. The streaming query control capability may support improvements or optimization in streaming query performance within an environment. The streaming query control capability may support improvements in streaming query performance via improvements in deployment of a streaming query to an environment. The streaming query control capability may support improvements in streaming query performance via modification of a streaming query intended for execution in an environment based on measurement data collected from the environment. The streaming query control capability may support improvements in streaming query performance via integrated deployment and activation of multiple streaming queries sharing a common characteristic. Various combinations of such capabilities may be supported for improvement or optimization of various aspects of streaming queries.
-
Citations
20 Claims
-
1. An apparatus, comprising:
a processor and a memory communicatively connected to the processor, the processor configured to; determine a centralized query plan configured to provide a centralized deployment of the streaming query; determine a tree representing a distributed environment in which the streaming query is to be deployed; and determine, based on the centralized query plan and the tree representing the distributed environment in which the streaming query is to be deployed, a distributed query plan configured to provide a distributed deployment of the streaming query within the distributed environment. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9)
-
10. A method, comprising:
using a processor and a memory for; determining a centralized query plan configured to provide a centralized deployment of the streaming query; determining a tree representing a distributed environment in which the streaming query is to be deployed; and determining, based on the centralized query plan and the tree representing the distributed environment in which the streaming query is to be deployed, a distributed query plan configured to provide a distributed deployment of the streaming query within the distributed environment.
-
11. An apparatus, comprising:
a processor and a memory communicatively connected to the processor, the processor configured to; identify a first streaming query and a second streaming query sharing a common characteristic; and determine, based on the common characteristic, a query plan configured for integrated deployment and execution of the first streaming query and the second streaming query within an environment. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19)
-
20. A method, comprising:
using a processor and a memory for; identifying a first streaming query and a second streaming query sharing a common characteristic; and determining, based on the common characteristic, a query plan configured for integrated deployment and execution of the first streaming query and the second streaming query within an environment.
Specification