== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#1126929, add#1126930, remove#1126931, metaData#1126932, protocol#1126933, cdc#1126934, checkpointMetadata#1126935, sidecar#1126936, domainMetadata#1126937, commitInfo#1126938]
Arguments: [txn#1126929, add#1126930, remove#1126931, metaData#1126932, protocol#1126933, cdc#1126934, checkpointMetadata#1126935, sidecar#1126936, domainMetadata#1126937, commitInfo#1126938], MapPartitionsRDD[64951] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1126929, add#1126930, remove#1126931, metaData#1126932, protocol#1126933, cdc#1126934, checkpointMetadata#1126935, sidecar#1126936, domainMetadata#1126937, commitInfo#1126938]
Condition : isnotnull(add#1126930)
(3) Project [codegen id : 1]
Output [11]: [add#1126930.path AS path#1126982, add#1126930.partitionValues AS partitionValues#1126983, add#1126930.size AS size#1126984L, add#1126930.modificationTime AS modificationTime#1126985L, add#1126930.dataChange AS dataChange#1126986, null AS stats#1126993, add#1126930.tags AS tags#1126988, add#1126930.deletionVector AS deletionVector#1126989, add#1126930.baseRowId AS baseRowId#1126990L, add#1126930.defaultRowCommitVersion AS defaultRowCommitVersion#1126991L, add#1126930.clusteringProvider AS clusteringProvider#1126992]
Input [10]: [txn#1126929, add#1126930, remove#1126931, metaData#1126932, protocol#1126933, cdc#1126934, checkpointMetadata#1126935, sidecar#1126936, domainMetadata#1126937, commitInfo#1126938]