Repository: ignite Updated Branches: refs/heads/master 7ae798afe -> 152104e42
IGNITE-6976 Visor CMD: Task to put/get/remove data to/from caches. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/152104e4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/152104e4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/152104e4 Branch: refs/heads/master Commit: 152104e42b31671ab5ee64ba92f6a31a0dc39b42 Parents: 7ae798a Author: vsisko <vsi...@gridgain.com> Authored: Tue Nov 21 21:30:03 2017 +0700 Committer: Alexey Kuznetsov <akuznet...@apache.org> Committed: Tue Nov 21 21:30:03 2017 +0700 ---------------------------------------------------------------------- .../visor/cache/VisorCacheModifyTask.java | 113 ++++++++++++++++++ .../visor/cache/VisorCacheModifyTaskArg.java | 114 +++++++++++++++++++ .../visor/cache/VisorCacheModifyTaskResult.java | 101 ++++++++++++++++ .../visor/cache/VisorModifyCacheMode.java | 47 ++++++++ .../internal/visor/query/VisorQueryTask.java | 3 - .../internal/visor/query/VisorQueryUtils.java | 25 ++-- .../resources/META-INF/classnames.properties | 77 +++++++++---- 7 files changed, 445 insertions(+), 35 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/152104e4/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 new file mode 100644 index 0000000..d6b1ff7 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTask.java @@ -0,0 +1,113 @@ +/* + * 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.UUID; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.internal.processors.task.GridInternal; +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.internal.visor.query.VisorQueryUtils; +import org.apache.ignite.internal.visor.util.VisorTaskUtils; + +/** + * Task that modify value in specified cache. + */ +@GridInternal +public class VisorCacheModifyTask extends VisorOneNodeTask<VisorCacheModifyTaskArg, VisorCacheModifyTaskResult> { + /** */ + private static final long serialVersionUID = 0L; + + /** {@inheritDoc} */ + @Override protected VisorCacheModifyJob job(VisorCacheModifyTaskArg arg) { + return new VisorCacheModifyJob(arg, debug); + } + + /** + * Job that clear specified caches. + */ + private static class VisorCacheModifyJob extends VisorJob<VisorCacheModifyTaskArg, VisorCacheModifyTaskResult> { + /** */ + private static final long serialVersionUID = 0L; + + /** + * Create job. + * + * @param arg Task argument. + * @param debug Debug flag. + */ + private VisorCacheModifyJob(VisorCacheModifyTaskArg arg, boolean debug) { + super(arg, debug); + } + + /** {@inheritDoc} */ + @Override protected VisorCacheModifyTaskResult run(final VisorCacheModifyTaskArg arg) { + assert arg != null; + + VisorModifyCacheMode mode = arg.getMode(); + String cacheName = arg.getCacheName(); + Object key = arg.getKey(); + + assert mode != null; + assert cacheName != null; + assert key != null; + + IgniteCache<Object, Object> cache = ignite.cache(cacheName); + + if (cache == null) + throw new IllegalArgumentException("Failed to find cache with specified name [cacheName=" + arg.getCacheName() + "]"); + + ClusterNode node = ignite.affinity(cacheName).mapKeyToNode(key); + + UUID nid = node != null ? node.id() : null; + + switch (mode) { + case PUT: + Object old = cache.get(key); + + cache.put(key, arg.getValue()); + + return new VisorCacheModifyTaskResult(nid, VisorTaskUtils.compactClass(old), + VisorQueryUtils.convertValue(old)); + + case GET: + Object value = cache.get(key); + + return new VisorCacheModifyTaskResult(nid, VisorTaskUtils.compactClass(value), + VisorQueryUtils.convertValue(value)); + + case REMOVE: + Object removed = cache.get(key); + + cache.remove(key); + + return new VisorCacheModifyTaskResult(nid, VisorTaskUtils.compactClass(removed), + VisorQueryUtils.convertValue(removed)); + } + + return new VisorCacheModifyTaskResult(nid, null, null); + } + + /** {@inheritDoc} */ + @Override public String toString() { + return S.toString(VisorCacheModifyJob.class, this); + } + } +} http://git-wip-us.apache.org/repos/asf/ignite/blob/152104e4/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 new file mode 100644 index 0000000..706aab7 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskArg.java @@ -0,0 +1,114 @@ +/* + * 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 org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.internal.visor.VisorDataTransferObject; + +/** + * Argument for {@link VisorCacheModifyTask}. + */ +public class VisorCacheModifyTaskArg extends VisorDataTransferObject { + /** */ + private static final long serialVersionUID = 0L; + + /** Cache name. */ + private String cacheName; + + /** Modification mode. */ + private VisorModifyCacheMode mode; + + /** Specified key. */ + private Object key; + + /** Specified value. */ + private Object value; + + /** + * Default constructor. + */ + public VisorCacheModifyTaskArg() { + // No-op. + } + + /** + * @param cacheName Cache name. + * @param mode Modification mode. + * @param key Specified key. + * @param value Specified value. + */ + public VisorCacheModifyTaskArg(String cacheName, VisorModifyCacheMode mode, Object key, Object value) { + this.cacheName = cacheName; + this.mode = mode; + this.key = key; + this.value = value; + } + + /** + * @return Cache name. + */ + public String getCacheName() { + return cacheName; + } + + /** + * @return Modification mode. + */ + public VisorModifyCacheMode getMode() { + return mode; + } + + /** + * @return Specified key. + */ + public Object getKey() { + return key; + } + + /** + * @return Specified value. + */ + public Object getValue() { + return value; + } + + /** {@inheritDoc} */ + @Override protected void writeExternalData(ObjectOutput out) throws IOException { + U.writeString(out, cacheName); + U.writeEnum(out, mode); + out.writeObject(key); + out.writeObject(value); + } + + /** {@inheritDoc} */ + @Override protected void readExternalData(byte protoVer, ObjectInput in) throws IOException, ClassNotFoundException { + cacheName = U.readString(in); + mode = VisorModifyCacheMode.fromOrdinal(in.readByte()); + key = in.readObject(); + value = in.readObject(); + } + + /** {@inheritDoc} */ + @Override public String toString() { + return S.toString(VisorCacheModifyTaskArg.class, this); + } +} http://git-wip-us.apache.org/repos/asf/ignite/blob/152104e4/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 new file mode 100644 index 0000000..ce09bb2 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheModifyTaskResult.java @@ -0,0 +1,101 @@ +/* + * 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.UUID; +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; + +/** + * Result for {@link VisorCacheModifyTask}. + */ +public class VisorCacheModifyTaskResult extends VisorDataTransferObject { + /** */ + private static final long serialVersionUID = 0L; + + /** Node ID where modified data contained. */ + private UUID affinityNode; + + /** Result type name. */ + private String resultType; + + /** Value for specified key or number of modified rows. */ + private Object result; + + /** + * Default constructor. + */ + public VisorCacheModifyTaskResult() { + // No-op. + } + + /** + * @param affinityNode Node ID where modified data contained. + * @param resultType Result type name. + * @param result Value for specified key or number of modified rows. + */ + public VisorCacheModifyTaskResult(UUID affinityNode, String resultType, Object result) { + this.affinityNode = affinityNode; + this.resultType = resultType; + this.result = result; + } + + /** + * @return Node ID where modified data contained. + */ + public UUID getAffinityNode() { + return affinityNode; + } + + /** + * @return Result type name. + */ + public String getResultType() { + return resultType; + } + + /** + * @return Value for specified key or number of modified rows.. + */ + public Object getResult() { + return result; + } + + /** {@inheritDoc} */ + @Override protected void writeExternalData(ObjectOutput out) throws IOException { + U.writeUuid(out, affinityNode); + U.writeString(out, resultType); + out.writeObject(result); + } + + /** {@inheritDoc} */ + @Override protected void readExternalData(byte protoVer, ObjectInput in) throws IOException, ClassNotFoundException { + affinityNode = U.readUuid(in); + resultType = U.readString(in); + result = in.readObject(); + } + + /** {@inheritDoc} */ + @Override public String toString() { + return S.toString(VisorCacheModifyTaskResult.class, this); + } +} http://git-wip-us.apache.org/repos/asf/ignite/blob/152104e4/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorModifyCacheMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorModifyCacheMode.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorModifyCacheMode.java new file mode 100644 index 0000000..4e28439 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorModifyCacheMode.java @@ -0,0 +1,47 @@ +/* + * 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 org.jetbrains.annotations.Nullable; + +/** + * Enumeration of all supported cache modify modes. + */ +public enum VisorModifyCacheMode { + /** Put new value into cache. */ + PUT, + + /** Get value from cache. */ + GET, + + /** Remove value from cache. */ + REMOVE; + + /** Enumerated values. */ + private static final VisorModifyCacheMode[] VALS = values(); + + /** + * Efficiently gets enumerated value from its ordinal. + * + * @param ord Ordinal value. + * @return Enumerated value or {@code null} if ordinal out of range. + */ + @Nullable public static VisorModifyCacheMode fromOrdinal(int ord) { + return ord >= 0 && ord < VALS.length ? VALS[ord] : null; + } +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/152104e4/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java index 933bacc..51bf7d6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java @@ -22,15 +22,12 @@ import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.UUID; -import javax.cache.CacheException; import org.apache.ignite.IgniteCache; import org.apache.ignite.cache.query.FieldsQueryCursor; import org.apache.ignite.cache.query.SqlFieldsQuery; import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; -import org.apache.ignite.internal.processors.query.IgniteSQLException; import org.apache.ignite.internal.processors.task.GridInternal; import org.apache.ignite.internal.util.typedef.F; -import org.apache.ignite.internal.util.typedef.X; import org.apache.ignite.internal.util.typedef.internal.S; import org.apache.ignite.internal.util.typedef.internal.U; import org.apache.ignite.internal.visor.VisorEither; http://git-wip-us.apache.org/repos/asf/ignite/blob/152104e4/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryUtils.java index 9a0262d..aa4cb48 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryUtils.java @@ -218,6 +218,17 @@ public class VisorQueryUtils { "typeId", obj.type().typeId(), true); } + public static Object convertValue(Object original) { + if (original == null) + return null; + else if (isKnownType(original)) + return original; + else if (original instanceof BinaryObject) + return binaryToString((BinaryObject)original); + else + return original.getClass().isArray() ? "binary" : original.toString(); + } + /** * Collects rows from sql query future, first time creates meta and column names arrays. * @@ -237,18 +248,8 @@ public class VisorQueryUtils { Object[] row = new Object[sz]; - for (int i = 0; i < sz; i++) { - Object o = next.get(i); - - if (o == null) - row[i] = null; - else if (isKnownType(o)) - row[i] = o; - else if (o instanceof BinaryObject) - row[i] = binaryToString((BinaryObject)o); - else - row[i] = o.getClass().isArray() ? "binary" : o.toString(); - } + for (int i = 0; i < sz; i++) + row[i] = convertValue(next.get(i)); rows.add(row); http://git-wip-us.apache.org/repos/asf/ignite/blob/152104e4/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 f3fc074..c27681e 100644 --- a/modules/core/src/main/resources/META-INF/classnames.properties +++ b/modules/core/src/main/resources/META-INF/classnames.properties @@ -54,15 +54,19 @@ org.apache.ignite.cache.affinity.AffinityUuid org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction$HashComparator org.apache.ignite.cache.eviction.AbstractEvictionPolicy +org.apache.ignite.cache.eviction.AbstractEvictionPolicyFactory org.apache.ignite.cache.eviction.EvictionFilter org.apache.ignite.cache.eviction.fifo.FifoEvictionPolicy +org.apache.ignite.cache.eviction.fifo.FifoEvictionPolicyFactory org.apache.ignite.cache.eviction.igfs.IgfsEvictionFilter org.apache.ignite.cache.eviction.igfs.IgfsPerBlockLruEvictionPolicy org.apache.ignite.cache.eviction.lru.LruEvictionPolicy +org.apache.ignite.cache.eviction.lru.LruEvictionPolicyFactory org.apache.ignite.cache.eviction.sorted.SortedEvictionPolicy org.apache.ignite.cache.eviction.sorted.SortedEvictionPolicy$DefaultHolderComparator org.apache.ignite.cache.eviction.sorted.SortedEvictionPolicy$GridConcurrentSkipListSetEx org.apache.ignite.cache.eviction.sorted.SortedEvictionPolicy$HolderComparator +org.apache.ignite.cache.eviction.sorted.SortedEvictionPolicyFactory org.apache.ignite.cache.query.CacheQueryEntryEvent org.apache.ignite.cache.query.ContinuousQuery org.apache.ignite.cache.query.Query @@ -135,12 +139,14 @@ org.apache.ignite.configuration.CacheConfiguration$IgniteAllNodesPredicate org.apache.ignite.configuration.CheckpointWriteOrder org.apache.ignite.configuration.CollectionConfiguration org.apache.ignite.configuration.DataPageEvictionMode +org.apache.ignite.configuration.DataRegionConfiguration +org.apache.ignite.configuration.DataStorageConfiguration org.apache.ignite.configuration.DeploymentMode org.apache.ignite.configuration.IgniteReflectionFactory -org.apache.ignite.configuration.DataStorageConfiguration -org.apache.ignite.configuration.DataRegionConfiguration +org.apache.ignite.configuration.MemoryConfiguration +org.apache.ignite.configuration.MemoryPolicyConfiguration org.apache.ignite.configuration.NearCacheConfiguration -org.apache.ignite.configuration.DataStorageConfiguration +org.apache.ignite.configuration.PersistentStoreConfiguration org.apache.ignite.configuration.TopologyValidator org.apache.ignite.configuration.TransactionConfiguration org.apache.ignite.configuration.WALMode @@ -183,6 +189,7 @@ org.apache.ignite.igfs.mapreduce.records.IgfsByteDelimiterRecordResolver org.apache.ignite.igfs.mapreduce.records.IgfsFixedLengthRecordResolver org.apache.ignite.igfs.mapreduce.records.IgfsNewLineRecordResolver org.apache.ignite.igfs.mapreduce.records.IgfsStringDelimiterRecordResolver +org.apache.ignite.internal.DuplicateTypeIdException org.apache.ignite.internal.ExecutorAwareMessage org.apache.ignite.internal.GridClosureCallMode org.apache.ignite.internal.GridComponent$DiscoveryDataExchangeType @@ -307,10 +314,12 @@ org.apache.ignite.internal.igfs.common.IgfsIpcCommand org.apache.ignite.internal.jdbc2.JdbcBatchUpdateTask org.apache.ignite.internal.jdbc2.JdbcConnection$JdbcConnectionValidationTask org.apache.ignite.internal.jdbc2.JdbcDatabaseMetadata$UpdateMetadataTask +org.apache.ignite.internal.jdbc2.JdbcQueryMultipleStatementsTask org.apache.ignite.internal.jdbc2.JdbcQueryTask org.apache.ignite.internal.jdbc2.JdbcQueryTask$1 -org.apache.ignite.internal.jdbc2.JdbcQueryTask$QueryResult -org.apache.ignite.internal.processors.cache.query.SqlFieldsQueryEx +org.apache.ignite.internal.jdbc2.JdbcQueryTaskResult +org.apache.ignite.internal.jdbc2.JdbcQueryTaskV2 +org.apache.ignite.internal.jdbc2.JdbcQueryTaskV3 org.apache.ignite.internal.managers.GridManagerAdapter$1$1 org.apache.ignite.internal.managers.checkpoint.GridCheckpointManager$CheckpointSet org.apache.ignite.internal.managers.checkpoint.GridCheckpointRequest @@ -341,7 +350,7 @@ org.apache.ignite.internal.mem.IgniteOutOfMemoryException org.apache.ignite.internal.pagemem.impl.PageMemoryNoStoreImpl$Segment org.apache.ignite.internal.pagemem.wal.StorageException org.apache.ignite.internal.pagemem.wal.WALIterator -org.apache.ignite.internal.pagemem.wal.record.TxRecord$TxAction +org.apache.ignite.internal.pagemem.wal.WALPointer org.apache.ignite.internal.pagemem.wal.record.WALRecord$RecordType org.apache.ignite.internal.pagemem.wal.record.delta.DeltaApplicationException org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion @@ -426,29 +435,29 @@ org.apache.ignite.internal.processors.cache.GridCacheAdapter$11 org.apache.ignite.internal.processors.cache.GridCacheAdapter$12 org.apache.ignite.internal.processors.cache.GridCacheAdapter$13 org.apache.ignite.internal.processors.cache.GridCacheAdapter$14 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$15$1 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$16 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$15 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$16$1 org.apache.ignite.internal.processors.cache.GridCacheAdapter$17 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$18 org.apache.ignite.internal.processors.cache.GridCacheAdapter$2 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$25$1 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$27 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$28$1 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$29 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$26$1 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$28 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$29$1 org.apache.ignite.internal.processors.cache.GridCacheAdapter$3 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$31 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$30 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$32 org.apache.ignite.internal.processors.cache.GridCacheAdapter$4 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$47 org.apache.ignite.internal.processors.cache.GridCacheAdapter$48 org.apache.ignite.internal.processors.cache.GridCacheAdapter$49 org.apache.ignite.internal.processors.cache.GridCacheAdapter$50 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$52 +org.apache.ignite.internal.processors.cache.GridCacheAdapter$51 org.apache.ignite.internal.processors.cache.GridCacheAdapter$53 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$53$1 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 org.apache.ignite.internal.processors.cache.GridCacheAdapter$8 -org.apache.ignite.internal.processors.cache.GridCacheAdapter$9 org.apache.ignite.internal.processors.cache.GridCacheAdapter$AsyncOp$1 org.apache.ignite.internal.processors.cache.GridCacheAdapter$AsyncOp$1$1 org.apache.ignite.internal.processors.cache.GridCacheAdapter$AsyncOpRetryFuture$1 @@ -584,6 +593,7 @@ org.apache.ignite.internal.processors.cache.StoredCacheData org.apache.ignite.internal.processors.cache.affinity.GridCacheAffinityProxy org.apache.ignite.internal.processors.cache.binary.BinaryMetadataHolder org.apache.ignite.internal.processors.cache.binary.BinaryMetadataKey +org.apache.ignite.internal.processors.cache.binary.BinaryMetadataTransport$2 org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryProcessorImpl$3 org.apache.ignite.internal.processors.cache.binary.MetadataRequestMessage org.apache.ignite.internal.processors.cache.binary.MetadataResponseMessage @@ -757,6 +767,7 @@ 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 @@ -817,6 +828,7 @@ 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 @@ -861,6 +873,8 @@ 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$22 +org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$23 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 @@ -900,9 +914,11 @@ org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree$DestroyBa 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.wal.AbstractWalRecordsIterator +org.apache.ignite.internal.processors.cache.persistence.wal.FileWALPointer org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager$FileArchiver$1 org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager$RecordsIterator org.apache.ignite.internal.processors.cache.persistence.wal.SegmentEofException +org.apache.ignite.internal.processors.cache.persistence.wal.WalSegmentTailReachedException org.apache.ignite.internal.processors.cache.persistence.wal.crc.IgniteDataIntegrityViolationException org.apache.ignite.internal.processors.cache.persistence.wal.reader.StandaloneWalRecordsIterator org.apache.ignite.internal.processors.cache.query.CacheQueryEntry @@ -919,8 +935,6 @@ org.apache.ignite.internal.processors.cache.query.GridCacheQueryDetailMetricsAda 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$10 -org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$11 -org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$12$1 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$4$1 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$4$2 org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$5 @@ -943,10 +957,16 @@ org.apache.ignite.internal.processors.cache.query.GridCacheQueryMetricsKey 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.GridCacheQuerySqlMetadataJobV2 +org.apache.ignite.internal.processors.cache.query.GridCacheQuerySqlMetadataJobV2$1 +org.apache.ignite.internal.processors.cache.query.GridCacheQuerySqlMetadataJobV2$2 +org.apache.ignite.internal.processors.cache.query.GridCacheQuerySqlMetadataJobV2$3 +org.apache.ignite.internal.processors.cache.query.GridCacheQuerySqlMetadataV2 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.SqlFieldsQueryEx org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryBatchAck org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryDeployableObject org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEntry @@ -973,6 +993,7 @@ org.apache.ignite.internal.processors.cache.ratemetrics.HitRateMetricsSandbox org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter$1 org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter$2 org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter$3 +org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter$StoreOperation org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$BatchingResult org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$StatefulValue org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$StoreOperation @@ -1264,6 +1285,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.JdbcStatementType org.apache.ignite.internal.processors.odbc.odbc.escape.OdbcEscapeType org.apache.ignite.internal.processors.platform.PlatformAbstractConfigurationClosure org.apache.ignite.internal.processors.platform.PlatformAbstractPredicate @@ -1287,6 +1309,7 @@ org.apache.ignite.internal.processors.platform.cache.query.PlatformContinuousQue org.apache.ignite.internal.processors.platform.cache.query.PlatformContinuousQueryFilter org.apache.ignite.internal.processors.platform.cache.query.PlatformContinuousQueryImpl org.apache.ignite.internal.processors.platform.cache.query.PlatformContinuousQueryRemoteFilter +org.apache.ignite.internal.processors.platform.client.IgniteClientException org.apache.ignite.internal.processors.platform.cluster.PlatformClusterNodeFilter org.apache.ignite.internal.processors.platform.cluster.PlatformClusterNodeFilterImpl org.apache.ignite.internal.processors.platform.compute.PlatformAbstractJob @@ -1323,6 +1346,7 @@ org.apache.ignite.internal.processors.platform.entityframework.PlatformDotNetEnt org.apache.ignite.internal.processors.platform.entityframework.PlatformDotNetEntityFrameworkCacheExtension$RemoveOldEntriesRunnable org.apache.ignite.internal.processors.platform.entityframework.PlatformDotNetEntityFrameworkIncreaseVersionProcessor org.apache.ignite.internal.processors.platform.events.PlatformEventFilterListenerImpl +org.apache.ignite.internal.processors.platform.events.PlatformLocalEventListener org.apache.ignite.internal.processors.platform.message.PlatformMessageFilter org.apache.ignite.internal.processors.platform.messaging.PlatformMessageFilterImpl org.apache.ignite.internal.processors.platform.messaging.PlatformMessageLocalFilter @@ -1361,7 +1385,9 @@ org.apache.ignite.internal.processors.query.schema.message.SchemaAbstractDiscove org.apache.ignite.internal.processors.query.schema.message.SchemaFinishDiscoveryMessage org.apache.ignite.internal.processors.query.schema.message.SchemaOperationStatusMessage org.apache.ignite.internal.processors.query.schema.message.SchemaProposeDiscoveryMessage +org.apache.ignite.internal.processors.query.schema.operation.SchemaAbstractAlterTableOperation org.apache.ignite.internal.processors.query.schema.operation.SchemaAbstractOperation +org.apache.ignite.internal.processors.query.schema.operation.SchemaAlterTableAddColumnOperation org.apache.ignite.internal.processors.query.schema.operation.SchemaIndexAbstractOperation org.apache.ignite.internal.processors.query.schema.operation.SchemaIndexCreateOperation org.apache.ignite.internal.processors.query.schema.operation.SchemaIndexDropOperation @@ -1465,6 +1491,8 @@ org.apache.ignite.internal.processors.task.GridTaskThreadContextKey org.apache.ignite.internal.processors.task.GridTaskWorker$3 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.transactions.IgniteTxHeuristicCheckedException org.apache.ignite.internal.transactions.IgniteTxOptimisticCheckedException org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException @@ -1557,6 +1585,7 @@ org.apache.ignite.internal.util.IgniteUtils$7 org.apache.ignite.internal.util.IgniteUtils$8 org.apache.ignite.internal.util.IgniteUtils$9 org.apache.ignite.internal.util.StripedCompositeReadWriteLock$ReadLock +org.apache.ignite.internal.util.StripedExecutor$StealingStripe$1 org.apache.ignite.internal.util.UUIDCollectionMessage org.apache.ignite.internal.util.future.AsyncFutureListener org.apache.ignite.internal.util.future.GridCompoundFuture$1 @@ -1772,6 +1801,10 @@ org.apache.ignite.internal.visor.cache.VisorCacheMetrics org.apache.ignite.internal.visor.cache.VisorCacheMetricsCollectorTask org.apache.ignite.internal.visor.cache.VisorCacheMetricsCollectorTask$VisorCacheMetricsCollectorJob org.apache.ignite.internal.visor.cache.VisorCacheMetricsCollectorTaskArg +org.apache.ignite.internal.visor.cache.VisorCacheModifyTask +org.apache.ignite.internal.visor.cache.VisorCacheModifyTask$VisorCacheClearJob +org.apache.ignite.internal.visor.cache.VisorCacheModifyTaskArg +org.apache.ignite.internal.visor.cache.VisorCacheModifyTaskResult org.apache.ignite.internal.visor.cache.VisorCacheNearConfiguration org.apache.ignite.internal.visor.cache.VisorCacheNodesTask org.apache.ignite.internal.visor.cache.VisorCacheNodesTask$VisorCacheNodesJob @@ -1797,6 +1830,7 @@ org.apache.ignite.internal.visor.cache.VisorCacheStopTask$VisorCacheStopJob org.apache.ignite.internal.visor.cache.VisorCacheStopTaskArg org.apache.ignite.internal.visor.cache.VisorCacheStoreConfiguration org.apache.ignite.internal.visor.cache.VisorMemoryMetrics +org.apache.ignite.internal.visor.cache.VisorModifyCacheMode org.apache.ignite.internal.visor.cache.VisorPartitionMap org.apache.ignite.internal.visor.compute.VisorComputeCancelSessionsTask org.apache.ignite.internal.visor.compute.VisorComputeCancelSessionsTask$VisorComputeCancelSessionsJob @@ -1874,6 +1908,9 @@ org.apache.ignite.internal.visor.node.VisorBasicConfiguration org.apache.ignite.internal.visor.node.VisorBinaryConfiguration org.apache.ignite.internal.visor.node.VisorBinaryTypeConfiguration org.apache.ignite.internal.visor.node.VisorCacheKeyConfiguration +org.apache.ignite.internal.visor.node.VisorClientConnectorConfiguration +org.apache.ignite.internal.visor.node.VisorDataRegionConfiguration +org.apache.ignite.internal.visor.node.VisorDataStorageConfiguration org.apache.ignite.internal.visor.node.VisorExecutorConfiguration org.apache.ignite.internal.visor.node.VisorExecutorServiceConfiguration org.apache.ignite.internal.visor.node.VisorGridConfiguration @@ -2008,6 +2045,7 @@ org.apache.ignite.plugin.segmentation.SegmentationResolver org.apache.ignite.services.Service org.apache.ignite.services.ServiceConfiguration org.apache.ignite.services.ServiceContext +org.apache.ignite.services.ServiceDeploymentException org.apache.ignite.services.ServiceDescriptor org.apache.ignite.spi.IgnitePortProtocol org.apache.ignite.spi.IgniteSpiCloseableIterator @@ -2094,4 +2132,3 @@ org.apache.ignite.transactions.TransactionRollbackException org.apache.ignite.transactions.TransactionState org.apache.ignite.transactions.TransactionTimeoutException org.apache.ignite.util.AttributeNodeFilter -org.apache.ignite.internal.processors.cache.persistence.file.AsyncFileIO
