Index A | B | C | D | E | F | G | H | I | J | L | M | N | O | P | R | S | T | U | V | W | X A AlipanDownloader (class in streaming.base.storage) apply_default() (streaming.Stream method) apply_weights() (streaming.Stream class method) AzureDataLakeDownloader (class in streaming.base.storage) AzureDataLakeUploader (class in streaming.base.storage) AzureDownloader (class in streaming.base.storage) AzureUploader (class in streaming.base.storage) B buf (streaming.base.shared.SharedMemory property) bytes_to_int() (in module streaming.base.util) C cache_usage (streaming.StreamingDataset property) check_bucket_exists() (streaming.base.storage.AzureUploader method) (streaming.base.storage.GCSUploader method) (streaming.base.storage.OCIUploader method) (streaming.base.storage.S3Uploader method) check_container_exists() (streaming.base.storage.AzureDataLakeUploader method) check_dataset_exists() (streaming.base.storage.HFUploader method) clean_stale_shared_memory() (in module streaming.base.util) clean_up() (streaming.base.storage.AlipanDownloader method) (streaming.base.storage.AzureDataLakeDownloader method) (streaming.base.storage.AzureDownloader method) (streaming.base.storage.CloudDownloader method) (streaming.base.storage.DatabricksUnityCatalogDownloader method) (streaming.base.storage.DBFSDownloader method) (streaming.base.storage.GCSDownloader method) (streaming.base.storage.HFDownloader method) (streaming.base.storage.LocalDownloader method) (streaming.base.storage.OCIDownloader method) (streaming.base.storage.S3Downloader method) (streaming.base.storage.SFTPDownloader method) cleanup() (streaming.base.shared.SharedMemory method) clear_local() (streaming.base.storage.CloudUploader method) CloudDownloader (class in streaming.base.storage) CloudUploader (class in streaming.base.storage) compress() (in module streaming.base.compression) copy() (streaming.base.world.World method) CSVWriter (class in streaming) D DatabricksUnityCatalogDownloader (class in streaming.base.storage) DBFSDownloader (class in streaming.base.storage) decode_sample() (streaming.base.format.Reader method) decompress() (in module streaming.base.compression) detect() (streaming.base.world.World class method) detect_workers() (streaming.base.world.World method) direct_download() (streaming.base.storage.CloudDownloader class method) download() (streaming.base.storage.CloudDownloader method) E encode_joint_shard() (streaming.MDSWriter method) encode_sample() (streaming.JSONWriter method) (streaming.MDSWriter method) (streaming.XSVWriter method) encode_split_shard() (streaming.JSONWriter method) (streaming.XSVWriter method) evict() (streaming.base.format.Reader method) evict_coldest_shard() (streaming.StreamingDataset method) evict_shard() (streaming.StreamingDataset method) F FileInfo (class in streaming.base.format) fix_register() (streaming.base.shared.SharedMemory method) fix_unregister() (streaming.base.shared.SharedMemory method) flag (streaming.base.shared.SharedBarrier property) G GCSDownloader (class in streaming.base.storage) GCSUploader (class in streaming.base.storage) get() (streaming.base.shared.SharedScalar method) (streaming.base.storage.CloudDownloader class method) (streaming.base.storage.CloudUploader class method) get_compression_extension() (in module streaming.base.compression) get_compressions() (in module streaming.base.compression) get_config() (streaming.CSVWriter method) (streaming.JSONWriter method) (streaming.MDSWriter method) (streaming.TSVWriter method) (streaming.XSVWriter method) get_hash() (in module streaming.base.hashing) get_hashes() (in module streaming.base.hashing) get_import_exception_message() (in module streaming.base.util) get_index_basename() (in module streaming.base.format) get_index_size() (streaming.Stream method) get_item() (streaming.base.format.Reader method) (streaming.LocalDataset method) (streaming.multimodal.StreamingInsideWebVid method) (streaming.multimodal.StreamingOutsideDTWebVid method) (streaming.multimodal.StreamingOutsideGIWebVid method) (streaming.StreamingDataset method) (streaming.text.StreamingC4 method) (streaming.text.StreamingEnWiki method) (streaming.text.StreamingPile method) (streaming.vision.StreamingADE20K method) (streaming.vision.StreamingCOCO method) get_list_arg() (in module streaming.base.util) get_max_size() (streaming.base.format.Reader method) get_partitions() (in module streaming.base.partition) get_partitions_orig() (in module streaming.base.partition) get_partitions_relaxed() (in module streaming.base.partition) get_persistent_size() (streaming.base.format.Reader method) get_raw_size() (streaming.base.format.Reader method) get_sample_data() (streaming.base.format.Reader method) get_shards() (streaming.Stream method) get_shm_prefix() (in module streaming.base.shared) get_shuffle() (in module streaming.base.shuffle) get_shuffle_naive() (in module streaming.base.shuffle) get_shuffle_py1b() (in module streaming.base.shuffle) get_shuffle_py1br() (in module streaming.base.shuffle) get_shuffle_py1e() (in module streaming.base.shuffle) get_shuffle_py1s() (in module streaming.base.shuffle) get_shuffle_py2s() (in module streaming.base.shuffle) get_worker_info() (in module streaming.base.world) get_zip_size() (streaming.base.format.Reader method) H HFDownloader (class in streaming.base.storage) HFUploader (class in streaming.base.storage) I is_compression() (in module streaming.base.compression) is_hash() (in module streaming.base.hashing) J JSONWriter (class in streaming) L list_objects() (streaming.base.storage.CloudUploader method) (streaming.base.storage.GCSUploader method) (streaming.base.storage.LocalUploader method) (streaming.base.storage.OCIUploader method) (streaming.base.storage.S3Uploader method) load_state_dict() (streaming.StreamingDataLoader method) (streaming.StreamingDataset method) LocalDataset (class in streaming) LocalDownloader (class in streaming.base.storage) LocalUploader (class in streaming.base.storage) M MDSWriter (class in streaming) merge_index() (in module streaming.base.util) module streaming streaming.base.compression streaming.base.format streaming.base.hashing streaming.base.partition streaming.base.shared streaming.base.shuffle streaming.base.storage streaming.base.util streaming.base.world streaming.multimodal streaming.text streaming.vision N NDArray (in module streaming.base.partition) (in module streaming.base.shuffle) next_epoch (streaming.StreamingDataset property) num_enter (streaming.base.shared.SharedBarrier property) num_exit (streaming.base.shared.SharedBarrier property) number_abbrev_to_int() (in module streaming.base.util) numpy() (streaming.base.shared.SharedArray method) O OCIDownloader (class in streaming.base.storage) OCIUploader (class in streaming.base.storage) on_exception() (streaming.StreamingDataset method) P prepare_shard() (streaming.Stream method) (streaming.StreamingDataset method) R Reader (class in streaming.base.format) reader_from_json() (in module streaming.base.format) replicate() (streaming.base.world.World method) resample_streams() (streaming.StreamingDataset method) retry() (in module streaming.base.util) S S3Downloader (class in streaming.base.storage) S3Uploader (class in streaming.base.storage) set() (streaming.base.shared.SharedScalar method) set_up_local() (streaming.base.format.Reader method) (streaming.Stream method) SFTPDownloader (class in streaming.base.storage) SharedArray (class in streaming.base.shared) SharedBarrier (class in streaming.base.shared) SharedMemory (class in streaming.base.shared) SharedScalar (class in streaming.base.shared) size (streaming.base.format.Reader property) (streaming.LocalDataset property) (streaming.StreamingDataset property) state_dict() (streaming.StreamingDataLoader method) (streaming.StreamingDataset method) Stream (class in streaming) streaming module streaming.base.compression module streaming.base.format module streaming.base.hashing module streaming.base.partition module streaming.base.shared module streaming.base.shuffle module streaming.base.storage module streaming.base.util module streaming.base.world module streaming.multimodal module streaming.text module streaming.vision module StreamingADE20K (class in streaming.vision) StreamingC4 (class in streaming.text) StreamingCIFAR10 (class in streaming.vision) StreamingCOCO (class in streaming.vision) StreamingDataLoader (class in streaming) StreamingDataset (class in streaming) StreamingEnWiki (class in streaming.text) StreamingImageNet (class in streaming.vision) StreamingInsideWebVid (class in streaming.multimodal) StreamingOutsideDTWebVid (class in streaming.multimodal) StreamingOutsideGIWebVid (class in streaming.multimodal) StreamingPile (class in streaming.text) T to_json() (streaming.base.world.World method) TSVWriter (class in streaming) U upload_file() (streaming.base.storage.AzureDataLakeUploader method) (streaming.base.storage.AzureUploader method) (streaming.base.storage.CloudUploader method) (streaming.base.storage.GCSUploader method) (streaming.base.storage.HFUploader method) (streaming.base.storage.LocalUploader method) (streaming.base.storage.OCIUploader method) (streaming.base.storage.S3Uploader method) V validate() (streaming.base.format.Reader method) validate_weights() (streaming.Stream class method) W wait_for_file_to_exist() (in module streaming.base.util) World (class in streaming.base.world) X XSVWriter (class in streaming)