Materialized View Info

class databricks.ml_features.entities.materialized_view_info.MaterializedViewInfo(*, pipeline_id: str, pipeline_name: str)

Bases: _FeatureStoreObject

Information about a materialized view.

Parameters

  • pipeline_id – The ID for the pipeline.

  • pipeline_name – The name of the pipeline.

__init__(*, pipeline_id: str, pipeline_name: str)

Initialize a MaterializedViewInfo object. See class documentation.

property pipeline_id: str

The ID for the pipeline.

property pipeline_name: str

The name of the pipeline.

Cron Schedule

class databricks.ml_features.entities.cron_schedule.CronSchedule(*, quartz_cron_expression: Optional[str] = None, timezone_id: Optional[str] = None, mode: Optional[CronScheduleMode] = None, pipeline_schedule_state: MaterializedFeaturePipelineScheduleState = MaterializedFeaturePipelineScheduleState.ACTIVE)

Bases: _FeatureStoreObject, Trigger

Defines a cron-based trigger for feature materialization.

CronSchedule() is the recommended schedule for aggregation features.

Parameters

  • quartz_cron_expression – The cron expression to use for a MANUAL request. Omit it for a DERIVED request. A schedule returned by the API may contain a service-computed expression in DERIVED mode. See http://www.quartz-scheduler.org/documentation/quartz-2.3.0/tutorials/crontrigger.html

  • timezone_id – A Java timezone ID for a manual schedule. This is incompatible with DERIVED mode. If not provided, UTC will be used. See https://docs.oracle.com/javase/7/docs/api/java/util/TimeZone.html

  • mode – How the schedule is determined. When omitted, the mode is DERIVED if no cron expression is provided and MANUAL otherwise. DERIVED computes the schedule from the aggregation window duration, window delay and offset, and source settling delay.

  • pipeline_schedule_state – The pipeline schedule state for this trigger (e.g. ACTIVE).

__init__(*, quartz_cron_expression: Optional[str] = None, timezone_id: Optional[str] = None, mode: Optional[CronScheduleMode] = None, pipeline_schedule_state: MaterializedFeaturePipelineScheduleState = MaterializedFeaturePipelineScheduleState.ACTIVE)

Initialize a CronSchedule object. See class documentation.

property quartz_cron_expression: Optional[str]

The cron expression to use.

property timezone_id: str

A Java timezone ID. The schedule for a job is resolved with respect to this timezone. See Java TimeZone for details.

property mode: Optional[CronScheduleMode]

How the schedule is determined.