O Atlas Stream Processing oferece suporte a operadores agregação pipeline 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 da instância de processamento de fluxo toda vez que o Atlas Stream Processing a 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. |