diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala index 644d8058a377a..da911f006d74c 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala @@ -197,6 +197,8 @@ case class TableV2Relation( def newReader(): DataSourceReader = table.createReader(options, None) + override def statistics: Statistics = computeStats(output, Seq.empty) + /** * Used to return statistics when filters and projection are available. */