IGNITE-141 - Optimization for object arrays
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/471ae3d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/471ae3d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/471ae3d6 Branch: refs/heads/ignite-51 Commit: 471ae3d60858b194981c080d2ce8419dc57f18e2 Parents: 8b26ec6 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Sat Mar 7 00:02:36 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Sat Mar 7 00:02:36 2015 -0800 ---------------------------------------------------------------------- .../ignite/internal/ClassesGenerator.java | 8 +- .../internal/MarshallerContextAdapter.java | 14 +- .../ignite/internal/MarshallerContextImpl.java | 6 +- .../GridClientOptimizedMarshaller.java | 2 +- .../ignite/marshaller/MarshallerContext.java | 3 +- .../optimized/OptimizedClassDescriptor.java | 52 ++++--- .../optimized/OptimizedMarshallerUtils.java | 48 +++++- .../optimized/OptimizedObjectInputStream.java | 20 ++- .../optimized/OptimizedObjectOutputStream.java | 3 +- .../META-INF/classnames-jdk.properties | 1 + .../resources/META-INF/classnames.properties | 150 +++++++++++++++++++ .../cache/GridCacheEntryMemorySizeSelfTest.java | 4 +- .../marshaller/MarshallerContextTestImpl.java | 4 +- 13 files changed, 262 insertions(+), 53 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/internal/ClassesGenerator.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/ClassesGenerator.java b/modules/core/src/main/java/org/apache/ignite/internal/ClassesGenerator.java index 6a03f0a..83c9d04 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/ClassesGenerator.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/ClassesGenerator.java @@ -202,11 +202,9 @@ public class ClassesGenerator { if (included) { Class<?> cls = Class.forName(clsName, false, ldr); - boolean isSerializable = !cls.isInterface() && !Modifier.isAbstract(cls.getModifiers()) && - Serializable.class.isAssignableFrom(cls); - - if (isSerializable) { - if (!cls.isEnum() && !cls.getSimpleName().isEmpty() && cls.getName().startsWith("org.apache.ignite")) { + if (Serializable.class.isAssignableFrom(cls)) { + if (!cls.isInterface() && !Modifier.isAbstract(cls.getModifiers()) && !cls.isEnum() && + !cls.getSimpleName().isEmpty() && cls.getName().startsWith("org.apache.ignite")) { try { Field field = cls.getDeclaredField("serialVersionUID"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java index 5b184e8..b6079df 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java @@ -80,12 +80,17 @@ public abstract class MarshallerContextAdapter implements MarshallerContext { } /** {@inheritDoc} */ - @Override public void registerClass(int id, Class cls) { + @Override public boolean registerClass(int id, Class cls) { + boolean registered = true; + if (!map.containsKey(id)) { - registerClassName(id, cls.getName()); + registered = registerClassName(id, cls.getName()); - map.putIfAbsent(id, cls.getName()); + if (registered) + map.putIfAbsent(id, cls.getName()); } + + return registered; } /** {@inheritDoc} */ @@ -111,8 +116,9 @@ public abstract class MarshallerContextAdapter implements MarshallerContext { * * @param id Type ID. * @param clsName Class name. + * @return Whether class name was registered. */ - protected abstract void registerClassName(int id, String clsName); + protected abstract boolean registerClassName(int id, String clsName); /** * Gets class name by type ID. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java index ec61707..6a2d92c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java @@ -45,10 +45,10 @@ public class MarshallerContextImpl extends MarshallerContextAdapter { } /** {@inheritDoc} */ - @Override protected void registerClassName(int id, String clsName) { + @Override protected boolean registerClassName(int id, String clsName) { try { if (cache == null) - U.awaitQuiet(latch); + return false; String old = cache.putIfAbsent(id, clsName); @@ -60,6 +60,8 @@ public class MarshallerContextImpl extends MarshallerContextAdapter { catch (IgniteCheckedException e) { throw U.convertException(e); } + + return true; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java b/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java index c5e415f..ccec503 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/marshaller/optimized/GridClientOptimizedMarshaller.java @@ -101,7 +101,7 @@ public class GridClientOptimizedMarshaller implements GridClientMarshaller { */ private static class ClientMarshallerContext extends MarshallerContextAdapter { /** {@inheritDoc} */ - @Override protected void registerClassName(int id, String clsName) { + @Override protected boolean registerClassName(int id, String clsName) { throw new UnsupportedOperationException(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/marshaller/MarshallerContext.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/MarshallerContext.java b/modules/core/src/main/java/org/apache/ignite/marshaller/MarshallerContext.java index 0d27a58..9b81626 100644 --- a/modules/core/src/main/java/org/apache/ignite/marshaller/MarshallerContext.java +++ b/modules/core/src/main/java/org/apache/ignite/marshaller/MarshallerContext.java @@ -26,8 +26,9 @@ public interface MarshallerContext { * * @param id Type ID. * @param cls Class. + * @return Whether class was registered. */ - public void registerClass(int id, Class cls); + public boolean registerClass(int id, Class cls); /** * Gets class for provided type ID. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedClassDescriptor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedClassDescriptor.java b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedClassDescriptor.java index 5bc2bab..2e9c659 100644 --- a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedClassDescriptor.java +++ b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedClassDescriptor.java @@ -113,27 +113,15 @@ class OptimizedClassDescriptor { * @throws IOException In case of error. */ @SuppressWarnings("ForLoopReplaceableByForEach") - OptimizedClassDescriptor(Class<?> cls, MarshallerContext ctx, OptimizedMarshallerIdMapper mapper) + OptimizedClassDescriptor(Class<?> cls, int typeId, MarshallerContext ctx, OptimizedMarshallerIdMapper mapper) throws IOException { this.cls = cls; + this.typeId = typeId; this.ctx = ctx; this.mapper = mapper; name = cls.getName(); - int typeId; - - if (mapper != null) { - typeId = mapper.typeId(name); - - if (typeId == 0) - typeId = name.hashCode(); - } - else - typeId = name.hashCode(); - - this.typeId = typeId; - excluded = MarshallerExclusions.isExcluded(cls); if (!excluded) { @@ -493,13 +481,6 @@ class OptimizedClassDescriptor { } /** - * @return Type ID. - */ - int typeId() { - return typeId; - } - - /** * @return Primitive flag. */ boolean isPrimitive() { @@ -633,7 +614,10 @@ class OptimizedClassDescriptor { break; case OBJ_ARR: - out.writeUTF(obj.getClass().getComponentType().getName()); + OptimizedClassDescriptor compDesc = classDescriptor(obj.getClass().getComponentType(), ctx, mapper); + + compDesc.writeTypeData(out); + out.writeArray((Object[])obj); break; @@ -689,20 +673,22 @@ class OptimizedClassDescriptor { break; case CLS: - OptimizedClassDescriptor desc = classDescriptor((Class<?>)obj, ctx, mapper); + OptimizedClassDescriptor clsDesc = classDescriptor((Class<?>)obj, ctx, mapper); - out.writeInt(desc.typeId()); + clsDesc.writeTypeData(out); break; case ENUM: - out.writeInt(typeId); + writeTypeData(out); + out.writeInt(((Enum)obj).ordinal()); break; case EXTERNALIZABLE: - out.writeInt(typeId); + writeTypeData(out); + out.writeShort(checksum); out.writeExternalizable(obj); @@ -714,7 +700,8 @@ class OptimizedClassDescriptor { "set OptimizedMarshaller.setRequireSerializable() to false " + "(note that performance may degrade if object is not Serializable): " + name); - out.writeInt(typeId); + writeTypeData(out); + out.writeShort(checksum); out.writeSerializable(obj, writeObjMtds, fields); @@ -726,6 +713,17 @@ class OptimizedClassDescriptor { } /** + * @param out Output stream. + * @throws IOException In case of error. + */ + void writeTypeData(OptimizedObjectOutputStream out) throws IOException { + out.writeInt(typeId); + + if (typeId == 0) + out.writeUTF(name); + } + + /** * Reads object from stream. * * @param in Input stream. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshallerUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshallerUtils.java b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshallerUtils.java index ccd1e4e..a979e8a 100644 --- a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshallerUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedMarshallerUtils.java @@ -183,20 +183,44 @@ class OptimizedMarshallerUtils { OptimizedClassDescriptor desc = DESC_BY_CLS.get(cls); if (desc == null) { - desc = new OptimizedClassDescriptor(cls, ctx, mapper); + int typeId = resolveTypeId(cls.getName(), mapper); - ctx.registerClass(desc.typeId(), cls); + boolean registered = ctx.registerClass(typeId, cls); - OptimizedClassDescriptor old = DESC_BY_CLS.putIfAbsent(cls, desc); + desc = new OptimizedClassDescriptor(cls, registered ? typeId : 0, ctx, mapper); - if (old != null) - desc = old; + if (registered) { + OptimizedClassDescriptor old = DESC_BY_CLS.putIfAbsent(cls, desc); + + if (old != null) + desc = old; + } } return desc; } /** + * @param clsName Class name. + * @param mapper Mapper. + * @return Type ID. + */ + private static int resolveTypeId(String clsName, OptimizedMarshallerIdMapper mapper) { + int typeId; + + if (mapper != null) { + typeId = mapper.typeId(clsName); + + if (typeId == 0) + typeId = clsName.hashCode(); + } + else + typeId = clsName.hashCode(); + + return typeId; + } + + /** * Gets descriptor for provided ID. * * @param id ID. @@ -209,7 +233,19 @@ class OptimizedMarshallerUtils { */ static OptimizedClassDescriptor classDescriptor(int id, ClassLoader ldr, MarshallerContext ctx, OptimizedMarshallerIdMapper mapper) throws IOException, ClassNotFoundException { - return classDescriptor(ctx.getClass(id, ldr), ctx, mapper); + Class cls = ctx.getClass(id, ldr); + + OptimizedClassDescriptor desc = DESC_BY_CLS.get(cls); + + if (desc == null) { + OptimizedClassDescriptor old = DESC_BY_CLS.putIfAbsent(cls, desc = + new OptimizedClassDescriptor(cls, resolveTypeId(cls.getName(), mapper), ctx, mapper)); + + if (old != null) + desc = old; + } + + return desc; } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectInputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectInputStream.java b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectInputStream.java index c0def75..987b676 100644 --- a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectInputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectInputStream.java @@ -203,7 +203,7 @@ class OptimizedObjectInputStream extends ObjectInputStream { return readBooleanArray(); case OBJ_ARR: - return readArray(Class.forName(readUTF(), false, clsLdr)); + return readArray(readClass()); case STR: return readString(); @@ -236,14 +236,16 @@ class OptimizedObjectInputStream extends ObjectInputStream { return readDate(); case CLS: - return classDescriptor(in.readInt(), clsLdr, ctx, mapper).describedClass(); + return readClass(); case ENUM: case EXTERNALIZABLE: case SERIALIZABLE: int typeId = readInt(); - OptimizedClassDescriptor desc = OptimizedMarshallerUtils.classDescriptor(typeId, clsLdr, ctx, mapper); + OptimizedClassDescriptor desc = typeId == 0 ? + classDescriptor(Class.forName(readUTF(), true, clsLdr), ctx, mapper): + classDescriptor(typeId, clsLdr, ctx, mapper); curCls = desc.describedClass(); @@ -265,6 +267,18 @@ class OptimizedObjectInputStream extends ObjectInputStream { } /** + * @return Class. + * @throws ClassNotFoundException If class was not found. + * @throws IOException In case of other error. + */ + private Class<?> readClass() throws ClassNotFoundException, IOException { + int compTypeId = readInt(); + + return compTypeId == 0 ? Class.forName(readUTF(), false, clsLdr) : + classDescriptor(compTypeId, clsLdr, ctx, mapper).describedClass(); + } + + /** * Reads array from this stream. * * @param compType Array component type. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectOutputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectOutputStream.java b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectOutputStream.java index 1faad50..59f1547 100644 --- a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectOutputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectOutputStream.java @@ -188,7 +188,8 @@ class OptimizedObjectOutputStream extends ObjectOutputStream { int handle = -1; - if (!desc.isPrimitive() && !desc.isEnum() && !desc.isClass()) handle = handles.lookup(obj); + if (!desc.isPrimitive() && !desc.isEnum() && !desc.isClass()) + handle = handles.lookup(obj); if (obj0 != obj) { obj = obj0; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/main/resources/META-INF/classnames-jdk.properties ---------------------------------------------------------------------- diff --git a/modules/core/src/main/resources/META-INF/classnames-jdk.properties b/modules/core/src/main/resources/META-INF/classnames-jdk.properties index 0cae0f7..81c02e1 100644 --- a/modules/core/src/main/resources/META-INF/classnames-jdk.properties +++ b/modules/core/src/main/resources/META-INF/classnames-jdk.properties @@ -24,6 +24,7 @@ [S [Z [Ljava.lang.Object; +java.lang.Object java.lang.AbstractMethodError java.lang.ArithmeticException java.lang.ArrayIndexOutOfBoundsException http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/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 92b5d4d..8de98eb 100644 --- a/modules/core/src/main/resources/META-INF/classnames.properties +++ b/modules/core/src/main/resources/META-INF/classnames.properties @@ -17,6 +17,7 @@ org.apache.ignite.IgniteAuthenticationException org.apache.ignite.IgniteCheckedException +org.apache.ignite.IgniteDataLoader$Updater org.apache.ignite.IgniteDeploymentException org.apache.ignite.IgniteException org.apache.ignite.IgniteIllegalStateException @@ -32,14 +33,19 @@ org.apache.ignite.cache.CachePartialUpdateException org.apache.ignite.cache.CachePeekMode org.apache.ignite.cache.CachePreloadMode org.apache.ignite.cache.CacheWriteSynchronizationMode +org.apache.ignite.cache.IgniteEntryProcessor +org.apache.ignite.cache.affinity.CacheAffinityFunction org.apache.ignite.cache.affinity.CacheAffinityKey +org.apache.ignite.cache.affinity.CacheAffinityKeyMapper org.apache.ignite.cache.affinity.CacheAffinityNodeAddressHashResolver +org.apache.ignite.cache.affinity.CacheAffinityNodeHashResolver org.apache.ignite.cache.affinity.CacheAffinityNodeIdHashResolver org.apache.ignite.cache.affinity.fair.CachePartitionFairAffinity org.apache.ignite.cache.affinity.fair.CachePartitionFairAffinity$PartitionSetComparator org.apache.ignite.cache.affinity.rendezvous.CacheRendezvousAffinityFunction org.apache.ignite.cache.affinity.rendezvous.CacheRendezvousAffinityFunction$HashComparator org.apache.ignite.cache.query.ContinuousQuery +org.apache.ignite.cache.query.Query org.apache.ignite.cache.query.ScanQuery org.apache.ignite.cache.query.SpiQuery org.apache.ignite.cache.query.SqlFieldsQuery @@ -66,13 +72,23 @@ org.apache.ignite.cache.store.jdbc.dialect.SQLServerDialect$3 org.apache.ignite.cluster.ClusterGroupEmptyException org.apache.ignite.cluster.ClusterTopologyException org.apache.ignite.compute.ComputeExecutionRejectedException +org.apache.ignite.compute.ComputeJob +org.apache.ignite.compute.ComputeJobAdapter +org.apache.ignite.compute.ComputeJobContinuationAdapter org.apache.ignite.compute.ComputeJobFailoverException org.apache.ignite.compute.ComputeJobResultPolicy +org.apache.ignite.compute.ComputeTask +org.apache.ignite.compute.ComputeTaskAdapter org.apache.ignite.compute.ComputeTaskCancelledException org.apache.ignite.compute.ComputeTaskSessionScope +org.apache.ignite.compute.ComputeTaskSplitAdapter org.apache.ignite.compute.ComputeTaskTimeoutException org.apache.ignite.compute.ComputeUserUndeclaredException +org.apache.ignite.compute.gridify.GridifyArgument +org.apache.ignite.compute.gridify.GridifyNodeFilter org.apache.ignite.compute.gridify.GridifyRuntimeException +org.apache.ignite.compute.gridify.GridifyTaskAdapter +org.apache.ignite.compute.gridify.GridifyTaskSplitAdapter org.apache.ignite.compute.gridify.aop.GridifyArgumentAdapter org.apache.ignite.compute.gridify.aop.GridifyDefaultRangeTask org.apache.ignite.compute.gridify.aop.GridifyDefaultTask @@ -87,6 +103,7 @@ org.apache.ignite.events.CacheQueryReadEvent org.apache.ignite.events.CheckpointEvent org.apache.ignite.events.DeploymentEvent org.apache.ignite.events.DiscoveryEvent +org.apache.ignite.events.Event org.apache.ignite.events.EventAdapter org.apache.ignite.events.IgfsEvent org.apache.ignite.events.JobEvent @@ -105,6 +122,9 @@ org.apache.ignite.igfs.IgfsParentNotDirectoryException org.apache.ignite.igfs.IgfsPath org.apache.ignite.igfs.IgfsPathAlreadyExistsException org.apache.ignite.igfs.IgfsPathSummary +org.apache.ignite.igfs.mapreduce.IgfsRecordResolver +org.apache.ignite.igfs.mapreduce.IgfsTask +org.apache.ignite.igfs.mapreduce.IgfsTaskNoReduceAdapter org.apache.ignite.igfs.mapreduce.records.IgfsByteDelimiterRecordResolver org.apache.ignite.igfs.mapreduce.records.IgfsFixedLengthRecordResolver org.apache.ignite.igfs.mapreduce.records.IgfsNewLineRecordResolver @@ -160,10 +180,12 @@ org.apache.ignite.internal.client.GridClientAuthenticationException org.apache.ignite.internal.client.GridClientCacheFlag org.apache.ignite.internal.client.GridClientCacheMode org.apache.ignite.internal.client.GridClientClosedException +org.apache.ignite.internal.client.GridClientDataMetrics org.apache.ignite.internal.client.GridClientDisconnectedException org.apache.ignite.internal.client.GridClientException org.apache.ignite.internal.client.GridClientFutureTimeoutException org.apache.ignite.internal.client.GridClientHandshakeException +org.apache.ignite.internal.client.GridClientNodeMetrics org.apache.ignite.internal.client.GridClientProtocol org.apache.ignite.internal.client.GridServerUnreachableException org.apache.ignite.internal.client.balancer.GridClientBalancerAdapter$1 @@ -218,8 +240,10 @@ org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$4$1 org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$6 org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$DiscoCache$1 org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$DiscoTopologyFuture +org.apache.ignite.internal.managers.discovery.GridLocalMetrics org.apache.ignite.internal.managers.eventstorage.GridEventStorageMessage org.apache.ignite.internal.managers.indexing.GridIndexingManager$1 +org.apache.ignite.internal.managers.loadbalancer.GridLoadBalancerAdapter org.apache.ignite.internal.managers.loadbalancer.GridLoadBalancerManager$1 org.apache.ignite.internal.processors.affinity.GridAffinityAssignment org.apache.ignite.internal.processors.affinity.GridAffinityAssignmentCache$AffinityReadyFuture @@ -235,6 +259,7 @@ org.apache.ignite.internal.processors.cache.CachePartialUpdateCheckedException org.apache.ignite.internal.processors.cache.CacheStoreBalancingWrapper$LoadFuture org.apache.ignite.internal.processors.cache.CacheStorePartialUpdateException org.apache.ignite.internal.processors.cache.CacheWeakQueryIteratorsHolder$WeakQueryFutureIterator +org.apache.ignite.internal.processors.cache.GridCacheAdapter org.apache.ignite.internal.processors.cache.GridCacheAdapter$10 org.apache.ignite.internal.processors.cache.GridCacheAdapter$12 org.apache.ignite.internal.processors.cache.GridCacheAdapter$13 @@ -274,6 +299,7 @@ org.apache.ignite.internal.processors.cache.GridCacheAdapter$UpdateGetTimeStatCl org.apache.ignite.internal.processors.cache.GridCacheAdapter$UpdatePutAndGetTimeStatClosure org.apache.ignite.internal.processors.cache.GridCacheAdapter$UpdatePutTimeStatClosure org.apache.ignite.internal.processors.cache.GridCacheAdapter$UpdateRemoveTimeStatClosure +org.apache.ignite.internal.processors.cache.GridCacheAdapter$UpdateTimeStatClosure org.apache.ignite.internal.processors.cache.GridCacheAtomicVersionComparator org.apache.ignite.internal.processors.cache.GridCacheAttributes org.apache.ignite.internal.processors.cache.GridCacheConcurrentMap$1 @@ -321,6 +347,7 @@ org.apache.ignite.internal.processors.cache.GridCacheIterator org.apache.ignite.internal.processors.cache.GridCacheKeySet org.apache.ignite.internal.processors.cache.GridCacheLockTimeoutException org.apache.ignite.internal.processors.cache.GridCacheLogger +org.apache.ignite.internal.processors.cache.GridCacheMessage org.apache.ignite.internal.processors.cache.GridCacheMultiTxFuture org.apache.ignite.internal.processors.cache.GridCacheMultiTxFuture$1 org.apache.ignite.internal.processors.cache.GridCacheMvccCandidate @@ -337,6 +364,7 @@ org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$2 org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$3 org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$4 org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeFutureSet +org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$MessageHandler org.apache.ignite.internal.processors.cache.GridCachePeekMode org.apache.ignite.internal.processors.cache.GridCacheProcessor$1 org.apache.ignite.internal.processors.cache.GridCacheProcessor$2 @@ -363,6 +391,7 @@ org.apache.ignite.internal.processors.cache.GridCacheSwapManager$6 org.apache.ignite.internal.processors.cache.GridCacheSwapManager$7 org.apache.ignite.internal.processors.cache.GridCacheSwapManager$8 org.apache.ignite.internal.processors.cache.GridCacheSwapManager$IteratorWrapper +org.apache.ignite.internal.processors.cache.GridCacheUtilityKey org.apache.ignite.internal.processors.cache.GridCacheUtils$10 org.apache.ignite.internal.processors.cache.GridCacheUtils$11 org.apache.ignite.internal.processors.cache.GridCacheUtils$12 @@ -400,6 +429,7 @@ org.apache.ignite.internal.processors.cache.IgniteCacheProxy$4 org.apache.ignite.internal.processors.cache.IgniteCacheProxy$5 org.apache.ignite.internal.processors.cache.IgniteCacheProxy$6 org.apache.ignite.internal.processors.cache.IgniteCacheProxy$7 +org.apache.ignite.internal.processors.cache.IgniteCacheProxy$ClIter org.apache.ignite.internal.processors.cache.affinity.GridCacheAffinityProxy org.apache.ignite.internal.processors.cache.datastructures.CacheDataStructuresManager$BlockSetCallable org.apache.ignite.internal.processors.cache.datastructures.CacheDataStructuresManager$QueueHeaderPredicate @@ -410,6 +440,8 @@ org.apache.ignite.internal.processors.cache.distributed.GridCacheOptimisticCheck org.apache.ignite.internal.processors.cache.distributed.GridCacheOptimisticCheckPreparedTxRequest org.apache.ignite.internal.processors.cache.distributed.GridCacheOptimisticCheckPreparedTxResponse org.apache.ignite.internal.processors.cache.distributed.GridCacheTtlUpdateRequest +org.apache.ignite.internal.processors.cache.distributed.GridDistributedBaseMessage +org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheAdapter org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheAdapter$1 org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheAdapter$GlobalRemoveAllCallable org.apache.ignite.internal.processors.cache.distributed.GridDistributedLockCancelledException @@ -427,6 +459,7 @@ org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtAffinityAssig org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtAffinityAssignmentResponse org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtAssignmentFetchFuture org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCache +org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter$2 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter$3 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter$5 @@ -450,6 +483,7 @@ org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLockFuture$Mi 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 +org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTransactionalCacheAdapter org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTransactionalCacheAdapter$1 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTransactionalCacheAdapter$2 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTransactionalCacheAdapter$3 @@ -470,6 +504,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.GridDhtTxLocalAdapter org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocalAdapter$1 org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareFuture org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareFuture$1 @@ -546,6 +581,7 @@ org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPar org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyMessage org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyPool$1 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionSupplyPool$DemandMessage +org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsAbstractMessage org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$1 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture$2 @@ -562,9 +598,11 @@ org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPre org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader$7 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader$8 org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader$9 +org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader$MessageHandler org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloaderAssignments org.apache.ignite.internal.processors.cache.distributed.near.GridNearAtomicCache org.apache.ignite.internal.processors.cache.distributed.near.GridNearAtomicCache$1 +org.apache.ignite.internal.processors.cache.distributed.near.GridNearCacheAdapter org.apache.ignite.internal.processors.cache.distributed.near.GridNearCacheAdapter$2 org.apache.ignite.internal.processors.cache.distributed.near.GridNearCacheAdapter$2$1 org.apache.ignite.internal.processors.cache.distributed.near.GridNearCacheAdapter$2$2 @@ -620,6 +658,8 @@ org.apache.ignite.internal.processors.cache.dr.GridCacheDrExpirationInfo org.apache.ignite.internal.processors.cache.dr.GridCacheDrInfo org.apache.ignite.internal.processors.cache.local.GridLocalCache org.apache.ignite.internal.processors.cache.local.GridLocalLockFuture +org.apache.ignite.internal.processors.cache.local.GridLocalTx +org.apache.ignite.internal.processors.cache.local.GridLocalTxFuture org.apache.ignite.internal.processors.cache.local.atomic.GridLocalAtomicCache org.apache.ignite.internal.processors.cache.local.atomic.GridLocalAtomicCache$10 org.apache.ignite.internal.processors.cache.local.atomic.GridLocalAtomicCache$11 @@ -644,6 +684,7 @@ org.apache.ignite.internal.processors.cache.query.GridCacheQueriesImpl org.apache.ignite.internal.processors.cache.query.GridCacheQueriesProxy org.apache.ignite.internal.processors.cache.query.GridCacheQueryAdapter$1 org.apache.ignite.internal.processors.cache.query.GridCacheQueryErrorFuture +org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter$1 org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter$2 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$1$1 @@ -663,6 +704,7 @@ org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$8 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 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$CachedResult$QueueIterator org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$CompoundIterator org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$FieldsResult @@ -678,6 +720,8 @@ org.apache.ignite.internal.processors.cache.query.GridCacheQueryRequest org.apache.ignite.internal.processors.cache.query.GridCacheQueryResponse org.apache.ignite.internal.processors.cache.query.GridCacheQueryResponseEntry org.apache.ignite.internal.processors.cache.query.GridCacheQueryType +org.apache.ignite.internal.processors.cache.query.GridCacheSqlIndexMetadata +org.apache.ignite.internal.processors.cache.query.GridCacheSqlMetadata org.apache.ignite.internal.processors.cache.query.GridCacheSqlQuery org.apache.ignite.internal.processors.cache.query.GridCacheTwoStepQuery org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEntry @@ -694,6 +738,7 @@ org.apache.ignite.internal.processors.cache.query.jdbc.GridCacheQueryJdbcTask$Jd org.apache.ignite.internal.processors.cache.query.jdbc.GridCacheQueryJdbcValidationTask org.apache.ignite.internal.processors.cache.query.jdbc.GridCacheQueryJdbcValidationTask$1 org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx$FinalizationStatus +org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter$1 org.apache.ignite.internal.processors.cache.transactions.IgniteTxEntry org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler$1 @@ -711,6 +756,7 @@ org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler$7 org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler$8 org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler$9 org.apache.ignite.internal.processors.cache.transactions.IgniteTxKey +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$10 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$11 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$12 @@ -726,10 +772,17 @@ org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$6 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$7 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$8 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$9 +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$FinishClosure +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PLC1 +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PLC2 +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PMC +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PostLockClosure1 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PostLockClosure1$1 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PostLockClosure1$2 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PostLockClosure1$3 org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PostLockClosure1$4 +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PostLockClosure2 +org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter$PostMissClosure org.apache.ignite.internal.processors.cache.transactions.IgniteTxManager$2 org.apache.ignite.internal.processors.cache.transactions.IgniteTxManager$AtomicInt org.apache.ignite.internal.processors.cache.transactions.IgniteTxManager$CommitListener @@ -764,6 +817,9 @@ org.apache.ignite.internal.processors.closure.GridClosureProcessor$T6 org.apache.ignite.internal.processors.closure.GridClosureProcessor$T7 org.apache.ignite.internal.processors.closure.GridClosureProcessor$T8 org.apache.ignite.internal.processors.closure.GridClosureProcessor$T9 +org.apache.ignite.internal.processors.closure.GridClosureProcessor$TaskNoReduceAdapter +org.apache.ignite.internal.processors.closure.GridPeerDeployAwareTaskAdapter +org.apache.ignite.internal.processors.continuous.GridContinuousHandler org.apache.ignite.internal.processors.continuous.GridContinuousMessage org.apache.ignite.internal.processors.continuous.GridContinuousMessageType org.apache.ignite.internal.processors.continuous.GridContinuousProcessor$DiscoveryData @@ -844,10 +900,13 @@ org.apache.ignite.internal.processors.datastructures.GridSetQueryPredicate org.apache.ignite.internal.processors.dr.GridDrDataLoadCacheUpdater org.apache.ignite.internal.processors.dr.GridDrType org.apache.ignite.internal.processors.hadoop.HadoopFileBlock +org.apache.ignite.internal.processors.hadoop.HadoopInputSplit org.apache.ignite.internal.processors.hadoop.HadoopJobId +org.apache.ignite.internal.processors.hadoop.HadoopJobInfo org.apache.ignite.internal.processors.hadoop.HadoopJobPhase org.apache.ignite.internal.processors.hadoop.HadoopJobProperty org.apache.ignite.internal.processors.hadoop.HadoopJobStatus +org.apache.ignite.internal.processors.hadoop.HadoopMapReducePlan org.apache.ignite.internal.processors.hadoop.HadoopTaskInfo org.apache.ignite.internal.processors.hadoop.HadoopTaskType org.apache.ignite.internal.processors.igfs.IgfsAckMessage @@ -855,6 +914,7 @@ org.apache.ignite.internal.processors.igfs.IgfsAttributes org.apache.ignite.internal.processors.igfs.IgfsBlockKey org.apache.ignite.internal.processors.igfs.IgfsBlockLocationImpl org.apache.ignite.internal.processors.igfs.IgfsBlocksMessage +org.apache.ignite.internal.processors.igfs.IgfsCommunicationMessage org.apache.ignite.internal.processors.igfs.IgfsDataManager$3 org.apache.ignite.internal.processors.igfs.IgfsDataManager$5$1 org.apache.ignite.internal.processors.igfs.IgfsDataManager$7 @@ -902,12 +962,14 @@ org.apache.ignite.internal.processors.job.GridJobProcessor$6 org.apache.ignite.internal.processors.job.GridJobProcessor$7 org.apache.ignite.internal.processors.job.GridJobWorker$3 org.apache.ignite.internal.processors.jobmetrics.GridJobMetricsProcessor$SnapshotReducer +org.apache.ignite.internal.processors.query.GridQueryFieldMetadata org.apache.ignite.internal.processors.query.GridQueryIndexType org.apache.ignite.internal.processors.resource.GridResourceProcessor$1 org.apache.ignite.internal.processors.rest.GridRestCommand org.apache.ignite.internal.processors.rest.GridRestProcessor$2$1 org.apache.ignite.internal.processors.rest.GridRestProcessor$3 org.apache.ignite.internal.processors.rest.GridRestResponse +org.apache.ignite.internal.processors.rest.client.message.GridClientAbstractMessage org.apache.ignite.internal.processors.rest.client.message.GridClientAuthenticationRequest org.apache.ignite.internal.processors.rest.client.message.GridClientCacheQueryRequest org.apache.ignite.internal.processors.rest.client.message.GridClientCacheQueryRequest$GridQueryOperation @@ -916,6 +978,7 @@ org.apache.ignite.internal.processors.rest.client.message.GridClientCacheRequest org.apache.ignite.internal.processors.rest.client.message.GridClientCacheRequest$GridCacheOperation org.apache.ignite.internal.processors.rest.client.message.GridClientHandshakeRequest org.apache.ignite.internal.processors.rest.client.message.GridClientHandshakeResponse +org.apache.ignite.internal.processors.rest.client.message.GridClientMessage org.apache.ignite.internal.processors.rest.client.message.GridClientNodeBean org.apache.ignite.internal.processors.rest.client.message.GridClientNodeMetricsBean org.apache.ignite.internal.processors.rest.client.message.GridClientPingPacket @@ -929,7 +992,9 @@ org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheClientQueryRe org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$2 org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$AddCommand org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$AppendCommand +org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$CacheCommand org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$CacheOperationCallable +org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$CacheProjectionCommand org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$CasCommand org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$FixedResult org.apache.ignite.internal.processors.rest.handlers.cache.GridCacheCommandHandler$FlaggedCacheOperationCallable @@ -1012,6 +1077,8 @@ org.apache.ignite.internal.util.GridBoundedConcurrentOrderedSet org.apache.ignite.internal.util.GridBoundedLinkedHashMap org.apache.ignite.internal.util.GridBoundedLinkedHashSet org.apache.ignite.internal.util.GridByteArrayList +org.apache.ignite.internal.util.GridCloseableIteratorAdapter +org.apache.ignite.internal.util.GridCloseableIteratorAdapterEx org.apache.ignite.internal.util.GridCollections$LockedCollection org.apache.ignite.internal.util.GridCollections$LockedList org.apache.ignite.internal.util.GridCollections$LockedMap @@ -1036,6 +1103,7 @@ org.apache.ignite.internal.util.GridLeanMap$Map5 org.apache.ignite.internal.util.GridLeanSet org.apache.ignite.internal.util.GridListSet org.apache.ignite.internal.util.GridListSet$1 +org.apache.ignite.internal.util.GridLogThrottle$LogLevel org.apache.ignite.internal.util.GridLogThrottle$LogLevel$1 org.apache.ignite.internal.util.GridLogThrottle$LogLevel$2 org.apache.ignite.internal.util.GridLogThrottle$LogLevel$3 @@ -1043,6 +1111,13 @@ org.apache.ignite.internal.util.GridLongList org.apache.ignite.internal.util.GridMutex org.apache.ignite.internal.util.GridRandom org.apache.ignite.internal.util.GridReflectionCache +org.apache.ignite.internal.util.GridSerializableCollection +org.apache.ignite.internal.util.GridSerializableFuture +org.apache.ignite.internal.util.GridSerializableIterable +org.apache.ignite.internal.util.GridSerializableIterator +org.apache.ignite.internal.util.GridSerializableList +org.apache.ignite.internal.util.GridSerializableMap +org.apache.ignite.internal.util.GridSerializableSet org.apache.ignite.internal.util.GridSetWrapper org.apache.ignite.internal.util.GridSnapshotLock$Sync org.apache.ignite.internal.util.GridSpiCloseableIteratorWrapper @@ -1078,6 +1153,10 @@ org.apache.ignite.internal.util.future.GridEmbeddedFuture$2 org.apache.ignite.internal.util.future.GridEmbeddedFuture$2$1 org.apache.ignite.internal.util.future.GridEmbeddedFuture$3 org.apache.ignite.internal.util.future.GridEmbeddedFuture$3$1 +org.apache.ignite.internal.util.future.GridEmbeddedFuture$AL1 +org.apache.ignite.internal.util.future.GridEmbeddedFuture$AL2 +org.apache.ignite.internal.util.future.GridEmbeddedFuture$AsyncListener1 +org.apache.ignite.internal.util.future.GridEmbeddedFuture$AsyncListener2 org.apache.ignite.internal.util.future.GridFinishedFuture org.apache.ignite.internal.util.future.GridFinishedFuture$2 org.apache.ignite.internal.util.future.GridFinishedFutureEx @@ -1101,6 +1180,9 @@ org.apache.ignite.internal.util.ipc.shmem.IpcOutOfSystemResourcesException org.apache.ignite.internal.util.ipc.shmem.IpcSharedMemoryInitRequest org.apache.ignite.internal.util.ipc.shmem.IpcSharedMemoryInitResponse org.apache.ignite.internal.util.ipc.shmem.IpcSharedMemoryOperationTimedoutException +org.apache.ignite.internal.util.lang.GridAbsClosure +org.apache.ignite.internal.util.lang.GridAbsClosureX +org.apache.ignite.internal.util.lang.GridCloseableIterator org.apache.ignite.internal.util.lang.GridClosureException org.apache.ignite.internal.util.lang.GridComputeJobWrapper org.apache.ignite.internal.util.lang.GridFunc$1 @@ -1266,10 +1348,14 @@ org.apache.ignite.internal.util.lang.GridFunc$96 org.apache.ignite.internal.util.lang.GridFunc$97 org.apache.ignite.internal.util.lang.GridFunc$98 org.apache.ignite.internal.util.lang.GridFunc$99 +org.apache.ignite.internal.util.lang.GridIterable org.apache.ignite.internal.util.lang.GridIterableAdapter org.apache.ignite.internal.util.lang.GridIterableAdapter$IteratorWrapper +org.apache.ignite.internal.util.lang.GridIterator +org.apache.ignite.internal.util.lang.GridIteratorAdapter org.apache.ignite.internal.util.lang.GridMapEntry org.apache.ignite.internal.util.lang.GridNodePredicate +org.apache.ignite.internal.util.lang.GridPeerDeployAware org.apache.ignite.internal.util.lang.GridPeerDeployAwareAdapter org.apache.ignite.internal.util.lang.GridTriple org.apache.ignite.internal.util.lang.GridTuple @@ -1278,7 +1364,19 @@ org.apache.ignite.internal.util.lang.GridTuple4 org.apache.ignite.internal.util.lang.GridTuple5 org.apache.ignite.internal.util.lang.GridTuple6 org.apache.ignite.internal.util.lang.GridTupleV +org.apache.ignite.internal.util.lang.IgniteClosure2X +org.apache.ignite.internal.util.lang.IgniteClosureX +org.apache.ignite.internal.util.lang.IgniteInClosure2X +org.apache.ignite.internal.util.lang.IgniteInClosureX +org.apache.ignite.internal.util.lang.IgniteOutClosureX org.apache.ignite.internal.util.lang.IgnitePair +org.apache.ignite.internal.util.lang.IgnitePredicate2X +org.apache.ignite.internal.util.lang.IgnitePredicateX +org.apache.ignite.internal.util.lang.IgniteReducer2 +org.apache.ignite.internal.util.lang.IgniteReducer2X +org.apache.ignite.internal.util.lang.IgniteReducer3 +org.apache.ignite.internal.util.lang.IgniteReducer3X +org.apache.ignite.internal.util.lang.IgniteReducerX org.apache.ignite.internal.util.nio.GridNioEmbeddedFuture org.apache.ignite.internal.util.nio.GridNioEmbeddedFuture$1 org.apache.ignite.internal.util.nio.GridNioException @@ -1299,9 +1397,36 @@ org.apache.ignite.internal.util.offheap.unsafe.GridUnsafePartitionedMap$3 org.apache.ignite.internal.util.snaptree.CopyOnWriteManager$COWEpoch org.apache.ignite.internal.util.snaptree.CopyOnWriteManager$Latch org.apache.ignite.internal.util.snaptree.Epoch$Root +org.apache.ignite.internal.util.snaptree.EpochNode org.apache.ignite.internal.util.snaptree.EpochNode$Child org.apache.ignite.internal.util.snaptree.SnapTreeMap org.apache.ignite.internal.util.snaptree.SnapTreeMap$SubMap +org.apache.ignite.internal.util.typedef.C1 +org.apache.ignite.internal.util.typedef.C2 +org.apache.ignite.internal.util.typedef.CA +org.apache.ignite.internal.util.typedef.CAX +org.apache.ignite.internal.util.typedef.CI1 +org.apache.ignite.internal.util.typedef.CI2 +org.apache.ignite.internal.util.typedef.CIX1 +org.apache.ignite.internal.util.typedef.CIX2 +org.apache.ignite.internal.util.typedef.CO +org.apache.ignite.internal.util.typedef.COX +org.apache.ignite.internal.util.typedef.CX1 +org.apache.ignite.internal.util.typedef.CX2 +org.apache.ignite.internal.util.typedef.P1 +org.apache.ignite.internal.util.typedef.P2 +org.apache.ignite.internal.util.typedef.PCE +org.apache.ignite.internal.util.typedef.PE +org.apache.ignite.internal.util.typedef.PKV +org.apache.ignite.internal.util.typedef.PN +org.apache.ignite.internal.util.typedef.PX1 +org.apache.ignite.internal.util.typedef.PX2 +org.apache.ignite.internal.util.typedef.R1 +org.apache.ignite.internal.util.typedef.R2 +org.apache.ignite.internal.util.typedef.R3 +org.apache.ignite.internal.util.typedef.RX1 +org.apache.ignite.internal.util.typedef.RX2 +org.apache.ignite.internal.util.typedef.RX3 org.apache.ignite.internal.util.typedef.T1 org.apache.ignite.internal.util.typedef.T2 org.apache.ignite.internal.util.typedef.T3 @@ -1310,6 +1435,9 @@ org.apache.ignite.internal.util.typedef.T5 org.apache.ignite.internal.util.typedef.T6 org.apache.ignite.internal.util.typedef.internal.SB org.apache.ignite.internal.util.worker.GridWorkerFuture +org.apache.ignite.internal.visor.VisorJob +org.apache.ignite.internal.visor.VisorMultiNodeTask +org.apache.ignite.internal.visor.VisorOneNodeTask org.apache.ignite.internal.visor.VisorTaskArgument org.apache.ignite.internal.visor.cache.VisorCache org.apache.ignite.internal.visor.cache.VisorCacheAffinityConfiguration @@ -1450,24 +1578,43 @@ org.apache.ignite.internal.visor.streamer.VisorStreamerResetTask$VisorStreamerRe org.apache.ignite.internal.visor.streamer.VisorStreamerStageMetrics org.apache.ignite.internal.visor.util.VisorEventMapper org.apache.ignite.internal.visor.util.VisorTaskUtils$4 +org.apache.ignite.lang.IgniteBiClosure +org.apache.ignite.lang.IgniteBiInClosure +org.apache.ignite.lang.IgniteBiPredicate org.apache.ignite.lang.IgniteBiTuple +org.apache.ignite.lang.IgniteCallable +org.apache.ignite.lang.IgniteClosure org.apache.ignite.lang.IgniteFutureCancelledException org.apache.ignite.lang.IgniteFutureTimeoutException +org.apache.ignite.lang.IgniteInClosure +org.apache.ignite.lang.IgniteOutClosure +org.apache.ignite.lang.IgnitePredicate org.apache.ignite.lang.IgniteProductVersion +org.apache.ignite.lang.IgniteReducer +org.apache.ignite.lang.IgniteRunnable org.apache.ignite.lang.IgniteUuid org.apache.ignite.lifecycle.LifecycleEventType org.apache.ignite.marshaller.jdk.JdkMarshallerDummySerializable org.apache.ignite.marshaller.optimized.OptimizedFieldType +org.apache.ignite.messaging.MessagingListenActor org.apache.ignite.plugin.PluginNotFoundException org.apache.ignite.plugin.PluginValidationException +org.apache.ignite.plugin.extensions.communication.Message org.apache.ignite.plugin.extensions.communication.MessageCollectionItemType org.apache.ignite.plugin.security.GridSecurityCredentials org.apache.ignite.plugin.security.GridSecurityException org.apache.ignite.plugin.security.GridSecurityPermission +org.apache.ignite.plugin.security.GridSecurityPermissionSet +org.apache.ignite.plugin.security.GridSecuritySubject org.apache.ignite.plugin.security.GridSecuritySubjectType org.apache.ignite.plugin.segmentation.GridSegmentationPolicy +org.apache.ignite.plugin.segmentation.GridSegmentationResolver +org.apache.ignite.services.Service org.apache.ignite.services.ServiceConfiguration +org.apache.ignite.services.ServiceContext +org.apache.ignite.services.ServiceDescriptor org.apache.ignite.spi.IgnitePortProtocol +org.apache.ignite.spi.IgniteSpiCloseableIterator org.apache.ignite.spi.IgniteSpiException org.apache.ignite.spi.IgniteSpiMultiException org.apache.ignite.spi.IgniteSpiVersionCheckException @@ -1493,6 +1640,7 @@ org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNodesRing$1 org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNodesRing$2 org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNodesRing$3 org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoverySpiState +org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAuthFailedMessage org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryCheckFailedMessage org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryClientReconnectMessage @@ -1530,6 +1678,7 @@ org.apache.ignite.streamer.window.StreamerBoundedTimeWindow$WindowHolder org.apache.ignite.transactions.TransactionConcurrency org.apache.ignite.transactions.TransactionHeuristicException org.apache.ignite.transactions.TransactionIsolation +org.apache.ignite.transactions.TransactionMetrics org.apache.ignite.transactions.TransactionOptimisticException org.apache.ignite.transactions.TransactionRollbackException org.apache.ignite.transactions.TransactionState @@ -1542,6 +1691,7 @@ org.jdk8.backport.ConcurrentLinkedHashMap$QueuePolicy org.jdk8.backport.ConcurrentLinkedHashMap$Segment org.jdk8.backport.ConcurrentLinkedHashMap$WriteThroughEntry org.jdk8.backport.LongAdder +org.jdk8.backport.Striped64 org.jdk8.backport.ThreadLocalRandom8 org.pcollections.MapPSet$In org.pcollections.SimpleImmutableEntry http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheEntryMemorySizeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheEntryMemorySizeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheEntryMemorySizeSelfTest.java index 9966777..e57de6f 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheEntryMemorySizeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheEntryMemorySizeSelfTest.java @@ -85,8 +85,8 @@ public class GridCacheEntryMemorySizeSelfTest extends GridCommonAbstractTest { Marshaller marsh = new OptimizedMarshaller(); marsh.setContext(new MarshallerContext() { - @Override public void registerClass(int id, Class cls) { - // No-op. + @Override public boolean registerClass(int id, Class cls) { + return true; } @Override public Class getClass(int id, ClassLoader ldr) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/471ae3d6/modules/core/src/test/java/org/apache/ignite/marshaller/MarshallerContextTestImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/marshaller/MarshallerContextTestImpl.java b/modules/core/src/test/java/org/apache/ignite/marshaller/MarshallerContextTestImpl.java index dda8fd5..63ec4f8 100644 --- a/modules/core/src/test/java/org/apache/ignite/marshaller/MarshallerContextTestImpl.java +++ b/modules/core/src/test/java/org/apache/ignite/marshaller/MarshallerContextTestImpl.java @@ -30,8 +30,10 @@ public class MarshallerContextTestImpl extends MarshallerContextAdapter { private final ConcurrentMap<Integer, String> map = new ConcurrentHashMap8<>(); /** {@inheritDoc} */ - @Override protected void registerClassName(int id, String clsName) { + @Override protected boolean registerClassName(int id, String clsName) { map.putIfAbsent(id, clsName); + + return true; } /** {@inheritDoc} */
