== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1008948, add#1008949, remove#1008950, metaData#1008951, protocol#1008952, cdc#1008953, checkpointMetadata#1008954, sidecar#1008955, domainMetadata#1008956, commitInfo#1008957]
Arguments: [txn#1008948, add#1008949, remove#1008950, metaData#1008951, protocol#1008952, cdc#1008953, checkpointMetadata#1008954, sidecar#1008955, domainMetadata#1008956, commitInfo#1008957], MapPartitionsRDD[47232] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1008948, add#1008949, remove#1008950, metaData#1008951, protocol#1008952, cdc#1008953, checkpointMetadata#1008954, sidecar#1008955, domainMetadata#1008956, commitInfo#1008957]
Condition : isnotnull(add#1008949)
(3) Project [codegen id : 1]
Output [11]: [add#1008949.path AS path#1009001, add#1008949.partitionValues AS partitionValues#1009002, add#1008949.size AS size#1009003L, add#1008949.modificationTime AS modificationTime#1009004L, add#1008949.dataChange AS dataChange#1009005, add#1008949.stats AS stats#1009006, add#1008949.tags AS tags#1009007, add#1008949.deletionVector AS deletionVector#1009008, add#1008949.baseRowId AS baseRowId#1009009L, add#1008949.defaultRowCommitVersion AS defaultRowCommitVersion#1009010L, add#1008949.clusteringProvider AS clusteringProvider#1009011]
Input [10]: [txn#1008948, add#1008949, remove#1008950, metaData#1008951, protocol#1008952, cdc#1008953, checkpointMetadata#1008954, sidecar#1008955, domainMetadata#1008956, commitInfo#1008957]