Atlas Stream Processing supports aggregation pipeline operators for processing continuous data streams.
In addition to these operators, the following table lists the aggregation pipeline expressions unique to Atlas Stream Processing and those which exist in modified form in Atlas Stream Processing.
Aggregation Pipeline Expression | Purpose |
|---|---|
Converts binary data in Apache Kafka headers between binData and int, long, double, and string types. | |
Returns the system time of the stream processing instance each time Atlas Stream Processing evaluates it. | |
Returns an object containing all streaming metadata for a document. | |
Returns a UUID BSON type. This expression does not take any arguments. | |
Runs custom JavaScript code locally within the pipeline. |