Index A | B | C | D | E | F | G | H | I | L | M | N | O | P | R | S | T | U | V | W A Actor add_stat() (rapidsmpf.statistics.Statistics method) ALL (rapidsmpf.memory.scoped_memory_record.AllocType attribute) AllGather AllocType (class in rapidsmpf.memory.scoped_memory_record) AvailableMemoryMap (class in rapidsmpf.memory.buffer_resource) B barrier() (in module rapidsmpf.communicator.ucxx) bootstrap_dask_cluster() (in module rapidsmpf.integrations.dask) br (rapidsmpf.memory.memory_reservation.MemoryReservation attribute) Buffer BufferResource (class in rapidsmpf.memory.buffer_resource) C Channel clear() (rapidsmpf.memory.memory_reservation.MemoryReservation method) (rapidsmpf.statistics.Statistics method) Collective Operation comm (rapidsmpf.integrations.ray.RapidsMPFActor property) (rapidsmpf.shuffler.Shuffler attribute) Communicator (class in rapidsmpf.communicator.communicator) COMMUNICATORS (in module rapidsmpf.communicator) Context CONTIGUOUS (rapidsmpf.shuffler.PartitionAssignment attribute) current() (rapidsmpf.memory.scoped_memory_record.ScopedMemoryRecord method) current_allocated (rapidsmpf.rmm_resource_adaptor.RmmResourceAdaptor attribute) D DEBUG (rapidsmpf.communicator.communicator.LOG_LEVEL attribute) debug() (rapidsmpf.communicator.communicator.Logger method) deserialize() (rapidsmpf.config.Options static method) DEVICE (rapidsmpf.memory.buffer.MemoryType attribute) device_mr (rapidsmpf.memory.buffer_resource.BufferResource attribute) E enabled (rapidsmpf.statistics.Statistics attribute) extract() (rapidsmpf.shuffler.Shuffler method) F FALLBACK (rapidsmpf.memory.scoped_memory_record.AllocType attribute) Fanout finished() (rapidsmpf.shuffler.Shuffler method) from_cudf_packed_columns() (rapidsmpf.memory.packed_data.PackedData class method) from_host_bytes() (rapidsmpf.memory.packed_data.PackedData class method) from_options() (rapidsmpf.memory.buffer_resource.AvailableMemoryMap class method) (rapidsmpf.memory.buffer_resource.BufferResource class method) (rapidsmpf.statistics.Statistics class method) G get() (rapidsmpf.config.Options method) get_environment_variables() (in module rapidsmpf.config) get_main_record() (rapidsmpf.rmm_resource_adaptor.RmmResourceAdaptor method) get_memory_records() (rapidsmpf.statistics.Statistics method) get_or_default() (rapidsmpf.config.Options method) get_root_ucxx_address() (in module rapidsmpf.communicator.ucxx) get_stat() (rapidsmpf.statistics.Statistics method) get_statistics() (rapidsmpf.integrations.WorkerContext method) get_str() (rapidsmpf.communicator.communicator.Communicator method) get_strings() (rapidsmpf.config.Options method) get_worker_context() (in module rapidsmpf.integrations.dask) (in module rapidsmpf.integrations.single) H HOST (rapidsmpf.memory.buffer.MemoryType attribute) I INFO (rapidsmpf.communicator.communicator.LOG_LEVEL attribute) info() (rapidsmpf.communicator.communicator.Logger method) insert_chunks() (rapidsmpf.shuffler.Shuffler method) insert_finished() (rapidsmpf.shuffler.Shuffler method) insert_if_absent() (rapidsmpf.config.Options method) is_initialized() (rapidsmpf.integrations.ray.RapidsMPFActor method) L LimitAvailableMemory (class in rapidsmpf.memory.buffer_resource) list_stat_names() (rapidsmpf.statistics.Statistics method) local_partitions() (rapidsmpf.shuffler.Shuffler method) LOG_LEVEL (class in rapidsmpf.communicator.communicator) Logger (class in rapidsmpf.communicator.communicator) logger (rapidsmpf.communicator.communicator.Communicator attribute) M mem_type (rapidsmpf.memory.memory_reservation.MemoryReservation attribute) memory_available() (rapidsmpf.memory.buffer_resource.BufferResource method) memory_profiling() (rapidsmpf.statistics.Statistics method) memory_profiling_enabled (rapidsmpf.statistics.Statistics attribute) memory_reserved() (rapidsmpf.memory.buffer_resource.BufferResource method) MemoryRecord (class in rapidsmpf.statistics) MemoryRecorder (class in rapidsmpf.statistics) MemoryReservation (class in rapidsmpf.memory.memory_reservation) MemoryType (class in rapidsmpf.memory.buffer) Message module rapidsmpf.communicator rapidsmpf.communicator.communicator rapidsmpf.communicator.mpi rapidsmpf.communicator.ucxx rapidsmpf.config rapidsmpf.integrations rapidsmpf.integrations.cudf rapidsmpf.integrations.cudf.partition rapidsmpf.integrations.dask rapidsmpf.integrations.ray rapidsmpf.integrations.single rapidsmpf.memory rapidsmpf.memory.buffer rapidsmpf.memory.buffer_resource rapidsmpf.memory.memory_reservation rapidsmpf.memory.packed_data rapidsmpf.memory.scoped_memory_record rapidsmpf.rmm_resource_adaptor rapidsmpf.shuffler rapidsmpf.statistics N Network new_communicator() (in module rapidsmpf.communicator.mpi) (in module rapidsmpf.communicator.ucxx) NONE (rapidsmpf.communicator.communicator.LOG_LEVEL attribute) nranks (rapidsmpf.communicator.communicator.Communicator attribute) nranks() (rapidsmpf.integrations.ray.RapidsMPFActor method) num_current_allocs() (rapidsmpf.memory.scoped_memory_record.ScopedMemoryRecord method) num_total_allocs() (rapidsmpf.memory.scoped_memory_record.ScopedMemoryRecord method) O opaque_memory_usage() (in module rapidsmpf.memory.memory_reservation) Optional (class in rapidsmpf.config) OptionalBytes (class in rapidsmpf.config) Options (class in rapidsmpf.config) P PackedData (class in rapidsmpf.memory.packed_data) Partition partition_and_pack() (in module rapidsmpf.integrations.cudf.partition) PartitionAssignment (class in rapidsmpf.shuffler) peak() (rapidsmpf.memory.scoped_memory_record.ScopedMemoryRecord method) periodic_spill_check_from_options() (in module rapidsmpf.memory.buffer_resource) PINNED_HOST (rapidsmpf.memory.buffer.MemoryType attribute) pinned_mr (rapidsmpf.memory.buffer_resource.BufferResource attribute) PRIMARY (rapidsmpf.memory.scoped_memory_record.AllocType attribute) PRINT (rapidsmpf.communicator.communicator.LOG_LEVEL attribute) print() (rapidsmpf.communicator.communicator.Logger method) progress_thread (rapidsmpf.communicator.communicator.Communicator attribute) ProgressThread R Rank rank (rapidsmpf.communicator.communicator.Communicator attribute) rank() (rapidsmpf.integrations.ray.RapidsMPFActor method) rapidsmpf.communicator module rapidsmpf.communicator.communicator module rapidsmpf.communicator.mpi module rapidsmpf.communicator.ucxx module rapidsmpf.config module rapidsmpf.integrations module rapidsmpf.integrations.cudf module rapidsmpf.integrations.cudf.partition module rapidsmpf.integrations.dask module rapidsmpf.integrations.ray module rapidsmpf.integrations.single module rapidsmpf.memory module rapidsmpf.memory.buffer module rapidsmpf.memory.buffer_resource module rapidsmpf.memory.memory_reservation module rapidsmpf.memory.packed_data module rapidsmpf.memory.scoped_memory_record module rapidsmpf.rmm_resource_adaptor module rapidsmpf.shuffler module rapidsmpf.statistics module rapidsmpf_shuffle_graph() (in module rapidsmpf.integrations.dask) (in module rapidsmpf.integrations.single) RapidsMPFActor (class in rapidsmpf.integrations.ray) record_allocation() (rapidsmpf.memory.scoped_memory_record.ScopedMemoryRecord method) record_deallocation() (rapidsmpf.memory.scoped_memory_record.ScopedMemoryRecord method) release() (rapidsmpf.memory.buffer_resource.BufferResource method) report() (rapidsmpf.statistics.Statistics method) reserve() (rapidsmpf.memory.buffer_resource.BufferResource method) reserve_device_memory_and_spill() (rapidsmpf.memory.buffer_resource.BufferResource method) RmmResourceAdaptor (class in rapidsmpf.rmm_resource_adaptor) ROUND_ROBIN (rapidsmpf.shuffler.PartitionAssignment attribute) S ScopedMemoryRecord (class in rapidsmpf.memory.scoped_memory_record) serialize() (rapidsmpf.config.Options method) setup_ray_ucxx_cluster() (in module rapidsmpf.integrations.ray) setup_root() (rapidsmpf.integrations.ray.RapidsMPFActor method) setup_worker() (in module rapidsmpf.integrations.single) (rapidsmpf.integrations.ray.RapidsMPFActor method) Shuffler (class in rapidsmpf.shuffler) shutdown() (rapidsmpf.shuffler.Shuffler method) size (rapidsmpf.memory.memory_reservation.MemoryReservation attribute) spill_partitions() (in module rapidsmpf.integrations.cudf.partition) SpillableMessages Spilling SpillManager split_and_pack() (in module rapidsmpf.integrations.cudf.partition) Statistics (class in rapidsmpf.statistics) statistics (rapidsmpf.integrations.ray.RapidsMPFActor property) (rapidsmpf.memory.buffer_resource.BufferResource attribute) stream_pool_from_options() (in module rapidsmpf.memory.buffer_resource) stream_pool_size() (rapidsmpf.memory.buffer_resource.BufferResource method) T to_host_bytes() (rapidsmpf.memory.packed_data.PackedData method) to_string() (rapidsmpf.integrations.ray.RapidsMPFActor method) total() (rapidsmpf.memory.scoped_memory_record.ScopedMemoryRecord method) TRACE (rapidsmpf.communicator.communicator.LOG_LEVEL attribute) trace() (rapidsmpf.communicator.communicator.Logger method) U unpack_and_concat() (in module rapidsmpf.integrations.cudf.partition) unspill_partitions() (in module rapidsmpf.integrations.cudf.partition) V verbosity_level (rapidsmpf.communicator.communicator.Logger attribute) W wait_any() (rapidsmpf.shuffler.Shuffler method) wait_on() (rapidsmpf.shuffler.Shuffler method) WARN (rapidsmpf.communicator.communicator.LOG_LEVEL attribute) warn() (rapidsmpf.communicator.communicator.Logger method) WorkerContext (class in rapidsmpf.integrations) write_json() (rapidsmpf.statistics.Statistics method) write_json_string() (rapidsmpf.statistics.Statistics method)
