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 values between binData and other types such as int, long, double, and string. Commonly used with Apache Kafka header values. | |
Returns the system time of the stream processing workspace 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. |