フィーチャビューを具体化する

Important

この機能はパブリックプレビュー段階です。ワークスペース管理者は、[ プレビュー] ページからこの機能へのアクセスを制御できます。 Manage Azure Databricks プレビューを参照してください。

Unity カタログに格納されているフィーチャービュー定義を作成したら、機能定義を使用してソーステーブルからフィーチャデータを生成できます。このプロセスは、特徴の具体化と呼ばれます。 Azure Databricksは、モデルのトレーニングとバッチスコアリングまたはオンラインサービスのために Unity カタログのテーブルを設定する Lakeflow パイプラインを作成および管理します。

フィーチャビューの提供の詳細については、「フィーチャビューを提供する」を参照してください。

選択されたエンティティのマテリアル化された値を除去するには、エンティティの特徴量の値をパージを参照してください。

Requirements

フィーチャーはフィーチャービューとして作成し、Unity カタログに格納する必要があります。
バージョン要件については、「要件」を参照してください。

特徴タイプ別のマテリアライゼーションサポート

特徴がどこで具現化できるかは、そのタイプによって異なります。

ColumnSelection 機能は、オンラインストアに具体化できます。 ColumnSelection の具体化を参照してください。
RollingWindowを使った一括生産Last機能はオンラインストアに具現化可能です。「 Materialize」の鮮度制限の最新値をご参照ください。
RequestSource、 FeatureViewSource、および CustomUDF 特徴は物質化できません。オンデマンド機能とマテリアライズを参照してください。

オンラインストアにのみ現れる機能はオフラインでも使えます。 create_training_set と compute_features はソースから直接時点値を計算するため、オフラインのマテリアル化は不要です。

ColumnSelection の具体化

ColumnSelection 機能は、集計なしでエンティティキーごとに 1 つの列の最新の値を選択します。これらは、オンラインストアにのみ具体化できます。オフラインユースケース (トレーニングとバッチ推論) の場合、 ColumnSelection 機能はクエリ時にソースデータから直接フェッチされるため、オフライン具体化は必要ありません。

具体化の動作

パイプラインは、エンティティキーごとの最新の行を集計ウィンドウなしでオンラインテーブルに書き込みます。
オンラインマテリアライズにより、オンラインテーブルにエンティティキーごとの現在の最新の値が設定されます。

例

from databricks.feature_engineering import FeatureEngineeringClient
from databricks.feature_engineering.entities import (
    DeltaTableSource, Feature, ColumnSelection, TableTrigger, OnlineStoreConfig,
)

fe = FeatureEngineeringClient()

delta_source = DeltaTableSource(
    catalog_name="catalog",
    schema_name="schema",
    table_name="transactions",
)

amount_feature = Feature(
    source=delta_source,
    function=ColumnSelection("amount"),
    entity=["user_id"],
    timeseries_column="transaction_time",
    name="latest_transaction_amount",
)

# Register before materializing
amount_feature = fe.register_feature(
    feature=amount_feature,
    catalog_name="catalog",
    schema_name="schema",
)

mfs = fe.materialize_features(
    features=[amount_feature],
    online_config=OnlineStoreConfig(
        catalog_name="catalog",
        schema_name="feats_online",
        table_name_prefix="txn_",
        online_store_name="lb_usw2"
    ),
    trigger=TableTrigger(),
)

ColumnSelection 機能は、ソース Delta テーブルが新しいコミットを受信するたびにパイプラインを実行する TableTriggerを使用します。 offline_config機能はオフラインユースケース (トレーニングとバッチ推論) のためにソースから直接読み取われるため、ColumnSelectionは必要ありません。

Note

RequestSource 特徴は、推論時に呼び出し元によって提供されたデータ (またはトレーニング時にラベル付けされた DataFrame から抽出される) を表しているため、具体化できません。読み取り元のソーステーブルがありません。値は、要求ペイロードまたはトレーニング DataFrame にのみ存在します。

新鮮度に限定された最新値を具現化する

RollingWindowを使ったバッチLast集約は、オンライン機能にタイム・トゥ・ライブ(TTL)を与えます。すなわち、ソース値がウィンドウ内に収まらなければオンラインストアからその価値が切れます。これは、価値の年齢がその価値の安全性を決定する場合に有用です。例えば、直近1時間のデバイス状態を処理し、古い状態は無期限に利用可能ではなくnullに解決されます。

RollingWindowは、特徴にTTLに似た挙動を与える明示的な持続時間を定義します。例えば、ソースが毎日値を公開し、過去7日間の値だけを保持したい場合は、7日間の期間を持つ RollingWindow を使いましょう。各トリガーで、マテリアライゼーションはオンラインテーブルを完全に置き換え、ウィンドウ外の値は予測可能なスケジュールで削除されます。これにより、RollingWindowを使ったストリーミングLastと同じ結果が得られますが、計算を連続的に実行しないためコストが低くなります。

この公開パターンは、スナップショットモードで公開されるTTLを持つ特徴テーブルに似ています。もし特徴テーブルのセットを維持し、他の機能ビューと併用したい場合は、それらを特徴ビュー作成フレームワークに適応させることができます。 RollingWindowとTableTriggerを使ったバッチLastを使いましょう。

この組み合わせには、以下の要件を満たす特別なオンライン専用のママリゼーションモードがあります:

その源は DeltaTableSourceに違いない。
集約関数は Lastでなければならず、そのウィンドウは RollingWindowでなければなりません。
マテリアライゼーションは OnlineStoreConfigを提供し、 OfflineStoreConfigを省略し、 TableTriggerを使わなければなりません。

以下の例では、 latest_device_state_1h は以下の要件を満たす登録フィーチャーです。

from databricks.feature_engineering import FeatureEngineeringClient
from databricks.feature_engineering.entities import OnlineStoreConfig, TableTrigger

fe = FeatureEngineeringClient()

materialized = fe.materialize_features(
    features=[latest_device_state_1h],
    online_config=OnlineStoreConfig(
        catalog_name="main",
        schema_name="feature_store",
        table_name_prefix="latest_device_state_serving",
        online_store_name="device_state_store",
    ),
    trigger=TableTrigger(),
)

オフライントレーニングやバッチスコアリングの場合、フィーチャーエンジニアリングクライアントはソースから直接時点値を計算します。この機能のオフラインの物質化は読み取れません。

考慮事項

有効期限が更新されるのは、トリガーされた場合のみです。 ソーステーブルのコミットによってマテリアライゼーションのリフレッシュがトリガーされると、オンライン値は更新され、その有効期限は延長されます。時間の経過だけではリフレッシュは起こりません。ソースが公開を停止した場合、最後に物質化された値はオンラインストアに残り、後のコミットでリフレッシュが発生します。
タイムシリーズの列をソースの公開時間に合わせます。 時系列列は、データソースがデータを公開した時期を反映しなければなりません。そうでない場合、オンラインとオフラインの値は乖離します。これは、オンラインストアではトリガー時刻で結合される一方、オフラインでの読み取り時にはタイムシリーズ時刻で結合されるためです。
ウィンドウの持続時間を公開のリズムの倍数に設定してください。 RollingWindowの持続時間がソースの公開頻度の倍数でない場合、オフライントレーニング中にオンライン上でまだ表示されている値を有効期限とみなします。

オンデマンド機能とマテリアル化

RequestSource 値はトレーニング中のDataFrameや推論リクエストから来るため、ソーステーブルを生成できません。 FeatureViewSource 特徴量は、トレーニング中またはサービス提供中に、上流の特徴量に CustomUDF を適用します。事前に計算された結果を保存しません。 Deltaテーブルを基盤とする CustomUDF 機能でもマテリアライゼーションはサポートされていません。

revenue_sum_7dやcost_sum_7dのような依存グラフがmargin特徴に供給する場合:

オフライントレーニングの場合は、create_training_set を使用して margin を呼び出します。上流の特徴を解決し、利用可能な場合に互換性のあるオフラインマテリアライゼーションを用いて時点値を計算します。
オンラインサービスについては、サポートされた収益とコスト機能をオンラインストアに提供してください。エンドポイントはそれらを検索し、各リクエストごとに margin を計算します。
marginやリクエストバック機能ではなく、サポートされている上流機能のみをmaterialize_featuresに渡してください。物質化は派生した特徴の依存関係を再帰的に物質化するものではありません。

リクエストバック機能のみを使用するグラフはオンラインストアを必要としません。 FeatureViewSource 特徴量を使ってトレーニングするおよび導出特徴量を提供するを参照してください。

Permissions

マテリアライゼーションには、フィーチャーおよびソースおよびデスティネーションリソースに対する権限が必要です。 Unity Catalogの特権に関する詳細な説明については、 Unity Catalog Privileges referenceを参照してください。

フィーチャーを具体化するには、 MANAGEが必要です。 materialize_featuresを呼び出すことで、LakeflowパイプラインやUnity Catalogテーブルが作成され管理されるため、管理操作となります。機能にはMANAGEが必要です。さらに、具体化される機能定義を読むにはREAD FEATUREも必要です。
物質化された特徴の削除は、その作成者に限定されます。 マティビリズド機能を作成したユーザーだけが delete_materialized_featureで削除できます。この制限はUnityカタログの権限とは独立しており、機能や親スキーマの上 MANAGE は他のユーザーが削除できません。
ソースデータを読むには SELECTが必要です。 Deltaテーブルソースを使用する機能の場合、ソーステーブルに SELECT が必要です。 Stream ソースを使用する機能では、Stream の取り込みテーブルに SELECT が設定されている必要があります。

ストリームの認証設定に必要なその他の権限については、 Kafka認証を参照してください。
宛先テーブルの作成には CREATE TABLEが必要です。 OfflineStoreConfigまたはOnlineStoreConfigで指定されたすべてのスキーマにCREATE TABLEが必要です。オフラインとオンラインの宛先は異なるスキーマやカタログに存在し、マテリアライゼーションにはそれぞれの宛先に権限が必要です。
オンラインストアに出店するには、CAN USE が必要です。 オンラインストアで使われているLakebaseのインスタンスやプロジェクトに CAN USE がある必要があります。 Lakebaseの許可に関する情報は「助成プロジェクト許可」をご覧ください。
具象化された特徴をリストアップするには親の特徴 READ FEATURE が必要です。 list_materialized_featuresを使用するには、具体化された機能でREAD FEATUREを使用している必要があります。
具体化されたデータを読み取るには、 SELECTが必要です。 アクセスするすべてのオフラインまたはオンライン出力テーブルに SELECT が必要です。 READ FEATURE 親機能ではこれらのテーブルへのアクセスは許されません。

マテリアライゼーションに関わるUnityカタログリソースごとに、親カタログに USE CATALOG 、親スキーマにも USE SCHEMA が必要です。この要件は機能、各ソースまたはストリームの取り込みテーブル、そして設定された各宛先に適用されます。 READ FEATURE と MANAGE をスキーマまたはカタログに対して付与すると、その中に現在含まれるすべてのオブジェクトと今後含まれるすべてのオブジェクトに適用されます。

API データ構造

`OfflineStoreConfig`

具体化された機能が書き込まれるオフラインストアの構成。 materialize_featuresが呼び出されると、このプレフィックスを使用してフィーチャストアバックエンドによってテーブルが作成されます。各パイプライン実行では、具体化スケジュールに従って、最新の特徴値がテーブルに具体化されます。

OfflineStoreConfig(
    catalog_name: str,        # Catalog name for the offline table where materialized features will be stored
    schema_name: str,         # Schema name for the offline table
    table_name_prefix: str    # Table name prefix for the offline table. The pipeline may create multiple tables with this prefix, each updated at different cadences
)

from databricks.feature_engineering.entities import OfflineStoreConfig

offline_store = OfflineStoreConfig(
    catalog_name="main",
    schema_name="feature_store",
    table_name_prefix="customer_features"
)

`OnlineStoreConfig`

モデルサービスによって使用される機能を格納するオンラインストアの構成。具体化では、 catalog.schema.table_name_prefixを持つ Delta テーブルが作成され、同じ名前のオンラインフィーチャーストアにテーブルがストリーム配信されます。

from databricks.feature_engineering.entities import OnlineStoreConfig

online_store = OnlineStoreConfig(
    catalog_name="main",
    schema_name="feature_store",
    table_name_prefix="customer_features_serving",
    online_store_name="customer_features_store"
)

`MaterializedFeature`

具体化されたフィーチャービュー、つまり Unity カタログで使用可能な事前計算済みの表現を表します。オフラインテーブルとオンラインテーブルには、個別の具体化された機能があります。通常、ユーザーは MaterializedFeature を直接インスタンス化しません。

API 関数呼び出し

`materialize_features()`

フィーチャビューのリストをオフラインの Delta テーブルまたはオンラインフィーチャストアに具体化します。この関数を呼び出す前に、機能を Unity カタログに登録する必要があります (たとえば、 create_feature や register_featureを使用)。登録されていないローカルで構築された機能は機能しません。

FeatureEngineeringClient.materialize_features(
    *,                                                                     # Arguments are keyword-only
    features: List[Feature],                                               # List of Feature Views to materialize
    offline_config: Optional[OfflineStoreConfig] = None,                   # Offline store config (aggregation features only)
    online_config: Optional[OnlineStoreConfig] = None,                     # Online store config
    trigger: Union[CronSchedule, TableTrigger, StreamingMode],             # Materialization trigger
    tags: Optional[Dict[str, str]] = None,                                 # Custom tags for cost attribution
    budget_policy_id: Optional[str] = None,                                # Serverless usage policy for cost attribution
) -> List[MaterializedFeature]:

このメソッドは、マテリアライズド機能の一覧を返します。このリストには、機能値が更新されるタイミングに関するメタデータと、特徴が具体化される Unity カタログテーブルが含まれます。

OnlineStoreConfigとOfflineStoreConfigの両方が指定されている場合は、提供された機能ごとに 2 つの具体化された特徴が返されます。1 つはストアの種類ごとに 1 つです。

trigger パラメーターは、具体化パイプラインを実行するタイミングを制御します。

CronSchedule: 機能のタイミングに基づいて作成されたスケジュール、または呼び出し元が指定した Quartz の cron スケジュールで実行されます。バッチ集約機能(AggregationFunctionDeltaTableSource)に対応しています。
TableTrigger: アップストリームの Delta テーブルがコミットを受け取ったときに実行されます。 ColumnSelection機能および集約機能(AggregationFunction)をサポートし、DeltaTableSourceによって裏付けられています。アグリゲーション機能では、パイプラインは機能の粒度の半分(スライドウィンドウの場合はスライド時間、タンブリングウィンドウの場合はウィンドウ長)に最大1回しか動作せず、1時間に制限され、5分ごとに1回以上は動作しません。例えば、1時間の細かさなら最大30分に1回、2時間以上の細かい分量なら最大1時間に1回です。この間隔は前回の実行から測定されるため、経過後に到達したコミットでもすぐに実行が発生します。
StreamingMode: 継続的ストリーミングパイプラインとして実行されます。 StreamSourceによってサポートされる機能に必要です。

1 回の materialize_features 呼び出しで異なるトリガーの種類を必要とする機能を混在することはできません。代わりに個別の呼び出しを発行します。

マテリアライゼーションのコストを算出するには、 tags、 budget_policy_id、または両方をパスしてください。 Azure Databricksは作成したジョブやパイプラインにそれらを適用し、支出が請求可能使用システムテーブルにあなたの帰属を反映させます。どちらも創造時に適用されるため、既存の物質化を異なる形で帰属させることは新しい物質化を創造することを意味します。 budget_policy_id サーバーレス使用ポリシーのIDを取得します。作成してIDを取得するには、「サーバーレス使用ポリシーの作成」をご覧ください。タグの制限、各値が到達するリソース、そして帰属された支出の照会方法については、 Feature Storeのコスト管理を参照してください。

オフラインストアに具体化する

from databricks.feature_engineering import FeatureEngineeringClient
from databricks.feature_engineering.entities import (
    CronSchedule, OfflineStoreConfig,
)

fe = FeatureEngineeringClient()

materialized = fe.materialize_features(
    features=features,
    offline_config=OfflineStoreConfig(
        catalog_name="main",
        schema_name="feature_store",
        table_name_prefix="customer_features"
    ),
    trigger=CronSchedule(
        quartz_cron_expression="0 0 * * * ?",  # Hourly
        timezone_id="UTC",
    ),
)

オンラインストアに具体化する

Note

ほとんどの集約機能をオンラインストアに具現化するには、オフラインストアにもマシリングする必要があります。 offline_configとonline_configの両方が必要です。 online_store_nameは、既存のオンラインフィーチャストアを参照する必要があります。作成手順については、「 Databricks Online Feature Stores」を参照してください。

ColumnSelection 機能には OfflineStoreConfigは必要ありません。 ColumnSelection の具体化を参照してください。

特別ケース付きのバッチ・LastRollingWindowもオンラインのみです。「 Materialize」の鮮度制限の最新値をご参照ください。

from databricks.feature_engineering import FeatureEngineeringClient
from databricks.feature_engineering.entities import (
    CronSchedule, OfflineStoreConfig, OnlineStoreConfig,
)

fe = FeatureEngineeringClient()

materialized = fe.materialize_features(
    features=features,
    offline_config=OfflineStoreConfig(
        catalog_name="main",
        schema_name="feature_store",
        table_name_prefix="customer_features"
    ),
    online_config=OnlineStoreConfig(
        catalog_name="main",
        schema_name="feature_store",
        table_name_prefix="customer_features_serving",
        online_store_name="customer_features_store"
    ),
    trigger=CronSchedule(
        quartz_cron_expression="0 0 * * * ?",  # Hourly
        timezone_id="UTC",
    ),
)

ストリーミング機能を具体化する

ストリーミング機能は、オンラインストアにのみ具体化できます。 offline_config パラメーターはサポートされていません。ストリーミング機能では、サブ秒の鮮度を確保するためにリアルタイムパイプラインが必要であるため、オフライン具体化はサポートされていません。オフライントレーニングまたは評価の場合、特徴エンジニアリングクライアントは、評価された各データポイントに基づいて特徴の値を再計算します。

ストリーミング機能は、同じ materialize_features 呼び出しのバッチ機能と混在させることはできません。

from databricks.feature_engineering import FeatureEngineeringClient
from databricks.feature_engineering.entities import (
    OnlineStoreConfig, StreamingMode,
)

fe = FeatureEngineeringClient()

materialized = fe.materialize_features(
    features=[streaming_feature],
    online_config=OnlineStoreConfig(
        catalog_name="my_catalog",
        schema_name="my_schema",
        table_name_prefix="streaming_features_serving",
        online_store_name="feature_store_online"
    ),
    trigger=StreamingMode(),
)

`list_materialized_features()`

完全な名前で識別される 1 つの特徴の具体化を返します。 feature_name は必須であり、キーワードのみです。多くの機能の具体化を確認するには、まずカタログまたはスキーマ内の機能を一覧表示してから、返された各機能に対して list_materialized_features を呼び出します。

既定では、最大 100 個の具体化が返されます。この制限は、 max_results パラメーターを使用して変更できます。

FeatureEngineeringClient.list_materialized_features(
    *,                                      # Arguments are keyword-only
    feature_name: str,                      # Required: full name of the feature whose materializations to list
    max_results: int = 100,                 # Maximum number of materializations to return
) -> List[MaterializedFeature]:

`delete_materialized_feature()`

具体化されたフィーチャーを削除する前に、フィーチャーを参照するモデルまたはフィーチャースペックを削除または更新します。

具体化されたフィーチャーを削除します。どの機能を渡すかは、機能の種類によって決まります。

集計機能: オフラインマテリアライズド機能を渡します。同じ機能に対してオンラインで具体化された機能がある場合、両方が削除されます。 RollingWindow を持つオンライン専用のバッチ Last 特徴量については、オンラインのマテリアライズド特徴量を渡します。
ColumnSelection 機能: オンラインマテリアライズド機能を渡します。 ColumnSelection 機能はオンラインストアにのみ具体化されるため ( ColumnSelection の具体化を参照)、ペアのオフライン機能はありません。

具体化の一環として、特徴は効率を高めるデータソースと集計ウィンドウごとにグループ化されます。 ColumnSelection 機能には集計ウィンドウがないため、データソースによってのみグループ化されます。具体化パイプライン、オフラインテーブル、およびオンラインテーブルは、グループ化されたすべての機能が削除されるまで削除されません。グループ内の最後の具体化されたフィーチャーが削除されると、機能ストアは、バックグラウンドプロセスによる自動クリーンアップのために関連するリソースをスケジュールします。「バックグラウンドリソースのクリーンアップ」を参照してください。

具体化された機能をクリーンアップするには、その具体化された機能に関連付けられたテーブルを確認します。コンピューティングテーブルリソースと Delta テーブルリソースがクリーンアップされる前に、テーブル内の各機能 (列ごとに 1 つ) を削除する必要があります。

list_materialized_features()を使用して、materialized_feature引数を取得します。

FeatureEngineeringClient.delete_materialized_feature(
    materialized_feature: MaterializedFeature,  # Required: The materialized feature to delete
) -> None

from databricks.feature_engineering import FeatureEngineeringClient

fe = FeatureEngineeringClient()

feature_names = [
    "main.feature_store.amount_sum_sliding_7d_1d",
    "main.feature_store.amount_sum_sliding_30d_1d",
    "main.feature_store.transaction_count_sliding_7d_1d",
    "main.feature_store.latest_transaction_amount",
    "main.feature_store.latest_user_tier",
]

for name in feature_names:
    mfs = fe.list_materialized_features(feature_name=name)   # required, keyword-only
    offline = [mf for mf in mfs if not mf.is_online]
    for mf in (offline or mfs):
        fe.delete_materialized_feature(materialized_feature=mf)
    fe.delete_feature(full_name=name)

バックグラウンドリソースのクリーンアップ

具体化されたフィーチャーを削除すると、Databricks は機能メタデータを直ちに削除します。関連付けられているインフラストラクチャ (テーブル、パイプライン、ジョブ) は、バックグラウンドプロセスによって非同期的にクリーンアップされます。

複数の具体化されたフィーチャーが同じテーブルとパイプラインを共有できるため、これらの共有リソースは、それらを参照するすべての具体化されたフィーチャーが削除されるまで削除されません。テーブルのセットを共有する最後の具体化された機能が削除されると、バックグラウンドプロセスによって次のリソースが自動的に削除されます。

具体化された特徴データを含むオフラインの Delta テーブル
オンラインテーブル (機能がオンラインストアに具体化された場合)
マテリアライズパイプライン
オーケストレーションジョブ

このバックグラウンドプロセスでは、Databricks で管理されるシステムサービスプリンシパルを使用して、ワークスペース内のテーブル、パイプライン、ジョブの削除など、これらのクリーンアップアクションをユーザーに代わって実行します。ユーザーからの操作は必要ありません。クリーンアップは、機能ストアによって完全に管理されます。

Note

グループ内の最後の具体化されたフィーチャーを削除してから、関連付けられているテーブルやその他のリソースを削除するまでに、少し時間がかかる場合があります。

マテリアライズのステータスを表示

Databricks UIでフィーチャービューのマテリアル化状態を確認し、マテリアル化エラーをデバッグするには、 Unity CatalogのExplore Feature Viewをご覧ください。

制限事項

バッチ機能

バッチ具体化パイプラインは、サーバーレスの Lakeflow パイプラインとして実行されます。
バッチのローリングウィンドウ機能は、鮮度制約付きの最新値をマテリアライズするで説明されている、オンライン専用のLast特別なケースを除き、マテリアライズできません。オフライントレーニングやバッチ推論では、各ポイントインタイムルックアップのソースデータからローリングウィンドウ特徴量が計算されます。
ColumnSelection 機能は、オンラインストアにのみ具体化できます。
RequestSource、 FeatureViewSource、および CustomUDF 特徴は物質化できません。オンデマンド機能とマテリアライズを参照してください。
具体化された機能は、作成されたワークスペースでのみ削除できます。
マテリアライズドフィーチャーを削除できるのは、そのフィーチャーまたはその親スキーマに対する Unity Catalog の権限の有無にかかわらず、それを作成したユーザーのみです。
具体化された集計機能の場合、オンラインマテリアライズドフィーチャーを直接削除することはできません。ペアになったオフラインマテリアライズドフィーチャーを削除すると、変更が両方に反映されます。
2026 年 4 月 20 日より前に作成された具体化された集計機能の場合、具体化パイプラインでは、パイプライン内のすべての具体化された特徴が削除されるまで新しい特徴値の生成が続行され、リソースのクリーンアップがトリガーされます。機能ごとの削除をサポートする更新されたパイプラインを作成するには、機能を削除して再具体化します。
具体化された ColumnSelection 機能の場合、具体化パイプラインは、パイプライン内のすべての具体化された特徴が削除されるまで新しい機能値の生成を続け、リソースのクリーンアップをトリガーします。

ストリーミング機能

ストリーミング機能は、オンラインストアにのみ具体化できます。トレーニング時のストリーミング機能は、ミリ秒レベルの精度を提供するために、データポイントごとの履歴イベントから再計算されるように設計されているため、オフライン具体化は必要ありません。
ストリーミング機能は、1 回の materialize_features 呼び出しでバッチ機能と混在させることはできません。
compute_features はストリーミング機能をサポートしていません。
ワークスペースは、Lakebase インスタンスをサポートするリージョンに存在する必要があります。
JSON でシリアル化された Kafka メッセージのみがサポートされます。メッセージスキーマは、JSON スキーマ形式で直接指定する必要があります。スキーマレジストリ (Confluent、Glue) は、プレビュー期間中は正式にはサポートされていませんが、スキーマを直接指定すると、パイプラインはスキーマレジストリによって管理されるトピックから読み取ることができます。
ストリーミング集計機能では、 RollingWindow のみがサポートされています。 TumblingWindow と SlidingWindow をバッチ機能と共に使用する必要があります。
ストリーミング機能には、 Count、 Avg、 Sum、 StddevPop、 Max、 Min、 First、 Last、 FirstN、 LastN、 FirstDistinct、 LastDistinct アグリゲーション機能のみがサポートされています。
ストリーミングソースからの列選択機能では、順序が異なったメッセージは処理されません。時系列列の値が以前に受信したイベントよりも前の場合でも、Kafka ストリームの最新のイベントが表示されます。
ストリーミングパイプラインは週に 2 回再起動されます。再起動するたびに、処理の遅延と起動時間が最大 1 分発生する可能性があります。再起動を除き、p99 の鮮度は 200 ミリ秒です。
マテリアライズに対するバックフィル機能はサポートされていません。フィーチャーがマテリアライズされると、その時点以降について計算されます。オンラインストアで新しく作成された集計は、時間枠が過ぎるまで不正確です。
Databricks Online Feature Store のみがサポートされています。
ストリーミング具体化パイプラインは、サーバーレスの Lakeflow パイプラインとして実行されます。
エンタープライズ層ワークスペースのみ。

フィードバック

このページはお役に立ちましたか?

最終更新: 2026-10-07

フィーチャ ビューを具体化する

Requirements

特徴タイプ別のマテリアライゼーションサポート

ColumnSelection の具体化

具体化の動作

例

新鮮度に限定された最新値を具現化する

考慮事項

オンデマンド機能とマテリアル化

Permissions

API データ構造

OfflineStoreConfig

OnlineStoreConfig

MaterializedFeature

API 関数呼び出し

materialize_features()

オフライン ストアに具体化する

オンライン ストアに具体化する

ストリーミング機能を具体化する

list_materialized_features()

delete_materialized_feature()

バックグラウンド リソースのクリーンアップ

マテリアライズのステータスを表示

制限事項

バッチ機能

ストリーミング機能

フィードバック

その他のリソース

フィーチャビューを具体化する

`OfflineStoreConfig`

`OnlineStoreConfig`

`MaterializedFeature`

`materialize_features()`

オフラインストアに具体化する

オンラインストアに具体化する

`list_materialized_features()`

`delete_materialized_feature()`

バックグラウンドリソースのクリーンアップ