== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#945709, add#945710, remove#945711, metaData#945712, protocol#945713, cdc#945714, checkpointMetadata#945715, sidecar#945716, domainMetadata#945717, commitInfo#945718]
Arguments: [txn#945709, add#945710, remove#945711, metaData#945712, protocol#945713, cdc#945714, checkpointMetadata#945715, sidecar#945716, domainMetadata#945717, commitInfo#945718], MapPartitionsRDD[44277] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#945709, add#945710, remove#945711, metaData#945712, protocol#945713, cdc#945714, checkpointMetadata#945715, sidecar#945716, domainMetadata#945717, commitInfo#945718]
Condition : isnotnull(add#945710)
(3) Project [codegen id : 1]
Output [11]: [add#945710.path AS path#945762, add#945710.partitionValues AS partitionValues#945763, add#945710.size AS size#945764L, add#945710.modificationTime AS modificationTime#945765L, add#945710.dataChange AS dataChange#945766, add#945710.stats AS stats#945767, add#945710.tags AS tags#945768, add#945710.deletionVector AS deletionVector#945769, add#945710.baseRowId AS baseRowId#945770L, add#945710.defaultRowCommitVersion AS defaultRowCommitVersion#945771L, add#945710.clusteringProvider AS clusteringProvider#945772]
Input [10]: [txn#945709, add#945710, remove#945711, metaData#945712, protocol#945713, cdc#945714, checkpointMetadata#945715, sidecar#945716, domainMetadata#945717, commitInfo#945718]