集計パイプライン演算子

Atlas Stream Processing は、連続データストリームを処理するための集計パイプライン演算子をサポートしています。

これらの演算子に加えて、次の表は 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