rapidsmpf::shuffler::Shuffler Member List

This is the complete list of members for rapidsmpf::shuffler::Shuffler, including all inherited members.

::ShuffleInsertGroupedTest (defined in rapidsmpf::shuffler::Shuffler)	rapidsmpf::shuffler::Shuffler	friend
chunk_id_counter_bits	rapidsmpf::shuffler::Shuffler	static
concat_insert(std::unordered_map< PartID, PackedData > &&chunks)	rapidsmpf::shuffler::Shuffler
counter_mask	rapidsmpf::shuffler::Shuffler	static
extract(PartID pid)	rapidsmpf::shuffler::Shuffler
extract_counter(detail::ChunkID cid)	rapidsmpf::shuffler::Shuffler	inlinestatic
extract_info(detail::ChunkID cid)	rapidsmpf::shuffler::Shuffler	inlinestatic
extract_rank(detail::ChunkID cid)	rapidsmpf::shuffler::Shuffler	inlinestatic
finished() const	rapidsmpf::shuffler::Shuffler
FinishedCallback typedef	rapidsmpf::shuffler::Shuffler
insert(std::unordered_map< PartID, PackedData > &&chunks)	rapidsmpf::shuffler::Shuffler
insert_finished(PartID pid)	rapidsmpf::shuffler::Shuffler
insert_finished(std::vector< PartID > &&pids)	rapidsmpf::shuffler::Shuffler
is_finished(PartID pid) const	rapidsmpf::shuffler::Shuffler
local_partitions(std::shared_ptr< Communicator > const &comm, PartID total_num_partitions, PartitionOwner partition_owner)	rapidsmpf::shuffler::Shuffler	static
local_partitions() const	rapidsmpf::shuffler::Shuffler
operator=(Shuffler const &)=delete (defined in rapidsmpf::shuffler::Shuffler)	rapidsmpf::shuffler::Shuffler
partition_owner	rapidsmpf::shuffler::Shuffler
PartitionOwner typedef	rapidsmpf::shuffler::Shuffler
round_robin(std::shared_ptr< Communicator > const &comm, PartID pid)	rapidsmpf::shuffler::Shuffler	inlinestatic
Shuffler(std::shared_ptr< Communicator > comm, std::shared_ptr< ProgressThread > progress_thread, OpID op_id, PartID total_num_partitions, BufferResource *br, FinishedCallback &&finished_callback, std::shared_ptr< Statistics > statistics=Statistics::disabled(), PartitionOwner partition_owner=round_robin)	rapidsmpf::shuffler::Shuffler
Shuffler(std::shared_ptr< Communicator > comm, std::shared_ptr< ProgressThread > progress_thread, OpID op_id, PartID total_num_partitions, BufferResource *br, std::shared_ptr< Statistics > statistics=Statistics::disabled(), PartitionOwner partition_owner=round_robin)	rapidsmpf::shuffler::Shuffler	inline
Shuffler(Shuffler const &)=delete (defined in rapidsmpf::shuffler::Shuffler)	rapidsmpf::shuffler::Shuffler
shutdown()	rapidsmpf::shuffler::Shuffler
spill(std::optional< std::size_t > amount=std::nullopt)	rapidsmpf::shuffler::Shuffler
str() const	rapidsmpf::shuffler::Shuffler
total_num_partitions	rapidsmpf::shuffler::Shuffler
wait_any(std::optional< std::chrono::milliseconds > timeout={})	rapidsmpf::shuffler::Shuffler
wait_on(PartID pid, std::optional< std::chrono::milliseconds > timeout={})	rapidsmpf::shuffler::Shuffler
~Shuffler() (defined in rapidsmpf::shuffler::Shuffler)	rapidsmpf::shuffler::Shuffler