com.aliyun.odps.storage.internal

Class BlobManagerImpl

java.lang.Object

com.aliyun.odps.storage.internal.BlobManagerImpl

All Implemented Interfaces:

BlobManager

public class BlobManagerImpl
extends Object
implements BlobManager

Constructor Summary

Constructors

Constructor and Description
BlobManagerImpl(StorageStub stub)

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.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlobManagerImpl

public BlobManagerImpl(StorageStub stub)

Method Detail

download

public InputStream download(Blob blobRef)

Description copied from interface: BlobManager

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.

Specified by:

download in interface BlobManager

Parameters:

blobRef - The blob reference to download

Returns:

An InputStream containing the blob data

batchDownload

public BlobDataIterator batchDownload(List<Blob> blobs)

Description copied from interface: BlobManager

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.

Specified by:

batchDownload in interface BlobManager

Parameters:

blobs - The list of blob references to download

Returns:

A BlobDataIterator that provides InputStreams for each blob