# ignite-648: iterator
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/dc674a10 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/dc674a10 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/dc674a10 Branch: refs/heads/ignite-648 Commit: dc674a10e87108206f0ec46dd7f6f8445168d383 Parents: 9cdd165 Author: ashutak <ashu...@gridgain.com> Authored: Mon Jun 22 17:23:23 2015 +0300 Committer: ashutak <ashu...@gridgain.com> Committed: Mon Jun 22 17:23:23 2015 +0300 ---------------------------------------------------------------------- .../cache/GridCacheAbstractFullApiSelfTest.java | 2 +- .../multijvm/framework/IgniteCacheProcessProxy.java | 15 +++++++++++++-- 2 files changed, 14 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dc674a10/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java index 292773c..75cba54 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java @@ -164,7 +164,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract for (Map.Entry<String, CacheConfiguration[]> entry : cacheCfgMap.entrySet()) { Ignite ignite; - + ignite = IgnitionEx.grid(entry.getKey()); for (CacheConfiguration cfg : entry.getValue()) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dc674a10/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java index 6e09286..61cbdc3 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java @@ -501,7 +501,7 @@ public class IgniteCacheProcessProxy<K, V> implements IgniteCache<K, V> { /** {@inheritDoc} */ @Override public <T> T unwrap(final Class<T> clazz) { - throw new UnsupportedOperationException("Method cannot be supported because T can be unmarshalliable."); + throw new UnsupportedOperationException("Method cannot be supported because T can be unmarshallable."); } /** {@inheritDoc} */ @@ -516,7 +516,18 @@ public class IgniteCacheProcessProxy<K, V> implements IgniteCache<K, V> { /** {@inheritDoc} */ @Override public Iterator<Entry<K, V>> iterator() { - throw new UnsupportedOperationException("Method should be supported."); + final Collection<Entry<K, V>> col = (Collection<Entry<K, V>>)compute.call(new IgniteCallable<Object>() { + @Override public Object call() throws Exception { + Collection res = new ArrayList(); + + for (Object o : cache()) + res.add(o); + + return res; + } + }); + + return col.iterator(); } /** {@inheritDoc} */
