Patent ID: 9043381
Filing Date: 2015-05-26
Classification: G06F

Abstract:
1. A method of predictively starting an operator, comprising: receiving streaming data to be processed by a plurality of operators, wherein each of the plurality of operators is configured to perform a respective one or more operations on received units of data; establishing an operator graph that defines at least one execution path through the plurality of operators, and wherein at least one of the plurality of operators is configured to receive data from at least one upstream operator and transmit data to at least one downstream operator; determining a respective historical startup time for each of two or more operators in the operator graph, which, once started, begin performing the respective one or more operations upon receiving a respective requisite amount of data from a respective one or more upstream operators; determining, for each of the two or more operators, an estimated amount of time the respective operator takes to receive the requisite amount of data from the respective one or more upstream operators, based on a rate at which data was historically received from the respective one or more upstream operators; and predictively starting each of the two or more operators at a respective startup time prior to the respective historical startup time based on the respective estimated amount of time historically taken to receive the requisite amount of data, such that the operator receives the requisite amount of data for performing the respective one or more operators by the determined historical startup time.