== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#912484, add#912485, remove#912486, metaData#912487, protocol#912488, cdc#912489, checkpointMetadata#912490, sidecar#912491, domainMetadata#912492, commitInfo#912493]
Arguments: [txn#912484, add#912485, remove#912486, metaData#912487, protocol#912488, cdc#912489, checkpointMetadata#912490, sidecar#912491, domainMetadata#912492, commitInfo#912493], MapPartitionsRDD[42737] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#912484, add#912485, remove#912486, metaData#912487, protocol#912488, cdc#912489, checkpointMetadata#912490, sidecar#912491, domainMetadata#912492, commitInfo#912493]
Condition : isnotnull(add#912485)
(3) Project [codegen id : 1]
Output [11]: [add#912485.path AS path#912537, add#912485.partitionValues AS partitionValues#912538, add#912485.size AS size#912539L, add#912485.modificationTime AS modificationTime#912540L, add#912485.dataChange AS dataChange#912541, add#912485.stats AS stats#912542, add#912485.tags AS tags#912543, add#912485.deletionVector AS deletionVector#912544, add#912485.baseRowId AS baseRowId#912545L, add#912485.defaultRowCommitVersion AS defaultRowCommitVersion#912546L, add#912485.clusteringProvider AS clusteringProvider#912547]
Input [10]: [txn#912484, add#912485, remove#912486, metaData#912487, protocol#912488, cdc#912489, checkpointMetadata#912490, sidecar#912491, domainMetadata#912492, commitInfo#912493]