You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/02/02 13:13:48 UTC
[3/3] incubator-ignite git commit: #IGNITE-106: Remove word GridGain
from examples.
#IGNITE-106: Remove word GridGain from examples.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/a234cdda
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/a234cdda
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/a234cdda
Branch: refs/heads/ignite-106
Commit: a234cdda168bdc9f8d4ededf360131da8ab6b3ec
Parents: b4a4f1b
Author: ivasilinets <iv...@gridgain.com>
Authored: Mon Feb 2 15:13:36 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Mon Feb 2 15:13:36 2015 +0300
----------------------------------------------------------------------
examples/config/example-cache.xml | 10 ++---
examples/config/example-compute.xml | 2 +-
examples/config/example-streamer.xml | 16 ++++----
examples/config/filesystem/core-site.xml | 2 +-
examples/config/filesystem/example-ggfs.xml | 12 +++---
.../hibernate/example-hibernate-L2-cache.xml | 2 +-
examples/config/servlet/WEB-INF/web.xml | 2 +-
examples/rest/http-rest-example.php | 6 +--
examples/rest/memcache-rest-example.php | 4 +-
.../apache/ignite/examples/ExamplesUtils.java | 2 +-
.../compute/ComputeBroadcastExample.java | 24 ++++++------
.../compute/ComputeCallableExample.java | 6 +--
.../examples/compute/ComputeClosureExample.java | 10 ++---
.../compute/ComputeContinuousMapperExample.java | 8 ++--
.../compute/ComputeExecutorServiceExample.java | 8 ++--
.../ComputeFibonacciContinuationExample.java | 22 +++++------
.../compute/ComputeProjectionExample.java | 9 ++---
.../examples/compute/ComputeReducerExample.java | 12 +++---
.../compute/ComputeRunnableExample.java | 6 +--
.../compute/ComputeScheduleExample.java | 8 ++--
.../examples/compute/ComputeTaskMapExample.java | 8 ++--
.../compute/ComputeTaskSplitExample.java | 8 ++--
.../failover/ComputeFailoverExample.java | 10 ++---
.../failover/ComputeFailoverNodeStartup.java | 4 +-
.../compute/montecarlo/CreditRiskExample.java | 8 ++--
.../examples/datagrid/CacheAffinityExample.java | 23 +++++------
.../examples/datagrid/CacheApiExample.java | 6 +--
.../datagrid/CacheContinuousQueryExample.java | 6 +--
.../datagrid/CacheDataLoaderExample.java | 8 ++--
.../examples/datagrid/CacheEventsExample.java | 10 ++---
.../datagrid/CachePopularNumbersExample.java | 24 ++++++------
.../examples/datagrid/CachePutGetExample.java | 14 +++----
.../examples/datagrid/CacheQueryExample.java | 20 +++++-----
.../datagrid/CacheTransactionExample.java | 8 ++--
.../datastructures/CacheAtomicLongExample.java | 11 +++---
.../CacheAtomicReferenceExample.java | 12 +++---
.../CacheAtomicSequenceExample.java | 8 ++--
.../CacheAtomicStampedExample.java | 12 +++---
.../CacheCountDownLatchExample.java | 8 ++--
.../datastructures/CacheQueueExample.java | 40 ++++++++++----------
.../datastructures/CacheSetExample.java | 30 +++++++--------
.../hibernate/HibernateL2CacheExample.java | 14 +++----
.../starschema/CacheStarSchemaExample.java | 10 ++---
.../datagrid/store/CacheStoreExample.java | 6 +--
.../store/CacheStoreLoadDataExample.java | 9 +++--
.../store/dummy/CacheDummyPersonStore.java | 2 +-
.../ignite/examples/events/EventsExample.java | 16 ++++----
.../ignite/examples/ggfs/GgfsExample.java | 10 ++---
.../examples/ggfs/GgfsMapReduceExample.java | 14 +++----
.../ignite/examples/ggfs/GgfsNodeStartup.java | 2 +-
.../apache/ignite/examples/ggfs/package.html | 2 +-
.../examples/messaging/MessagingExample.java | 24 ++++++------
.../messaging/MessagingPingPongExample.java | 18 ++++-----
.../MessagingPingPongListenActorExample.java | 16 ++++----
.../client/memcache/MemcacheRestExample.java | 22 +++++------
.../misc/deployment/DeploymentExample.java | 12 +++---
.../misc/lifecycle/LifecycleExample.java | 4 +-
.../misc/springbean/SpringBeanExample.java | 8 ++--
.../examples/services/ServicesExample.java | 8 ++--
.../streaming/StreamingCheckInExample.java | 12 +++---
.../StreamingPopularNumbersExample.java | 26 ++++++-------
.../streaming/StreamingPriceBarsExample.java | 30 +++++++--------
.../StreamingRunningAverageExample.java | 6 +--
.../ignite/examples/MessagingExample.java | 10 ++---
.../examples/ScalarCacheAffinityExample1.scala | 2 +-
.../ScalarCachePopularNumbersExample.scala | 2 +-
.../examples/ScalarCacheQueryExample.scala | 8 ++--
.../scalar/examples/ScalarJvmCloudExample.scala | 4 +-
.../examples/ScalarSnowflakeSchemaExample.scala | 2 +-
.../scalar/examples/ScalarTaskExample.scala | 2 +-
.../GridMonteCarloExamplesSelfTest.java | 2 +-
71 files changed, 377 insertions(+), 375 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/config/example-cache.xml
----------------------------------------------------------------------
diff --git a/examples/config/example-cache.xml b/examples/config/example-cache.xml
index 9ec2ef2..70ffa80 100644
--- a/examples/config/example-cache.xml
+++ b/examples/config/example-cache.xml
@@ -18,13 +18,13 @@
-->
<!--
- GridGain Spring configuration file to startup grid cache.
+ Ignite Spring configuration file to startup grid cache.
- When starting a standalone GridGain node, you need to execute the following command:
+ When starting a standalone node, you need to execute the following command:
{IGNITE_HOME}/bin/ignite.{bat|sh} examples/config/example-cache.xml
- When starting GridGain from Java IDE, pass path to this file to GridGain:
- GridGain.start("examples/config/example-cache.xml");
+ When starting Ignite from Java IDE, pass path to this file to Ignition:
+ Ignition.start("examples/config/example-cache.xml");
-->
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
@@ -106,7 +106,7 @@
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
- GridGain provides several options for automatic discovery that can be used
+ Ignite provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://doc.gridgain.org/latest/Automatic+Node+Discovery
-->
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/config/example-compute.xml
----------------------------------------------------------------------
diff --git a/examples/config/example-compute.xml b/examples/config/example-compute.xml
index af32d1b..420ccdf 100644
--- a/examples/config/example-compute.xml
+++ b/examples/config/example-compute.xml
@@ -49,7 +49,7 @@
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
- GridGain provides several options for automatic discovery that can be used
+ Ignite provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://doc.gridgain.org/latest/Automatic+Node+Discovery
-->
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/config/example-streamer.xml
----------------------------------------------------------------------
diff --git a/examples/config/example-streamer.xml b/examples/config/example-streamer.xml
index c13b90d..0d9c024 100644
--- a/examples/config/example-streamer.xml
+++ b/examples/config/example-streamer.xml
@@ -18,18 +18,18 @@
-->
<!--
- GridGain Spring configuration file to startup grid with streamers.
+ Ignite Spring configuration file to startup grid with streamers.
- When starting a standalone GridGain node, you need to execute the following command:
+ When starting a standalone node, you need to execute the following command:
{IGNITE_HOME}/bin/ignite.{bat|sh} examples/config/example-streamer.xml
When starting nodes this way JAR file containing the examples code
should be placed to {IGNITE_HOME}/libs folder. You can build
- gridgain-examples.jar by running "mvn package" in {IGNITE_HOME}/examples folder.
- After that gridgain-examples.jar will be generated by Maven in
+ ignite-examples.jar by running "mvn package" in {IGNITE_HOME}/examples folder.
+ After that ignite-examples.jar will be generated by Maven in
{IGNITE_HOME}/examples/target folder.
- When starting GridGain from Java IDE, pass path to this file into GridGain:
- GridGain.start("examples/config/example-streamer.xml");
+ When starting Ignite from Java IDE, pass path to this file to Ignition:
+ Ignition.start("examples/config/example-cache.xml");
-->
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
@@ -88,7 +88,7 @@
-->
<bean class="org.apache.ignite.streamer.router.StreamerRandomEventRouter"/>
<!--
- <bean class="org.gridgain.grid.streamer.router.GridStreamerLocalEventRouter"/>
+ <bean class="org.apache.ignite.streamer.router.GridStreamerLocalEventRouter"/>
-->
</property>
@@ -272,7 +272,7 @@
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
- GridGain provides several options for automatic discovery that can be used
+ Ignite provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://doc.gridgain.org/latest/Automatic+Node+Discovery
-->
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/config/filesystem/core-site.xml
----------------------------------------------------------------------
diff --git a/examples/config/filesystem/core-site.xml b/examples/config/filesystem/core-site.xml
index c9d78f2..58ae948 100644
--- a/examples/config/filesystem/core-site.xml
+++ b/examples/config/filesystem/core-site.xml
@@ -19,7 +19,7 @@
-->
<!--
- Example configuration of the Hadoop FS driver over GridGain FS API.
+ Example configuration of the Hadoop FS driver over Ignite FS API.
Copy this file into '$HADOOP_HOME/conf/core-site.xml'.
-->
<configuration>
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/config/filesystem/example-ggfs.xml
----------------------------------------------------------------------
diff --git a/examples/config/filesystem/example-ggfs.xml b/examples/config/filesystem/example-ggfs.xml
index fb64227..9f19a42 100644
--- a/examples/config/filesystem/example-ggfs.xml
+++ b/examples/config/filesystem/example-ggfs.xml
@@ -18,13 +18,13 @@
-->
<!--
- GridGain Spring configuration file to startup grid cache.
+ Ignite Spring configuration file to startup grid cache.
- When starting a standalone GridGain node, you need to execute the following command:
+ When starting a standalone node, you need to execute the following command:
{IGNITE_HOME}/bin/ignite.{bat|sh} examples/config/filesystem/example-ggfs.xml
- When starting GridGain from Java IDE, pass path to this file into GridGain:
- GridGain.start("examples/config/filesystem/example-ggfs.xml");
+ When starting Ignite from Java IDE, pass path to this file into Ignition:
+ Ignition.start("examples/config/filesystem/example-ggfs.xml");
-->
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
@@ -81,7 +81,7 @@
<!--
This will disable IPC endpoint binding thus preventing Hadoop clients from connecting to GGFS.
With this option set to false the only possible way to interact with GGFS is through
- GridGain API.
+ Ignite API.
-->
<property name="ipcEndpointEnabled" value="false"/>
@@ -144,7 +144,7 @@
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
- GridGain provides several options for automatic discovery that can be used
+ Ignition provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://doc.gridgain.org/latest/Automatic+Node+Discovery
-->
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/config/hibernate/example-hibernate-L2-cache.xml
----------------------------------------------------------------------
diff --git a/examples/config/hibernate/example-hibernate-L2-cache.xml b/examples/config/hibernate/example-hibernate-L2-cache.xml
index 779dd36..0c69248 100644
--- a/examples/config/hibernate/example-hibernate-L2-cache.xml
+++ b/examples/config/hibernate/example-hibernate-L2-cache.xml
@@ -41,7 +41,7 @@
<!-- Generate L2 cache statistics. -->
<property name="generate_statistics">true</property>
- <!-- Specify GridGain as L2 cache provider. -->
+ <!-- Specify Ignite as L2 cache provider. -->
<property name="cache.region.factory_class">org.apache.ignite.cache.hibernate.GridHibernateRegionFactory</property>
<!-- Specify the name of the grid, that will be used for second level caching. -->
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/config/servlet/WEB-INF/web.xml
----------------------------------------------------------------------
diff --git a/examples/config/servlet/WEB-INF/web.xml b/examples/config/servlet/WEB-INF/web.xml
index d099aeb..f48921e 100644
--- a/examples/config/servlet/WEB-INF/web.xml
+++ b/examples/config/servlet/WEB-INF/web.xml
@@ -18,7 +18,7 @@
-->
<!--
- Example web.xml to startup GridGain from Servlet container, like Tomcat.
+ Example web.xml to startup Ignite from Servlet container, like Tomcat.
-->
<web-app xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/rest/http-rest-example.php
----------------------------------------------------------------------
diff --git a/examples/rest/http-rest-example.php b/examples/rest/http-rest-example.php
index 26bb394..c853e3c 100644
--- a/examples/rest/http-rest-example.php
+++ b/examples/rest/http-rest-example.php
@@ -19,7 +19,7 @@
*/
/**
- * To execute this script simply start up an instance of GridGain with cache enabled.
+ * To execute this script simply start up an instance of Ignite with cache enabled.
* You can use any cache configuration from examples/config folder as follows:
* ----
* ${IGNITE_HOME}/bin/ignite.sh examples/config/example-cache.xml
@@ -95,9 +95,9 @@ function execute($query, $post) {
curl_close($request);
if (!$response)
- die('Nothing was returned. Do you have a connection to GridGain Jetty server?');
+ die('Nothing was returned. Do you have a connection to Ignite Jetty server?');
- echo "Response received from GridGain: $response\n\n";
+ echo "Response received from Ignite: $response\n\n";
// JSON decoder.
$result = json_decode($response, true);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/rest/memcache-rest-example.php
----------------------------------------------------------------------
diff --git a/examples/rest/memcache-rest-example.php b/examples/rest/memcache-rest-example.php
index b8509cf..b019eb1 100644
--- a/examples/rest/memcache-rest-example.php
+++ b/examples/rest/memcache-rest-example.php
@@ -19,13 +19,13 @@
*/
/**
- * This example shows how to use PHP Memcache client for manipulating GridGain cache.
+ * This example shows how to use PHP Memcache client for manipulating Ignite cache.
*
* To execute this script you need to have PHP Memcached extension installed.
* See http://pecl.php.net/package/memcached for details.
*
* You can use default cache configuration from examples/config folder to
- * start up an instance of GridGain with cache enabled as follows:
+ * start up an instance of Ignite with cache enabled as follows:
* ----
* ${IGNITE_HOME}/bin/ignite.sh examples/config/example-cache-default.xml
* ----
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java b/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java
index 2874fd8..5098156 100644
--- a/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java
+++ b/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java
@@ -82,7 +82,7 @@ public class ExamplesUtils {
}
/**
- * @param ignite Grid.
+ * @param ignite Ignite.
* @param name Streamer name.
* @return {@code True} if grid has streamer with given name.
*/
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java
index a12b6ac..b7a2612 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java
@@ -30,7 +30,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeBroadcastExample {
@@ -54,14 +54,14 @@ public class ComputeBroadcastExample {
}
/**
- * Print 'Hello' message on all grid nodes.
+ * Print 'Hello' message on all nodes.
*
- * @param g Grid instance.
+ * @param ignite Ignite instance.
* @throws IgniteCheckedException If failed.
*/
- private static void hello(Ignite g) throws IgniteCheckedException {
+ private static void hello(Ignite ignite) throws IgniteCheckedException {
// Print out hello message on all nodes.
- g.compute().broadcast(
+ ignite.compute().broadcast(
new IgniteRunnable() {
@Override public void run() {
System.out.println();
@@ -77,22 +77,22 @@ public class ComputeBroadcastExample {
/**
* Gather system info from all nodes and print it out.
*
- * @param g Grid instance.
+ * @param ignite Ignite instance.
* @throws IgniteCheckedException if failed.
*/
- private static void gatherSystemInfo(Ignite g) throws IgniteCheckedException {
+ private static void gatherSystemInfo(Ignite ignite) throws IgniteCheckedException {
// Gather system info from all nodes.
- Collection<String> res = g.compute().broadcast(
+ Collection<String> res = ignite.compute().broadcast(
new IgniteCallable<String>() {
- // Automatically inject grid instance.
+ // Automatically inject ignite instance.
@IgniteInstanceResource
- private Ignite grid;
+ private Ignite ignite;
@Override public String call() {
System.out.println();
- System.out.println("Executing task on node: " + grid.cluster().localNode().id());
+ System.out.println("Executing task on node: " + ignite.cluster().localNode().id());
- return "Node ID: " + grid.cluster().localNode().id() + "\n" +
+ return "Node ID: " + ignite.cluster().localNode().id() + "\n" +
"OS: " + System.getProperty("os.name") + " " + System.getProperty("os.version") + " " +
System.getProperty("os.arch") + "\n" +
"User: " + System.getProperty("user.name") + "\n" +
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java
index 880ed10..1f50b13 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java
@@ -33,7 +33,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeCallableExample {
@@ -44,7 +44,7 @@ public class ComputeCallableExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println(">>> Compute callable example started.");
@@ -63,7 +63,7 @@ public class ComputeCallableExample {
}
// Execute collection of callables on the grid.
- Collection<Integer> res = g.compute().call(calls);
+ Collection<Integer> res = ignite.compute().call(calls);
int sum = 0;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java
index d0b2538..a206a9f 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java
@@ -24,7 +24,7 @@ import org.apache.ignite.lang.*;
import java.util.*;
/**
- * Demonstrates a simple use of GridGain grid with reduce closure.
+ * Demonstrates a simple use of Ignite grid with reduce closure.
* <p>
* This example splits a phrase into collection of words, computes their length on different
* nodes and then computes total amount of non-whitespaces characters in the phrase.
@@ -32,7 +32,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeClosureExample {
@@ -43,12 +43,12 @@ public class ComputeClosureExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println(">>> Compute closure example started.");
// Execute closure on all grid nodes.
- Collection<Integer> res = g.compute().apply(
+ Collection<Integer> res = ignite.compute().apply(
new IgniteClosure<String, Integer>() {
@Override public Integer apply(String word) {
System.out.println();
@@ -59,7 +59,7 @@ public class ComputeClosureExample {
}
},
- // Job parameters. GridGain will create as many jobs as there are parameters.
+ // Job parameters. Ignite will create as many jobs as there are parameters.
Arrays.asList("Count characters using closure".split(" "))
);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
index cfbbc94..ce78041 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
@@ -42,7 +42,7 @@ import java.util.concurrent.atomic.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeContinuousMapperExample {
@@ -56,8 +56,8 @@ public class ComputeContinuousMapperExample {
System.out.println();
System.out.println(">>> Compute continuous mapper example started.");
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
- int phraseLen = g.compute().execute(GridContinuousMapperTask.class, "Hello Continuous Mapper");
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
+ int phraseLen = ignite.compute().execute(GridContinuousMapperTask.class, "Hello Continuous Mapper");
System.out.println();
System.out.println(">>> Total number of characters in the phrase is '" + phraseLen + "'.");
@@ -69,7 +69,7 @@ public class ComputeContinuousMapperExample {
* is split into multiple words and next word is sent out for processing only
* when the result for the previous word was received.
* <p>
- * Note that annotation {@link org.apache.ignite.compute.ComputeTaskNoResultCache} is optional and tells GridGain
+ * Note that annotation {@link org.apache.ignite.compute.ComputeTaskNoResultCache} is optional and tells Ignite
* not to accumulate results from individual jobs. In this example we increment
* total character count directly in {@link #result(org.apache.ignite.compute.ComputeJobResult, List)} method,
* and therefore don't need to accumulate them be be processed at reduction step.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java
index 38f277f..62ab8a4 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java
@@ -24,12 +24,12 @@ import org.apache.ignite.lang.*;
import java.util.concurrent.*;
/**
- * Simple example to demonstrate usage of grid-enabled executor service provided by GridGain.
+ * Simple example to demonstrate usage of grid-enabled executor service provided by Ignite.
* <p>
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public final class ComputeExecutorServiceExample {
@@ -41,12 +41,12 @@ public final class ComputeExecutorServiceExample {
*/
@SuppressWarnings({"TooBroadScope"})
public static void main(String[] args) throws Exception {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println(">>> Compute executor service example started.");
// Get grid-enabled executor service.
- ExecutorService exec = g.executorService();
+ ExecutorService exec = ignite.executorService();
// Iterate through all words in the sentence and create callable jobs.
for (final String word : "Print words using runnable".split(" ")) {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
index 6f2ced7..8c5e3a4 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
@@ -30,7 +30,7 @@ import java.math.*;
import java.util.*;
/**
- * This example demonstrates how to use continuation feature of GridGain by
+ * This example demonstrates how to use continuation feature of Ignite by
* performing the distributed recursive calculation of {@code 'Fibonacci'}
* numbers on the grid. Continuations
* functionality is exposed via {@link org.apache.ignite.compute.ComputeJobContext#holdcc()} and
@@ -39,7 +39,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public final class ComputeFibonacciContinuationExample {
@@ -50,25 +50,25 @@ public final class ComputeFibonacciContinuationExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println("Compute Fibonacci continuation example started.");
long N = 100;
- final UUID exampleNodeId = g.cluster().localNode().id();
+ final UUID exampleNodeId = ignite.cluster().localNode().id();
// Filter to exclude this node from execution.
final IgnitePredicate<ClusterNode> nodeFilter = new IgnitePredicate<ClusterNode>() {
@Override public boolean apply(ClusterNode n) {
// Give preference to remote nodes.
- return g.cluster().forRemotes().nodes().isEmpty() || !n.id().equals(exampleNodeId);
+ return ignite.cluster().forRemotes().nodes().isEmpty() || !n.id().equals(exampleNodeId);
}
};
long start = System.currentTimeMillis();
- BigInteger fib = g.compute(g.cluster().forPredicate(nodeFilter)).apply(new FibonacciClosure(nodeFilter), N);
+ BigInteger fib = ignite.compute(ignite.cluster().forPredicate(nodeFilter)).apply(new FibonacciClosure(nodeFilter), N);
long duration = System.currentTimeMillis() - start;
@@ -96,9 +96,9 @@ public final class ComputeFibonacciContinuationExample {
@IgniteJobContextResource
private ComputeJobContext jobCtx;
- /** Auto-inject grid instance. */
+ /** Auto-inject ignite instance. */
@IgniteInstanceResource
- private Ignite g;
+ private Ignite ignite;
/** Predicate. */
private final IgnitePredicate<ClusterNode> nodeFilter;
@@ -124,15 +124,15 @@ public final class ComputeFibonacciContinuationExample {
return n == 0 ? BigInteger.ZERO : BigInteger.ONE;
// Node-local storage.
- ClusterNodeLocalMap<Long, IgniteInternalFuture<BigInteger>> locMap = g.cluster().nodeLocalMap();
+ ClusterNodeLocalMap<Long, IgniteInternalFuture<BigInteger>> locMap = ignite.cluster().nodeLocalMap();
// Check if value is cached in node-local-map first.
fut1 = locMap.get(n - 1);
fut2 = locMap.get(n - 2);
- ClusterGroup p = g.cluster().forPredicate(nodeFilter);
+ ClusterGroup p = ignite.cluster().forPredicate(nodeFilter);
- IgniteCompute compute = g.compute(p).withAsync();
+ IgniteCompute compute = ignite.compute(p).withAsync();
// If future is not cached in node-local-map, cache it.
if (fut1 == null) {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java
index 0131003..a363578 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java
@@ -28,7 +28,7 @@ import org.apache.ignite.lang.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeProjectionExample {
@@ -49,7 +49,6 @@ public class ComputeProjectionExample {
IgniteCluster cluster = ignite.cluster();
// Say hello to all nodes in the grid, including local node.
- // Note, that Grid itself also implements GridProjection.
sayHello(ignite, cluster);
// Say hello to all remote nodes.
@@ -74,10 +73,10 @@ public class ComputeProjectionExample {
}
/**
- * Print 'Hello' message on remote grid nodes.
+ * Print 'Hello' message on remote nodes.
*
- * @param ignite Grid.
- * @param prj Grid projection.
+ * @param ignite Ignite.
+ * @param prj Projection.
* @throws IgniteCheckedException If failed.
*/
private static void sayHello(Ignite ignite, final ClusterGroup prj) throws IgniteCheckedException {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java
index 4942875..7aed33e 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java
@@ -25,15 +25,15 @@ import java.util.*;
import java.util.concurrent.atomic.*;
/**
- * Demonstrates a simple use of GridGain grid with reduce closure.
+ * Demonstrates a simple use of Ignite grid with reduce closure.
* <p>
- * Phrase is split into words and distributed across Grid nodes where length of each word is
+ * Phrase is split into words and distributed across nodes where length of each word is
* calculated. Then total phrase length is calculated using reducer.
* <p>
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start Ignite node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeReducerExample {
@@ -44,11 +44,11 @@ public class ComputeReducerExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println("Compute reducer example started.");
- Integer sum = g.compute().apply(
+ Integer sum = ignite.compute().apply(
new IgniteClosure<String, Integer>() {
@Override public Integer apply(String word) {
System.out.println();
@@ -59,7 +59,7 @@ public class ComputeReducerExample {
}
},
- // Job parameters. GridGain will create as many jobs as there are parameters.
+ // Job parameters. Ignite will create as many jobs as there are parameters.
Arrays.asList("Count characters using reducer".split(" ")),
// Reducer to process results as they come.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
index e062335..b6fe8d9 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
@@ -30,7 +30,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeRunnableExample {
@@ -41,14 +41,14 @@ public class ComputeRunnableExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println("Compute runnable example started.");
Collection<IgniteInternalFuture> futs = new ArrayList<>();
// Enable asynchronous mode.
- IgniteCompute compute = g.compute().withAsync();
+ IgniteCompute compute = ignite.compute().withAsync();
// Iterate through all words in the sentence and create callable jobs.
for (final String word : "Print words using runnable".split(" ")) {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
index 7802f75..6cd7fc7 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
@@ -32,7 +32,7 @@ import java.util.concurrent.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeScheduleExample {
@@ -43,12 +43,12 @@ public class ComputeScheduleExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println("Compute schedule example started.");
// Schedule output message every minute.
- SchedulerFuture<?> fut = g.scheduler().scheduleLocal(
+ SchedulerFuture<?> fut = ignite.scheduler().scheduleLocal(
new Callable<Integer>() {
private int invocations;
@@ -56,7 +56,7 @@ public class ComputeScheduleExample {
invocations++;
try {
- g.compute().broadcast(
+ ignite.compute().broadcast(
new IgniteRunnable() {
@Override public void run() {
System.out.println();
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java
index bd3fc67..5127b89 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java
@@ -26,7 +26,7 @@ import org.jetbrains.annotations.*;
import java.util.*;
/**
- * Demonstrates a simple use of GridGain grid with
+ * Demonstrates a simple use of Ignite grid with
* {@link org.apache.ignite.compute.ComputeTaskAdapter}.
* <p>
* Phrase passed as task argument is split into words on map stage and distributed among grid nodes.
@@ -36,7 +36,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeTaskMapExample {
@@ -47,12 +47,12 @@ public class ComputeTaskMapExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println("Compute task map example started.");
// Execute task on the grid and wait for its completion.
- int cnt = g.compute().execute(CharacterCountTask.class, "Hello Grid Enabled World!");
+ int cnt = ignite.compute().execute(CharacterCountTask.class, "Hello Grid Enabled World!");
System.out.println();
System.out.println(">>> Total number of characters in the phrase is '" + cnt + "'.");
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java
index d6c7d4c..cf991c2 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java
@@ -25,7 +25,7 @@ import org.jetbrains.annotations.*;
import java.util.*;
/**
- * Demonstrates a simple use of GridGain grid with {@link org.apache.ignite.compute.ComputeTaskSplitAdapter}.
+ * Demonstrates a simple use of Ignite grid with {@link org.apache.ignite.compute.ComputeTaskSplitAdapter}.
* <p>
* Phrase passed as task argument is split into jobs each taking one word. Then jobs are distributed among
* grid nodes. Each node computes word length and returns result to master node where total phrase length
@@ -34,7 +34,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public class ComputeTaskSplitExample {
@@ -45,12 +45,12 @@ public class ComputeTaskSplitExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println("Compute task split example started.");
// Execute task on the grid and wait for its completion.
- int cnt = g.compute().execute(CharacterCountTask.class, "Hello Grid Enabled World!");
+ int cnt = ignite.compute().execute(CharacterCountTask.class, "Hello Grid Enabled World!");
System.out.println();
System.out.println(">>> Total number of characters in the phrase is '" + cnt + "'.");
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
index fa065aa..23fbbe9 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
@@ -27,7 +27,7 @@ import org.apache.ignite.internal.util.lang.*;
import java.util.*;
/**
- * Demonstrates the usage of checkpoints in GridGain.
+ * Demonstrates the usage of checkpoints in Ignite.
* <p>
* The example tries to compute phrase length. In order to mitigate possible node failures, intermediate
* result is saved as as checkpoint after each job step.
@@ -42,15 +42,15 @@ public class ComputeFailoverExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start(ComputeFailoverNodeStartup.configuration())) {
- if (!ExamplesUtils.checkMinTopologySize(g.cluster(), 2))
+ try (Ignite ignite = Ignition.start(ComputeFailoverNodeStartup.configuration())) {
+ if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))
return;
System.out.println();
System.out.println("Compute failover example started.");
// Number of letters.
- int charCnt = g.compute().apply(new CheckPointJob(), "Stage1 Stage2");
+ int charCnt = ignite.compute().apply(new CheckPointJob(), "Stage1 Stage2");
System.out.println();
System.out.println(">>> Finished executing fail-over example with checkpoints.");
@@ -66,7 +66,7 @@ public class ComputeFailoverExample {
@IgniteTaskSessionResource
private ComputeTaskSession jobSes;
- /** Injected grid logger. */
+ /** Injected ignite logger. */
@IgniteLoggerResource
private IgniteLogger log;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java
index dcfbdf9..0c64c83 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java
@@ -43,9 +43,9 @@ public class ComputeFailoverNodeStartup {
}
/**
- * Create Grid configuration with configured checkpoints.
+ * Create Ignite configuration with configured checkpoints.
*
- * @return Grid configuration.
+ * @return Ignite configuration.
* @throws IgniteCheckedException If configuration creation failed.
*/
public static IgniteConfiguration configuration() throws IgniteCheckedException {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java
index 49a2667..e8bbf43 100644
--- a/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java
@@ -29,7 +29,7 @@ import java.util.*;
* Remote nodes should always be started with special configuration file which
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
* <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start GridGain node
+ * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
* with {@code examples/config/example-compute.xml} configuration.
*/
public final class CreditRiskExample {
@@ -40,7 +40,7 @@ public final class CreditRiskExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-compute.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
System.out.println();
System.out.println("Credit risk example started.");
@@ -78,7 +78,7 @@ public final class CreditRiskExample {
// Credit risk crdRisk is the minimal amount that creditor has to have
// available to cover possible defaults.
- double crdRisk = g.compute().call(jobs(g.cluster().nodes().size(), portfolio, horizon, iter, percentile),
+ double crdRisk = ignite.compute().call(jobs(ignite.cluster().nodes().size(), portfolio, horizon, iter, percentile),
new IgniteReducer<Double, Double>() {
/** Collected values sum. */
private double sum;
@@ -134,7 +134,7 @@ public final class CreditRiskExample {
// will be identical. In real life scenarios when heterogeneous environment
// is used a split that is weighted by, for example, CPU benchmarks of each
// node in the split will be more efficient. It is fairly easy addition and
- // GridGain comes with convenient Spring-compatible benchmark that can be
+ // Ignite comes with convenient Spring-compatible benchmark that can be
// used for weighted splits.
for (int i = 0; i < gridSize; i++) {
final int nodeIter = i == gridSize - 1 ? lastNodeIter : iterPerNode;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java
index aa99368..e75e781 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java
@@ -33,7 +33,7 @@ import java.util.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public final class CacheAffinityExample {
/** Cache name. */
@@ -49,11 +49,11 @@ public final class CacheAffinityExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache affinity example started.");
- IgniteCache<Integer, String> cache = g.jcache(CACHE_NAME);
+ IgniteCache<Integer, String> cache = ignite.jcache(CACHE_NAME);
// Clean up caches on all nodes before run.
cache.clear();
@@ -76,9 +76,9 @@ public final class CacheAffinityExample {
* @throws IgniteCheckedException If failed.
*/
private static void visitUsingAffinityRun() throws IgniteCheckedException {
- Ignite g = Ignition.ignite();
+ Ignite ignite = Ignition.ignite();
- final IgniteCache<Integer, String> cache = g.jcache(CACHE_NAME);
+ final IgniteCache<Integer, String> cache = ignite.jcache(CACHE_NAME);
for (int i = 0; i < KEY_CNT; i++) {
final int key = i;
@@ -86,7 +86,7 @@ public final class CacheAffinityExample {
// This runnable will execute on the remote node where
// data with the given key is located. Since it will be co-located
// we can use local 'peek' operation safely.
- g.compute().affinityRun(CACHE_NAME, key, new IgniteRunnable() {
+ ignite.compute().affinityRun(CACHE_NAME, key, new IgniteRunnable() {
@Override public void run() {
// Peek is a local memory lookup, however, value should never be 'null'
// as we are co-located with node that has a given key.
@@ -104,7 +104,7 @@ public final class CacheAffinityExample {
* @throws IgniteCheckedException If failed.
*/
private static void visitUsingMapKeysToNodes() throws IgniteCheckedException {
- final Ignite g = Ignition.ignite();
+ final Ignite ignite = Ignition.ignite();
Collection<Integer> keys = new ArrayList<>(KEY_CNT);
@@ -112,7 +112,7 @@ public final class CacheAffinityExample {
keys.add(i);
// Map all keys to nodes.
- Map<ClusterNode, Collection<Integer>> mappings = g.cluster().mapKeysToNodes(CACHE_NAME, keys);
+ Map<ClusterNode, Collection<Integer>> mappings = ignite.cluster().mapKeysToNodes(CACHE_NAME, keys);
for (Map.Entry<ClusterNode, Collection<Integer>> mapping : mappings.entrySet()) {
ClusterNode node = mapping.getKey();
@@ -121,9 +121,10 @@ public final class CacheAffinityExample {
if (node != null) {
// Bring computations to the nodes where the data resides (i.e. collocation).
- g.compute(g.cluster().forNode(node)).run(new IgniteRunnable() {
- @Override public void run() {
- IgniteCache<Integer, String> cache = g.jcache(CACHE_NAME);
+ ignite.compute(ignite.cluster().forNode(node)).run(new IgniteRunnable() {
+ @Override
+ public void run() {
+ IgniteCache<Integer, String> cache = ignite.jcache(CACHE_NAME);
// Peek is a local memory lookup, however, value should never be 'null'
// as we are co-located with node that has a given key.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java
index 269d841..0666fbb 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java
@@ -31,7 +31,7 @@ import java.util.concurrent.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CacheApiExample {
/** Cache name. */
@@ -44,12 +44,12 @@ public class CacheApiExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache API example started.");
// Clean up caches on all nodes before run.
- g.jcache(CACHE_NAME).clear();
+ ignite.jcache(CACHE_NAME).clear();
// Demonstrate atomic map operations.
atomicMapOperations();
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
index d801148..9ee65f7 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
@@ -31,7 +31,7 @@ import java.util.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CacheContinuousQueryExample {
/** Cache name. */
@@ -44,11 +44,11 @@ public class CacheContinuousQueryExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException, InterruptedException {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache continuous query example started.");
- GridCache<Integer, String> cache = g.cache(CACHE_NAME);
+ GridCache<Integer, String> cache = ignite.cache(CACHE_NAME);
// Clean up caches on all nodes before run.
cache.globalClearAll(0);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
index 0fdd3db..7d6f8b6 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
@@ -30,7 +30,7 @@ import org.apache.ignite.examples.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CacheDataLoaderExample {
/** Cache name. */
@@ -51,19 +51,19 @@ public class CacheDataLoaderExample {
public static void main(String[] args) throws Exception {
ExamplesUtils.checkMinMemory(MIN_MEMORY);
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache data loader example started.");
// Clean up caches on all nodes before run.
- g.jcache(CACHE_NAME).clear();
+ ignite.jcache(CACHE_NAME).clear();
System.out.println();
System.out.println(">>> Cache clear finished.");
long start = System.currentTimeMillis();
- try (IgniteDataLoader<Integer, String> ldr = g.dataLoader(CACHE_NAME)) {
+ try (IgniteDataLoader<Integer, String> ldr = ignite.dataLoader(CACHE_NAME)) {
// Configure loader.
ldr.perNodeBufferSize(1024);
ldr.perNodeParallelLoadOperations(8);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
index dd7ab89..1aabeb8 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
@@ -34,7 +34,7 @@ import static org.apache.ignite.events.IgniteEventType.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CacheEventsExample {
/** Cache name. */
@@ -47,11 +47,11 @@ public class CacheEventsExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException, InterruptedException {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache events example started.");
- final IgniteCache<Integer, String> cache = g.jcache(CACHE_NAME);
+ final IgniteCache<Integer, String> cache = ignite.jcache(CACHE_NAME);
// Clean up caches on all nodes before run.
cache.clear();
@@ -75,13 +75,13 @@ public class CacheEventsExample {
int key = evt.key();
- return key >= 10 && g.affinity(CACHE_NAME).isPrimary(g.cluster().localNode(), key);
+ return key >= 10 && ignite.affinity(CACHE_NAME).isPrimary(ignite.cluster().localNode(), key);
}
};
// Subscribe to specified cache events on all nodes that have cache running.
// Cache events are explicitly enabled in examples/config/example-cache.xml file.
- g.events(g.cluster().forCache(CACHE_NAME)).remoteListen(locLsnr, rmtLsnr,
+ ignite.events(ignite.cluster().forCache(CACHE_NAME)).remoteListen(locLsnr, rmtLsnr,
EVT_CACHE_OBJECT_PUT, EVT_CACHE_OBJECT_READ, EVT_CACHE_OBJECT_REMOVED);
// Generate cache events.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
index 51cc3b7..1dc1246 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
@@ -33,7 +33,7 @@ import java.util.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CachePopularNumbersExample {
/** Cache name. */
@@ -60,14 +60,14 @@ public class CachePopularNumbersExample {
public static void main(String[] args) throws Exception {
Timer popularNumbersQryTimer = new Timer("numbers-query-worker");
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache popular numbers example started.");
// Clean up caches on all nodes before run.
- g.jcache(CACHE_NAME).clear();
+ ignite.jcache(CACHE_NAME).clear();
- ClusterGroup prj = g.cluster().forCache(CACHE_NAME);
+ ClusterGroup prj = ignite.cluster().forCache(CACHE_NAME);
if (prj.nodes().isEmpty()) {
System.out.println("Grid does not have cache configured: " + CACHE_NAME);
@@ -75,9 +75,9 @@ public class CachePopularNumbersExample {
return;
}
- TimerTask task = scheduleQuery(g, popularNumbersQryTimer, POPULAR_NUMBERS_CNT);
+ TimerTask task = scheduleQuery(ignite, popularNumbersQryTimer, POPULAR_NUMBERS_CNT);
- streamData(g);
+ streamData(ignite);
// Force one more run to get final counts.
task.run();
@@ -89,11 +89,11 @@ public class CachePopularNumbersExample {
/**
* Populates cache in real time with numbers and keeps count for every number.
*
- * @param g Grid.
+ * @param ignite Ignite.
* @throws IgniteCheckedException If failed.
*/
- private static void streamData(final Ignite g) throws IgniteCheckedException {
- try (IgniteDataLoader<Integer, Long> ldr = g.dataLoader(CACHE_NAME)) {
+ private static void streamData(final Ignite ignite) throws IgniteCheckedException {
+ try (IgniteDataLoader<Integer, Long> ldr = ignite.dataLoader(CACHE_NAME)) {
// Set larger per-node buffer size since our state is relatively small.
ldr.perNodeBufferSize(2048);
@@ -107,18 +107,18 @@ public class CachePopularNumbersExample {
/**
* Schedules our popular numbers query to run every 3 seconds.
*
- * @param g Grid.
+ * @param ignite Ignite.
* @param timer Timer.
* @param cnt Number of popular numbers to return.
* @return Scheduled task.
*/
- private static TimerTask scheduleQuery(final Ignite g, Timer timer, final int cnt) {
+ private static TimerTask scheduleQuery(final Ignite ignite, Timer timer, final int cnt) {
TimerTask task = new TimerTask() {
private CacheQuery<List<?>> qry;
@Override public void run() {
// Get reference to cache.
- GridCache<Integer, Long> cache = g.cache(CACHE_NAME);
+ GridCache<Integer, Long> cache = ignite.cache(CACHE_NAME);
if (qry == null)
qry = cache.queries().
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java
index 231abbb..14a76ec 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java
@@ -29,7 +29,7 @@ import java.util.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CachePutGetExample {
/** Cache name. */
@@ -42,9 +42,9 @@ public class CachePutGetExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws Exception {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
// Clean up caches on all nodes before run.
- g.jcache(CACHE_NAME).clear();
+ ignite.jcache(CACHE_NAME).clear();
// Individual puts and gets.
putGet();
@@ -63,9 +63,9 @@ public class CachePutGetExample {
System.out.println();
System.out.println(">>> Cache put-get example started.");
- Ignite g = Ignition.ignite();
+ Ignite ignite = Ignition.ignite();
- final IgniteCache<Integer, String> cache = g.jcache(CACHE_NAME);
+ final IgniteCache<Integer, String> cache = ignite.jcache(CACHE_NAME);
final int keyCnt = 20;
@@ -88,9 +88,9 @@ public class CachePutGetExample {
System.out.println();
System.out.println(">>> Starting putAll-getAll example.");
- Ignite g = Ignition.ignite();
+ Ignite ignite = Ignition.ignite();
- final IgniteCache<Integer, String> cache = g.jcache(CACHE_NAME);
+ final IgniteCache<Integer, String> cache = ignite.jcache(CACHE_NAME);
final int keyCnt = 20;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java
index 3237348..773133c 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java
@@ -62,7 +62,7 @@ import java.util.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CacheQueryExample {
/** Cache name. */
@@ -75,12 +75,12 @@ public class CacheQueryExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws Exception {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache query example started.");
// Clean up caches on all nodes before run.
- g.jcache(CACHE_NAME).clear();
+ ignite.jcache(CACHE_NAME).clear();
// Populate cache.
initialize();
@@ -148,7 +148,7 @@ public class CacheQueryExample {
"and lower(Organization.name) = lower(?)");
// Execute queries for find employees for different organizations.
- print("Following people are 'GridGain' employees: ", qry.execute("GridGain").get());
+ print("Following people are 'Ignite' employees: ", qry.execute("Ignite").get());
print("Following people are 'Other' employees: ", qry.execute("Other").get());
}
@@ -181,7 +181,7 @@ public class CacheQueryExample {
private static void sqlQueryWithReducers() throws IgniteCheckedException {
CacheProjection<CacheAffinityKey<UUID>, Person> cache = Ignition.ignite().cache(CACHE_NAME);
- // Calculate average of salary of all persons in GridGain.
+ // Calculate average of salary of all persons in Ignite.
CacheQuery<Map.Entry<CacheAffinityKey<UUID>, Person>> qry = cache.queries().createSqlQuery(
Person.class,
"from Person, Organization where Person.orgId = Organization.id and " +
@@ -205,7 +205,7 @@ public class CacheQueryExample {
@Override public IgniteBiTuple<Double, Integer> reduce() {
return new IgniteBiTuple<>(sum, cnt);
}
- }, "GridGain").get();
+ }, "Ignite").get();
double sum = 0.0d;
int cnt = 0;
@@ -218,7 +218,7 @@ public class CacheQueryExample {
double avg = sum / cnt;
// Calculate average salary for a specific organization.
- print("Average salary for 'GridGain' employees: " + avg);
+ print("Average salary for 'Ignite' employees: " + avg);
}
/**
@@ -246,8 +246,8 @@ public class CacheQueryExample {
}
};
- // Query all nodes for names of all GridGain employees.
- print("Names of all 'GridGain' employees: " + qry.execute(trans, "GridGain").get());
+ // Query all nodes for names of all Ignite employees.
+ print("Names of all 'Ignite' employees: " + qry.execute(trans, "Ignite").get());
}
/**
@@ -310,7 +310,7 @@ public class CacheQueryExample {
cache.projection(CacheAffinityKey.class, Person.class);
// Organizations.
- Organization org1 = new Organization("GridGain");
+ Organization org1 = new Organization("Ignite");
Organization org2 = new Organization("Other");
// People.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
index ee52b79..540543d 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
@@ -34,7 +34,7 @@ import static org.apache.ignite.transactions.IgniteTxIsolation.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public class CacheTransactionExample {
/** Cache name. */
@@ -47,14 +47,14 @@ public class CacheTransactionExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache transaction example started.");
// Clean up caches on all nodes before run.
- g.jcache(CACHE_NAME).clear();
+ ignite.jcache(CACHE_NAME).clear();
- IgniteCache<Integer, Account> cache = g.jcache(CACHE_NAME);
+ IgniteCache<Integer, Account> cache = ignite.jcache(CACHE_NAME);
// Initialize.
cache.put(1, new Account(1, 100));
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java
index 51359fd..f6c6662 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java
@@ -31,7 +31,7 @@ import java.util.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public final class CacheAtomicLongExample {
/** Cache name. */
@@ -47,7 +47,7 @@ public final class CacheAtomicLongExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache atomic long example started.");
@@ -55,15 +55,16 @@ public final class CacheAtomicLongExample {
String atomicName = UUID.randomUUID().toString();
// Initialize atomic long in grid.
- final CacheAtomicLong atomicLong = g.cache(CACHE_NAME).dataStructures().atomicLong(atomicName, 0, true);
+ final CacheAtomicLong atomicLong = ignite.cache(CACHE_NAME).dataStructures().atomicLong(atomicName, 0, true);
System.out.println();
System.out.println("Atomic long initial value : " + atomicLong.get() + '.');
// Try increment atomic long from all grid nodes.
// Note that this node is also part of the grid.
- g.compute(g.cluster().forCache(CACHE_NAME)).call(new IgniteCallable<Object>() {
- @Override public Object call() throws Exception {
+ ignite.compute(ignite.cluster().forCache(CACHE_NAME)).call(new IgniteCallable<Object>() {
+ @Override
+ public Object call() throws Exception {
for (int i = 0; i < RETRIES; i++)
System.out.println("AtomicLong value has been incremented: " + atomicLong.incrementAndGet());
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a234cdda/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java
index fa86d21..9e60c6c 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java
@@ -31,7 +31,7 @@ import java.util.*;
* enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
* <p>
* Alternatively you can run {@link CacheNodeStartup} in another JVM which will
- * start GridGain node with {@code examples/config/example-cache.xml} configuration.
+ * start node with {@code examples/config/example-cache.xml} configuration.
*/
public final class CacheAtomicReferenceExample {
/** Cache name. */
@@ -44,7 +44,7 @@ public final class CacheAtomicReferenceExample {
* @throws IgniteCheckedException If example execution failed.
*/
public static void main(String[] args) throws IgniteCheckedException {
- try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
+ try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
System.out.println();
System.out.println(">>> Cache atomic reference example started.");
@@ -55,7 +55,7 @@ public final class CacheAtomicReferenceExample {
String val = UUID.randomUUID().toString();
// Initialize atomic reference in grid.
- CacheAtomicReference<String> ref = g.cache(CACHE_NAME).dataStructures().
+ CacheAtomicReference<String> ref = ignite.cache(CACHE_NAME).dataStructures().
atomicReference(refName, val, true);
System.out.println("Atomic reference initial value : " + ref.get() + '.');
@@ -64,7 +64,7 @@ public final class CacheAtomicReferenceExample {
Runnable c = new ReferenceClosure(CACHE_NAME, refName);
// Check atomic reference on all grid nodes.
- g.compute().run(c);
+ ignite.compute().run(c);
// Make new value of atomic reference.
String newVal = UUID.randomUUID().toString();
@@ -75,7 +75,7 @@ public final class CacheAtomicReferenceExample {
// Check atomic reference on all grid nodes.
// Atomic reference value shouldn't be changed.
- g.compute().run(c);
+ ignite.compute().run(c);
System.out.println("Try to change value of atomic reference with correct expected value.");
@@ -83,7 +83,7 @@ public final class CacheAtomicReferenceExample {
// Check atomic reference on all grid nodes.
// Atomic reference value should be changed.
- g.compute().run(c);
+ ignite.compute().run(c);
}
System.out.println();