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 Kafka headers between binData and int, long,
double, and string types. |