Class FeaturesClient

Backfill features.

Batch create materialized features.

Create a Feature.

Create a feature spec.

Create a Kafka config. During PrPr, Kafka configs can be read and used when creating features under the entire metastore. Only the creator of the Kafka config can delete it.

Create a materialization set.

Create a materialized feature.

Create a Stream, a governed UC entity representing an external streaming data source.

Delete a Feature.

Delete a feature spec.

Delete a Kafka config. During PrPr, Kafka configs can be read and used when creating features under the entire metastore. Only the creator of the Kafka config can delete it.

Delete a materialization set and every materialized feature in it. The set is gone afterwards, so a later read returns NOT_FOUND and the set id is free to use again.

Delete a materialized feature.

Delete a Stream by its full three-part name (catalog.schema.stream).

Get a Feature.

Get a feature spec.

Get a Kafka config. During PrPr, Kafka configs can be read and used when creating features under the entire metastore. Only the creator of the Kafka config can delete it.

Get a materialization set and the materialized features in it. A set whose materialized feature members have all been deleted is returned with an empty member list.

Get a materialized feature.

Get a Stream by its full three-part name (catalog.schema.stream).

List Features.

List Kafka configs. During PrPr, Kafka configs can be read and used when creating features under the entire metastore. Only the creator of the Kafka config can delete it.

List materialized features.

List Streams under a given catalog.schema parent.

Purge materialized feature values for specified entities.

Requests materialization of all members of the set. The set must be nonempty and contain only batch materializations. Runs are allowed while automatic scheduling is paused. Requested runs may wait in a queue, subject to queue limits and expiry.

Returns a long-running operation that completes when every requested run reaches a terminal state. Success requires all runs and any required online synchronization to succeed. Individual outcomes are available in MaterializationSetTriggerProgress.

Use CancelOperation to request cancellation of this operation's unfinished work. Cancellation is best effort and does not undo completed writes. Online synchronization already in progress may continue.

Runs use the features' configured windows and settling delay.

Update a Feature.

Update a Kafka config. During PrPr, Kafka configs can be read and used when creating features under the entire metastore. Only the creator of the Kafka config can delete it.

Updates a materialization set. Supports changing pause settings and deleting materialized features from the set.

Changes are not atomic. Some updates or deletions may succeed even if the operation fails. Individual outcomes are available in MaterializationSetUpdateProgress.

Updates a materialized feature.

Update a Stream. Only fields listed in update_mask are mutated.