ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject ignite git commit: IGNITE-9337 Added optional group name to VisorNodeDataCollectorTask. Implemented VisorCacheNamesCollectorTask to collect all cache names and deployment IDs. Minor code cleanup. Updated classnames.properties to match master codebase
Date Tue, 21 Aug 2018 07:59:02 GMT
Repository: ignite
Updated Branches:
  refs/heads/master 0e1763131 -> 1ad03f070


IGNITE-9337
 Added optional group name to VisorNodeDataCollectorTask.
 Implemented VisorCacheNamesCollectorTask to collect all cache names and deployment IDs.
 Minor code cleanup.
 Updated classnames.properties to match master codebase.


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

Branch: refs/heads/master
Commit: 1ad03f070b14f6f0c24ff0fde25b6c0cb8e5bcca
Parents: 0e17631
Author: Alexey Kuznetsov <akuznetsov@apache.org>
Authored: Tue Aug 21 14:58:58 2018 +0700
Committer: Alexey Kuznetsov <akuznetsov@apache.org>
Committed: Tue Aug 21 14:58:58 2018 +0700

----------------------------------------------------------------------
 .../VisorCacheConfigurationCollectorTask.java   |   1 -
 .../cache/VisorCacheLostPartitionsTask.java     |   5 +-
 .../visor/cache/VisorCacheModifyTask.java       |  14 +--
 .../visor/cache/VisorCacheModifyTaskArg.java    |  14 +--
 .../visor/cache/VisorCacheModifyTaskResult.java |  28 ++---
 .../cache/VisorCacheNamesCollectorTask.java     |  90 ++++++++++++++++
 .../VisorCacheNamesCollectorTaskResult.java     |  88 ++++++++++++++++
 .../visor/cache/VisorCachePartitionsTask.java   |   2 +-
 .../VisorCacheResetLostPartitionsTask.java      |   2 +-
 .../internal/visor/file/VisorFileBlock.java     |   2 +-
 .../visor/node/VisorNodeDataCollectorJob.java   |  19 +++-
 .../visor/node/VisorNodeDataCollectorTask.java  |   2 +-
 .../node/VisorNodeDataCollectorTaskArg.java     |  47 ++++++++-
 .../visor/service/VisorServiceTask.java         |   2 +-
 .../resources/META-INF/classnames.properties    | 104 +++++++++++++++----
 15 files changed, 353 insertions(+), 67 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfigurationCollectorTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfigurationCollectorTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfigurationCollectorTask.java
index 154e39e..fd224a8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfigurationCollectorTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheConfigurationCollectorTask.java
@@ -20,7 +20,6 @@ package org.apache.ignite.internal.visor.cache;
 import java.util.Map;
 import org.apache.ignite.internal.processors.task.GridInternal;
 import org.apache.ignite.internal.visor.VisorOneNodeTask;
-import org.apache.ignite.lang.IgniteUuid;
 
 /**
  * Task that collect cache metrics from all nodes.

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLostPartitionsTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLostPartitionsTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLostPartitionsTask.java
index 24b4069..52db552 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLostPartitionsTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheLostPartitionsTask.java
@@ -66,8 +66,9 @@ public class VisorCacheLostPartitionsTask
                 IgniteInternalCache cache = ignite.cachex(cacheName);
 
                 if (cache != null) {
-                    GridDhtPartitionTopology topology = cache.context().topology();
-                    List<Integer> lostPartitions = new ArrayList<>(topology.lostPartitions());
+                    GridDhtPartitionTopology top = cache.context().topology();
+
+                    List<Integer> lostPartitions = new ArrayList<>(top.lostPartitions());
 
                     if (!lostPartitions.isEmpty())
                         res.put(cacheName, lostPartitions);

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTask.java
index d6b1ff7..62e7ac6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTask.java
@@ -41,7 +41,7 @@ public class VisorCacheModifyTask extends VisorOneNodeTask<VisorCacheModifyTaskA
     }
 
     /**
-     * Job that clear specified caches.
+     * Job that modify value in specified cache.
      */
     private static class VisorCacheModifyJob extends VisorJob<VisorCacheModifyTaskArg, VisorCacheModifyTaskResult> {
         /** */
@@ -88,18 +88,18 @@ public class VisorCacheModifyTask extends VisorOneNodeTask<VisorCacheModifyTaskA
                         VisorQueryUtils.convertValue(old));
 
                 case GET:
-                    Object value = cache.get(key);
+                    Object val = cache.get(key);
 
-                    return new VisorCacheModifyTaskResult(nid, VisorTaskUtils.compactClass(value),
-                        VisorQueryUtils.convertValue(value));
+                    return new VisorCacheModifyTaskResult(nid, VisorTaskUtils.compactClass(val),
+                        VisorQueryUtils.convertValue(val));
 
                 case REMOVE:
-                    Object removed = cache.get(key);
+                    Object rmv = cache.get(key);
 
                     cache.remove(key);
 
-                    return new VisorCacheModifyTaskResult(nid, VisorTaskUtils.compactClass(removed),
-                        VisorQueryUtils.convertValue(removed));
+                    return new VisorCacheModifyTaskResult(nid, VisorTaskUtils.compactClass(rmv),
+                        VisorQueryUtils.convertValue(rmv));
             }
 
             return new VisorCacheModifyTaskResult(nid, null, null);

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskArg.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskArg.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskArg.java
index 706aab7..bef73ed 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskArg.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskArg.java
@@ -41,7 +41,7 @@ public class VisorCacheModifyTaskArg extends VisorDataTransferObject {
     private Object key;
 
     /** Specified value. */
-    private Object value;
+    private Object val;
 
     /**
      * Default constructor.
@@ -54,13 +54,13 @@ public class VisorCacheModifyTaskArg extends VisorDataTransferObject {
      * @param cacheName Cache name.
      * @param mode Modification mode.
      * @param key Specified key.
-     * @param value Specified value.
+     * @param val Specified value.
      */
-    public VisorCacheModifyTaskArg(String cacheName, VisorModifyCacheMode mode, Object key, Object value) {
+    public VisorCacheModifyTaskArg(String cacheName, VisorModifyCacheMode mode, Object key, Object val) {
         this.cacheName = cacheName;
         this.mode = mode;
         this.key = key;
-        this.value = value;
+        this.val = val;
     }
 
     /**
@@ -88,7 +88,7 @@ public class VisorCacheModifyTaskArg extends VisorDataTransferObject {
      * @return Specified value.
      */
     public Object getValue() {
-        return value;
+        return val;
     }
 
     /** {@inheritDoc} */
@@ -96,7 +96,7 @@ public class VisorCacheModifyTaskArg extends VisorDataTransferObject {
         U.writeString(out, cacheName);
         U.writeEnum(out, mode);
         out.writeObject(key);
-        out.writeObject(value);
+        out.writeObject(val);
     }
 
     /** {@inheritDoc} */
@@ -104,7 +104,7 @@ public class VisorCacheModifyTaskArg extends VisorDataTransferObject {
         cacheName = U.readString(in);
         mode = VisorModifyCacheMode.fromOrdinal(in.readByte());
         key = in.readObject();
-        value = in.readObject();
+        val = in.readObject();
     }
 
     /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskResult.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskResult.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskResult.java
index ce09bb2..8d0152a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskResult.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskResult.java
@@ -36,10 +36,10 @@ public class VisorCacheModifyTaskResult extends VisorDataTransferObject {
     private UUID affinityNode;
 
     /** Result type name. */
-    private String resultType;
+    private String resType;
 
     /** Value for specified key or number of modified rows. */
-    private Object result;
+    private Object res;
 
     /**
      * Default constructor.
@@ -50,13 +50,13 @@ public class VisorCacheModifyTaskResult extends VisorDataTransferObject {
 
     /**
      * @param affinityNode Node ID where modified data contained.
-     * @param resultType Result type name.
-     * @param result Value for specified key or number of modified rows.
+     * @param resType Result type name.
+     * @param res Value for specified key or number of modified rows.
      */
-    public VisorCacheModifyTaskResult(UUID affinityNode, String resultType, Object result) {
+    public VisorCacheModifyTaskResult(UUID affinityNode, String resType, Object res) {
         this.affinityNode = affinityNode;
-        this.resultType = resultType;
-        this.result = result;
+        this.resType = resType;
+        this.res = res;
     }
 
     /**
@@ -70,28 +70,28 @@ public class VisorCacheModifyTaskResult extends VisorDataTransferObject {
      * @return Result type name.
      */
     public String getResultType() {
-        return resultType;
+        return resType;
     }
 
     /**
-     * @return Value for specified key or number of modified rows..
+     * @return Value for specified key or number of modified rows.
      */
     public Object getResult() {
-        return result;
+        return res;
     }
 
     /** {@inheritDoc} */
     @Override protected void writeExternalData(ObjectOutput out) throws IOException {
         U.writeUuid(out, affinityNode);
-        U.writeString(out, resultType);
-        out.writeObject(result);
+        U.writeString(out, resType);
+        out.writeObject(res);
     }
 
     /** {@inheritDoc} */
     @Override protected void readExternalData(byte protoVer, ObjectInput in) throws IOException, ClassNotFoundException {
         affinityNode = U.readUuid(in);
-        resultType = U.readString(in);
-        result = in.readObject();
+        resType = U.readString(in);
+        res = in.readObject();
     }
 
     /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTask.java
new file mode 100644
index 0000000..7d934d1
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTask.java
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.visor.cache;
+
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
+
+import org.apache.ignite.internal.processors.cache.DynamicCacheDescriptor;
+import org.apache.ignite.internal.processors.cache.GridCacheProcessor;
+import org.apache.ignite.internal.processors.task.GridInternal;
+import org.apache.ignite.internal.util.typedef.F;
+import org.apache.ignite.internal.util.typedef.internal.S;
+import org.apache.ignite.internal.visor.VisorJob;
+import org.apache.ignite.internal.visor.VisorOneNodeTask;
+import org.apache.ignite.lang.IgniteUuid;
+
+/**
+ * Task that collect cache names and deployment IDs.
+ */
+@GridInternal
+public class VisorCacheNamesCollectorTask extends VisorOneNodeTask<Void, VisorCacheNamesCollectorTaskResult> {
+    /** */
+    private static final long serialVersionUID = 0L;
+
+    /** {@inheritDoc} */
+    @Override protected VisorCacheNamesCollectorJob job(Void arg) {
+        return new VisorCacheNamesCollectorJob(arg, debug);
+    }
+
+    /**
+     * Job that collect cache names and deployment IDs.
+     */
+    private static class VisorCacheNamesCollectorJob extends VisorJob<Void, VisorCacheNamesCollectorTaskResult> {
+        /** */
+        private static final long serialVersionUID = 0L;
+
+        /**
+         * Create job.
+         *
+         * @param arg Task argument.
+         * @param debug Debug flag.
+         */
+        private VisorCacheNamesCollectorJob(Void arg, boolean debug) {
+            super(arg, debug);
+        }
+
+        /** {@inheritDoc} */
+        @Override protected VisorCacheNamesCollectorTaskResult run(Void arg) {
+            GridCacheProcessor cacheProc = ignite.context().cache();
+
+            Map<String, IgniteUuid> caches = new HashMap<>();
+            Set<String> groups = new HashSet<>();
+
+            for (Map.Entry<String, DynamicCacheDescriptor> item : cacheProc.cacheDescriptors().entrySet()) {
+                DynamicCacheDescriptor cd = item.getValue();
+
+                caches.put(item.getKey(), cd.deploymentId());
+
+                String grp = cd.groupDescriptor().groupName();
+
+                if (!F.isEmpty(grp))
+                    groups.add(grp);
+            }
+
+            return new VisorCacheNamesCollectorTaskResult(caches, groups);
+        }
+
+        /** {@inheritDoc} */
+        @Override public String toString() {
+            return S.toString(VisorCacheNamesCollectorJob.class, this);
+        }
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTaskResult.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTaskResult.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTaskResult.java
new file mode 100644
index 0000000..a2e0908
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheNamesCollectorTaskResult.java
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.visor.cache;
+
+import java.io.IOException;
+import java.io.ObjectInput;
+import java.io.ObjectOutput;
+import java.util.Map;
+import java.util.Set;
+import org.apache.ignite.internal.util.typedef.internal.S;
+import org.apache.ignite.internal.util.typedef.internal.U;
+import org.apache.ignite.internal.visor.VisorDataTransferObject;
+import org.apache.ignite.lang.IgniteUuid;
+
+/**
+ * Result for {@link VisorCacheNamesCollectorTask}.
+ */
+public class VisorCacheNamesCollectorTaskResult extends VisorDataTransferObject {
+    /** */
+    private static final long serialVersionUID = 0L;
+
+    /** Cache names and deployment IDs. */
+    private Map<String, IgniteUuid> caches;
+
+    /** Cache groups. */
+    private Set<String> groups;
+
+    /**
+     * Default constructor.
+     */
+    public VisorCacheNamesCollectorTaskResult() {
+        // No-op.
+    }
+
+    /**
+     * @param caches Cache names and deployment IDs.
+     */
+    public VisorCacheNamesCollectorTaskResult(Map<String, IgniteUuid> caches, Set<String> groups) {
+        this.caches = caches;
+        this.groups = groups;
+    }
+
+    /**
+     * @return Value for specified key or number of modified rows..
+     */
+    public Map<String, IgniteUuid> getCaches() {
+        return caches;
+    }
+
+    /**
+     * @return Value for specified key or number of modified rows..
+     */
+    public Set<String> getGroups() {
+        return groups;
+    }
+
+    /** {@inheritDoc} */
+    @Override protected void writeExternalData(ObjectOutput out) throws IOException {
+        U.writeMap(out, caches);
+        U.writeCollection(out, groups);
+    }
+
+    /** {@inheritDoc} */
+    @Override protected void readExternalData(byte protoVer, ObjectInput in) throws IOException, ClassNotFoundException {
+        caches = U.readMap(in);
+        groups = U.readSet(in);
+    }
+
+    /** {@inheritDoc} */
+    @Override public String toString() {
+        return S.toString(VisorCacheNamesCollectorTaskResult.class, this);
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCachePartitionsTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCachePartitionsTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCachePartitionsTask.java
index af65de0..76ace17 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCachePartitionsTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCachePartitionsTask.java
@@ -63,7 +63,7 @@ public class VisorCachePartitionsTask extends VisorMultiNodeTask<VisorCacheParti
             if (res.getException() != null)
                 throw res.getException();
 
-            parts.put(res.getNode().id(), (VisorCachePartitions)res.getData());
+            parts.put(res.getNode().id(), res.getData());
         }
 
         return parts;

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheResetLostPartitionsTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheResetLostPartitionsTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheResetLostPartitionsTask.java
index eb48cd2..2ad88ee 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheResetLostPartitionsTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheResetLostPartitionsTask.java
@@ -43,7 +43,7 @@ public class VisorCacheResetLostPartitionsTask extends VisorOneNodeTask<VisorCac
         private static final long serialVersionUID = 0L;
 
         /**
-         * @param arg Object with list cache names to reset lost partitons.
+         * @param arg Object with list cache names to reset lost partitions.
          * @param debug Debug flag.
          */
         private VisorCacheResetLostPartitionsJob(VisorCacheResetLostPartitionsTaskArg arg, boolean debug) {

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/file/VisorFileBlock.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/file/VisorFileBlock.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/file/VisorFileBlock.java
index 23540b5..79d0e93 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/file/VisorFileBlock.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/file/VisorFileBlock.java
@@ -53,7 +53,7 @@ public class VisorFileBlock extends VisorDataTransferObject {
      * Default constructor.
      */
     public VisorFileBlock() {
-
+        // No-op.
     }
 
     /**

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorJob.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorJob.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorJob.java
index 14b9281..578300e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorJob.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorJob.java
@@ -20,8 +20,9 @@ package org.apache.ignite.internal.visor.node;
 import java.util.Collection;
 import java.util.List;
 import java.util.concurrent.ConcurrentMap;
-import org.apache.ignite.IgniteFileSystem;
+
 import org.apache.ignite.DataRegionMetrics;
+import org.apache.ignite.IgniteFileSystem;
 import org.apache.ignite.cache.CacheMetrics;
 import org.apache.ignite.cluster.ClusterNode;
 import org.apache.ignite.configuration.FileSystemConfiguration;
@@ -32,6 +33,7 @@ import org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeMan
 import org.apache.ignite.internal.processors.cache.GridCacheProcessor;
 import org.apache.ignite.internal.processors.igfs.IgfsProcessorAdapter;
 import org.apache.ignite.internal.util.ipc.IpcServerEndpoint;
+import org.apache.ignite.internal.util.typedef.F;
 import org.apache.ignite.internal.util.typedef.internal.S;
 import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.internal.visor.VisorJob;
@@ -159,7 +161,7 @@ public class VisorNodeDataCollectorJob extends VisorJob<VisorNodeDataCollectorTa
             List<VisorMemoryMetrics> memoryMetrics = res.getMemoryMetrics();
 
             // TODO: Should be really fixed in IGNITE-7111.
-            if (ignite.active()) {
+            if (ignite.cluster().active()) {
                 for (DataRegionMetrics m : ignite.dataRegionMetrics())
                     memoryMetrics.add(new VisorMemoryMetrics(m));
             }
@@ -181,17 +183,21 @@ public class VisorNodeDataCollectorJob extends VisorJob<VisorNodeDataCollectorTa
 
             GridCacheProcessor cacheProc = ignite.context().cache();
 
-            List<VisorCache> resCaches = res.getCaches();
+            String cacheGrpToCollect = arg.getCacheGroup();
 
             int partitions = 0;
             double total = 0;
             double ready = 0;
 
+            List<VisorCache> resCaches = res.getCaches();
+
             for (String cacheName : cacheProc.cacheNames()) {
                 if (proxyCache(cacheName))
                     continue;
 
-                if (arg.getSystemCaches() || !(isSystemCache(cacheName) || isIgfsCache(cfg, cacheName))) {
+                boolean sysCache = isSystemCache(cacheName);
+
+                if (arg.getSystemCaches() || !(sysCache || isIgfsCache(cfg, cacheName))) {
                     long start0 = U.currentTimeMillis();
 
                     try {
@@ -213,7 +219,10 @@ public class VisorNodeDataCollectorJob extends VisorJob<VisorNodeDataCollectorTa
                         total += partTotal;
                         ready += partReady;
 
-                        resCaches.add(new VisorCache(ignite, ca, arg.isCollectCacheMetrics()));
+                        String cacheGrp = ca.configuration().getGroupName();
+
+                        if (F.eq(cacheGrpToCollect, cacheGrp))
+                            resCaches.add(new VisorCache(ignite, ca, arg.isCollectCacheMetrics()));
                     }
                     catch(IllegalStateException | IllegalArgumentException e) {
                         if (debug && ignite.log() != null)

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/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 fffc3bf..067c57b 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
@@ -72,7 +72,7 @@ public class VisorNodeDataCollectorTask extends VisorMultiNodeTask<VisorNodeData
             }
         }
 
-        taskRes.setActive(ignite.active());
+        taskRes.setActive(ignite.cluster().active());
 
         return taskRes;
     }

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTaskArg.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTaskArg.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTaskArg.java
index 1876d06..e6f8027 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTaskArg.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeDataCollectorTaskArg.java
@@ -46,6 +46,9 @@ public class VisorNodeDataCollectorTaskArg extends VisorDataTransferObject {
     /** If {@code false} then cache metrics will not be collected. */
     private boolean collectCacheMetrics;
 
+    /** Optional cache group, if provided, then caches only from that group will be collected. */
+    private String cacheGrp;
+
     /**
      * Default constructor.
      */
@@ -61,19 +64,40 @@ public class VisorNodeDataCollectorTaskArg extends VisorDataTransferObject {
      * @param evtThrottleCntrKey Event throttle counter key, unique for Visor instance.
      * @param sysCaches If {@code true} then collect information about system caches.
      * @param collectCacheMetrics If {@code false} then cache metrics will not be collected.
+     * @param cacheGrp Optional cache group, if provided, then caches only from that group will be collected.
      */
     public VisorNodeDataCollectorTaskArg(
         boolean taskMonitoringEnabled,
         String evtOrderKey,
         String evtThrottleCntrKey,
         boolean sysCaches,
-        boolean collectCacheMetrics
+        boolean collectCacheMetrics,
+        String cacheGrp
     ) {
         this.taskMonitoringEnabled = taskMonitoringEnabled;
         this.evtOrderKey = evtOrderKey;
         this.evtThrottleCntrKey = evtThrottleCntrKey;
         this.sysCaches = sysCaches;
         this.collectCacheMetrics = collectCacheMetrics;
+        this.cacheGrp = cacheGrp;
+    }
+    /**
+     * Create task arguments with given parameters.
+     *
+     * @param taskMonitoringEnabled If {@code true} then Visor should collect information about tasks.
+     * @param evtOrderKey Event order key, unique for Visor instance.
+     * @param evtThrottleCntrKey Event throttle counter key, unique for Visor instance.
+     * @param sysCaches If {@code true} then collect information about system caches.
+     * @param collectCacheMetrics If {@code false} then cache metrics will not be collected.
+     */
+    public VisorNodeDataCollectorTaskArg(
+        boolean taskMonitoringEnabled,
+        String evtOrderKey,
+        String evtThrottleCntrKey,
+        boolean sysCaches,
+        boolean collectCacheMetrics
+    ) {
+        this(taskMonitoringEnabled, evtOrderKey, evtThrottleCntrKey, sysCaches, collectCacheMetrics, null);
     }
 
     /**
@@ -90,7 +114,7 @@ public class VisorNodeDataCollectorTaskArg extends VisorDataTransferObject {
         String evtThrottleCntrKey,
         boolean sysCaches
     ) {
-        this(taskMonitoringEnabled, evtOrderKey, evtThrottleCntrKey, sysCaches, true);
+        this(taskMonitoringEnabled, evtOrderKey, evtThrottleCntrKey, sysCaches, true, null);
     }
 
     /**
@@ -163,9 +187,23 @@ public class VisorNodeDataCollectorTaskArg extends VisorDataTransferObject {
         this.collectCacheMetrics = collectCacheMetrics;
     }
 
+    /**
+     * @return Optional cache group, if provided, then caches only from that group will be collected.
+     */
+    public String getCacheGroup() {
+        return cacheGrp;
+    }
+
+    /**
+     * @param cacheGrp Optional cache group, if provided, then caches only from that group will be collected.
+     */
+    public void setCollectCacheMetrics(String cacheGrp) {
+        this.cacheGrp = cacheGrp;
+    }
+
     /** {@inheritDoc} */
     @Override public byte getProtocolVersion() {
-        return V2;
+        return V3;
     }
 
     /** {@inheritDoc} */
@@ -175,6 +213,7 @@ public class VisorNodeDataCollectorTaskArg extends VisorDataTransferObject {
         U.writeString(out, evtThrottleCntrKey);
         out.writeBoolean(sysCaches);
         out.writeBoolean(collectCacheMetrics);
+        U.writeString(out, cacheGrp);
     }
 
     /** {@inheritDoc} */
@@ -185,6 +224,8 @@ public class VisorNodeDataCollectorTaskArg extends VisorDataTransferObject {
         sysCaches = in.readBoolean();
 
         collectCacheMetrics = protoVer < V2 || in.readBoolean();
+
+        cacheGrp = protoVer < V3 ? null : U.readString(in);
     }
 
     /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/java/org/apache/ignite/internal/visor/service/VisorServiceTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/service/VisorServiceTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/service/VisorServiceTask.java
index f2489bc..e2a1fb7 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/service/VisorServiceTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/service/VisorServiceTask.java
@@ -59,7 +59,7 @@ public class VisorServiceTask extends VisorOneNodeTask<Void, Collection<VisorSer
         @Override protected Collection<VisorServiceDescriptor> run(final Void arg) {
             Collection<VisorServiceDescriptor> res = new ArrayList<>();
 
-            if (ignite.active()) {
+            if (ignite.cluster().active()) {
                 Collection<ServiceDescriptor> services = ignite.services().serviceDescriptors();
 
                 for (ServiceDescriptor srvc : services)

http://git-wip-us.apache.org/repos/asf/ignite/blob/1ad03f07/modules/core/src/main/resources/META-INF/classnames.properties
----------------------------------------------------------------------
diff --git a/modules/core/src/main/resources/META-INF/classnames.properties b/modules/core/src/main/resources/META-INF/classnames.properties
index d4bbf0b..27934ad 100644
--- a/modules/core/src/main/resources/META-INF/classnames.properties
+++ b/modules/core/src/main/resources/META-INF/classnames.properties
@@ -24,6 +24,7 @@ org.apache.ignite.IgniteDeploymentException
 org.apache.ignite.IgniteException
 org.apache.ignite.IgniteIllegalStateException
 org.apache.ignite.IgniteInterruptedException
+org.apache.ignite.IgniteJdbcThinDataSource
 org.apache.ignite.IgniteState
 org.apache.ignite.binary.BinaryInvalidTypeException
 org.apache.ignite.binary.BinaryObject
@@ -172,7 +173,9 @@ org.apache.ignite.events.EventAdapter
 org.apache.ignite.events.IgfsEvent
 org.apache.ignite.events.JobEvent
 org.apache.ignite.events.TaskEvent
+org.apache.ignite.events.TransactionStateChangedEvent
 org.apache.ignite.events.WalSegmentArchivedEvent
+org.apache.ignite.events.WalSegmentCompactedEvent
 org.apache.ignite.failure.FailureType
 org.apache.ignite.hadoop.HadoopInputSplit
 org.apache.ignite.hadoop.HadoopMapReducePlan
@@ -252,13 +255,19 @@ org.apache.ignite.internal.IgniteInterruptedCheckedException
 org.apache.ignite.internal.IgniteKernal
 org.apache.ignite.internal.IgniteKernal$1
 org.apache.ignite.internal.IgniteKernal$5
-org.apache.ignite.internal.IgniteKernal$6
 org.apache.ignite.internal.IgniteMessagingImpl
 org.apache.ignite.internal.IgniteNeedReconnectException
 org.apache.ignite.internal.IgniteSchedulerImpl
 org.apache.ignite.internal.IgniteServicesImpl
+org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance$2
+org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance$3
 org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance$4
 org.apache.ignite.internal.NodeStoppingException
+org.apache.ignite.internal.SecurityCredentialsAttrFilterPredicate
+org.apache.ignite.internal.TransactionMetricsMxBeanImpl
+org.apache.ignite.internal.TransactionsMXBeanImpl$1
+org.apache.ignite.internal.UnregisteredBinaryTypeException
+org.apache.ignite.internal.UnregisteredClassException
 org.apache.ignite.internal.binary.BinaryEnumObjectImpl
 org.apache.ignite.internal.binary.BinaryFieldMetadata
 org.apache.ignite.internal.binary.BinaryMetadata
@@ -321,6 +330,8 @@ org.apache.ignite.internal.cluster.IgniteKillTask$IgniteKillJob
 org.apache.ignite.internal.cluster.NodeOrderComparator
 org.apache.ignite.internal.cluster.NodeOrderLegacyComparator
 org.apache.ignite.internal.commandline.Command
+org.apache.ignite.internal.commandline.CommandHandler$1
+org.apache.ignite.internal.commandline.CommandHandler$2
 org.apache.ignite.internal.commandline.cache.CacheCommand
 org.apache.ignite.internal.compute.ComputeTaskCancelledCheckedException
 org.apache.ignite.internal.compute.ComputeTaskTimeoutCheckedException
@@ -472,6 +483,7 @@ org.apache.ignite.internal.processors.cache.ClientCacheChangeDiscoveryMessage
 org.apache.ignite.internal.processors.cache.ClientCacheChangeDummyDiscoveryMessage
 org.apache.ignite.internal.processors.cache.ClusterCachesInfo$1$1
 org.apache.ignite.internal.processors.cache.DynamicCacheChangeBatch
+org.apache.ignite.internal.processors.cache.DynamicCacheChangeFailureMessage
 org.apache.ignite.internal.processors.cache.DynamicCacheChangeRequest
 org.apache.ignite.internal.processors.cache.EntryProcessorResourceInjectorProxy
 org.apache.ignite.internal.processors.cache.ExchangeActions$1
@@ -501,7 +513,6 @@ org.apache.ignite.internal.processors.cache.GridCacheAdapter$50
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$51
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$53
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$54
-org.apache.ignite.internal.processors.cache.GridCacheAdapter$54$1
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$55
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$56
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$6
@@ -515,6 +526,7 @@ org.apache.ignite.internal.processors.cache.GridCacheAdapter$GlobalClearAllJob
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$GlobalClearAllNearJob
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$GlobalClearKeySetJob
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$GlobalClearKeySetNearJob
+org.apache.ignite.internal.processors.cache.GridCacheAdapter$InvokeAllTimeStatClosure
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$LoadCacheClosure
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$LoadCacheJob
 org.apache.ignite.internal.processors.cache.GridCacheAdapter$LoadCacheJobV2
@@ -643,6 +655,7 @@ org.apache.ignite.internal.processors.cache.KeyCacheObject
 org.apache.ignite.internal.processors.cache.KeyCacheObjectImpl
 org.apache.ignite.internal.processors.cache.QueryCursorImpl$State
 org.apache.ignite.internal.processors.cache.StoredCacheData
+org.apache.ignite.internal.processors.cache.TxTimeoutOnPartitionMapExchangeChangeMessage
 org.apache.ignite.internal.processors.cache.WalStateAbstractMessage
 org.apache.ignite.internal.processors.cache.WalStateAckMessage
 org.apache.ignite.internal.processors.cache.WalStateFinishMessage
@@ -709,6 +722,7 @@ org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtInvalidPartit
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockFuture$1
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockFuture$2
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockFuture$3
+org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockFuture$4
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockRequest
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockResponse
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionState
@@ -734,6 +748,7 @@ org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishRespo
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocal
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocal$1
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocal$2
+org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocal$3
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocalAdapter
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocalAdapter$1
 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocalAdapter$2
@@ -826,7 +841,6 @@ org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtCol
 org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtColocatedLockFuture$2
 org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtColocatedLockFuture$3
 org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtColocatedLockFuture$4
-org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtColocatedLockFuture$5
 org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtColocatedLockFuture$LockTimeoutObject$1
 org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtColocatedLockFuture$MiniFuture$1
 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.CacheGroupAffinityMessage
@@ -853,7 +867,8 @@ org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPar
 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$6
 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$7
 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$8
-org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$8$1$1
+org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$9
+org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$9$1$1
 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$ExchangeLocalState
 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$ExchangeType
 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsFullMessage
@@ -889,7 +904,6 @@ org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockFuture$
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockFuture$2
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockFuture$3
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockFuture$4
-org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockFuture$5
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockFuture$LockTimeoutObject$1
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockFuture$MiniFuture$1
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearLockRequest
@@ -916,13 +930,13 @@ org.apache.ignite.internal.processors.cache.distributed.near.GridNearTransaction
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTransactionalCache$2
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture$1
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture$2
+org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture$3
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture$FinishMiniFuture$1
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishRequest
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishResponse
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$1
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$10
-org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$11
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$12
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$13
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$14
@@ -934,15 +948,19 @@ org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$19
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$2
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$20
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$21
+org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$21$1
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$22
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$23
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$24
+org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25
+org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$26
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$3
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$4
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$5
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$6
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$7
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$8
+org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$9
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$FinishClosure
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareFutureAdapter$1
 org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareRequest
@@ -960,17 +978,18 @@ org.apache.ignite.internal.processors.cache.local.atomic.GridLocalAtomicCache$5
 org.apache.ignite.internal.processors.cache.local.atomic.GridLocalAtomicCache$8
 org.apache.ignite.internal.processors.cache.local.atomic.GridLocalAtomicCache$9
 org.apache.ignite.internal.processors.cache.persistence.CacheDataRowAdapter$RowData
-org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$12
-org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$6
-org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$9
-org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$CheckpointEntryType
+org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$2
+org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$4
+org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$7
 org.apache.ignite.internal.processors.cache.persistence.GridCacheOffheapManager$WALHistoricalIterator
 org.apache.ignite.internal.processors.cache.persistence.IgniteCacheDatabaseSharedManager$1
+org.apache.ignite.internal.processors.cache.persistence.checkpoint.CheckpointEntryType
 org.apache.ignite.internal.processors.cache.persistence.file.AsyncFileIOFactory
 org.apache.ignite.internal.processors.cache.persistence.file.FileDownloader$1
 org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory
 org.apache.ignite.internal.processors.cache.persistence.file.PersistentStorageIOException
 org.apache.ignite.internal.processors.cache.persistence.file.RandomAccessFileIOFactory
+org.apache.ignite.internal.processors.cache.persistence.migration.UpgradePendingTreeToPerPartitionTask
 org.apache.ignite.internal.processors.cache.persistence.pagemem.PageMemoryImpl$Segment
 org.apache.ignite.internal.processors.cache.persistence.pagemem.PageMemoryImpl$ThrottlingPolicy
 org.apache.ignite.internal.processors.cache.persistence.pagemem.PagesWriteSpeedBasedThrottle$ThrottleMode
@@ -978,16 +997,18 @@ org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotDiscove
 org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotOperation
 org.apache.ignite.internal.processors.cache.persistence.snapshot.TrackingPageIsCorruptedException
 org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree$Bool
-org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree$DestroyBag
 org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree$Result
 org.apache.ignite.internal.processors.cache.persistence.tree.io.DataPageIO$EntryPart
+org.apache.ignite.internal.processors.cache.persistence.tree.reuse.LongListReuseBag
 org.apache.ignite.internal.processors.cache.persistence.wal.AbstractWalRecordsIterator
 org.apache.ignite.internal.processors.cache.persistence.wal.AbstractWalRecordsIterator$StartSeekingFilter
 org.apache.ignite.internal.processors.cache.persistence.wal.FileWALPointer
+org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager$7
 org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager$FileArchiver$1
 org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager$FileArchiver$2
 org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager$FileCompressor$1
 org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager$RecordsIterator
+org.apache.ignite.internal.processors.cache.persistence.wal.FsyncModeFileWriteAheadLogManager$7
 org.apache.ignite.internal.processors.cache.persistence.wal.FsyncModeFileWriteAheadLogManager$FileArchiver$1
 org.apache.ignite.internal.processors.cache.persistence.wal.FsyncModeFileWriteAheadLogManager$FileArchiver$2
 org.apache.ignite.internal.processors.cache.persistence.wal.FsyncModeFileWriteAheadLogManager$FileCompressor$1
@@ -1023,6 +1044,7 @@ org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$9
 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$CacheSqlIndexMetadata
 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$CacheSqlMetadata
 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$CachedResult$QueueIterator
+org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$InternalScanFilter
 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$MetadataJob
 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$MetadataJob$1
 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$MetadataJob$2
@@ -1080,6 +1102,8 @@ org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$Stat
 org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$StoreOperation
 org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$ValueStatus
 org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx$FinalizationStatus
+org.apache.ignite.internal.processors.cache.transactions.IgniteTransactionsImpl$1
+org.apache.ignite.internal.processors.cache.transactions.IgniteTransactionsImpl$2
 org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter
 org.apache.ignite.internal.processors.cache.transactions.IgniteTxEntry
 org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler$1
@@ -1121,9 +1145,14 @@ org.apache.ignite.internal.processors.cache.transactions.IgniteTxManager$NodeFai
 org.apache.ignite.internal.processors.cache.transactions.IgniteTxMap
 org.apache.ignite.internal.processors.cache.transactions.IgniteTxMap$1
 org.apache.ignite.internal.processors.cache.transactions.IgniteTxMap$1$1
+org.apache.ignite.internal.processors.cache.transactions.TransactionEventProxyImpl
 org.apache.ignite.internal.processors.cache.transactions.TransactionMetricsAdapter
+org.apache.ignite.internal.processors.cache.transactions.TransactionMetricsAdapter$1
+org.apache.ignite.internal.processors.cache.transactions.TransactionMetricsAdapter$2
+org.apache.ignite.internal.processors.cache.transactions.TransactionMetricsAdapter$3
 org.apache.ignite.internal.processors.cache.transactions.TransactionProxyImpl
 org.apache.ignite.internal.processors.cache.transactions.TransactionProxyImpl$1
+org.apache.ignite.internal.processors.cache.transactions.TransactionProxyRollbackOnlyImpl
 org.apache.ignite.internal.processors.cache.transactions.TxDeadlockDetection$UniqueDeque
 org.apache.ignite.internal.processors.cache.transactions.TxEntryValueHolder
 org.apache.ignite.internal.processors.cache.transactions.TxLock
@@ -1131,23 +1160,25 @@ org.apache.ignite.internal.processors.cache.transactions.TxLockList
 org.apache.ignite.internal.processors.cache.transactions.TxLocksRequest
 org.apache.ignite.internal.processors.cache.transactions.TxLocksResponse
 org.apache.ignite.internal.processors.cache.verify.CacheInfo
-org.apache.ignite.internal.processors.cache.verify.CacheInfo$1
-org.apache.ignite.internal.processors.cache.verify.CacheInfo$2
 org.apache.ignite.internal.processors.cache.verify.CollectConflictPartitionKeysTask
 org.apache.ignite.internal.processors.cache.verify.CollectConflictPartitionKeysTask$CollectPartitionEntryHashesJob
 org.apache.ignite.internal.processors.cache.verify.ContentionClosure
 org.apache.ignite.internal.processors.cache.verify.ContentionInfo
-org.apache.ignite.internal.processors.cache.verify.IdleVerifyResultV2
 org.apache.ignite.internal.processors.cache.verify.IdleVerifyDumpResult
+org.apache.ignite.internal.processors.cache.verify.IdleVerifyResultV2
 org.apache.ignite.internal.processors.cache.verify.PartitionEntryHashRecord
 org.apache.ignite.internal.processors.cache.verify.PartitionHashRecord
+org.apache.ignite.internal.processors.cache.verify.PartitionHashRecordV2
 org.apache.ignite.internal.processors.cache.verify.PartitionKey
+org.apache.ignite.internal.processors.cache.verify.PartitionKeyV2
 org.apache.ignite.internal.processors.cache.verify.RetrieveConflictPartitionValuesTask
 org.apache.ignite.internal.processors.cache.verify.RetrieveConflictPartitionValuesTask$RetrieveConflictValuesJob
+org.apache.ignite.internal.processors.cache.verify.VerifyBackupPartitionsDumpTask
 org.apache.ignite.internal.processors.cache.verify.VerifyBackupPartitionsTask
 org.apache.ignite.internal.processors.cache.verify.VerifyBackupPartitionsTask$VerifyBackupPartitionsJob
+org.apache.ignite.internal.processors.cache.verify.VerifyBackupPartitionsTaskV2
+org.apache.ignite.internal.processors.cache.verify.VerifyBackupPartitionsTaskV2$VerifyBackupPartitionsJobV2
 org.apache.ignite.internal.processors.cache.verify.ViewCacheClosure
-org.apache.ignite.internal.processors.cache.verify.ViewCacheClosure$1
 org.apache.ignite.internal.processors.cache.version.GridCacheRawVersionedEntry
 org.apache.ignite.internal.processors.cache.version.GridCacheVersion
 org.apache.ignite.internal.processors.cache.version.GridCacheVersionConflictContext$State
@@ -1290,6 +1321,7 @@ org.apache.ignite.internal.processors.datastructures.GridCacheSemaphoreImpl$Sync
 org.apache.ignite.internal.processors.datastructures.GridCacheSemaphoreState
 org.apache.ignite.internal.processors.datastructures.GridCacheSetHeader
 org.apache.ignite.internal.processors.datastructures.GridCacheSetHeaderKey
+org.apache.ignite.internal.processors.datastructures.GridCacheSetImpl$5
 org.apache.ignite.internal.processors.datastructures.GridCacheSetImpl$SumReducer
 org.apache.ignite.internal.processors.datastructures.GridCacheSetItemKey
 org.apache.ignite.internal.processors.datastructures.GridCacheSetProxy
@@ -1397,6 +1429,7 @@ org.apache.ignite.internal.processors.marshaller.MappingProposedMessage$Proposal
 org.apache.ignite.internal.processors.marshaller.MarshallerMappingItem
 org.apache.ignite.internal.processors.marshaller.MissingMappingRequestMessage
 org.apache.ignite.internal.processors.marshaller.MissingMappingResponseMessage
+org.apache.ignite.internal.processors.odbc.jdbc.JdbcRequestHandler$1
 org.apache.ignite.internal.processors.odbc.jdbc.JdbcStatementType
 org.apache.ignite.internal.processors.odbc.odbc.escape.OdbcEscapeType
 org.apache.ignite.internal.processors.platform.PlatformAbstractConfigurationClosure
@@ -1606,6 +1639,7 @@ org.apache.ignite.internal.processors.task.GridTaskWorker$5
 org.apache.ignite.internal.processors.task.GridTaskWorker$State
 org.apache.ignite.internal.sql.SqlLexerTokenType
 org.apache.ignite.internal.sql.SqlParseException
+org.apache.ignite.internal.sql.SqlStrictParseException
 org.apache.ignite.internal.transactions.IgniteTxHeuristicCheckedException
 org.apache.ignite.internal.transactions.IgniteTxOptimisticCheckedException
 org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException
@@ -1887,6 +1921,8 @@ org.apache.ignite.internal.visor.baseline.VisorBaselineTask
 org.apache.ignite.internal.visor.baseline.VisorBaselineTask$VisorBaselineJob
 org.apache.ignite.internal.visor.baseline.VisorBaselineTaskArg
 org.apache.ignite.internal.visor.baseline.VisorBaselineTaskResult
+org.apache.ignite.internal.visor.baseline.VisorBaselineViewTask
+org.apache.ignite.internal.visor.baseline.VisorBaselineViewTask$VisorBaselineViewJob
 org.apache.ignite.internal.visor.binary.VisorBinaryMetadata
 org.apache.ignite.internal.visor.binary.VisorBinaryMetadataCollectorTask
 org.apache.ignite.internal.visor.binary.VisorBinaryMetadataCollectorTask$VisorBinaryCollectMetadataJob
@@ -1929,6 +1965,9 @@ org.apache.ignite.internal.visor.cache.VisorCacheModifyTask
 org.apache.ignite.internal.visor.cache.VisorCacheModifyTask$VisorCacheModifyJob
 org.apache.ignite.internal.visor.cache.VisorCacheModifyTaskArg
 org.apache.ignite.internal.visor.cache.VisorCacheModifyTaskResult
+org.apache.ignite.internal.visor.cache.VisorCacheNamesCollectorTask
+org.apache.ignite.internal.visor.cache.VisorCacheNamesCollectorTask$VisorCacheNamesCollectorJob
+org.apache.ignite.internal.visor.cache.VisorCacheNamesCollectorTaskResult
 org.apache.ignite.internal.visor.cache.VisorCacheNearConfiguration
 org.apache.ignite.internal.visor.cache.VisorCacheNodesTask
 org.apache.ignite.internal.visor.cache.VisorCacheNodesTask$VisorCacheNodesJob
@@ -2023,13 +2062,13 @@ org.apache.ignite.internal.visor.misc.VisorAckTaskArg
 org.apache.ignite.internal.visor.misc.VisorChangeGridActiveStateTask
 org.apache.ignite.internal.visor.misc.VisorChangeGridActiveStateTask$VisorChangeGridActiveStateJob
 org.apache.ignite.internal.visor.misc.VisorChangeGridActiveStateTaskArg
+org.apache.ignite.internal.visor.misc.VisorClusterNode
 org.apache.ignite.internal.visor.misc.VisorLatestVersionTask
 org.apache.ignite.internal.visor.misc.VisorLatestVersionTask$VisorLatestVersionJob
 org.apache.ignite.internal.visor.misc.VisorNopTask
 org.apache.ignite.internal.visor.misc.VisorNopTask$VisorNopJob
 org.apache.ignite.internal.visor.misc.VisorResolveHostNameTask
 org.apache.ignite.internal.visor.misc.VisorResolveHostNameTask$VisorResolveHostNameJob
-org.apache.ignite.internal.visor.misc.VisorClusterNode
 org.apache.ignite.internal.visor.misc.VisorWalTask
 org.apache.ignite.internal.visor.misc.VisorWalTask$VisorWalJob
 org.apache.ignite.internal.visor.misc.VisorWalTaskArg
@@ -2132,18 +2171,27 @@ org.apache.ignite.internal.visor.service.VisorCancelServiceTaskArg
 org.apache.ignite.internal.visor.service.VisorServiceDescriptor
 org.apache.ignite.internal.visor.service.VisorServiceTask
 org.apache.ignite.internal.visor.service.VisorServiceTask$VisorServiceJob
-org.apache.ignite.internal.visor.util.VisorClusterGroupEmptyException
-org.apache.ignite.internal.visor.util.VisorEventMapper
-org.apache.ignite.internal.visor.util.VisorExceptionWrapper
-org.apache.ignite.internal.visor.util.VisorTaskUtils$4
 org.apache.ignite.internal.visor.tx.VisorTxInfo
 org.apache.ignite.internal.visor.tx.VisorTxOperation
 org.apache.ignite.internal.visor.tx.VisorTxProjection
 org.apache.ignite.internal.visor.tx.VisorTxSortOrder
 org.apache.ignite.internal.visor.tx.VisorTxTask
+org.apache.ignite.internal.visor.tx.VisorTxTask$1
+org.apache.ignite.internal.visor.tx.VisorTxTask$2
+org.apache.ignite.internal.visor.tx.VisorTxTask$3
+org.apache.ignite.internal.visor.tx.VisorTxTask$4
+org.apache.ignite.internal.visor.tx.VisorTxTask$5
+org.apache.ignite.internal.visor.tx.VisorTxTask$NearKillClosure
+org.apache.ignite.internal.visor.tx.VisorTxTask$RemoteKillClosure
+org.apache.ignite.internal.visor.tx.VisorTxTask$TxKillClosure
+org.apache.ignite.internal.visor.tx.VisorTxTask$VisorTxJob
 org.apache.ignite.internal.visor.tx.VisorTxTaskArg
 org.apache.ignite.internal.visor.tx.VisorTxTaskResult
-org.apache.ignite.internal.visor.verify.VisorViewCacheCmd
+org.apache.ignite.internal.visor.util.VisorClusterGroupEmptyException
+org.apache.ignite.internal.visor.util.VisorEventMapper
+org.apache.ignite.internal.visor.util.VisorExceptionWrapper
+org.apache.ignite.internal.visor.util.VisorTaskUtils$4
+org.apache.ignite.internal.visor.verify.IndexValidationIssue
 org.apache.ignite.internal.visor.verify.ValidateIndexesPartitionResult
 org.apache.ignite.internal.visor.verify.VisorContentionJobResult
 org.apache.ignite.internal.visor.verify.VisorContentionTask
@@ -2156,15 +2204,22 @@ org.apache.ignite.internal.visor.verify.VisorIdleAnalyzeTask$VisorIdleVerifyJob$
 org.apache.ignite.internal.visor.verify.VisorIdleAnalyzeTask$VisorIdleVerifyJob$2
 org.apache.ignite.internal.visor.verify.VisorIdleAnalyzeTaskArg
 org.apache.ignite.internal.visor.verify.VisorIdleAnalyzeTaskResult
+org.apache.ignite.internal.visor.verify.VisorIdleVerifyDumpTask
+org.apache.ignite.internal.visor.verify.VisorIdleVerifyDumpTaskArg
+org.apache.ignite.internal.visor.verify.VisorIdleVerifyJob
+org.apache.ignite.internal.visor.verify.VisorIdleVerifyJob$1
 org.apache.ignite.internal.visor.verify.VisorIdleVerifyTask
 org.apache.ignite.internal.visor.verify.VisorIdleVerifyTask$VisorIdleVerifyJob
 org.apache.ignite.internal.visor.verify.VisorIdleVerifyTask$VisorIdleVerifyJob$1
 org.apache.ignite.internal.visor.verify.VisorIdleVerifyTaskArg
-org.apache.ignite.internal.visor.verify.VisorIdleVerifyDumpTaskArg
 org.apache.ignite.internal.visor.verify.VisorIdleVerifyTaskResult
+org.apache.ignite.internal.visor.verify.VisorIdleVerifyTaskV2
+org.apache.ignite.internal.visor.verify.VisorIdleVerifyTaskV2$VisorIdleVerifyJobV2
+org.apache.ignite.internal.visor.verify.VisorIdleVerifyTaskV2$VisorIdleVerifyJobV2$1
 org.apache.ignite.internal.visor.verify.VisorValidateIndexesJobResult
 org.apache.ignite.internal.visor.verify.VisorValidateIndexesTaskArg
 org.apache.ignite.internal.visor.verify.VisorValidateIndexesTaskResult
+org.apache.ignite.internal.visor.verify.VisorViewCacheCmd
 org.apache.ignite.internal.visor.verify.VisorViewCacheTask
 org.apache.ignite.internal.visor.verify.VisorViewCacheTask$VisorViewCacheJob
 org.apache.ignite.internal.visor.verify.VisorViewCacheTaskArg
@@ -2187,8 +2242,10 @@ org.apache.ignite.lang.IgniteReducer
 org.apache.ignite.lang.IgniteRunnable
 org.apache.ignite.lang.IgniteUuid
 org.apache.ignite.lifecycle.LifecycleEventType
+org.apache.ignite.marshaller.MarshallerUtils$1
 org.apache.ignite.marshaller.jdk.JdkMarshallerDummySerializable
 org.apache.ignite.messaging.MessagingListenActor
+org.apache.ignite.mxbean.TransactionMetricsMxBean
 org.apache.ignite.platform.dotnet.PlatformDotNetAffinityFunction
 org.apache.ignite.platform.dotnet.PlatformDotNetCacheStoreFactory
 org.apache.ignite.platform.dotnet.PlatformDotNetCacheStoreFactoryNative
@@ -2224,7 +2281,6 @@ org.apache.ignite.spi.collision.jobstealing.JobStealingRequest
 org.apache.ignite.spi.collision.priorityqueue.PriorityQueueCollisionSpi$PriorityGridCollisionJobContextComparator
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$1
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$10
-org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$11
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$2$1
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$2$2
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$2$ConnectClosure
@@ -2233,6 +2289,7 @@ org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$2$ConnectClosureNew
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$2$ConnectClosureNew$1
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$3
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$4
+org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$9
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$HandshakeClosure
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$HandshakeException
 org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$HandshakeTimeoutException
@@ -2245,6 +2302,7 @@ org.apache.ignite.spi.discovery.DiscoverySpiCustomMessage
 org.apache.ignite.spi.discovery.tcp.ClientImpl$State
 org.apache.ignite.spi.discovery.tcp.ServerImpl$IpFinderCleaner$1
 org.apache.ignite.spi.discovery.tcp.ServerImpl$IpFinderCleaner$2
+org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageSendState
 org.apache.ignite.spi.discovery.tcp.internal.DiscoveryDataPacket
 org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode
 org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode$1


Mime
View raw message