== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#15013, add#15014, remove#15015, metaData#15016, protocol#15017, cdc#15018, checkpointMetadata#15019, sidecar#15020, domainMetadata#15021, commitInfo#15022]
Arguments: [txn#15013, add#15014, remove#15015, metaData#15016, protocol#15017, cdc#15018, checkpointMetadata#15019, sidecar#15020, domainMetadata#15021, commitInfo#15022], MapPartitionsRDD[1488] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#15013, add#15014, remove#15015, metaData#15016, protocol#15017, cdc#15018, checkpointMetadata#15019, sidecar#15020, domainMetadata#15021, commitInfo#15022]
Condition : isnotnull(add#15014)
(3) Project [codegen id : 1]
Output [11]: [add#15014.path AS path#15066, add#15014.partitionValues AS partitionValues#15067, add#15014.size AS size#15068L, add#15014.modificationTime AS modificationTime#15069L, add#15014.dataChange AS dataChange#15070, null AS stats#15077, add#15014.tags AS tags#15072, add#15014.deletionVector AS deletionVector#15073, add#15014.baseRowId AS baseRowId#15074L, add#15014.defaultRowCommitVersion AS defaultRowCommitVersion#15075L, add#15014.clusteringProvider AS clusteringProvider#15076]
Input [10]: [txn#15013, add#15014, remove#15015, metaData#15016, protocol#15017, cdc#15018, checkpointMetadata#15019, sidecar#15020, domainMetadata#15021, commitInfo#15022]