ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [03/50] [abbrv] ignite git commit: Improved affinityRun documentation
Date Mon, 13 Mar 2017 10:27:37 GMT
Improved affinityRun documentation


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7618b586
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7618b586
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7618b586

Branch: refs/heads/ignite-4565-ddl
Commit: 7618b5869e490148a8f13d4ea55ae4d08c741c3e
Parents: a7f77d4
Author: Denis Magda <dmagda@gridgain.com>
Authored: Wed Mar 1 13:16:42 2017 -0800
Committer: Denis Magda <dmagda@gridgain.com>
Committed: Wed Mar 1 13:16:42 2017 -0800

----------------------------------------------------------------------
 .../java/org/apache/ignite/IgniteCompute.java   | 44 ++++++++++++--------
 1 file changed, 26 insertions(+), 18 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/7618b586/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
index 212849a..b5c6261 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java
@@ -123,8 +123,10 @@ public interface IgniteCompute extends IgniteAsyncSupport {
 
     /**
      * Executes given job on the node where data for provided affinity key is located
-     * (a.k.a. affinity co-location). The data of the partition where affKey is stored
-     * will not be migrated from the target node while the job is executed.
+     * (a.k.a. affinity co-location).
+     * </p>
+     * It's guaranteed that the data of the whole partition, the affinity key belongs to,
+     * will present on the destination node throughout the job execution.
      *
      * @param cacheName Name of the cache to use for affinity co-location.
      * @param affKey Affinity key.
@@ -136,11 +138,13 @@ public interface IgniteCompute extends IgniteAsyncSupport {
 
     /**
      * Executes given job on the node where data for provided affinity key is located
-     * (a.k.a. affinity co-location). The data of the partition where affKey is stored
-     * will not be migrated from the target node while the job is executed. The data
-     * of the extra caches' partitions with the same partition number also will not be migrated.
+     * (a.k.a. affinity co-location).
+     * </p>
+     * It's guaranteed that the data of all the partitions of all participating caches,
+     * the affinity key belongs to, will present on the destination node throughout the job
execution.
      *
-     * @param cacheNames Names of the caches to to reserve the partition. The first cache
uses for affinity co-location.
+     * @param cacheNames Names of the caches to to reserve the partition. The first cache
is used for
+     *                   affinity co-location.
      * @param affKey Affinity key.
      * @param job Job which will be co-located on the node with given affinity key.
      * @throws IgniteException If job failed.
@@ -151,11 +155,12 @@ public interface IgniteCompute extends IgniteAsyncSupport {
 
     /**
      * Executes given job on the node where partition is located (the partition is primary
on the node)
-     * The data of the partition will not be migrated from the target node
-     * while the job is executed. The data of the extra caches' partitions with the same
partition number
-     * also will not be migrated.
+     * </p>
+     * It's guaranteed that the data of all the partitions of all participating caches,
+     * the affinity key belongs to, will present on the destination node throughout the job
execution.
      *
-     * @param cacheNames Names of the caches to to reserve the partition. The first cache
uses for affinity co-location.
+     * @param cacheNames Names of the caches to to reserve the partition. The first cache
is used for
+     *                   affinity co-location.
      * @param partId Partition number.
      * @param job Job which will be co-located on the node with given affinity key.
      * @throws IgniteException If job failed.
@@ -166,8 +171,10 @@ public interface IgniteCompute extends IgniteAsyncSupport {
 
     /**
      * Executes given job on the node where data for provided affinity key is located
-     * (a.k.a. affinity co-location). The data of the partition where affKey is stored
-     * will not be migrated from the target node while the job is executed.
+     * (a.k.a. affinity co-location).
+     * </p>
+     * It's guaranteed that the data of the whole partition, the affinity key belongs to,
+     * will present on the destination node throughout the job execution.
      *
      * @param cacheName Name of the cache to use for affinity co-location.
      * @param affKey Affinity key.
@@ -180,9 +187,10 @@ public interface IgniteCompute extends IgniteAsyncSupport {
 
     /**
      * Executes given job on the node where data for provided affinity key is located
-     * (a.k.a. affinity co-location). The data of the partition where affKey is stored
-     * will not be migrated from the target node while the job is executed. The data
-     * of the extra caches' partitions with the same partition number also will not be migrated.
+     * (a.k.a. affinity co-location).
+     * </p>
+     * It's guaranteed that the data of all the partitions of all participating caches,
+     * the affinity key belongs to, will present on the destination node throughout the job
execution.
      *
      * @param cacheNames Names of the caches to to reserve the partition. The first cache
uses for affinity co-location.
      * @param affKey Affinity key.
@@ -196,9 +204,9 @@ public interface IgniteCompute extends IgniteAsyncSupport {
 
     /**
      * Executes given job on the node where partition is located (the partition is primary
on the node)
-     * The data of the partition will not be migrated from the target node
-     * while the job is executed. The data of the extra caches' partitions with the same
partition number
-     * also will not be migrated.
+     * </p>
+     * It's guaranteed that the data of all the partitions of all participating caches,
+     * the affinity key belongs to, will present on the destination node throughout the job
execution.
      *
      * @param cacheNames Names of the caches to to reserve the partition. The first cache
uses for affinity co-location.
      * @param partId Partition to reserve.


Mime
View raw message