public final class PageBlobClient extends BlobClientBase
SpecializedBlobClientBuilder
or via the method
BlobClient.getPageBlobClient()
. This class does not hold any state about a particular blob, but is instead a
convenient way of sending appropriate requests to the resource on the service.
Please refer to the Azure Docs for more information.
Modifier and Type | Field and Description |
---|---|
static int |
MAX_PUT_PAGES_BYTES
Indicates the maximum number of bytes that may be sent in a call to putPage.
|
static int |
PAGE_BYTES
Indicates the number of bytes in a page.
|
Modifier and Type | Method and Description |
---|---|
PageBlobItem |
clearPages(PageRange pageRange)
Frees the specified pages from the page blob.
|
Response<PageBlobItem> |
clearPagesWithResponse(PageRange pageRange,
PageBlobRequestConditions pageBlobRequestConditions,
Duration timeout,
Context context)
Frees the specified pages from the page blob.
|
CopyStatusType |
copyIncremental(String source,
String snapshot)
Begins an operation to start an incremental copy from one page blob's snapshot to this page blob.
|
Response<CopyStatusType> |
copyIncrementalWithResponse(String source,
String snapshot,
RequestConditions modifiedAccessConditions,
Duration timeout,
Context context)
Begins an operation to start an incremental copy from one page blob's snapshot to this page blob.
|
PageBlobItem |
create(long size)
Creates a page blob of the specified length.
|
PageBlobItem |
create(long size,
boolean overwrite)
Creates a page blob of the specified length.
|
Response<PageBlobItem> |
createWithResponse(long size,
Long sequenceNumber,
BlobHttpHeaders headers,
Map<String,String> metadata,
BlobRequestConditions accessConditions,
Duration timeout,
Context context)
Creates a page blob of the specified length.
|
BlobOutputStream |
getBlobOutputStream(PageRange pageRange)
Creates and opens an output stream to write data to the page blob.
|
BlobOutputStream |
getBlobOutputStream(PageRange pageRange,
BlobRequestConditions accessConditions)
Creates and opens an output stream to write data to the page blob.
|
PageList |
getPageRanges(BlobRange blobRange)
Returns the list of valid page ranges for a page blob or snapshot of a page blob.
|
PageList |
getPageRangesDiff(BlobRange blobRange,
String prevSnapshot)
Gets the collection of page ranges that differ between a specified snapshot and this page blob.
|
Response<PageList> |
getPageRangesDiffWithResponse(BlobRange blobRange,
String prevSnapshot,
BlobRequestConditions accessConditions,
Duration timeout,
Context context)
Gets the collection of page ranges that differ between a specified snapshot and this page blob.
|
Response<PageList> |
getPageRangesWithResponse(BlobRange blobRange,
BlobRequestConditions accessConditions,
Duration timeout,
Context context)
Returns the list of valid page ranges for a page blob or snapshot of a page blob.
|
PageBlobItem |
resize(long size)
Resizes the page blob to the specified size (which must be a multiple of 512).
|
Response<PageBlobItem> |
resizeWithResponse(long size,
BlobRequestConditions accessConditions,
Duration timeout,
Context context)
Resizes the page blob to the specified size (which must be a multiple of 512).
|
PageBlobItem |
updateSequenceNumber(SequenceNumberActionType action,
Long sequenceNumber)
Sets the page blob's sequence number.
|
Response<PageBlobItem> |
updateSequenceNumberWithResponse(SequenceNumberActionType action,
Long sequenceNumber,
BlobRequestConditions accessConditions,
Duration timeout,
Context context)
Sets the page blob's sequence number.
|
PageBlobItem |
uploadPages(PageRange pageRange,
InputStream body)
Writes one or more pages to the page blob.
|
PageBlobItem |
uploadPagesFromUrl(PageRange range,
String sourceUrl,
Long sourceOffset)
Writes one or more pages from the source page blob to this page blob.
|
Response<PageBlobItem> |
uploadPagesFromUrlWithResponse(PageRange range,
String sourceUrl,
Long sourceOffset,
byte[] sourceContentMd5,
PageBlobRequestConditions destAccessConditions,
BlobRequestConditions sourceRequestConditions,
Duration timeout,
Context context)
Writes one or more pages from the source page blob to this page blob.
|
Response<PageBlobItem> |
uploadPagesWithResponse(PageRange pageRange,
InputStream body,
byte[] contentMd5,
PageBlobRequestConditions pageBlobRequestConditions,
Duration timeout,
Context context)
Writes one or more pages to the page blob.
|
abortCopyFromUrl, abortCopyFromUrlWithResponse, beginCopy, beginCopy, copyFromUrl, copyFromUrlWithResponse, createSnapshot, createSnapshotWithResponse, delete, deleteWithResponse, download, downloadToFile, downloadToFileWithResponse, downloadWithResponse, exists, existsWithResponse, getAccountInfo, getAccountInfoWithResponse, getAccountName, getBlobName, getBlobUrl, getContainerName, getCustomerProvidedKey, getHttpPipeline, getProperties, getPropertiesWithResponse, getServiceVersion, getSnapshotClient, getSnapshotId, isSnapshot, openInputStream, openInputStream, setAccessTier, setAccessTierWithResponse, setHttpHeaders, setHttpHeadersWithResponse, setMetadata, setMetadataWithResponse, undelete, undeleteWithResponse
public static final int PAGE_BYTES
public static final int MAX_PUT_PAGES_BYTES
public BlobOutputStream getBlobOutputStream(PageRange pageRange)
pageRange
- A PageRange
object. Given that pages must be aligned with 512-byte boundaries, the start
offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte ranges
are 0-511, 512-1023, etc.BlobOutputStream
object used to write data to the blob.BlobStorageException
- If a storage service error occurred.public BlobOutputStream getBlobOutputStream(PageRange pageRange, BlobRequestConditions accessConditions)
pageRange
- A PageRange
object. Given that pages must be aligned with 512-byte boundaries, the start
offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte ranges
are 0-511, 512-1023, etc.accessConditions
- A BlobRequestConditions
object that represents the access conditions for the
blob.BlobOutputStream
object used to write data to the blob.BlobStorageException
- If a storage service error occurred.public PageBlobItem create(long size)
Code Samples
PageBlobItem
pageBlob = client.create(size);System
.out.printf("Created page blob with sequence number %s%n", pageBlob.getBlobSequenceNumber());
size
- Specifies the maximum size for the page blob, up to 8 TB. The page blob size must be aligned to a
512-byte boundary.public PageBlobItem create(long size, boolean overwrite)
Code Samples
boolean overwrite = false; // Default valuePageBlobItem
pageBlob = client.create(size, overwrite);System
.out.printf("Created page blob with sequence number %s%n", pageBlob.getBlobSequenceNumber());
size
- Specifies the maximum size for the page blob, up to 8 TB. The page blob size must be aligned to a
512-byte boundary.overwrite
- Whether or not to overwrite, should data exist on the blob.public Response<PageBlobItem> createWithResponse(long size, Long sequenceNumber, BlobHttpHeaders headers, Map<String,String> metadata, BlobRequestConditions accessConditions, Duration timeout, Context context)
Code Samples
BlobHttpHeaders
headers = newBlobHttpHeaders
() .setContentLanguage("en-US") .setContentType("binary");BlobRequestConditions
blobRequestConditions = newBlobRequestConditions
().setLeaseId(leaseId);Context
context = newContext
(key, value);PageBlobItem
pageBlob = client .createWithResponse(size, sequenceNumber, headers, metadata, blobRequestConditions, timeout, context) .getValue();System
.out.printf("Created page blob with sequence number %s%n", pageBlob.getBlobSequenceNumber());
size
- Specifies the maximum size for the page blob, up to 8 TB. The page blob size must be aligned to a
512-byte boundary.sequenceNumber
- A user-controlled value that you can use to track requests. The value of the sequence
number must be between 0 and 2^63 - 1.The default value is 0.headers
- BlobHttpHeaders
metadata
- Metadata to associate with the blob.accessConditions
- BlobRequestConditions
timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.public PageBlobItem uploadPages(PageRange pageRange, InputStream body)
Note that the data passed must be replayable if retries are enabled (the default). In other words, the
Flux
must produce the same data each time it is subscribed to.
Code Samples
PageRange
pageRange = newPageRange
() .setStart(0) .setEnd(511);InputStream
dataStream = newByteArrayInputStream
(data.getBytes(StandardCharsets
.UTF_8));PageBlobItem
pageBlob = client.uploadPages(pageRange, dataStream);System
.out.printf("Uploaded page blob with sequence number %s%n", pageBlob.getBlobSequenceNumber());
pageRange
- A PageRange
object. Given that pages must be aligned with 512-byte boundaries, the start
offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte ranges
are 0-511, 512-1023, etc.body
- The data to upload.public Response<PageBlobItem> uploadPagesWithResponse(PageRange pageRange, InputStream body, byte[] contentMd5, PageBlobRequestConditions pageBlobRequestConditions, Duration timeout, Context context)
Note that the data passed must be replayable if retries are enabled (the default). In other words, the
Flux
must produce the same data each time it is subscribed to.
Code Samples
byte[] md5 =MessageDigest
.getInstance("MD5").digest("data".getBytes(StandardCharsets
.UTF_8));PageRange
pageRange = newPageRange
() .setStart(0) .setEnd(511);InputStream
dataStream = newByteArrayInputStream
(data.getBytes(StandardCharsets
.UTF_8));PageBlobRequestConditions
pageBlobRequestConditions = newPageBlobRequestConditions
().setLeaseId(leaseId);Context
context = newContext
(key, value);PageBlobItem
pageBlob = client .uploadPagesWithResponse(pageRange, dataStream, md5, pageBlobRequestConditions, timeout, context).getValue();System
.out.printf("Uploaded page blob with sequence number %s%n", pageBlob.getBlobSequenceNumber());
pageRange
- A PageRange
object. Given that pages must be aligned with 512-byte boundaries, the start
offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte ranges
are 0-511, 512-1023, etc.body
- The data to upload.contentMd5
- An MD5 hash of the page content. This hash is used to verify the integrity of the page during
transport. When this header is specified, the storage service compares the hash of the content that has arrived
with this header value. Note that this MD5 hash is not stored with the blob. If the two hashes do not match, the
operation will fail.pageBlobRequestConditions
- PageBlobRequestConditions
timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.UnexpectedLengthException
- when the length of data does not match the input length
.NullPointerException
- if the input data is null.public PageBlobItem uploadPagesFromUrl(PageRange range, String sourceUrl, Long sourceOffset)
Code Samples
PageRange
pageRange = newPageRange
() .setStart(0) .setEnd(511);PageBlobItem
pageBlob = client.uploadPagesFromUrl(pageRange, url, sourceOffset);System
.out.printf("Uploaded page blob from URL with sequence number %s%n", pageBlob.getBlobSequenceNumber());
range
- A PageRange
object. Given that pages must be aligned with 512-byte boundaries, the start
offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte ranges
are 0-511, 512-1023, etc.sourceUrl
- The url to the blob that will be the source of the copy. A source blob in the same storage
account can be authenticated via Shared Key. However, if the source is a blob in another account, the source blob
must either be public or must be authenticated via a shared access signature. If the source blob is public, no
authentication is required to perform the operation.sourceOffset
- The source offset to copy from. Pass null or 0 to copy from the beginning of source page
blob.IllegalArgumentException
- If sourceUrl
is a malformed URL
.public Response<PageBlobItem> uploadPagesFromUrlWithResponse(PageRange range, String sourceUrl, Long sourceOffset, byte[] sourceContentMd5, PageBlobRequestConditions destAccessConditions, BlobRequestConditions sourceRequestConditions, Duration timeout, Context context)
Code Samples
PageRange
pageRange = newPageRange
() .setStart(0) .setEnd(511);InputStream
dataStream = newByteArrayInputStream
(data.getBytes(StandardCharsets
.UTF_8)); byte[] sourceContentMD5 = new byte[512];PageBlobRequestConditions
pageBlobRequestConditions = newPageBlobRequestConditions
().setLeaseId(leaseId);BlobRequestConditions
sourceAccessConditions = newBlobRequestConditions
() .setIfUnmodifiedSince(OffsetDateTime
.now().minusDays(3));Context
context = newContext
(key, value);PageBlobItem
pageBlob = client .uploadPagesFromUrlWithResponse(pageRange, url, sourceOffset, sourceContentMD5, pageBlobRequestConditions, sourceAccessConditions, timeout, context).getValue();System
.out.printf("Uploaded page blob from URL with sequence number %s%n", pageBlob.getBlobSequenceNumber());
range
- The destination PageRange
range. Given that pages must be aligned with 512-byte boundaries,
the start offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte
ranges are 0-511, 512-1023, etc.sourceUrl
- The url to the blob that will be the source of the copy. A source blob in the same storage
account can be authenticated via Shared Key. However, if the source is a blob in another account, the source blob
must either be public or must be authenticated via a shared access signature. If the source blob is public, no
authentication is required to perform the operation.sourceOffset
- The source offset to copy from. Pass null or 0 to copy from the beginning of source blob.sourceContentMd5
- An MD5 hash of the block content from the source blob. If specified, the service will
calculate the MD5 of the received data and fail the request if it does not match the provided MD5.destAccessConditions
- PageBlobRequestConditions
sourceRequestConditions
- BlobRequestConditions
timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.IllegalArgumentException
- If sourceUrl
is a malformed URL
.public PageBlobItem clearPages(PageRange pageRange)
Code Samples
PageRange
pageRange = newPageRange
() .setStart(0) .setEnd(511);PageBlobItem
pageBlob = client.clearPages(pageRange);System
.out.printf("Cleared page blob with sequence number %s%n", pageBlob.getBlobSequenceNumber());
pageRange
- A PageRange
object. Given that pages must be aligned with 512-byte boundaries, the start
offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte ranges
are 0-511, 512-1023, etc.public Response<PageBlobItem> clearPagesWithResponse(PageRange pageRange, PageBlobRequestConditions pageBlobRequestConditions, Duration timeout, Context context)
Code Samples
PageRange
pageRange = newPageRange
() .setStart(0) .setEnd(511);PageBlobRequestConditions
pageBlobRequestConditions = newPageBlobRequestConditions
().setLeaseId(leaseId);Context
context = newContext
(key, value);PageBlobItem
pageBlob = client .clearPagesWithResponse(pageRange, pageBlobRequestConditions, timeout, context).getValue();System
.out.printf("Cleared page blob with sequence number %s%n", pageBlob.getBlobSequenceNumber());
pageRange
- A PageRange
object. Given that pages must be aligned with 512-byte boundaries, the start
offset must be a modulus of 512 and the end offset must be a modulus of 512 - 1. Examples of valid byte ranges
are 0-511, 512-1023, etc.timeout
- An optional timeout value beyond which a RuntimeException
will be raised.pageBlobRequestConditions
- PageBlobRequestConditions
context
- Additional context that is passed through the Http pipeline during the service call.public PageList getPageRanges(BlobRange blobRange)
Code Samples
BlobRange
blobRange = newBlobRange
(offset);PageList
pageList = client.getPageRanges(blobRange);System
.out.println("Valid Page Ranges are:"); for (PageRange
pageRange : pageList.getPageRange()) {System
.out.printf("Start: %s, End: %s%n", pageRange.getStart(), pageRange.getEnd()); }
blobRange
- BlobRange
public Response<PageList> getPageRangesWithResponse(BlobRange blobRange, BlobRequestConditions accessConditions, Duration timeout, Context context)
Code Samples
BlobRange
blobRange = newBlobRange
(offset);BlobRequestConditions
blobRequestConditions = newBlobRequestConditions
().setLeaseId(leaseId);Context
context = newContext
(key, value);PageList
pageList = client .getPageRangesWithResponse(blobRange, blobRequestConditions, timeout, context).getValue();System
.out.println("Valid Page Ranges are:"); for (PageRange
pageRange : pageList.getPageRange()) {System
.out.printf("Start: %s, End: %s%n", pageRange.getStart(), pageRange.getEnd()); }
blobRange
- BlobRange
accessConditions
- BlobRequestConditions
timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.public PageList getPageRangesDiff(BlobRange blobRange, String prevSnapshot)
Code Samples
BlobRange
blobRange = newBlobRange
(offset); finalString
prevSnapshot = "previous snapshot";PageList
pageList = client.getPageRangesDiff(blobRange, prevSnapshot);System
.out.println("Valid Page Ranges are:"); for (PageRange
pageRange : pageList.getPageRange()) {System
.out.printf("Start: %s, End: %s%n", pageRange.getStart(), pageRange.getEnd()); }
blobRange
- BlobRange
prevSnapshot
- Specifies that the response will contain only pages that were changed between target blob and
previous snapshot. Changed pages include both updated and cleared pages. The target blob may be a snapshot, as
long as the snapshot specified by prevsnapshot is the older of the two.public Response<PageList> getPageRangesDiffWithResponse(BlobRange blobRange, String prevSnapshot, BlobRequestConditions accessConditions, Duration timeout, Context context)
Code Samples
BlobRange
blobRange = newBlobRange
(offset); finalString
prevSnapshot = "previous snapshot";BlobRequestConditions
blobRequestConditions = newBlobRequestConditions
().setLeaseId(leaseId);Context
context = newContext
(key, value);PageList
pageList = client .getPageRangesDiffWithResponse(blobRange, prevSnapshot, blobRequestConditions, timeout, context).getValue();System
.out.println("Valid Page Ranges are:"); for (PageRange
pageRange : pageList.getPageRange()) {System
.out.printf("Start: %s, End: %s%n", pageRange.getStart(), pageRange.getEnd()); }
blobRange
- BlobRange
prevSnapshot
- Specifies that the response will contain only pages that were changed between target blob and
previous snapshot. Changed pages include both updated and cleared pages. The target blob may be a snapshot, as
long as the snapshot specified by prevsnapshot is the older of the two.accessConditions
- BlobRequestConditions
timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.public PageBlobItem resize(long size)
Code Samples
PageBlobItem
pageBlob = client.resize(size);System
.out.printf("Page blob resized with sequence number %s%n", pageBlob.getBlobSequenceNumber());
size
- Resizes a page blob to the specified size. If the specified value is less than the current size of
the blob, then all pages above the specified value are cleared.public Response<PageBlobItem> resizeWithResponse(long size, BlobRequestConditions accessConditions, Duration timeout, Context context)
Code Samples
BlobRequestConditions
blobRequestConditions = newBlobRequestConditions
().setLeaseId(leaseId);Context
context = newContext
(key, value);PageBlobItem
pageBlob = client .resizeWithResponse(size, blobRequestConditions, timeout, context).getValue();System
.out.printf("Page blob resized with sequence number %s%n", pageBlob.getBlobSequenceNumber());
size
- Resizes a page blob to the specified size. If the specified value is less than the current size of
the blob, then all pages above the specified value are cleared.accessConditions
- BlobRequestConditions
timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.public PageBlobItem updateSequenceNumber(SequenceNumberActionType action, Long sequenceNumber)
Code Samples
PageBlobItem
pageBlob = client.updateSequenceNumber(SequenceNumberActionType
.INCREMENT, size);System
.out.printf("Page blob updated to sequence number %s%n", pageBlob.getBlobSequenceNumber());
action
- Indicates how the service should modify the blob's sequence number.sequenceNumber
- The blob's sequence number. The sequence number is a user-controlled property that you can
use to track requests and manage concurrency issues.public Response<PageBlobItem> updateSequenceNumberWithResponse(SequenceNumberActionType action, Long sequenceNumber, BlobRequestConditions accessConditions, Duration timeout, Context context)
Code Samples
BlobRequestConditions
blobRequestConditions = newBlobRequestConditions
().setLeaseId(leaseId);Context
context = newContext
(key, value);PageBlobItem
pageBlob = client.updateSequenceNumberWithResponse(SequenceNumberActionType
.INCREMENT, size, blobRequestConditions, timeout, context).getValue();System
.out.printf("Page blob updated to sequence number %s%n", pageBlob.getBlobSequenceNumber());
action
- Indicates how the service should modify the blob's sequence number.sequenceNumber
- The blob's sequence number. The sequence number is a user-controlled property that you can
use to track requests and manage concurrency issues.accessConditions
- BlobRequestConditions
timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.public CopyStatusType copyIncremental(String source, String snapshot)
Code Samples
finalString
snapshot = "copy snapshot";CopyStatusType
statusType = client.copyIncremental(url, snapshot); if (CopyStatusType
.SUCCESS == statusType) {System
.out.println("Page blob copied successfully"); } else if (CopyStatusType
.FAILED == statusType) {System
.out.println("Page blob copied failed"); } else if (CopyStatusType
.ABORTED == statusType) {System
.out.println("Page blob copied aborted"); } else if (CopyStatusType
.PENDING == statusType) {System
.out.println("Page blob copied pending"); }
source
- The source page blob.snapshot
- The snapshot on the copy source.IllegalArgumentException
- If source
is a malformed URL
.public Response<CopyStatusType> copyIncrementalWithResponse(String source, String snapshot, RequestConditions modifiedAccessConditions, Duration timeout, Context context)
Code Samples
finalString
snapshot = "copy snapshot";RequestConditions
modifiedAccessConditions = newRequestConditions
() .setIfNoneMatch("snapshotMatch");Context
context = newContext
(key, value);CopyStatusType
statusType = client .copyIncrementalWithResponse(url, snapshot, modifiedAccessConditions, timeout, context).getValue(); if (CopyStatusType
.SUCCESS == statusType) {System
.out.println("Page blob copied successfully"); } else if (CopyStatusType
.FAILED == statusType) {System
.out.println("Page blob copied failed"); } else if (CopyStatusType
.ABORTED == statusType) {System
.out.println("Page blob copied aborted"); } else if (CopyStatusType
.PENDING == statusType) {System
.out.println("Page blob copied pending"); }
source
- The source page blob.snapshot
- The snapshot on the copy source.modifiedAccessConditions
- Standard HTTP Access conditions related to the modification of data. ETag and
LastModifiedTime are used to construct conditions related to when the blob was changed relative to the given
request. The request will fail if the specified condition is not satisfied.timeout
- An optional timeout value beyond which a RuntimeException
will be raised.context
- Additional context that is passed through the Http pipeline during the service call.IllegalArgumentException
- If source
is a malformed URL
.Copyright © 2019 Microsoft Corporation. All rights reserved.