== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1100160, add#1100161, remove#1100162, metaData#1100163, protocol#1100164, cdc#1100165, checkpointMetadata#1100166, sidecar#1100167, domainMetadata#1100168, commitInfo#1100169]
Arguments: [txn#1100160, add#1100161, remove#1100162, metaData#1100163, protocol#1100164, cdc#1100165, checkpointMetadata#1100166, sidecar#1100167, domainMetadata#1100168, commitInfo#1100169], MapPartitionsRDD[54781] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1100160, add#1100161, remove#1100162, metaData#1100163, protocol#1100164, cdc#1100165, checkpointMetadata#1100166, sidecar#1100167, domainMetadata#1100168, commitInfo#1100169]
Condition : isnotnull(add#1100161)
(3) Project [codegen id : 1]
Output [11]: [add#1100161.path AS path#1100213, add#1100161.partitionValues AS partitionValues#1100214, add#1100161.size AS size#1100215L, add#1100161.modificationTime AS modificationTime#1100216L, add#1100161.dataChange AS dataChange#1100217, null AS stats#1100224, add#1100161.tags AS tags#1100219, add#1100161.deletionVector AS deletionVector#1100220, add#1100161.baseRowId AS baseRowId#1100221L, add#1100161.defaultRowCommitVersion AS defaultRowCommitVersion#1100222L, add#1100161.clusteringProvider AS clusteringProvider#1100223]
Input [10]: [txn#1100160, add#1100161, remove#1100162, metaData#1100163, protocol#1100164, cdc#1100165, checkpointMetadata#1100166, sidecar#1100167, domainMetadata#1100168, commitInfo#1100169]