== Physical Plan ==
DeserializeToObject (6)
+- * Sort (5)
+- Exchange (4)
+- * Project (3)
+- * Filter (2)
+- * Scan ExistingRDD Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log (1)
(1) Scan ExistingRDD Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log [codegen id : 1]
Output [10]: [txn#551, add#552, remove#553, metaData#554, protocol#555, cdc#556, checkpointMetadata#557, sidecar#558, domainMetadata#559, commitInfo#560]
Arguments: [txn#551, add#552, remove#553, metaData#554, protocol#555, cdc#556, checkpointMetadata#557, sidecar#558, domainMetadata#559, commitInfo#560], Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log MapPartitionsRDD[49] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#551, add#552, remove#553, metaData#554, protocol#555, cdc#556, checkpointMetadata#557, sidecar#558, domainMetadata#559, commitInfo#560]
Condition : isnotnull(add#552)
(3) Project [codegen id : 1]
Output [11]: [add#552.path AS path#625, add#552.partitionValues AS partitionValues#626, add#552.size AS size#627L, add#552.modificationTime AS modificationTime#628L, add#552.dataChange AS dataChange#629, add#552.stats AS stats#630, add#552.tags AS tags#631, add#552.deletionVector AS deletionVector#632, add#552.baseRowId AS baseRowId#633L, add#552.defaultRowCommitVersion AS defaultRowCommitVersion#634L, add#552.clusteringProvider AS clusteringProvider#635]
Input [10]: [txn#551, add#552, remove#553, metaData#554, protocol#555, cdc#556, checkpointMetadata#557, sidecar#558, domainMetadata#559, commitInfo#560]
(4) Exchange
Input [11]: [path#625, partitionValues#626, size#627L, modificationTime#628L, dataChange#629, stats#630, tags#631, deletionVector#632, baseRowId#633L, defaultRowCommitVersion#634L, clusteringProvider#635]
Arguments: rangepartitioning(modificationTime#628L ASC NULLS FIRST, path#625 ASC NULLS FIRST, 50), REPARTITION_BY_NUM, [plan_id=435]
(5) Sort [codegen id : 2]
Input [11]: [path#625, partitionValues#626, size#627L, modificationTime#628L, dataChange#629, stats#630, tags#631, deletionVector#632, baseRowId#633L, defaultRowCommitVersion#634L, clusteringProvider#635]
Arguments: [modificationTime#628L ASC NULLS FIRST, path#625 ASC NULLS FIRST], true, 0
(6) DeserializeToObject
Input [11]: [path#625, partitionValues#626, size#627L, modificationTime#628L, dataChange#629, stats#630, tags#631, deletionVector#632, baseRowId#633L, defaultRowCommitVersion#634L, clusteringProvider#635]
Arguments: newInstance(class org.apache.spark.sql.delta.actions.AddFile), obj#704: org.apache.spark.sql.delta.actions.AddFile