Repository: incubator-ignite Updated Branches: refs/heads/ignite-389 389ec79df -> 7439b5b7d
IGNITE-389 - WIP Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/520cd035 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/520cd035 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/520cd035 Branch: refs/heads/ignite-389 Commit: 520cd035c16bd09ed67b940cc1f28ac331b94a97 Parents: 389ec79 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Wed May 20 16:42:44 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Wed May 20 16:42:44 2015 -0700 ---------------------------------------------------------------------- .../cache/IgniteDynamicCacheStartSelfTest.java | 23 ++++++++++++++++++++ .../spark/examples/IgniteProcessExample.scala | 6 ++--- 2 files changed, 26 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/520cd035/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartSelfTest.java index 72b76d7..adece63 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicCacheStartSelfTest.java @@ -792,6 +792,29 @@ public class IgniteDynamicCacheStartSelfTest extends GridCommonAbstractTest { /** * @throws Exception If failed. */ + public void testGetOrCreateMultiNodeTemplate() throws Exception { + for (int i = 0; i < 100; i++) { + info(">>> Iteration " + i); + + final AtomicInteger idx = new AtomicInteger(); + + GridTestUtils.runMultiThreaded(new Callable<Object>() { + @Override public Object call() throws Exception { + int idx0 = idx.getAndIncrement(); + + ignite(idx0 % nodeCount()).getOrCreateCache(DYNAMIC_CACHE_NAME); + + return null; + } + }, nodeCount() * 4, "runner"); + + ignite(0).destroyCache(DYNAMIC_CACHE_NAME); + } + } + + /** + * @throws Exception If failed. + */ public void testGetOrCreateNearOnlyMultiNode() throws Exception { checkGetOrCreateNear(true); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/520cd035/modules/spark/src/main/scala/org/apache/ignite/spark/examples/IgniteProcessExample.scala ---------------------------------------------------------------------- diff --git a/modules/spark/src/main/scala/org/apache/ignite/spark/examples/IgniteProcessExample.scala b/modules/spark/src/main/scala/org/apache/ignite/spark/examples/IgniteProcessExample.scala index 4aeecb0..3932a26 100644 --- a/modules/spark/src/main/scala/org/apache/ignite/spark/examples/IgniteProcessExample.scala +++ b/modules/spark/src/main/scala/org/apache/ignite/spark/examples/IgniteProcessExample.scala @@ -28,9 +28,9 @@ object IgniteProcessExample { val partitioned = new IgniteContext[Object, String](sc, ExampleConfiguration.configuration _, "partitioned") // Search for lines containing "Ignite". - val scan = partitioned.scan((k, v) => v.contains("Ignite")) + val scanRdd = partitioned.scan((k, v) => v.contains("Ignite")) - val processed = scan.filter(line => { + val processedRdd = scanRdd.filter(line => { println("Analyzing line: " + line) true @@ -39,6 +39,6 @@ object IgniteProcessExample { // Create a new cache for results. val results = new IgniteContext[Object, String](sc, ExampleConfiguration.configuration _, "results") - results.saveToIgnite(processed) + results.saveToIgnite(processedRdd) } } \ No newline at end of file
