摘要 |
A method, system, and computer program product for improved clustering of analytic functions in a data processing environment are described. A set of instances of an analytic function receiving data input from a set of data sources is identified. A first subset of instances is configured to receive input from a first subset of data sources, and a second subset of instances is configured to receive input from a second subset of data sources. The set of instances is assigned to a cluster. The cluster begins executing in a computer in the data processing environment, when the first subset of data sources begins transmitting time series data input to the first subset of instances in the cluster. |