apache_beam.io.azure package

Submodules

• apache_beam.io.azure.blobstoragefilesystem module
  • BlobStorageFileSystem
    • BlobStorageFileSystem.CHUNK_SIZE
    • BlobStorageFileSystem.AZURE_FILE_SYSTEM_PREFIX
    • BlobStorageFileSystem.scheme()
    • BlobStorageFileSystem.join()
    • BlobStorageFileSystem.split()
    • BlobStorageFileSystem.mkdirs()
    • BlobStorageFileSystem.has_dirs()
    • BlobStorageFileSystem.create()
    • BlobStorageFileSystem.open()
    • BlobStorageFileSystem.copy()
    • BlobStorageFileSystem.rename()
    • BlobStorageFileSystem.exists()
    • BlobStorageFileSystem.size()
    • BlobStorageFileSystem.last_updated()
    • BlobStorageFileSystem.checksum()
    • BlobStorageFileSystem.metadata()
    • BlobStorageFileSystem.delete()
    • BlobStorageFileSystem.report_lineage()
• apache_beam.io.azure.blobstorageio module
  • parse_azfs_path()
  • get_azfs_url()
  • Blob
  • BlobStorageIOError
  • BlobStorageError
  • BlobStorageIO
    • BlobStorageIO.open()
    • BlobStorageIO.copy()
    • BlobStorageIO.copy_tree()
    • BlobStorageIO.copy_paths()
    • BlobStorageIO.rename()
    • BlobStorageIO.rename_files()
    • BlobStorageIO.exists()
    • BlobStorageIO.size()
    • BlobStorageIO.last_updated()
    • BlobStorageIO.checksum()
    • BlobStorageIO.delete()
    • BlobStorageIO.delete_paths()
    • BlobStorageIO.delete_tree()
    • BlobStorageIO.delete_files()
    • BlobStorageIO.list_prefix()
    • BlobStorageIO.list_files()
  • BlobStorageDownloader
    • BlobStorageDownloader.size
    • BlobStorageDownloader.get_range()
  • BlobStorageUploader
    • BlobStorageUploader.put()
    • BlobStorageUploader.finish()