A system provides an environment for parallel programming by providing a plurality of modular parallelizable operators stored in a computer readable memory. Each operator defines operation programming for performing an operation, one or more communication ports, each of which is either an input port for providing the operation programming a data stream of records, or an output port for receiving a data stream of records from the operation programming and an indication for each of the operator's input ports, if any, of a partitioning method to be applied to the data stream supplied to the input port. An interface enables users to define a data flow graph by giving instructions to select a specific one of the operators for inclusion in the graph, or instructions to select a specific data object, which is capable of supplying or receiving a data stream of one or more records, for inclusion in the graph, or instructions to associate a data link with a specific communication port of an operator in the graph, which data link defines a path for the communication of a data stream of one or more records between its associated communications port and either a specific data object or the specific communication port of another specific operator in said graph. The execution of a data flow graph equivalent to that defined by the users is automatically parallelized by causing a separate instance of each such operator, including its associated operation programming, to be run on each of multiple processors, with each instance of a given operator having a corresponding input and output port for each input and output port of the given operator, and by automatically partitioning the data stream supplied to the corresponding inputs of the instances of a given operator as a function of the partitioning method indication for the given operator's corresponding input.

Un sistema proporciona un ambiente para la programación paralela proporcionando una pluralidad de operadores parallelizable modulares almacenados en una memoria legible por computador. Cada operador define la operación que programa para realizar una operación, unos o más puertos de comunicación, cada uno de los cuales es un puerto de la entrada para proporcionar la operación que programa una secuencia de datos de expedientes, o un puerto de salida para recibir una secuencia de datos de expedientes de la programación de la operación y de una indicación para cada uno de los puertos de la entrada del operador, si los hay, de un método que reparte para ser aplicado a la secuencia de datos provista al puerto de la entrada. Un interfaz permite a usuarios definir datos flujo gráfico dando instrucciones de seleccionar específico de los operadores para la inclusión en el gráfico, o las instrucciones de seleccionar los datos específicos se oponen, que es capaz de proveer o de recibir una secuencia de datos de unos o más expedientes, para la inclusión en el gráfico, o las instrucciones de asociar una trasmisión de datos a un puerto de comunicación específico de un operador en el gráfico, que la trasmisión de datos define una trayectoria para la comunicación de una secuencia de datos de unos o más expedientes entre su puerto de comunicaciones asociado y datos específicos se oponen o el puerto de comunicación específico de otro operador específico en el gráfico dicho. La ejecución de datos flujo gráfico equivalente a ése definidos por los usuarios es hecha parelelismo automáticamente causando un caso separado de cada tal operador, incluyendo su operación asociada que programa, para ser funcionado en cada uno de procesadores múltiples, con cada caso de un operador dado que tiene un puerto correspondiente de la entrada y de salida para cada puerto de la entrada y de salida del operador dado, y automáticamente repartiendo la secuencia de datos provista a las entradas correspondientes de los casos de un operador dado en función de la indicación del método que reparte para la entrada correspondiente del operador dado.