== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#67994, add#67995, remove#67996, metaData#67997, protocol#67998, cdc#67999, checkpointMetadata#68000, sidecar#68001, domainMetadata#68002, commitInfo#68003]
Arguments: [txn#67994, add#67995, remove#67996, metaData#67997, protocol#67998, cdc#67999, checkpointMetadata#68000, sidecar#68001, domainMetadata#68002, commitInfo#68003], MapPartitionsRDD[4022] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#67994, add#67995, remove#67996, metaData#67997, protocol#67998, cdc#67999, checkpointMetadata#68000, sidecar#68001, domainMetadata#68002, commitInfo#68003]
Condition : isnotnull(add#67995)
(3) Project [codegen id : 1]
Output [11]: [add#67995.path AS path#68047, add#67995.partitionValues AS partitionValues#68048, add#67995.size AS size#68049L, add#67995.modificationTime AS modificationTime#68050L, add#67995.dataChange AS dataChange#68051, null AS stats#68058, add#67995.tags AS tags#68053, add#67995.deletionVector AS deletionVector#68054, add#67995.baseRowId AS baseRowId#68055L, add#67995.defaultRowCommitVersion AS defaultRowCommitVersion#68056L, add#67995.clusteringProvider AS clusteringProvider#68057]
Input [10]: [txn#67994, add#67995, remove#67996, metaData#67997, protocol#67998, cdc#67999, checkpointMetadata#68000, sidecar#68001, domainMetadata#68002, commitInfo#68003]