Class FeatureOnlineStoreServiceGrpc.FeatureOnlineStoreServiceBlockingV2Stub (3.77.0)
public static final class FeatureOnlineStoreServiceGrpc.FeatureOnlineStoreServiceBlockingV2Stub extends AbstractBlockingStub<FeatureOnlineStoreServiceGrpc.FeatureOnlineStoreServiceBlockingV2Stub>
A stub to allow clients to do synchronous rpc calls to service FeatureOnlineStoreService.
A service for fetching feature values from the online store.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractBlockingStub >
FeatureOnlineStoreServiceGrpc.FeatureOnlineStoreServiceBlockingV2Stub
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<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(java.time.Duration)
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()
Methods
protected FeatureOnlineStoreServiceGrpc.FeatureOnlineStoreServiceBlockingV2Stub build(Channel channel, CallOptions callOptions)
| Parameters |
| Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
public BlockingClientCall<FeatureViewDirectWriteRequest,FeatureViewDirectWriteResponse> featureViewDirectWrite()
Bidirectional streaming RPC to directly write to feature values in a
feature view. Requests may not have a one-to-one mapping to responses and
responses may be returned out-of-order to reduce latency.
public FetchFeatureValuesResponse fetchFeatureValues(FetchFeatureValuesRequest request)
Fetch feature values under a FeatureView.
public SearchNearestEntitiesResponse searchNearestEntities(SearchNearestEntitiesRequest request)
Search the nearest entities under a FeatureView.
Search only works for indexable feature view; if a feature view isn't
indexable, returns Invalid argument response.
public BlockingClientCall<StreamingFetchFeatureValuesRequest,StreamingFetchFeatureValuesResponse> streamingFetchFeatureValues()
Bidirectional streaming RPC to fetch feature values under a FeatureView.
Requests may not have a one-to-one mapping to responses and responses may
be returned out-of-order to reduce latency.
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-10-11 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-10-11 UTC."],[],[]]
