http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample1.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample1.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample1.scala index c9b0539..d89b987 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample1.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample1.scala @@ -59,12 +59,12 @@ object ScalarCacheAffinityExample1 { ('A' to 'Z').foreach(keys :+= _.toString) - populateCache(grid$, keys) + populateCache(ignite, keys) var results = Map.empty[String, String] keys.foreach(key => { - val res = grid$.call$( + val res = ignite.call$( new Callable[String] { @CacheAffinityKeyMapped def affinityKey(): String = key @@ -78,7 +78,7 @@ object ScalarCacheAffinityExample1 { val cache = cache$[String, String](NAME) if (!cache.isDefined) { - println(">>> Cache not found [nodeId=" + grid$.cluster().localNode.id + + println(">>> Cache not found [nodeId=" + ignite.cluster().localNode.id + ", cacheName=" + NAME + ']') "Error"
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample2.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample2.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample2.scala index e12f3bf..3dea5fd 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample2.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample2.scala @@ -53,17 +53,17 @@ object ScalarCacheAffinityExample2 { ('A' to 'Z').foreach(keys :+= _.toString) - populateCache(grid$, keys) + populateCache(ignite, keys) // Map all keys to nodes. - val mappings = grid$.cluster().mapKeysToNodes(NAME, keys) + val mappings = ignite.cluster().mapKeysToNodes(NAME, keys) mappings.foreach(mapping => { val node = mapping._1 val mappedKeys = mapping._2 if (node != null) { - grid$.cluster().forNode(node) *< (() => { + ignite.cluster().forNode(node) *< (() => { breakable { println(">>> Executing affinity job for keys: " + mappedKeys) @@ -73,7 +73,7 @@ object ScalarCacheAffinityExample2 { // If cache is not defined at this point then it means that // job was not routed by affinity. if (!cache.isDefined) - println(">>> Cache not found [nodeId=" + grid$.cluster().localNode().id() + + println(">>> Cache not found [nodeId=" + ignite.cluster().localNode().id() + ", cacheName=" + NAME + ']').^^ // Check cache without loading the value. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala index 12c2f96..f6e12ca 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala @@ -53,7 +53,7 @@ object ScalarCacheAffinitySimpleExample extends App { // Clean up caches on all nodes before run. cache$(NAME).get.globalClearAll(0) - val c = grid$.cache[Int, String](NAME) + val c = ignite.cache[Int, String](NAME) populate(c) visit(c) @@ -67,7 +67,7 @@ object ScalarCacheAffinitySimpleExample extends App { */ private def visit(c: Cache) { (0 until KEY_CNT).foreach(i => - grid$.compute().affinityRun(NAME, i, + ignite.compute().affinityRun(NAME, i, () => println("Co-located [key= " + i + ", value=" + c.peek(i) + ']')) ) } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheExample.scala index 22ab99e..3855269 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheExample.scala @@ -126,7 +126,7 @@ object ScalarCacheExample extends App { * so we can actually see what happens underneath locally and remotely. */ def registerListener() { - val g = grid$ + val g = ignite g *< (() => { val lsnr = new IgnitePredicate[IgniteEvent] { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala index 0605a8c..f239547 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala @@ -36,7 +36,7 @@ import scala.util.Random * start node with `examples/config/example-cache.xml` configuration. * <p> * The counts are kept in cache on all remote nodes. Top `10` counts from each node are then grabbed to produce - * an overall top `10` list within the grid. + * an overall top `10` list within the ignite. */ object ScalarCachePopularNumbersExample extends App { /** Cache name. */ @@ -58,7 +58,7 @@ object ScalarCachePopularNumbersExample extends App { println() println(">>> Cache popular numbers example started.") - val prj = grid$.cluster().forCache(CACHE_NAME) + val prj = ignite.cluster().forCache(CACHE_NAME) if (prj.nodes().isEmpty) println("Grid does not have cache configured: " + CACHE_NAME); @@ -75,7 +75,7 @@ object ScalarCachePopularNumbersExample extends App { query(POPULAR_NUMBERS_CNT) // Clean up caches on all nodes after run. - grid$.cluster().forCache(CACHE_NAME).bcastRun(() => grid$.cache(CACHE_NAME).clearAll(), null) + ignite.cluster().forCache(CACHE_NAME).bcastRun(() => ignite.cache(CACHE_NAME).clearAll(), null) } finally { popularNumbersQryTimer.cancel() http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheQueryExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheQueryExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheQueryExample.scala index 61347c3..108c415 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheQueryExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheQueryExample.scala @@ -45,7 +45,7 @@ object ScalarCacheQueryExample { */ def main(args: Array[String]) { scalar("examples/config/example-cache.xml") { - example(grid$) + example(ignite) } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarClosureExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarClosureExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarClosureExample.scala index fc4b46b..4b37ea0 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarClosureExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarClosureExample.scala @@ -41,7 +41,7 @@ object ScalarClosureExample extends App { * Prints grid topology. */ def topology() { - grid$ foreach (n => println("Node: " + nid8$(n))) + ignite foreach (n => println("Node: " + nid8$(n))) } /** @@ -51,31 +51,31 @@ object ScalarClosureExample extends App { // Notice the example usage of Java-side closure 'F.println(...)' and method 'scala' // that explicitly converts Java side object to a proper Scala counterpart. // This method is required since implicit conversion won't be applied here. - grid$.run$(for (w <- "Hello World!".split(" ")) yield () => println(w), null) + ignite.run$(for (w <- "Hello World!".split(" ")) yield () => println(w), null) } /** * Obligatory example - cloud enabled Hello World! */ def helloWorld() { - grid$.run$("HELLO WORLD!".split(" ") map (w => () => println(w)), null) + ignite.run$("HELLO WORLD!".split(" ") map (w => () => println(w)), null) } /** * One way to execute closures on the grid. */ def broadcast() { - grid$.bcastRun(() => println("Broadcasting!!!"), null) + ignite.bcastRun(() => println("Broadcasting!!!"), null) } /** * Greats all remote nodes only. */ def greetRemotes() { - val me = grid$.cluster().localNode.id + val me = ignite.cluster().localNode.id // Note that usage Java-based closure. - grid$.cluster().forRemotes() match { + ignite.cluster().forRemotes() match { case p if p.isEmpty => println("No remote nodes!") case p => p.bcastRun(() => println("Greetings from: " + me), null) } @@ -85,11 +85,11 @@ object ScalarClosureExample extends App { * Same as previous greetings for all remote nodes but remote projection is created manually. */ def greetRemotesAgain() { - val me = grid$.cluster().localNode.id + val me = ignite.cluster().localNode.id // Just show that we can create any projections we like... // Note that usage of Java-based closure via 'F' typedef. - grid$.cluster().forPredicate((n: ClusterNode) => n.id != me) match { + ignite.cluster().forPredicate((n: ClusterNode) => n.id != me) match { case p if p.isEmpty => println("No remote nodes!") case p => p.bcastRun(() => println("Greetings again from: " + me), null) } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala index 1c1dc46..85dd07e 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarContinuationExample.scala @@ -48,21 +48,21 @@ object ScalarContinuationExample { // Calculate fibonacci for N. val N: Long = 100 - val thisNode = grid$.cluster().localNode + val thisNode = ignite.cluster().localNode val start = System.currentTimeMillis // Projection that excludes this node if others exists. - val prj = if (grid$.cluster().nodes().size() > 1) grid$.cluster().forOthers(thisNode) else grid$.cluster().forNode(thisNode) + val prj = if (ignite.cluster().nodes().size() > 1) ignite.cluster().forOthers(thisNode) else ignite.cluster().forNode(thisNode) - val fib = grid$.compute(prj).apply(new FibonacciClosure(thisNode.id()), N) + val fib = ignite.compute(prj).apply(new FibonacciClosure(thisNode.id()), N) val duration = System.currentTimeMillis - start println(">>>") println(">>> Finished executing Fibonacci for '" + N + "' in " + duration + " ms.") println(">>> Fibonacci sequence for input number '" + N + "' is '" + fib + "'.") - println(">>> You should see prints out every recursive Fibonacci execution on grid nodes.") + println(">>> You should see prints out every recursive Fibonacci execution on cluster nodes.") println(">>> Check remote nodes for output.") println(">>>") } @@ -95,7 +95,7 @@ class FibonacciClosure ( // Make sure n is not negative. val n = math.abs(num) - val g = grid$ + val g = ignite if (n <= 2) return if (n == 0) @@ -110,12 +110,12 @@ class FibonacciClosure ( fut1 = store.get(n - 1) fut2 = store.get(n - 2) - val excludeNode = grid$.cluster().node(excludeNodeId) + val excludeNode = ignite.cluster().node(excludeNodeId) // Projection that excludes node with id passed in constructor if others exists. - val prj = if (grid$.cluster().nodes().size() > 1) grid$.cluster().forOthers(excludeNode) else grid$.cluster().forNode(excludeNode) + val prj = if (ignite.cluster().nodes().size() > 1) ignite.cluster().forOthers(excludeNode) else ignite.cluster().forNode(excludeNode) - val comp = grid$.compute(prj).withAsync() + val comp = ignite.compute(prj).withAsync() // If future is not cached in node-local store, cache it. // Note recursive grid execution! http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala index 65393f7..18b1fb3 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala @@ -62,10 +62,10 @@ object ScalarCreditRiskExample { // Calculate credit risk and print it out. // As you can see the grid enabling is completely hidden from the caller // and it is fully transparent to him. In fact, the caller is never directly - // aware if method was executed just locally or on the 100s of grid nodes. + // aware if method was executed just locally or on the 100s of cluster nodes. // Credit risk crdRisk is the minimal amount that creditor has to have // available to cover possible defaults. - val crdRisk = grid$ @< (closures(grid$.cluster().nodes().size(), portfolio, horizon, iter, percentile), + val crdRisk = ignite @< (closures(ignite.cluster().nodes().size(), portfolio, horizon, iter, percentile), (s: Seq[Double]) => s.sum / s.size, null) println("Credit risk [crdRisk=" + crdRisk + ", duration=" + http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPiCalculationExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPiCalculationExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPiCalculationExample.scala index 12b72b7..44244ac 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPiCalculationExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPiCalculationExample.scala @@ -36,9 +36,9 @@ object ScalarPiCalculationExample { def main(args: Array[String]) { scalar("examples/config/example-compute.xml") { - val jobs = for (i <- 0 until grid$.cluster().nodes().size()) yield () => calcPi(i * N) + val jobs = for (i <- 0 until ignite.cluster().nodes().size()) yield () => calcPi(i * N) - println("Pi estimate: " + grid$.reduce$[Double, Double](jobs, _.sum, null)) + println("Pi estimate: " + ignite.reduce$[Double, Double](jobs, _.sum, null)) } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPingPongExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPingPongExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPingPongExample.scala index dbdd9e0..8eb0d8e 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPingPongExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPingPongExample.scala @@ -41,7 +41,7 @@ object ScalarPingPongExample extends App { * Implements Ping Pong example between local and remote node. */ def pingPong() { - val g = grid$ + val g = ignite if (g.cluster().nodes().size < 2) { println(">>>") @@ -71,7 +71,7 @@ object ScalarPingPongExample extends App { // Set up local player: configure local node 'loc' // to listen for messages from remote node 'rmt'. - grid$.message().localListen(null, new MessagingListenActor[String]() { + ignite.message().localListen(null, new MessagingListenActor[String]() { def receive(nodeId: UUID, msg: String) { println(msg) @@ -96,7 +96,7 @@ object ScalarPingPongExample extends App { * Implements Ping Pong example between two remote nodes. */ def pingPong2() { - val g = grid$ + val g = ignite if (g.cluster().forRemotes().nodes().size() < 2) { println(">>>") http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPrimeExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPrimeExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPrimeExample.scala index 3a29101..25af7d7 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPrimeExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarPrimeExample.scala @@ -39,7 +39,7 @@ import scala.util.control.Breaks._ * output). * * Note that when running this example on a multi-core box, simply - * starting additional grid node on the same box will speed up + * starting additional cluster node on the same box will speed up * prime number calculation by a factor of 2. */ object ScalarPrimeExample { @@ -58,7 +58,7 @@ object ScalarPrimeExample { println(">>>") println(">>> Starting to check the following numbers for primes: " + util.Arrays.toString(checkVals)) - val g = grid$ + val g = ignite checkVals.foreach(checkVal => { val divisor = g.reduce$[Option[Long], Option[Option[Long]]]( http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarScheduleExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarScheduleExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarScheduleExample.scala index 299bc0f..05fec2c 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarScheduleExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarScheduleExample.scala @@ -22,7 +22,7 @@ import org.apache.ignite.scalar.scalar._ /** * Demonstrates a cron-based `Runnable` execution scheduling. - * Test runnable object broadcasts a phrase to all grid nodes every minute + * Test runnable object broadcasts a phrase to all cluster nodes every minute * three times with initial scheduling delay equal to five seconds. * <p> * Remote nodes should always be started with special configuration file which @@ -33,12 +33,12 @@ object ScalarScheduleExample extends App { println() println("Compute schedule example started.") - val g = grid$ + val g = ignite var invocations = 0 // Schedule callable that returns incremented value each time. - val fut = grid$.scheduleLocalCall( + val fut = ignite.scheduleLocalCall( () => { invocations += 1 http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarSnowflakeSchemaExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarSnowflakeSchemaExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarSnowflakeSchemaExample.scala index 87317d0..21c2b95 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarSnowflakeSchemaExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarSnowflakeSchemaExample.scala @@ -77,7 +77,7 @@ object ScalarSnowflakeSchemaExample { * `DimStore` and `DimProduct` instances. */ def populateDimensions() { - val dimCache = grid$.jcache[Int, Object](REPL_CACHE_NAME) + val dimCache = ignite.jcache[Int, Object](REPL_CACHE_NAME) val store1 = new DimStore(idGen.next(), "Store1", "12345", "321 Chilly Dr, NY") val store2 = new DimStore(idGen.next(), "Store2", "54321", "123 Windy Dr, San Francisco") @@ -99,7 +99,7 @@ object ScalarSnowflakeSchemaExample { * `FactPurchase` objects stored in `partitioned` cache. */ def queryStorePurchases() { - val factCache = grid$.cache[Int, FactPurchase](PART_CACHE_NAME) + val factCache = ignite.cache[Int, FactPurchase](PART_CACHE_NAME) val storePurchases = factCache.sql( "from \"replicated\".DimStore, \"partitioned\".FactPurchase " + @@ -115,8 +115,8 @@ object ScalarSnowflakeSchemaExample { * stored in `partitioned` cache. */ private def queryProductPurchases() { - val dimCache = grid$.cache[Int, Object](REPL_CACHE_NAME) - val factCache = grid$.cache[Int, FactPurchase](PART_CACHE_NAME) + val dimCache = ignite.cache[Int, Object](REPL_CACHE_NAME) + val factCache = ignite.cache[Int, FactPurchase](PART_CACHE_NAME) val prods: CacheProjection[Int, DimProduct] = dimCache.viewByType(classOf[Int], classOf[DimProduct]) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarTaskExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarTaskExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarTaskExample.scala index fd63601..eac3efd 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarTaskExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarTaskExample.scala @@ -36,7 +36,7 @@ import scala.collection.JavaConversions._ */ object ScalarTaskExample extends App { scalar("examples/config/example-compute.xml") { - grid$.compute().execute(classOf[GridHelloWorld], "Hello Cloud World!") + ignite.compute().execute(classOf[GridHelloWorld], "Hello Cloud World!") } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarWorldShortestMapReduce.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarWorldShortestMapReduce.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarWorldShortestMapReduce.scala index 8d73cda..ce577ad 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarWorldShortestMapReduce.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarWorldShortestMapReduce.scala @@ -33,7 +33,7 @@ object ScalarWorldShortestMapReduce extends App { val input = "World shortest mapreduce application" println("Non-space characters count: " + - grid$.reduce$[Int, Int](for (w <- input.split(" ")) yield () => w.length, _.sum, null) + ignite.reduce$[Int, Int](for (w <- input.split(" ")) yield () => w.length, _.sum, null) ) } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/BasicExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/BasicExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/BasicExamplesMultiNodeSelfTest.java new file mode 100644 index 0000000..f2ce6fe --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/BasicExamplesMultiNodeSelfTest.java @@ -0,0 +1,28 @@ +/* + * 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.examples; + +/** + * Closure examples multi-node self test. + */ +public class BasicExamplesMultiNodeSelfTest extends BasicExamplesSelfTest { + /** {@inheritDoc} */ + @Override protected void beforeTest() throws Exception { + startRemoteNodes(); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/BasicExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/BasicExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/BasicExamplesSelfTest.java new file mode 100644 index 0000000..e95b0cc --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/BasicExamplesSelfTest.java @@ -0,0 +1,82 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.compute.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * Closure examples self test. + */ +public class BasicExamplesSelfTest extends AbstractExamplesTest { + /** + * @throws Exception If failed. + */ + public void testBroadcastExample() throws Exception { + ComputeBroadcastExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCallableExample() throws Exception { + ComputeCallableExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testClosureExample() throws Exception { + ComputeClosureExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testExecutorExample() throws Exception { + ComputeExecutorServiceExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testReducerExample() throws Exception { + ComputeReducerExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testRunnableExample() throws Exception { + ComputeRunnableExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testTaskMapExample() throws Exception { + ComputeTaskMapExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testTaskSplitExample() throws Exception { + ComputeTaskSplitExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/CacheExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/CacheExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/CacheExamplesMultiNodeSelfTest.java new file mode 100644 index 0000000..27bac02 --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/CacheExamplesMultiNodeSelfTest.java @@ -0,0 +1,48 @@ +/* + * 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.examples; + +/** + * Cache examples multi-node self test. + */ +public class CacheExamplesMultiNodeSelfTest extends CacheExamplesSelfTest { + /** {@inheritDoc} */ + @Override protected String defaultConfig() { + return "examples/config/example-cache.xml"; + } + + /** {@inheritDoc} */ + @Override protected void beforeTest() throws Exception { + startRemoteNodes(); + } + + /** {@inheritDoc} */ + @Override protected long getTestTimeout() { + return 10 * 60 * 1000; + } + + /** {@inheritDoc} */ + @Override public void testCacheStoreExample() throws Exception { + // No-op. + } + + /** {@inheritDoc} */ + @Override public void testCacheStoreLoaderExample() throws Exception { + // No-op. + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/CacheExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/CacheExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/CacheExamplesSelfTest.java new file mode 100644 index 0000000..f541390 --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/CacheExamplesSelfTest.java @@ -0,0 +1,155 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.datagrid.*; +import org.apache.ignite.examples.datagrid.datastructures.*; +import org.apache.ignite.examples.datagrid.starschema.*; +import org.apache.ignite.examples.datagrid.store.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * Cache examples self test. + */ +public class CacheExamplesSelfTest extends AbstractExamplesTest { + /** + * @throws Exception If failed. + */ + public void testCacheAffinityExample() throws Exception { + CacheAffinityExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheAtomicLongExample() throws Exception { + CacheAtomicLongExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheAtomicReferenceExample() throws Exception { + CacheAtomicReferenceExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheAtomicSequenceExample() throws Exception { + CacheAtomicSequenceExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheAtomicStampedExample() throws Exception { + CacheAtomicStampedExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheCountDownLatchExample() throws Exception { + CacheCountDownLatchExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheQueueExample() throws Exception { + CacheQueueExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheSetExample() throws Exception { + CacheSetExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheStoreExample() throws Exception { + CacheStoreExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheQueryExample() throws Exception { + CacheQueryExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheApiExample() throws Exception { + CacheApiExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheTransactionExample() throws Exception { + CacheTransactionExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheDataLoaderExample() throws Exception { + CacheDataLoaderExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testPopularNumbersRealTimeExample() throws Exception { + CachePopularNumbersExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheStoreLoaderExample() throws Exception { + CacheStoreLoadDataExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCachePutGetExample() throws Exception { + CachePutGetExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testSnowflakeSchemaExample() throws Exception { + CacheStarSchemaExample.main(EMPTY_ARGS); + } + + /** + * @throws Exception If failed. + */ + public void testCacheContinuousQueryExample() throws Exception { + CacheContinuousQueryExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/CacheStoreLoadDataExampleMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/CacheStoreLoadDataExampleMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/CacheStoreLoadDataExampleMultiNodeSelfTest.java new file mode 100644 index 0000000..dc160c9 --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/CacheStoreLoadDataExampleMultiNodeSelfTest.java @@ -0,0 +1,39 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.datagrid.store.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * + */ +public class CacheStoreLoadDataExampleMultiNodeSelfTest extends AbstractExamplesTest { + /** {@inheritDoc} */ + @Override protected void beforeTest() throws Exception { + for (int i = 0; i < RMT_NODES_CNT; i++) + startGrid("node-" + i, CacheNodeWithStoreStartup.configure()); + } + + /** + * @throws Exception If failed. + */ + public void testGridCacheStoreLoaderExample() throws Exception { + CacheStoreLoadDataExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/CheckpointExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/CheckpointExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/CheckpointExamplesSelfTest.java new file mode 100644 index 0000000..54e3c22 --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/CheckpointExamplesSelfTest.java @@ -0,0 +1,45 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.compute.failover.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * Checkpoint examples self test. + */ +public class CheckpointExamplesSelfTest extends AbstractExamplesTest { + /** + * Starts remote nodes before each test. + * + * Note: using beforeTestsStarted() to start nodes only once won't work. + * + * @throws Exception If remote nodes start failed. + */ + @Override protected void beforeTest() throws Exception { + for (int i = 0; i < RMT_NODES_CNT; i++) + startGrid("node-" + i, ComputeFailoverNodeStartup.configuration()); + } + + /** + * @throws Exception If failed. + */ + public void testGridCheckpointExample() throws Exception { + ComputeFailoverExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesMultiNodeSelfTest.java new file mode 100644 index 0000000..8b0d305 --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesMultiNodeSelfTest.java @@ -0,0 +1,28 @@ +/* + * 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.examples; + +/** + * Continuation example multi-node self test. + */ +public class ContinuationExamplesMultiNodeSelfTest extends ContinuationExamplesSelfTest { + /** {@inheritDoc} */ + @Override protected void beforeTest() throws Exception { + startRemoteNodes(); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesSelfTest.java new file mode 100644 index 0000000..48ca73e --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/ContinuationExamplesSelfTest.java @@ -0,0 +1,33 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.compute.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * Continuation example self test. + */ +public class ContinuationExamplesSelfTest extends AbstractExamplesTest { + /** + * @throws Exception If failed. + */ + public void testGridContinuationExample() throws Exception { + ComputeFibonacciContinuationExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesMultiNodeSelfTest.java new file mode 100644 index 0000000..59bc10d --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesMultiNodeSelfTest.java @@ -0,0 +1,28 @@ +/* + * 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.examples; + +/** + * GridContinuousMapperExample multi-node self test. + */ +public class ContinuousMapperExamplesMultiNodeSelfTest extends ContinuationExamplesSelfTest { + /** {@inheritDoc} */ + @Override protected void beforeTest() throws Exception { + startRemoteNodes(); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesSelfTest.java new file mode 100644 index 0000000..cbb79d6 --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/ContinuousMapperExamplesSelfTest.java @@ -0,0 +1,33 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.compute.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * GridContinuousMapperExample self test. + */ +public class ContinuousMapperExamplesSelfTest extends AbstractExamplesTest { + /** + * @throws Exception If failed. + */ + public void testGridContinuousMapperExample() throws Exception { + ComputeContinuousMapperExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesMultiNodeSelfTest.java new file mode 100644 index 0000000..7141d4c --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesMultiNodeSelfTest.java @@ -0,0 +1,30 @@ +/* + * 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.examples; + +/** + * Deployment examples multi-node self test. + */ +public class DeploymentExamplesMultiNodeSelfTest extends DeploymentExamplesSelfTest { + /** {@inheritDoc} */ + @Override public void testGridDeploymentExample() throws Exception { + startRemoteNodes(); + + super.testGridDeploymentExample(); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesSelfTest.java new file mode 100644 index 0000000..8fd4da0 --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/DeploymentExamplesSelfTest.java @@ -0,0 +1,33 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.misc.deployment.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * Deployment examples self test. + */ +public class DeploymentExamplesSelfTest extends AbstractExamplesTest { + /** + * @throws Exception If failed. + */ + public void testGridDeploymentExample() throws Exception { + DeploymentExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/EventsExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/EventsExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/EventsExamplesMultiNodeSelfTest.java new file mode 100644 index 0000000..8ce2aad --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/EventsExamplesMultiNodeSelfTest.java @@ -0,0 +1,28 @@ +/* + * 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.examples; + +/** + * Events examples multi-node self test. + */ +public class EventsExamplesMultiNodeSelfTest extends EventsExamplesSelfTest { + /** {@inheritDoc} */ + @Override protected void beforeTest() throws Exception { + startRemoteNodes(); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/EventsExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/EventsExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/EventsExamplesSelfTest.java new file mode 100644 index 0000000..55341ba --- /dev/null +++ b/examples/src/test/java/org/apache/ignite/examples/EventsExamplesSelfTest.java @@ -0,0 +1,33 @@ +/* + * 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.examples; + +import org.apache.ignite.examples.events.*; +import org.apache.ignite.testframework.junits.common.*; + +/** + * Events examples self test. + */ +public class EventsExamplesSelfTest extends AbstractExamplesTest { + /** + * @throws Exception If failed. + */ + public void testGridEventsExample() throws Exception { + EventsExample.main(EMPTY_ARGS); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesMultiNodeSelfTest.java deleted file mode 100644 index 191018e..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesMultiNodeSelfTest.java +++ /dev/null @@ -1,28 +0,0 @@ -/* - * 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.examples; - -/** - * Closure examples multi-node self test. - */ -public class GridBasicExamplesMultiNodeSelfTest extends GridBasicExamplesSelfTest { - /** {@inheritDoc} */ - @Override protected void beforeTest() throws Exception { - startRemoteNodes(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesSelfTest.java deleted file mode 100644 index 4e4a3e6..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridBasicExamplesSelfTest.java +++ /dev/null @@ -1,82 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.compute.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * Closure examples self test. - */ -public class GridBasicExamplesSelfTest extends GridAbstractExamplesTest { - /** - * @throws Exception If failed. - */ - public void testGridBroadcastExample() throws Exception { - ComputeBroadcastExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCallableExample() throws Exception { - ComputeCallableExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridClosureExample() throws Exception { - ComputeClosureExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridExecutorExample() throws Exception { - ComputeExecutorServiceExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridReducerExample() throws Exception { - ComputeReducerExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridRunnableExample() throws Exception { - ComputeRunnableExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridTaskMapExample() throws Exception { - ComputeTaskMapExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridTaskSplitExample() throws Exception { - ComputeTaskSplitExample.main(EMPTY_ARGS); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesMultiNodeSelfTest.java deleted file mode 100644 index 71621e2..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesMultiNodeSelfTest.java +++ /dev/null @@ -1,48 +0,0 @@ -/* - * 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.examples; - -/** - * Cache examples multi-node self test. - */ -public class GridCacheExamplesMultiNodeSelfTest extends GridCacheExamplesSelfTest { - /** {@inheritDoc} */ - @Override protected String defaultConfig() { - return "examples/config/example-cache.xml"; - } - - /** {@inheritDoc} */ - @Override protected void beforeTest() throws Exception { - startRemoteNodes(); - } - - /** {@inheritDoc} */ - @Override protected long getTestTimeout() { - return 10 * 60 * 1000; - } - - /** {@inheritDoc} */ - @Override public void testGridCacheStoreExample() throws Exception { - // No-op. - } - - /** {@inheritDoc} */ - @Override public void testGridCacheStoreLoaderExample() throws Exception { - // No-op. - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesSelfTest.java deleted file mode 100644 index 129b8a5..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridCacheExamplesSelfTest.java +++ /dev/null @@ -1,155 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.datagrid.*; -import org.apache.ignite.examples.datagrid.datastructures.*; -import org.apache.ignite.examples.datagrid.starschema.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * Cache examples self test. - */ -public class GridCacheExamplesSelfTest extends GridAbstractExamplesTest { - /** - * @throws Exception If failed. - */ - public void testGridCacheAffinityExample() throws Exception { - CacheAffinityExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheAtomicLongExample() throws Exception { - CacheAtomicLongExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheAtomicReferenceExample() throws Exception { - CacheAtomicReferenceExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheAtomicSequenceExample() throws Exception { - CacheAtomicSequenceExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheAtomicStampedExample() throws Exception { - CacheAtomicStampedExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheCountDownLatchExample() throws Exception { - CacheCountDownLatchExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheQueueExample() throws Exception { - CacheQueueExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheSetExample() throws Exception { - CacheSetExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheStoreExample() throws Exception { - CacheStoreExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheQueryExample() throws Exception { - CacheQueryExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheApiExample() throws Exception { - CacheApiExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheTransactionExample() throws Exception { - CacheTransactionExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheDataLoaderExample() throws Exception { - CacheDataLoaderExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridPopularNumbersRealTimeExample() throws Exception { - CachePopularNumbersExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheStoreLoaderExample() throws Exception { - CacheStoreLoadDataExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCachePutGetExample() throws Exception { - CachePutGetExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridSnowflakeSchemaExample() throws Exception { - CacheStarSchemaExample.main(EMPTY_ARGS); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheContinuousQueryExample() throws Exception { - CacheContinuousQueryExample.main(EMPTY_ARGS); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridCacheStoreLoadDataExampleMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridCacheStoreLoadDataExampleMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridCacheStoreLoadDataExampleMultiNodeSelfTest.java deleted file mode 100644 index 5edea86..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridCacheStoreLoadDataExampleMultiNodeSelfTest.java +++ /dev/null @@ -1,39 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * - */ -public class GridCacheStoreLoadDataExampleMultiNodeSelfTest extends GridAbstractExamplesTest { - /** {@inheritDoc} */ - @Override protected void beforeTest() throws Exception { - for (int i = 0; i < RMT_NODES_CNT; i++) - startGrid("node-" + i, CacheNodeWithStoreStartup.configure()); - } - - /** - * @throws Exception If failed. - */ - public void testGridCacheStoreLoaderExample() throws Exception { - CacheStoreLoadDataExample.main(EMPTY_ARGS); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridCheckpointExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridCheckpointExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridCheckpointExamplesSelfTest.java deleted file mode 100644 index 228b30f..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridCheckpointExamplesSelfTest.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.compute.failover.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * Checkpoint examples self test. - */ -public class GridCheckpointExamplesSelfTest extends GridAbstractExamplesTest { - /** - * Starts remote nodes before each test. - * - * Note: using beforeTestsStarted() to start nodes only once won't work. - * - * @throws Exception If remote nodes start failed. - */ - @Override protected void beforeTest() throws Exception { - for (int i = 0; i < RMT_NODES_CNT; i++) - startGrid("node-" + i, ComputeFailoverNodeStartup.configuration()); - } - - /** - * @throws Exception If failed. - */ - public void testGridCheckpointExample() throws Exception { - ComputeFailoverExample.main(EMPTY_ARGS); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesMultiNodeSelfTest.java deleted file mode 100644 index f97ccac..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesMultiNodeSelfTest.java +++ /dev/null @@ -1,28 +0,0 @@ -/* - * 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.examples; - -/** - * Continuation example multi-node self test. - */ -public class GridContinuationExamplesMultiNodeSelfTest extends GridContinuationExamplesSelfTest { - /** {@inheritDoc} */ - @Override protected void beforeTest() throws Exception { - startRemoteNodes(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesSelfTest.java deleted file mode 100644 index 165d640..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridContinuationExamplesSelfTest.java +++ /dev/null @@ -1,33 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.compute.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * Continuation example self test. - */ -public class GridContinuationExamplesSelfTest extends GridAbstractExamplesTest { - /** - * @throws Exception If failed. - */ - public void testGridContinuationExample() throws Exception { - ComputeFibonacciContinuationExample.main(EMPTY_ARGS); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesMultiNodeSelfTest.java deleted file mode 100644 index 2a549c1..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesMultiNodeSelfTest.java +++ /dev/null @@ -1,28 +0,0 @@ -/* - * 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.examples; - -/** - * GridContinuousMapperExample multi-node self test. - */ -public class GridContinuousMapperExamplesMultiNodeSelfTest extends GridContinuationExamplesSelfTest { - /** {@inheritDoc} */ - @Override protected void beforeTest() throws Exception { - startRemoteNodes(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesSelfTest.java deleted file mode 100644 index babf8ea..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridContinuousMapperExamplesSelfTest.java +++ /dev/null @@ -1,33 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.compute.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * GridContinuousMapperExample self test. - */ -public class GridContinuousMapperExamplesSelfTest extends GridAbstractExamplesTest { - /** - * @throws Exception If failed. - */ - public void testGridContinuousMapperExample() throws Exception { - ComputeContinuousMapperExample.main(EMPTY_ARGS); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesMultiNodeSelfTest.java deleted file mode 100644 index 265d44d..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesMultiNodeSelfTest.java +++ /dev/null @@ -1,30 +0,0 @@ -/* - * 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.examples; - -/** - * Deployment examples multi-node self test. - */ -public class GridDeploymentExamplesMultiNodeSelfTest extends GridDeploymentExamplesSelfTest { - /** {@inheritDoc} */ - @Override public void testGridDeploymentExample() throws Exception { - startRemoteNodes(); - - super.testGridDeploymentExample(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesSelfTest.java deleted file mode 100644 index cdade73..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridDeploymentExamplesSelfTest.java +++ /dev/null @@ -1,33 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.misc.deployment.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * Deployment examples self test. - */ -public class GridDeploymentExamplesSelfTest extends GridAbstractExamplesTest { - /** - * @throws Exception If failed. - */ - public void testGridDeploymentExample() throws Exception { - DeploymentExample.main(EMPTY_ARGS); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesMultiNodeSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesMultiNodeSelfTest.java deleted file mode 100644 index e2cb5f7..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesMultiNodeSelfTest.java +++ /dev/null @@ -1,28 +0,0 @@ -/* - * 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.examples; - -/** - * Events examples multi-node self test. - */ -public class GridEventsExamplesMultiNodeSelfTest extends GridEventsExamplesSelfTest { - /** {@inheritDoc} */ - @Override protected void beforeTest() throws Exception { - startRemoteNodes(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/921fd0c7/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesSelfTest.java ---------------------------------------------------------------------- diff --git a/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesSelfTest.java b/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesSelfTest.java deleted file mode 100644 index f159f1a..0000000 --- a/examples/src/test/java/org/apache/ignite/examples/GridEventsExamplesSelfTest.java +++ /dev/null @@ -1,33 +0,0 @@ -/* - * 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.examples; - -import org.apache.ignite.examples.events.*; -import org.apache.ignite.testframework.junits.common.*; - -/** - * Events examples self test. - */ -public class GridEventsExamplesSelfTest extends GridAbstractExamplesTest { - /** - * @throws Exception If failed. - */ - public void testGridEventsExample() throws Exception { - EventsExample.main(EMPTY_ARGS); - } -}
