LAZY INITIALIZATION OF OPERATOR GRAPH IN A STREAM COMPUTING APPLICATION

摘要

System, method, and computer program product to perform an operation, comprising receiving job information for a stream computing application, the job information comprising a plurality of processing elements configured to process streaming data tuples according to an execution path defined by a operator graph, deploying a first set of processing elements of the plurality of processing elements to one or more compute nodes, initializing a subset of the first set of processing elements, executing the stream computing application on the first set of processing elements, and, responsive to receiving a predefined number of data tuples to be processed by an additional processing element of the plurality of processing elements when executing the stream computing application, deploying the additional processing element to the one or more compute nodes, and initializing the additional processing element.

主权项

1. A method, comprising:
receiving job information for a stream computing application, the job information defining at least a plurality of processing elements configured to process streaming data tuples by operation of one or more computer processors and according to an execution path defined by an operator graph; deploying a first set of processing elements of the plurality of processing elements to one or more compute nodes; initializing a subset of the first set of processing elements; executing the stream computing application on the first set of processing elements; and responsive to receiving a predefined number of data tuples to be processed by an additional processing element of the plurality of processing elements when executing the stream computing application:
deploying the additional processing element to the one or more compute nodes; andinitializing the additional processing element.