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. The returned job results will be reduced
/// into an individual result by provided reducer.
/// </summary>
/// <param name="clo">Job to run.</param>
/// <param name="args">Job arguments.</param>
/// <param name="rdc">Reducer to reduce all job results into one individual return value.</param>
/// <returns>Reduced job result for this execution.</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. The returned job results will be reduced
into an individual result by provided reducer.
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 . The returned job results will be reduced into an individual result by provided reducer .
public Future<TReduceRes> Apply<TArg, TJobRes, TReduceRes>(IComputeFunc<TArg, TJobRes> clo, 
            IEnumerable<TArg> args, IComputeReducer<TJobRes, TReduceRes> rdc)
        {
            IgniteArgumentCheck.NotNull(clo, "clo");
            IgniteArgumentCheck.NotNull(clo, "clo");
            IgniteArgumentCheck.NotNull(clo, "clo");
            ICollection<IComputeJob> jobs = new List<IComputeJob>(GetCountOrZero(args));
            var func = clo.ToNonGeneric();
            foreach (TArg arg in args)
                jobs.Add(new ComputeFuncJob(func, arg));
            return ExecuteClosures0(new ComputeReducingClosureTask<TArg, TJobRes, TReduceRes>(rdc),
                null, jobs, false);
        }
public Future < TReduceRes > Apply < TArg , TJobRes , TReduceRes > ( IComputeFunc < TArg , TJobRes > clo , IEnumerable < TArg > args , IComputeReducer < TJobRes , TReduceRes > rdc ) { IgniteArgumentCheck . NotNull ( clo , " " ) ; IgniteArgumentCheck . NotNull ( clo , " " ) ; IgniteArgumentCheck . NotNull ( clo , " " ) ; ICollection < IComputeJob > jobs = new List < IComputeJob > ( GetCountOrZero ( args ) ) ; var func = clo . ToNonGeneric ( ) ; foreach ( TArg arg in args ) jobs . Add ( new ComputeFuncJob ( func , arg ) ) ; return ExecuteClosures0 ( new ComputeReducingClosureTask < TArg , TJobRes , TReduceRes > ( rdc ) , null , jobs , false ) ; }
Executes provided closure job on nodes within this grid projection.
Executes provided closure job on nodes within this grid projection .
Reduced job result for this execution.
Reduced job result for this execution .
clo
IComputeFunc<TArg, TJobRes>
Job to run.
Job to run .
args
IEnumerable<TArg>
None
rdc
IComputeReducer<TJobRes, TReduceRes>
Reducer to reduce all job results into one individual return value.
Reducer to reduce all job results into one individual return value .