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="action">Job to execute.</param>
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<object> AffinityRun(string cacheName, object affinityKey, IComputeAction action)
        {
            IgniteArgumentCheck.NotNull(cacheName, "cacheName");
            IgniteArgumentCheck.NotNull(action, "action");
            return ExecuteClosures0(new ComputeSingleClosureTask<object, object, object>(),
                new ComputeActionJob(action), opId: OpAffinity,
                writeAction: w => WriteAffinity(w, cacheName, affinityKey));
        }
public Future < object > AffinityRun ( string cacheName , object affinityKey , IComputeAction action ) { IgniteArgumentCheck . NotNull ( cacheName , " " ) ; IgniteArgumentCheck . NotNull ( action , " " ) ; return ExecuteClosures0 ( new ComputeSingleClosureTask < object , object , object > ( ) , new ComputeActionJob ( action ) , 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 .
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
action
IComputeAction
Job to execute.
Job to execute .