== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#21517102, add#21517103, remove#21517104, metaData#21517105, protocol#21517106, cdc#21517107, checkpointMetadata#21517108, sidecar#21517109, domainMetadata#21517110, commitInfo#21517111]
Arguments: [txn#21517102, add#21517103, remove#21517104, metaData#21517105, protocol#21517106, cdc#21517107, checkpointMetadata#21517108, sidecar#21517109, domainMetadata#21517110, commitInfo#21517111], MapPartitionsRDD[1241217] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#21517102, add#21517103, remove#21517104, metaData#21517105, protocol#21517106, cdc#21517107, checkpointMetadata#21517108, sidecar#21517109, domainMetadata#21517110, commitInfo#21517111]
Condition : isnotnull(add#21517103)
(3) Project [codegen id : 1]
Output [11]: [add#21517103.path AS path#21517155, add#21517103.partitionValues AS partitionValues#21517156, add#21517103.size AS size#21517157L, add#21517103.modificationTime AS modificationTime#21517158L, add#21517103.dataChange AS dataChange#21517159, add#21517103.stats AS stats#21517160, add#21517103.tags AS tags#21517161, add#21517103.deletionVector AS deletionVector#21517162, add#21517103.baseRowId AS baseRowId#21517163L, add#21517103.defaultRowCommitVersion AS defaultRowCommitVersion#21517164L, add#21517103.clusteringProvider AS clusteringProvider#21517165]
Input [10]: [txn#21517102, add#21517103, remove#21517104, metaData#21517105, protocol#21517106, cdc#21517107, checkpointMetadata#21517108, sidecar#21517109, domainMetadata#21517110, commitInfo#21517111]