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 datos binarios en los encabezados de Apache Kafka entre binData y tipos int, long, double y string. | |
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. |