Index A | B | C | D | E | F | G | H | I | L | M | N | O | P | R | S | T | U | V | W A Actor add_report_entry() (rapidsmpf.statistics.Statistics method) 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) br (rapidsmpf.memory.memory_reservation.MemoryReservation attribute) Buffer BufferResource (class in rapidsmpf.memory.buffer_resource) Bytes (rapidsmpf.statistics.Formatter attribute) 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) copy() (rapidsmpf.statistics.Statistics method) 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) Default (rapidsmpf.statistics.Formatter attribute) deserialize() (rapidsmpf.config.Options static method) (rapidsmpf.statistics.Statistics static method) DEVICE (rapidsmpf.memory.buffer.MemoryType attribute) device_mr (rapidsmpf.memory.buffer_resource.BufferResource attribute) Duration (rapidsmpf.statistics.Formatter 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) Formatter (class in rapidsmpf.statistics) 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) H HitRate (rapidsmpf.statistics.Formatter attribute) 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_reserved() (rapidsmpf.memory.buffer_resource.BufferResource method) MemoryRecord (class in rapidsmpf.statistics) MemoryRecorder (class in rapidsmpf.statistics) MemoryReservation (class in rapidsmpf.memory.memory_reservation) MemoryThroughput (rapidsmpf.statistics.Formatter attribute) MemoryType (class in rapidsmpf.memory.buffer) merge() (rapidsmpf.statistics.Statistics static method) 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.ray 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.ray 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 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) reserve_or_fail() (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) (rapidsmpf.statistics.Statistics method) setup_ray_ucxx_cluster() (in module rapidsmpf.integrations.ray) setup_root() (rapidsmpf.integrations.ray.RapidsMPFActor method) setup_worker() (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_dict() (rapidsmpf.statistics.Statistics method) 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) unregister_python_spill_callback() (rapidsmpf.integrations.WorkerContext method) unspill_partitions() (in module rapidsmpf.integrations.cudf.partition) V verbosity_level (rapidsmpf.communicator.communicator.Logger attribute) W wait() (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)
