Skip to content

Commit b89f379

Browse files
cloud-java-botcloud-java-bot
committed
chore: generate libraries at Tue Aug 5 02:47:43 UTC 2025
1 parent d5253f4 commit b89f379

File tree

64 files changed

+11381
-408
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

64 files changed

+11381
-408
lines changed

‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeatureOnlineStoreServiceClient.java‎

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import com.google.api.gax.paging.AbstractFixedSizeCollection;
2323
import com.google.api.gax.paging.AbstractPage;
2424
import com.google.api.gax.paging.AbstractPagedListResponse;
25+
import com.google.api.gax.rpc.BidiStreamingCallable;
2526
import com.google.api.gax.rpc.PageContext;
2627
import com.google.api.gax.rpc.UnaryCallable;
2728
import com.google.cloud.aiplatform.v1.stub.FeatureOnlineStoreServiceStub;
@@ -109,6 +110,16 @@
109110
* </td>
110111
* </tr>
111112
* <tr>
113+
* <td><p> FeatureViewDirectWrite</td>
114+
* <td><p> 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.</td>
115+
* <td>
116+
* <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
117+
* <ul>
118+
* <li><p> featureViewDirectWriteCallable()
119+
* </ul>
120+
* </td>
121+
* </tr>
122+
* <tr>
112123
* <td><p> ListLocations</td>
113124
* <td><p> Lists information about the supported locations for this service.</td>
114125
* <td>
@@ -494,6 +505,45 @@ public final SearchNearestEntitiesResponse searchNearestEntities(
494505
return stub.searchNearestEntitiesCallable();
495506
}
496507

508+
// AUTO-GENERATED DOCUMENTATION AND METHOD.
509+
/**
510+
* Bidirectional streaming RPC to directly write to feature values in a feature view. Requests may
511+
* not have a one-to-one mapping to responses and responses may be returned out-of-order to reduce
512+
* latency.
513+
*
514+
* <p>Sample code:
515+
*
516+
* <pre>{@code
517+
* // This snippet has been automatically generated and should be regarded as a code template only.
518+
* // It will require modifications to work:
519+
* // - It may require correct/in-range values for request initialization.
520+
* // - It may require specifying regional endpoints when creating the service client as shown in
521+
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
522+
* try (FeatureOnlineStoreServiceClient featureOnlineStoreServiceClient =
523+
* FeatureOnlineStoreServiceClient.create()) {
524+
* BidiStream<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse> bidiStream =
525+
* featureOnlineStoreServiceClient.featureViewDirectWriteCallable().call();
526+
* FeatureViewDirectWriteRequest request =
527+
* FeatureViewDirectWriteRequest.newBuilder()
528+
* .setFeatureView(
529+
* FeatureViewName.of(
530+
* "[PROJECT]", "[LOCATION]", "[FEATURE_ONLINE_STORE]", "[FEATURE_VIEW]")
531+
* .toString())
532+
* .addAllDataKeyAndFeatureValues(
533+
* new ArrayList<FeatureViewDirectWriteRequest.DataKeyAndFeatureValues>())
534+
* .build();
535+
* bidiStream.send(request);
536+
* for (FeatureViewDirectWriteResponse response : bidiStream) {
537+
* // Do something when a response is received.
538+
* }
539+
* }
540+
* }</pre>
541+
*/
542+
public final BidiStreamingCallable<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
543+
featureViewDirectWriteCallable() {
544+
return stub.featureViewDirectWriteCallable();
545+
}
546+
497547
// AUTO-GENERATED DOCUMENTATION AND METHOD.
498548
/**
499549
* Lists information about the supported locations for this service.

‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/FeatureOnlineStoreServiceSettings.java‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import com.google.api.gax.rpc.ClientContext;
2727
import com.google.api.gax.rpc.ClientSettings;
2828
import com.google.api.gax.rpc.PagedCallSettings;
29+
import com.google.api.gax.rpc.StreamingCallSettings;
2930
import com.google.api.gax.rpc.TransportChannelProvider;
3031
import com.google.api.gax.rpc.UnaryCallSettings;
3132
import com.google.cloud.aiplatform.v1.stub.FeatureOnlineStoreServiceStubSettings;
@@ -110,6 +111,13 @@ public class FeatureOnlineStoreServiceSettings
110111
.searchNearestEntitiesSettings();
111112
}
112113

114+
/** Returns the object with the settings used for calls to featureViewDirectWrite. */
115+
public StreamingCallSettings<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
116+
featureViewDirectWriteSettings() {
117+
return ((FeatureOnlineStoreServiceStubSettings) getStubSettings())
118+
.featureViewDirectWriteSettings();
119+
}
120+
113121
/** Returns the object with the settings used for calls to listLocations. */
114122
public PagedCallSettings<ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
115123
listLocationsSettings() {
@@ -246,6 +254,13 @@ public Builder applyToAllUnaryMethods(
246254
return getStubSettingsBuilder().searchNearestEntitiesSettings();
247255
}
248256

257+
/** Returns the builder for the settings used for calls to featureViewDirectWrite. */
258+
public StreamingCallSettings.Builder<
259+
FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
260+
featureViewDirectWriteSettings() {
261+
return getStubSettingsBuilder().featureViewDirectWriteSettings();
262+
}
263+
249264
/** Returns the builder for the settings used for calls to listLocations. */
250265
public PagedCallSettings.Builder<
251266
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>

‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/gapic_metadata.json‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -274,6 +274,9 @@
274274
"grpc": {
275275
"libraryClient": "FeatureOnlineStoreServiceClient",
276276
"rpcs": {
277+
"FeatureViewDirectWrite": {
278+
"methods": ["featureViewDirectWriteCallable"]
279+
},
277280
"FetchFeatureValues": {
278281
"methods": ["fetchFeatureValues", "fetchFeatureValues", "fetchFeatureValues", "fetchFeatureValuesCallable"]
279282
},

‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/FeatureOnlineStoreServiceStub.java‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,10 @@
1919
import static com.google.cloud.aiplatform.v1.FeatureOnlineStoreServiceClient.ListLocationsPagedResponse;
2020

2121
import com.google.api.gax.core.BackgroundResource;
22+
import com.google.api.gax.rpc.BidiStreamingCallable;
2223
import com.google.api.gax.rpc.UnaryCallable;
24+
import com.google.cloud.aiplatform.v1.FeatureViewDirectWriteRequest;
25+
import com.google.cloud.aiplatform.v1.FeatureViewDirectWriteResponse;
2326
import com.google.cloud.aiplatform.v1.FetchFeatureValuesRequest;
2427
import com.google.cloud.aiplatform.v1.FetchFeatureValuesResponse;
2528
import com.google.cloud.aiplatform.v1.SearchNearestEntitiesRequest;
@@ -54,6 +57,11 @@ public abstract class FeatureOnlineStoreServiceStub implements BackgroundResourc
5457
throw new UnsupportedOperationException("Not implemented: searchNearestEntitiesCallable()");
5558
}
5659

60+
public BidiStreamingCallable<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
61+
featureViewDirectWriteCallable() {
62+
throw new UnsupportedOperationException("Not implemented: featureViewDirectWriteCallable()");
63+
}
64+
5765
public UnaryCallable<ListLocationsRequest, ListLocationsPagedResponse>
5866
listLocationsPagedCallable() {
5967
throw new UnsupportedOperationException("Not implemented: listLocationsPagedCallable()");

‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/FeatureOnlineStoreServiceStubSettings.java‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,10 +36,13 @@
3636
import com.google.api.gax.rpc.PagedListDescriptor;
3737
import com.google.api.gax.rpc.PagedListResponseFactory;
3838
import com.google.api.gax.rpc.StatusCode;
39+
import com.google.api.gax.rpc.StreamingCallSettings;
3940
import com.google.api.gax.rpc.StubSettings;
4041
import com.google.api.gax.rpc.TransportChannelProvider;
4142
import com.google.api.gax.rpc.UnaryCallSettings;
4243
import com.google.api.gax.rpc.UnaryCallable;
44+
import com.google.cloud.aiplatform.v1.FeatureViewDirectWriteRequest;
45+
import com.google.cloud.aiplatform.v1.FeatureViewDirectWriteResponse;
4346
import com.google.cloud.aiplatform.v1.FetchFeatureValuesRequest;
4447
import com.google.cloud.aiplatform.v1.FetchFeatureValuesResponse;
4548
import com.google.cloud.aiplatform.v1.SearchNearestEntitiesRequest;
@@ -123,6 +126,8 @@ public class FeatureOnlineStoreServiceStubSettings
123126
fetchFeatureValuesSettings;
124127
private final UnaryCallSettings<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
125128
searchNearestEntitiesSettings;
129+
private final StreamingCallSettings<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
130+
featureViewDirectWriteSettings;
126131
private final PagedCallSettings<
127132
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
128133
listLocationsSettings;
@@ -195,6 +200,12 @@ public ApiFuture<ListLocationsPagedResponse> getFuturePagedResponse(
195200
return searchNearestEntitiesSettings;
196201
}
197202

203+
/** Returns the object with the settings used for calls to featureViewDirectWrite. */
204+
public StreamingCallSettings<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
205+
featureViewDirectWriteSettings() {
206+
return featureViewDirectWriteSettings;
207+
}
208+
198209
/** Returns the object with the settings used for calls to listLocations. */
199210
public PagedCallSettings<ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
200211
listLocationsSettings() {
@@ -305,6 +316,7 @@ protected FeatureOnlineStoreServiceStubSettings(Builder settingsBuilder) throws
305316

306317
fetchFeatureValuesSettings = settingsBuilder.fetchFeatureValuesSettings().build();
307318
searchNearestEntitiesSettings = settingsBuilder.searchNearestEntitiesSettings().build();
319+
featureViewDirectWriteSettings = settingsBuilder.featureViewDirectWriteSettings().build();
308320
listLocationsSettings = settingsBuilder.listLocationsSettings().build();
309321
getLocationSettings = settingsBuilder.getLocationSettings().build();
310322
setIamPolicySettings = settingsBuilder.setIamPolicySettings().build();
@@ -321,6 +333,9 @@ public static class Builder
321333
private final UnaryCallSettings.Builder<
322334
SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
323335
searchNearestEntitiesSettings;
336+
private final StreamingCallSettings.Builder<
337+
FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
338+
featureViewDirectWriteSettings;
324339
private final PagedCallSettings.Builder<
325340
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
326341
listLocationsSettings;
@@ -358,6 +373,7 @@ protected Builder(ClientContext clientContext) {
358373

359374
fetchFeatureValuesSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
360375
searchNearestEntitiesSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
376+
featureViewDirectWriteSettings = StreamingCallSettings.newBuilder();
361377
listLocationsSettings = PagedCallSettings.newBuilder(LIST_LOCATIONS_PAGE_STR_FACT);
362378
getLocationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
363379
setIamPolicySettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
@@ -381,6 +397,7 @@ protected Builder(FeatureOnlineStoreServiceStubSettings settings) {
381397

382398
fetchFeatureValuesSettings = settings.fetchFeatureValuesSettings.toBuilder();
383399
searchNearestEntitiesSettings = settings.searchNearestEntitiesSettings.toBuilder();
400+
featureViewDirectWriteSettings = settings.featureViewDirectWriteSettings.toBuilder();
384401
listLocationsSettings = settings.listLocationsSettings.toBuilder();
385402
getLocationSettings = settings.getLocationSettings.toBuilder();
386403
setIamPolicySettings = settings.setIamPolicySettings.toBuilder();
@@ -476,6 +493,13 @@ public Builder applyToAllUnaryMethods(
476493
return searchNearestEntitiesSettings;
477494
}
478495

496+
/** Returns the builder for the settings used for calls to featureViewDirectWrite. */
497+
public StreamingCallSettings.Builder<
498+
FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
499+
featureViewDirectWriteSettings() {
500+
return featureViewDirectWriteSettings;
501+
}
502+
479503
/** Returns the builder for the settings used for calls to listLocations. */
480504
public PagedCallSettings.Builder<
481505
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>

‎java-aiplatform/google-cloud-aiplatform/src/main/java/com/google/cloud/aiplatform/v1/stub/GrpcFeatureOnlineStoreServiceStub.java‎

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,12 @@
2222
import com.google.api.gax.core.BackgroundResourceAggregation;
2323
import com.google.api.gax.grpc.GrpcCallSettings;
2424
import com.google.api.gax.grpc.GrpcStubCallableFactory;
25+
import com.google.api.gax.rpc.BidiStreamingCallable;
2526
import com.google.api.gax.rpc.ClientContext;
2627
import com.google.api.gax.rpc.RequestParamsBuilder;
2728
import com.google.api.gax.rpc.UnaryCallable;
29+
import com.google.cloud.aiplatform.v1.FeatureViewDirectWriteRequest;
30+
import com.google.cloud.aiplatform.v1.FeatureViewDirectWriteResponse;
2831
import com.google.cloud.aiplatform.v1.FetchFeatureValuesRequest;
2932
import com.google.cloud.aiplatform.v1.FetchFeatureValuesResponse;
3033
import com.google.cloud.aiplatform.v1.SearchNearestEntitiesRequest;
@@ -77,6 +80,20 @@ public class GrpcFeatureOnlineStoreServiceStub extends FeatureOnlineStoreService
7780
ProtoUtils.marshaller(SearchNearestEntitiesResponse.getDefaultInstance()))
7881
.build();
7982

83+
private static final MethodDescriptor<
84+
FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
85+
featureViewDirectWriteMethodDescriptor =
86+
MethodDescriptor
87+
.<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>newBuilder()
88+
.setType(MethodDescriptor.MethodType.BIDI_STREAMING)
89+
.setFullMethodName(
90+
"google.cloud.aiplatform.v1.FeatureOnlineStoreService/FeatureViewDirectWrite")
91+
.setRequestMarshaller(
92+
ProtoUtils.marshaller(FeatureViewDirectWriteRequest.getDefaultInstance()))
93+
.setResponseMarshaller(
94+
ProtoUtils.marshaller(FeatureViewDirectWriteResponse.getDefaultInstance()))
95+
.build();
96+
8097
private static final MethodDescriptor<ListLocationsRequest, ListLocationsResponse>
8198
listLocationsMethodDescriptor =
8299
MethodDescriptor.<ListLocationsRequest, ListLocationsResponse>newBuilder()
@@ -127,6 +144,8 @@ public class GrpcFeatureOnlineStoreServiceStub extends FeatureOnlineStoreService
127144
fetchFeatureValuesCallable;
128145
private final UnaryCallable<SearchNearestEntitiesRequest, SearchNearestEntitiesResponse>
129146
searchNearestEntitiesCallable;
147+
private final BidiStreamingCallable<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
148+
featureViewDirectWriteCallable;
130149
private final UnaryCallable<ListLocationsRequest, ListLocationsResponse> listLocationsCallable;
131150
private final UnaryCallable<ListLocationsRequest, ListLocationsPagedResponse>
132151
listLocationsPagedCallable;
@@ -204,6 +223,18 @@ protected GrpcFeatureOnlineStoreServiceStub(
204223
return builder.build();
205224
})
206225
.build();
226+
GrpcCallSettings<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
227+
featureViewDirectWriteTransportSettings =
228+
GrpcCallSettings
229+
.<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>newBuilder()
230+
.setMethodDescriptor(featureViewDirectWriteMethodDescriptor)
231+
.setParamsExtractor(
232+
request -> {
233+
RequestParamsBuilder builder = RequestParamsBuilder.create();
234+
builder.add("feature_view", String.valueOf(request.getFeatureView()));
235+
return builder.build();
236+
})
237+
.build();
207238
GrpcCallSettings<ListLocationsRequest, ListLocationsResponse> listLocationsTransportSettings =
208239
GrpcCallSettings.<ListLocationsRequest, ListLocationsResponse>newBuilder()
209240
.setMethodDescriptor(listLocationsMethodDescriptor)
@@ -266,6 +297,11 @@ protected GrpcFeatureOnlineStoreServiceStub(
266297
searchNearestEntitiesTransportSettings,
267298
settings.searchNearestEntitiesSettings(),
268299
clientContext);
300+
this.featureViewDirectWriteCallable =
301+
callableFactory.createBidiStreamingCallable(
302+
featureViewDirectWriteTransportSettings,
303+
settings.featureViewDirectWriteSettings(),
304+
clientContext);
269305
this.listLocationsCallable =
270306
callableFactory.createUnaryCallable(
271307
listLocationsTransportSettings, settings.listLocationsSettings(), clientContext);
@@ -307,6 +343,12 @@ public GrpcOperationsStub getOperationsStub() {
307343
return searchNearestEntitiesCallable;
308344
}
309345

346+
@Override
347+
public BidiStreamingCallable<FeatureViewDirectWriteRequest, FeatureViewDirectWriteResponse>
348+
featureViewDirectWriteCallable() {
349+
return featureViewDirectWriteCallable;
350+
}
351+
310352
@Override
311353
public UnaryCallable<ListLocationsRequest, ListLocationsResponse> listLocationsCallable() {
312354
return listLocationsCallable;

0 commit comments

Comments
 (0)