Merge

Descripción

El modulo Merge recopila y unifica datos de múltiples chunks procesados en paralelo (por ejemplo, desde un Iterator). Espera a que todos los chunks de una ejecución (identificados por workflowRunId) hayan sido procesados y almacenados en la base de datos. Cuando se recibe el último chunk, combina todos los datos en un array unificado (mergedResult) y limpia los registros temporales. Si aun faltan chunks, retorna un mensaje de espera sin continuar el flujo. Es el complemento natural del Iterator para recombinar resultados.

Configuración

Parámetros

Parámetro	Tipo	Requerido	Descripción
(sin parámetros configurables)	-	-	Este modulo no requiere configuración adicional. Opera automáticamente basandose en los metadatos _meta_ del data.

Salida

{
  "nextModule": "siguiente_modulo",
  "data": {
    "mergedResult": [
      { "item1": "datos_procesados_1" },
      { "item2": "datos_procesados_2" },
      { "item3": "datos_procesados_3" }
    ]
  }
}

Ejemplo de Uso

Caso básico

{
  "label": "merge"
}

Notas

• Requiere que los datos de entrada contengan _meta_.workflowRunId y _meta_.totalChunks para funcionar correctamente.
• Los chunks se almacenan en la tabla merge_chunks de la base de datos.
• Si no se han recibido todos los chunks, retorna nextModule: null con un mensaje de progreso.
• Una vez completado el merge, se eliminan los registros temporales de la tabla merge_chunks.
• Los datos se combinan en un array ordenado dentro de mergedResult.
• Es el complemento del modulo Iterator: el Iterator divide, el Merge recombina.

Nodos Relacionados

• Iterator - divide un array en chunks para procesamiento paralelo
• MergeResults - merge avanzado con soporte para niveles de iteración
• MergeMultiple - merge de múltiples ramas del flujo