== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1011616, add#1011617, remove#1011618, metaData#1011619, protocol#1011620, cdc#1011621, checkpointMetadata#1011622, sidecar#1011623, domainMetadata#1011624, commitInfo#1011625]
Arguments: [txn#1011616, add#1011617, remove#1011618, metaData#1011619, protocol#1011620, cdc#1011621, checkpointMetadata#1011622, sidecar#1011623, domainMetadata#1011624, commitInfo#1011625], MapPartitionsRDD[50482] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1011616, add#1011617, remove#1011618, metaData#1011619, protocol#1011620, cdc#1011621, checkpointMetadata#1011622, sidecar#1011623, domainMetadata#1011624, commitInfo#1011625]
Condition : isnotnull(add#1011617)
(3) Project [codegen id : 1]
Output [11]: [add#1011617.path AS path#1011669, add#1011617.partitionValues AS partitionValues#1011670, add#1011617.size AS size#1011671L, add#1011617.modificationTime AS modificationTime#1011672L, add#1011617.dataChange AS dataChange#1011673, add#1011617.stats AS stats#1011674, add#1011617.tags AS tags#1011675, add#1011617.deletionVector AS deletionVector#1011676, add#1011617.baseRowId AS baseRowId#1011677L, add#1011617.defaultRowCommitVersion AS defaultRowCommitVersion#1011678L, add#1011617.clusteringProvider AS clusteringProvider#1011679]
Input [10]: [txn#1011616, add#1011617, remove#1011618, metaData#1011619, protocol#1011620, cdc#1011621, checkpointMetadata#1011622, sidecar#1011623, domainMetadata#1011624, commitInfo#1011625]