ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-1232-2 changed benchmark
Date Thu, 28 Jul 2016 12:12:00 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1232-2 5612aac80 -> 18b8eef1c


ignite-1232-2 changed benchmark


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

Branch: refs/heads/ignite-1232-2
Commit: 18b8eef1cc247e43fadf921e6a7663199fc80152
Parents: 5612aac
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Jul 28 15:11:56 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu Jul 28 15:11:56 2016 +0300

----------------------------------------------------------------------
 .../IgniteSqlQueryDistributedJoinBenchmark.java | 35 +++++---------------
 1 file changed, 9 insertions(+), 26 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/18b8eef1/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteSqlQueryDistributedJoinBenchmark.java
----------------------------------------------------------------------
diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteSqlQueryDistributedJoinBenchmark.java
b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteSqlQueryDistributedJoinBenchmark.java
index 1f009e6..60a4d14 100644
--- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteSqlQueryDistributedJoinBenchmark.java
+++ b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteSqlQueryDistributedJoinBenchmark.java
@@ -49,10 +49,8 @@ public class IgniteSqlQueryDistributedJoinBenchmark extends IgniteCacheAbstractB
 
         long start = System.nanoTime();
 
-        int personCnt = 0;
-
         try (IgniteDataStreamer<Object, Object> dataLdr = ignite().dataStreamer(cache.getName()))
{
-            orgRange = args.range() / 10;
+            orgRange = args.range();
 
             if (orgRange <= 0)
                 throw new IllegalArgumentException();
@@ -61,29 +59,14 @@ public class IgniteSqlQueryDistributedJoinBenchmark extends IgniteCacheAbstractB
             for (int orgId = 0; orgId < orgRange; orgId++) {
                 dataLdr.addData(orgId, new Organization(orgId, "org" + orgId));
 
-                if (orgId % 1000 == 0 && Thread.currentThread().isInterrupted())
-                    return;
-            }
-
-            dataLdr.flush();
-
-            // Populate persons.
-            for (int orgId = 0; orgId < orgRange; orgId++) {
-                int persons = orgId % 10 + 1;
-
-                for (int j = 0; j < persons; j++) {
-                    int personId = orgRange + personCnt++;
-
-                    Person p = new Person(personId,
-                        orgId,
-                        "firstName" + personId,
-                        "lastName" + personId, 1000);
+                int personId = orgRange + orgId;
 
-                    dataLdr.addData(personId, p);
-                }
+                Person p = new Person(personId,
+                    orgId,
+                    "firstName" + personId,
+                    "lastName" + personId, 1000);
 
-                if (personCnt % 100000 == 0)
-                    println(cfg, "Populated persons: " + personCnt);
+                dataLdr.addData(personId, p);
 
                 if (orgId % 1000 == 0 && Thread.currentThread().isInterrupted())
                     return;
@@ -93,7 +76,7 @@ public class IgniteSqlQueryDistributedJoinBenchmark extends IgniteCacheAbstractB
         }
 
         println(cfg, "Finished populating join query [orgCnt=" + orgRange +
-            ", personCnt=" + personCnt +
+            ", personCnt=" + orgRange +
             ", broadcastJoin=" + broadcast +
             ", time=" + ((System.nanoTime() - start) / 1_000_000) + "ms]");
 
@@ -113,7 +96,7 @@ public class IgniteSqlQueryDistributedJoinBenchmark extends IgniteCacheAbstractB
 
         Collection<List<?>> res = executeQueryJoin(orgId, broadcast, false);
 
-        int persons = orgId % 10 + 1;
+        int persons = 1;
 
         if (res.size() != persons)
             throw new Exception("Invalid join result [orgId=" + orgId + ", resSize=" + res.size()
+ ']');


Mime
View raw message