You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datasketches.apache.org by le...@apache.org on 2022/04/17 18:30:54 UTC

[datasketches-characterization] branch master updated: Updating KllProfiles for new Kll Sketch

This is an automated email from the ASF dual-hosted git repository.

leerho pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/datasketches-characterization.git


The following commit(s) were added to refs/heads/master by this push:
     new 36a2b60  Updating KllProfiles for new Kll Sketch
36a2b60 is described below

commit 36a2b6046256d75be64df451975b895a8a29c853
Author: Lee Rhodes <le...@users.noreply.github.com>
AuthorDate: Sun Apr 17 11:30:47 2022 -0700

    Updating KllProfiles for new Kll Sketch
---
 .../quantiles/KllDoublesSketchRankGaussianAccuracyProfile.java      | 6 ++++--
 .../quantiles/KllFloatsSketchRankGaussianAccuracyProfile.java       | 6 ++++--
 .../characterization/quantiles/KllFloatsSketchSpeedProfile.java     | 3 ++-
 .../characterization/quantiles/KllSketchAccuracyProfile.java        | 6 ++++--
 .../characterization/quantiles/KllSketchSizeSpeedProfile.java       | 6 ++++--
 5 files changed, 18 insertions(+), 9 deletions(-)

diff --git a/src/main/java/org/apache/datasketches/characterization/quantiles/KllDoublesSketchRankGaussianAccuracyProfile.java b/src/main/java/org/apache/datasketches/characterization/quantiles/KllDoublesSketchRankGaussianAccuracyProfile.java
index 4dbc82e..b79a5ae 100644
--- a/src/main/java/org/apache/datasketches/characterization/quantiles/KllDoublesSketchRankGaussianAccuracyProfile.java
+++ b/src/main/java/org/apache/datasketches/characterization/quantiles/KllDoublesSketchRankGaussianAccuracyProfile.java
@@ -126,7 +126,8 @@ public class KllDoublesSketchRankGaussianAccuracyProfile implements JobProfile {
   }
 
   void configureSketch() {
-    sk = new KllDoublesSketch(K);
+    sk = KllDoublesSketch.newHeapInstance(K);
+    //sk = new KllDoublesSketch(K);
   }
 
   private void doJob() {
@@ -178,7 +179,8 @@ public class KllDoublesSketchRankGaussianAccuracyProfile implements JobProfile {
 
     //Do numTrials for all plot points
     for (int t = 0; t < numTrials; t++) {
-      sk = new KllDoublesSketch(K);
+      sk = KllDoublesSketch.newHeapInstance(K);
+      // sk = new KllDoublesSketch(K);
       doTrial(sk, stream, trueValues, corrTrueValues, errQSkArr);
     }
 
diff --git a/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchRankGaussianAccuracyProfile.java b/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchRankGaussianAccuracyProfile.java
index b7b4255..862222f 100644
--- a/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchRankGaussianAccuracyProfile.java
+++ b/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchRankGaussianAccuracyProfile.java
@@ -127,7 +127,8 @@ public class KllFloatsSketchRankGaussianAccuracyProfile implements JobProfile {
   }
 
   void configureSketch() {
-    sk = new KllFloatsSketch(K);
+    sk = KllFloatsSketch.newHeapInstance(K);
+    //sk = new KllFloatsSketch(K);
   }
 
   private void doJob() {
@@ -179,7 +180,8 @@ public class KllFloatsSketchRankGaussianAccuracyProfile implements JobProfile {
 
     //Do numTrials for all plot points
     for (int t = 0; t < numTrials; t++) {
-      sk = new KllFloatsSketch(K);
+      sk = KllFloatsSketch.newHeapInstance(K);
+      //sk = new KllFloatsSketch(K);
       doTrial(sk, stream, trueValues, corrTrueValues, errQSkArr);
     }
 
diff --git a/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchSpeedProfile.java b/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchSpeedProfile.java
index 579b7cb..5bb4387 100644
--- a/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchSpeedProfile.java
+++ b/src/main/java/org/apache/datasketches/characterization/quantiles/KllFloatsSketchSpeedProfile.java
@@ -75,7 +75,8 @@ public class KllFloatsSketchSpeedProfile extends BaseQuantilesSpeedProfile {
   @Override
   void doTrial() {
     final long startBuild = System.nanoTime();
-    final KllFloatsSketch sketch = new KllFloatsSketch(k);
+    final KllFloatsSketch sketch = KllFloatsSketch.newHeapInstance(k);
+    //final KllFloatsSketch sketch = new KllFloatsSketch(k);
     final long stopBuild = System.nanoTime();
     buildTimeNs += stopBuild - startBuild;
 
diff --git a/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchAccuracyProfile.java b/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchAccuracyProfile.java
index e5b1139..4d9800b 100644
--- a/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchAccuracyProfile.java
+++ b/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchAccuracyProfile.java
@@ -91,7 +91,8 @@ public class KllSketchAccuracyProfile extends BaseQuantilesAccuracyProfile {
     if (useFloat) {
       shuffle(inputFloatValues);
       // build sketch
-      final KllFloatsSketch sketch = new KllFloatsSketch(k);
+      final KllFloatsSketch sketch = KllFloatsSketch.newHeapInstance(k);
+      //final KllFloatsSketch sketch = new KllFloatsSketch(k);
       for (int i = 0; i < inputFloatValues.length; i++) {
         sketch.update(inputFloatValues[i]);
       }
@@ -115,7 +116,8 @@ public class KllSketchAccuracyProfile extends BaseQuantilesAccuracyProfile {
     else if (useDouble) {
       shuffle(inputDoubleValues);
       // build sketch
-      final KllDoublesSketch sketch = new KllDoublesSketch(k);
+      final KllDoublesSketch sketch = KllDoublesSketch.newHeapInstance(k);
+      //final KllDoublesSketch sketch = new KllDoublesSketch(k);
       for (int i = 0; i < inputDoubleValues.length; i++) {
         sketch.update(inputDoubleValues[i]);
       }
diff --git a/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchSizeSpeedProfile.java b/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchSizeSpeedProfile.java
index 058237b..370c0d8 100644
--- a/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchSizeSpeedProfile.java
+++ b/src/main/java/org/apache/datasketches/characterization/quantiles/KllSketchSizeSpeedProfile.java
@@ -79,7 +79,8 @@ public class KllSketchSizeSpeedProfile implements JobProfile {
   }
 
   void configureSketch() {
-    kllSk = new KllFloatsSketch(kllK);
+    kllSk = KllFloatsSketch.newHeapInstance(kllK);
+    // kllSk = new KllFloatsSketch(kllK);
   }
 
 //JobProfile interface
@@ -132,7 +133,8 @@ public class KllSketchSizeSpeedProfile implements JobProfile {
    * @return the average update time per item for this trial
    */
   private double doTrial(final int streamLen) {
-    kllSk = new KllFloatsSketch(kllK);
+    kllSk = KllFloatsSketch.newHeapInstance(kllK);
+    //kllSk = new KllFloatsSketch(kllK);
     final long startUpdateTime_nS = System.nanoTime();
 
     for (int i = 0; i < streamLen; i++) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datasketches.apache.org
For additional commands, e-mail: commits-help@datasketches.apache.org