rapidsmpf::streaming::Partitioning Struct Reference

Hierarchical partitioning metadata for a data stream. More...

#include <channel_metadata.hpp>

Public Member Functions
bool	operator== (Partitioning const &) const =default
	Equality comparison. More...

Public Attributes
PartitioningSpec	inter_rank
	Distribution across ranks (corresponds to primary communicator).
PartitioningSpec	local
	Distribution within a rank (corresponds to local/single communicator).

Detailed Description

Hierarchical partitioning metadata for a data stream.

Describes how data flowing through a channel is partitioned at multiple levels of the system hierarchy. Each level corresponds to a communicator used to shuffle data at that level:

• inter_rank: Distribution across ranks, corresponding to the primary communicator (e.g., Context::comm()). Shuffle operations at this level move data between ranks.
• local: Distribution within a rank, corresponding to a single-rank communicator. Operations at this level repartition data locally without network communication.

Definition at line 103 of file channel_metadata.hpp.

Member Function Documentation

operator==()

bool rapidsmpf::streaming::Partitioning::operator== ( Partitioning const &  ) const

default

Equality comparison.

Returns

True if both partitionings are equal.

---

The documentation for this struct was generated from the following file:

• /__w/rapidsmpf/rapidsmpf/cpp/include/rapidsmpf/streaming/cudf/channel_metadata.hpp