O Atlas Stream Processing oferece suporte a operadores de pipeline de agregação 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 valores entre binData e outros tipos, como int, long, double e string. Comumente usado com valores de cabeçalho do Apache Kafka. | |
Retorna o horário do sistema do espaço de trabalho do processamento de fluxos cada 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 de UUID BSON. Esta expressão não utiliza quaisquer argumentos. | |
Executa código JavaScript personalizado localmente dentro do pipeline. |