Expand description
Logical messages carried by the ordered shuffle transport.
The data/barrier wire encoding is gRPC/protobuf (proto/shuffle.proto, ShuffleFrame);
transport identity is internal to super::transport. A data message’s batch is
Arrow IPC-encoded as one self-contained logical payload. Wire fragmentation
slices that allocation without copying it or retaining per-stage codec state.
Enums§
- Shuffle
Message - Logical message carried on a shuffle connection.
Constants§
- MAX_
PAYLOAD_ BYTES - Maximum reassembled Arrow IPC payload for one logical shuffled batch: 16 MiB.