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

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

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

BlobStore.streamBlob介绍

暂无

代码示例

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

@Override
  public InputStream streamBlob(String container, String name, ExecutorService executor) {
   return delegate().streamBlob(container, name, executor);
  }
}

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

@Override
public InputStream streamBlob(String container, String name) {
 return delegate().streamBlob(container, name);
}

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

@Override
  public InputStream streamBlob(String container, String name, ExecutorService executor) {
   return delegate().streamBlob(container, name, executor);
  }
}

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

@Override
  public InputStream streamBlob(String container, String name, ExecutorService executor) {
   return delegate().streamBlob(container, name, executor);
  }
}

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

@Override
  public InputStream streamBlob(String container, String name, ExecutorService executor) {
   return delegate().streamBlob(container, name, executor);
  }
}

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

@Override
public InputStream streamBlob(String container, String name) {
 return delegate().streamBlob(container, name);
}

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

@Override
public InputStream streamBlob(String container, String name) {
 return delegate().streamBlob(container, name);
}

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

@Override
public InputStream streamBlob(String container, String name) {
 return delegate().streamBlob(container, name);
}

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

@Test(dependsOnMethods = "uploadMultipartBlob", singleThreaded = true)
public void streamParallelBlob() throws IOException {
 InputStream is = blobStore.streamBlob(CONTAINER, bigFile.getName(), executor);
 byte[] segment = new byte[1000000];
 Hasher hasher = Hashing.md5().newHasher();
 int read;
 while ( (read = is.read(segment)) > 0) {
   System.out.println("Read " + read + " bytes from input stream.");
   hasher.putBytes(segment, 0, read);
 }
 is.close();
 assertEquals(hasher.hash().toString(), etag);
}

相关文章