== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#993288, add#993289, remove#993290, metaData#993291, protocol#993292, cdc#993293, checkpointMetadata#993294, sidecar#993295, domainMetadata#993296, commitInfo#993297]
Arguments: [txn#993288, add#993289, remove#993290, metaData#993291, protocol#993292, cdc#993293, checkpointMetadata#993294, sidecar#993295, domainMetadata#993296, commitInfo#993297], MapPartitionsRDD[46560] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#993288, add#993289, remove#993290, metaData#993291, protocol#993292, cdc#993293, checkpointMetadata#993294, sidecar#993295, domainMetadata#993296, commitInfo#993297]
Condition : isnotnull(add#993289)
(3) Project [codegen id : 1]
Output [11]: [add#993289.path AS path#993341, add#993289.partitionValues AS partitionValues#993342, add#993289.size AS size#993343L, add#993289.modificationTime AS modificationTime#993344L, add#993289.dataChange AS dataChange#993345, add#993289.stats AS stats#993346, add#993289.tags AS tags#993347, add#993289.deletionVector AS deletionVector#993348, add#993289.baseRowId AS baseRowId#993349L, add#993289.defaultRowCommitVersion AS defaultRowCommitVersion#993350L, add#993289.clusteringProvider AS clusteringProvider#993351]
Input [10]: [txn#993288, add#993289, remove#993290, metaData#993291, protocol#993292, cdc#993293, checkpointMetadata#993294, sidecar#993295, domainMetadata#993296, commitInfo#993297]