Repository: incubator-ignite Updated Branches: refs/heads/ignite-648 aaca0e8b3 -> ae4e791fd
# ignite-648: IgniteClusterProcessProxy.java instead of local cluster Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ae4e791f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ae4e791f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ae4e791f Branch: refs/heads/ignite-648 Commit: ae4e791fd5d31d1cad229510dd3337860eaf2959 Parents: aaca0e8 Author: ashutak <ashu...@gridgain.com> Authored: Wed Jul 1 15:20:10 2015 +0300 Committer: ashutak <ashu...@gridgain.com> Committed: Wed Jul 1 15:20:10 2015 +0300 ---------------------------------------------------------------------- .../multijvm/IgniteClusterProcessProxy.java | 320 +++++++++++++++++++ .../multijvm/IgniteEventsProcessProxy.java | 32 +- .../junits/multijvm/IgniteProcessProxy.java | 94 +++--- 3 files changed, 383 insertions(+), 63 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae4e791f/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteClusterProcessProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteClusterProcessProxy.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteClusterProcessProxy.java new file mode 100644 index 0000000..99ec424 --- /dev/null +++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteClusterProcessProxy.java @@ -0,0 +1,320 @@ +/* + * 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.testframework.junits.multijvm; + +import org.apache.ignite.*; +import org.apache.ignite.cluster.*; +import org.apache.ignite.internal.cluster.*; +import org.apache.ignite.lang.*; +import org.jetbrains.annotations.*; + +import java.io.*; +import java.util.*; +import java.util.concurrent.*; + +/** + * Proxy class for cluster at another jvm. + */ +@SuppressWarnings("TransientFieldInNonSerializableClass") +public class IgniteClusterProcessProxy implements IgniteClusterEx { + /** Grid id. */ + private final UUID gridId; + + /** Compute. */ + private final transient IgniteCompute compute; + + /** */ + private final IgniteProcessProxy proxy; + + /** + * @param proxy Ignite Proxy. + */ + public IgniteClusterProcessProxy(IgniteProcessProxy proxy) { + this.proxy = proxy; + gridId = proxy.getId(); + compute = proxy.remoteCompute(); + } + + /** + * Returns cluster instance. Method to be called from closure at another JVM. + * + * @return Cache. + */ + private IgniteClusterEx cluster() { + return (IgniteClusterEx)Ignition.ignite(gridId).cluster(); + } + + /** {@inheritDoc} */ + @Override public ClusterGroupEx forSubjectId(final UUID subjId) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forCacheNodes(@Nullable String cacheName, boolean affNodes, boolean nearNodes, + boolean clientNodes) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterNode localNode() { + return compute.call(new IgniteCallable<ClusterNode>() { + @Override public ClusterNode call() throws Exception { + return cluster().localNode(); + } + }); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forLocal() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public <K, V> ConcurrentMap<K, V> nodeLocalMap() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public boolean pingNode(UUID nodeId) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public long topologyVersion() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public Collection<ClusterNode> topology(long topVer) throws UnsupportedOperationException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public <K> Map<ClusterNode, Collection<K>> mapKeysToNodes(@Nullable String cacheName, + @Nullable Collection<? extends K> keys) throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public <K> ClusterNode mapKeyToNode(@Nullable String cacheName, K key) throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public Collection<ClusterStartNodeResult> startNodes(File file, boolean restart, int timeout, + int maxConn) throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public Collection<ClusterStartNodeResult> startNodes(Collection<Map<String, Object>> hosts, + @Nullable Map<String, Object> dflts, boolean restart, int timeout, int maxConn) throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public void stopNodes() throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public void stopNodes(Collection<UUID> ids) throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public void restartNodes() throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public void restartNodes(Collection<UUID> ids) throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public void resetMetrics() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public IgniteCluster withAsync() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public boolean isAsync() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public <R> IgniteFuture<R> future() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public Ignite ignite() { + return proxy; + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forNodes(Collection<? extends ClusterNode> nodes) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forNode(ClusterNode node, ClusterNode... nodes) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forOthers(ClusterNode node, ClusterNode... nodes) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forOthers(ClusterGroup prj) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forNodeIds(Collection<UUID> ids) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forNodeId(UUID id, UUID... ids) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forPredicate(IgnitePredicate<ClusterNode> p) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forAttribute(String name, @Nullable Object val) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forServers() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forClients() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forCacheNodes(String cacheName) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forDataNodes(String cacheName) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forClientNodes(String cacheName) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forRemotes() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forHost(ClusterNode node) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forHost(String host, String... hosts) { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forDaemons() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forRandom() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forOldest() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterGroup forYoungest() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public Collection<ClusterNode> nodes() { + return compute.call(new IgniteCallable<Collection<ClusterNode>>() { + @Override public Collection<ClusterNode> call() throws Exception { + return cluster().nodes(); + } + }); + } + + /** {@inheritDoc} */ + @Override public ClusterNode node(final UUID nid) { + return compute.call(new IgniteCallable<ClusterNode>() { + @Override public ClusterNode call() throws Exception { + return cluster().node(nid); + } + }); + } + + /** {@inheritDoc} */ + @Override public ClusterNode node() { + return compute.call(new IgniteCallable<ClusterNode>() { + @Override public ClusterNode call() throws Exception { + return cluster().node(); + } + }); + } + + /** {@inheritDoc} */ + @Override public Collection<String> hostNames() { + return compute.call(new IgniteCallable<Collection<String>>() { + @Override public Collection<String> call() throws Exception { + return cluster().hostNames(); + } + }); + } + + /** {@inheritDoc} */ + @Override public IgnitePredicate<ClusterNode> predicate() { + throw new UnsupportedOperationException("Operation is not supported yet."); + } + + /** {@inheritDoc} */ + @Override public ClusterMetrics metrics() throws IgniteException { + throw new UnsupportedOperationException("Operation is not supported yet."); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae4e791f/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteEventsProcessProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteEventsProcessProxy.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteEventsProcessProxy.java index eb09965..018aa8d 100644 --- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteEventsProcessProxy.java +++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteEventsProcessProxy.java @@ -54,47 +54,47 @@ public class IgniteEventsProcessProxy implements IgniteEvents { /** {@inheritDoc} */ @Override public ClusterGroup clusterGroup() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T extends Event> List<T> remoteQuery(IgnitePredicate<T> p, long timeout, @Nullable int... types) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T extends Event> UUID remoteListen(@Nullable IgniteBiPredicate<UUID, T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @Nullable int... types) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T extends Event> UUID remoteListen(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID, T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @Nullable int... types) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public void stopRemoteListen(UUID opId) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T extends Event> T waitForLocal(@Nullable IgnitePredicate<T> filter, @Nullable int... types) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T extends Event> Collection<T> localQuery(IgnitePredicate<T> p, @Nullable int... types) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public void recordLocal(Event evt) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @@ -108,41 +108,41 @@ public class IgniteEventsProcessProxy implements IgniteEvents { /** {@inheritDoc} */ @Override public boolean stopLocalListen(IgnitePredicate<? extends Event> lsnr, @Nullable int... types) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public void enableLocal(int... types) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public void disableLocal(int... types) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public int[] enabledEvents() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public boolean isEnabled(int type) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteEvents withAsync() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public boolean isAsync() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <R> IgniteFuture<R> future() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ae4e791f/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteProcessProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteProcessProxy.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteProcessProxy.java index 5ed5b87..b96fe5f 100644 --- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteProcessProxy.java +++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/multijvm/IgniteProcessProxy.java @@ -77,7 +77,7 @@ public class IgniteProcessProxy implements IgniteEx { List<String> jvmArgs = U.jvmArgs(); - List<String> filteredJvmArgs = new ArrayList<>(); + Collection<String> filteredJvmArgs = new ArrayList<>(); for (String arg : jvmArgs) { if(!arg.toLowerCase().startsWith("-agentlib")) @@ -195,63 +195,63 @@ public class IgniteProcessProxy implements IgniteEx { /** {@inheritDoc} */ @Override public <K extends GridCacheUtilityKey, V> IgniteInternalCache<K, V> utilityCache() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Nullable @Override public <K, V> IgniteInternalCache<K, V> cachex(@Nullable String name) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Nullable @Override public <K, V> IgniteInternalCache<K, V> cachex() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public Collection<IgniteInternalCache<?, ?>> cachesx( @Nullable IgnitePredicate<? super IgniteInternalCache<?, ?>>... p) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public boolean eventUserRecordable(int type) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public boolean allEventsUserRecordable(int[] types) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public boolean isJmxRemoteEnabled() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public boolean isRestartEnabled() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Nullable @Override public IgniteFileSystem igfsx(@Nullable String name) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public Hadoop hadoop() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteClusterEx cluster() { - return (IgniteClusterEx)locJvmGrid.cluster(); + return new IgniteClusterProcessProxy(this); } /** {@inheritDoc} */ @Nullable @Override public String latestVersion() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @@ -265,27 +265,27 @@ public class IgniteProcessProxy implements IgniteEx { /** {@inheritDoc} */ @Override public GridKernalContext context() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteCompute compute() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteCompute compute(ClusterGroup grp) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteMessaging message() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteMessaging message(ClusterGroup grp) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @@ -295,85 +295,85 @@ public class IgniteProcessProxy implements IgniteEx { /** {@inheritDoc} */ @Override public IgniteEvents events(ClusterGroup grp) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteServices services() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteServices services(ClusterGroup grp) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public ExecutorService executorService() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public ExecutorService executorService(ClusterGroup grp) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteProductVersion version() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteScheduler scheduler() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> createCache(CacheConfiguration<K, V> cacheCfg) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> createCache(String cacheName) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> getOrCreateCache(CacheConfiguration<K, V> cacheCfg) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> getOrCreateCache(String cacheName) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> void addCacheConfiguration(CacheConfiguration<K, V> cacheCfg) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> createCache(CacheConfiguration<K, V> cacheCfg, NearCacheConfiguration<K, V> nearCfg) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> getOrCreateCache(CacheConfiguration<K, V> cacheCfg, NearCacheConfiguration<K, V> nearCfg) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> createNearCache(@Nullable String cacheName, NearCacheConfiguration<K, V> nearCfg) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> getOrCreateNearCache(@Nullable String cacheName, NearCacheConfiguration<K, V> nearCfg) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @@ -383,7 +383,7 @@ public class IgniteProcessProxy implements IgniteEx { /** {@inheritDoc} */ @Override public <K, V> IgniteCache<K, V> cache(@Nullable final String name) { - return new IgniteCacheProcessProxy(name, this); + return new IgniteCacheProcessProxy<>(name, this); } /** {@inheritDoc} */ @@ -393,61 +393,61 @@ public class IgniteProcessProxy implements IgniteEx { /** {@inheritDoc} */ @Override public <K, V> IgniteDataStreamer<K, V> dataStreamer(@Nullable String cacheName) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteFileSystem fileSystem(String name) { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public Collection<IgniteFileSystem> fileSystems() { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteAtomicSequence atomicSequence(String name, long initVal, boolean create) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteAtomicLong atomicLong(String name, long initVal, boolean create) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T> IgniteAtomicReference<T> atomicReference(String name, @Nullable T initVal, boolean create) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T, S> IgniteAtomicStamped<T, S> atomicStamped(String name, @Nullable T initVal, @Nullable S initStamp, boolean create) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public IgniteCountDownLatch countDownLatch(String name, int cnt, boolean autoDel, boolean create) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T> IgniteQueue<T> queue(String name, int cap, @Nullable CollectionConfiguration cfg) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T> IgniteSet<T> set(String name, @Nullable CollectionConfiguration cfg) throws IgniteException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @Override public <T extends IgnitePlugin> T plugin(String name) throws PluginNotFoundException { - throw new UnsupportedOperationException("Operation doesn't supported yet."); + throw new UnsupportedOperationException("Operation isn't supported yet."); } /** {@inheritDoc} */ @@ -462,7 +462,7 @@ public class IgniteProcessProxy implements IgniteEx { /** {@inheritDoc} */ @Override public <K> Affinity<K> affinity(String cacheName) { - return new AffinityProcessProxy(cacheName, this); + return new AffinityProcessProxy<>(cacheName, this); } /**
