public static interface FeatureOnlineStoreServiceGrpc.AsyncServiceA service for fetching feature values from the online store.
Methods
featureViewDirectWrite(StreamObserver<FeatureViewDirectWriteResponse> responseObserver)
public default StreamObserver<FeatureViewDirectWriteRequest> featureViewDirectWrite(StreamObserver<FeatureViewDirectWriteResponse> responseObserver)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.
| Parameter | |
|---|---|
| Name | Description |
responseObserver |
io.grpc.stub.StreamObserver<FeatureViewDirectWriteResponse> |
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.StreamObserver<FeatureViewDirectWriteRequest> |
|
fetchFeatureValues(FetchFeatureValuesRequest request, StreamObserver<FetchFeatureValuesResponse> responseObserver)
public default void fetchFeatureValues(FetchFeatureValuesRequest request, StreamObserver<FetchFeatureValuesResponse> responseObserver)Fetch feature values under a FeatureView.
| Parameters | |
|---|---|
| Name | Description |
request |
FetchFeatureValuesRequest |
responseObserver |
io.grpc.stub.StreamObserver<FetchFeatureValuesResponse> |
searchNearestEntities(SearchNearestEntitiesRequest request, StreamObserver<SearchNearestEntitiesResponse> responseObserver)
public default void searchNearestEntities(SearchNearestEntitiesRequest request, StreamObserver<SearchNearestEntitiesResponse> responseObserver)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.
| Parameters | |
|---|---|
| Name | Description |
request |
SearchNearestEntitiesRequest |
responseObserver |
io.grpc.stub.StreamObserver<SearchNearestEntitiesResponse> |