本文整理了Java中org.jclouds.blobstore.BlobStore.abortMultipartUpload()方法的一些代码示例，展示了BlobStore.abortMultipartUpload()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。BlobStore.abortMultipartUpload()方法的具体详情如下：
包路径：org.jclouds.blobstore.BlobStore
类名称：BlobStore
方法名：abortMultipartUpload

BlobStore.abortMultipartUpload介绍

暂无

代码示例

代码示例来源：origin: gaul/s3proxy

@Override
public void abortMultipartUpload(MultipartUpload mpu) {
  delegate().abortMultipartUpload(mpu);
}

代码示例来源：origin: gaul/s3proxy

private static void handleContainerDelete(HttpServletResponse response,
    BlobStore blobStore, String containerName)
    throws IOException, S3Exception {
  if (!blobStore.containerExists(containerName)) {
    throw new S3Exception(S3ErrorCode.NO_SUCH_BUCKET);
  }
  String blobStoreType = getBlobStoreType(blobStore);
  if (blobStoreType.equals("b2")) {
    // S3 allows deleting a container with in-progress MPU while B2 does
    // not.  Explicitly cancel uploads for B2.
    for (MultipartUpload mpu : blobStore.listMultipartUploads(
        containerName)) {
      blobStore.abortMultipartUpload(mpu);
    }
  }
  if (!blobStore.deleteContainerIfEmpty(containerName)) {
    throw new S3Exception(S3ErrorCode.BUCKET_NOT_EMPTY);
  }
  response.setStatus(HttpServletResponse.SC_NO_CONTENT);
}

代码示例来源：origin: gaul/s3proxy

private static void handleAbortMultipartUpload(HttpServletResponse response,
    BlobStore blobStore, String containerName, String blobName,
    String uploadId) throws IOException, S3Exception {
  if (Quirks.MULTIPART_REQUIRES_STUB.contains(getBlobStoreType(
      blobStore))) {
    if (!blobStore.blobExists(containerName, uploadId)) {
      throw new S3Exception(S3ErrorCode.NO_SUCH_UPLOAD);
    }
    blobStore.removeBlob(containerName, uploadId);
  }
  // TODO: how to reconstruct original mpu?
  MultipartUpload mpu = MultipartUpload.create(containerName,
      blobName, uploadId, createFakeBlobMetadata(blobStore),
      new PutOptions());
  blobStore.abortMultipartUpload(mpu);
  response.sendError(HttpServletResponse.SC_NO_CONTENT);
}

代码示例来源：origin: com.amysta.jclouds/jclouds-blobstore

@Override
public void abortMultipartUpload(MultipartUpload mpu) {
 delegate().abortMultipartUpload(mpu);
}

代码示例来源：origin: org.gaul/s3proxy

@Override
public void abortMultipartUpload(MultipartUpload mpu) {
  delegate().abortMultipartUpload(mpu);
}

代码示例来源：origin: Nextdoor/bender

@Override
public void abortMultipartUpload(MultipartUpload mpu) {
 delegate().abortMultipartUpload(mpu);
}

代码示例来源：origin: org.apache.jclouds/jclouds-blobstore

@Override
public void abortMultipartUpload(MultipartUpload mpu) {
 delegate().abortMultipartUpload(mpu);
}

代码示例来源：origin: Nextdoor/bender

@Override
public void abortMultipartUpload(MultipartUpload mpu) {
  delegate().abortMultipartUpload(mpu);
}

代码示例来源：origin: apache/jclouds

@Override
public void abortMultipartUpload(MultipartUpload mpu) {
 delegate().abortMultipartUpload(mpu);
}

代码示例来源：origin: org.gaul/s3proxy

private static void handleContainerDelete(HttpServletResponse response,
    BlobStore blobStore, String containerName)
    throws IOException, S3Exception {
  if (!blobStore.containerExists(containerName)) {
    throw new S3Exception(S3ErrorCode.NO_SUCH_BUCKET);
  }
  String blobStoreType = getBlobStoreType(blobStore);
  if (blobStoreType.equals("b2")) {
    // S3 allows deleting a container with in-progress MPU while B2 does
    // not.  Explicitly cancel uploads for B2.
    for (MultipartUpload mpu : blobStore.listMultipartUploads(
        containerName)) {
      blobStore.abortMultipartUpload(mpu);
    }
  }
  if (!blobStore.deleteContainerIfEmpty(containerName)) {
    throw new S3Exception(S3ErrorCode.BUCKET_NOT_EMPTY);
  }
  response.setStatus(HttpServletResponse.SC_NO_CONTENT);
}

代码示例来源：origin: Nextdoor/bender

private static void handleContainerDelete(HttpServletResponse response,
    BlobStore blobStore, String containerName)
    throws IOException, S3Exception {
  if (!blobStore.containerExists(containerName)) {
    throw new S3Exception(S3ErrorCode.NO_SUCH_BUCKET);
  }
  String blobStoreType = getBlobStoreType(blobStore);
  if (blobStoreType.equals("b2")) {
    // S3 allows deleting a container with in-progress MPU while B2 does
    // not.  Explicitly cancel uploads for B2.
    for (MultipartUpload mpu : blobStore.listMultipartUploads(
        containerName)) {
      blobStore.abortMultipartUpload(mpu);
    }
  }
  if (!blobStore.deleteContainerIfEmpty(containerName)) {
    throw new S3Exception(S3ErrorCode.BUCKET_NOT_EMPTY);
  }
  response.setStatus(HttpServletResponse.SC_NO_CONTENT);
}

代码示例来源：origin: Nextdoor/bender

private static void handleAbortMultipartUpload(HttpServletResponse response,
    BlobStore blobStore, String containerName, String blobName,
    String uploadId) throws IOException, S3Exception {
  if (Quirks.MULTIPART_REQUIRES_STUB.contains(getBlobStoreType(
      blobStore))) {
    if (!blobStore.blobExists(containerName, uploadId)) {
      throw new S3Exception(S3ErrorCode.NO_SUCH_UPLOAD);
    }
    blobStore.removeBlob(containerName, uploadId);
  }
  // TODO: how to reconstruct original mpu?
  MultipartUpload mpu = MultipartUpload.create(containerName,
      blobName, uploadId, createFakeBlobMetadata(blobStore),
      new PutOptions());
  blobStore.abortMultipartUpload(mpu);
  response.sendError(HttpServletResponse.SC_NO_CONTENT);
}

代码示例来源：origin: org.gaul/s3proxy

private static void handleAbortMultipartUpload(HttpServletResponse response,
    BlobStore blobStore, String containerName, String blobName,
    String uploadId) throws IOException, S3Exception {
  if (Quirks.MULTIPART_REQUIRES_STUB.contains(getBlobStoreType(
      blobStore))) {
    if (!blobStore.blobExists(containerName, uploadId)) {
      throw new S3Exception(S3ErrorCode.NO_SUCH_UPLOAD);
    }
    blobStore.removeBlob(containerName, uploadId);
  }
  // TODO: how to reconstruct original mpu?
  MultipartUpload mpu = MultipartUpload.create(containerName,
      blobName, uploadId, createFakeBlobMetadata(blobStore),
      new PutOptions());
  blobStore.abortMultipartUpload(mpu);
  response.sendError(HttpServletResponse.SC_NO_CONTENT);
}

代码示例来源：origin: apache/jclouds

@Test(groups = { "integration", "live" })
public void testMultipartUploadNoPartsAbort() throws Exception {
 BlobStore blobStore = view.getBlobStore();
 String container = getContainerName();
 try {
   String name = "blob-name";
   Blob blob = blobStore.blobBuilder(name).build();
   MultipartUpload mpu = blobStore.initiateMultipartUpload(container, blob.getMetadata(), new PutOptions());
   List<MultipartPart> parts = blobStore.listMultipartUpload(mpu);
   assertThat(parts).isEqualTo(ImmutableList.of());
   blobStore.abortMultipartUpload(mpu);
   blob = blobStore.getBlob(container, name);
   assertThat(blob).isNull();
 } finally {
   returnContainer(container);
 }
}

代码示例来源：origin: apache/jclouds

blobStore.abortMultipartUpload(mpu);