== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#19265, add#19266, remove#19267, metaData#19268, protocol#19269, cdc#19270, checkpointMetadata#19271, sidecar#19272, domainMetadata#19273, commitInfo#19274]
Arguments: [txn#19265, add#19266, remove#19267, metaData#19268, protocol#19269, cdc#19270, checkpointMetadata#19271, sidecar#19272, domainMetadata#19273, commitInfo#19274], MapPartitionsRDD[1912] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#19265, add#19266, remove#19267, metaData#19268, protocol#19269, cdc#19270, checkpointMetadata#19271, sidecar#19272, domainMetadata#19273, commitInfo#19274]
Condition : isnotnull(add#19266)
(3) Project [codegen id : 1]
Output [11]: [add#19266.path AS path#19318, add#19266.partitionValues AS partitionValues#19319, add#19266.size AS size#19320L, add#19266.modificationTime AS modificationTime#19321L, add#19266.dataChange AS dataChange#19322, null AS stats#19329, add#19266.tags AS tags#19324, add#19266.deletionVector AS deletionVector#19325, add#19266.baseRowId AS baseRowId#19326L, add#19266.defaultRowCommitVersion AS defaultRowCommitVersion#19327L, add#19266.clusteringProvider AS clusteringProvider#19328]
Input [10]: [txn#19265, add#19266, remove#19267, metaData#19268, protocol#19269, cdc#19270, checkpointMetadata#19271, sidecar#19272, domainMetadata#19273, commitInfo#19274]