clientStream = func.apply(respond);
- StreamController controller = TestUtils.nullStreamController();
- respond.onStart(controller);
- return clientStream;
- });
- }
-
- /**
- * BidiStreamingCallable isn't functional even though it's a single abstract method.
- *
- * Define a method that can adapt a TriFunc as the required implementation of {@link
- * BidiStreamingCallable#internalCall(ResponseObserver, ClientStreamReadyObserver,
- * ApiCallContext)}.
- *
- *
Saves several lines of boilerplate in each test.
- */
- private static BidiStreamingCallable adapt(
- StreamingStreamTest.TriFunc<
- ResponseObserver,
- ClientStreamReadyObserver,
- ApiCallContext,
- ClientStream>
- func) {
- return new BidiStreamingCallable() {
- @Override
- public ClientStream internalCall(
- ResponseObserver respond,
- ClientStreamReadyObserver onReady,
- ApiCallContext context) {
- return func.apply(respond, onReady, context);
- }
- };
- }
-
- @FunctionalInterface
- interface TriFunc {
- R apply(A a, B b, C c);
- }
}
public static final class BidiUploadStreamingStreamResponseObserverTest {
@@ -2289,18 +2233,4 @@ static BidiWriteObjectRequest flushOffset(long offset) {
}
return BidiWriteObjectResponse.newBuilder().setResource(f.apply(b)).build();
}
-
- @FunctionalInterface
- private interface OnlySendClientStream extends ClientStream {
- @Override
- default void closeSendWithError(Throwable t) {}
-
- @Override
- default void closeSend() {}
-
- @Override
- default boolean isSendReady() {
- return true;
- }
- }
}
diff --git a/google-cloud-storage/src/test/java/com/google/cloud/storage/BidiUploadTestUtils.java b/google-cloud-storage/src/test/java/com/google/cloud/storage/BidiUploadTestUtils.java
index 827f1320d3..110fdd4510 100644
--- a/google-cloud-storage/src/test/java/com/google/cloud/storage/BidiUploadTestUtils.java
+++ b/google-cloud-storage/src/test/java/com/google/cloud/storage/BidiUploadTestUtils.java
@@ -21,12 +21,19 @@
import com.google.api.gax.grpc.GrpcStatusCode;
import com.google.api.gax.rpc.AbortedException;
+import com.google.api.gax.rpc.ApiCallContext;
+import com.google.api.gax.rpc.BidiStreamingCallable;
+import com.google.api.gax.rpc.ClientStream;
+import com.google.api.gax.rpc.ClientStreamReadyObserver;
import com.google.api.gax.rpc.ErrorDetails;
+import com.google.api.gax.rpc.ResponseObserver;
+import com.google.api.gax.rpc.StreamController;
import com.google.cloud.storage.ChunkSegmenter.ChunkSegment;
import com.google.cloud.storage.it.ChecksummedTestContent;
import com.google.common.collect.ImmutableList;
import com.google.protobuf.Any;
import com.google.protobuf.ByteString;
+import com.google.protobuf.Message;
import com.google.protobuf.Timestamp;
import com.google.rpc.Code;
import com.google.storage.v2.BidiWriteObjectRedirectedError;
@@ -39,6 +46,7 @@
import java.nio.ByteBuffer;
import java.time.OffsetDateTime;
import java.util.List;
+import java.util.function.Function;
import org.checkerframework.checker.nullness.qual.NonNull;
final class BidiUploadTestUtils {
@@ -122,4 +130,71 @@ static BidiWriteObjectRequest withFlushAndStateLookup(BidiWriteObjectRequest ori
static Timestamp timestampNow() {
return Conversions.grpc().timestampCodec.encode(OffsetDateTime.now());
}
+
+ static BidiStreamingCallable
+ alwaysErrorBidiStreamingCallable(Status status) {
+ return adaptOnlySend(respond -> request -> respond.onError(status.asRuntimeException()));
+ }
+
+ static BidiStreamingCallable adaptOnlySend(
+ Function, OnlySendClientStream> func) {
+ return adapt(func::apply);
+ }
+
+ static BidiStreamingCallable adapt(
+ Function, ClientStream> func) {
+ return adapt(
+ (respond, onReady, context) -> {
+ ClientStream clientStream = func.apply(respond);
+ StreamController controller = TestUtils.nullStreamController();
+ respond.onStart(controller);
+ return clientStream;
+ });
+ }
+
+ /**
+ * BidiStreamingCallable isn't functional even though it's a single abstract method.
+ *
+ * Define a method that can adapt a TriFunc as the required implementation of {@link
+ * BidiStreamingCallable#internalCall(ResponseObserver, ClientStreamReadyObserver,
+ * ApiCallContext)}.
+ *
+ *
Saves several lines of boilerplate in each test.
+ */
+ static BidiStreamingCallable adapt(
+ TriFunc<
+ ResponseObserver,
+ ClientStreamReadyObserver,
+ ApiCallContext,
+ ClientStream>
+ func) {
+ return new BidiStreamingCallable() {
+ @Override
+ public ClientStream internalCall(
+ ResponseObserver respond,
+ ClientStreamReadyObserver onReady,
+ ApiCallContext context) {
+ return func.apply(respond, onReady, context);
+ }
+ };
+ }
+
+ @FunctionalInterface
+ interface TriFunc {
+ R apply(A a, B b, C c);
+ }
+
+ @FunctionalInterface
+ interface OnlySendClientStream extends ClientStream {
+ @Override
+ default void closeSendWithError(Throwable t) {}
+
+ @Override
+ default void closeSend() {}
+
+ @Override
+ default boolean isSendReady() {
+ return true;
+ }
+ }
}
From f63c8c770ba16444f3cd81ab220c5f355a22171f Mon Sep 17 00:00:00 2001
From: cloud-java-bot <122572305+cloud-java-bot@users.noreply.github.com>
Date: Wed, 17 Sep 2025 10:32:08 -0400
Subject: [PATCH 10/17] chore: Update generation configuration at Wed Sep 17
02:26:46 UTC 2025 (#3294)
* chore: Update generation configuration at Tue Sep 16 02:25:05 UTC 2025
* chore: generate libraries at Tue Sep 16 02:25:39 UTC 2025
* chore: Update generation configuration at Wed Sep 17 02:26:46 UTC 2025
---
README.md | 2 +-
generation_config.yaml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/README.md b/README.md
index 305c76dfd3..82d0352d5c 100644
--- a/README.md
+++ b/README.md
@@ -19,7 +19,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file:
com.google.cloud
libraries-bom
- 26.67.0
+ 26.68.0
pom
import
diff --git a/generation_config.yaml b/generation_config.yaml
index 4a3266aa5c..336cafb17c 100644
--- a/generation_config.yaml
+++ b/generation_config.yaml
@@ -1,5 +1,5 @@
gapic_generator_version: 2.62.1
-googleapis_commitish: c99b529e5ba7aeb0e0be3d47521d9db65d45b8bf
+googleapis_commitish: 9f0cd3d817cac49dce85e353be70fd8dea1f8889
libraries_bom_version: 26.68.0
libraries:
- api_shortname: storage
From 1489f3a74c8a27f0888c40600c83adedcfd9a9ec Mon Sep 17 00:00:00 2001
From: Mend Renovate
Date: Thu, 18 Sep 2025 21:46:08 +0200
Subject: [PATCH 11/17] deps: update dependency
com.google.cloud:sdk-platform-java-config to v3.52.2 (#3298)
---
.github/workflows/unmanaged_dependency_check.yaml | 2 +-
google-cloud-storage-bom/pom.xml | 2 +-
pom.xml | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/.github/workflows/unmanaged_dependency_check.yaml b/.github/workflows/unmanaged_dependency_check.yaml
index fe151dfff2..cf2460525e 100644
--- a/.github/workflows/unmanaged_dependency_check.yaml
+++ b/.github/workflows/unmanaged_dependency_check.yaml
@@ -17,6 +17,6 @@ jobs:
# repository
.kokoro/build.sh
- name: Unmanaged dependency check
- uses: googleapis/sdk-platform-java/java-shared-dependencies/unmanaged-dependency-check@google-cloud-shared-dependencies/v3.52.1
+ uses: googleapis/sdk-platform-java/java-shared-dependencies/unmanaged-dependency-check@google-cloud-shared-dependencies/v3.52.2
with:
bom-path: google-cloud-storage-bom/pom.xml
diff --git a/google-cloud-storage-bom/pom.xml b/google-cloud-storage-bom/pom.xml
index ef1a2fc16b..188afb7cd5 100644
--- a/google-cloud-storage-bom/pom.xml
+++ b/google-cloud-storage-bom/pom.xml
@@ -24,7 +24,7 @@
com.google.cloud
sdk-platform-java-config
- 3.52.1
+ 3.52.2
diff --git a/pom.xml b/pom.xml
index da494e61aa..670bd8d768 100644
--- a/pom.xml
+++ b/pom.xml
@@ -14,7 +14,7 @@
com.google.cloud
sdk-platform-java-config
- 3.52.1
+ 3.52.2
From c3b05ac8798140f9ddcab098948a3a2f3638dc6b Mon Sep 17 00:00:00 2001
From: Mend Renovate
Date: Thu, 18 Sep 2025 21:46:33 +0200
Subject: [PATCH 12/17] deps: update googleapis/sdk-platform-java action to
v2.62.2 (#3299)
---
.github/workflows/hermetic_library_generation.yaml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.github/workflows/hermetic_library_generation.yaml b/.github/workflows/hermetic_library_generation.yaml
index 44c2b4abb1..01d885fae3 100644
--- a/.github/workflows/hermetic_library_generation.yaml
+++ b/.github/workflows/hermetic_library_generation.yaml
@@ -43,7 +43,7 @@ jobs:
with:
fetch-depth: 0
token: ${{ secrets.CLOUD_JAVA_BOT_TOKEN }}
- - uses: googleapis/sdk-platform-java/.github/scripts@v2.62.1
+ - uses: googleapis/sdk-platform-java/.github/scripts@v2.62.2
if: env.SHOULD_RUN == 'true'
with:
base_ref: ${{ github.base_ref }}
From 34e797d4ceaba27c97e753f9e57c2e769523608f Mon Sep 17 00:00:00 2001
From: nidhiii-27
Date: Tue, 23 Sep 2025 00:41:14 +0530
Subject: [PATCH 13/17] samples: add samples for ranged reads and appendable
uploads (#3275)
---
.../AppendableObjectMultipleRangedRead.java | 65 +++++++++++++
.../AppendableObjectReadFullObject.java | 63 +++++++++++++
.../AppendableObjectSingleRangedRead.java | 58 ++++++++++++
.../FinalizeAppendableObjectUpload.java | 64 +++++++++++++
.../object/ResumeAppendableObjectUpload.java | 91 +++++++++++++++++++
.../object/StartAppendableObjectUpload.java | 70 ++++++++++++++
6 files changed, 411 insertions(+)
create mode 100644 samples/snippets/src/main/java/com/example/storage/object/AppendableObjectMultipleRangedRead.java
create mode 100644 samples/snippets/src/main/java/com/example/storage/object/AppendableObjectReadFullObject.java
create mode 100644 samples/snippets/src/main/java/com/example/storage/object/AppendableObjectSingleRangedRead.java
create mode 100644 samples/snippets/src/main/java/com/example/storage/object/FinalizeAppendableObjectUpload.java
create mode 100644 samples/snippets/src/main/java/com/example/storage/object/ResumeAppendableObjectUpload.java
create mode 100644 samples/snippets/src/main/java/com/example/storage/object/StartAppendableObjectUpload.java
diff --git a/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectMultipleRangedRead.java b/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectMultipleRangedRead.java
new file mode 100644
index 0000000000..ce36771ad9
--- /dev/null
+++ b/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectMultipleRangedRead.java
@@ -0,0 +1,65 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.storage.object;
+
+// [START storage_read_appendable_object_multiple_ranges]
+
+import com.google.api.core.ApiFuture;
+import com.google.api.core.ApiFutures;
+import com.google.cloud.storage.BlobId;
+import com.google.cloud.storage.BlobReadSession;
+import com.google.cloud.storage.RangeSpec;
+import com.google.cloud.storage.ReadProjectionConfigs;
+import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.StorageOptions;
+import com.google.common.collect.ImmutableList;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+public class AppendableObjectMultipleRangedRead {
+ public static void appendableObjectMultipleRangedRead(
+ String bucketName, String objectName, long offset1, int length1, long offset2, int length2)
+ throws Exception {
+ try (Storage storage = StorageOptions.grpc().build().getService()) {
+ BlobId blobId = BlobId.of(bucketName, objectName);
+ ApiFuture futureBlobReadSession = storage.blobReadSession(blobId);
+ RangeSpec rangeSpec1 = RangeSpec.of(offset1, length1);
+ RangeSpec rangeSpec2 = RangeSpec.of(offset2, length2);
+
+ try (BlobReadSession blobReadSession = futureBlobReadSession.get(10, TimeUnit.SECONDS)) {
+ ApiFuture future1 =
+ blobReadSession.readAs(ReadProjectionConfigs.asFutureBytes().withRangeSpec(rangeSpec1));
+ ApiFuture future2 =
+ blobReadSession.readAs(ReadProjectionConfigs.asFutureBytes().withRangeSpec(rangeSpec2));
+
+ List allBytes = ApiFutures.allAsList(ImmutableList.of(future1, future2)).get();
+
+ byte[] bytes1 = allBytes.get(0);
+ byte[] bytes2 = allBytes.get(1);
+
+ System.out.println(
+ "Successfully read "
+ + bytes1.length
+ + " bytes from range 1 and "
+ + bytes2.length
+ + " bytes from range 2.");
+ }
+ }
+ }
+}
+
+// [END storage_read_appendable_object_multiple_ranges]
diff --git a/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectReadFullObject.java b/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectReadFullObject.java
new file mode 100644
index 0000000000..0b24051ca6
--- /dev/null
+++ b/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectReadFullObject.java
@@ -0,0 +1,63 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.storage.object;
+
+// [START storage_read_appendable_object_full]
+
+import com.google.api.core.ApiFuture;
+import com.google.cloud.storage.BlobId;
+import com.google.cloud.storage.BlobReadSession;
+import com.google.cloud.storage.ReadAsChannel;
+import com.google.cloud.storage.ReadProjectionConfigs;
+import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.StorageOptions;
+import java.nio.ByteBuffer;
+import java.nio.channels.ScatteringByteChannel;
+import java.util.Locale;
+import java.util.concurrent.TimeUnit;
+
+public class AppendableObjectReadFullObject {
+ public static void appendableObjectReadFullObject(String bucketName, String objectName)
+ throws Exception {
+ try (Storage storage = StorageOptions.grpc().build().getService()) {
+ BlobId blobId = BlobId.of(bucketName, objectName);
+ ApiFuture futureBlobReadSession = storage.blobReadSession(blobId);
+
+ try (BlobReadSession blobReadSession = futureBlobReadSession.get(10, TimeUnit.SECONDS)) {
+
+ ReadAsChannel readAsChannelConfig = ReadProjectionConfigs.asChannel();
+ try (ScatteringByteChannel channel = blobReadSession.readAs(readAsChannelConfig)) {
+ long totalBytesRead = 0;
+ ByteBuffer buffer = ByteBuffer.allocate(64 * 1024);
+ int bytesRead;
+
+ while ((bytesRead = channel.read(buffer)) != -1) {
+ totalBytesRead += bytesRead;
+ buffer.clear();
+ }
+
+ System.out.printf(
+ Locale.US,
+ "Successfully read a total of %d bytes from object %s%n",
+ totalBytesRead,
+ blobId.toGsUtilUri());
+ }
+ }
+ }
+ }
+}
+// [END storage_read_appendable_object_full]
diff --git a/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectSingleRangedRead.java b/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectSingleRangedRead.java
new file mode 100644
index 0000000000..437f47203f
--- /dev/null
+++ b/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectSingleRangedRead.java
@@ -0,0 +1,58 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.storage.object;
+
+// [START storage_read_appendable_object_single_range]
+
+import com.google.api.core.ApiFuture;
+import com.google.cloud.storage.BlobId;
+import com.google.cloud.storage.BlobReadSession;
+import com.google.cloud.storage.RangeSpec;
+import com.google.cloud.storage.ReadProjectionConfigs;
+import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.StorageOptions;
+import java.util.concurrent.TimeUnit;
+
+public class AppendableObjectSingleRangedRead {
+ public static void appendableObjectSingleRangedRead(
+ String bucketName, String objectName, long offset, int length) throws Exception {
+
+ try (Storage storage = StorageOptions.grpc().build().getService()) {
+ BlobId blobId = BlobId.of(bucketName, objectName);
+ ApiFuture futureBlobReadSession = storage.blobReadSession(blobId);
+
+ try (BlobReadSession blobReadSession = futureBlobReadSession.get(10, TimeUnit.SECONDS)) {
+ // Define the range of bytes to read.
+ RangeSpec rangeSpec = RangeSpec.of(offset, length);
+ ApiFuture future =
+ blobReadSession.readAs(ReadProjectionConfigs.asFutureBytes().withRangeSpec(rangeSpec));
+
+ // Wait for the read to complete.
+ byte[] bytes = future.get();
+
+ System.out.println(
+ "Successfully read "
+ + bytes.length
+ + " bytes from object "
+ + objectName
+ + " in bucket "
+ + bucketName);
+ }
+ }
+ }
+}
+// [END storage_read_appendable_object_single_range]
diff --git a/samples/snippets/src/main/java/com/example/storage/object/FinalizeAppendableObjectUpload.java b/samples/snippets/src/main/java/com/example/storage/object/FinalizeAppendableObjectUpload.java
new file mode 100644
index 0000000000..161a2272cf
--- /dev/null
+++ b/samples/snippets/src/main/java/com/example/storage/object/FinalizeAppendableObjectUpload.java
@@ -0,0 +1,64 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.storage.object;
+
+// [START storage_finalize_appendable_object_upload]
+
+import com.google.cloud.storage.Blob;
+import com.google.cloud.storage.BlobAppendableUpload;
+import com.google.cloud.storage.BlobAppendableUploadConfig;
+import com.google.cloud.storage.BlobId;
+import com.google.cloud.storage.BlobInfo;
+import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.StorageOptions;
+
+public class FinalizeAppendableObjectUpload {
+ public static void finalizeAppendableObjectUpload(String bucketName, String objectName)
+ throws Exception {
+ // The ID of your GCS bucket
+ // String bucketName = "your-unique-bucket-name";
+
+ // The ID of your GCS unfinalized appendable object
+ // String objectName = "your-object-name";
+
+ try (Storage storage = StorageOptions.grpc().build().getService()) {
+ BlobId blobId = BlobId.of(bucketName, objectName);
+ Blob existingBlob = storage.get(blobId);
+
+ if (existingBlob == null) {
+ System.out.println("Object " + objectName + " not found in bucket " + bucketName);
+ return;
+ }
+
+ BlobInfo blobInfoForTakeover = BlobInfo.newBuilder(existingBlob.getBlobId()).build();
+ BlobAppendableUpload finalizingSession =
+ storage.blobAppendableUpload(
+ blobInfoForTakeover,
+ BlobAppendableUploadConfig.of()
+ .withCloseAction(BlobAppendableUploadConfig.CloseAction.FINALIZE_WHEN_CLOSING));
+
+ try (BlobAppendableUpload.AppendableUploadWriteableByteChannel channel =
+ finalizingSession.open()) {
+ channel.finalizeAndClose();
+ }
+
+ System.out.println(
+ "Successfully finalized object " + objectName + " in bucket " + bucketName);
+ }
+ }
+}
+// [END storage_finalize_appendable_object_upload]
diff --git a/samples/snippets/src/main/java/com/example/storage/object/ResumeAppendableObjectUpload.java b/samples/snippets/src/main/java/com/example/storage/object/ResumeAppendableObjectUpload.java
new file mode 100644
index 0000000000..8852b585d8
--- /dev/null
+++ b/samples/snippets/src/main/java/com/example/storage/object/ResumeAppendableObjectUpload.java
@@ -0,0 +1,91 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.storage.object;
+
+// [START storage_resume_appendable_object_upload]
+
+import com.google.cloud.storage.Blob;
+import com.google.cloud.storage.BlobAppendableUpload;
+import com.google.cloud.storage.BlobAppendableUpload.AppendableUploadWriteableByteChannel;
+import com.google.cloud.storage.BlobAppendableUploadConfig;
+import com.google.cloud.storage.BlobAppendableUploadConfig.CloseAction;
+import com.google.cloud.storage.BlobId;
+import com.google.cloud.storage.BlobInfo;
+import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.StorageOptions;
+import com.google.common.io.ByteStreams;
+import java.io.IOException;
+import java.nio.channels.FileChannel;
+import java.nio.file.Paths;
+import java.util.Locale;
+
+public class ResumeAppendableObjectUpload {
+ public static void resumeAppendableObjectUpload(
+ String bucketName, String objectName, String filePath) throws Exception {
+ // The ID of your GCS bucket
+ // String bucketName = "your-unique-bucket-name";
+
+ // The ID of your GCS unfinalized appendable object
+ // String objectName = "your-object-name";
+
+ // The path to the file to upload
+ // String filePath = "path/to/your/file";
+
+ try (Storage storage = StorageOptions.grpc().build().getService()) {
+ BlobId blobId = BlobId.of(bucketName, objectName);
+ Blob existingBlob = storage.get(blobId);
+ BlobInfo blobInfoForTakeover = BlobInfo.newBuilder(existingBlob.getBlobId()).build();
+
+ long currentObjectSize = existingBlob.getSize();
+ System.out.printf(
+ Locale.US,
+ "Resuming upload for %s. Currently uploaded size: %d bytes\n",
+ blobId.toGsUtilUri(),
+ currentObjectSize);
+
+ BlobAppendableUploadConfig config =
+ BlobAppendableUploadConfig.of().withCloseAction(CloseAction.CLOSE_WITHOUT_FINALIZING);
+ BlobAppendableUpload resumeUploadSession =
+ storage.blobAppendableUpload(blobInfoForTakeover, config);
+ try (FileChannel fileChannel = FileChannel.open(Paths.get(filePath));
+ AppendableUploadWriteableByteChannel channel = resumeUploadSession.open()) {
+
+ if (fileChannel.size() < currentObjectSize) {
+ throw new IOException(
+ "Local file is smaller than the already uploaded data. File size: "
+ + fileChannel.size()
+ + ", Uploaded size: "
+ + currentObjectSize);
+ } else if (fileChannel.size() == currentObjectSize) {
+ System.out.println("No more data to upload.");
+ } else {
+ fileChannel.position(currentObjectSize);
+ System.out.printf(
+ Locale.US, "Appending %d bytes\n", fileChannel.size() - currentObjectSize);
+ ByteStreams.copy(fileChannel, channel);
+ }
+ }
+ BlobInfo result = storage.get(blobId);
+ System.out.printf(
+ Locale.US,
+ "Object %s successfully resumed. Total size: %d\n",
+ result.getBlobId().toGsUtilUriWithGeneration(),
+ result.getSize());
+ }
+ }
+}
+// [END storage_resume_appendable_object_upload]
diff --git a/samples/snippets/src/main/java/com/example/storage/object/StartAppendableObjectUpload.java b/samples/snippets/src/main/java/com/example/storage/object/StartAppendableObjectUpload.java
new file mode 100644
index 0000000000..cda8b7c898
--- /dev/null
+++ b/samples/snippets/src/main/java/com/example/storage/object/StartAppendableObjectUpload.java
@@ -0,0 +1,70 @@
+/*
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.storage.object;
+
+// [START storage_start_appendable_object_upload]
+
+import com.google.cloud.storage.BlobAppendableUpload;
+import com.google.cloud.storage.BlobAppendableUpload.AppendableUploadWriteableByteChannel;
+import com.google.cloud.storage.BlobAppendableUploadConfig;
+import com.google.cloud.storage.BlobAppendableUploadConfig.CloseAction;
+import com.google.cloud.storage.BlobId;
+import com.google.cloud.storage.BlobInfo;
+import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.StorageOptions;
+import com.google.common.io.ByteStreams;
+import java.io.IOException;
+import java.nio.channels.FileChannel;
+import java.nio.channels.ReadableByteChannel;
+import java.nio.file.Paths;
+import java.util.Locale;
+
+public class StartAppendableObjectUpload {
+ public static void startAppendableObjectUpload(
+ String bucketName, String objectName, String filePath) throws Exception {
+ // The ID of your GCS bucket
+ // String bucketName = "your-unique-bucket-name";
+
+ // The ID of your GCS object
+ // String objectName = "your-object-name";
+
+ // The path to the file to upload
+ // String filePath = "path/to/your/file";
+
+ try (Storage storage = StorageOptions.grpc().build().getService()) {
+ BlobId blobId = BlobId.of(bucketName, objectName);
+ BlobInfo blobInfo = BlobInfo.newBuilder(blobId).build();
+
+ BlobAppendableUploadConfig config =
+ BlobAppendableUploadConfig.of().withCloseAction(CloseAction.CLOSE_WITHOUT_FINALIZING);
+ BlobAppendableUpload uploadSession = storage.blobAppendableUpload(blobInfo, config);
+ try (AppendableUploadWriteableByteChannel channel = uploadSession.open();
+ ReadableByteChannel readableByteChannel = FileChannel.open(Paths.get(filePath))) {
+ ByteStreams.copy(readableByteChannel, channel);
+ } catch (IOException ex) {
+ throw new IOException("Failed to upload to object " + blobId.toGsUtilUri(), ex);
+ }
+ BlobInfo result = storage.get(blobId);
+ System.out.printf(
+ Locale.US,
+ "Object %s successfully uploaded",
+ result.getBlobId().toGsUtilUriWithGeneration());
+ }
+ }
+}
+
+// [END storage_start_appendable_object_upload]
From aa904688b784d7427454318196ef88628e415246 Mon Sep 17 00:00:00 2001
From: BenWhitehead
Date: Mon, 22 Sep 2025 16:16:23 -0400
Subject: [PATCH 14/17] fix: fix IllegalMonitorStateException thrown from
BlobAppendableUpload.isOpen() (#3302)
FileChannel.transferTo first checks if the destination is open. Our tests didn't catch this before because they did not probe openness before writing bytes.
---
.../com/google/cloud/storage/BlobAppendableUploadImpl.java | 1 +
.../java/com/google/cloud/storage/ITAppendableUploadTest.java | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobAppendableUploadImpl.java b/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobAppendableUploadImpl.java
index cc3bac3f1a..5445473e6a 100644
--- a/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobAppendableUploadImpl.java
+++ b/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobAppendableUploadImpl.java
@@ -111,6 +111,7 @@ public int write(ByteBuffer src) throws IOException {
@Override
public boolean isOpen() {
+ lock.lock();
try {
return buffered.isOpen();
} finally {
diff --git a/google-cloud-storage/src/test/java/com/google/cloud/storage/ITAppendableUploadTest.java b/google-cloud-storage/src/test/java/com/google/cloud/storage/ITAppendableUploadTest.java
index 2e2b7da788..9e3ae209fb 100644
--- a/google-cloud-storage/src/test/java/com/google/cloud/storage/ITAppendableUploadTest.java
+++ b/google-cloud-storage/src/test/java/com/google/cloud/storage/ITAppendableUploadTest.java
@@ -15,7 +15,6 @@
*/
package com.google.cloud.storage;
-import static com.google.cloud.storage.ByteSizeConstants._1MiB;
import static com.google.cloud.storage.TestUtils.assertAll;
import static com.google.cloud.storage.TestUtils.xxd;
import static com.google.common.truth.Truth.assertThat;
@@ -44,6 +43,7 @@
import com.google.cloud.storage.it.runner.registry.Generator;
import com.google.common.base.MoreObjects;
import com.google.common.collect.ImmutableList;
+import com.google.common.io.ByteStreams;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SeekableByteChannel;
@@ -222,7 +222,7 @@ public void testUploadFileUsingAppendable() throws Exception {
storage.blobAppendableUpload(BlobInfo.newBuilder(bid).build(), p.uploadConfig);
try (SeekableByteChannel r = tmpFile.reader();
AppendableUploadWriteableByteChannel w = appendable.open()) {
- long copied = Buffers.copyUsingBuffer(Buffers.allocate(8 * _1MiB), r, w);
+ long copied = ByteStreams.copy(r, w);
assertThat(copied).isEqualTo(fileSize);
}
BlobInfo bi = appendable.getResult().get(5, TimeUnit.SECONDS);
From 984f8ca23a38c7a892a2256a694b72431e44aa27 Mon Sep 17 00:00:00 2001
From: cloud-java-bot <122572305+cloud-java-bot@users.noreply.github.com>
Date: Tue, 23 Sep 2025 12:47:03 -0400
Subject: [PATCH 15/17] chore: Update generation configuration at Tue Sep 23
02:27:50 UTC 2025 (#3297)
* chore: Update generation configuration at Thu Sep 18 02:26:00 UTC 2025
* chore: Update generation configuration at Fri Sep 19 02:27:11 UTC 2025
* chore: generate libraries at Fri Sep 19 02:27:40 UTC 2025
* chore: Update generation configuration at Sat Sep 20 02:23:59 UTC 2025
* chore: Update generation configuration at Tue Sep 23 02:27:50 UTC 2025
* chore: generate libraries at Tue Sep 23 02:28:19 UTC 2025
---
.kokoro/presubmit/graalvm-native-a.cfg | 2 +-
.kokoro/presubmit/graalvm-native-b.cfg | 2 +-
.kokoro/presubmit/graalvm-native-c.cfg | 2 +-
README.md | 6 ++++++
generation_config.yaml | 4 ++--
5 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/.kokoro/presubmit/graalvm-native-a.cfg b/.kokoro/presubmit/graalvm-native-a.cfg
index a562a6398b..5554627daa 100644
--- a/.kokoro/presubmit/graalvm-native-a.cfg
+++ b/.kokoro/presubmit/graalvm-native-a.cfg
@@ -3,7 +3,7 @@
# Configure the docker image for kokoro-trampoline.
env_vars: {
key: "TRAMPOLINE_IMAGE"
- value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.52.1" # {x-version-update:google-cloud-shared-dependencies:current}
+ value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.52.2" # {x-version-update:google-cloud-shared-dependencies:current}
}
env_vars: {
diff --git a/.kokoro/presubmit/graalvm-native-b.cfg b/.kokoro/presubmit/graalvm-native-b.cfg
index 2257ccce67..1089437409 100644
--- a/.kokoro/presubmit/graalvm-native-b.cfg
+++ b/.kokoro/presubmit/graalvm-native-b.cfg
@@ -3,7 +3,7 @@
# Configure the docker image for kokoro-trampoline.
env_vars: {
key: "TRAMPOLINE_IMAGE"
- value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_b:3.52.1" # {x-version-update:google-cloud-shared-dependencies:current}
+ value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_b:3.52.2" # {x-version-update:google-cloud-shared-dependencies:current}
}
env_vars: {
diff --git a/.kokoro/presubmit/graalvm-native-c.cfg b/.kokoro/presubmit/graalvm-native-c.cfg
index a9294de35a..5465e51923 100644
--- a/.kokoro/presubmit/graalvm-native-c.cfg
+++ b/.kokoro/presubmit/graalvm-native-c.cfg
@@ -3,7 +3,7 @@
# Configure the docker image for kokoro-trampoline.
env_vars: {
key: "TRAMPOLINE_IMAGE"
- value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_c:3.52.1" # {x-version-update:google-cloud-shared-dependencies:current}
+ value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_c:3.52.2" # {x-version-update:google-cloud-shared-dependencies:current}
}
env_vars: {
diff --git a/README.md b/README.md
index 82d0352d5c..df3b325f07 100644
--- a/README.md
+++ b/README.md
@@ -321,6 +321,9 @@ Samples are in the [`samples/`](https://github.com/googleapis/java-storage/tree/
| Get Managed Folder | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/managedfolders/GetManagedFolder.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/managedfolders/GetManagedFolder.java) |
| List Managed Folders | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/managedfolders/ListManagedFolders.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/managedfolders/ListManagedFolders.java) |
| Add Blob Owner | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/AddBlobOwner.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/AddBlobOwner.java) |
+| Appendable Object Multiple Ranged Read | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectMultipleRangedRead.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/AppendableObjectMultipleRangedRead.java) |
+| Appendable Object Read Full Object | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectReadFullObject.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/AppendableObjectReadFullObject.java) |
+| Appendable Object Single Ranged Read | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/AppendableObjectSingleRangedRead.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/AppendableObjectSingleRangedRead.java) |
| Atomic Move Object | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/AtomicMoveObject.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/AtomicMoveObject.java) |
| Batch Set Object Metadata | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/BatchSetObjectMetadata.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/BatchSetObjectMetadata.java) |
| Change Object Csek To Kms | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/ChangeObjectCsekToKms.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/ChangeObjectCsekToKms.java) |
@@ -337,6 +340,7 @@ Samples are in the [`samples/`](https://github.com/googleapis/java-storage/tree/
| Download Object Into Memory | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/DownloadObjectIntoMemory.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/DownloadObjectIntoMemory.java) |
| Download Public Object | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/DownloadPublicObject.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/DownloadPublicObject.java) |
| Download Requester Pays Object | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/DownloadRequesterPaysObject.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/DownloadRequesterPaysObject.java) |
+| Finalize Appendable Object Upload | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/FinalizeAppendableObjectUpload.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/FinalizeAppendableObjectUpload.java) |
| Generate Encryption Key | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/GenerateEncryptionKey.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/GenerateEncryptionKey.java) |
| Generate V4 Get Object Signed Url | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/GenerateV4GetObjectSignedUrl.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/GenerateV4GetObjectSignedUrl.java) |
| Generate V4 Put Object Signed Url | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/GenerateV4PutObjectSignedUrl.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/GenerateV4PutObjectSignedUrl.java) |
@@ -353,11 +357,13 @@ Samples are in the [`samples/`](https://github.com/googleapis/java-storage/tree/
| Release Temporary Hold | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/ReleaseTemporaryHold.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/ReleaseTemporaryHold.java) |
| Remove Blob Owner | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/RemoveBlobOwner.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/RemoveBlobOwner.java) |
| Restore Soft Deleted Object | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/RestoreSoftDeletedObject.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/RestoreSoftDeletedObject.java) |
+| Resume Appendable Object Upload | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/ResumeAppendableObjectUpload.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/ResumeAppendableObjectUpload.java) |
| Rotate Object Encryption Key | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/RotateObjectEncryptionKey.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/RotateObjectEncryptionKey.java) |
| Set Event Based Hold | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/SetEventBasedHold.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/SetEventBasedHold.java) |
| Set Object Metadata | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/SetObjectMetadata.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/SetObjectMetadata.java) |
| Set Object Retention Policy | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/SetObjectRetentionPolicy.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/SetObjectRetentionPolicy.java) |
| Set Temporary Hold | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/SetTemporaryHold.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/SetTemporaryHold.java) |
+| Start Appendable Object Upload | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/StartAppendableObjectUpload.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/StartAppendableObjectUpload.java) |
| Stream Object Download | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/StreamObjectDownload.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/StreamObjectDownload.java) |
| Stream Object Upload | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/StreamObjectUpload.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/StreamObjectUpload.java) |
| Upload Encrypted Object | [source code](https://github.com/googleapis/java-storage/blob/main/samples/snippets/src/main/java/com/example/storage/object/UploadEncryptedObject.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-storage&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/storage/object/UploadEncryptedObject.java) |
diff --git a/generation_config.yaml b/generation_config.yaml
index 336cafb17c..10d104bfe0 100644
--- a/generation_config.yaml
+++ b/generation_config.yaml
@@ -1,5 +1,5 @@
-gapic_generator_version: 2.62.1
-googleapis_commitish: 9f0cd3d817cac49dce85e353be70fd8dea1f8889
+gapic_generator_version: 2.62.2
+googleapis_commitish: d89b4d093fa1526255dbc724495c3bdb0e5dd384
libraries_bom_version: 26.68.0
libraries:
- api_shortname: storage
From 2fd15f69e93a3df2b8dbbd4f08edd07c087e957c Mon Sep 17 00:00:00 2001
From: nidhiii-27
Date: Tue, 23 Sep 2025 23:49:28 +0530
Subject: [PATCH 16/17] fix: update object context diff logic to be shallow
rather than deep (#3287)
Previously, deleting an object context key by setting its value to null
would fail. This change corrects the diffMaps utility to ensure that
null payloads are always treated as deletions.
The produced update mask is now `contexts.custom.` instead of
`contexts.custom..value`
---
.../com/google/cloud/storage/BlobInfo.java | 22 +-------
.../com/google/cloud/storage/JsonUtils.java | 37 +++++++-------
.../java/com/google/cloud/storage/Utils.java | 46 +++--------------
.../google/cloud/storage/BlobInfoTest.java | 51 +++++++++++++++++++
.../com/google/cloud/storage/TestUtils.java | 11 ++--
.../storage/it/ITNestedUpdateMaskTest.java | 5 +-
6 files changed, 86 insertions(+), 86 deletions(-)
diff --git a/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobInfo.java b/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobInfo.java
index aa78fa7276..a083338e74 100644
--- a/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobInfo.java
+++ b/google-cloud-storage/src/main/java/com/google/cloud/storage/BlobInfo.java
@@ -33,7 +33,6 @@
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
-import com.google.common.collect.Maps;
import com.google.common.io.BaseEncoding;
import java.io.Serializable;
import java.nio.ByteBuffer;
@@ -1273,18 +1272,15 @@ public Builder setContexts(ObjectContexts contexts) {
// about the timestamps when determining if a value needs to be patched. Create a new map
// where we remove the timestamps so equals is usable.
Map left =
- this.contexts == null
- ? null
- : ignoreCustomContextPayloadTimestamps(this.contexts.getCustom());
+ this.contexts == null ? null : this.contexts.getCustom();
Map right =
- contexts == null ? null : ignoreCustomContextPayloadTimestamps(contexts.getCustom());
+ contexts == null ? null : contexts.getCustom();
if (!Objects.equals(left, right)) {
if (right != null) {
diffMaps(
NamedField.nested(BlobField.OBJECT_CONTEXTS, NamedField.literal("custom")),
left,
right,
- f -> NamedField.nested(f, NAMED_FIELD_LITERAL_VALUE),
modifiedFields::add);
this.contexts = contexts;
} else {
@@ -1295,20 +1291,6 @@ public Builder setContexts(ObjectContexts contexts) {
return this;
}
- private static @Nullable Map<@NonNull String, @Nullable ObjectCustomContextPayload>
- ignoreCustomContextPayloadTimestamps(
- @Nullable Map<@NonNull String, @Nullable ObjectCustomContextPayload> orig) {
- if (orig == null) {
- return null;
- }
- return Maps.transformValues(
- orig,
- v ->
- v == null
- ? null
- : ObjectCustomContextPayload.newBuilder().setValue(v.getValue()).build());
- }
-
@Override
public BlobInfo build() {
checkNotNull(blobId);
diff --git a/google-cloud-storage/src/main/java/com/google/cloud/storage/JsonUtils.java b/google-cloud-storage/src/main/java/com/google/cloud/storage/JsonUtils.java
index 50427a8cf4..f5297ee837 100644
--- a/google-cloud-storage/src/main/java/com/google/cloud/storage/JsonUtils.java
+++ b/google-cloud-storage/src/main/java/com/google/cloud/storage/JsonUtils.java
@@ -22,9 +22,6 @@
import com.google.cloud.storage.UnifiedOpts.NamedField;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.collect.ImmutableSet;
-import com.google.common.collect.MapDifference;
-import com.google.common.collect.MapDifference.ValueDifference;
-import com.google.common.collect.Maps;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.JsonArray;
@@ -41,7 +38,6 @@
import java.util.Set;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
-import java.util.stream.Stream;
import org.checkerframework.checker.nullness.qual.NonNull;
final class JsonUtils {
@@ -70,7 +66,7 @@ static T getOutputJsonWithSelectedFields(
.map(NamedField::getApiaryName)
.collect(ImmutableSet.toImmutableSet());
try {
- // The datamodel of the apiairy json representation doesn't have a common parent for all
+ // The datamodel of the apiary json representation doesn't have a common parent for all
// field types, rather than writing a significant amount of code to handle all of these types
// leverage Gson.
// 1. serialize the object to it's json string
@@ -104,24 +100,25 @@ static T getOutputJsonWithSelectedFields(
static @NonNull JsonObject getOutputJson(JsonObject inputJson, Set fieldsInOutput) {
Map l = flatten(inputJson);
- Map r = Utils.setToMap(fieldsInOutput, k -> null);
-
- MapDifference diff = Maps.difference(l, r);
// use hashmap so we can have null values
HashMap flat = new HashMap<>();
- Stream.of(
- diff.entriesInCommon().entrySet().stream(),
- diff.entriesOnlyOnRight().entrySet().stream(),
- // if the key is present in both maps, but has a differing value select the value from
- // the left side, as that is the value from inputJson
- Maps.transformValues(diff.entriesDiffering(), ValueDifference::leftValue)
- .entrySet()
- .stream())
- // flatten
- .flatMap(x -> x)
- .forEach(e -> flat.put(e.getKey(), e.getValue()));
-
+ for (String fieldToRetain : fieldsInOutput) {
+ boolean keyFound = false;
+ // Check for exact match or prefix match in the flattened source map (l)
+ for (Map.Entry sourceEntry : l.entrySet()) {
+ String sourceKey = sourceEntry.getKey();
+ if (sourceKey.equals(fieldToRetain) || sourceKey.startsWith(fieldToRetain + ".")) {
+ flat.put(sourceKey, sourceEntry.getValue());
+ keyFound = true;
+ }
+ }
+ // If the field to retain wasn't found in the source, it means we need to add it
+ // to the output with a null value, signaling a deletion.
+ if (!keyFound) {
+ flat.put(fieldToRetain, null);
+ }
+ }
return treeify(flat);
}
diff --git a/google-cloud-storage/src/main/java/com/google/cloud/storage/Utils.java b/google-cloud-storage/src/main/java/com/google/cloud/storage/Utils.java
index d6f96b8ad4..eece2fe79d 100644
--- a/google-cloud-storage/src/main/java/com/google/cloud/storage/Utils.java
+++ b/google-cloud-storage/src/main/java/com/google/cloud/storage/Utils.java
@@ -29,7 +29,6 @@
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.MapDifference;
-import com.google.common.collect.MapDifference.ValueDifference;
import com.google.common.collect.Maps;
import com.google.common.io.BaseEncoding;
import com.google.common.primitives.Ints;
@@ -282,57 +281,28 @@ static T firstNonNull(Supplier<@Nullable T>... ss) {
*/
static void diffMaps(
NamedField parent, Map left, Map right, Consumer sink) {
- diffMaps(parent, left, right, Function.identity(), sink);
- }
-
- /**
- * Diff two maps, and append each differing key to {@code sink} with the parent of {{@code
- * parent}. Conditionally apply {@code dec} if deeper qualification is necessary.
- */
- static void diffMaps(
- NamedField parent,
- Map left,
- Map right,
- Function dec,
- Consumer sink) {
- final Stream keys;
+ final Stream keys;
if (left != null && right == null) {
- keys = left.keySet().stream().map(NamedField::literal);
+ keys = left.keySet().stream();
} else if (left == null && right != null) {
- keys = right.keySet().stream().map(NamedField::literal).map(dec);
+ keys = right.keySet().stream();
} else if (left != null && right != null) {
MapDifference difference = Maps.difference(left, right);
keys =
Stream.of(
// keys with modified values
- difference.entriesDiffering().entrySet().stream()
- .map(
- e -> {
- String key = e.getKey();
- NamedField literal = NamedField.literal(key);
- ValueDifference diff = e.getValue();
-
- if (diff.leftValue() != null && diff.rightValue() == null) {
- return literal;
- } else if (diff.leftValue() == null && diff.rightValue() != null) {
- return literal;
- } else {
- return dec.apply(literal);
- }
- }),
+ difference.entriesDiffering().keySet().stream(),
// Only include keys to remove if ALL keys were removed
right.isEmpty()
- ? difference.entriesOnlyOnLeft().keySet().stream().map(NamedField::literal)
- : Stream.empty(),
+ ? difference.entriesOnlyOnLeft().keySet().stream()
+ : Stream.empty(),
// new keys
- difference.entriesOnlyOnRight().keySet().stream()
- .map(NamedField::literal)
- .map(dec))
+ difference.entriesOnlyOnRight().keySet().stream())
.flatMap(x -> x);
} else {
keys = Stream.empty();
}
- keys.map(k -> NamedField.nested(parent, k)).forEach(sink);
+ keys.map(NamedField::literal).map(k -> NamedField.nested(parent, k)).forEach(sink);
}
static T[] subArray(T[] ts, int offset, int length) {
diff --git a/google-cloud-storage/src/test/java/com/google/cloud/storage/BlobInfoTest.java b/google-cloud-storage/src/test/java/com/google/cloud/storage/BlobInfoTest.java
index 862709a5ae..6ecb483918 100644
--- a/google-cloud-storage/src/test/java/com/google/cloud/storage/BlobInfoTest.java
+++ b/google-cloud-storage/src/test/java/com/google/cloud/storage/BlobInfoTest.java
@@ -19,6 +19,8 @@
import static com.google.cloud.storage.Acl.Project.ProjectRole.VIEWERS;
import static com.google.cloud.storage.Acl.Role.READER;
import static com.google.cloud.storage.Acl.Role.WRITER;
+import static com.google.cloud.storage.TestUtils.hashMapOf;
+import static com.google.common.truth.Truth.assertThat;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNull;
@@ -30,12 +32,16 @@
import com.google.cloud.storage.BlobInfo.CustomerEncryption;
import com.google.cloud.storage.BlobInfo.ObjectContexts;
import com.google.cloud.storage.BlobInfo.ObjectCustomContextPayload;
+import com.google.cloud.storage.UnifiedOpts.NamedField;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.ImmutableSet;
import java.math.BigInteger;
import java.util.Collections;
import java.util.List;
import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
import org.junit.Test;
public class BlobInfoTest {
@@ -352,4 +358,49 @@ public void testToPbAndFromPb() {
public void testBlobId() {
assertEquals(BlobId.of("b", "n", GENERATION), BLOB_INFO.getBlobId());
}
+
+ @Test
+ public void deepFieldDiffDetectionWorksCorrectly_mutateRetrievedObject() {
+ BlobInfo info =
+ BlobInfo.newBuilder("bucket", "object")
+ .setContexts(
+ ObjectContexts.newBuilder()
+ .setCustom(
+ hashMapOf(
+ "c1", ObjectCustomContextPayload.newBuilder().setValue("C1").build(),
+ "c2", ObjectCustomContextPayload.newBuilder().setValue("C2").build()))
+ .build())
+ .setMetadata(
+ hashMapOf(
+ "m1", "M1",
+ "m2", "M2"))
+ .build();
+
+ BlobInfo modified =
+ info.toBuilder()
+ .setMetadata(hashMapOf("m2", null))
+ .setContexts(ObjectContexts.newBuilder().setCustom(hashMapOf("k2", null)).build())
+ .build();
+ Set modifiedFields =
+ modified.getModifiedFields().stream()
+ .map(NamedField::getGrpcName)
+ .collect(Collectors.toSet());
+
+ assertThat(modifiedFields).isEqualTo(ImmutableSet.of("contexts.custom.k2", "metadata.m2"));
+ }
+
+ @Test
+ public void deepFieldDiffDetectionWorksCorrectly_declaredDiff() {
+ BlobInfo modified =
+ BlobInfo.newBuilder("bucket", "object")
+ .setMetadata(hashMapOf("m2", null))
+ .setContexts(ObjectContexts.newBuilder().setCustom(hashMapOf("k2", null)).build())
+ .build();
+ Set modifiedFields =
+ modified.getModifiedFields().stream()
+ .map(UnifiedOpts.NamedField::getGrpcName)
+ .collect(Collectors.toSet());
+
+ assertThat(modifiedFields).isEqualTo(ImmutableSet.of("contexts.custom.k2", "metadata.m2"));
+ }
}
diff --git a/google-cloud-storage/src/test/java/com/google/cloud/storage/TestUtils.java b/google-cloud-storage/src/test/java/com/google/cloud/storage/TestUtils.java
index f493570acc..5231b8fe00 100644
--- a/google-cloud-storage/src/test/java/com/google/cloud/storage/TestUtils.java
+++ b/google-cloud-storage/src/test/java/com/google/cloud/storage/TestUtils.java
@@ -279,20 +279,19 @@ public static void assertAll(ThrowingRunnable... trs) throws Exception {
}
/** ImmutableMap does not allow null values, this method does */
- public static Map<@NonNull String, @Nullable String> hashMapOf(
- @NonNull String k1, @Nullable String v1) {
+ public static Map<@NonNull K, @Nullable V> hashMapOf(@NonNull K k1, @Nullable V v1) {
requireNonNull(k1, "k1 must be non null");
- HashMap map = new HashMap<>();
+ HashMap map = new HashMap<>();
map.put(k1, v1);
return Collections.unmodifiableMap(map);
}
/** ImmutableMap does not allow null values, this method does */
- public static Map<@NonNull String, @Nullable String> hashMapOf(
- @NonNull String k1, @Nullable String v1, @NonNull String k2, @Nullable String v2) {
+ public static Map<@NonNull K, @Nullable V> hashMapOf(
+ @NonNull K k1, @Nullable V v1, @NonNull K k2, @Nullable V v2) {
requireNonNull(k1, "k1 must be non null");
requireNonNull(k2, "k2 must be non null");
- HashMap map = new HashMap<>();
+ HashMap map = new HashMap<>();
map.put(k1, v1);
map.put(k2, v2);
return Collections.unmodifiableMap(map);
diff --git a/google-cloud-storage/src/test/java/com/google/cloud/storage/it/ITNestedUpdateMaskTest.java b/google-cloud-storage/src/test/java/com/google/cloud/storage/it/ITNestedUpdateMaskTest.java
index e8e3a25728..e84ccf5a5e 100644
--- a/google-cloud-storage/src/test/java/com/google/cloud/storage/it/ITNestedUpdateMaskTest.java
+++ b/google-cloud-storage/src/test/java/com/google/cloud/storage/it/ITNestedUpdateMaskTest.java
@@ -78,6 +78,7 @@ public static final class NestedUpdateMaskParametersProvider implements Paramete
private static final Map k1a_k2null = hashMapOf("k1", "a", "k2", null);
private static final Map k1null = hashMapOf("k1", null);
private static final Map k2null = hashMapOf("k2", null);
+ private static final Map k1null_k2null = hashMapOf("k1", null, "k2", null);
/**
*
@@ -95,7 +96,7 @@ public static final class NestedUpdateMaskParametersProvider implements Paramete
* | {"k1":"a","k2":"b"} | {"k2":null} | {"k1":"a"} |
* | {"k1":"a"} | {} | null |
* | {"k1":"a"} | {"k1":null} | null |
- * | {"k1":"a","k2":"b"} | null | null |
+ * | {"k1":"a","k2":"b"} | {"k1:null,"k2":null} | null |
*
*/
@Override
@@ -111,7 +112,7 @@ public ImmutableList parameters() {
new Param("2 keys, modify 1 null (fine)", k1a_k2b, k2null, k1a),
new Param("1 key, set empty", k1a, empty, null),
new Param("1 key, null key", k1a, k1null, null),
- new Param("2 keys, set null", k1a_k2b, null, null));
+ new Param("2 keys, set null", k1a_k2b, k1null_k2null, null));
}
}
From dbaf633c41df23d0f009ec812fd506d430ff1237 Mon Sep 17 00:00:00 2001
From: "release-please[bot]"
<55107282+release-please[bot]@users.noreply.github.com>
Date: Tue, 23 Sep 2025 15:03:22 -0400
Subject: [PATCH 17/17] chore(main): release 2.58.0 (#3290)
Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>
Co-authored-by: cloud-java-bot
---
CHANGELOG.md | 21 +++++++++++++++++++
README.md | 6 +++---
gapic-google-cloud-storage-v2/pom.xml | 4 ++--
google-cloud-storage-bom/pom.xml | 16 +++++++-------
google-cloud-storage-control/pom.xml | 4 ++--
google-cloud-storage/pom.xml | 4 ++--
grpc-google-cloud-storage-control-v2/pom.xml | 4 ++--
grpc-google-cloud-storage-v2/pom.xml | 4 ++--
pom.xml | 16 +++++++-------
proto-google-cloud-storage-control-v2/pom.xml | 4 ++--
proto-google-cloud-storage-v2/pom.xml | 4 ++--
samples/snapshot/pom.xml | 6 +++---
storage-shared-benchmarking/pom.xml | 4 ++--
versions.txt | 14 ++++++-------
14 files changed, 66 insertions(+), 45 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index a5eaba8078..40b1ce9f18 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,26 @@
# Changelog
+## [2.58.0](https://github.com/googleapis/java-storage/compare/v2.57.0...v2.58.0) (2025-09-23)
+
+
+### Features
+
+* **storagecontrol:** Add GetIamPolicy, SetIamPolicy, and TestIamPermissions RPCs ([c884551](https://github.com/googleapis/java-storage/commit/c884551048a323f2a3fd7aaf4fce469d4d4f543e))
+
+
+### Bug Fixes
+
+* **deps:** Update the Java code generator (gapic-generator-java) to 2.62.2 ([984f8ca](https://github.com/googleapis/java-storage/commit/984f8ca23a38c7a892a2256a694b72431e44aa27))
+* Fix appendable upload finalization race condition ([#3295](https://github.com/googleapis/java-storage/issues/3295)) ([485be18](https://github.com/googleapis/java-storage/commit/485be184c08c7b857d8c9a9443f32903df879b23))
+* Fix IllegalMonitorStateException thrown from BlobAppendableUpload.isOpen() ([#3302](https://github.com/googleapis/java-storage/issues/3302)) ([aa90468](https://github.com/googleapis/java-storage/commit/aa904688b784d7427454318196ef88628e415246))
+* Update object context diff logic to be shallow rather than deep ([#3287](https://github.com/googleapis/java-storage/issues/3287)) ([2fd15f6](https://github.com/googleapis/java-storage/commit/2fd15f69e93a3df2b8dbbd4f08edd07c087e957c))
+
+
+### Dependencies
+
+* Update dependency com.google.cloud:sdk-platform-java-config to v3.52.2 ([#3298](https://github.com/googleapis/java-storage/issues/3298)) ([1489f3a](https://github.com/googleapis/java-storage/commit/1489f3a74c8a27f0888c40600c83adedcfd9a9ec))
+* Update googleapis/sdk-platform-java action to v2.62.2 ([#3299](https://github.com/googleapis/java-storage/issues/3299)) ([c3b05ac](https://github.com/googleapis/java-storage/commit/c3b05ac8798140f9ddcab098948a3a2f3638dc6b))
+
## [2.57.0](https://github.com/googleapis/java-storage/compare/v2.56.0...v2.57.0) (2025-09-09)
diff --git a/README.md b/README.md
index df3b325f07..3dd16fc128 100644
--- a/README.md
+++ b/README.md
@@ -66,13 +66,13 @@ implementation 'com.google.cloud:google-cloud-storage'
If you are using Gradle without BOM, add this to your dependencies:
```Groovy
-implementation 'com.google.cloud:google-cloud-storage:2.57.0'
+implementation 'com.google.cloud:google-cloud-storage:2.58.0'
```
If you are using SBT, add this to your dependencies:
```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-storage" % "2.57.0"
+libraryDependencies += "com.google.cloud" % "google-cloud-storage" % "2.58.0"
```
## Authentication
@@ -479,7 +479,7 @@ Java is a registered trademark of Oracle and/or its affiliates.
[kokoro-badge-link-5]: http://storage.googleapis.com/cloud-devrel-public/java/badges/java-storage/java11.html
[stability-image]: https://img.shields.io/badge/stability-stable-green
[maven-version-image]: https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-storage.svg
-[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-storage/2.57.0
+[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-storage/2.58.0
[authentication]: https://github.com/googleapis/google-cloud-java#authentication
[auth-scopes]: https://developers.google.com/identity/protocols/oauth2/scopes
[predefined-iam-roles]: https://cloud.google.com/iam/docs/understanding-roles#predefined_roles
diff --git a/gapic-google-cloud-storage-v2/pom.xml b/gapic-google-cloud-storage-v2/pom.xml
index 9c6d4085f7..8f51bf0aae 100644
--- a/gapic-google-cloud-storage-v2/pom.xml
+++ b/gapic-google-cloud-storage-v2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
gapic-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
gapic-google-cloud-storage-v2
GRPC library for gapic-google-cloud-storage-v2
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
diff --git a/google-cloud-storage-bom/pom.xml b/google-cloud-storage-bom/pom.xml
index 188afb7cd5..ca3ddcbf37 100644
--- a/google-cloud-storage-bom/pom.xml
+++ b/google-cloud-storage-bom/pom.xml
@@ -19,7 +19,7 @@
4.0.0
com.google.cloud
google-cloud-storage-bom
- 2.57.1-SNAPSHOT
+ 2.58.0
pom
com.google.cloud
@@ -69,37 +69,37 @@
com.google.cloud
google-cloud-storage
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
gapic-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
grpc-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
proto-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.cloud
google-cloud-storage-control
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
grpc-google-cloud-storage-control-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
proto-google-cloud-storage-control-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
diff --git a/google-cloud-storage-control/pom.xml b/google-cloud-storage-control/pom.xml
index 19c6ac33ca..7e85834bd0 100644
--- a/google-cloud-storage-control/pom.xml
+++ b/google-cloud-storage-control/pom.xml
@@ -5,13 +5,13 @@
4.0.0
com.google.cloud
google-cloud-storage-control
- 2.57.1-SNAPSHOT
+ 2.58.0
google-cloud-storage-control
GRPC library for google-cloud-storage-control
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
diff --git a/google-cloud-storage/pom.xml b/google-cloud-storage/pom.xml
index fa014b65d5..989a49db4a 100644
--- a/google-cloud-storage/pom.xml
+++ b/google-cloud-storage/pom.xml
@@ -2,7 +2,7 @@
4.0.0
google-cloud-storage
- 2.57.1-SNAPSHOT
+ 2.58.0
jar
Google Cloud Storage
https://github.com/googleapis/java-storage
@@ -12,7 +12,7 @@
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
google-cloud-storage
diff --git a/grpc-google-cloud-storage-control-v2/pom.xml b/grpc-google-cloud-storage-control-v2/pom.xml
index 5b59cbb287..c594fe4bd8 100644
--- a/grpc-google-cloud-storage-control-v2/pom.xml
+++ b/grpc-google-cloud-storage-control-v2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
grpc-google-cloud-storage-control-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
grpc-google-cloud-storage-control-v2
GRPC library for google-cloud-storage
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
diff --git a/grpc-google-cloud-storage-v2/pom.xml b/grpc-google-cloud-storage-v2/pom.xml
index 8f6a2ad604..b1729bff6a 100644
--- a/grpc-google-cloud-storage-v2/pom.xml
+++ b/grpc-google-cloud-storage-v2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
grpc-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
grpc-google-cloud-storage-v2
GRPC library for grpc-google-cloud-storage-v2
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
diff --git a/pom.xml b/pom.xml
index 670bd8d768..b14e256786 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
com.google.cloud
google-cloud-storage-parent
pom
- 2.57.1-SNAPSHOT
+ 2.58.0
Storage Parent
https://github.com/googleapis/java-storage
@@ -82,7 +82,7 @@
com.google.cloud
google-cloud-storage
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.apis
@@ -104,32 +104,32 @@
com.google.api.grpc
proto-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
grpc-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
gapic-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
grpc-google-cloud-storage-control-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.api.grpc
proto-google-cloud-storage-control-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.cloud
google-cloud-storage-control
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.cloud
diff --git a/proto-google-cloud-storage-control-v2/pom.xml b/proto-google-cloud-storage-control-v2/pom.xml
index 4d3eaa5fe0..d75d4c367c 100644
--- a/proto-google-cloud-storage-control-v2/pom.xml
+++ b/proto-google-cloud-storage-control-v2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
proto-google-cloud-storage-control-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
proto-google-cloud-storage-control-v2
Proto library for proto-google-cloud-storage-control-v2
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
diff --git a/proto-google-cloud-storage-v2/pom.xml b/proto-google-cloud-storage-v2/pom.xml
index f07e2de661..c1d72f4600 100644
--- a/proto-google-cloud-storage-v2/pom.xml
+++ b/proto-google-cloud-storage-v2/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
proto-google-cloud-storage-v2
- 2.57.1-SNAPSHOT
+ 2.58.0
proto-google-cloud-storage-v2
PROTO library for proto-google-cloud-storage-v2
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index 04ec3fe6de..814b1ea2d6 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -28,12 +28,12 @@
com.google.cloud
google-cloud-storage
- 2.57.1-SNAPSHOT
+ 2.58.0
com.google.cloud
google-cloud-storage-control
- 2.57.1-SNAPSHOT
+ 2.58.0
compile
@@ -70,7 +70,7 @@
com.google.cloud
google-cloud-storage
- 2.57.1-SNAPSHOT
+ 2.58.0
tests
test
diff --git a/storage-shared-benchmarking/pom.xml b/storage-shared-benchmarking/pom.xml
index 5f52db9ec4..ec0080c9b1 100644
--- a/storage-shared-benchmarking/pom.xml
+++ b/storage-shared-benchmarking/pom.xml
@@ -10,7 +10,7 @@
com.google.cloud
google-cloud-storage-parent
- 2.57.1-SNAPSHOT
+ 2.58.0
@@ -31,7 +31,7 @@
com.google.cloud
google-cloud-storage
- 2.57.1-SNAPSHOT
+ 2.58.0
tests
diff --git a/versions.txt b/versions.txt
index 4fc046f462..1a8a97cccd 100644
--- a/versions.txt
+++ b/versions.txt
@@ -1,10 +1,10 @@
# Format:
# module:released-version:current-version
-google-cloud-storage:2.57.0:2.57.1-SNAPSHOT
-gapic-google-cloud-storage-v2:2.57.0:2.57.1-SNAPSHOT
-grpc-google-cloud-storage-v2:2.57.0:2.57.1-SNAPSHOT
-proto-google-cloud-storage-v2:2.57.0:2.57.1-SNAPSHOT
-google-cloud-storage-control:2.57.0:2.57.1-SNAPSHOT
-proto-google-cloud-storage-control-v2:2.57.0:2.57.1-SNAPSHOT
-grpc-google-cloud-storage-control-v2:2.57.0:2.57.1-SNAPSHOT
+google-cloud-storage:2.58.0:2.58.0
+gapic-google-cloud-storage-v2:2.58.0:2.58.0
+grpc-google-cloud-storage-v2:2.58.0:2.58.0
+proto-google-cloud-storage-v2:2.58.0:2.58.0
+google-cloud-storage-control:2.58.0:2.58.0
+proto-google-cloud-storage-control-v2:2.58.0:2.58.0
+grpc-google-cloud-storage-control-v2:2.58.0:2.58.0