Index

A

Actor add_report_entry() (rapidsmpf.statistics.Statistics method)

add_stat() (rapidsmpf.statistics.Statistics method) AllGather allocate() (rapidsmpf.memory.pinned_memory_resource.PinnedMemoryResource method)

B

barrier() (in module rapidsmpf.communicator.ucxx) br (rapidsmpf.memory.memory_reservation.MemoryReservation attribute) Buffer (class in rapidsmpf.memory.buffer)

BufferHostView (class in rapidsmpf.memory.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

deallocate() (rapidsmpf.memory.pinned_memory_resource.PinnedMemoryResource method) 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_limit_from_options() (in module rapidsmpf.memory.buffer_resource) device_mr (rapidsmpf.memory.buffer_resource.BufferResource attribute) device_mr_adaptor() (rapidsmpf.memory.buffer_resource.BufferResource method) disable() (rapidsmpf.statistics.Statistics method) disabled() (rapidsmpf.statistics.Statistics class method) Duration (rapidsmpf.statistics.Formatter attribute)

E

enable() (rapidsmpf.statistics.Statistics method) enabled (rapidsmpf.memory.pinned_memory_resource.PinnedMemoryResource attribute) (rapidsmpf.statistics.Statistics attribute)

extract() (rapidsmpf.shuffler.Shuffler method)

F

Fanout finished() (rapidsmpf.shuffler.Shuffler method) Formatter (class in rapidsmpf.statistics)

from_device_buffer() (rapidsmpf.memory.packed_data.PackedData class method) from_host_bytes() (rapidsmpf.memory.packed_data.PackedData class method) from_options() (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_str() (rapidsmpf.communicator.communicator.Communicator method) get_strings() (rapidsmpf.config.Options method)

H

HitRate (rapidsmpf.statistics.Formatter attribute)

HOST (rapidsmpf.memory.buffer.MemoryType attribute) host_view() (rapidsmpf.memory.buffer.Buffer method)

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) is_pinned_memory_resources_supported() (in module rapidsmpf.memory.pinned_memory_resource)

L

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

make_buffer() (rapidsmpf.memory.buffer_resource.BufferResource method) mem_type (rapidsmpf.memory.buffer.Buffer attribute) (rapidsmpf.memory.memory_reservation.MemoryReservation attribute) memory_available() (rapidsmpf.memory.buffer_resource.BufferResource method) memory_available_for_reservation() (rapidsmpf.memory.buffer_resource.BufferResource method) memory_profiling() (rapidsmpf.statistics.Statistics 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.ray rapidsmpf.memory rapidsmpf.memory.buffer rapidsmpf.memory.buffer_resource rapidsmpf.memory.memory_reservation rapidsmpf.memory.packed_data rapidsmpf.memory.pinned_memory_resource 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) OwningDeviceMemoryResource (class in rapidsmpf.memory.buffer_resource)

P

PackedData (class in rapidsmpf.memory.packed_data) 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) PinnedMemoryResource (class in rapidsmpf.memory.pinned_memory_resource) PinnedPoolProperties (class in rapidsmpf.memory.pinned_memory_resource) 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.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.pinned_memory_resource module rapidsmpf.memory.scoped_memory_record module rapidsmpf.rmm_resource_adaptor module rapidsmpf.shuffler module rapidsmpf.statistics module rapidsmpf::AllowOverbooking (C++ enum) rapidsmpf::AllowOverbooking::NO (C++ enumerator) rapidsmpf::AllowOverbooking::YES (C++ enumerator) rapidsmpf::any_device_resource (C++ type) rapidsmpf::any_host_device_resource (C++ type) rapidsmpf::any_host_resource (C++ type) rapidsmpf::bootstrap::BackendType (C++ enum) rapidsmpf::bootstrap::BackendType::AUTO (C++ enumerator) rapidsmpf::bootstrap::BackendType::FILE (C++ enumerator) rapidsmpf::bootstrap::BackendType::SLURM (C++ enumerator) rapidsmpf::bootstrap::BackendType::SOCKET (C++ enumerator) rapidsmpf::bootstrap::barrier (C++ function) rapidsmpf::bootstrap::compare_cpu_affinity (C++ function) rapidsmpf::bootstrap::compare_device_lists (C++ function) rapidsmpf::bootstrap::Duration (C++ type) rapidsmpf::bootstrap::get (C++ function) rapidsmpf::bootstrap::get_current_cpu_affinity (C++ function) rapidsmpf::bootstrap::get_gpu_id (C++ function) rapidsmpf::bootstrap::get_nranks (C++ function) rapidsmpf::bootstrap::get_rank (C++ function) rapidsmpf::bootstrap::get_ucx_net_devices (C++ function) rapidsmpf::bootstrap::getenv_int (C++ function) rapidsmpf::bootstrap::getenv_optional (C++ function) rapidsmpf::bootstrap::init (C++ function) rapidsmpf::bootstrap::is_running_with_rrun (C++ function) rapidsmpf::bootstrap::is_running_with_slurm (C++ function) rapidsmpf::bootstrap::max_key_size (C++ member) rapidsmpf::bootstrap::parse_cpu_list (C++ function) rapidsmpf::bootstrap::put (C++ function) rapidsmpf::bootstrap::Rank (C++ type) rapidsmpf::bootstrap::rapidsmpf::bootstrap::Context (C++ struct) rapidsmpf::bootstrap::rapidsmpf::bootstrap::Context::backend (C++ member) rapidsmpf::bootstrap::rapidsmpf::bootstrap::Context::coord_dir (C++ member) rapidsmpf::bootstrap::rapidsmpf::bootstrap::Context::nranks (C++ member) rapidsmpf::bootstrap::rapidsmpf::bootstrap::Context::rank (C++ member) rapidsmpf::bootstrap::rapidsmpf::bootstrap::Context::type (C++ member) rapidsmpf::bootstrap::sync (C++ function) rapidsmpf::bootstrap::validate_key (C++ function) rapidsmpf::buffer_copy (C++ function) rapidsmpf::ceil_div (C++ function) rapidsmpf::chunk_indices (C++ function) rapidsmpf::Clock (C++ type) rapidsmpf::coll::rapidsmpf::coll::AllGather (C++ class) rapidsmpf::coll::rapidsmpf::coll::AllGather::AllGather (C++ function), [1], [2] rapidsmpf::coll::rapidsmpf::coll::AllGather::comm (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllGather::event_loop (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllGather::insert (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllGather::insert_finished (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllGather::operator= (C++ function), [1] rapidsmpf::coll::rapidsmpf::coll::AllGather::Ordered (C++ enum) rapidsmpf::coll::rapidsmpf::coll::AllGather::Ordered::NO (C++ enumerator) rapidsmpf::coll::rapidsmpf::coll::AllGather::Ordered::YES (C++ enumerator) rapidsmpf::coll::rapidsmpf::coll::AllGather::wait_and_extract (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllGather::~AllGather (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllReduce (C++ class) rapidsmpf::coll::rapidsmpf::coll::AllReduce::AllReduce (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllReduce::comm (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllReduce::finished (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllReduce::is_ready (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllReduce::wait_and_extract (C++ function) rapidsmpf::coll::rapidsmpf::coll::AllReduce::~AllReduce (C++ function) rapidsmpf::coll::rapidsmpf::coll::SparseAlltoall (C++ class) rapidsmpf::coll::rapidsmpf::coll::SparseAlltoall::comm (C++ function) rapidsmpf::coll::rapidsmpf::coll::SparseAlltoall::extract (C++ function) rapidsmpf::coll::rapidsmpf::coll::SparseAlltoall::insert (C++ function) rapidsmpf::coll::rapidsmpf::coll::SparseAlltoall::insert_finished (C++ function) rapidsmpf::coll::rapidsmpf::coll::SparseAlltoall::SparseAlltoall (C++ function) rapidsmpf::coll::rapidsmpf::coll::SparseAlltoall::wait (C++ function) rapidsmpf::coll::ReduceOperator (C++ type) rapidsmpf::COMM_HAVE_MPI (C++ member) rapidsmpf::COMM_HAVE_UCXX (C++ member) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange (C++ class) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::finish (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::is_idle (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message (C++ class) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message::data (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message::Message (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message::metadata (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message::peer_rank (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message::release_data (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message::release_metadata (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::Message::set_data (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::progress (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::recv (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::MetadataPayloadExchange::send (C++ function), [1] rapidsmpf::communicator::rapidsmpf::communicator::TagMetadataPayloadExchange (C++ class) rapidsmpf::communicator::rapidsmpf::communicator::TagMetadataPayloadExchange::finish (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::TagMetadataPayloadExchange::is_idle (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::TagMetadataPayloadExchange::progress (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::TagMetadataPayloadExchange::recv (C++ function) rapidsmpf::communicator::rapidsmpf::communicator::TagMetadataPayloadExchange::send (C++ function), [1] rapidsmpf::communicator::rapidsmpf::communicator::TagMetadataPayloadExchange::TagMetadataPayloadExchange (C++ function) rapidsmpf::config::DEFAULTS (C++ member) rapidsmpf::config::get_environment_variables (C++ function), [1] rapidsmpf::config::OptionFactory (C++ type) rapidsmpf::config::rapidsmpf::config::Options (C++ class) rapidsmpf::config::rapidsmpf::config::Options::deserialize (C++ function) rapidsmpf::config::rapidsmpf::config::Options::get (C++ function) rapidsmpf::config::rapidsmpf::config::Options::get_strings (C++ function) rapidsmpf::config::rapidsmpf::config::Options::insert_if_absent (C++ function), [1], [2] rapidsmpf::config::rapidsmpf::config::Options::Options (C++ function), [1] rapidsmpf::config::rapidsmpf::config::Options::serialize (C++ function) rapidsmpf::config::rapidsmpf::config::OptionValue (C++ class) rapidsmpf::config::rapidsmpf::config::OptionValue::get_value (C++ function) rapidsmpf::config::rapidsmpf::config::OptionValue::get_value_as_string (C++ function) rapidsmpf::config::rapidsmpf::config::OptionValue::OptionValue (C++ function), [1], [2] rapidsmpf::config::rapidsmpf::config::OptionValue::set_value (C++ function) rapidsmpf::contains (C++ function) rapidsmpf::cuda_memcpy_async (C++ function) rapidsmpf::cuda_memcpy_batch_async (C++ function) rapidsmpf::cuda_stream_join (C++ function), [1] rapidsmpf::device_limit_from_options (C++ function) rapidsmpf::Duration (C++ type) rapidsmpf::extract_item (C++ function), [1] rapidsmpf::extract_key (C++ function), [1] rapidsmpf::extract_value (C++ function), [1] rapidsmpf::format_duration (C++ function) rapidsmpf::format_nbytes (C++ function) rapidsmpf::get_current_numa_node (C++ function) rapidsmpf::get_current_numa_nodes (C++ function) rapidsmpf::get_host_memory_per_gpu (C++ function) rapidsmpf::get_numa_node_host_memory (C++ function) rapidsmpf::get_total_host_memory (C++ function) rapidsmpf::is_device_accessible (C++ function) rapidsmpf::is_host_accessible (C++ function) rapidsmpf::is_pinned_memory_resources_supported (C++ function) rapidsmpf::is_running_under_valgrind (C++ function) rapidsmpf::leq_memory_types (C++ function) rapidsmpf::MEMORY_TYPE_NAMES (C++ member) rapidsmpf::MEMORY_TYPES (C++ member) rapidsmpf::MemoryType (C++ enum) rapidsmpf::MemoryType::DEVICE (C++ enumerator) rapidsmpf::MemoryType::HOST (C++ enumerator) rapidsmpf::MemoryType::PINNED_HOST (C++ enumerator) rapidsmpf::mpi::init (C++ function) rapidsmpf::mpi::is_initialized (C++ function) rapidsmpf::operator<< (C++ function), [1] rapidsmpf::operator>> (C++ function) rapidsmpf::OpID (C++ type) rapidsmpf::owner_equal (C++ function) rapidsmpf::parse_duration (C++ function) rapidsmpf::parse_nbytes (C++ function) rapidsmpf::parse_nbytes_or_percent (C++ function) rapidsmpf::parse_nbytes_unsigned (C++ function) rapidsmpf::parse_optional (C++ function) rapidsmpf::parse_string (C++ function), [1] rapidsmpf::parse_string_list (C++ function) rapidsmpf::periodic_spill_check_from_options (C++ function) rapidsmpf::pinned_pool_properties_from_options (C++ function) rapidsmpf::PinnedMemoryDisabled (C++ member) rapidsmpf::Rank (C++ type) rapidsmpf::rapidsmpf::BackRefMixin (C++ class) rapidsmpf::rapidsmpf::BackRefMixin::BackRefMixin (C++ function), [1], [2] rapidsmpf::rapidsmpf::BackRefMixin::operator= (C++ function), [1] rapidsmpf::rapidsmpf::BackRefMixin::operator== (C++ function) rapidsmpf::rapidsmpf::BackRefMixin::set_backref (C++ function) rapidsmpf::rapidsmpf::bad_alloc (C++ class) rapidsmpf::rapidsmpf::bad_alloc::bad_alloc (C++ function), [1] rapidsmpf::rapidsmpf::bad_alloc::what (C++ function) rapidsmpf::rapidsmpf::Buffer (C++ class) rapidsmpf::rapidsmpf::Buffer::Buffer (C++ function) rapidsmpf::rapidsmpf::Buffer::data (C++ function) rapidsmpf::rapidsmpf::Buffer::device_buffer_types (C++ member) rapidsmpf::rapidsmpf::Buffer::DeviceBufferT (C++ type) rapidsmpf::rapidsmpf::Buffer::exclusive_data_access (C++ function) rapidsmpf::rapidsmpf::Buffer::host_buffer_types (C++ member) rapidsmpf::rapidsmpf::Buffer::HostBufferT (C++ type) rapidsmpf::rapidsmpf::Buffer::is_latest_write_done (C++ function) rapidsmpf::rapidsmpf::Buffer::latest_write_event (C++ function) rapidsmpf::rapidsmpf::Buffer::mem_type (C++ function) rapidsmpf::rapidsmpf::Buffer::rebind_stream (C++ function) rapidsmpf::rapidsmpf::Buffer::size (C++ member) rapidsmpf::rapidsmpf::Buffer::stream (C++ function) rapidsmpf::rapidsmpf::Buffer::unlock (C++ function) rapidsmpf::rapidsmpf::Buffer::write_access (C++ function) rapidsmpf::rapidsmpf::BufferResource (C++ class) rapidsmpf::rapidsmpf::BufferResource::BufferResource (C++ function), [1] rapidsmpf::rapidsmpf::BufferResource::create (C++ function) rapidsmpf::rapidsmpf::BufferResource::device_mr (C++ function) rapidsmpf::rapidsmpf::BufferResource::device_mr_adaptor (C++ function) rapidsmpf::rapidsmpf::BufferResource::from_options (C++ function) rapidsmpf::rapidsmpf::BufferResource::host_mr (C++ function) rapidsmpf::rapidsmpf::BufferResource::make_buffer (C++ function), [1] rapidsmpf::rapidsmpf::BufferResource::memory_available (C++ function) rapidsmpf::rapidsmpf::BufferResource::memory_available_for_reservation (C++ function) rapidsmpf::rapidsmpf::BufferResource::move (C++ function), [1] rapidsmpf::rapidsmpf::BufferResource::move_to_device_buffer (C++ function) rapidsmpf::rapidsmpf::BufferResource::move_to_host_buffer (C++ function) rapidsmpf::rapidsmpf::BufferResource::operator= (C++ function), [1] rapidsmpf::rapidsmpf::BufferResource::pinned_mr (C++ function) rapidsmpf::rapidsmpf::BufferResource::release (C++ function) rapidsmpf::rapidsmpf::BufferResource::reserve (C++ function) rapidsmpf::rapidsmpf::BufferResource::reserve_device_memory_and_spill (C++ function) rapidsmpf::rapidsmpf::BufferResource::reserve_or_fail (C++ function), [1] rapidsmpf::rapidsmpf::BufferResource::set_memory_limit (C++ function) rapidsmpf::rapidsmpf::BufferResource::spill_manager (C++ function) rapidsmpf::rapidsmpf::BufferResource::statistics (C++ function) rapidsmpf::rapidsmpf::BufferResource::stream_pool (C++ function) rapidsmpf::rapidsmpf::BufferResource::try_pinned_mr (C++ function) rapidsmpf::rapidsmpf::Communicator (C++ class) rapidsmpf::rapidsmpf::Communicator::Future (C++ class) rapidsmpf::rapidsmpf::Communicator::Future::Future (C++ function), [1] rapidsmpf::rapidsmpf::Communicator::Future::operator= (C++ function), [1] rapidsmpf::rapidsmpf::Communicator::logger (C++ function) rapidsmpf::rapidsmpf::Communicator::nranks (C++ function) rapidsmpf::rapidsmpf::Communicator::progress_thread (C++ function) rapidsmpf::rapidsmpf::Communicator::rank (C++ function) rapidsmpf::rapidsmpf::Communicator::recv (C++ function) rapidsmpf::rapidsmpf::Communicator::recv_any (C++ function) rapidsmpf::rapidsmpf::Communicator::recv_from (C++ function) rapidsmpf::rapidsmpf::Communicator::recv_sync_host_data (C++ function) rapidsmpf::rapidsmpf::Communicator::release_data (C++ function) rapidsmpf::rapidsmpf::Communicator::release_sync_host_data (C++ function) rapidsmpf::rapidsmpf::Communicator::send (C++ function), [1] rapidsmpf::rapidsmpf::Communicator::str (C++ function) rapidsmpf::rapidsmpf::Communicator::test (C++ function) rapidsmpf::rapidsmpf::Communicator::test_some (C++ function), [1] rapidsmpf::rapidsmpf::Communicator::wait (C++ function) rapidsmpf::rapidsmpf::Communicator::wait_all (C++ function) rapidsmpf::rapidsmpf::ContentDescription (C++ class) rapidsmpf::rapidsmpf::ContentDescription::content_size (C++ function), [1], [2] rapidsmpf::rapidsmpf::ContentDescription::ContentDescription (C++ function), [1] rapidsmpf::rapidsmpf::ContentDescription::operator== (C++ function) rapidsmpf::rapidsmpf::ContentDescription::principal_memory_type (C++ function) rapidsmpf::rapidsmpf::ContentDescription::Spillable (C++ enum) rapidsmpf::rapidsmpf::ContentDescription::spillable (C++ function) rapidsmpf::rapidsmpf::ContentDescription::Spillable::NO (C++ enumerator) rapidsmpf::rapidsmpf::ContentDescription::Spillable::YES (C++ enumerator) rapidsmpf::rapidsmpf::cuda_error (C++ struct) rapidsmpf::rapidsmpf::CudaEvent (C++ class) rapidsmpf::rapidsmpf::CudaEvent::CudaEvent (C++ function), [1], [2] rapidsmpf::rapidsmpf::CudaEvent::host_wait (C++ function) rapidsmpf::rapidsmpf::CudaEvent::is_ready (C++ function) rapidsmpf::rapidsmpf::CudaEvent::make_shared_record (C++ function) rapidsmpf::rapidsmpf::CudaEvent::operator cudaEvent_t const& (C++ function) rapidsmpf::rapidsmpf::CudaEvent::operator= (C++ function), [1] rapidsmpf::rapidsmpf::CudaEvent::record (C++ function) rapidsmpf::rapidsmpf::CudaEvent::stream_wait (C++ function) rapidsmpf::rapidsmpf::CudaEvent::value (C++ function) rapidsmpf::rapidsmpf::CudaEvent::~CudaEvent (C++ function) rapidsmpf::rapidsmpf::HostBuffer (C++ class) rapidsmpf::rapidsmpf::HostBuffer::copy_to_uint8_vector (C++ function) rapidsmpf::rapidsmpf::HostBuffer::data (C++ function), [1] rapidsmpf::rapidsmpf::HostBuffer::deallocate_async (C++ function) rapidsmpf::rapidsmpf::HostBuffer::empty (C++ function) rapidsmpf::rapidsmpf::HostBuffer::from_owned_vector (C++ function) rapidsmpf::rapidsmpf::HostBuffer::from_rmm_device_buffer (C++ function) rapidsmpf::rapidsmpf::HostBuffer::from_uint8_vector (C++ function) rapidsmpf::rapidsmpf::HostBuffer::HostBuffer (C++ function), [1] rapidsmpf::rapidsmpf::HostBuffer::operator= (C++ function) rapidsmpf::rapidsmpf::HostBuffer::set_stream (C++ function) rapidsmpf::rapidsmpf::HostBuffer::size (C++ function) rapidsmpf::rapidsmpf::HostBuffer::stream (C++ function) rapidsmpf::rapidsmpf::HostMemoryResource (C++ class) rapidsmpf::rapidsmpf::HostMemoryResource::allocate (C++ function) rapidsmpf::rapidsmpf::HostMemoryResource::allocate_sync (C++ function) rapidsmpf::rapidsmpf::HostMemoryResource::deallocate (C++ function) rapidsmpf::rapidsmpf::HostMemoryResource::deallocate_sync (C++ function) rapidsmpf::rapidsmpf::HostMemoryResource::get_property (C++ function) rapidsmpf::rapidsmpf::HostMemoryResource::HostMemoryResource (C++ function), [1] rapidsmpf::rapidsmpf::HostMemoryResource::operator!= (C++ function) rapidsmpf::rapidsmpf::HostMemoryResource::operator= (C++ function), [1] rapidsmpf::rapidsmpf::HostMemoryResource::operator== (C++ function) rapidsmpf::rapidsmpf::Logger (C++ class) rapidsmpf::rapidsmpf::Logger::create (C++ function) rapidsmpf::rapidsmpf::Logger::debug (C++ function) rapidsmpf::rapidsmpf::Logger::from_options (C++ function) rapidsmpf::rapidsmpf::Logger::info (C++ function) rapidsmpf::rapidsmpf::Logger::level_name (C++ function) rapidsmpf::rapidsmpf::Logger::log (C++ function) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL (C++ enum) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL::DEBUG (C++ enumerator) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL::INFO (C++ enumerator) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL::NONE (C++ enumerator) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL::PRINT (C++ enumerator) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL::TRACE (C++ enumerator) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL::WARN (C++ enumerator) rapidsmpf::rapidsmpf::Logger::LOG_LEVEL_NAMES (C++ member) rapidsmpf::rapidsmpf::Logger::print (C++ function) rapidsmpf::rapidsmpf::Logger::set_name (C++ function) rapidsmpf::rapidsmpf::Logger::trace (C++ function) rapidsmpf::rapidsmpf::Logger::verbosity_level (C++ function) rapidsmpf::rapidsmpf::Logger::warn (C++ function) rapidsmpf::rapidsmpf::MemoryReservation (C++ class) rapidsmpf::rapidsmpf::MemoryReservation::br (C++ function) rapidsmpf::rapidsmpf::MemoryReservation::clear (C++ function) rapidsmpf::rapidsmpf::MemoryReservation::mem_type (C++ function) rapidsmpf::rapidsmpf::MemoryReservation::MemoryReservation (C++ function), [1] rapidsmpf::rapidsmpf::MemoryReservation::operator= (C++ function) rapidsmpf::rapidsmpf::MemoryReservation::size (C++ function) rapidsmpf::rapidsmpf::MemoryReservation::split (C++ function) rapidsmpf::rapidsmpf::MemoryReservation::~MemoryReservation (C++ function) rapidsmpf::rapidsmpf::MPI (C++ class) rapidsmpf::rapidsmpf::MPI::Future (C++ class) rapidsmpf::rapidsmpf::MPI::Future::Future (C++ function), [1] rapidsmpf::rapidsmpf::MPI::logger (C++ function) rapidsmpf::rapidsmpf::MPI::MPI (C++ function) rapidsmpf::rapidsmpf::MPI::nranks (C++ function) rapidsmpf::rapidsmpf::MPI::progress_thread (C++ function) rapidsmpf::rapidsmpf::MPI::rank (C++ function) rapidsmpf::rapidsmpf::MPI::recv (C++ function) rapidsmpf::rapidsmpf::MPI::recv_any (C++ function) rapidsmpf::rapidsmpf::MPI::recv_from (C++ function) rapidsmpf::rapidsmpf::MPI::recv_sync_host_data (C++ function) rapidsmpf::rapidsmpf::MPI::release_data (C++ function) rapidsmpf::rapidsmpf::MPI::release_sync_host_data (C++ function) rapidsmpf::rapidsmpf::MPI::send (C++ function), [1] rapidsmpf::rapidsmpf::MPI::str (C++ function) rapidsmpf::rapidsmpf::MPI::test (C++ function) rapidsmpf::rapidsmpf::MPI::test_some (C++ function), [1] rapidsmpf::rapidsmpf::MPI::wait (C++ function) rapidsmpf::rapidsmpf::MPI::wait_all (C++ function) rapidsmpf::rapidsmpf::out_of_memory (C++ class) rapidsmpf::rapidsmpf::out_of_memory::out_of_memory (C++ function), [1] rapidsmpf::rapidsmpf::overloaded (C++ struct) rapidsmpf::rapidsmpf::OwningWrapper (C++ class) rapidsmpf::rapidsmpf::OwningWrapper::deleter_type (C++ type) rapidsmpf::rapidsmpf::OwningWrapper::get (C++ function) rapidsmpf::rapidsmpf::OwningWrapper::OwningWrapper (C++ function) rapidsmpf::rapidsmpf::OwningWrapper::release (C++ function) rapidsmpf::rapidsmpf::PackedData (C++ struct) rapidsmpf::rapidsmpf::PackedData::copy (C++ function) rapidsmpf::rapidsmpf::PackedData::data (C++ member) rapidsmpf::rapidsmpf::PackedData::empty (C++ function) rapidsmpf::rapidsmpf::PackedData::metadata (C++ member) rapidsmpf::rapidsmpf::PackedData::operator= (C++ function) rapidsmpf::rapidsmpf::PackedData::PackedData (C++ function), [1] rapidsmpf::rapidsmpf::PackedData::stream (C++ function) rapidsmpf::rapidsmpf::PinnedMemoryResource (C++ class) rapidsmpf::rapidsmpf::PinnedMemoryResource::allocate (C++ function) rapidsmpf::rapidsmpf::PinnedMemoryResource::current_allocated (C++ function) rapidsmpf::rapidsmpf::PinnedMemoryResource::deallocate (C++ function)

rapidsmpf::rapidsmpf::PinnedMemoryResource::get_main_memory_record (C++ function) rapidsmpf::rapidsmpf::PinnedMemoryResource::get_property (C++ function) rapidsmpf::rapidsmpf::PinnedMemoryResource::operator== (C++ function) rapidsmpf::rapidsmpf::PinnedMemoryResource::properties (C++ function) rapidsmpf::rapidsmpf::PinnedPoolProperties (C++ struct) rapidsmpf::rapidsmpf::PinnedPoolProperties::initial_pool_size (C++ member) rapidsmpf::rapidsmpf::PinnedPoolProperties::max_pool_size (C++ member) rapidsmpf::rapidsmpf::PinnedPoolProperties::numa_id (C++ member) rapidsmpf::rapidsmpf::ProgressThread (C++ class) rapidsmpf::rapidsmpf::ProgressThread::add_function (C++ function) rapidsmpf::rapidsmpf::ProgressThread::Function (C++ type) rapidsmpf::rapidsmpf::ProgressThread::FunctionID (C++ struct) rapidsmpf::rapidsmpf::ProgressThread::FunctionID::function_index (C++ member) rapidsmpf::rapidsmpf::ProgressThread::FunctionID::FunctionID (C++ function), [1] rapidsmpf::rapidsmpf::ProgressThread::FunctionID::is_valid (C++ function) rapidsmpf::rapidsmpf::ProgressThread::FunctionID::thread_address (C++ member) rapidsmpf::rapidsmpf::ProgressThread::FunctionIndex (C++ type) rapidsmpf::rapidsmpf::ProgressThread::FunctionState (C++ class) rapidsmpf::rapidsmpf::ProgressThread::FunctionState::function (C++ member) rapidsmpf::rapidsmpf::ProgressThread::FunctionState::FunctionState (C++ function) rapidsmpf::rapidsmpf::ProgressThread::FunctionState::is_done (C++ member) rapidsmpf::rapidsmpf::ProgressThread::FunctionState::operator() (C++ function) rapidsmpf::rapidsmpf::ProgressThread::is_running (C++ function) rapidsmpf::rapidsmpf::ProgressThread::pause (C++ function) rapidsmpf::rapidsmpf::ProgressThread::ProgressState (C++ enum) rapidsmpf::rapidsmpf::ProgressThread::ProgressState::Done (C++ enumerator) rapidsmpf::rapidsmpf::ProgressThread::ProgressState::InProgress (C++ enumerator) rapidsmpf::rapidsmpf::ProgressThread::ProgressThread (C++ function) rapidsmpf::rapidsmpf::ProgressThread::ProgressThreadAddress (C++ type) rapidsmpf::rapidsmpf::ProgressThread::remove_function (C++ function) rapidsmpf::rapidsmpf::ProgressThread::resume (C++ function) rapidsmpf::rapidsmpf::ProgressThread::statistics (C++ function) rapidsmpf::rapidsmpf::ProgressThread::stop (C++ function) rapidsmpf::rapidsmpf::reservation_error (C++ class) rapidsmpf::rapidsmpf::reservation_error::reservation_error (C++ function), [1] rapidsmpf::rapidsmpf::RmmResourceAdaptor (C++ class) rapidsmpf::rapidsmpf::RmmResourceAdaptor::begin_scoped_memory_record (C++ function) rapidsmpf::rapidsmpf::RmmResourceAdaptor::current_allocated (C++ function) rapidsmpf::rapidsmpf::RmmResourceAdaptor::end_scoped_memory_record (C++ function) rapidsmpf::rapidsmpf::RmmResourceAdaptor::get_main_record (C++ function) rapidsmpf::rapidsmpf::RmmResourceAdaptor::get_property (C++ function) rapidsmpf::rapidsmpf::RmmResourceAdaptor::get_upstream_resource (C++ function) rapidsmpf::rapidsmpf::RmmResourceAdaptor::operator== (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord (C++ struct) rapidsmpf::rapidsmpf::ScopedMemoryRecord::add_scope (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::add_subscope (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::current (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::max (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::num_current_allocs (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::num_total_allocs (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::peak (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::record_allocation (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::record_deallocation (C++ function) rapidsmpf::rapidsmpf::ScopedMemoryRecord::total (C++ function) rapidsmpf::rapidsmpf::Single (C++ class) rapidsmpf::rapidsmpf::Single::Future (C++ class) rapidsmpf::rapidsmpf::Single::logger (C++ function) rapidsmpf::rapidsmpf::Single::nranks (C++ function) rapidsmpf::rapidsmpf::Single::progress_thread (C++ function) rapidsmpf::rapidsmpf::Single::rank (C++ function) rapidsmpf::rapidsmpf::Single::recv (C++ function) rapidsmpf::rapidsmpf::Single::recv_any (C++ function) rapidsmpf::rapidsmpf::Single::recv_from (C++ function) rapidsmpf::rapidsmpf::Single::recv_sync_host_data (C++ function) rapidsmpf::rapidsmpf::Single::release_data (C++ function) rapidsmpf::rapidsmpf::Single::release_sync_host_data (C++ function) rapidsmpf::rapidsmpf::Single::send (C++ function), [1] rapidsmpf::rapidsmpf::Single::Single (C++ function) rapidsmpf::rapidsmpf::Single::str (C++ function) rapidsmpf::rapidsmpf::Single::test (C++ function) rapidsmpf::rapidsmpf::Single::test_some (C++ function), [1] rapidsmpf::rapidsmpf::Single::wait (C++ function) rapidsmpf::rapidsmpf::Single::wait_all (C++ function) rapidsmpf::rapidsmpf::SpillManager (C++ class) rapidsmpf::rapidsmpf::SpillManager::add_spill_function (C++ function) rapidsmpf::rapidsmpf::SpillManager::remove_spill_function (C++ function) rapidsmpf::rapidsmpf::SpillManager::spill (C++ function) rapidsmpf::rapidsmpf::SpillManager::spill_to_make_headroom (C++ function) rapidsmpf::rapidsmpf::SpillManager::SpillFunction (C++ type) rapidsmpf::rapidsmpf::SpillManager::SpillFunctionID (C++ type) rapidsmpf::rapidsmpf::SpillManager::SpillManager (C++ function) rapidsmpf::rapidsmpf::SpillManager::try_spill_to_make_headroom (C++ function) rapidsmpf::rapidsmpf::SpillManager::~SpillManager (C++ function) rapidsmpf::rapidsmpf::Statistics (C++ class) rapidsmpf::rapidsmpf::Statistics::add_bytes_stat (C++ function) rapidsmpf::rapidsmpf::Statistics::add_duration_stat (C++ function) rapidsmpf::rapidsmpf::Statistics::add_report_entry (C++ function), [1] rapidsmpf::rapidsmpf::Statistics::add_stat (C++ function) rapidsmpf::rapidsmpf::Statistics::clear (C++ function) rapidsmpf::rapidsmpf::Statistics::copy (C++ function) rapidsmpf::rapidsmpf::Statistics::create (C++ function) rapidsmpf::rapidsmpf::Statistics::create_memory_recorder (C++ function) rapidsmpf::rapidsmpf::Statistics::deserialize (C++ function) rapidsmpf::rapidsmpf::Statistics::disable (C++ function) rapidsmpf::rapidsmpf::Statistics::disabled (C++ function) rapidsmpf::rapidsmpf::Statistics::enable (C++ function) rapidsmpf::rapidsmpf::Statistics::enabled (C++ function) rapidsmpf::rapidsmpf::Statistics::Formatter (C++ enum) rapidsmpf::rapidsmpf::Statistics::Formatter::_Count (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::Formatter::Bytes (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::Formatter::Default (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::Formatter::Duration (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::Formatter::HitRate (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::Formatter::MemoryThroughput (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::from_options (C++ function) rapidsmpf::rapidsmpf::Statistics::get_memory_records (C++ function) rapidsmpf::rapidsmpf::Statistics::get_stat (C++ function) rapidsmpf::rapidsmpf::Statistics::list_stat_names (C++ function) rapidsmpf::rapidsmpf::Statistics::MemoryRecord (C++ struct) rapidsmpf::rapidsmpf::Statistics::MemoryRecord::global_peak (C++ member) rapidsmpf::rapidsmpf::Statistics::MemoryRecord::num_calls (C++ member) rapidsmpf::rapidsmpf::Statistics::MemoryRecord::scoped (C++ member) rapidsmpf::rapidsmpf::Statistics::MemoryRecorder (C++ class) rapidsmpf::rapidsmpf::Statistics::MemoryRecorder::MemoryRecorder (C++ function), [1] rapidsmpf::rapidsmpf::Statistics::merge (C++ function) rapidsmpf::rapidsmpf::Statistics::Mode (C++ enum) rapidsmpf::rapidsmpf::Statistics::Mode::Disabled (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::Mode::Enabled (C++ enumerator) rapidsmpf::rapidsmpf::Statistics::record_alloc (C++ function) rapidsmpf::rapidsmpf::Statistics::record_copy (C++ function) rapidsmpf::rapidsmpf::Statistics::report (C++ function), [1] rapidsmpf::rapidsmpf::Statistics::ReportArgs (C++ struct) rapidsmpf::rapidsmpf::Statistics::ReportArgs::header (C++ member) rapidsmpf::rapidsmpf::Statistics::ReportArgs::mr (C++ member) rapidsmpf::rapidsmpf::Statistics::ReportArgs::pinned_mr (C++ member) rapidsmpf::rapidsmpf::Statistics::serialize (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat (C++ class) rapidsmpf::rapidsmpf::Statistics::Stat::add (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::count (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::deserialize (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::max (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::merge (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::operator<=> (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::serialize (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::serialized_size (C++ function) rapidsmpf::rapidsmpf::Statistics::Stat::Stat (C++ function), [1] rapidsmpf::rapidsmpf::Statistics::Stat::value (C++ function) rapidsmpf::rapidsmpf::Statistics::write_json (C++ function), [1] rapidsmpf::rapidsmpf::StreamOrderedTiming (C++ class) rapidsmpf::rapidsmpf::StreamOrderedTiming::cancel_inflight_timings (C++ function) rapidsmpf::rapidsmpf::StreamOrderedTiming::stop_and_record (C++ function) rapidsmpf::rapidsmpf::StreamOrderedTiming::StreamOrderedTiming (C++ function) rapidsmpf::rapidsmpf::StreamPool (C++ class) rapidsmpf::rapidsmpf::StreamPool::get_pool_size (C++ function) rapidsmpf::rapidsmpf::StreamPool::get_stream (C++ function), [1] rapidsmpf::rapidsmpf::StreamPool::StreamPool (C++ function), [1] rapidsmpf::rapidsmpf::Tag (C++ class) rapidsmpf::rapidsmpf::Tag::bit_length (C++ function) rapidsmpf::rapidsmpf::Tag::max_value (C++ function) rapidsmpf::rapidsmpf::Tag::op (C++ function) rapidsmpf::rapidsmpf::Tag::op_id_bits (C++ member) rapidsmpf::rapidsmpf::Tag::op_id_mask (C++ member) rapidsmpf::rapidsmpf::Tag::operator StorageT (C++ function) rapidsmpf::rapidsmpf::Tag::stage (C++ function) rapidsmpf::rapidsmpf::Tag::stage_id_bits (C++ member) rapidsmpf::rapidsmpf::Tag::stage_id_mask (C++ member) rapidsmpf::rapidsmpf::Tag::StorageT (C++ type) rapidsmpf::rapidsmpf::Tag::Tag (C++ function) rapidsmpf::rrun::bind (C++ function), [1] rapidsmpf::rrun::check_binding (C++ function) rapidsmpf::rrun::get_expected_binding (C++ function) rapidsmpf::rrun::rapidsmpf::rrun::bind_options (C++ struct) rapidsmpf::rrun::rapidsmpf::rrun::bind_options::cpu (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::bind_options::memory (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::bind_options::network (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::bind_options::verify (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::binding_validation (C++ struct) rapidsmpf::rrun::rapidsmpf::rrun::binding_validation::all_passed (C++ function) rapidsmpf::rrun::rapidsmpf::rrun::binding_validation::cpu_ok (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::binding_validation::expected_ucx_devices (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::binding_validation::numa_ok (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::binding_validation::ucx_ok (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::expected_binding (C++ struct) rapidsmpf::rrun::rapidsmpf::rrun::expected_binding::cpu_affinity (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::expected_binding::memory_binding (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::expected_binding::network_devices (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::resource_binding (C++ struct) rapidsmpf::rrun::rapidsmpf::rrun::resource_binding::cpu_affinity (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::resource_binding::gpu_id (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::resource_binding::gpu_pci_bus_id (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::resource_binding::numa_nodes (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::resource_binding::rank (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::resource_binding::ucx_net_devices (C++ member) rapidsmpf::rrun::rapidsmpf::rrun::ScopedEnvVar (C++ class) rapidsmpf::rrun::rapidsmpf::rrun::ScopedEnvVar::ScopedEnvVar (C++ function) rapidsmpf::rrun::validate_binding (C++ function) rapidsmpf::safe_cast (C++ function) rapidsmpf::safe_div (C++ function) rapidsmpf::shuffler::operator<< (C++ function), [1] rapidsmpf::shuffler::PartID (C++ type) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler (C++ class) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::chunk_id_counter_bits (C++ member) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::comm (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::contiguous (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::extract (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::extract_rank (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::finished (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::FinishedCallback (C++ type) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::insert (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::insert_finished (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::local_partitions (C++ function), [1] rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::partition_owner (C++ member) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::PartitionOwner (C++ type) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::round_robin (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::Shuffler (C++ function), [1] rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::shutdown (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::spill (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::str (C++ function) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::total_num_partitions (C++ member) rapidsmpf::shuffler::rapidsmpf::shuffler::Shuffler::wait (C++ function) rapidsmpf::spill_partitions (C++ function) rapidsmpf::SPILL_TARGET_MEMORY_TYPES (C++ member) rapidsmpf::StageID (C++ type) rapidsmpf::stream_pool_from_options (C++ function) rapidsmpf::streaming::Actor (C++ type) rapidsmpf::streaming::actor::allgather (C++ function) rapidsmpf::streaming::actor::fanout (C++ function) rapidsmpf::streaming::actor::FanoutPolicy (C++ enum) rapidsmpf::streaming::actor::FanoutPolicy::BOUNDED (C++ enumerator) rapidsmpf::streaming::actor::FanoutPolicy::UNBOUNDED (C++ enumerator) rapidsmpf::streaming::actor::pull_from_channel (C++ function) rapidsmpf::streaming::actor::push_to_channel (C++ function) rapidsmpf::streaming::actor::shuffler (C++ function) rapidsmpf::streaming::coro_results (C++ function), [1] rapidsmpf::streaming::get_content_description (C++ function), [1], [2] rapidsmpf::streaming::rapidsmpf::streaming::AllGather (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::AllGather::AllGather (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllGather::comm (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllGather::ctx (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllGather::extract_all (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllGather::insert (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllGather::insert_finished (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllGather::Ordered (C++ type) rapidsmpf::streaming::rapidsmpf::streaming::AllReduce (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::AllReduce::AllReduce (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllReduce::comm (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllReduce::ctx (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::AllReduce::extract (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::BoundedQueue (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::BoundedQueue::acquire (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::BoundedQueue::drain (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::BoundedQueue::raii_shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::BoundedQueue::receive (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::BoundedQueue::shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::Channel::drain (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::drain_metadata (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::empty (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::is_shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::receive (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::receive_metadata (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::send (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::send_metadata (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Channel::shutdown_metadata (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::Context::br (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::Context (C++ function), [1] rapidsmpf::streaming::rapidsmpf::streaming::Context::create_bounded_queue (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::create_channel (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::executor (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::from_options (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::logger (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::memory (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::options (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::spillable_messages (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::statistics (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Context::uid (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::CoroThreadPoolExecutor (C++ function), [1], [2] rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::get (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::num_streaming_threads (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::schedule (C++ function), [1] rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::spawn_detached (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::spawn_joinable (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::CoroThreadPoolExecutor::yield (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Lineariser (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::Lineariser::drain (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Lineariser::get_queues (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Lineariser::Lineariser (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Lineariser::shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::br (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::executor (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::MemoryReserveOrWait (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::missing_net_memory_delta (C++ member) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::periodic_memory_check_counter (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::reserve_or_wait (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::reserve_or_wait_or_fail (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::reserve_or_wait_or_overbook (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::shutdown (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::size (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::MemoryReserveOrWait::timeout (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::Message::content_description (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::copy (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::copy_cb (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::copy_cost (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::CopyCallback (C++ type) rapidsmpf::streaming::rapidsmpf::streaming::Message::empty (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::get (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::holds (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::Message (C++ function), [1], [2] rapidsmpf::streaming::rapidsmpf::streaming::Message::operator= (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::release (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::reset (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::Message::sequence_number (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::PartitionMapChunk (C++ struct) rapidsmpf::streaming::rapidsmpf::streaming::PartitionMapChunk::data (C++ member) rapidsmpf::streaming::rapidsmpf::streaming::PartitionVectorChunk (C++ struct) rapidsmpf::streaming::rapidsmpf::streaming::PartitionVectorChunk::data (C++ member) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::comm (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::ctx (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::extract (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::insert (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::insert_finished (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::local_partitions (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::partition_owner (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::ShufflerAsync (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShufflerAsync::total_num_partitions (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ShutdownAtExit (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::ShutdownAtExit::ShutdownAtExit (C++ function), [1] rapidsmpf::streaming::rapidsmpf::streaming::ShutdownAtExit::~ShutdownAtExit (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SparseAlltoall (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::SparseAlltoall::comm (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SparseAlltoall::ctx (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SparseAlltoall::extract (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SparseAlltoall::insert (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SparseAlltoall::insert_finished (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SparseAlltoall::SparseAlltoall (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::clear (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::copy (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::extract (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::get_content_description (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::get_content_descriptions (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::insert (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::MessageId (C++ type) rapidsmpf::streaming::rapidsmpf::streaming::SpillableMessages::spill (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ThrottlingAdaptor (C++ class) rapidsmpf::streaming::rapidsmpf::streaming::ThrottlingAdaptor::acquire (C++ function) rapidsmpf::streaming::rapidsmpf::streaming::ThrottlingAdaptor::ThrottlingAdaptor (C++ function) rapidsmpf::streaming::reserve_memory (C++ function) rapidsmpf::streaming::run_actor_network (C++ function) rapidsmpf::streaming::Semaphore (C++ type) rapidsmpf::streaming::to_message (C++ function), [1], [2] rapidsmpf::TimePoint (C++ type) rapidsmpf::to_lower (C++ function) rapidsmpf::to_string (C++ function) rapidsmpf::to_upper (C++ function) rapidsmpf::to_vector (C++ function) rapidsmpf::trim (C++ function) rapidsmpf::TrimZeroFraction (C++ enum) rapidsmpf::TrimZeroFraction::NO (C++ enumerator) rapidsmpf::TrimZeroFraction::YES (C++ enumerator) rapidsmpf::unspill_partitions (C++ function) 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) set_memory_limit() (rapidsmpf.memory.buffer_resource.BufferResource 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.buffer.Buffer attribute) (rapidsmpf.memory.memory_reservation.MemoryReservation attribute)

SpillableMessages Spilling SpillManager split() (rapidsmpf.memory.memory_reservation.MemoryReservation method) Statistics (class in rapidsmpf.statistics) statistics (rapidsmpf.integrations.ray.RapidsMPFActor property) (rapidsmpf.memory.buffer_resource.BufferResource attribute) stream_pool (rapidsmpf.memory.buffer_resource.BufferResource attribute) stream_pool_from_options() (in module rapidsmpf.memory.buffer_resource)

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)

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) write_json() (rapidsmpf.statistics.Statistics method) write_json_string() (rapidsmpf.statistics.Statistics method)