modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeImpl.cs
/// <summary>
/// Executes given task on the grid projection. For step-by-step explanation of task execution process
/// refer to <see cref="IComputeTask{A,T,R}"/> documentation.
/// </summary>
/// <param name="task">Task to execute.</param>
/// <param name="taskArg">Optional task argument.</param>
/// <returns>Task result.</returns>
Executes given task on the grid projection. For step-by-step explanation of task execution process
refer to  documentation.
Executes given task on the grid projection . For step - by - step explanation of task execution process refer to documentation .
public Future<TReduceRes> Execute<TArg, TJobRes, TReduceRes>(IComputeTask<TArg, TJobRes, TReduceRes> task, 
            TArg taskArg)
        {
            IgniteArgumentCheck.NotNull(task, "task");
            var holder = new ComputeTaskHolder<TArg, TJobRes, TReduceRes>((Ignite) _prj.Ignite, this, task, taskArg);
            long ptr = Marshaller.Ignite.HandleRegistry.Allocate(holder);
            var futTarget = DoOutOpObject(OpExecNative, (IBinaryStream s) =>
            {
                s.WriteLong(ptr);
                s.WriteLong(_prj.TopologyVersion);
            });
            var future = holder.Future;
            future.SetTarget(new Listenable(futTarget));
            return future;
        }
public Future < TReduceRes > Execute < TArg , TJobRes , TReduceRes > ( IComputeTask < TArg , TJobRes , TReduceRes > task , TArg taskArg ) { IgniteArgumentCheck . NotNull ( task , " " ) ; var holder = new ComputeTaskHolder < TArg , TJobRes , TReduceRes > ( ( Ignite ) _prj . Ignite , this , task , taskArg ) ; long ptr = Marshaller . Ignite . HandleRegistry . Allocate ( holder ) ; var futTarget = DoOutOpObject ( OpExecNative , ( IBinaryStream s ) => { s . WriteLong ( ptr ) ; s . WriteLong ( _prj . TopologyVersion ) ; } ) ; var future = holder . Future ; future . SetTarget ( new Listenable ( futTarget ) ) ; return future ; }
Executes given task on the grid projection.
Executes given task on the grid projection .
None
task
IComputeTask<TArg, TJobRes, TReduceRes>
Task to execute.
Task to execute .
taskArg
TArg
Optional task argument.
Optional task argument .