modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeImpl.cs
/// <summary>
/// Executes collection of jobs on nodes within this grid projection.
/// </summary>
/// <param name="clos">Collection of jobs to execute.</param>
/// <param name="rdc">Reducer to reduce all job results into one individual return value.</param>
/// <returns>Collection of job results for this execution.</returns>
Executes collection of jobs on nodes within this grid projection.
Executes collection of jobs on nodes within this grid projection .
public Future<TReduceRes> Execute<TJobRes, TReduceRes>(IEnumerable<IComputeFunc<TJobRes>> clos, 
            IComputeReducer<TJobRes, TReduceRes> rdc)
        {
            IgniteArgumentCheck.NotNull(clos, "clos");
            ICollection<IComputeJob> jobs = new List<IComputeJob>(GetCountOrZero(clos));
            foreach (var clo in clos)
                jobs.Add(new ComputeOutFuncJob(clo.ToNonGeneric()));
            return ExecuteClosures0(new ComputeReducingClosureTask<object, TJobRes, TReduceRes>(rdc), null, jobs, false);
        }
public Future < TReduceRes > Execute < TJobRes , TReduceRes > ( IEnumerable < IComputeFunc < TJobRes > > clos , IComputeReducer < TJobRes , TReduceRes > rdc ) { IgniteArgumentCheck . NotNull ( clos , " " ) ; ICollection < IComputeJob > jobs = new List < IComputeJob > ( GetCountOrZero ( clos ) ) ; foreach ( var clo in clos ) jobs . Add ( new ComputeOutFuncJob ( clo . ToNonGeneric ( ) ) ) ; return ExecuteClosures0 ( new ComputeReducingClosureTask < object , TJobRes , TReduceRes > ( rdc ) , null , jobs , false ) ; }
Executes collection of jobs on nodes within this grid projection.
Executes collection of jobs on nodes within this grid projection .
Collection of job results for this execution.
Collection of job results for this execution .
clos
IEnumerable<IComputeFunc<TJobRes>>
Collection of jobs to execute.
Collection of jobs to execute .
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 .