Supported Aggregation Pipeline Expression

Atlas Stream Processing supports aggregation pipeline expressions for processing continuous data streams.

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
`$convert`	Converts binary data in Apache Kafka headers between binData and int, long, double, and string types.
`$currentDate`	Returns the system time of the stream processing instance each time Atlas Stream Processing evaluates it.
`$meta`	Returns an object containing all streaming metadata for a document.
`$createUUID`	Returns a UUID BSON type. This expression does not take any arguments.

Back

Manage VPC Peering Connections

$convert