gravitino.filesystem.gvfs_storage_handler.ABSStorageHandler

class gravitino.filesystem.gvfs_storage_handler.ABSStorageHandler

Bases: StorageHandler

Azure Blob Storage Handler

__init__()

Methods

__init__()
actual_info_to_gvfs_info(entry, ...)	Convert a file info from an actual entry to a virtual entry.
actual_path_to_gvfs_path(actual_path, ...)	Convert the actual path to the gvfs path.
get_filesystem([actual_path])	Get the file system.
get_filesystem_with_expiration(credentials, ...)	Get the file system with expiration.
storage_type()	Get the storage type.
strip_storage_protocol(path)	Strip the storage protocol from the path.

actual_info_to_gvfs_info(entry: Dict, fileset_location: str, gvfs_path_prefix: str)

Convert a file info from an actual entry to a virtual entry. :param entry: A dict of the actual file info :param fileset_location: Storage location of the fileset :param gvfs_path_prefix: The prefix of the virtual path :return A dict of the virtual file info

actual_path_to_gvfs_path(actual_path: str, fileset_location: str, gvfs_path_prefix: str)

Convert the actual path to the gvfs path. :param actual_path: The actual path :param fileset_location: The fileset location :param gvfs_path_prefix: The gvfs path prefix :return: The gvfs path

get_filesystem(actual_path: str | None = None, **kwargs) → AbstractFileSystem

Get the file system. :return: The file system

get_filesystem_with_expiration(credentials: List[Credential], catalog_props: Dict[str, str], options: Dict[str, str], actual_path: str | None = None, **kwargs) → Tuple[int, AbstractFileSystem]

Get the file system with expiration. :return: The file system and the expiration time

storage_type()

Get the storage type. :return: The storage type

strip_storage_protocol(path: str)

Strip the storage protocol from the path. We need to remove the protocol and account from the path, for instance, the path can be converted from ‘abfss://container@account/path’ to ‘container/path’. :param path: The path :return: The stripped path