== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1008135, add#1008136, remove#1008137, metaData#1008138, protocol#1008139, cdc#1008140, checkpointMetadata#1008141, sidecar#1008142, domainMetadata#1008143, commitInfo#1008144]
Arguments: [txn#1008135, add#1008136, remove#1008137, metaData#1008138, protocol#1008139, cdc#1008140, checkpointMetadata#1008141, sidecar#1008142, domainMetadata#1008143, commitInfo#1008144], MapPartitionsRDD[47127] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1008135, add#1008136, remove#1008137, metaData#1008138, protocol#1008139, cdc#1008140, checkpointMetadata#1008141, sidecar#1008142, domainMetadata#1008143, commitInfo#1008144]
Condition : isnotnull(add#1008136)
(3) Project [codegen id : 1]
Output [11]: [add#1008136.path AS path#1008188, add#1008136.partitionValues AS partitionValues#1008189, add#1008136.size AS size#1008190L, add#1008136.modificationTime AS modificationTime#1008191L, add#1008136.dataChange AS dataChange#1008192, add#1008136.stats AS stats#1008193, add#1008136.tags AS tags#1008194, add#1008136.deletionVector AS deletionVector#1008195, add#1008136.baseRowId AS baseRowId#1008196L, add#1008136.defaultRowCommitVersion AS defaultRowCommitVersion#1008197L, add#1008136.clusteringProvider AS clusteringProvider#1008198]
Input [10]: [txn#1008135, add#1008136, remove#1008137, metaData#1008138, protocol#1008139, cdc#1008140, checkpointMetadata#1008141, sidecar#1008142, domainMetadata#1008143, commitInfo#1008144]