== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#10859, add#10860, remove#10861, metaData#10862, protocol#10863, cdc#10864, checkpointMetadata#10865, sidecar#10866, domainMetadata#10867, commitInfo#10868]
Arguments: [txn#10859, add#10860, remove#10861, metaData#10862, protocol#10863, cdc#10864, checkpointMetadata#10865, sidecar#10866, domainMetadata#10867, commitInfo#10868], MapPartitionsRDD[1068] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#10859, add#10860, remove#10861, metaData#10862, protocol#10863, cdc#10864, checkpointMetadata#10865, sidecar#10866, domainMetadata#10867, commitInfo#10868]
Condition : isnotnull(add#10860)
(3) Project [codegen id : 1]
Output [11]: [add#10860.path AS path#10912, add#10860.partitionValues AS partitionValues#10913, add#10860.size AS size#10914L, add#10860.modificationTime AS modificationTime#10915L, add#10860.dataChange AS dataChange#10916, add#10860.stats AS stats#10917, add#10860.tags AS tags#10918, add#10860.deletionVector AS deletionVector#10919, add#10860.baseRowId AS baseRowId#10920L, add#10860.defaultRowCommitVersion AS defaultRowCommitVersion#10921L, add#10860.clusteringProvider AS clusteringProvider#10922]
Input [10]: [txn#10859, add#10860, remove#10861, metaData#10862, protocol#10863, cdc#10864, checkpointMetadata#10865, sidecar#10866, domainMetadata#10867, commitInfo#10868]