== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#13830, add#13831, remove#13832, metaData#13833, protocol#13834, cdc#13835, checkpointMetadata#13836, sidecar#13837, domainMetadata#13838, commitInfo#13839]
Arguments: [txn#13830, add#13831, remove#13832, metaData#13833, protocol#13834, cdc#13835, checkpointMetadata#13836, sidecar#13837, domainMetadata#13838, commitInfo#13839], MapPartitionsRDD[631] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#13830, add#13831, remove#13832, metaData#13833, protocol#13834, cdc#13835, checkpointMetadata#13836, sidecar#13837, domainMetadata#13838, commitInfo#13839]
Condition : isnotnull(add#13831)
(3) Project [codegen id : 1]
Output [11]: [add#13831.path AS path#13883, add#13831.partitionValues AS partitionValues#13884, add#13831.size AS size#13885L, add#13831.modificationTime AS modificationTime#13886L, add#13831.dataChange AS dataChange#13887, null AS stats#13894, add#13831.tags AS tags#13889, add#13831.deletionVector AS deletionVector#13890, add#13831.baseRowId AS baseRowId#13891L, add#13831.defaultRowCommitVersion AS defaultRowCommitVersion#13892L, add#13831.clusteringProvider AS clusteringProvider#13893]
Input [10]: [txn#13830, add#13831, remove#13832, metaData#13833, protocol#13834, cdc#13835, checkpointMetadata#13836, sidecar#13837, domainMetadata#13838, commitInfo#13839]