kapot_executor

Function new_standalone_executor

Source 
pub async fn new_standalone_executor<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan>(
    scheduler: SchedulerGrpcClient<Channel>,
    concurrent_tasks: usize,
    codec: KapotCodec<T, U>,
) -> Result<()>