聚合管道操作符

Atlas Stream Processing支持聚合管道操作符来处理连续数据流。

除了这些操作符之外，下表还列出了Atlas Stream Processing特有的聚合管道表达式，以及以修改后的形式存在于Atlas Stream Processing中的表达式。

聚合管道表达式	用途
$convert	在 binData 和其他类型（例如 int、long、double 和 string）之间转换值。通常与Apache Kafka标头值一起使用。
$currentDate	每次 Atlas Stream Processing 评估工作区时，都会返回 Stream Processing 工作区的系统时间。
$meta	返回一个对象，其中包含文档的所有流媒体元数据。
$createUUID	返回 UUID BSON类型。该表达式不带任何参数。
$function	在管道中本地运行自定义JavaScript代码。

后退

开发流处理器

来年

$convert