sumSimpleState
説明
SimpleState
コンビネータは sum
関数に適用でき、すべての入力値の合計を返します。結果は SimpleAggregateFunction
タイプで返されます。
使用例
上昇票と下降票の追跡
投稿に対する票を追跡するテーブルを使用した実用例を見てみましょう。各投稿について、上昇票、下降票、および全体スコアの累計を維持したいと考えています。SimpleAggregateFunction
タイプを使用した sum は、集計の全状態を保持するのではなく、累計のみを保存するため、このユースケースに適しています。その結果、処理が高速になり、部分的な集計状態のマージが不要になります。
まず、生データ用のテーブルを作成します:
次に、集計データを保存するターゲットテーブルを作成します:
その後、SimpleAggregateFunction
タイプのカラムを持つマテリアライズドビューを作成します:
サンプルデータを挿入します:
SimpleState
コンビネータを使用してマテリアライズドビューにクエリを実行します: