Function mz_dataflow::server::serve_boundary

source · [−]
pub fn serve_boundary<SC: StorageCapture, CR: ComputeReplay, B: Fn(usize) -> (SC, CR) + Send + Sync + 'static>(
    config: Config, 
    create_boundary: B
) -> Result<(Server, LocalStorageClient, LocalComputeClient), Error>
Expand description

Initiates a timely dataflow computation, processing materialized commands.

  • create_boundary: A function to obtain the worker-local boundary components.