Skip to content

Commit df686d6

Browse files
feat: add default_missing_value_interpretation field; indicate KMS_SERVICE_ERROR is retryable (#2229)
* feat: add beta2 deprecation message PiperOrigin-RevId: 556875976 Source-Link: googleapis/googleapis@29b8ec7 Source-Link: https://github.com/googleapis/googleapis-gen/commit/cc401b7cac5c77c681056c788ab1c8e2025e7ba6 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiY2M0MDFiN2NhYzVjNzdjNjgxMDU2Yzc4OGFiMWM4ZTIwMjVlN2JhNiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add default_missing_value_interpretation field; indicate KMS_SERVICE_ERROR is retryable PiperOrigin-RevId: 556931084 Source-Link: googleapis/googleapis@ca3d7e8 Source-Link: https://github.com/googleapis/googleapis-gen/commit/861a1c34624a57251345c820d69887a495ee417a Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiODYxYTFjMzQ2MjRhNTcyNTEzNDVjODIwZDY5ODg3YTQ5NWVlNDE3YSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 9b9b5c0 commit df686d6

File tree

13 files changed

+520
-185
lines changed

13 files changed

+520
-185
lines changed

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClient.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,10 @@
3232
*
3333
* <p>The Write API can be used to write data to BigQuery.
3434
*
35+
* <p>The [google.cloud.bigquery.storage.v1
36+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1) should be used
37+
* instead of the v1beta2 API for BigQueryWrite operations.
38+
*
3539
* <p>This class provides the ability to make remote calls to the backing service through method
3640
* calls that map to API methods. Sample code to get started:
3741
*

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/package-info.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,10 @@
5151
*
5252
* <p>The Write API can be used to write data to BigQuery.
5353
*
54+
* <p>The [google.cloud.bigquery.storage.v1
55+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1) should be used
56+
* instead of the v1beta2 API for BigQueryWrite operations.
57+
*
5458
* <p>Sample for BigQueryWriteClient:
5559
*
5660
* <pre>{@code

grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteGrpc.java

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,9 @@
2323
* <pre>
2424
* BigQuery Write API.
2525
* The Write API can be used to write data to BigQuery.
26+
* The [google.cloud.bigquery.storage.v1
27+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1)
28+
* should be used instead of the v1beta2 API for BigQueryWrite operations.
2629
* </pre>
2730
*/
2831
@javax.annotation.Generated(
@@ -369,6 +372,9 @@ public BigQueryWriteFutureStub newStub(
369372
* <pre>
370373
* BigQuery Write API.
371374
* The Write API can be used to write data to BigQuery.
375+
* The [google.cloud.bigquery.storage.v1
376+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1)
377+
* should be used instead of the v1beta2 API for BigQueryWrite operations.
372378
* </pre>
373379
*/
374380
public interface AsyncService {
@@ -502,6 +508,9 @@ default void flushRows(
502508
* <pre>
503509
* BigQuery Write API.
504510
* The Write API can be used to write data to BigQuery.
511+
* The [google.cloud.bigquery.storage.v1
512+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1)
513+
* should be used instead of the v1beta2 API for BigQueryWrite operations.
505514
* </pre>
506515
*/
507516
public abstract static class BigQueryWriteImplBase
@@ -519,6 +528,9 @@ public final io.grpc.ServerServiceDefinition bindService() {
519528
* <pre>
520529
* BigQuery Write API.
521530
* The Write API can be used to write data to BigQuery.
531+
* The [google.cloud.bigquery.storage.v1
532+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1)
533+
* should be used instead of the v1beta2 API for BigQueryWrite operations.
522534
* </pre>
523535
*/
524536
public static final class BigQueryWriteStub
@@ -670,6 +682,9 @@ public void flushRows(
670682
* <pre>
671683
* BigQuery Write API.
672684
* The Write API can be used to write data to BigQuery.
685+
* The [google.cloud.bigquery.storage.v1
686+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1)
687+
* should be used instead of the v1beta2 API for BigQueryWrite operations.
673688
* </pre>
674689
*/
675690
public static final class BigQueryWriteBlockingStub
@@ -773,6 +788,9 @@ public com.google.cloud.bigquery.storage.v1beta2.FlushRowsResponse flushRows(
773788
* <pre>
774789
* BigQuery Write API.
775790
* The Write API can be used to write data to BigQuery.
791+
* The [google.cloud.bigquery.storage.v1
792+
* API](/bigquery/docs/reference/storage/rpc/google.cloud.bigquery.storage.v1)
793+
* should be used instead of the v1beta2 API for BigQueryWrite operations.
776794
* </pre>
777795
*/
778796
public static final class BigQueryWriteFutureStub

proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/AppendRowsRequest.java

Lines changed: 239 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@ private AppendRowsRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> buil
4848
private AppendRowsRequest() {
4949
writeStream_ = "";
5050
traceId_ = "";
51+
defaultMissingValueInterpretation_ = 0;
5152
}
5253

5354
@java.lang.Override
@@ -2119,6 +2120,66 @@ public int getMissingValueInterpretationsValueOrThrow(java.lang.String key) {
21192120
return map.get(key);
21202121
}
21212122

2123+
public static final int DEFAULT_MISSING_VALUE_INTERPRETATION_FIELD_NUMBER = 8;
2124+
private int defaultMissingValueInterpretation_ = 0;
2125+
/**
2126+
*
2127+
*
2128+
* <pre>
2129+
* Optional. Default missing value interpretation for all columns in the
2130+
* table. When a value is specified on an `AppendRowsRequest`, it is applied
2131+
* to all requests on the connection from that point forward, until a
2132+
* subsequent `AppendRowsRequest` sets it to a different value.
2133+
* `missing_value_interpretation` can override
2134+
* `default_missing_value_interpretation`. For example, if you want to write
2135+
* `NULL` instead of using default values for some columns, you can set
2136+
* `default_missing_value_interpretation` to `DEFAULT_VALUE` and at the same
2137+
* time, set `missing_value_interpretations` to `NULL_VALUE` on those columns.
2138+
* </pre>
2139+
*
2140+
* <code>
2141+
* .google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation default_missing_value_interpretation = 8 [(.google.api.field_behavior) = OPTIONAL];
2142+
* </code>
2143+
*
2144+
* @return The enum numeric value on the wire for defaultMissingValueInterpretation.
2145+
*/
2146+
@java.lang.Override
2147+
public int getDefaultMissingValueInterpretationValue() {
2148+
return defaultMissingValueInterpretation_;
2149+
}
2150+
/**
2151+
*
2152+
*
2153+
* <pre>
2154+
* Optional. Default missing value interpretation for all columns in the
2155+
* table. When a value is specified on an `AppendRowsRequest`, it is applied
2156+
* to all requests on the connection from that point forward, until a
2157+
* subsequent `AppendRowsRequest` sets it to a different value.
2158+
* `missing_value_interpretation` can override
2159+
* `default_missing_value_interpretation`. For example, if you want to write
2160+
* `NULL` instead of using default values for some columns, you can set
2161+
* `default_missing_value_interpretation` to `DEFAULT_VALUE` and at the same
2162+
* time, set `missing_value_interpretations` to `NULL_VALUE` on those columns.
2163+
* </pre>
2164+
*
2165+
* <code>
2166+
* .google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation default_missing_value_interpretation = 8 [(.google.api.field_behavior) = OPTIONAL];
2167+
* </code>
2168+
*
2169+
* @return The defaultMissingValueInterpretation.
2170+
*/
2171+
@java.lang.Override
2172+
public com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation
2173+
getDefaultMissingValueInterpretation() {
2174+
com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation result =
2175+
com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation.forNumber(
2176+
defaultMissingValueInterpretation_);
2177+
return result == null
2178+
? com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation
2179+
.UNRECOGNIZED
2180+
: result;
2181+
}
2182+
21222183
private byte memoizedIsInitialized = -1;
21232184

21242185
@java.lang.Override
@@ -2157,6 +2218,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
21572218
internalGetMissingValueInterpretations(),
21582219
MissingValueInterpretationsDefaultEntryHolder.defaultEntry,
21592220
7);
2221+
if (defaultMissingValueInterpretation_
2222+
!= com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation
2223+
.MISSING_VALUE_INTERPRETATION_UNSPECIFIED
2224+
.getNumber()) {
2225+
output.writeEnum(8, defaultMissingValueInterpretation_);
2226+
}
21602227
getUnknownFields().writeTo(output);
21612228
}
21622229

@@ -2193,6 +2260,14 @@ public int getSerializedSize() {
21932260
com.google.protobuf.CodedOutputStream.computeMessageSize(
21942261
7, missingValueInterpretations__);
21952262
}
2263+
if (defaultMissingValueInterpretation_
2264+
!= com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation
2265+
.MISSING_VALUE_INTERPRETATION_UNSPECIFIED
2266+
.getNumber()) {
2267+
size +=
2268+
com.google.protobuf.CodedOutputStream.computeEnumSize(
2269+
8, defaultMissingValueInterpretation_);
2270+
}
21962271
size += getUnknownFields().getSerializedSize();
21972272
memoizedSize = size;
21982273
return size;
@@ -2217,6 +2292,8 @@ public boolean equals(final java.lang.Object obj) {
22172292
if (!getTraceId().equals(other.getTraceId())) return false;
22182293
if (!internalGetMissingValueInterpretations()
22192294
.equals(other.internalGetMissingValueInterpretations())) return false;
2295+
if (defaultMissingValueInterpretation_ != other.defaultMissingValueInterpretation_)
2296+
return false;
22202297
if (!getRowsCase().equals(other.getRowsCase())) return false;
22212298
switch (rowsCase_) {
22222299
case 4:
@@ -2248,6 +2325,8 @@ public int hashCode() {
22482325
hash = (37 * hash) + MISSING_VALUE_INTERPRETATIONS_FIELD_NUMBER;
22492326
hash = (53 * hash) + internalGetMissingValueInterpretations().hashCode();
22502327
}
2328+
hash = (37 * hash) + DEFAULT_MISSING_VALUE_INTERPRETATION_FIELD_NUMBER;
2329+
hash = (53 * hash) + defaultMissingValueInterpretation_;
22512330
switch (rowsCase_) {
22522331
case 4:
22532332
hash = (37 * hash) + PROTO_ROWS_FIELD_NUMBER;
@@ -2435,6 +2514,7 @@ public Builder clear() {
24352514
}
24362515
traceId_ = "";
24372516
internalGetMutableMissingValueInterpretations().clear();
2517+
defaultMissingValueInterpretation_ = 0;
24382518
rowsCase_ = 0;
24392519
rows_ = null;
24402520
return this;
@@ -2487,6 +2567,9 @@ private void buildPartial0(com.google.cloud.bigquery.storage.v1.AppendRowsReques
24872567
result.missingValueInterpretations_ = internalGetMissingValueInterpretations();
24882568
result.missingValueInterpretations_.makeImmutable();
24892569
}
2570+
if (((from_bitField0_ & 0x00000020) != 0)) {
2571+
result.defaultMissingValueInterpretation_ = defaultMissingValueInterpretation_;
2572+
}
24902573
}
24912574

24922575
private void buildPartialOneofs(com.google.cloud.bigquery.storage.v1.AppendRowsRequest result) {
@@ -2559,6 +2642,10 @@ public Builder mergeFrom(com.google.cloud.bigquery.storage.v1.AppendRowsRequest
25592642
internalGetMutableMissingValueInterpretations()
25602643
.mergeFrom(other.internalGetMissingValueInterpretations());
25612644
bitField0_ |= 0x00000010;
2645+
if (other.defaultMissingValueInterpretation_ != 0) {
2646+
setDefaultMissingValueInterpretationValue(
2647+
other.getDefaultMissingValueInterpretationValue());
2648+
}
25622649
switch (other.getRowsCase()) {
25632650
case PROTO_ROWS:
25642651
{
@@ -2641,6 +2728,12 @@ public Builder mergeFrom(
26412728
bitField0_ |= 0x00000010;
26422729
break;
26432730
} // case 58
2731+
case 64:
2732+
{
2733+
defaultMissingValueInterpretation_ = input.readEnum();
2734+
bitField0_ |= 0x00000020;
2735+
break;
2736+
} // case 64
26442737
default:
26452738
{
26462739
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -4005,6 +4098,152 @@ public Builder putAllMissingValueInterpretationsValue(
40054098
return this;
40064099
}
40074100

4101+
private int defaultMissingValueInterpretation_ = 0;
4102+
/**
4103+
*
4104+
*
4105+
* <pre>
4106+
* Optional. Default missing value interpretation for all columns in the
4107+
* table. When a value is specified on an `AppendRowsRequest`, it is applied
4108+
* to all requests on the connection from that point forward, until a
4109+
* subsequent `AppendRowsRequest` sets it to a different value.
4110+
* `missing_value_interpretation` can override
4111+
* `default_missing_value_interpretation`. For example, if you want to write
4112+
* `NULL` instead of using default values for some columns, you can set
4113+
* `default_missing_value_interpretation` to `DEFAULT_VALUE` and at the same
4114+
* time, set `missing_value_interpretations` to `NULL_VALUE` on those columns.
4115+
* </pre>
4116+
*
4117+
* <code>
4118+
* .google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation default_missing_value_interpretation = 8 [(.google.api.field_behavior) = OPTIONAL];
4119+
* </code>
4120+
*
4121+
* @return The enum numeric value on the wire for defaultMissingValueInterpretation.
4122+
*/
4123+
@java.lang.Override
4124+
public int getDefaultMissingValueInterpretationValue() {
4125+
return defaultMissingValueInterpretation_;
4126+
}
4127+
/**
4128+
*
4129+
*
4130+
* <pre>
4131+
* Optional. Default missing value interpretation for all columns in the
4132+
* table. When a value is specified on an `AppendRowsRequest`, it is applied
4133+
* to all requests on the connection from that point forward, until a
4134+
* subsequent `AppendRowsRequest` sets it to a different value.
4135+
* `missing_value_interpretation` can override
4136+
* `default_missing_value_interpretation`. For example, if you want to write
4137+
* `NULL` instead of using default values for some columns, you can set
4138+
* `default_missing_value_interpretation` to `DEFAULT_VALUE` and at the same
4139+
* time, set `missing_value_interpretations` to `NULL_VALUE` on those columns.
4140+
* </pre>
4141+
*
4142+
* <code>
4143+
* .google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation default_missing_value_interpretation = 8 [(.google.api.field_behavior) = OPTIONAL];
4144+
* </code>
4145+
*
4146+
* @param value The enum numeric value on the wire for defaultMissingValueInterpretation to set.
4147+
* @return This builder for chaining.
4148+
*/
4149+
public Builder setDefaultMissingValueInterpretationValue(int value) {
4150+
defaultMissingValueInterpretation_ = value;
4151+
bitField0_ |= 0x00000020;
4152+
onChanged();
4153+
return this;
4154+
}
4155+
/**
4156+
*
4157+
*
4158+
* <pre>
4159+
* Optional. Default missing value interpretation for all columns in the
4160+
* table. When a value is specified on an `AppendRowsRequest`, it is applied
4161+
* to all requests on the connection from that point forward, until a
4162+
* subsequent `AppendRowsRequest` sets it to a different value.
4163+
* `missing_value_interpretation` can override
4164+
* `default_missing_value_interpretation`. For example, if you want to write
4165+
* `NULL` instead of using default values for some columns, you can set
4166+
* `default_missing_value_interpretation` to `DEFAULT_VALUE` and at the same
4167+
* time, set `missing_value_interpretations` to `NULL_VALUE` on those columns.
4168+
* </pre>
4169+
*
4170+
* <code>
4171+
* .google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation default_missing_value_interpretation = 8 [(.google.api.field_behavior) = OPTIONAL];
4172+
* </code>
4173+
*
4174+
* @return The defaultMissingValueInterpretation.
4175+
*/
4176+
@java.lang.Override
4177+
public com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation
4178+
getDefaultMissingValueInterpretation() {
4179+
com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation result =
4180+
com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation
4181+
.forNumber(defaultMissingValueInterpretation_);
4182+
return result == null
4183+
? com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation
4184+
.UNRECOGNIZED
4185+
: result;
4186+
}
4187+
/**
4188+
*
4189+
*
4190+
* <pre>
4191+
* Optional. Default missing value interpretation for all columns in the
4192+
* table. When a value is specified on an `AppendRowsRequest`, it is applied
4193+
* to all requests on the connection from that point forward, until a
4194+
* subsequent `AppendRowsRequest` sets it to a different value.
4195+
* `missing_value_interpretation` can override
4196+
* `default_missing_value_interpretation`. For example, if you want to write
4197+
* `NULL` instead of using default values for some columns, you can set
4198+
* `default_missing_value_interpretation` to `DEFAULT_VALUE` and at the same
4199+
* time, set `missing_value_interpretations` to `NULL_VALUE` on those columns.
4200+
* </pre>
4201+
*
4202+
* <code>
4203+
* .google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation default_missing_value_interpretation = 8 [(.google.api.field_behavior) = OPTIONAL];
4204+
* </code>
4205+
*
4206+
* @param value The defaultMissingValueInterpretation to set.
4207+
* @return This builder for chaining.
4208+
*/
4209+
public Builder setDefaultMissingValueInterpretation(
4210+
com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation value) {
4211+
if (value == null) {
4212+
throw new NullPointerException();
4213+
}
4214+
bitField0_ |= 0x00000020;
4215+
defaultMissingValueInterpretation_ = value.getNumber();
4216+
onChanged();
4217+
return this;
4218+
}
4219+
/**
4220+
*
4221+
*
4222+
* <pre>
4223+
* Optional. Default missing value interpretation for all columns in the
4224+
* table. When a value is specified on an `AppendRowsRequest`, it is applied
4225+
* to all requests on the connection from that point forward, until a
4226+
* subsequent `AppendRowsRequest` sets it to a different value.
4227+
* `missing_value_interpretation` can override
4228+
* `default_missing_value_interpretation`. For example, if you want to write
4229+
* `NULL` instead of using default values for some columns, you can set
4230+
* `default_missing_value_interpretation` to `DEFAULT_VALUE` and at the same
4231+
* time, set `missing_value_interpretations` to `NULL_VALUE` on those columns.
4232+
* </pre>
4233+
*
4234+
* <code>
4235+
* .google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation default_missing_value_interpretation = 8 [(.google.api.field_behavior) = OPTIONAL];
4236+
* </code>
4237+
*
4238+
* @return This builder for chaining.
4239+
*/
4240+
public Builder clearDefaultMissingValueInterpretation() {
4241+
bitField0_ = (bitField0_ & ~0x00000020);
4242+
defaultMissingValueInterpretation_ = 0;
4243+
onChanged();
4244+
return this;
4245+
}
4246+
40084247
@java.lang.Override
40094248
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
40104249
return super.setUnknownFields(unknownFields);

0 commit comments

Comments
 (0)