Rename skipping index check method

Signed-off-by: Chen Dai <[email protected]>
opensearch-project · Mar 20, 2024 · c8b358c · c8b358c
1 parent d878587
commit c8b358c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ion/src/main/scala/org/opensearch/flint/spark/skipping/ApplyFlintSparkSkippingIndex.scala b/...ion/src/main/scala/org/opensearch/flint/spark/skipping/ApplyFlintSparkSkippingIndex.scala
@@ -40,7 +40,7 @@ class ApplyFlintSparkSkippingIndex(flint: FlintSpark) extends Rule[LogicalPlan]
             false))
         if hasNoDisjunction(condition) && !location.isInstanceOf[FlintSparkSkippingFileIndex] =>
       val index = flint.describeIndex(getIndexName(table))
-      if (hasActiveSkippingIndex(index)) {
+      if (isActiveSkippingIndex(index)) {
         val skippingIndex = index.get.asInstanceOf[FlintSparkSkippingIndex]
         val indexFilter = rewriteToIndexFilter(skippingIndex, condition)
 
@@ -69,7 +69,7 @@ class ApplyFlintSparkSkippingIndex(flint: FlintSpark) extends Rule[LogicalPlan]
           // Check if query plan already rewritten
           table.isInstanceOf[LogsTable] && !table.asInstanceOf[LogsTable].hasFileIndexScan() =>
       val index = flint.describeIndex(getIndexName(catalog, identifier))
-      if (hasActiveSkippingIndex(index)) {
+      if (isActiveSkippingIndex(index)) {
         val skippingIndex = index.get.asInstanceOf[FlintSparkSkippingIndex]
         val indexFilter = rewriteToIndexFilter(skippingIndex, condition)
         /*
@@ -123,7 +123,7 @@ class ApplyFlintSparkSkippingIndex(flint: FlintSpark) extends Rule[LogicalPlan]
     }.isEmpty
   }
 
-  private def hasActiveSkippingIndex(index: Option[FlintSparkIndex]): Boolean = {
+  private def isActiveSkippingIndex(index: Option[FlintSparkIndex]): Boolean = {
     index.isDefined &&
     index.get.kind == SKIPPING_INDEX_TYPE &&
     index.get.latestLogEntry.exists(_.state != DELETED)