yaooqinn commented on code in PR #50798:
URL: https://github.com/apache/spark/pull/50798#discussion_r2075256731
##########
sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala:
##########
@@ -239,21 +239,23 @@ trait FileSourceScanLike extends DataSourceScanExec {
// Identifier for the table in the metastore.
def tableIdentifier: Option[TableIdentifier]
-
lazy val fileConstantMetadataColumns: Seq[AttributeReference] =
output.collect {
// Collect metadata columns to be handled outside of the scan by appending
constant columns.
case FileSourceConstantMetadataAttribute(attr) => attr
}
- override def vectorTypes: Option[Seq[String]] =
+ protected def sessionState: SessionState = relation.sparkSession.sessionState
Review Comment:
We can add style check later
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
