From d454579264aba83fb633400a6f6f6fee84ede0f7 Mon Sep 17 00:00:00 2001 From: vamshiwmd Date: Fri, 21 Jul 2023 08:42:36 -0700 Subject: [PATCH] Reversed Change clean --- .../com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala | 2 +- .../scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala b/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala index f806c4a8d..2d6bb53a6 100644 --- a/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala +++ b/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala @@ -6,7 +6,7 @@ import org.apache.spark.sql.types._ import scala.collection.mutable import scala.collection.mutable.ArrayBuffer -/* +/** * DISTINCT aggregation implementation. * * @param metricCol Name of the metric column or a Spark SQL column expression for derived metric diff --git a/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala b/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala index 147d2df7f..dfc3f3796 100644 --- a/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala +++ b/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala @@ -198,6 +198,7 @@ object AssertFeatureUtils { } else if(field.dataType == ArrayType(StringType, false)) { assertStringArrayEquals(actualValue.asInstanceOf[Array[String]], expectedValue.asInstanceOf[Array[String]]) } else { + } } }