== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#87945, add#87946, remove#87947, metaData#87948, protocol#87949, cdc#87950, checkpointMetadata#87951, sidecar#87952, domainMetadata#87953, commitInfo#87954]
Arguments: [txn#87945, add#87946, remove#87947, metaData#87948, protocol#87949, cdc#87950, checkpointMetadata#87951, sidecar#87952, domainMetadata#87953, commitInfo#87954], MapPartitionsRDD[5061] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#87945, add#87946, remove#87947, metaData#87948, protocol#87949, cdc#87950, checkpointMetadata#87951, sidecar#87952, domainMetadata#87953, commitInfo#87954]
Condition : isnotnull(add#87946)
(3) Project [codegen id : 1]
Output [11]: [add#87946.path AS path#87998, add#87946.partitionValues AS partitionValues#87999, add#87946.size AS size#88000L, add#87946.modificationTime AS modificationTime#88001L, add#87946.dataChange AS dataChange#88002, add#87946.stats AS stats#88003, add#87946.tags AS tags#88004, add#87946.deletionVector AS deletionVector#88005, add#87946.baseRowId AS baseRowId#88006L, add#87946.defaultRowCommitVersion AS defaultRowCommitVersion#88007L, add#87946.clusteringProvider AS clusteringProvider#88008]
Input [10]: [txn#87945, add#87946, remove#87947, metaData#87948, protocol#87949, cdc#87950, checkpointMetadata#87951, sidecar#87952, domainMetadata#87953, commitInfo#87954]