== 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/10000000096/stream-10000000096-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/10000000096/stream-10000000096-1/_delta_log [codegen id : 1]
Output [10]: [txn#1647, add#1648, remove#1649, metaData#1650, protocol#1651, cdc#1652, checkpointMetadata#1653, sidecar#1654, domainMetadata#1655, commitInfo#1656]
Arguments: [txn#1647, add#1648, remove#1649, metaData#1650, protocol#1651, cdc#1652, checkpointMetadata#1653, sidecar#1654, domainMetadata#1655, commitInfo#1656], 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/10000000096/stream-10000000096-1/_delta_log MapPartitionsRDD[160] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1647, add#1648, remove#1649, metaData#1650, protocol#1651, cdc#1652, checkpointMetadata#1653, sidecar#1654, domainMetadata#1655, commitInfo#1656]
Condition : isnotnull(add#1648)
(3) Project [codegen id : 1]
Output [11]: [add#1648.path AS path#1721, add#1648.partitionValues AS partitionValues#1722, add#1648.size AS size#1723L, add#1648.modificationTime AS modificationTime#1724L, add#1648.dataChange AS dataChange#1725, add#1648.stats AS stats#1726, add#1648.tags AS tags#1727, add#1648.deletionVector AS deletionVector#1728, add#1648.baseRowId AS baseRowId#1729L, add#1648.defaultRowCommitVersion AS defaultRowCommitVersion#1730L, add#1648.clusteringProvider AS clusteringProvider#1731]
Input [10]: [txn#1647, add#1648, remove#1649, metaData#1650, protocol#1651, cdc#1652, checkpointMetadata#1653, sidecar#1654, domainMetadata#1655, commitInfo#1656]
(4) Exchange
Input [11]: [path#1721, partitionValues#1722, size#1723L, modificationTime#1724L, dataChange#1725, stats#1726, tags#1727, deletionVector#1728, baseRowId#1729L, defaultRowCommitVersion#1730L, clusteringProvider#1731]
Arguments: rangepartitioning(modificationTime#1724L ASC NULLS FIRST, path#1721 ASC NULLS FIRST, 50), REPARTITION_BY_NUM, [plan_id=1253]
(5) Sort [codegen id : 2]
Input [11]: [path#1721, partitionValues#1722, size#1723L, modificationTime#1724L, dataChange#1725, stats#1726, tags#1727, deletionVector#1728, baseRowId#1729L, defaultRowCommitVersion#1730L, clusteringProvider#1731]
Arguments: [modificationTime#1724L ASC NULLS FIRST, path#1721 ASC NULLS FIRST], true, 0
(6) DeserializeToObject
Input [11]: [path#1721, partitionValues#1722, size#1723L, modificationTime#1724L, dataChange#1725, stats#1726, tags#1727, deletionVector#1728, baseRowId#1729L, defaultRowCommitVersion#1730L, clusteringProvider#1731]
Arguments: newInstance(class org.apache.spark.sql.delta.actions.AddFile), obj#1800: org.apache.spark.sql.delta.actions.AddFile