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 canalización 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 procesamiento de flujo cada vez que Atlas Stream Processing lo evalúa. | |
Devuelve un objeto que contiene todos los metadatos de transmisión de un documento. | |
Devuelve un UUID Tipo BSON. Esta expresión no acepta ningún argumento. | |
Ejecuta código JavaScript personalizado localmente dentro de la canalización. |