You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2017/03/13 10:27:37 UTC
[03/50] [abbrv] ignite git commit: Improved affinityRun documentation
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 <dm...@gridgain.com>
Authored: Wed Mar 1 13:16:42 2017 -0800
Committer: Denis Magda <dm...@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.