com.aliyun.odps.storage

Interface BlobManager

All Known Implementing Classes:

BlobManagerImpl

public interface BlobManager

Manager for blob download operations in MaxCompute Storage API.

This interface provides methods for downloading blobs from MaxCompute storage. Both single blob download and batch download operations are supported.

Example usage for single blob download:

 Blob blobRef = Blob.fromReference("blob_reference");
 try (InputStream stream = blobManager.download(blobRef)) {
     // Read data from stream
 }
 

Example usage for batch blob download:

 List<Blob> blobs = Arrays.asList(blob1, blob2, blob3);
 try (BlobDataIterator iterator = blobManager.batchDownload(blobs)) {
     while (iterator.hasNext()) {
         try (InputStream stream = iterator.next()) {
             // Read data from stream
         }
     }
 }
 

Method Summary

Modifier and Type	Method and Description
BlobDataIterator	batchDownload(List<Blob> blobs) Downloads multiple blobs in batch.
InputStream	download(Blob blobRef) Downloads a single blob from MaxCompute storage.

Method Detail

download

InputStream download(Blob blobRef)

Downloads a single blob from MaxCompute storage.

The returned InputStream must be closed by the caller to release resources. It is recommended to use try-with-resources to ensure the stream is properly closed.

Parameters:

blobRef - The blob reference to download

Returns:

An InputStream containing the blob data

Throws:

BlobDownloadException - if the blob download fails

MaxStorageException - if the blob does not exist or access is denied

ClientException - if there is a client-side error

batchDownload

BlobDataIterator batchDownload(List<Blob> blobs)

Downloads multiple blobs in batch.

The returned BlobDataIterator must be closed by the caller to release resources. It is recommended to use try-with-resources to ensure the iterator is properly closed.

The order of blobs returned by the iterator matches the order of the input list. If any blob fails to download, the iterator will throw a BlobDownloadException.

Parameters:

blobs - The list of blob references to download

Returns:

A BlobDataIterator that provides InputStreams for each blob

Throws:

BlobDownloadException - if any blob download fails

MaxStorageException - if any blob does not exist or access is denied

ClientException - if there is a client-side error