Patent ID: 8161187
Filing Date: 2012-04-17
Classification: G06Q

Abstract:
1. A method, in a stream processing system, for composing stream processing workflows using automatic planning, comprising: receiving, by one or more processors of one or more computers, a request for stream processing in the stream processing system, wherein the stream processing system receives one or more primal streams and executes stream processing applications in a stream processing operating environment, wherein the request is a goal-based problem with specified restrictions, and wherein resulting output streams represent a flow of information satisfying the specified restrictions, wherein each primal stream is a stream that is received by the stream processing system, but that is not generated within the stream processing system; translating, by the one or more processors, the request for stream processing into a formal expression of the request in a description language; generating, by the one or more processors, a workflow based on the formal expression of the request and a domain definition in the description language, wherein the domain definition describes the stream processing operating environment, and wherein the workflow comprises a graph having nodes corresponding to stream processing application components with possible parameters values set and links corresponding to streams; adapting, by the one or more processors, the graph to a current configuration of the stream processing operating environment; and producing the resulting output streams in the stream processing system operating environment that satisfy the specified restrictions using the workflow.