Zouxxyy commented on code in PR #5985:
URL: https://github.com/apache/paimon/pull/5985#discussion_r2245275768
##########
paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/ColumnPruningAndPushDown.scala:
##########
@@ -30,12 +31,20 @@ import org.apache.spark.sql.connector.read.Scan
import org.apache.spark.sql.types.StructType
trait ColumnPruningAndPushDown extends Scan with Logging {
- def table: Table
+ def table: InnerTable
def requiredSchema: StructType
def filters: Seq[Predicate]
def pushDownLimit: Option[Int] = None
- lazy val tableRowType: RowType = table.rowType
+ lazy val tableRowType: RowType = {
+ val coreOptions: CoreOptions = CoreOptions.fromMap(table.options())
+ if (coreOptions.rowTrackingEnabled()) {
Review Comment:
Actually only when there are row lineage fields in `requiredSchema` (line
56) , then they will enter to `withReadType` to scan. `tableRowType` here just
like full rowtype can be scanned
--
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: issues-unsubscr...@paimon.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
