Skip to content
This repository was archived by the owner on May 8, 2026. It is now read-only.

Commit 979d668

Browse files
chore: generate libraries at Wed Apr 15 19:50:31 UTC 2026
1 parent baaac6c commit 979d668

5 files changed

Lines changed: 48 additions & 31 deletions

File tree

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminClientV2.java

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -46,12 +46,13 @@ protected BigtableTableAdminClientV2(BigtableTableAdminStub stub) {
4646
}
4747

4848
/** Constructs an instance of BigtableTableAdminClientV2 with the given settings. */
49-
public static final BigtableTableAdminClientV2 createClient(BaseBigtableTableAdminSettings settings)
50-
throws IOException {
49+
public static final BigtableTableAdminClientV2 createClient(
50+
BaseBigtableTableAdminSettings settings) throws IOException {
5151
// Explicitly create the enhanced stub
5252
EnhancedBigtableTableAdminStub stub =
5353
EnhancedBigtableTableAdminStub.createEnhanced(
54-
(com.google.cloud.bigtable.admin.v2.stub.BigtableTableAdminStubSettings) settings.getStubSettings());
54+
(com.google.cloud.bigtable.admin.v2.stub.BigtableTableAdminStubSettings)
55+
settings.getStubSettings());
5556
// Pass the enhanced stub to the existing stub-based constructor
5657
return new BigtableTableAdminClientV2(stub);
5758
}
@@ -89,7 +90,9 @@ public ApiFuture<Empty> awaitOptimizeRestoredTable(ApiFuture<RestoredTableResult
8990
}
9091

9192
// 3. Return the future for the optimization operation
92-
return ((EnhancedBigtableTableAdminStub) getStub()).awaitOptimizeRestoredTableCallable().resumeFutureCall(token.getOperationName());
93+
return ((EnhancedBigtableTableAdminStub) getStub())
94+
.awaitOptimizeRestoredTableCallable()
95+
.resumeFutureCall(token.getOperationName());
9396
}
9497

9598
/**
@@ -137,7 +140,9 @@ public void awaitOptimizeRestoredTable(OptimizeRestoredTableOperationToken token
137140
public ApiFuture<Void> awaitOptimizeRestoredTableAsync(
138141
OptimizeRestoredTableOperationToken token) {
139142
ApiFuture<Empty> emptyFuture =
140-
((EnhancedBigtableTableAdminStub) getStub()).awaitOptimizeRestoredTableCallable().resumeFutureCall(token.getOperationName());
143+
((EnhancedBigtableTableAdminStub) getStub())
144+
.awaitOptimizeRestoredTableCallable()
145+
.resumeFutureCall(token.getOperationName());
141146
return ApiFutures.transform(
142147
emptyFuture,
143148
new com.google.api.core.ApiFunction<Empty, Void>() {
@@ -158,7 +163,8 @@ public Void apply(Empty input) {
158163
* @param consistencyToken The token to poll.
159164
*/
160165
public void waitForConsistency(String tableName, String consistencyToken) {
161-
ApiExceptions.callAndTranslateApiException(waitForConsistencyAsync(tableName, consistencyToken));
166+
ApiExceptions.callAndTranslateApiException(
167+
waitForConsistencyAsync(tableName, consistencyToken));
162168
}
163169

164170
/**
@@ -169,7 +175,8 @@ public void waitForConsistency(String tableName, String consistencyToken) {
169175
* @param consistencyToken The token to poll.
170176
*/
171177
public ApiFuture<Void> waitForConsistencyAsync(String tableName, String consistencyToken) {
172-
return ((EnhancedBigtableTableAdminStub) getStub()).awaitConsistencyCallable()
178+
return ((EnhancedBigtableTableAdminStub) getStub())
179+
.awaitConsistencyCallable()
173180
.futureCall(ConsistencyRequest.forReplicationFromTableName(tableName, consistencyToken));
174181
}
175182
}

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/models/ConsistencyRequest.java

Lines changed: 22 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,10 @@ public static ConsistencyRequest forReplication(String tableId, String consisten
6161
Preconditions.checkNotNull(consistencyToken, "consistencyToken must not be null");
6262

6363
return new AutoValue_ConsistencyRequest(
64-
tableId, CheckConsistencyRequest.ModeCase.STANDARD_READ_REMOTE_WRITES, consistencyToken, false);
64+
tableId,
65+
CheckConsistencyRequest.ModeCase.STANDARD_READ_REMOTE_WRITES,
66+
consistencyToken,
67+
false);
6568
}
6669

6770
public static ConsistencyRequest forDataBoost(String tableId) {
@@ -76,17 +79,23 @@ public static ConsistencyRequest forReplicationFromTableName(String tableName) {
7679
}
7780

7881
@InternalApi
79-
public static ConsistencyRequest forReplicationFromTableName(String tableName, String consistencyToken) {
82+
public static ConsistencyRequest forReplicationFromTableName(
83+
String tableName, String consistencyToken) {
8084
Preconditions.checkNotNull(consistencyToken, "consistencyToken must not be null");
8185

8286
return new AutoValue_ConsistencyRequest(
83-
tableName, CheckConsistencyRequest.ModeCase.STANDARD_READ_REMOTE_WRITES, consistencyToken, true);
87+
tableName,
88+
CheckConsistencyRequest.ModeCase.STANDARD_READ_REMOTE_WRITES,
89+
consistencyToken,
90+
true);
8491
}
8592

8693
@InternalApi
8794
public CheckConsistencyRequest toCheckConsistencyProto(
8895
TableAdminRequestContext requestContext, String token) {
89-
Preconditions.checkState(!isFullyQualified(), "Use toCheckConsistencyProto(String token) for fully qualified table names.");
96+
Preconditions.checkState(
97+
!isFullyQualified(),
98+
"Use toCheckConsistencyProto(String token) for fully qualified table names.");
9099
CheckConsistencyRequest.Builder builder = CheckConsistencyRequest.newBuilder();
91100
TableName tableName =
92101
TableName.of(requestContext.getProjectId(), requestContext.getInstanceId(), getTableId());
@@ -102,7 +111,10 @@ public CheckConsistencyRequest toCheckConsistencyProto(
102111

103112
@InternalApi
104113
public CheckConsistencyRequest toCheckConsistencyProto(String token) {
105-
Preconditions.checkState(isFullyQualified(), "Use toCheckConsistencyProto(TableAdminRequestContext, String) for non-qualified table names.");
114+
Preconditions.checkState(
115+
isFullyQualified(),
116+
"Use toCheckConsistencyProto(TableAdminRequestContext, String) for non-qualified table"
117+
+ " names.");
106118
CheckConsistencyRequest.Builder builder = CheckConsistencyRequest.newBuilder();
107119

108120
if (getMode().equals(CheckConsistencyRequest.ModeCase.STANDARD_READ_REMOTE_WRITES)) {
@@ -117,7 +129,8 @@ public CheckConsistencyRequest toCheckConsistencyProto(String token) {
117129
@InternalApi
118130
public GenerateConsistencyTokenRequest toGenerateTokenProto(
119131
TableAdminRequestContext requestContext) {
120-
Preconditions.checkState(!isFullyQualified(), "Use toGenerateTokenProto() for fully qualified table names.");
132+
Preconditions.checkState(
133+
!isFullyQualified(), "Use toGenerateTokenProto() for fully qualified table names.");
121134
GenerateConsistencyTokenRequest.Builder builder = GenerateConsistencyTokenRequest.newBuilder();
122135
TableName tableName =
123136
TableName.of(requestContext.getProjectId(), requestContext.getInstanceId(), getTableId());
@@ -127,7 +140,9 @@ public GenerateConsistencyTokenRequest toGenerateTokenProto(
127140

128141
@InternalApi
129142
public GenerateConsistencyTokenRequest toGenerateTokenProto() {
130-
Preconditions.checkState(isFullyQualified(), "Use toGenerateTokenProto(TableAdminRequestContext) for non-qualified table names.");
143+
Preconditions.checkState(
144+
isFullyQualified(),
145+
"Use toGenerateTokenProto(TableAdminRequestContext) for non-qualified table names.");
131146
GenerateConsistencyTokenRequest.Builder builder = GenerateConsistencyTokenRequest.newBuilder();
132147
return builder.setName(getTableId()).build();
133148
}

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/stub/EnhancedBigtableTableAdminStub.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,7 @@ public class EnhancedBigtableTableAdminStub extends GrpcBigtableTableAdminStub {
5454
private final BigtableTableAdminStubSettings settings;
5555
private final ClientContext clientContext;
5656

57-
@javax.annotation.Nullable
58-
private final TableAdminRequestContext requestContext;
57+
@javax.annotation.Nullable private final TableAdminRequestContext requestContext;
5958

6059
@Deprecated private final AwaitReplicationCallable awaitReplicationCallable;
6160

@@ -64,10 +63,8 @@ public class EnhancedBigtableTableAdminStub extends GrpcBigtableTableAdminStub {
6463
optimizeRestoredTableOperationBaseCallable;
6564

6665
public static EnhancedBigtableTableAdminStub createEnhanced(
67-
BigtableTableAdminStubSettings settings)
68-
throws IOException {
69-
return new EnhancedBigtableTableAdminStub(
70-
settings, ClientContext.create(settings), null);
66+
BigtableTableAdminStubSettings settings) throws IOException {
67+
return new EnhancedBigtableTableAdminStub(settings, ClientContext.create(settings), null);
7168
}
7269

7370
public static EnhancedBigtableTableAdminStub createEnhanced(

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BigtableInstanceAdminClientV2Test.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,15 +30,14 @@ public class BigtableInstanceAdminClientV2Test {
3030
public void testCreateWithStub() {
3131
BigtableInstanceAdminStub mockStub = Mockito.mock(BigtableInstanceAdminStub.class);
3232
BigtableInstanceAdminClientV2 client = BigtableInstanceAdminClientV2.createClient(mockStub);
33-
33+
3434
assertThat(client).isNotNull();
3535
}
3636

3737
@Test
3838
public void testCreateClientWithSettings() throws Exception {
3939
BaseBigtableInstanceAdminSettings settings =
40-
BaseBigtableInstanceAdminSettings.newBuilder()
41-
.build();
40+
BaseBigtableInstanceAdminSettings.newBuilder().build();
4241
try (BigtableInstanceAdminClientV2 settingsClient =
4342
BigtableInstanceAdminClientV2.createClient(settings)) {
4443
assertThat(settingsClient).isNotNull();

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminClientV2Test.java

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -44,12 +44,12 @@
4444
public class BigtableTableAdminClientV2Test {
4545
@Rule public final MockitoRule mockitoRule = MockitoJUnit.rule();
4646

47-
private static final String TABLE_NAME = "projects/my-project/instances/my-instance/tables/my-table";
47+
private static final String TABLE_NAME =
48+
"projects/my-project/instances/my-instance/tables/my-table";
4849

4950
@Mock private EnhancedBigtableTableAdminStub mockStub;
5051

51-
@Mock
52-
private UnaryCallable<ConsistencyRequest, Void> mockAwaitConsistencyCallable;
52+
@Mock private UnaryCallable<ConsistencyRequest, Void> mockAwaitConsistencyCallable;
5353

5454
@Mock
5555
private OperationCallable<Void, Empty, OptimizeRestoredTableMetadata>
@@ -68,7 +68,8 @@ public void testWaitForConsistencyWithToken() {
6868
Mockito.when(mockStub.awaitConsistencyCallable()).thenReturn(mockAwaitConsistencyCallable);
6969

7070
String token = "my-token";
71-
ConsistencyRequest expectedRequest = ConsistencyRequest.forReplicationFromTableName(TABLE_NAME, token);
71+
ConsistencyRequest expectedRequest =
72+
ConsistencyRequest.forReplicationFromTableName(TABLE_NAME, token);
7273

7374
final AtomicBoolean wasCalled = new AtomicBoolean(false);
7475

@@ -141,14 +142,12 @@ public void testAwaitOptimizeRestoredTable_NoOp() throws Exception {
141142

142143
@Test
143144
public void testCreateClientWithSettings() throws Exception {
144-
BaseBigtableTableAdminSettings settings =
145-
BaseBigtableTableAdminSettings.newBuilder()
146-
.build();
145+
BaseBigtableTableAdminSettings settings = BaseBigtableTableAdminSettings.newBuilder().build();
147146
try (BigtableTableAdminClientV2 settingsClient =
148147
BigtableTableAdminClientV2.createClient(settings)) {
149148
// Verify that the underlying stub was correctly instantiated as the Enhanced stub
150149
// so that downcasts in the CUJs do not throw a ClassCastException.
151150
assertThat(settingsClient.getStub()).isInstanceOf(EnhancedBigtableTableAdminStub.class);
152151
}
153152
}
154-
}
153+
}

0 commit comments

Comments
 (0)