Class FeaturestoreServiceGrpc.FeaturestoreServiceFutureStub (3.54.0)

Version latest

• 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 static final class FeaturestoreServiceGrpc.FeaturestoreServiceFutureStub extends AbstractFutureStub<FeaturestoreServiceGrpc.FeaturestoreServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service FeaturestoreService.

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

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractFutureStub > FeaturestoreServiceGrpc.FeaturestoreServiceFutureStub

Inherited Members

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withOnReadyThreshold(int)

io.grpc.stub.AbstractStub.withWaitForReady()

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)

Methods

batchCreateFeatures(BatchCreateFeaturesRequest request)

public ListenableFuture<Operation> batchCreateFeatures(BatchCreateFeaturesRequest request)

Creates a batch of Features in a given EntityType.

Parameter
Name	Description
request	BatchCreateFeaturesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

batchReadFeatureValues(BatchReadFeatureValuesRequest request)

public ListenableFuture<Operation> batchReadFeatureValues(BatchReadFeatureValuesRequest request)

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.

Parameter
Name	Description
request	BatchReadFeatureValuesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

build(Channel channel, CallOptions callOptions)

protected FeaturestoreServiceGrpc.FeaturestoreServiceFutureStub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
channel	io.grpc.Channel
callOptions	io.grpc.CallOptions

Returns
Type	Description
FeaturestoreServiceGrpc.FeaturestoreServiceFutureStub

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createEntityType(CreateEntityTypeRequest request)

public ListenableFuture<Operation> createEntityType(CreateEntityTypeRequest request)

Creates a new EntityType in a given Featurestore.

Parameter
Name	Description
request	CreateEntityTypeRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

createFeature(CreateFeatureRequest request)

public ListenableFuture<Operation> createFeature(CreateFeatureRequest request)

Creates a new Feature in a given EntityType.

Parameter
Name	Description
request	CreateFeatureRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

createFeaturestore(CreateFeaturestoreRequest request)

public ListenableFuture<Operation> createFeaturestore(CreateFeaturestoreRequest request)

Creates a new Featurestore in a given project and location.

Parameter
Name	Description
request	CreateFeaturestoreRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

deleteEntityType(DeleteEntityTypeRequest request)

public ListenableFuture<Operation> deleteEntityType(DeleteEntityTypeRequest request)

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

Parameter
Name	Description
request	DeleteEntityTypeRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

deleteFeature(DeleteFeatureRequest request)

public ListenableFuture<Operation> deleteFeature(DeleteFeatureRequest request)

Deletes a single Feature.

Parameter
Name	Description
request	DeleteFeatureRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

deleteFeatureValues(DeleteFeatureValuesRequest request)

public ListenableFuture<Operation> deleteFeatureValues(DeleteFeatureValuesRequest request)

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.

Parameter
Name	Description
request	DeleteFeatureValuesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

deleteFeaturestore(DeleteFeaturestoreRequest request)

public ListenableFuture<Operation> deleteFeaturestore(DeleteFeaturestoreRequest request)

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

Parameter
Name	Description
request	DeleteFeaturestoreRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

exportFeatureValues(ExportFeatureValuesRequest request)

public ListenableFuture<Operation> exportFeatureValues(ExportFeatureValuesRequest request)

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

Parameter
Name	Description
request	ExportFeatureValuesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

getEntityType(GetEntityTypeRequest request)

public ListenableFuture<EntityType> getEntityType(GetEntityTypeRequest request)

Gets details of a single EntityType.

Parameter
Name	Description
request	GetEntityTypeRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<EntityType>

getFeature(GetFeatureRequest request)

public ListenableFuture<Feature> getFeature(GetFeatureRequest request)

Gets details of a single Feature.

Parameter
Name	Description
request	GetFeatureRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Feature>

getFeaturestore(GetFeaturestoreRequest request)

public ListenableFuture<Featurestore> getFeaturestore(GetFeaturestoreRequest request)

Gets details of a single Featurestore.

Parameter
Name	Description
request	GetFeaturestoreRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Featurestore>

importFeatureValues(ImportFeatureValuesRequest request)

public ListenableFuture<Operation> importFeatureValues(ImportFeatureValuesRequest request)

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.

Parameter
Name	Description
request	ImportFeatureValuesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

listEntityTypes(ListEntityTypesRequest request)

public ListenableFuture<ListEntityTypesResponse> listEntityTypes(ListEntityTypesRequest request)

Lists EntityTypes in a given Featurestore.

Parameter
Name	Description
request	ListEntityTypesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<ListEntityTypesResponse>

listFeatures(ListFeaturesRequest request)

public ListenableFuture<ListFeaturesResponse> listFeatures(ListFeaturesRequest request)

Lists Features in a given EntityType.

Parameter
Name	Description
request	ListFeaturesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<ListFeaturesResponse>

listFeaturestores(ListFeaturestoresRequest request)

public ListenableFuture<ListFeaturestoresResponse> listFeaturestores(ListFeaturestoresRequest request)

Lists Featurestores in a given project and location.

Parameter
Name	Description
request	ListFeaturestoresRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<ListFeaturestoresResponse>

searchFeatures(SearchFeaturesRequest request)

public ListenableFuture<SearchFeaturesResponse> searchFeatures(SearchFeaturesRequest request)

Searches Features matching a query in a given project.

Parameter
Name	Description
request	SearchFeaturesRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<SearchFeaturesResponse>

updateEntityType(UpdateEntityTypeRequest request)

public ListenableFuture<EntityType> updateEntityType(UpdateEntityTypeRequest request)

Updates the parameters of a single EntityType.

Parameter
Name	Description
request	UpdateEntityTypeRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<EntityType>

updateFeature(UpdateFeatureRequest request)

public ListenableFuture<Feature> updateFeature(UpdateFeatureRequest request)

Updates the parameters of a single Feature.

Parameter
Name	Description
request	UpdateFeatureRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Feature>

updateFeaturestore(UpdateFeaturestoreRequest request)

public ListenableFuture<Operation> updateFeaturestore(UpdateFeaturestoreRequest request)

Updates the parameters of a single Featurestore.

Parameter
Name	Description
request	UpdateFeaturestoreRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>