mars.services.storage.StorageAPI

class mars.services.storage.StorageAPI(address: str, session_id: str, band_name: str)

__init__(address: str, session_id: str, band_name: str)

Methods

__init__(address, session_id, band_name)
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[, band_name])	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_info(level)	Get the customized storage backend info of requested storage backend.
get_storage_level_info(level)	Get storage level's info.
is_seekable([storage_level])	If storage backend is seekable.
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.