Skip to main content

split_command

Function split_command 

Source
fn split_command(
    command: UnifiedCommand,
    parts: usize,
) -> impl Iterator<Item = (usize, UnifiedCommand)>
Expand description

Split the given command into one part per target worker.

Compute CreateDataflow commands are partitioned among the workers. Every other command is replicated to all workers.