== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#13928, add#13929, remove#13930, metaData#13931, protocol#13932, cdc#13933, checkpointMetadata#13934, sidecar#13935, domainMetadata#13936, commitInfo#13937]
Arguments: [txn#13928, add#13929, remove#13930, metaData#13931, protocol#13932, cdc#13933, checkpointMetadata#13934, sidecar#13935, domainMetadata#13936, commitInfo#13937], MapPartitionsRDD[635] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#13928, add#13929, remove#13930, metaData#13931, protocol#13932, cdc#13933, checkpointMetadata#13934, sidecar#13935, domainMetadata#13936, commitInfo#13937]
Condition : isnotnull(add#13929)
(3) Project [codegen id : 1]
Output [11]: [add#13929.path AS path#13981, add#13929.partitionValues AS partitionValues#13982, add#13929.size AS size#13983L, add#13929.modificationTime AS modificationTime#13984L, add#13929.dataChange AS dataChange#13985, add#13929.stats AS stats#13986, add#13929.tags AS tags#13987, add#13929.deletionVector AS deletionVector#13988, add#13929.baseRowId AS baseRowId#13989L, add#13929.defaultRowCommitVersion AS defaultRowCommitVersion#13990L, add#13929.clusteringProvider AS clusteringProvider#13991]
Input [10]: [txn#13928, add#13929, remove#13930, metaData#13931, protocol#13932, cdc#13933, checkpointMetadata#13934, sidecar#13935, domainMetadata#13936, commitInfo#13937]