== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#152224, add#152225, remove#152226, metaData#152227, protocol#152228, cdc#152229, checkpointMetadata#152230, sidecar#152231, domainMetadata#152232, commitInfo#152233]
Arguments: [txn#152224, add#152225, remove#152226, metaData#152227, protocol#152228, cdc#152229, checkpointMetadata#152230, sidecar#152231, domainMetadata#152232, commitInfo#152233], MapPartitionsRDD[8791] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#152224, add#152225, remove#152226, metaData#152227, protocol#152228, cdc#152229, checkpointMetadata#152230, sidecar#152231, domainMetadata#152232, commitInfo#152233]
Condition : isnotnull(add#152225)
(3) Project [codegen id : 1]
Output [11]: [add#152225.path AS path#152277, add#152225.partitionValues AS partitionValues#152278, add#152225.size AS size#152279L, add#152225.modificationTime AS modificationTime#152280L, add#152225.dataChange AS dataChange#152281, null AS stats#152288, add#152225.tags AS tags#152283, add#152225.deletionVector AS deletionVector#152284, add#152225.baseRowId AS baseRowId#152285L, add#152225.defaultRowCommitVersion AS defaultRowCommitVersion#152286L, add#152225.clusteringProvider AS clusteringProvider#152287]
Input [10]: [txn#152224, add#152225, remove#152226, metaData#152227, protocol#152228, cdc#152229, checkpointMetadata#152230, sidecar#152231, domainMetadata#152232, commitInfo#152233]