pyarrow.fs.FSSpecHandler

class pyarrow.fs.FSSpecHandler(fs)[source]

Bases: pyarrow._fs.FileSystemHandler

Handler for fsspec-based Python filesystems.

https://filesystem-spec.readthedocs.io/en/latest/index.html

Parameters

fs (The FSSpec-compliant filesystem instance.) –

Examples

>>> PyFileSystem(FSSpecHandler(fsspec_fs))
__init__(fs)[source]

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__(fs)

Initialize self.

copy_file(self, src, dest)

Implement PyFileSystem.copy_file(…).

create_dir(self, path, recursive)

Implement PyFileSystem.create_dir(…).

delete_dir(self, path)

Implement PyFileSystem.delete_dir(…).

delete_dir_contents(self, path)

Implement PyFileSystem.delete_dir_contents(…).

delete_file(self, path)

Implement PyFileSystem.delete_file(…).

delete_root_dir_contents(self)

Implement PyFileSystem.delete_dir_contents(“/”, accept_root_dir=True).

get_file_info(self, paths)

Implement PyFileSystem.get_file_info(paths).

get_file_info_selector(self, selector)

Implement PyFileSystem.get_file_info(selector).

get_type_name(self)

Implement PyFileSystem.type_name.

move(self, src, dest)

Implement PyFileSystem.move(…).

normalize_path(self, path)

Implement PyFileSystem.normalize_path(…).

open_append_stream(self, path, metadata)

Implement PyFileSystem.open_append_stream(…).

open_input_file(self, path)

Implement PyFileSystem.open_input_file(…).

open_input_stream(self, path)

Implement PyFileSystem.open_input_stream(…).

open_output_stream(self, path, metadata)

Implement PyFileSystem.open_output_stream(…).

copy_file(self, src, dest)[source]

Implement PyFileSystem.copy_file(…).

Parameters
  • src (path of what should be copied.) –

  • dest (path of where it should be copied to.) –

create_dir(self, path, recursive)[source]

Implement PyFileSystem.create_dir(…).

Parameters
  • path (path of the directory.) –

  • recursive (if the parent directories should be created too.) –

delete_dir(self, path)[source]

Implement PyFileSystem.delete_dir(…).

Parameters

path (path of the directory.) –

delete_dir_contents(self, path)[source]

Implement PyFileSystem.delete_dir_contents(…).

Parameters

path (path of the directory.) –

delete_file(self, path)[source]

Implement PyFileSystem.delete_file(…).

Parameters

path (path of the file.) –

delete_root_dir_contents(self)[source]

Implement PyFileSystem.delete_dir_contents(“/”, accept_root_dir=True).

get_file_info(self, paths)[source]

Implement PyFileSystem.get_file_info(paths).

Parameters

paths (paths for which we want to retrieve the info.) –

get_file_info_selector(self, selector)[source]

Implement PyFileSystem.get_file_info(selector).

Parameters

selector (selector for which we want to retrieve the info.) –

get_type_name(self)[source]

Implement PyFileSystem.type_name.

move(self, src, dest)[source]

Implement PyFileSystem.move(…).

Parameters
  • src (path of what should be moved.) –

  • dest (path of where it should be moved to.) –

normalize_path(self, path)[source]

Implement PyFileSystem.normalize_path(…).

Parameters

path (path of what should be normalized.) –

open_append_stream(self, path, metadata)[source]

Implement PyFileSystem.open_append_stream(…).

Parameters
  • path (path of what should be opened.) –

  • metadata (mapping of string keys to string values.) – Some filesystems support storing metadata along the file (such as “Content-Type”).

open_input_file(self, path)[source]

Implement PyFileSystem.open_input_file(…).

Parameters

path (path of what should be opened.) –

open_input_stream(self, path)[source]

Implement PyFileSystem.open_input_stream(…).

Parameters

path (path of what should be opened.) –

open_output_stream(self, path, metadata)[source]

Implement PyFileSystem.open_output_stream(…).

Parameters
  • path (path of what should be opened.) –

  • metadata (mapping of string keys to string values.) – Some filesystems support storing metadata along the file (such as “Content-Type”).