(datasketches-spark) branch kll_merge updated: Define more merge constructors to fix SQL multi-argument issue

[jm...@apache.org]

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

jmalkin pushed a commit to branch kll_merge
in repository https://gitbox.apache.org/repos/asf/datasketches-spark.git


The following commit(s) were added to refs/heads/kll_merge by this push:
     new b4c2478  Define more merge constructors to fix SQL multi-argument issue
b4c2478 is described below

commit b4c24782dee8fb46bf1e365dd37ce40df09ea216
Author: Jon Malkin <78...@users.noreply.github.com>
AuthorDate: Tue Jan 7 21:02:05 2025 -0800

    Define more merge constructors to fix SQL multi-argument issue
---
 .../scala/org/apache/spark/sql/aggregate/KllMerge.scala     | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/src/main/scala/org/apache/spark/sql/aggregate/KllMerge.scala b/src/main/scala/org/apache/spark/sql/aggregate/KllMerge.scala
index 77ef12a..cfcb5c1 100644
--- a/src/main/scala/org/apache/spark/sql/aggregate/KllMerge.scala
+++ b/src/main/scala/org/apache/spark/sql/aggregate/KllMerge.scala
@@ -69,7 +69,18 @@ case class KllDoublesMergeAgg(
   }
 
   // Constructors
-  def this(left: Expression) = this(left, Literal(KllSketch.DEFAULT_K), 0, 0)
+  def this(left: Expression) = {
+    this(left, Literal(KllSketch.DEFAULT_K), 0, 0)
+  }
+
+  def this(child: Expression, k: Expression) = {
+    this(child, k, 0, 0)
+  }
+
+  def this(child: Expression, k: Int) = {
+    this(child, Literal(k), 0, 0)
+  }
+
 
   // Copy constructors
   override def withNewMutableAggBufferOffset(newMutableAggBufferOffset: Int): KllDoublesMergeAgg =


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