はじめに

先日、以下の記事を発表しました。

新しいテクノロジーに触れる時はいつでも楽しいものです。

まだまだ勉強中ですが、公式ドキュメントの学習過程の記録として、以下の記事をまとめてみました。

本稿情報のソースとして、下記ドキュメントを参照ください。

エンティティ

エンティティは、Kaskada が特徴エンジニアリングで使用するためにデータを編成する方法です。エンティティは、Kaskadaシステム(実行環境)内部での特定の種類のオブジェクトの表現だと言えます。

エンティティとは何か?

エンティティは、Kaskadaシステム内の「（普通※）名詞」を表します（※個々のエンティティの実体を「固有名詞」を持つもの、と捉えることができます。）
一般な表現を用いると、エンティティは、システムに取り込まれたデータセットから識別できるオブジェクトの任意のカテゴリと考えることができます。
エンティティの一般的な例は、「ユーザー」または「ベンダー」です。
何かに名前またはその他の一意の識別子を与えることができる場合、それはおそらくエンティティとして表現できます(リレーショナルデータベースでは、エンティティとは、テーブルのセット内の同じキーによって識別されるものです)
Kaskadaの「テーブル」について、すでに認識されていれば、エンティティは、テーブルと対応していると捉えることができます。

エンティティキーとは何か?

エンティティはものの種類のカテゴリを表しますが、「エンティティキー」はそのカテゴリ内の特定のアイテムを表します。以下は、エンティティの例と特定のエンティティインスタンスを示した表です。

どのようにエンティティを使うのか?

エンティティが Fenl式の中で、どのように扱われるかを示すために、2 つのテーブルで構成される単純化されたデータセットから始めます。

このPurchase表は購入トランザクションを説明しています。

{ customer_id: string, time: datetime, product_id: string, amount: number }

このProductReview表は、購入した製品に対する顧客の評価を示しています

{ customer_id: string, time: datetime, product_id: string, stars: number }

エンティティごとの集計

すべての集計関数 (すなわちsum、countなど) は、集計対象式のエンティティにスコープされます。

たとえば、以下の例では、「購入」データから顧客ごとの結果（購入のカウント/数）が生成されます。

Purchase | count()

クロステーブル操作

2 つのテーブルが同じエンティティについてのデータを保持している場合、結合条件を指定することなく結合できます。
エンティティキーは暗黙的な結合キーとして機能します。

たとえば、ここで、Purchaseと ProductReviewテーブルの両方のエンティティは「顧客」です。そのため、定型的な結合コードを使用せずに、各テーブルの集計を結合できます。

{
  p_count: Purchase | count(),
  c_avg_rating: ProductReview.stars | mean(),
}

エンティティの変更

一部の値は複数のエンティティに関連します。たとえば、 ProductReviewは製品をレビューした「顧客」とレビューされた「製品」の両方の観点から捉えることができます。このような場合には、式が暗黙に前提するエンティティを、新しいエンティティキーを指定することで変更できます。

ProductReview | with_key(ProductReview.product_id)

式のエンティティを変更しても、式によって生成される値には影響しません。変更は、結果がエンティティキーに依存する操作 (集計など) で使用される場合にのみ表れます。

ProductReview
  | with_key(ProductReview.product_id)
  | mean()

さまざまなエンティティとの連携

多くの場合、異なるエンティティに関連付けられた値を組み合わせる必要があります。これは、特定のキーで式の値を検索することで実現できます。

lookup 関数は 2 つの引数を取ります。最初の引数 (キー式) は検索されるエンティティキーを記述し、2 番目の引数 (外部式) は検索される値を記述します。

let avg_review_by_product = ProductReview
  | with_key(ProductReview.product_id)
  | mean()

in {
  p_count: Purchase | count(),
  c_avg_rating: ProductReview.stars | mean(),
  p_avg_rating: avg_review_by_product | lookup($input, Purchase.product_id)
}

lookup 式は、キー式が null 以外の値を生成するたびに、外部式の値を生成します。

Note:タイムトラベル

他のすべての Fenl 式と同様に、ルックアップは「temporal」なものです。これは、検索式によって生成される値が、生成時に検索される値を正確に反映していることを意味します。Kaskada では、現実世界と同様に、情報が時間を逆行することはできません。

クエリ結果内のエンティティ

すべての Fenl 式はエンティティに関連付けられ、すべての Fenl 値はエンティティキーに関連付けられます。

Fenl クエリは、クエリ式によって生成されたすべての非 null 値を返します。エンティティがテーブル内に存在しても、特定のクエリに対して値を生成しない場合があります。

let total = Purchase.amount | sum()
in { total: total | if(total >= 0) }

NULL値はクエリ結果から省略されるため、この式では合計が負のエンティティに対してゼロ行が生成される可能性があります。 NULL値をキャプチャするには、条件をレコード内に移動します。そうすると、値はNULLになりますが、それを囲むレコードはNULLになりません。

let total = Purchase.amount | sum()
in { total: total | if(total >= 0) }