System of type inference for tuple graph programs method of executing a tuple graph program across a network
First Claim
1. A method for type inference in a program, the method comprising:
- receiving, by one or more computing devices, first type information for one or more input streams of the program, wherein the program includes a directed graph wherein nodes in the graph represent operators and wherein edges in the graph represent streams of tuples that flow from one operator to another along the edges during execution of the program;
receiving, by the one or more computing devices, for each operator, an output type annotation;
determining, for each operator in one forward pass through the graph, second type information for one or more output streams based on the first type information associated with one or more incoming streams of the operator and the output type annotation associated with the operator, wherein the second type information includes constraints that restrict the tuples included in the one or more streams; and
associating the second type information with the respective one or more output streams.
2 Assignments
0 Petitions
Accused Products
Abstract
A programming model provides a method for type inference in programming operations. Information defining one or more attributes of an operation is received, the information specifying a field including a field name and a field type identifier for each of the attributes. Constraints for the operation are determined at least based on the attributes, wherein the constraints restrict at least one of a type of input for the operation or a type of output for the operation. Information defining an input for the operation is received, and it is determined, based on the constraints and the received information defining the input, the type of output for the operation. The type of output is associated with an output for the operation.
-
Citations
9 Claims
-
1. A method for type inference in a program, the method comprising:
-
receiving, by one or more computing devices, first type information for one or more input streams of the program, wherein the program includes a directed graph wherein nodes in the graph represent operators and wherein edges in the graph represent streams of tuples that flow from one operator to another along the edges during execution of the program; receiving, by the one or more computing devices, for each operator, an output type annotation; determining, for each operator in one forward pass through the graph, second type information for one or more output streams based on the first type information associated with one or more incoming streams of the operator and the output type annotation associated with the operator, wherein the second type information includes constraints that restrict the tuples included in the one or more streams; and associating the second type information with the respective one or more output streams. - View Dependent Claims (2, 3)
-
-
4. A system for type inference in a program, the system comprising:
-
a memory; and one or more processors configured to; receive first type information for one or more input streams of the program, wherein the program includes a directed graph wherein nodes in the graph represent operators and wherein edges in the graph represent streams of tuples that flow from one operator to another along the edges during execution of the program; receive, for each operator, an output type annotation; determine, for each operator in one forward pass through the graph, second type information for one or more output streams based on the first type information associated with one or more incoming streams of the operator and the output type annotation associated with the operator, wherein the second type information includes constraints that restrict the tuples included in the one or more streams; and associate the second type information with the respective one or more output streams. - View Dependent Claims (5, 6)
-
-
7. A non-transitory computer-readable medium storing instructions executable by one or more processors for performing a method for type inference in a program, comprising:
-
receiving first type information for one or more input streams of the program, wherein the program includes a directed graph wherein nodes in the graph represent operators and wherein edges in the graph represent streams of tuples that flow from one operator to another along the edges during execution of the program; receiving, for each operator, an output type annotation; determining, for each operator in one forward pass through the graph, second type information for one or more output streams based on the first type information associated with one or more incoming streams of the operator and the output type annotation associated with the operator, wherein the second type information includes constraints that restrict the tuples included in the one or more streams; and associating the second type information with the respective one or more output streams. - View Dependent Claims (8, 9)
-
Specification