org.jclouds.blobstore.BlobStore.getBlob()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(163)

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

BlobStore.getBlob介绍

[英]Retrieves a Blob representing the data at location container/name
[中]检索表示位置容器/名称处的数据的Blob

代码示例

代码示例来源:origin: apache/usergrid

  1. Blob blob = blobStore.getBlob(bucketName, blobFileName);
  2. if ( blob == null) {
  3. throw new RuntimeException(

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

  1. if (Quirks.MULTIPART_REQUIRES_STUB.contains(getBlobStoreType(
  2. blobStore))) {
  3. Blob stubBlob = blobStore.getBlob(containerName, uploadId);
  4. BlobAccess access = blobStore.getBlobAccess(containerName,
  5. uploadId);

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

  1. @Override
  2. public String call() {
  3. Blob nearBlob = writeStore.getBlob(containerName, nearName);
  4. String farETag = delegate().putBlob(containerName,
  5. nearBlob, options);
  6. return farETag;
  7. }
  8. });

代码示例来源:origin: apache/usergrid

  1. Assert.fail("Blob does not exist: " + expectedFileName);
  2. Blob bo = blobStore.getBlob(bucketName, expectedFileName);

代码示例来源:origin: apache/usergrid

  1. assertEquals( numOfFiles, numWeWant );
  2. bo = blobStore.getBlob( bucketName, expectedFileName );

代码示例来源:origin: apache/usergrid

  1. Blob bo = blobStore.getBlob(bucketName, expectedFileName);
  2. Long numWeWant = 5L;
  3. blobStore.deleteContainer( bucketName );

代码示例来源:origin: rackerlabs/blueflood

  1. public String call() throws Exception {
  2. Blob blob = store.getBlob(container, name);
  3. Payload payload = blob.getPayload();
  4. InputStream is = payload.getInput();

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

  1. Blob blob = blobStore.getBlob(containerName, blobName, options);
  2. if (blob == null) {
  3. throw new S3Exception(S3ErrorCode.NO_SUCH_KEY);

代码示例来源:origin: jclouds/legacy-jclouds

  1. @Override
  2. public InputStream get(Object o) {
  3. String realKey = prefixer.apply(o.toString());
  4. Blob blob = blobstore.getBlob(containerName, realKey);
  5. return getInputStreamOrNull(blob);
  6. }

代码示例来源:origin: jclouds/legacy-jclouds

  1. @Override
  2. public Blob get(Object key) {
  3. String realKey = prefixer.apply(checkNotNull(key, "key").toString());
  4. Blob blob = blobstore.getBlob(containerName, realKey);
  5. return blob != null ? stripPrefix(blob) : null;
  6. }

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

  1. @Override
  2. public Blob get(Object key) {
  3. String realKey = prefixer.apply(checkNotNull(key, "key").toString());
  4. Blob blob = blobstore.getBlob(containerName, realKey);
  5. return blob != null ? stripPrefix(blob) : null;
  6. }

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

  1. @Override
  2. public String call() {
  3. Blob nearBlob = writeStore.getBlob(containerName, nearName);
  4. String farETag = delegate().putBlob(containerName,
  5. nearBlob, options);
  6. return farETag;
  7. }
  8. });

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

  1. @Override
  2. public Blob getBlob(String containerName, String blobName,
  3. GetOptions getOptions) {
  4. return delegate().getBlob(containerName, blobName, getOptions);
  5. }

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

  1. @Override
  2. public String call() {
  3. Blob nearBlob = writeStore.getBlob(containerName, nearName);
  4. String farETag = delegate().putBlob(containerName,
  5. nearBlob, options);
  6. return farETag;
  7. }
  8. });

代码示例来源:origin: apache/attic-whirr

  1. @Override
  2. public Cluster load() throws IOException {
  3. Blob blob = context.getBlobStore().getBlob(container, blobName);
  4. if (blob != null) {
  5. return unserialize(spec,
  6. IOUtils.toString(blob.getPayload().getInput(), "utf-8"));
  7. }
  8. return null;
  9. }

代码示例来源:origin: jclouds/legacy-jclouds

  1. public void run() {
  2. try {
  3. Location actualLoc = view.getBlobStore().getBlob(containerName, blobName).getMetadata().getLocation();
  4. assert loc.equals(actualLoc) : String.format(
  5. "blob %s in %s, in location %s instead of %s", blobName, containerName, actualLoc, loc);
  6. } catch (Exception e) {
  7. Throwables.propagate(e);
  8. }
  9. }
  10. });

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

  1. public void run() {
  2. try {
  3. Location actualLoc = view.getBlobStore().getBlob(containerName, blobName).getMetadata().getLocation();
  4. assert loc.equals(actualLoc) : String.format(
  5. "blob %s in %s, in location %s instead of %s", blobName, containerName, actualLoc, loc);
  6. } catch (Exception e) {
  7. Throwables.propagate(e);
  8. }
  9. }
  10. });

代码示例来源:origin: jclouds/legacy-jclouds

  1. public void run() {
  2. try {
  3. Blob blob = view.getBlobStore().getBlob(containerName, blobName);
  4. Date actualExpires = blob.getPayload().getContentMetadata().getExpires();
  5. assert expectedExpires.equals(actualExpires) : "expires=" + actualExpires + "; expected="
  6. + expectedExpires;
  7. } catch (Exception e) {
  8. Throwables.propagateIfPossible(e);
  9. }
  10. }
  11. });

代码示例来源:origin: jclouds/legacy-jclouds

  1. protected Blob validateContent(String container, String name) throws InterruptedException {
  2. assertConsistencyAwareContainerSize(container, 1);
  3. Blob newObject = view.getBlobStore().getBlob(container, name);
  4. assert newObject != null;
  5. validateMetadata(newObject.getMetadata(), container, name);
  6. try {
  7. assertEquals(getContentAsStringOrNullAndClose(newObject), TEST_STRING);
  8. } catch (IOException e) {
  9. throw new RuntimeException(e);
  10. }
  11. return newObject;
  12. }

代码示例来源:origin: jclouds/legacy-jclouds

  1. @Test(groups = { "integration", "live" })
  2. public void testGetTwoRanges() throws InterruptedException, IOException {
  3. String container = getContainerName();
  4. try {
  5. String name = "apples";
  6. addObjectAndValidateContent(container, name);
  7. Blob blob = view.getBlobStore().getBlob(container, name, range(0, 5).range(6, TEST_STRING.length()));
  8. validateMetadata(blob.getMetadata(), container, name);
  9. assertEquals(getContentAsStringOrNullAndClose(blob), TEST_STRING);
  10. } finally {
  11. returnContainer(container);
  12. }
  13. }

相关文章