From 25aed33c0e926ed79f8860c70f396bdf103efa63 Mon Sep 17 00:00:00 2001 From: Sayed Bilal Bari Date: Thu, 20 Feb 2025 16:50:54 -0800 Subject: [PATCH] Updated datatype for count - StatisticsMetrics Signed-off-by: Sayed Bilal Bari --- .../nvidia/spark/rapids/tool/analysis/StatisticsMetrics.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/StatisticsMetrics.scala b/core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/StatisticsMetrics.scala index de4b92b38..5c7e505cb 100644 --- a/core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/StatisticsMetrics.scala +++ b/core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/StatisticsMetrics.scala @@ -19,12 +19,12 @@ package com.nvidia.spark.rapids.tool.analysis import org.apache.spark.sql.rapids.tool.util.InPlaceMedianArrView.{chooseMidpointPivotInPlace, findMedianInPlace} // Store (min, median, max, total) for a given metric -case class StatisticsMetrics(min: Long, med: Long, max: Long, count: Int, total: Long) +case class StatisticsMetrics(min: Long, med: Long, max: Long, count: Long, total: Long) object StatisticsMetrics { // a static variable used to represent zero-statistics instead of allocating a dummy record // on every calculation. - val ZERO_RECORD: StatisticsMetrics = StatisticsMetrics(0L, 0L, 0L, 0, 0L) + val ZERO_RECORD: StatisticsMetrics = StatisticsMetrics(0L, 0L, 0L, 0L, 0L) def createFromArr(arr: Array[Long]): StatisticsMetrics = { if (arr.isEmpty) {