Managed function execution for processing data streams in real time

A method, comprising:

• performing, by one or more computing devices providing customizable stream processing functions for one or more clients:
• receiving, from a client of the one or more clients via a programmatic interface, a function for a data stream that specifies one or more operations to be performed upon data records of a data stream;
• determining one or more stream processing nodes configured to apply the function with respect to the data stream;
• and
• executing the function at the one or more stream processing nodes such that the one or more operations are performed upon the data records of the data stream as the data records are received at the one or more stream processing nodes.

A non-transitory, computer-readable storage medium, storing program instructions that when executed by one or more computing devices cause the one or more computing devices to implement:

• receiving, via a programmatic interface, a processing function for a data stream;
• provisioning one or more stream processing nodes capable of applying the processing function with respect to the data stream;
• and
• initiating execution of the processing function at the one or more stream processing nodes such that the processing function is applied to data records of the data stream as the data records are received at the one or more stream processing nodes;
• wherein the one or more computing devices implement a managed stream processing system providing customizable stream processing functions for one or more clients.