25. The system of claim 16 , wherein the processor is further operative with the program to: deploy a stream processing application embodying the at least one data source or the at least one component of the stream processing graph; and operate the stream processing application.
16. A system for assembling a stream processing application, comprising: a memory device for storing a program; a processor in communication with the memory device, the processor operative with the program to: receive and compile a plurality of data source descriptions, wherein each of the data source descriptions includes a graph pattern that semantically describes an output of a data source; receive and compile a plurality of component descriptions, wherein each of the component descriptions includes a graph pattern that semantically describes an input of a component and a graph pattern that semantically describes an output of the component; receive and compile a stream processing request, wherein the stream processing request includes a goal that is represented by a graph pattern that semantically describes a desired stream processing outcome; assemble a stream processing graph in response to the stream processing request, wherein the stream processing graph is assembled by using the plurality of data source descriptions and the plurality of component descriptions and includes at least one of the data sources or at least one of the components that satisfies the desired processing outcome; and output the stream processing graph.