Struct StreamPlan 

pub struct StreamPlan {
    pub assignments: Vec<StreamAssignment>,
    pub sync_points: Vec<SyncPoint>,
    pub num_streams: usize,
    pub max_streams: usize,
}

The result of stream partitioning.

Fields

assignments: Vec<StreamAssignment>

Per-node stream assignments.

sync_points: Vec<SyncPoint>

Cross-stream sync points (event record/wait pairs to insert).

num_streams: usize

Number of distinct streams used.

max_streams: usize

Maximum number of streams the pass was allowed to create.

Implementations

impl StreamPlan

pub fn stream_of(&self, node: NodeId) -> StreamId

Returns the stream assigned to node, or StreamId(0) if not found.

pub fn nodes_on(&self, stream: StreamId) -> Vec<NodeId>

Returns all nodes assigned to stream.

pub fn has_concurrency(&self) -> bool

Returns true if any two nodes have been assigned to different streams.

pub fn sync_count(&self) -> usize

Returns the number of cross-stream synchronisation points.

Trait Implementations

impl Clone for StreamPlan

fn clone(&self) -> StreamPlan

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamPlan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.