Fix dataformat routing: check for 'composite' not 'parquet'

The pluggable dataformat value is 'composite', not 'parquet'.

Signed-off-by: bowenlan-amzn <bowenlan23@gmail.com>

Author: bowenlan-amzn

plugin/src/main/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryAction.java

@@ -76,7 +76,7 @@ public RestUnifiedQueryAction(
   /**
    * Returns true iff the target index has {@link
    * IndexSettings#PLUGGABLE_DATAFORMAT_ENABLED_SETTING} set and {@link
-   * IndexSettings#PLUGGABLE_DATAFORMAT_VALUE_SETTING} is {@code "parquet"}, routing it to
+   * IndexSettings#PLUGGABLE_DATAFORMAT_VALUE_SETTING} is {@code "composite"}, routing it to
    * DataFusion instead of the Calcite→DSL path.
    *
    * <p>Note: This creates a separate UnifiedQueryContext for parsing. The context cannot be shared
@@ -110,7 +110,7 @@ private boolean isPluggableDataformatIndex(String indexName) {
     }
     var settings = indexMetadata.getSettings();
     return IndexSettings.PLUGGABLE_DATAFORMAT_ENABLED_SETTING.get(settings)
-        && "parquet".equals(IndexSettings.PLUGGABLE_DATAFORMAT_VALUE_SETTING.get(settings));
+        && "composite".equals(IndexSettings.PLUGGABLE_DATAFORMAT_VALUE_SETTING.get(settings));
   }
 
   /** Execute a query through the unified query pipeline on the sql-worker thread pool. */

plugin/src/test/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryActionTest.java

@@ -25,7 +25,7 @@
 
 /**
  * Tests for analytics index routing in RestUnifiedQueryAction. Routing requires both {@code
- * index.pluggable.dataformat.enabled=true} and {@code index.pluggable.dataformat=parquet}.
+ * index.pluggable.dataformat.enabled=true} and {@code index.pluggable.dataformat=composite}.
  */
 public class RestUnifiedQueryActionTest {
 
@@ -57,7 +57,7 @@ public void pluggableDataformatIndexRoutesToAnalytics() {
         "parquet_logs",
         Settings.builder()
             .put(IndexSettings.PLUGGABLE_DATAFORMAT_ENABLED_SETTING.getKey(), true)
-            .put(IndexSettings.PLUGGABLE_DATAFORMAT_VALUE_SETTING.getKey(), "parquet")
+            .put(IndexSettings.PLUGGABLE_DATAFORMAT_VALUE_SETTING.getKey(), "composite")
             .build());
 
     assertTrue(action.isAnalyticsIndex("source = parquet_logs | fields ts", QueryType.PPL));