refactor(python): remove explain_plan api from sql

python/python/lance/dataset.py

@@ -3575,24 +3575,6 @@ def to_stream_reader(self) -> pa.RecordBatchReader:
         """
         return self._query.to_stream_reader()
 
-    def explain_plan(self, verbose: bool = False, analyze: bool = False) -> str:
-        """
-        Explain the query plan.
-
-        Parameters
-        ----------
-        verbose: bool, default False
-            If True, print the verbose plan.
-        analyze: bool, default False
-            If True, analyze the query and print the statistics.
-
-        Returns
-        -------
-        str
-            The query plan.
-        """
-        return self._query.explain_plan(verbose, analyze)
-
 
 class SqlQueryBuilder:
     """

python/python/tests/test_dataset.py

@@ -4043,6 +4043,11 @@ def test_dataset_sql(tmp_path: Path):
     expected = pa.table({"id": [2, 3], "value": ["b", "c"]})
     assert pa.Table.from_batches(result) == expected
 
+    # Validate explain_plan() returns readable plan text and contains recognizable markers
+    plan_text = query.explain_plan()
+    assert isinstance(plan_text, str) and len(plan_text) > 0
+    assert any(tok in plan_text for tok in ["ProjectionExec", "LanceRead", "logical_plan", "Plan with Metrics"])
+
     stream_result = (
         ds.sql("SELECT value FROM test WHERE id = 1")
         .table_name("test")

python/src/dataset.rs

@@ -2620,7 +2620,6 @@ impl SqlQuery {
             Box::new(LanceReader::from_stream(dataset_stream));
         Python::with_gil(|py| reader.into_pyarrow(py))
     }
-}
 
 #[pyclass(name = "SqlQueryBuilder", module = "_lib", subclass)]
 #[derive(Clone)]

rust/lance/src/dataset/sql.rs

@@ -3,10 +3,12 @@
 
 use crate::datafusion::LanceTableProvider;
 use crate::Dataset;
 use arrow_array::RecordBatch;
 use datafusion::dataframe::DataFrame;
 use datafusion::execution::SendableRecordBatchStream;
 use datafusion::prelude::SessionContext;
+use datafusion::physical_plan::display::DisplayableExecutionPlan;
+use lance_datafusion::exec::{analyze_plan, LanceExecutionOptions};
 use futures::TryStreamExt;
 use std::sync::Arc;