User interface for customizing data streams

A computing system comprising:

• memory;
• a display device;
• and
• one or more processing devices coupled to the memory and configured to:
• cause display of a first graphical control of a first graphical user interface on the display device, the first graphical control enabling a user to define one or more data streams;
• cause display of a second graphical control of a second graphical user interface on the display device, the second graphical control enabling the user to define one or more processing pipelines, the second graphical control further enabling the user to specify a data route that comprises the one or more data streams and the one or more processing pipelines;
• implement the one or more data streams and the one or more processing pipelines based on the data route, wherein each processing pipeline of the one or more processing pipelines performs one or more corresponding data transformations based on input obtained via the second graphical control, wherein each data stream of the one or more data streams, based on input obtained via the first graphical control:
• obtains data from one or more of a first processing pipeline of the one or more processing pipelines or a data source and writes the data to a second processing pipeline of the one or more processing pipelines, or
• obtains data from a first processing pipeline of the one or more processing pipelines and writes the data to a second processing pipeline of the one or more processing pipelines or a data sink;
• and
• route a set of data based at least in part on the data route specified by the second graphical control.

Non-transitory computer readable media comprising computer-executable instructions that, when executed by a computing system of a streaming data processing system, cause the computing system to:

• cause display of a first graphical control of a first graphical user interface on a display device, the first graphical control enabling a user to define one or more data streams;
• cause display of a second graphical control of a second graphical user interface on the display device, the second graphical control enabling the user to define one or more processing pipelines, the second graphical control further enabling the user to specify a data route that comprises the one or more data streams and the one or more processing pipelines;
• implement the one or more data streams and the one or more processing pipelines based on the data route, wherein each processing pipeline of the one or more processing pipelines performs one or more corresponding data transformations based on input obtained via the second graphical control, wherein each data stream of the one or more data streams, based on input obtained via the first graphical control:
• obtains data from one or more of a first processing pipeline of the one or more processing pipelines or a data source and writes the data to a second processing pipeline of the one or more processing pipelines, or
• obtains data from a first processing pipeline of the one or more processing pipelines and writes the data to a second processing pipeline of the one or more processing pipelines or a data sink;
• and
• route a set of data based at least in part on the data route specified by the second graphical control.