Class FeaturestoreServiceGrpc.FeaturestoreServiceImplBase (3.5.0)

Version 3.5.0

• 3.52.0 (latest)
• 3.50.0
• 3.49.0
• 3.48.0
• 3.47.0
• 3.46.0
• 3.45.0
• 3.44.0
• 3.43.0
• 3.42.0
• 3.41.0
• 3.40.0
• 3.38.0
• 3.37.0
• 3.36.0
• 3.35.0
• 3.34.0
• 3.33.0
• 3.32.0
• 3.31.0
• 3.30.0
• 3.29.0
• 3.28.0
• 3.25.0
• 3.24.0
• 3.23.0
• 3.22.0
• 3.21.0
• 3.20.0
• 3.19.0
• 3.18.0
• 3.17.0
• 3.16.0
• 3.15.0
• 3.14.0
• 3.13.0
• 3.12.0
• 3.11.0
• 3.10.0
• 3.9.0
• 3.8.0
• 3.7.0
• 3.6.0
• 3.5.0
• 3.4.2
• 3.3.0
• 3.2.0
• 3.0.0
• 2.9.8
• 2.8.9
• 2.7.4
• 2.5.3
• 2.4.0

public abstract static class FeaturestoreServiceGrpc.FeaturestoreServiceImplBase implements BindableService

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

Inheritance

java.lang.Object > FeaturestoreServiceGrpc.FeaturestoreServiceImplBase

Implements

io.grpc.BindableService

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

FeaturestoreServiceImplBase()

public FeaturestoreServiceImplBase()

Methods

batchCreateFeatures(BatchCreateFeaturesRequest request, StreamObserver<Operation> responseObserver)

public void batchCreateFeatures(BatchCreateFeaturesRequest request, StreamObserver<Operation> 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<Operation> responseObserver)

public 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

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

bindService()

public final ServerServiceDefinition bindService()

Returns

Type	Description
io.grpc.ServerServiceDefinition

createEntityType(CreateEntityTypeRequest request, StreamObserver<Operation> responseObserver)

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

Creates a new EntityType in a given Featurestore.

Parameters

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

createFeature(CreateFeatureRequest request, StreamObserver<Operation> responseObserver)

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

Creates a new Feature in a given EntityType.

Parameters

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

createFeaturestore(CreateFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

public void createFeaturestore(CreateFeaturestoreRequest request, StreamObserver<Operation> 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<Operation> responseObserver)

public 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

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

deleteFeature(DeleteFeatureRequest request, StreamObserver<Operation> responseObserver)

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

Deletes a single Feature.

Parameters

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

deleteFeatureValues(DeleteFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

public 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

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

deleteFeaturestore(DeleteFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

public 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

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

exportFeatureValues(ExportFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

public void exportFeatureValues(ExportFeatureValuesRequest request, StreamObserver<Operation> 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<EntityType> responseObserver)

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

Gets details of a single EntityType.

Parameters

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

getFeature(GetFeatureRequest request, StreamObserver<Feature> responseObserver)

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

Gets details of a single Feature.

Parameters

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

getFeaturestore(GetFeaturestoreRequest request, StreamObserver<Featurestore> responseObserver)

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

Gets details of a single Featurestore.

Parameters

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

importFeatureValues(ImportFeatureValuesRequest request, StreamObserver<Operation> responseObserver)

public 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

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

listEntityTypes(ListEntityTypesRequest request, StreamObserver<ListEntityTypesResponse> responseObserver)

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

Lists EntityTypes in a given Featurestore.

Parameters

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

listFeatures(ListFeaturesRequest request, StreamObserver<ListFeaturesResponse> responseObserver)

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

Lists Features in a given EntityType.

Parameters

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

listFeaturestores(ListFeaturestoresRequest request, StreamObserver<ListFeaturestoresResponse> responseObserver)

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

Lists Featurestores in a given project and location.

Parameters

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

searchFeatures(SearchFeaturesRequest request, StreamObserver<SearchFeaturesResponse> responseObserver)

public void searchFeatures(SearchFeaturesRequest request, StreamObserver<SearchFeaturesResponse> 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<EntityType> responseObserver)

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

Updates the parameters of a single EntityType.

Parameters

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

updateFeature(UpdateFeatureRequest request, StreamObserver<Feature> responseObserver)

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

Updates the parameters of a single Feature.

Parameters

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

updateFeaturestore(UpdateFeaturestoreRequest request, StreamObserver<Operation> responseObserver)

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

Updates the parameters of a single Featurestore.

Parameters

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