== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#141984, add#141985, remove#141986, metaData#141987, protocol#141988, cdc#141989, checkpointMetadata#141990, sidecar#141991, domainMetadata#141992, commitInfo#141993]
Arguments: [txn#141984, add#141985, remove#141986, metaData#141987, protocol#141988, cdc#141989, checkpointMetadata#141990, sidecar#141991, domainMetadata#141992, commitInfo#141993], MapPartitionsRDD[8271] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#141984, add#141985, remove#141986, metaData#141987, protocol#141988, cdc#141989, checkpointMetadata#141990, sidecar#141991, domainMetadata#141992, commitInfo#141993]
Condition : isnotnull(add#141985)
(3) Project [codegen id : 1]
Output [11]: [add#141985.path AS path#142037, add#141985.partitionValues AS partitionValues#142038, add#141985.size AS size#142039L, add#141985.modificationTime AS modificationTime#142040L, add#141985.dataChange AS dataChange#142041, null AS stats#142048, add#141985.tags AS tags#142043, add#141985.deletionVector AS deletionVector#142044, add#141985.baseRowId AS baseRowId#142045L, add#141985.defaultRowCommitVersion AS defaultRowCommitVersion#142046L, add#141985.clusteringProvider AS clusteringProvider#142047]
Input [10]: [txn#141984, add#141985, remove#141986, metaData#141987, protocol#141988, cdc#141989, checkpointMetadata#141990, sidecar#141991, domainMetadata#141992, commitInfo#141993]