Interface FeaturestoreServiceGrpc.AsyncService (3.22.0)

public static interface FeaturestoreServiceGrpc.AsyncService

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

Methods

batchCreateFeatures(BatchCreateFeaturesRequest request, StreamObserver<Operation> responseObserver)

public default void batchCreateFeatures(BatchCreateFeaturesRequest request, StreamObserver<Operation> responseObserver)

Creates a batch of Features in a given EntityType.

Parameters
NameDescription
requestBatchCreateFeaturesRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

batchReadFeatureValues(BatchReadFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

public default void batchReadFeatureValues(BatchReadFeatureValuesRequest request, StreamObserver<Operation> 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
NameDescription
requestBatchReadFeatureValuesRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

createEntityType(CreateEntityTypeRequest request, StreamObserver<Operation> responseObserver)

public default void createEntityType(CreateEntityTypeRequest request, StreamObserver<Operation> responseObserver)

Creates a new EntityType in a given Featurestore.

Parameters
NameDescription
requestCreateEntityTypeRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

createFeature(CreateFeatureRequest request, StreamObserver<Operation> responseObserver)

public default void createFeature(CreateFeatureRequest request, StreamObserver<Operation> responseObserver)

Creates a new Feature in a given EntityType.

Parameters
NameDescription
requestCreateFeatureRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

createFeaturestore(CreateFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

public default void createFeaturestore(CreateFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

Creates a new Featurestore in a given project and location.

Parameters
NameDescription
requestCreateFeaturestoreRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteEntityType(DeleteEntityTypeRequest request, StreamObserver<Operation> responseObserver)

public default void deleteEntityType(DeleteEntityTypeRequest request, StreamObserver<Operation> 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
NameDescription
requestDeleteEntityTypeRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteFeature(DeleteFeatureRequest request, StreamObserver<Operation> responseObserver)

public default void deleteFeature(DeleteFeatureRequest request, StreamObserver<Operation> responseObserver)

Deletes a single Feature.

Parameters
NameDescription
requestDeleteFeatureRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteFeatureValues(DeleteFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

public default void deleteFeatureValues(DeleteFeatureValuesRequest request, StreamObserver<Operation> 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
NameDescription
requestDeleteFeatureValuesRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteFeaturestore(DeleteFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

public default void deleteFeaturestore(DeleteFeaturestoreRequest request, StreamObserver<Operation> 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
NameDescription
requestDeleteFeaturestoreRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

exportFeatureValues(ExportFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

public default void exportFeatureValues(ExportFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

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

Parameters
NameDescription
requestExportFeatureValuesRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

getEntityType(GetEntityTypeRequest request, StreamObserver<EntityType> responseObserver)

public default void getEntityType(GetEntityTypeRequest request, StreamObserver<EntityType> responseObserver)

Gets details of a single EntityType.

Parameters
NameDescription
requestGetEntityTypeRequest
responseObserverio.grpc.stub.StreamObserver<EntityType>

getFeature(GetFeatureRequest request, StreamObserver<Feature> responseObserver)

public default void getFeature(GetFeatureRequest request, StreamObserver<Feature> responseObserver)

Gets details of a single Feature.

Parameters
NameDescription
requestGetFeatureRequest
responseObserverio.grpc.stub.StreamObserver<Feature>

getFeaturestore(GetFeaturestoreRequest request, StreamObserver<Featurestore> responseObserver)

public default void getFeaturestore(GetFeaturestoreRequest request, StreamObserver<Featurestore> responseObserver)

Gets details of a single Featurestore.

Parameters
NameDescription
requestGetFeaturestoreRequest
responseObserverio.grpc.stub.StreamObserver<Featurestore>

importFeatureValues(ImportFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

public default void importFeatureValues(ImportFeatureValuesRequest request, StreamObserver<Operation> 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
NameDescription
requestImportFeatureValuesRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

listEntityTypes(ListEntityTypesRequest request, StreamObserver<ListEntityTypesResponse> responseObserver)

public default void listEntityTypes(ListEntityTypesRequest request, StreamObserver<ListEntityTypesResponse> responseObserver)

Lists EntityTypes in a given Featurestore.

Parameters
NameDescription
requestListEntityTypesRequest
responseObserverio.grpc.stub.StreamObserver<ListEntityTypesResponse>

listFeatures(ListFeaturesRequest request, StreamObserver<ListFeaturesResponse> responseObserver)

public default void listFeatures(ListFeaturesRequest request, StreamObserver<ListFeaturesResponse> responseObserver)

Lists Features in a given EntityType.

Parameters
NameDescription
requestListFeaturesRequest
responseObserverio.grpc.stub.StreamObserver<ListFeaturesResponse>

listFeaturestores(ListFeaturestoresRequest request, StreamObserver<ListFeaturestoresResponse> responseObserver)

public default void listFeaturestores(ListFeaturestoresRequest request, StreamObserver<ListFeaturestoresResponse> responseObserver)

Lists Featurestores in a given project and location.

Parameters
NameDescription
requestListFeaturestoresRequest
responseObserverio.grpc.stub.StreamObserver<ListFeaturestoresResponse>

searchFeatures(SearchFeaturesRequest request, StreamObserver<SearchFeaturesResponse> responseObserver)

public default void searchFeatures(SearchFeaturesRequest request, StreamObserver<SearchFeaturesResponse> responseObserver)

Searches Features matching a query in a given project.

Parameters
NameDescription
requestSearchFeaturesRequest
responseObserverio.grpc.stub.StreamObserver<SearchFeaturesResponse>

updateEntityType(UpdateEntityTypeRequest request, StreamObserver<EntityType> responseObserver)

public default void updateEntityType(UpdateEntityTypeRequest request, StreamObserver<EntityType> responseObserver)

Updates the parameters of a single EntityType.

Parameters
NameDescription
requestUpdateEntityTypeRequest
responseObserverio.grpc.stub.StreamObserver<EntityType>

updateFeature(UpdateFeatureRequest request, StreamObserver<Feature> responseObserver)

public default void updateFeature(UpdateFeatureRequest request, StreamObserver<Feature> responseObserver)

Updates the parameters of a single Feature.

Parameters
NameDescription
requestUpdateFeatureRequest
responseObserverio.grpc.stub.StreamObserver<Feature>

updateFeaturestore(UpdateFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

public default void updateFeaturestore(UpdateFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

Updates the parameters of a single Featurestore.

Parameters
NameDescription
requestUpdateFeaturestoreRequest
responseObserverio.grpc.stub.StreamObserver<Operation>