Rename class

Signed-off-by: Rupal Mahajan <[email protected]>
opensearch-project · Apr 15, 2024 · 8bee98f · 8bee98f
1 parent b782c1d
commit 8bee98f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSpark.scala b/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSpark.scala
@@ -20,7 +20,7 @@ import org.opensearch.flint.spark.refresh.FlintSparkIndexRefresh
 import org.opensearch.flint.spark.refresh.FlintSparkIndexRefresh.RefreshMode._
 import org.opensearch.flint.spark.skipping.FlintSparkSkippingIndex
 import org.opensearch.flint.spark.skipping.FlintSparkSkippingStrategy.SkippingKindSerializer
-import org.opensearch.flint.spark.skipping.recommendations.DataTypeSkippingStrategy
+import org.opensearch.flint.spark.skipping.recommendations.RuleBasedSkippingStrategy
 
 import org.apache.spark.internal.Logging
 import org.apache.spark.sql.{DataFrame, Row, SparkSession}
@@ -376,7 +376,7 @@ class FlintSpark(val spark: SparkSession) extends Logging {
    *   skipping index recommendation dataframe
    */
   def analyzeSkippingIndex(schema: StructType, data: Seq[Row]): Seq[Row] = {
-    new DataTypeSkippingStrategy()
+    new RuleBasedSkippingStrategy()
       .analyzeSkippingIndexColumns(
         spark.createDataFrame(spark.sparkContext.parallelize(data), schema),
         spark)

diff --git a/...mendations/DataTypeSkippingStrategy.scala → ...endations/RuleBasedSkippingStrategy.scala b/...mendations/DataTypeSkippingStrategy.scala → ...endations/RuleBasedSkippingStrategy.scala
@@ -15,7 +15,7 @@ import org.apache.spark.sql.functions.col
 /**
  * Data type based skipping index column and algorithm selection.
  */
-class DataTypeSkippingStrategy extends AnalyzeSkippingStrategy {
+class RuleBasedSkippingStrategy extends AnalyzeSkippingStrategy {
 
   /**
    * Recommend skipping index columns and algorithm.