== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1194, add#1195, remove#1196, metaData#1197, protocol#1198, cdc#1199, checkpointMetadata#1200, sidecar#1201, domainMetadata#1202, commitInfo#1203]
Arguments: [txn#1194, add#1195, remove#1196, metaData#1197, protocol#1198, cdc#1199, checkpointMetadata#1200, sidecar#1201, domainMetadata#1202, commitInfo#1203], MapPartitionsRDD[110] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1194, add#1195, remove#1196, metaData#1197, protocol#1198, cdc#1199, checkpointMetadata#1200, sidecar#1201, domainMetadata#1202, commitInfo#1203]
Condition : isnotnull(add#1195)
(3) Project [codegen id : 1]
Output [11]: [add#1195.path AS path#1247, add#1195.partitionValues AS partitionValues#1248, add#1195.size AS size#1249L, add#1195.modificationTime AS modificationTime#1250L, add#1195.dataChange AS dataChange#1251, null AS stats#1258, add#1195.tags AS tags#1253, add#1195.deletionVector AS deletionVector#1254, add#1195.baseRowId AS baseRowId#1255L, add#1195.defaultRowCommitVersion AS defaultRowCommitVersion#1256L, add#1195.clusteringProvider AS clusteringProvider#1257]
Input [10]: [txn#1194, add#1195, remove#1196, metaData#1197, protocol#1198, cdc#1199, checkpointMetadata#1200, sidecar#1201, domainMetadata#1202, commitInfo#1203]