ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [21/50] [abbrv] incubator-ignite git commit: # sprint-2
Date Sat, 14 Mar 2015 02:37:01 GMT
# sprint-2


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b2f1e434
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b2f1e434
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b2f1e434

Branch: refs/heads/ignite-45
Commit: b2f1e43412e4d66bc911f33da0f1a094b822d28a
Parents: d775504
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Mar 13 12:39:37 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Mar 13 12:39:37 2015 +0300

----------------------------------------------------------------------
 .../datagrid/store/CacheStoreLoadDataExample.java | 18 ++++++------------
 1 file changed, 6 insertions(+), 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b2f1e434/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
index 8a47c1a..4a0cf2b 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
@@ -22,9 +22,8 @@ import org.apache.ignite.examples.*;
 import org.apache.ignite.lang.*;
 
 /**
- * Loads data from persistent store at cache startup by calling
- * {@link IgniteCache#loadCache(IgniteBiPredicate, Object...)} method on
- * all nodes.
+ * Loads data on all cache nodes from persistent store at cache startup by calling
+ * {@link IgniteCache#loadCache(IgniteBiPredicate, Object...)} method.
  * <p>
  * Remote nodes should always be started using {@link CacheNodeWithStoreStartup}.
  * Also you can change type of underlying store modifying configuration in the
@@ -35,7 +34,7 @@ public class CacheStoreLoadDataExample {
     public static final int MIN_MEMORY = 1024 * 1024 * 1024;
 
     /** Number of entries to load. */
-    private static final int ENTRY_COUNT = 1000000;
+    private static final int ENTRY_COUNT = 100_000;
 
     /**
      * Executes example.
@@ -57,17 +56,12 @@ public class CacheStoreLoadDataExample {
 
             long start = System.currentTimeMillis();
 
-            // Start loading cache on all caching nodes.
-            ignite.compute(ignite.cluster().forCacheNodes(null)).broadcast(new IgniteRunnable()
{
-                @Override public void run() {
-                    // Load cache from persistent store.
-                    cache.loadCache(null, ENTRY_COUNT);
-                }
-            });
+            // Start loading cache from persistent store on all caching nodes.
+            cache.loadCache(null, ENTRY_COUNT);
 
             long end = System.currentTimeMillis();
 
-            System.out.println(">>> Loaded " + cache.size() +" keys with backups
in " + (end - start) + "ms.");
+            System.out.println(">>> Loaded " + cache.size() + " keys with backups
in " + (end - start) + "ms.");
         }
     }
 }


Mime
View raw message