modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeImpl.cs
/// <summary>
/// Executes given job on the node where data for provided affinity key is located
/// (a.k.a. affinity co-location).
/// </summary>
/// <param name="cacheName">Name of the cache to use for affinity co-location.</param>
/// <param name="affinityKey">Affinity key.</param>
/// <param name="clo">Job to execute.</param>
/// <returns>Job result for this execution.</returns>
/// <typeparam name="TJobRes">Type of job result.</typeparam>
Executes given job on the node where data for provided affinity key is located
(a.k.a. affinity co-location).
Executes given job on the node where data for provided affinity key is located ( a . k . a . affinity co - location ) .
public Future<TJobRes> AffinityCall<TJobRes>(string cacheName, object affinityKey, IComputeFunc<TJobRes> clo)
        {
            IgniteArgumentCheck.NotNull(cacheName, "cacheName");
            IgniteArgumentCheck.NotNull(clo, "clo");
            return ExecuteClosures0(new ComputeSingleClosureTask<object, TJobRes, TJobRes>(),
                new ComputeOutFuncJob(clo.ToNonGeneric()), opId: OpAffinity,
                writeAction: w => WriteAffinity(w, cacheName, affinityKey));
        }
public Future < TJobRes > AffinityCall < TJobRes > ( string cacheName , object affinityKey , IComputeFunc < TJobRes > clo ) { IgniteArgumentCheck . NotNull ( cacheName , " " ) ; IgniteArgumentCheck . NotNull ( clo , " " ) ; return ExecuteClosures0 ( new ComputeSingleClosureTask < object , TJobRes , TJobRes > ( ) , new ComputeOutFuncJob ( clo . ToNonGeneric ( ) ) , opId : OpAffinity , writeAction : w => WriteAffinity ( w , cacheName , affinityKey ) ) ; }
Executes given job on the node where data for provided affinity key is located
(a.k.a.
Executes given job on the node where data for provided affinity key is located ( a . k . a .
Job result for this execution.
Job result for this execution .
cacheName
string
Name of the cache to use for affinity co-location.
Name of the cache to use for affinity co - location .
affinityKey
object
None
clo
IComputeFunc<TJobRes>
Job to execute.
Job to execute .
typeparam
Type of job result.
Type of job result .