聚合管道操作符

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

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

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

后退

开发流处理器

来年

$convert