Skip to main content

encode_shuffle_flush_flags

Function encode_shuffle_flush_flags 

Source
pub fn encode_shuffle_flush_flags(
    wave: u64,
    activity: bool,
) -> Result<u64, &'static str>
Expand description

Encode one internal clustered-shuffle flush marker.

The returned value is valid only in the flags field of an in-band shuffle barrier. It must not be copied into checkpoint metadata or cluster control traffic.

ยงErrors

Returns an error instead of truncating a wave ordinal that does not fit the reserved field.