diff --git a/plugin/src/main/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryAction.java b/plugin/src/main/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryAction.java index 7d39deb68d..e1bb84778d 100644 --- a/plugin/src/main/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryAction.java +++ b/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. * *

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. */ diff --git a/plugin/src/test/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryActionTest.java b/plugin/src/test/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryActionTest.java index 25f157f0d9..c801266036 100644 --- a/plugin/src/test/java/org/opensearch/sql/plugin/rest/RestUnifiedQueryActionTest.java +++ b/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));