本文整理了Java中org.jclouds.blobstore.BlobStore.getMinimumMultipartPartSize()
方法的一些代码示例,展示了BlobStore.getMinimumMultipartPartSize()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。BlobStore.getMinimumMultipartPartSize()
方法的具体详情如下:
包路径:org.jclouds.blobstore.BlobStore
类名称:BlobStore
方法名:getMinimumMultipartPartSize
暂无
代码示例来源:origin: gaul/s3proxy
if (partSize < blobStore.getMinimumMultipartPartSize() &&
partSize != -1 && it.hasNext()) {
throw new S3Exception(S3ErrorCode.ENTITY_TOO_SMALL);
代码示例来源:origin: org.apache.jclouds/jclouds-blobstore
@Override
public long getMinimumMultipartPartSize() {
return delegate().getMinimumMultipartPartSize();
}
代码示例来源:origin: com.amysta.jclouds/jclouds-blobstore
@Override
public long getMinimumMultipartPartSize() {
return delegate().getMinimumMultipartPartSize();
}
代码示例来源:origin: Nextdoor/bender
@Override
public long getMinimumMultipartPartSize() {
return delegate().getMinimumMultipartPartSize();
}
代码示例来源:origin: apache/jclouds
@Override
public long getMinimumMultipartPartSize() {
return delegate().getMinimumMultipartPartSize();
}
代码示例来源:origin: apache/jclouds
@Override
protected long getMinimumMultipartBlobSize() {
return view.getBlobStore().getMinimumMultipartPartSize() + 1;
}
代码示例来源:origin: org.gaul/s3proxy
if (partSize < blobStore.getMinimumMultipartPartSize() &&
partSize != -1 && it.hasNext()) {
throw new S3Exception(S3ErrorCode.ENTITY_TOO_SMALL);
代码示例来源:origin: Nextdoor/bender
if (partSize < blobStore.getMinimumMultipartPartSize() &&
partSize != -1 && it.hasNext()) {
throw new S3Exception(S3ErrorCode.ENTITY_TOO_SMALL);
代码示例来源:origin: apache/jclouds
@Test(groups = { "integration", "live" })
public void testPutMultipartByteSource() throws Exception {
long length = Math.max(getMinimumMultipartBlobSize(), MultipartUploadSlicingAlgorithm.DEFAULT_PART_SIZE + 1);
BlobStore blobStore = view.getBlobStore();
MultipartUploadSlicingAlgorithm algorithm = new MultipartUploadSlicingAlgorithm(
blobStore.getMinimumMultipartPartSize(), blobStore.getMaximumMultipartPartSize(),
blobStore.getMaximumNumberOfParts());
// make sure that we are creating multiple parts
assertThat(algorithm.calculateChunkSize(length)).isLessThan(length);
ByteSource byteSource = TestUtils.randomByteSource().slice(0, length);
Payload payload = new ByteSourcePayload(byteSource);
HashCode hashCode = byteSource.hash(Hashing.md5());
testPut(payload, hashCode, payload, length, new PutOptions().multipart(true));
}
代码示例来源:origin: apache/jclouds
@Test(groups = { "integration", "live" })
public void test10000PartMultipartUpload() throws Exception {
BlobStore blobStore = view.getBlobStore();
String container = getContainerName();
int partSize = (int) blobStore.getMinimumMultipartPartSize();
try {
String name = "blob-name";
BlobBuilder blobBuilder = blobStore.blobBuilder(name);
Blob blob = blobBuilder.build();
MultipartUpload mpu = blobStore.initiateMultipartUpload(container, blob.getMetadata(), new PutOptions());
ImmutableList.Builder<MultipartPart> parts = ImmutableList.builder();
byte[] content = new byte[partSize];
for (int i = 0; i < 10 * 1000; ++i) {
Payload payload = Payloads.newByteArrayPayload(content);
payload.getContentMetadata().setContentLength((long) partSize);
parts.add(blobStore.uploadMultipartPart(mpu, i, payload));
}
blobStore.completeMultipartUpload(mpu, parts.build());
BlobMetadata newBlobMetadata = blobStore.blobMetadata(container, name);
assertThat(newBlobMetadata.getSize()).isEqualTo(10 * 1000 * partSize);
} finally {
returnContainer(container);
}
}
代码示例来源:origin: apache/jclouds
@Test(groups = { "integration", "live" })
public void testPutMultipartInputStream() throws Exception {
long length = Math.max(getMinimumMultipartBlobSize(), MultipartUploadSlicingAlgorithm.DEFAULT_PART_SIZE + 1);
BlobStore blobStore = view.getBlobStore();
MultipartUploadSlicingAlgorithm algorithm = new MultipartUploadSlicingAlgorithm(
blobStore.getMinimumMultipartPartSize(), blobStore.getMaximumMultipartPartSize(),
blobStore.getMaximumNumberOfParts());
// make sure that we are creating multiple parts
assertThat(algorithm.calculateChunkSize(length)).isLessThan(length);
ByteSource byteSource = TestUtils.randomByteSource().slice(0, length);
Payload payload = new InputStreamPayload(byteSource.openStream());
testPut(payload, null, new ByteSourcePayload(byteSource), length, new PutOptions().multipart(true));
}
代码示例来源:origin: apache/jclouds
MultipartUpload mpu = blobStore.initiateMultipartUpload(container, blob.getMetadata(), new PutOptions());
ByteSource byteSource = TestUtils.randomByteSource().slice(0, blobStore.getMinimumMultipartPartSize() + 1);
ByteSource byteSource1 = byteSource.slice(0, blobStore.getMinimumMultipartPartSize());
ByteSource byteSource2 = byteSource.slice(blobStore.getMinimumMultipartPartSize(), 1);
Payload payload1 = Payloads.newByteSourcePayload(byteSource1);
Payload payload2 = Payloads.newByteSourcePayload(byteSource2);
代码示例来源:origin: apache/jclouds
ByteSource byteSource = TestUtils.randomByteSource().slice(0, blobStore.getMinimumMultipartPartSize() + 1);
ByteSource byteSource1 = byteSource.slice(0, blobStore.getMinimumMultipartPartSize());
ByteSource byteSource2 = byteSource.slice(blobStore.getMinimumMultipartPartSize(), 1);
Payload payload1 = Payloads.newByteSourcePayload(byteSource1);
Payload payload2 = Payloads.newByteSourcePayload(byteSource2);
内容来源于网络,如有侵权,请联系作者删除!