update docs

apache · Nov 29, 2024 · 70f4d3b · 70f4d3b
1 parent 41370eb
commit 70f4d3b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/common/src/main/scala/org/apache/comet/vector/NativeUtil.scala b/common/src/main/scala/org/apache/comet/vector/NativeUtil.scala
@@ -142,6 +142,8 @@ class NativeUtil {
    *
    * @param numOutputCols
    *   The number of output columns
+   * @param arrowFfiMetric
+   *   SQLMetric to record time spend performing Arrow FFI to transfer batches from native to JVM
    * @param func
    *   The function to call to get the next batch
    * @return

diff --git a/spark/src/main/scala/org/apache/spark/sql/comet/CometTakeOrderedAndProjectExec.scala b/spark/src/main/scala/org/apache/spark/sql/comet/CometTakeOrderedAndProjectExec.scala
@@ -79,11 +79,7 @@ case class CometTakeOrderedAndProjectExec(
         childRDD
       } else {
         val localTopK = if (orderingSatisfies) {
-          CometExecUtils.getNativeLimitRDD(
-            childRDD,
-            child.output,
-            limit,
-            arrowFfiMetric)
+          CometExecUtils.getNativeLimitRDD(childRDD, child.output, limit, arrowFfiMetric)
         } else {
           val numParts = childRDD.getNumPartitions
           childRDD.mapPartitionsWithIndexInternal { case (idx, iter) =>