== Physical Plan ==
* Project (3)
+- * Filter (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [10]: [txn#9599, add#9600, remove#9601, metaData#9602, protocol#9603, cdc#9604, checkpointMetadata#9605, sidecar#9606, domainMetadata#9607, commitInfo#9608]
Arguments: [txn#9599, add#9600, remove#9601, metaData#9602, protocol#9603, cdc#9604, checkpointMetadata#9605, sidecar#9606, domainMetadata#9607, commitInfo#9608], MapPartitionsRDD[362] at Spark Connect - session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
command {
write_operation {
input {
common {
..., ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#9599, add#9600, remove#9601, metaData#9602, protocol#9603, cdc#9604, checkpointMetadata#9605, sidecar#9606, domainMetadata#9607, commitInfo#9608]
Condition : isnotnull(add#9600)
(3) Project [codegen id : 1]
Output [11]: [add#9600.path AS path#9652, add#9600.partitionValues AS partitionValues#9653, add#9600.size AS size#9654L, add#9600.modificationTime AS modificationTime#9655L, add#9600.dataChange AS dataChange#9656, add#9600.stats AS stats#9657, add#9600.tags AS tags#9658, add#9600.deletionVector AS deletionVector#9659, add#9600.baseRowId AS baseRowId#9660L, add#9600.defaultRowCommitVersion AS defaultRowCommitVersion#9661L, add#9600.clusteringProvider AS clusteringProvider#9662]
Input [10]: [txn#9599, add#9600, remove#9601, metaData#9602, protocol#9603, cdc#9604, checkpointMetadata#9605, sidecar#9606, domainMetadata#9607, commitInfo#9608]