Procesamiento paralelo de consultas continuas sobre flujos de datos.

Un motor de procesamiento paralelo de flujos de datos que ejecuta consultas continuas sobre una pluralidad de nodos de procesamiento (1),

en el que una consulta continua comprende una pluralidad de operadores interconectados, siendo seleccionable cada operador de la consulta entre un operador sin estado (M, F) y un operador con estado (A, J), que comprende:

a) unos medios para dividir una consulta continua en al menos una subconsulta, en el que cada una de dicha al menos una subconsulta consiste en un operador con estado (A, J) seguido por al menos un operador sin estado (M, F), excepto por una subconsulta inicial que solo contiene operadores sin estado (M, F),

b) unos medios para asociar cada al menos una subconsulta con al menos dos nodos (1); en el que los nodos (1) están configurados para ejecutar la subconsulta; en el que una subconsulta ejecutada genera al menos una tupla;

c) unos medios para etiquetar las tuplas generadas con una etiqueta de orden que comprende una marca de tiempo que indica un orden relativo entre las tuplas y que se emplea para ordenar las tuplas a una subconsulta de destino (3) en el mezclador de entradas (IM) caracterizado por que este comprende adicionalmente

d) unos medios para enviar y recibir tuplas entre subconsultas interconectadas, una subconsulta de origen (2) y una subconsulta de destino (3) que comprenden operadores interconectados entre las mismas; en el que los medios para enviar y recibir tuplas comprenden:

- para cada nodo (1) que ejecuta una subconsulta de origen (2), un equilibrador de carga (LB) que está configurado para enviar una pluralidad de tuplas generadas a los nodos (1) que ejecutan una subconsulta de destino (3);

- para cada nodo (1) que ejecuta una subconsulta de destino, un mezclador de entradas (IM) que está configurado para recibir una pluralidad de tuplas generadas que son enviadas por cada equilibrador de carga (LB) de la subconsulta de origen;

en el que el equilibrador de carga (LB) está configurado para determinar el nodo (1) al que se envía una tupla en función de al menos un campo comprendido en la tupla, campo que se denomina campo de clave;

y en el que para cada subconsulta que comprende un operador sin estado (M, F) o un operador con estado (A, J):

- se introduce un mezclador de entradas (IM) al inicio de cada operador (A, M) y un equilibrador de carga (LB) al final de cada operador (A, M), en donde se ejecuta la subconsulta, y

en el que cada equilibrador de carga (LB) está conectado con cada mezclador de entradas (IM) respectivamente para distribuir las tuplas de salida de la subconsulta de origen (2) a la subconsulta de destino (3), en el que cada equilibrador de carga está configurado para:

- enviar tuplas con un mismo campo de clave a un mismo nodo (1) que ejecuta la subconsulta de destino (3), cuando el operador es un operador con estado (A, J), o

- enviar tuplas a la subconsulta de destino de una forma por orden cíclico, cuando el operador es un operador sin estado (M, F).