集計パイプライン演算子

これらの演算子に加えて、次の表は Atlas Stream Processing に固有の集計パイプライン式と、Atlas Stream Processing に変更された形式で存在するパイプラインライン式を示しています。

集計パイプライン式	目的
$convert	Apache Kafkaヘッダー内のバイナリデータを、binData と int、long、double 型、string 型の間で変換します。
$currentDate	Atlas Stream Processing が評価するたびに、ストリーム処理ワークスペースのシステム時間を返します。
$meta	ドキュメントのすべてのストリーミングメタデータを含むオブジェクトを返します。
$createUUID	UUID BSON型を返します。この式は引数を取りません。
$function	パイプライン内でカスタムJavaScriptコードをローカルに実行します。

戻る

ストリームプロセッサの開発

$convert