Java 类org.apache.hadoop.fs.azure.StorageInterfaceImpl.CloudPageBlobWrapperImpl 实例源码

/**
 * 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 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 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 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());
  }
}