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

Blob.getPayload介绍

暂无

代码示例

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

tempFile.deleteOnExit();
fop = new FileOutputStream(tempFile);
InputStream is = blob.getPayload().openStream();
IOUtils.copyLarge(is, fop);
return tempFile;

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

public String call() throws Exception {
  Blob blob = store.getBlob(container, name);
  Payload payload = blob.getPayload();
  InputStream is = payload.getInput();
  File tempFile = new File(downloadDir, name + ".tmp");

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

try (InputStream is = blob.getPayload().openStream();
   OutputStream os = response.getOutputStream()) {
  ByteStreams.copy(is, os);

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

@Override
public String putBlob(String containerName, Blob blob,
    PutOptions options) {
  long length;
  try (InputStream is = blob.getPayload().openStream()) {
    length = ByteStreams.copy(is, ByteStreams.nullOutputStream());
  } catch (IOException ioe) {
    throw new RuntimeException(ioe);
  }
  byte[] array = Longs.toByteArray(length);
  ByteSourcePayload payload = new ByteSourcePayload(
      ByteSource.wrap(array));
  payload.setContentMetadata(blob.getPayload().getContentMetadata());
  payload.getContentMetadata().setContentLength((long) array.length);
  payload.getContentMetadata().setContentMD5((HashCode) null);
  blob.setPayload(payload);
  return super.putBlob(containerName, blob, options);
}

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

@Override
@Nullable
public Blob getBlob(String container, String name, GetOptions options) {
  Blob blob = super.getBlob(container, name, options);
  if (blob == null) {
    return null;
  }
  byte[] array;
  try (InputStream is = blob.getPayload().openStream()) {
    array = ByteStreams.toByteArray(is);
  } catch (IOException ioe) {
    throw new RuntimeException(ioe);
  }
  long length = Longs.fromByteArray(array);
  ByteSourcePayload payload = new ByteSourcePayload(
      new NullByteSource().slice(0, length));
  payload.setContentMetadata(blob.getPayload().getContentMetadata());
  payload.getContentMetadata().setContentLength(length);
  payload.getContentMetadata().setContentMD5((HashCode) null);
  blob.setPayload(payload);
  return blob;
}

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

private Blob copyBlob(Blob blob) {
 Blob returnVal = blobFactory.create(BlobStoreUtils.copy(blob.getMetadata()));
 returnVal.setPayload(blob.getPayload());
 copyPayloadHeadersToBlob(blob.getPayload(), returnVal);
 return returnVal;
}

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

@Override
public String putBlob(final String containerName, final Blob blob) throws IOException {
 Blob newBlob = createUpdatedCopyOfBlobInContainer(containerName, blob);
 Map<String, Blob> map = containerToBlobs.get(containerName);
 map.put(newBlob.getMetadata().getName(), newBlob);
 Payloads.calculateMD5(newBlob);
 return base16().lowerCase().encode(newBlob.getPayload().getContentMetadata().getContentMD5());
}

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

public AtmosObject apply(Blob from) {
   if (from == null)
     return null;
   AtmosObject object = blobMd2Object.apply(from.getMetadata());
   object.setPayload(checkNotNull(from.getPayload(), "payload: " + from));
   object.setAllHeaders(from.getAllHeaders());
   return object;
  }
}

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

@Override
  public <R extends HttpRequest> R bindToRequest(R request, Object input) {
   checkArgument(checkNotNull(input, "input") instanceof Blob, "this binder is only valid for Blobs!");
   checkNotNull(request, "request");
   Blob blob = Blob.class.cast(input);

   Part part = Part.create(blob.getMetadata().getName(), blob.getPayload(),
      new PartOptions().contentType(blob.getMetadata().getContentMetadata().getContentType()));

   request.setPayload(new MultipartForm(part));
   return request;
  }
}

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

@Override
public HttpRequest signPutBlob(String container, Blob blob) {
 HttpRequest request = HttpRequest.builder().method("PUT").endpoint(
      URI.create(String.format("%s/%s/%s", endpoint.get(), container, blob.getMetadata().getName()))).payload(
      blob.getPayload()).headers(
      contentMetadataCodec.toHeaders(blob.getMetadata().getContentMetadata())).build();
 return basicAuth.filter(request);
}

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

public S3Object apply(Blob from) {
   if (from == null)
     return null;
   S3Object object = objectProvider.create(blob2ObjectMd.apply(from.getMetadata()));
   object.setPayload(checkNotNull(from.getPayload(), "payload: " + from));
   object.setAllHeaders(from.getAllHeaders());
   return object;
  }
}

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

public SwiftObject apply(Blob from) {
   if (from == null)
     return null;
   SwiftObject object = objectProvider.create(blob2ObjectMd.apply(from.getMetadata()));
   object.setPayload(checkNotNull(from.getPayload(), "payload: " + from));
   object.setAllHeaders(from.getAllHeaders());
   return object;
  }
}

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

public void run() {
   try {
     Blob blob = view.getBlobStore().getBlob(containerName, blobName);
     Date actualExpires = blob.getPayload().getContentMetadata().getExpires();
     assert expectedExpires.equals(actualExpires) : "expires=" + actualExpires + "; expected="
         + expectedExpires;
   } catch (Exception e) {
     Throwables.propagateIfPossible(e);
   }
  }
});

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

@Override
protected void checkContentDisposition(Blob blob, String contentDisposition) {
 assert blob.getPayload().getContentMetadata().getContentDisposition().startsWith(contentDisposition) : blob
      .getPayload().getContentMetadata().getContentDisposition();
 assert blob.getMetadata().getContentMetadata().getContentDisposition().startsWith(contentDisposition) : blob
      .getMetadata().getContentMetadata().getContentDisposition();
}

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

protected void checkContentType(Blob blob, String contentType) {
 assert blob.getPayload().getContentMetadata().getContentType().startsWith(contentType) : blob.getPayload()
      .getContentMetadata().getContentType();
 assert blob.getMetadata().getContentMetadata().getContentType().startsWith(contentType) : blob.getMetadata()
      .getContentMetadata().getContentType();
}

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

protected void checkContentDisposition(Blob blob, String contentDisposition) {
 assert blob.getPayload().getContentMetadata().getContentDisposition().startsWith(contentDisposition) : blob
      .getPayload().getContentMetadata().getContentDisposition();
 assert blob.getMetadata().getContentMetadata().getContentDisposition().startsWith(contentDisposition) : blob
      .getMetadata().getContentMetadata().getContentDisposition();
}

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

protected void checkContentEncoding(Blob blob, String contentEncoding) {
 assert (blob.getPayload().getContentMetadata().getContentEncoding().indexOf(contentEncoding) != -1) : blob
      .getPayload().getContentMetadata().getContentEncoding();
 assert (blob.getMetadata().getContentMetadata().getContentEncoding().indexOf(contentEncoding) != -1) : blob
      .getMetadata().getContentMetadata().getContentEncoding();
}

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

@Override
protected void checkContentLanguage(Blob blob, String contentLanguage) {
 assert blob.getPayload().getContentMetadata().getContentLanguage() == null;
 assert blob.getMetadata().getContentMetadata().getContentLanguage() == null;
}

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

@Override
  protected void checkContentDisposition(Blob blob, String contentDisposition) {
   assert blob.getPayload().getContentMetadata().getContentDisposition() == null;
   assert blob.getMetadata().getContentMetadata().getContentDisposition() == null;
  }
}

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

@Test
public void testSignPutBlobWithTime() throws Exception {
 BlobStore signPutBloblWithTime = requestsSendResponses(init());
 Blob blob = signPutBloblWithTime.blobBuilder(name).payload(text).contentType("text/plain").build();
 HttpRequest compare = putBlobWithTime();
 compare.setPayload(blob.getPayload());
 assertEquals(signPutBloblWithTime.getContext().getSigner().signPutBlob(container, blob, 3l /* seconds */),
    compare);
}