Java 类org.apache.hadoop.fs.azure.StorageInterface.CloudBlockBlobWrapper 实例源码

/**
 * Opens a new output stream to the given blob (page or block blob)
 * to populate it from scratch with data.
 */
private OutputStream openOutputStream(final CloudBlobWrapper blob)
    throws StorageException {
  if (blob instanceof CloudPageBlobWrapperImpl){
    return new PageBlobOutputStream(
        (CloudPageBlobWrapper)blob, getInstrumentedContext(), sessionConfiguration);
  } else {

    // Handle both ClouldBlockBlobWrapperImpl and (only for the test code path)
    // MockCloudBlockBlobWrapper.
    return ((CloudBlockBlobWrapper) blob).openOutputStream(getUploadOptions(),
              getInstrumentedContext());
  }
}

/**
 * Opens a new input stream for the given blob (page or block blob)
 * to read its data.
 */
private InputStream openInputStream(CloudBlobWrapper blob)
    throws StorageException, IOException {
  if (blob instanceof CloudBlockBlobWrapper) {
    return blob.openInputStream(getDownloadOptions(),
        getInstrumentedContext(isConcurrentOOBAppendAllowed()));
  } else {
    return new PageBlobInputStream(
        (CloudPageBlobWrapper) blob, getInstrumentedContext(
            isConcurrentOOBAppendAllowed()));
  }
}

/**
 * Opens a new output stream to the given blob (page or block blob)
 * to populate it from scratch with data.
 */
private OutputStream openOutputStream(final CloudBlobWrapper blob)
    throws StorageException {
  if (blob instanceof CloudPageBlobWrapperImpl){
    return new PageBlobOutputStream(
        (CloudPageBlobWrapper)blob, getInstrumentedContext(), sessionConfiguration);
  } else {

    // Handle both ClouldBlockBlobWrapperImpl and (only for the test code path)
    // MockCloudBlockBlobWrapper.
    return ((CloudBlockBlobWrapper) blob).openOutputStream(getUploadOptions(),
              getInstrumentedContext());
  }
}

/**
 * Opens a new input stream for the given blob (page or block blob)
 * to read its data.
 */
private InputStream openInputStream(CloudBlobWrapper blob)
    throws StorageException, IOException {
  if (blob instanceof CloudBlockBlobWrapper) {
    return blob.openInputStream(getDownloadOptions(),
        getInstrumentedContext(isConcurrentOOBAppendAllowed()));
  } else {
    return new PageBlobInputStream(
        (CloudPageBlobWrapper) blob, getInstrumentedContext(
            isConcurrentOOBAppendAllowed()));
  }
}

/**
 * Opens a new output stream to the given blob (page or block blob)
 * to populate it from scratch with data.
 */
private OutputStream openOutputStream(final CloudBlobWrapper blob)
    throws StorageException {
  if (blob instanceof CloudPageBlobWrapperImpl){
    return new PageBlobOutputStream(
        (CloudPageBlobWrapper)blob, getInstrumentedContext(), sessionConfiguration);
  } else {

    // Handle both ClouldBlockBlobWrapperImpl and (only for the test code path)
    // MockCloudBlockBlobWrapper.
    return ((CloudBlockBlobWrapper) blob).openOutputStream(getUploadOptions(),
              getInstrumentedContext());
  }
}

/**
 * Opens a new input stream for the given blob (page or block blob)
 * to read its data.
 */
private InputStream openInputStream(CloudBlobWrapper blob)
    throws StorageException, IOException {
  if (blob instanceof CloudBlockBlobWrapper) {
    return blob.openInputStream(getDownloadOptions(),
        getInstrumentedContext(isConcurrentOOBAppendAllowed()));
  } else {
    return new PageBlobInputStream(
        (CloudPageBlobWrapper) blob, getInstrumentedContext(
            isConcurrentOOBAppendAllowed()));
  }
}

/**
 * Opens a new output stream to the given blob (page or block blob)
 * to populate it from scratch with data.
 */
private OutputStream openOutputStream(final CloudBlobWrapper blob)
    throws StorageException {
  if (blob instanceof CloudPageBlobWrapperImpl){
    return new PageBlobOutputStream(
        (CloudPageBlobWrapper)blob, getInstrumentedContext(), sessionConfiguration);
  } else {

    // Handle both ClouldBlockBlobWrapperImpl and (only for the test code path)
    // MockCloudBlockBlobWrapper.
    return ((CloudBlockBlobWrapper) blob).openOutputStream(getUploadOptions(),
              getInstrumentedContext());
  }
}

/**
 * Opens a new input stream for the given blob (page or block blob)
 * to read its data.
 */
private InputStream openInputStream(CloudBlobWrapper blob)
    throws StorageException, IOException {
  if (blob instanceof CloudBlockBlobWrapper) {
    return blob.openInputStream(getDownloadOptions(),
        getInstrumentedContext(isConcurrentOOBAppendAllowed()));
  } else {
    return new PageBlobInputStream(
        (CloudPageBlobWrapper) blob, getInstrumentedContext(
            isConcurrentOOBAppendAllowed()));
  }
}