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.FeatureOnlineStoreServiceBlockingV2StubMethods
build(Channel channel, CallOptions callOptions)
protected FeatureOnlineStoreServiceGrpc.FeatureOnlineStoreServiceBlockingV2Stub build(Channel channel, CallOptions callOptions)| Parameters | |
|---|---|
| Name | Description |
channel |
io.grpc.Channel |
callOptions |
io.grpc.CallOptions |
| Returns | |
|---|---|
| Type | Description |
FeatureOnlineStoreServiceGrpc.FeatureOnlineStoreServiceBlockingV2Stub |
|
featureViewDirectWrite()
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.
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.BlockingClientCall<FeatureViewDirectWriteRequest,FeatureViewDirectWriteResponse> |
|
fetchFeatureValues(FetchFeatureValuesRequest request)
public FetchFeatureValuesResponse fetchFeatureValues(FetchFeatureValuesRequest request)Fetch feature values under a FeatureView.
| Parameter | |
|---|---|
| Name | Description |
request |
FetchFeatureValuesRequest |
| Returns | |
|---|---|
| Type | Description |
FetchFeatureValuesResponse |
|
| Exceptions | |
|---|---|
| Type | Description |
io.grpc.StatusException |
|
generateFetchAccessToken(GenerateFetchAccessTokenRequest request)
public GenerateFetchAccessTokenResponse generateFetchAccessToken(GenerateFetchAccessTokenRequest request)RPC to generate an access token for the given feature view. FeatureViews under the same FeatureOnlineStore share the same access token.
| Parameter | |
|---|---|
| Name | Description |
request |
GenerateFetchAccessTokenRequest |
| Returns | |
|---|---|
| Type | Description |
GenerateFetchAccessTokenResponse |
|
| Exceptions | |
|---|---|
| Type | Description |
io.grpc.StatusException |
|
searchNearestEntities(SearchNearestEntitiesRequest request)
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.
| Parameter | |
|---|---|
| Name | Description |
request |
SearchNearestEntitiesRequest |
| Returns | |
|---|---|
| Type | Description |
SearchNearestEntitiesResponse |
|
| Exceptions | |
|---|---|
| Type | Description |
io.grpc.StatusException |
|
streamingFetchFeatureValues()
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.
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.BlockingClientCall<StreamingFetchFeatureValuesRequest,StreamingFetchFeatureValuesResponse> |
|