== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#246, add#247, remove#248, metaData#249, protocol#250, cdc#251, checkpointMetadata#252, sidecar#253, domainMetadata#254, commitInfo#255]
Arguments: [txn#246, add#247, remove#248, metaData#249, protocol#250, cdc#251, checkpointMetadata#252, sidecar#253, domainMetadata#254, commitInfo#255], MapPartitionsRDD[13] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#246, add#247, remove#248, metaData#249, protocol#250, cdc#251, checkpointMetadata#252, sidecar#253, domainMetadata#254, commitInfo#255]
Condition : isnotnull(add#247)
(3) Project [codegen id : 1]
Output [11]: [add#247.path AS path#299, add#247.partitionValues AS partitionValues#300, add#247.size AS size#301L, add#247.modificationTime AS modificationTime#302L, add#247.dataChange AS dataChange#303, add#247.stats AS stats#304, add#247.tags AS tags#305, add#247.deletionVector AS deletionVector#306, add#247.baseRowId AS baseRowId#307L, add#247.defaultRowCommitVersion AS defaultRowCommitVersion#308L, add#247.clusteringProvider AS clusteringProvider#309]
Input [10]: [txn#246, add#247, remove#248, metaData#249, protocol#250, cdc#251, checkpointMetadata#252, sidecar#253, domainMetadata#254, commitInfo#255]