Atlas Stream Processing admite la canalización de agregación operadores para procesar flujos de datos continuos.
Además de estos operadores, la siguiente tabla enumera las expresiones de canalización de agregación exclusivas de Atlas Stream Processing y aquellas que existen en forma modificada en Atlas Stream Processing.
Expresión de pipeline de agregación | Propósito |
|---|---|
Convierte datos binarios en Apache Kafka encabezados 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 UUID BSON type. Esta expresión no acepta ningún argumento. | |
Ejecuta código JavaScript personalizado localmente dentro del pipeline. |