modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeImpl.cs
/// <summary>
/// Executes provided closure job on nodes within this grid projection. A new job is executed for
/// every argument in the passed in collection. The number of actual job executions will be
/// equal to size of the job arguments collection.
/// </summary>
/// <param name="clo">Job to run.</param>
/// <param name="args">Job arguments.</param>
/// <returns>Collection of job results.</returns>
Executes provided closure job on nodes within this grid projection. A new job is executed for
every argument in the passed in collection. The number of actual job executions will be
equal to size of the job arguments collection.
Executes provided closure job on nodes within this grid projection . A new job is executed for every argument in the passed in collection . The number of actual job executions will be equal to size of the job arguments collection .
public Future<ICollection<TJobRes>> Apply<TArg, TJobRes>(IComputeFunc<TArg, TJobRes> clo, 
            IEnumerable<TArg> args)
        {
            IgniteArgumentCheck.NotNull(clo, "clo");
            IgniteArgumentCheck.NotNull(clo, "clo");
            var jobs = new List<IComputeJob>(GetCountOrZero(args));
            var func = clo.ToNonGeneric();
            foreach (TArg arg in args)
                jobs.Add(new ComputeFuncJob(func, arg));
            return ExecuteClosures0(new ComputeMultiClosureTask<TArg, TJobRes, ICollection<TJobRes>>(jobs.Count),
                null, jobs, false);
        }
public Future < ICollection < TJobRes > > Apply < TArg , TJobRes > ( IComputeFunc < TArg , TJobRes > clo , IEnumerable < TArg > args ) { IgniteArgumentCheck . NotNull ( clo , " " ) ; IgniteArgumentCheck . NotNull ( clo , " " ) ; var jobs = new List < IComputeJob > ( GetCountOrZero ( args ) ) ; var func = clo . ToNonGeneric ( ) ; foreach ( TArg arg in args ) jobs . Add ( new ComputeFuncJob ( func , arg ) ) ; return ExecuteClosures0 ( new ComputeMultiClosureTask < TArg , TJobRes , ICollection < TJobRes > > ( jobs . Count ) , null , jobs , false ) ; }
Executes provided closure job on nodes within this grid projection.
Executes provided closure job on nodes within this grid projection .
Collection of job results.
Collection of job results .
clo
IComputeFunc<TArg, TJobRes>
Job to run.
Job to run .
args
IEnumerable<TArg>
None