Skip to content

Commit

Permalink
feat!: release gapic-generator-java v2.0.0
Browse files Browse the repository at this point in the history 
Committer: @miraleung
PiperOrigin-RevId: 388535346

Source-Author: Google APIs <noreply@google.com>
Source-Date: Tue Aug 3 13:48:38 2021 -0700
Source-Repo: googleapis/googleapis
Source-Sha: d9eaf41de44d953458b18712a3f240bb4c564e48
Source-Link: googleapis/googleapis@d9eaf41
  • Loading branch information
@yoshi-automation
yoshi-automation committed Aug 4, 2021
1 parent 0e515f6 commit 2e944d2
Show file tree
Hide file tree
Showing 21 changed files with 101 additions and 1,283 deletions.
3 changes: 1 addition & 2 deletions ...ystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java
View file
Expand Up @@ -169,14 +169,13 @@ public BigQueryReadStubSettings.Builder getStubSettingsBuilder() {
return ((BigQueryReadStubSettings.Builder) getStubSettings());
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
Expand Down
3 changes: 1 addition & 2 deletions ...age/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java
View file
Expand Up @@ -323,14 +323,13 @@ private static Builder initDefaults(Builder builder) {
return builder;
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
return this;
}
Expand Down
37 changes: 13 additions & 24 deletions ...storage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadStub.java
View file
Expand Up @@ -21,7 +21,6 @@
import com.google.api.gax.grpc.GrpcCallSettings;
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest;
Expand All @@ -35,7 +34,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

Expand Down Expand Up @@ -128,41 +126,32 @@ protected GrpcBigQueryReadStub(
GrpcCallSettings.<CreateReadSessionRequest, ReadSession>newBuilder()
.setMethodDescriptor(createReadSessionMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<CreateReadSessionRequest>() {
@Override
public Map<String, String> extract(CreateReadSessionRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"read_session.table", String.valueOf(request.getReadSession().getTable()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"read_session.table", String.valueOf(request.getReadSession().getTable()));
return params.build();
})
.build();
GrpcCallSettings<ReadRowsRequest, ReadRowsResponse> readRowsTransportSettings =
GrpcCallSettings.<ReadRowsRequest, ReadRowsResponse>newBuilder()
.setMethodDescriptor(readRowsMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<ReadRowsRequest>() {
@Override
public Map<String, String> extract(ReadRowsRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("read_stream", String.valueOf(request.getReadStream()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("read_stream", String.valueOf(request.getReadStream()));
return params.build();
})
.build();
GrpcCallSettings<SplitReadStreamRequest, SplitReadStreamResponse>
splitReadStreamTransportSettings =
GrpcCallSettings.<SplitReadStreamRequest, SplitReadStreamResponse>newBuilder()
.setMethodDescriptor(splitReadStreamMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<SplitReadStreamRequest>() {
@Override
public Map<String, String> extract(SplitReadStreamRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();

Expand Down
3 changes: 1 addition & 2 deletions .../src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java
View file
Expand Up @@ -188,14 +188,13 @@ public BigQueryStorageStubSettings.Builder getStubSettingsBuilder() {
return ((BigQueryStorageStubSettings.Builder) getStubSettings());
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
Expand Down
3 changes: 1 addition & 2 deletions ...main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java
View file
Expand Up @@ -375,14 +375,13 @@ private static Builder initDefaults(Builder builder) {
return builder;
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
return this;
}
Expand Down
76 changes: 29 additions & 47 deletions ...src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageStub.java
View file
Expand Up @@ -22,7 +22,6 @@
import com.google.api.gax.grpc.GrpcCallSettings;
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.bigquery.storage.v1beta1.Storage;
Expand All @@ -32,7 +31,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

Expand Down Expand Up @@ -173,33 +171,27 @@ protected GrpcBigQueryStorageStub(
GrpcCallSettings.<Storage.CreateReadSessionRequest, Storage.ReadSession>newBuilder()
.setMethodDescriptor(createReadSessionMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<Storage.CreateReadSessionRequest>() {
@Override
public Map<String, String> extract(Storage.CreateReadSessionRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"table_reference.dataset_id",
String.valueOf(request.getTableReference().getDatasetId()));
params.put(
"table_reference.project_id",
String.valueOf(request.getTableReference().getProjectId()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"table_reference.dataset_id",
String.valueOf(request.getTableReference().getDatasetId()));
params.put(
"table_reference.project_id",
String.valueOf(request.getTableReference().getProjectId()));
return params.build();
})
.build();
GrpcCallSettings<Storage.ReadRowsRequest, Storage.ReadRowsResponse> readRowsTransportSettings =
GrpcCallSettings.<Storage.ReadRowsRequest, Storage.ReadRowsResponse>newBuilder()
.setMethodDescriptor(readRowsMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<Storage.ReadRowsRequest>() {
@Override
public Map<String, String> extract(Storage.ReadRowsRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"read_position.stream.name",
String.valueOf(request.getReadPosition().getStream().getName()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"read_position.stream.name",
String.valueOf(request.getReadPosition().getStream().getName()));
return params.build();
})
.build();
GrpcCallSettings<
Expand All @@ -212,27 +204,20 @@ public Map<String, String> extract(Storage.ReadRowsRequest request) {
newBuilder()
.setMethodDescriptor(batchCreateReadSessionStreamsMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<Storage.BatchCreateReadSessionStreamsRequest>() {
@Override
public Map<String, String> extract(
Storage.BatchCreateReadSessionStreamsRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("session.name", String.valueOf(request.getSession().getName()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("session.name", String.valueOf(request.getSession().getName()));
return params.build();
})
.build();
GrpcCallSettings<Storage.FinalizeStreamRequest, Empty> finalizeStreamTransportSettings =
GrpcCallSettings.<Storage.FinalizeStreamRequest, Empty>newBuilder()
.setMethodDescriptor(finalizeStreamMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<Storage.FinalizeStreamRequest>() {
@Override
public Map<String, String> extract(Storage.FinalizeStreamRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("stream.name", String.valueOf(request.getStream().getName()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("stream.name", String.valueOf(request.getStream().getName()));
return params.build();
})
.build();
GrpcCallSettings<Storage.SplitReadStreamRequest, Storage.SplitReadStreamResponse>
Expand All @@ -241,15 +226,12 @@ public Map<String, String> extract(Storage.FinalizeStreamRequest request) {
.<Storage.SplitReadStreamRequest, Storage.SplitReadStreamResponse>newBuilder()
.setMethodDescriptor(splitReadStreamMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<Storage.SplitReadStreamRequest>() {
@Override
public Map<String, String> extract(Storage.SplitReadStreamRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"original_stream.name",
String.valueOf(request.getOriginalStream().getName()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"original_stream.name",
String.valueOf(request.getOriginalStream().getName()));
return params.build();
})
.build();

Expand Down
3 changes: 1 addition & 2 deletions ...age/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java
View file
Expand Up @@ -170,14 +170,13 @@ public BigQueryReadStubSettings.Builder getStubSettingsBuilder() {
return ((BigQueryReadStubSettings.Builder) getStubSettings());
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
Expand Down
3 changes: 1 addition & 2 deletions ...torage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteSettings.java
View file
Expand Up @@ -185,14 +185,13 @@ public BigQueryWriteStubSettings.Builder getStubSettingsBuilder() {
return ((BigQueryWriteStubSettings.Builder) getStubSettings());
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
Expand Down
3 changes: 1 addition & 2 deletions ...rc/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java
View file
Expand Up @@ -324,14 +324,13 @@ private static Builder initDefaults(Builder builder) {
return builder;
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
return this;
}
Expand Down
3 changes: 1 addition & 2 deletions ...c/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStubSettings.java
View file
Expand Up @@ -386,14 +386,13 @@ private static Builder initDefaults(Builder builder) {
return builder;
}

// NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) {
super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
return this;
}
Expand Down
37 changes: 13 additions & 24 deletions ...ge/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadStub.java
View file
Expand Up @@ -22,7 +22,6 @@
import com.google.api.gax.grpc.GrpcCallSettings;
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest;
Expand All @@ -36,7 +35,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

Expand Down Expand Up @@ -132,41 +130,32 @@ protected GrpcBigQueryReadStub(
GrpcCallSettings.<CreateReadSessionRequest, ReadSession>newBuilder()
.setMethodDescriptor(createReadSessionMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<CreateReadSessionRequest>() {
@Override
public Map<String, String> extract(CreateReadSessionRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"read_session.table", String.valueOf(request.getReadSession().getTable()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"read_session.table", String.valueOf(request.getReadSession().getTable()));
return params.build();
})
.build();
GrpcCallSettings<ReadRowsRequest, ReadRowsResponse> readRowsTransportSettings =
GrpcCallSettings.<ReadRowsRequest, ReadRowsResponse>newBuilder()
.setMethodDescriptor(readRowsMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<ReadRowsRequest>() {
@Override
public Map<String, String> extract(ReadRowsRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("read_stream", String.valueOf(request.getReadStream()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("read_stream", String.valueOf(request.getReadStream()));
return params.build();
})
.build();
GrpcCallSettings<SplitReadStreamRequest, SplitReadStreamResponse>
splitReadStreamTransportSettings =
GrpcCallSettings.<SplitReadStreamRequest, SplitReadStreamResponse>newBuilder()
.setMethodDescriptor(splitReadStreamMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<SplitReadStreamRequest>() {
@Override
public Map<String, String> extract(SplitReadStreamRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
}
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();

Expand Down

0 comments on commit 2e944d2

Please sign in to comment.