mars.services.storage.StorageAPI¶
- class mars.services.storage.StorageAPI(address: str, session_id: str)[source]¶
-
Methods
__init__(address, session_id)batch_delete(data_key[, error])Delete object.
batch_fetch(data_key[, level, band_name, …])Fetch object from remote worker or load object from disk.
batch_get(data_key[, conditions, error])Get object by data key.
batch_put(data_key, obj[, level])Put object into storage.
batch_unpin(data_key[, error])Unpin the data, allow storage to release the data.
create(session_id, address, **kwargs)Create storage API.
delete(data_key[, error])Delete object.
fetch(data_key[, level, band_name, …])Fetch object from remote worker or load object from disk.
get(data_key[, conditions, error])Get object by data key.
get_infos(data_key)Get data information items for specific data key
get_storage_level_info(level)Get storage level’s info.
list(level)List all stored data_keys in storage.
open_reader(data_key)Return a file-like object for reading.
open_writer(data_key, size, level)Return a file-like object for writing data.
put(data_key, obj[, level])Put object into storage.
unpin(data_key[, error])Unpin the data, allow storage to release the data.