== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#9289, add#9290, remove#9291, metaData#9292, protocol#9293, cdc#9294, checkpointMetadata#9295, sidecar#9296, domainMetadata#9297, commitInfo#9298]
Arguments: [txn#9289, add#9290, remove#9291, metaData#9292, protocol#9293, cdc#9294, checkpointMetadata#9295, sidecar#9296, domainMetadata#9297, commitInfo#9298], MapPartitionsRDD[353] at Spark Connect - session_id: "29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0"
plan {
command {
write_operation {
input {
common {
..., ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#9289, add#9290, remove#9291, metaData#9292, protocol#9293, cdc#9294, checkpointMetadata#9295, sidecar#9296, domainMetadata#9297, commitInfo#9298]
Condition : isnotnull(add#9290)
(3) Project [codegen id : 1]
Output [11]: [add#9290.path AS path#9342, add#9290.partitionValues AS partitionValues#9343, add#9290.size AS size#9344L, add#9290.modificationTime AS modificationTime#9345L, add#9290.dataChange AS dataChange#9346, add#9290.stats AS stats#9347, add#9290.tags AS tags#9348, add#9290.deletionVector AS deletionVector#9349, add#9290.baseRowId AS baseRowId#9350L, add#9290.defaultRowCommitVersion AS defaultRowCommitVersion#9351L, add#9290.clusteringProvider AS clusteringProvider#9352]
Input [10]: [txn#9289, add#9290, remove#9291, metaData#9292, protocol#9293, cdc#9294, checkpointMetadata#9295, sidecar#9296, domainMetadata#9297, commitInfo#9298]