Distributed data stream programming and processing
AssigneeT-Mobile USA, Inc.
InventorSergey Slovetskiy
Life of this patent
Estimating the term…
Abstract
Techniques are described herein for distributed data stream programming and processing. The techniques include sending a request indicating one or more regions of a program code to access a stream in a stream pool and to execute on a processing node in a processing nodes pool. The techniques also include accessing the stream defined in the one or more regions of the program code to service the request. Thereafter, the processing node is selected to use for execution of the one or more regions of the program code and the processing node executes one or more instances of the one or more regions of the program code.
Claims20
One or more non-transitory computer-readable media storing computer-executable instructions that upon execution cause one or more processors to perform acts comprising:
- sending a request indicating one or more regions of program code to access a stream in a stream pool and to execute on a processing node in a processing nodes pool;
- accessing the stream defined in the one or more regions of the program code to service the request;
- selecting the processing node to use for execution of the one or more regions of the program code;
- and
- commanding the processing node to execute one or more instances of the one or more regions of the program code.
A computer-implemented method, comprising:
- sending a request indicating one or more regions of a program code to access a stream in a stream pool and to execute on a processing node in a processing nodes pool;
- accessing the stream defined in the one or more regions of the program code to service the request;
- selecting the processing node to use for execution of the one or more regions of the program code;
- and
- commanding the processing node to execute one or more instances of the one or more regions of the program code.
A system, comprising:
- one or more non-transitory storage mediums configured to provide stored computer-readable instructions, the one or more non-transitory storage mediums coupled to one or more processors, the one or more processors configured to execute the computer-readable instructions to cause the one or more processors to:
- send a request indicating one or more regions of a program code to access a stream in a stream pool and to execute on a processing node in a processing nodes pool;
- access the stream defined in the one or more regions of the program code to service the request;
- select the processing node to use for execution of the one or more regions of the program code;
- and
- command the processing node to execute one or more instances of the one or more regions of the program code.
Dependencies are inferred from the claim text.