Atlas Stream Processing es compatible con operadores de pipeline de agregación para procesar flujos de datos continuos.
Además de estos operadores, la siguiente tabla enumera las expresiones de pipeline de agregación exclusivas de Atlas Stream Processing y aquellas que se presentan en una forma modificada.
Expresión de pipeline de agregación | Propósito |
|---|---|
Convierte valores entre binData y otros tipos como int, long, double y string. Se usa comúnmente con los valores de encabezado de Apache Kafka. | |
Devuelve la hora del sistema del espacio de trabajo de Stream Processing cada vez que Atlas Stream Processing lo evalúa. | |
Devuelve un objeto que contiene todos los metadatos para un documento en transmisión. | |
Devuelve un tipo de BSON UUID. Esta expresión no acepta ningún argumento. | |
Ejecuta código JavaScript personalizado localmente dentro del pipeline. |