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 2016/09/06 14:39:28 UTC
[06/50] [abbrv] ignite git commit: VisorNodeDataCollectorTask should
be aware of passed nodes IDs.
VisorNodeDataCollectorTask should be aware of passed nodes IDs.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c35c6522
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c35c6522
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c35c6522
Branch: refs/heads/ignite-1.5.31-1
Commit: c35c6522d9d2e34322ab39de9d689f7a72647b39
Parents: 8ed13e8
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Wed Jul 6 17:48:12 2016 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Wed Jul 6 17:48:12 2016 +0700
----------------------------------------------------------------------
.../visor/node/VisorNodeDataCollectorTask.java | 26 --------------------
1 file changed, 26 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/c35c6522/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTask.java
index 494f902..746583d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTask.java
@@ -18,22 +18,15 @@
package org.apache.ignite.internal.visor.node;
import java.util.List;
-import java.util.Map;
import java.util.UUID;
import org.apache.ignite.IgniteException;
import org.apache.ignite.cluster.ClusterGroupEmptyException;
-import org.apache.ignite.cluster.ClusterNode;
-import org.apache.ignite.compute.ComputeJob;
import org.apache.ignite.compute.ComputeJobResult;
import org.apache.ignite.internal.processors.task.GridInternal;
-import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.visor.VisorMultiNodeTask;
-import org.apache.ignite.internal.visor.VisorTaskArgument;
import org.apache.ignite.internal.visor.util.VisorExceptionWrapper;
import org.jetbrains.annotations.Nullable;
-import static org.apache.ignite.internal.visor.util.VisorTaskUtils.logMapped;
-
/**
* Collects current Grid state mostly topology and metrics.
*/
@@ -44,25 +37,6 @@ public class VisorNodeDataCollectorTask extends VisorMultiNodeTask<VisorNodeData
private static final long serialVersionUID = 0L;
/** {@inheritDoc} */
- @Override protected Map<? extends ComputeJob, ClusterNode> map0(List<ClusterNode> subgrid,
- VisorTaskArgument<VisorNodeDataCollectorTaskArg> arg) {
- assert arg != null;
-
- Map<ComputeJob, ClusterNode> map = U.newHashMap(subgrid.size());
-
- try {
- for (ClusterNode node : subgrid)
- map.put(job(taskArg), node);
-
- return map;
- }
- finally {
- if (debug)
- logMapped(ignite.log(), getClass(), map.values());
- }
- }
-
- /** {@inheritDoc} */
@Override protected VisorNodeDataCollectorJob job(VisorNodeDataCollectorTaskArg arg) {
return new VisorNodeDataCollectorJob(arg, debug);
}