[Do not checkin] [For Reference] Java MPU POC

google-cloud-storage/pom.xml

@@ -140,7 +140,10 @@
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-api</artifactId>
     </dependency>
-
+    <dependency>
+    <groupId>com.fasterxml.jackson.dataformat</groupId>
+    <artifactId>jackson-dataformat-xml</artifactId>
+    </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-sdk-metrics</artifactId>

google-cloud-storage/src/main/java/com/google/cloud/storage/HttpRequestManager.java

@@ -0,0 +1,109 @@
+/*
+ * Copyright 2024 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.google.cloud.storage;
+
+import com.google.api.client.http.ByteArrayContent;
+import com.google.api.client.http.GenericUrl;
+import com.google.api.client.http.HttpContent;
+import com.google.api.client.http.HttpRequest;
+import com.google.api.client.http.HttpRequestFactory;
+import com.google.api.client.http.HttpResponse;
+import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadRequest;
+import java.io.IOException;
+import java.util.Map;
+
+public class HttpRequestManager {
+
+  private final HttpRequestFactory requestFactory;
+
+  public HttpRequestManager(HttpRequestFactory requestFactory) {
+    this.requestFactory = requestFactory;
+  }
+
+  public HttpResponse sendCreateMultipartUploadRequest(
+      String uri,
+      String contentType,
+      CreateMultipartUploadRequest request,
+      Map<String, String> extensionHeaders)
+      throws IOException {
+    HttpRequest httpRequest =
+        requestFactory.buildPostRequest(
+            new GenericUrl(uri), new ByteArrayContent(contentType, new byte[0]));
+    httpRequest.getHeaders().setContentType(contentType);
+    for (Map.Entry<String, String> entry : extensionHeaders.entrySet()) {
+      httpRequest.getHeaders().set(entry.getKey(), entry.getValue());
+    }
+    httpRequest.setThrowExceptionOnExecuteError(false);
+    return httpRequest.execute();
+  }
+
+  public HttpResponse sendUploadPartRequest(
+      String uri,
+      HttpContent content,
+      String contentType,
+      Map<String, String> extensionHeaders)
+      throws IOException {
+    HttpRequest httpRequest =
+        requestFactory.buildPutRequest(
+            new GenericUrl(uri), content);
+    httpRequest.getHeaders().setContentType(contentType);
+    for (Map.Entry<String, String> entry : extensionHeaders.entrySet()) {
+      httpRequest.getHeaders().set(entry.getKey(), entry.getValue());
+    }
+    httpRequest.setThrowExceptionOnExecuteError(false);
+    return httpRequest.execute();
+  }
+
+  public HttpResponse sendCompleteMultipartUploadRequest(
+      String uri,
+      byte[] xmlBodyBytes,
+      String contentType,
+      Map<String, String> extensionHeaders)
+      throws IOException {
+    HttpRequest httpRequest =
+        requestFactory.buildPostRequest(
+            new GenericUrl(uri), new ByteArrayContent(contentType, xmlBodyBytes));
+    httpRequest.getHeaders().setContentType(contentType);
+    for (Map.Entry<String, String> entry : extensionHeaders.entrySet()) {
+      httpRequest.getHeaders().set(entry.getKey(), entry.getValue());
+    }
+    httpRequest.setThrowExceptionOnExecuteError(false);
+    return httpRequest.execute();
+  }
+
+  public HttpResponse sendAbortMultipartUploadRequest(
+      String uri, String contentType, Map<String, String> extensionHeaders)
+      throws IOException {
+    HttpRequest httpRequest = requestFactory.buildDeleteRequest(new GenericUrl(uri));
+    httpRequest.getHeaders().setContentType(contentType);
+    for (Map.Entry<String, String> entry : extensionHeaders.entrySet()) {
+      httpRequest.getHeaders().set(entry.getKey(), entry.getValue());
+    }
+    httpRequest.setThrowExceptionOnExecuteError(false);
+    return httpRequest.execute();
+  }
+
+  public HttpResponse sendListPartsRequest(
+      String uri, Map<String, String> extensionHeaders)
+      throws IOException {
+    HttpRequest httpRequest = requestFactory.buildGetRequest(new GenericUrl(uri));
+    for (Map.Entry<String, String> entry : extensionHeaders.entrySet()) {
+      httpRequest.getHeaders().set(entry.getKey(), entry.getValue());
+    }
+    httpRequest.setThrowExceptionOnExecuteError(false);
+    return httpRequest.execute();
+  }
+}

google-cloud-storage/src/main/java/com/google/cloud/storage/HttpStorageOptions.java

@@ -26,15 +26,13 @@
 import com.google.api.gax.rpc.HeaderProvider;
 import com.google.api.gax.tracing.ApiTracerFactory;
 import com.google.auth.Credentials;
+import com.google.cloud.storage.Retrying.RetryingDependencies;
 import com.google.cloud.ServiceFactory;
 import com.google.cloud.ServiceRpc;
 import com.google.cloud.TransportOptions;
 import com.google.cloud.http.HttpTransportOptions;
 import com.google.cloud.spi.ServiceRpcFactory;
 import com.google.cloud.storage.BlobWriteSessionConfig.WriterFactory;
-import com.google.cloud.storage.Retrying.DefaultRetrier;
-import com.google.cloud.storage.Retrying.HttpRetrier;
-import com.google.cloud.storage.Retrying.RetryingDependencies;
 import com.google.cloud.storage.Storage.BlobWriteOption;
 import com.google.cloud.storage.TransportCompatibility.Transport;
 import com.google.cloud.storage.spi.StorageRpcFactory;
@@ -407,15 +405,7 @@ public Storage create(StorageOptions options) {
             blobWriteSessionConfig = HttpStorageOptions.defaults().getDefaultStorageWriterConfig();
           }
           WriterFactory factory = blobWriteSessionConfig.createFactory(clock);
-          StorageImpl storage =
-              new StorageImpl(
-                  httpStorageOptions,
-                  factory,
-                  new HttpRetrier(
-                      new DefaultRetrier(
-                          OtelStorageDecorator.retryContextDecorator(otel),
-                          RetryingDependencies.simple(
-                              options.getClock(), options.getRetrySettings()))));
+          StorageImpl storage = new StorageImpl(httpStorageOptions, factory, options.createRetrier());
           return OtelStorageDecorator.decorate(storage, otel, Transport.HTTP);
         } catch (IOException e) {
           throw new IllegalStateException(

google-cloud-storage/src/main/java/com/google/cloud/storage/MultipartUploadClient.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.google.cloud.storage;
+
+import com.google.api.core.BetaApi;
+import com.google.api.core.InternalExtensionOnly;
+import com.google.cloud.storage.multipartupload.model.AbortMultipartUploadRequest;
+import com.google.cloud.storage.multipartupload.model.AbortMultipartUploadResponse;
+import com.google.cloud.storage.multipartupload.model.CompleteMultipartUploadRequest;
+import com.google.cloud.storage.multipartupload.model.CompleteMultipartUploadResponse;
+import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadRequest;
+import com.google.cloud.storage.multipartupload.model.CreateMultipartUploadResponse;
+import com.google.cloud.storage.multipartupload.model.ListPartsRequest;
+import com.google.cloud.storage.multipartupload.model.ListPartsResponse;
+import com.google.cloud.storage.multipartupload.model.UploadPartRequest;
+import com.google.cloud.storage.multipartupload.model.UploadPartResponse;
+import java.io.IOException;
+import java.net.URI;
+import java.security.NoSuchAlgorithmException;
+
+@BetaApi
+@InternalExtensionOnly
+public abstract class MultipartUploadClient {
+
+  MultipartUploadClient() {}
+
+  public abstract CreateMultipartUploadResponse createMultipartUpload(CreateMultipartUploadRequest request)
+      throws IOException;
+
+  public abstract UploadPartResponse uploadPart(UploadPartRequest request, RequestBody requestBody)
+      throws IOException, NoSuchAlgorithmException;
+
+  public abstract CompleteMultipartUploadResponse completeMultipartUpload(
+      CompleteMultipartUploadRequest request)
+      throws NoSuchAlgorithmException, IOException;
+
+  public abstract AbortMultipartUploadResponse abortMultipartUpload(AbortMultipartUploadRequest request)
+      throws IOException, NoSuchAlgorithmException;
+
+  public abstract ListPartsResponse listParts(ListPartsRequest listPartsRequest) throws IOException;
+
+  public static MultipartUploadClient create(MultipartUploadSettings config) {
+    HttpStorageOptions options = config.getOptions();
+    return new MultipartUploadClientImpl(
+        URI.create(options.getHost()),
+        options.getStorageRpcV1().getStorage().getRequestFactory(),
+        options.createRetrier(),
+        options);
+  }
+}