== Physical Plan ==
DeserializeToObject (6)
+- * Sort (5)
+- Exchange (4)
+- * Project (3)
+- * Filter (2)
+- * Scan ExistingRDD Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000001328/stream-10000001328-1/_delta_log (1)
(1) Scan ExistingRDD Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000001328/stream-10000001328-1/_delta_log [codegen id : 1]
Output [10]: [txn#9038, add#9039, remove#9040, metaData#9041, protocol#9042, cdc#9043, checkpointMetadata#9044, sidecar#9045, domainMetadata#9046, commitInfo#9047]
Arguments: [txn#9038, add#9039, remove#9040, metaData#9041, protocol#9042, cdc#9043, checkpointMetadata#9044, sidecar#9045, domainMetadata#9046, commitInfo#9047], Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000001328/stream-10000001328-1/_delta_log MapPartitionsRDD[892] at start at FileStorageAdapterImpl.java:179, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#9038, add#9039, remove#9040, metaData#9041, protocol#9042, cdc#9043, checkpointMetadata#9044, sidecar#9045, domainMetadata#9046, commitInfo#9047]
Condition : isnotnull(add#9039)
(3) Project [codegen id : 1]
Output [11]: [add#9039.path AS path#9112, add#9039.partitionValues AS partitionValues#9113, add#9039.size AS size#9114L, add#9039.modificationTime AS modificationTime#9115L, add#9039.dataChange AS dataChange#9116, add#9039.stats AS stats#9117, add#9039.tags AS tags#9118, add#9039.deletionVector AS deletionVector#9119, add#9039.baseRowId AS baseRowId#9120L, add#9039.defaultRowCommitVersion AS defaultRowCommitVersion#9121L, add#9039.clusteringProvider AS clusteringProvider#9122]
Input [10]: [txn#9038, add#9039, remove#9040, metaData#9041, protocol#9042, cdc#9043, checkpointMetadata#9044, sidecar#9045, domainMetadata#9046, commitInfo#9047]
(4) Exchange
Input [11]: [path#9112, partitionValues#9113, size#9114L, modificationTime#9115L, dataChange#9116, stats#9117, tags#9118, deletionVector#9119, baseRowId#9120L, defaultRowCommitVersion#9121L, clusteringProvider#9122]
Arguments: rangepartitioning(modificationTime#9115L ASC NULLS FIRST, path#9112 ASC NULLS FIRST, 50), REPARTITION_BY_NUM, [plan_id=6663]
(5) Sort [codegen id : 2]
Input [11]: [path#9112, partitionValues#9113, size#9114L, modificationTime#9115L, dataChange#9116, stats#9117, tags#9118, deletionVector#9119, baseRowId#9120L, defaultRowCommitVersion#9121L, clusteringProvider#9122]
Arguments: [modificationTime#9115L ASC NULLS FIRST, path#9112 ASC NULLS FIRST], true, 0
(6) DeserializeToObject
Input [11]: [path#9112, partitionValues#9113, size#9114L, modificationTime#9115L, dataChange#9116, stats#9117, tags#9118, deletionVector#9119, baseRowId#9120L, defaultRowCommitVersion#9121L, clusteringProvider#9122]
Arguments: newInstance(class org.apache.spark.sql.delta.actions.AddFile), obj#9191: org.apache.spark.sql.delta.actions.AddFile