O Atlas Stream Processing oferece suporte a operadores agregação pipeline operadores para processar fluxos de dados contínuos.
Além desses operadores, a tabela a seguir lista as expressões de pipeline de agregação exclusivas do Atlas Stream Processing e aquelas que existem de forma modificada no Atlas Stream Processing.
Expressão de Pipeline de Agregação | Propósito |
|---|---|
Converte dados binários em cabeçalhos Apache Kafka entre binData e tipos int, longo, duplo e string. | |
Retorna a hora do sistema do espaço de trabalho de processamento de fluxo toda vez que o Atlas Stream Processing o avalia. | |
Retorna um objeto que contém todos os metadados de streaming de um documento. | |
Retorna um tipo deBSON UUID . Esta expressão não utiliza quaisquer argumentos. | |
Executa código JavaScript personalizado localmente dentro do pipeline. |