Interface FeaturestoreServiceGrpc.AsyncService (3.64.0)

public static interface FeaturestoreServiceGrpc.AsyncService

The service that handles CRUD and List for resources for Featurestore.

Methods

batchCreateFeatures(BatchCreateFeaturesRequest request, StreamObserver responseObserver)

public default void batchCreateFeatures(BatchCreateFeaturesRequest request, StreamObserver responseObserver)

Creates a batch of Features in a given EntityType.

Parameters
Name Description
request BatchCreateFeaturesRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

batchReadFeatureValues(BatchReadFeatureValuesRequest request, StreamObserver responseObserver)

public default void batchReadFeatureValues(BatchReadFeatureValuesRequest request, StreamObserver responseObserver)

Batch reads Feature values from a Featurestore. This API enables batch reading Feature values, where each read instance in the batch may read Feature values of entities from one or more EntityTypes. Point-in-time correctness is guaranteed for Feature values of each read instance as of each instance's read timestamp.

Parameters
Name Description
request BatchReadFeatureValuesRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

createEntityType(CreateEntityTypeRequest request, StreamObserver responseObserver)

public default void createEntityType(CreateEntityTypeRequest request, StreamObserver responseObserver)

Creates a new EntityType in a given Featurestore.

Parameters
Name Description
request CreateEntityTypeRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

createFeature(CreateFeatureRequest request, StreamObserver responseObserver)

public default void createFeature(CreateFeatureRequest request, StreamObserver responseObserver)

Creates a new Feature in a given EntityType.

Parameters
Name Description
request CreateFeatureRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

createFeaturestore(CreateFeaturestoreRequest request, StreamObserver responseObserver)

public default void createFeaturestore(CreateFeaturestoreRequest request, StreamObserver responseObserver)

Creates a new Featurestore in a given project and location.

Parameters
Name Description
request CreateFeaturestoreRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

deleteEntityType(DeleteEntityTypeRequest request, StreamObserver responseObserver)

public default void deleteEntityType(DeleteEntityTypeRequest request, StreamObserver responseObserver)

Deletes a single EntityType. The EntityType must not have any Features or force must be set to true for the request to succeed.

Parameters
Name Description
request DeleteEntityTypeRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

deleteFeature(DeleteFeatureRequest request, StreamObserver responseObserver)

public default void deleteFeature(DeleteFeatureRequest request, StreamObserver responseObserver)

Deletes a single Feature.

Parameters
Name Description
request DeleteFeatureRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

deleteFeatureValues(DeleteFeatureValuesRequest request, StreamObserver responseObserver)

public default void deleteFeatureValues(DeleteFeatureValuesRequest request, StreamObserver responseObserver)

Delete Feature values from Featurestore. The progress of the deletion is tracked by the returned operation. The deleted feature values are guaranteed to be invisible to subsequent read operations after the operation is marked as successfully done. If a delete feature values operation fails, the feature values returned from reads and exports may be inconsistent. If consistency is required, the caller must retry the same delete request again and wait till the new operation returned is marked as successfully done.

Parameters
Name Description
request DeleteFeatureValuesRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

deleteFeaturestore(DeleteFeaturestoreRequest request, StreamObserver responseObserver)

public default void deleteFeaturestore(DeleteFeaturestoreRequest request, StreamObserver responseObserver)

Deletes a single Featurestore. The Featurestore must not contain any EntityTypes or force must be set to true for the request to succeed.

Parameters
Name Description
request DeleteFeaturestoreRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

exportFeatureValues(ExportFeatureValuesRequest request, StreamObserver responseObserver)

public default void exportFeatureValues(ExportFeatureValuesRequest request, StreamObserver responseObserver)

Exports Feature values from all the entities of a target EntityType.

Parameters
Name Description
request ExportFeatureValuesRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

getEntityType(GetEntityTypeRequest request, StreamObserver responseObserver)

public default void getEntityType(GetEntityTypeRequest request, StreamObserver responseObserver)

Gets details of a single EntityType.

Parameters
Name Description
request GetEntityTypeRequest
responseObserver io.grpc.stub.StreamObserver<EntityType>

getFeature(GetFeatureRequest request, StreamObserver responseObserver)

public default void getFeature(GetFeatureRequest request, StreamObserver responseObserver)

Gets details of a single Feature.

Parameters
Name Description
request GetFeatureRequest
responseObserver io.grpc.stub.StreamObserver<Feature>

getFeaturestore(GetFeaturestoreRequest request, StreamObserver responseObserver)

public default void getFeaturestore(GetFeaturestoreRequest request, StreamObserver responseObserver)

Gets details of a single Featurestore.

Parameters
Name Description
request GetFeaturestoreRequest
responseObserver io.grpc.stub.StreamObserver<Featurestore>

importFeatureValues(ImportFeatureValuesRequest request, StreamObserver responseObserver)

public default void importFeatureValues(ImportFeatureValuesRequest request, StreamObserver responseObserver)

Imports Feature values into the Featurestore from a source storage. The progress of the import is tracked by the returned operation. The imported features are guaranteed to be visible to subsequent read operations after the operation is marked as successfully done. If an import operation fails, the Feature values returned from reads and exports may be inconsistent. If consistency is required, the caller must retry the same import request again and wait till the new operation returned is marked as successfully done. There are also scenarios where the caller can cause inconsistency.

  • Source data for import contains multiple distinct Feature values for the same entity ID and timestamp.
  • Source is modified during an import. This includes adding, updating, or removing source data and/or metadata. Examples of updating metadata include but are not limited to changing storage location, storage class, or retention policy.
  • Online serving cluster is under-provisioned.
Parameters
Name Description
request ImportFeatureValuesRequest
responseObserver io.grpc.stub.StreamObserver<Operation>

listEntityTypes(ListEntityTypesRequest request, StreamObserver responseObserver)

public default void listEntityTypes(ListEntityTypesRequest request, StreamObserver responseObserver)

Lists EntityTypes in a given Featurestore.

Parameters
Name Description
request ListEntityTypesRequest
responseObserver io.grpc.stub.StreamObserver<ListEntityTypesResponse>

listFeatures(ListFeaturesRequest request, StreamObserver responseObserver)

public default void listFeatures(ListFeaturesRequest request, StreamObserver responseObserver)

Lists Features in a given EntityType.

Parameters
Name Description
request ListFeaturesRequest
responseObserver io.grpc.stub.StreamObserver<ListFeaturesResponse>

listFeaturestores(ListFeaturestoresRequest request, StreamObserver responseObserver)

public default void listFeaturestores(ListFeaturestoresRequest request, StreamObserver responseObserver)

Lists Featurestores in a given project and location.

Parameters
Name Description
request ListFeaturestoresRequest
responseObserver io.grpc.stub.StreamObserver<ListFeaturestoresResponse>

searchFeatures(SearchFeaturesRequest request, StreamObserver responseObserver)

public default void searchFeatures(SearchFeaturesRequest request, StreamObserver responseObserver)

Searches Features matching a query in a given project.

Parameters
Name Description
request SearchFeaturesRequest
responseObserver io.grpc.stub.StreamObserver<SearchFeaturesResponse>

updateEntityType(UpdateEntityTypeRequest request, StreamObserver responseObserver)

public default void updateEntityType(UpdateEntityTypeRequest request, StreamObserver responseObserver)

Updates the parameters of a single EntityType.

Parameters
Name Description
request UpdateEntityTypeRequest
responseObserver io.grpc.stub.StreamObserver<EntityType>

updateFeature(UpdateFeatureRequest request, StreamObserver responseObserver)

public default void updateFeature(UpdateFeatureRequest request, StreamObserver responseObserver)

Updates the parameters of a single Feature.

Parameters
Name Description
request UpdateFeatureRequest
responseObserver io.grpc.stub.StreamObserver<Feature>

updateFeaturestore(UpdateFeaturestoreRequest request, StreamObserver responseObserver)

public default void updateFeaturestore(UpdateFeaturestoreRequest request, StreamObserver responseObserver)

Updates the parameters of a single Featurestore.

Parameters
Name Description
request UpdateFeaturestoreRequest
responseObserver io.grpc.stub.StreamObserver<Operation>