== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1100258, add#1100259, remove#1100260, metaData#1100261, protocol#1100262, cdc#1100263, checkpointMetadata#1100264, sidecar#1100265, domainMetadata#1100266, commitInfo#1100267]
Arguments: [txn#1100258, add#1100259, remove#1100260, metaData#1100261, protocol#1100262, cdc#1100263, checkpointMetadata#1100264, sidecar#1100265, domainMetadata#1100266, commitInfo#1100267], MapPartitionsRDD[54785] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1100258, add#1100259, remove#1100260, metaData#1100261, protocol#1100262, cdc#1100263, checkpointMetadata#1100264, sidecar#1100265, domainMetadata#1100266, commitInfo#1100267]
Condition : isnotnull(add#1100259)
(3) Project [codegen id : 1]
Output [11]: [add#1100259.path AS path#1100311, add#1100259.partitionValues AS partitionValues#1100312, add#1100259.size AS size#1100313L, add#1100259.modificationTime AS modificationTime#1100314L, add#1100259.dataChange AS dataChange#1100315, add#1100259.stats AS stats#1100316, add#1100259.tags AS tags#1100317, add#1100259.deletionVector AS deletionVector#1100318, add#1100259.baseRowId AS baseRowId#1100319L, add#1100259.defaultRowCommitVersion AS defaultRowCommitVersion#1100320L, add#1100259.clusteringProvider AS clusteringProvider#1100321]
Input [10]: [txn#1100258, add#1100259, remove#1100260, metaData#1100261, protocol#1100262, cdc#1100263, checkpointMetadata#1100264, sidecar#1100265, domainMetadata#1100266, commitInfo#1100267]