|
42 | 42 | import com.google.firestore.v1.DeleteDocumentRequest; |
43 | 43 | import com.google.firestore.v1.Document; |
44 | 44 | import com.google.firestore.v1.DocumentMask; |
| 45 | +import com.google.firestore.v1.ExecutePipelineRequest; |
| 46 | +import com.google.firestore.v1.ExecutePipelineResponse; |
45 | 47 | import com.google.firestore.v1.GetDocumentRequest; |
46 | 48 | import com.google.firestore.v1.ListCollectionIdsRequest; |
47 | 49 | import com.google.firestore.v1.ListCollectionIdsResponse; |
|
247 | 249 | * </td> |
248 | 250 | * </tr> |
249 | 251 | * <tr> |
| 252 | + * <td><p> ExecutePipeline</td> |
| 253 | + * <td><p> Executes a pipeline query.</td> |
| 254 | + * <td> |
| 255 | + * <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> |
| 256 | + * <ul> |
| 257 | + * <li><p> executePipelineCallable() |
| 258 | + * </ul> |
| 259 | + * </td> |
| 260 | + * </tr> |
| 261 | + * <tr> |
250 | 262 | * <td><p> RunAggregationQuery</td> |
251 | 263 | * <td><p> Runs an aggregation query. |
252 | 264 | * <p> Rather than producing [Document][google.firestore.v1.Document] results like [Firestore.RunQuery][google.firestore.v1.Firestore.RunQuery], this API allows running an aggregation to produce a series of [AggregationResult][google.firestore.v1.AggregationResult] server-side. |
@@ -1123,6 +1135,34 @@ public final ServerStreamingCallable<RunQueryRequest, RunQueryResponse> runQuery |
1123 | 1135 | return stub.runQueryCallable(); |
1124 | 1136 | } |
1125 | 1137 |
|
| 1138 | + // AUTO-GENERATED DOCUMENTATION AND METHOD. |
| 1139 | + /** |
| 1140 | + * Executes a pipeline query. |
| 1141 | + * |
| 1142 | + * <p>Sample code: |
| 1143 | + * |
| 1144 | + * <pre>{@code |
| 1145 | + * // This snippet has been automatically generated and should be regarded as a code template only. |
| 1146 | + * // It will require modifications to work: |
| 1147 | + * // - It may require correct/in-range values for request initialization. |
| 1148 | + * // - It may require specifying regional endpoints when creating the service client as shown in |
| 1149 | + * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library |
| 1150 | + * try (FirestoreClient firestoreClient = FirestoreClient.create()) { |
| 1151 | + * ExecutePipelineRequest request = |
| 1152 | + * ExecutePipelineRequest.newBuilder().setDatabase("database1789464955").build(); |
| 1153 | + * ServerStream<ExecutePipelineResponse> stream = |
| 1154 | + * firestoreClient.executePipelineCallable().call(request); |
| 1155 | + * for (ExecutePipelineResponse response : stream) { |
| 1156 | + * // Do something when a response is received. |
| 1157 | + * } |
| 1158 | + * } |
| 1159 | + * }</pre> |
| 1160 | + */ |
| 1161 | + public final ServerStreamingCallable<ExecutePipelineRequest, ExecutePipelineResponse> |
| 1162 | + executePipelineCallable() { |
| 1163 | + return stub.executePipelineCallable(); |
| 1164 | + } |
| 1165 | + |
1126 | 1166 | // AUTO-GENERATED DOCUMENTATION AND METHOD. |
1127 | 1167 | /** |
1128 | 1168 | * Runs an aggregation query. |
|
0 commit comments