class Materialization

A handle to a server-side materialization (replay) job, which enriches a Timeline (or set of Timelines) by running it (them) through a given Topology.

Objects are not constructed directly. Materializations are returned by methods of the Client class.

Attributes

branch: str property

Topology branch used for materialization.

event_types: list[str] property

Materialized event types

hash: str property

Unique hash identifying the job.

path: str property

S3 bucket path where results are stored.

timeline_keys: list[str] property

Timeline keys for each feature to support querying from cache

timelines: list[str] property

Timelines materialized by the job.

Functions

get_errors(event_type, features=[])

Return event-level materialization errors for specified event type. Waits if job is still processing.

Parameters:

Name	Type	Description	Default
event_type	str	Name of event type to fetch.	required
features	list[str]	Feature names to fetch. By default, fetch all.	[]

Returns:

Type	Description
DataFrame	Event-level errors

get_features(event_type, features=[])

Return feature values for given event type. Waits if job is still processing.

Parameters:

Name	Type	Description	Default
event_type	str	Name of event type to fetch.	required
features	list[str]	Feature names to fetch. By default, fetch all.	[]

Returns:

Type	Description
DataFrame	Feature dataframe

progress()

Current progress of subjobs: X of Y jobs completed.

status()

Current status of the job. One of {'processing', 'materialized', 'error'}

wait()

Wait until materialization completes. In a Notebook, a progress bar is displayed.

Returns:

Type	Description
str	Materialization status