Skip to content

Commit 6ed0dfe

Browse files
---
yaml --- r: 19047 b: refs/heads/autosynth-bigquerydatatransfer c: f7f692f h: refs/heads/master i: 19045: ea88821 19043: 83eebc9 19039: 054a450
1 parent 6bd134d commit 6ed0dfe

2 files changed

Lines changed: 16 additions & 7 deletions

File tree

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ refs/tags/v0.68.0: 9cc799fcf68c82ab431d425fefa58ef615ce8e5b
123123
refs/tags/v0.69.0: 78f67a29e8b9c46ba01de566a2eae0fd1c03edea
124124
refs/heads/autosynth-asset: cd8251de8c40e239ad24dcf9ed93ea2708a3eed5
125125
refs/heads/autosynth-automl: 2a8b018cf05811fd472e5d1053e67a12ceec0b64
126-
refs/heads/autosynth-bigquerydatatransfer: c66160837bfc72dae3cb423049feb92a142c91db
126+
refs/heads/autosynth-bigquerydatatransfer: f7f692f2e6d839487042b3167a81abea2a9803d6
127127
refs/heads/autosynth-bigquerystorage: 14ab055598b943ae3f33f484e9fb1653355d08e7
128128
refs/heads/autosynth-bigtable: 2fbcb15847e0e89e79d6dc07420e28d7dfcea894
129129
refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca

branches/autosynth-bigquerydatatransfer/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStubSettings.java

Lines changed: 15 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import com.google.api.gax.rpc.ServerStreamingCallSettings;
2727
import com.google.api.gax.rpc.StatusCode.Code;
2828
import com.google.api.gax.rpc.StubSettings;
29+
import com.google.api.gax.rpc.TransportChannelProvider;
2930
import com.google.api.gax.rpc.UnaryCallSettings;
3031
import com.google.cloud.bigtable.data.v2.internal.DummyBatchingDescriptor;
3132
import com.google.cloud.bigtable.data.v2.models.ConditionalRowMutation;
@@ -176,6 +177,19 @@ public String getAppProfileId() {
176177
return appProfileId;
177178
}
178179

180+
/** Returns a builder for the default ChannelProvider for this service. */
181+
public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
182+
return BigtableStubSettings.defaultGrpcTransportProviderBuilder()
183+
// TODO: tune channels
184+
.setChannelsPerCpu(2)
185+
.setMaxInboundMessageSize(MAX_MESSAGE_SIZE);
186+
}
187+
188+
@SuppressWarnings("WeakerAccess")
189+
public static TransportChannelProvider defaultTransportChannelProvider() {
190+
return defaultGrpcTransportProviderBuilder().build();
191+
}
192+
179193
/** Returns a builder for the default credentials for this service. */
180194
public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() {
181195
return BigtableStubSettings.defaultCredentialsProviderBuilder()
@@ -260,12 +274,7 @@ private Builder() {
260274
BigtableStubSettings.Builder baseDefaults = BigtableStubSettings.newBuilder();
261275

262276
setEndpoint(baseDefaults.getEndpoint());
263-
setTransportChannelProvider(
264-
InstantiatingGrpcChannelProvider.newBuilder()
265-
// TODO: tune channels
266-
.setChannelsPerCpu(2)
267-
.setMaxInboundMessageSize(MAX_MESSAGE_SIZE)
268-
.build());
277+
setTransportChannelProvider(defaultTransportChannelProvider());
269278
setStreamWatchdogCheckInterval(baseDefaults.getStreamWatchdogCheckInterval());
270279
setStreamWatchdogProvider(baseDefaults.getStreamWatchdogProvider());
271280

0 commit comments

Comments
 (0)