| 90531 |
Delta Table State #1 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-logisticalroundingprofilecodes/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.1 KiB |
0.0 B |
| 90608 |
Delta Table State #2 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-unitofmeasurecodes-v2/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.0 KiB |
0.0 B |
| 90860 |
Delta Table State #109 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/insight-configuration/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.1 KiB |
0.0 B |
| 90864 |
Delta Table State with Stats #109 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/insight-configuration/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1506.0 B |
0.0 B |
| 101879 |
Delta Table State #46 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/uom-category/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
12.1 KiB |
0.0 B |
| 101889 |
Delta Table State with Stats #46 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/uom-category/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
8.8 KiB |
0.0 B |
| 103811 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002262/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
188.7 KiB |
0.0 B |
| 103815 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002262/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
134.5 KiB |
0.0 B |
| 105080 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002262/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
25.8 KiB |
0.0 B |
| 105084 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002262/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
20.2 KiB |
0.0 B |
| 105135 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000002262/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1947.0 B |
0.0 B |
| 109823 |
Delta Table State #92 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/order-grouping-profile/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
16.2 KiB |
0.0 B |
| 109827 |
Delta Table State with Stats #92 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/order-grouping-profile/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
10.5 KiB |
0.0 B |
| 112549 |
Delta Table State #86 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/supplier-minimum-profile/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
19.4 KiB |
0.0 B |
| 124254 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000002262/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1275.0 B |
0.0 B |
| 127519 |
Delta Table State with Stats #1 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-logisticalroundingprofilecodes/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1526.0 B |
0.0 B |
| 167000 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002275/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.4 KiB |
0.0 B |
| 167004 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002275/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1634.0 B |
0.0 B |
| 167021 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000002275/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1947.0 B |
0.0 B |
| 169027 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002276/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.4 KiB |
0.0 B |
| 169031 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002276/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1634.0 B |
0.0 B |
| 174290 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002277/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
7.5 KiB |
0.0 B |
| 174294 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002277/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
4.0 KiB |
0.0 B |
| 175197 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002277/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.0 KiB |
0.0 B |
| 175201 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002277/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1341.0 B |
0.0 B |
| 175231 |
Delta Table State #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000002277/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1947.0 B |
0.0 B |
| 175261 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000002275/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1275.0 B |
0.0 B |
| 176542 |
Delta Table State with Stats #0 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000002277/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1275.0 B |
0.0 B |
| 187747 |
Delta Table State #10 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002262/stream-10000002262-1/shardId=0_1_10000002262/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
39.4 KiB |
0.0 B |
| 188261 |
Delta Table State #36 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
6.4 KiB |
0.0 B |
| 188295 |
Delta Table State #271 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
7.2 KiB |
0.0 B |
| 188320 |
Delta Table State with Stats #36 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.5 KiB |
0.0 B |
| 188326 |
Delta Table State with Stats #271 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.8 KiB |
0.0 B |
| 188341 |
Delta Table State #2 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-product-v2/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
3.0 KiB |
0.0 B |
| 188345 |
Delta Table State with Stats #2 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-product-v2/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1951.0 B |
0.0 B |
| 188428 |
Delta Table State #34 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/order-grouping-profile/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
5.4 KiB |
0.0 B |
| 188432 |
Delta Table State with Stats #34 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/order-grouping-profile/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
3.0 KiB |
0.0 B |
| 188821 |
Delta Table State #173 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/market-unit/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
16.6 KiB |
0.0 B |
| 188825 |
Delta Table State with Stats #173 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/market-unit/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
10.0 KiB |
0.0 B |
| 188858 |
Delta Table State #1 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-logisticalroundingprofilecodes/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.1 KiB |
0.0 B |
| 188895 |
Delta Table State #38 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/constraint-profile/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
8.8 KiB |
0.0 B |
| 188914 |
Delta Table State #1 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-unitofmeasurecodes-v2/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.0 KiB |
0.0 B |
| 188939 |
Delta Table State #45 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/supplier-minimum-profile/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
9.4 KiB |
0.0 B |
| 189118 |
Delta Table State #8 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/uom-category/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.9 KiB |
0.0 B |
| 189122 |
Delta Table State with Stats #8 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/uom-category/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.0 KiB |
0.0 B |
| 189139 |
Delta Table State #43 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/insight-configuration/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.1 KiB |
0.0 B |
| 189143 |
Delta Table State with Stats #43 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/insight-configuration/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1506.0 B |
0.0 B |
| 189255 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000001436/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
469.2 KiB |
0.0 B |
| 189259 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000001436/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
302.4 KiB |
0.0 B |
| 189487 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000001436/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
41.7 KiB |
0.0 B |
| 189491 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000001436/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
34.1 KiB |
0.0 B |
| 189504 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000001436/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1947.0 B |
0.0 B |
| 191962 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000001436/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1275.0 B |
0.0 B |
| 200444 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
17.8 KiB |
0.0 B |
| 200512 |
*(3) Project [shardId#2722434, worklistShardItemId#2722512L, version#2722521, product#2722582, plant#2722577, availabilityDateTime#2722584 AS periodStart#2722621, nextAvailabilityDateTime#2722585 AS periodEnd#2722622, qty#2722517]
+- *(3) BroadcastHashJoin [worklistShardItemId#2722512L], [worklistShardItemId#2722596L], LeftOuter, BuildRight, (shardId#2722434 = 0_1_10000001436), false
:- *(3) Project [shardId#2722434, worklistShardItemId#2722512L, qty#2722517, element_at([1], ((cast(array_position([0_1_10000001436], shardId#2722434) as int) - 1) + 1), None, false) AS version#2722521]
: +- *(3) Generate explode(requestedQuantities#2722515), [shardId#2722434, worklistShardItemId#2722512L], false, [qty#2722517]
: +- *(3) Project [shardId#2722434, item#2722511.worklistShardItemId AS worklistShardItemId#2722512L, item#2722511.requestedQuantities AS requestedQuantities#2722515]
: +- *(3) Filter ((size(item#2722511.requestedQuantities, true) > 0) AND isnotnull(item#2722511.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
42.9 KiB |
0.0 B |
| 200704 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
17.0 KiB |
0.0 B |
| 200772 |
*(3) Project [shardId#2724648, worklistShardItemId#2724726L, version#2724735, product#2724796, plant#2724791, availabilityDateTime#2724798 AS periodStart#2724835, nextAvailabilityDateTime#2724799 AS periodEnd#2724836, qty#2724731]
+- *(3) BroadcastHashJoin [worklistShardItemId#2724726L], [worklistShardItemId#2724810L], LeftOuter, BuildRight, (shardId#2724648 = 0_1_10000001436), false
:- *(3) Project [shardId#2724648, worklistShardItemId#2724726L, qty#2724731, element_at([2], ((cast(array_position([0_1_10000001436], shardId#2724648) as int) - 1) + 1), None, false) AS version#2724735]
: +- *(3) Generate explode(requestedQuantities#2724729), [shardId#2724648, worklistShardItemId#2724726L], false, [qty#2724731]
: +- *(3) Project [shardId#2724648, item#2724725.worklistShardItemId AS worklistShardItemId#2724726L, item#2724725.requestedQuantities AS requestedQuantities#2724729]
: +- *(3) Filter ((size(item#2724725.requestedQuantities, true) > 0) AND isnotnull(item#2724725.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
29.0 KiB |
0.0 B |
| 200964 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
8.5 KiB |
0.0 B |
| 201032 |
*(3) Project [shardId#2726862, worklistShardItemId#2726940L, version#2726949, product#2727010, plant#2727005, availabilityDateTime#2727012 AS periodStart#2727049, nextAvailabilityDateTime#2727013 AS periodEnd#2727050, qty#2726945]
+- *(3) BroadcastHashJoin [worklistShardItemId#2726940L], [worklistShardItemId#2727024L], LeftOuter, BuildRight, (shardId#2726862 = 0_1_10000001436), false
:- *(3) Project [shardId#2726862, worklistShardItemId#2726940L, qty#2726945, element_at([3], ((cast(array_position([0_1_10000001436], shardId#2726862) as int) - 1) + 1), None, false) AS version#2726949]
: +- *(3) Generate explode(requestedQuantities#2726943), [shardId#2726862, worklistShardItemId#2726940L], false, [qty#2726945]
: +- *(3) Project [shardId#2726862, item#2726939.worklistShardItemId AS worklistShardItemId#2726940L, item#2726939.requestedQuantities AS requestedQuantities#2726943]
: +- *(3) Filter ((size(item#2726939.requestedQuantities, true) > 0) AND isnotnull(item#2726939.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
7.4 KiB |
0.0 B |
| 201224 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
5.1 KiB |
0.0 B |
| 201292 |
*(3) Project [shardId#2729076, worklistShardItemId#2729154L, version#2729163, product#2729224, plant#2729219, availabilityDateTime#2729226 AS periodStart#2729263, nextAvailabilityDateTime#2729227 AS periodEnd#2729264, qty#2729159]
+- *(3) BroadcastHashJoin [worklistShardItemId#2729154L], [worklistShardItemId#2729238L], LeftOuter, BuildRight, (shardId#2729076 = 0_1_10000001436), false
:- *(3) Project [shardId#2729076, worklistShardItemId#2729154L, qty#2729159, element_at([4], ((cast(array_position([0_1_10000001436], shardId#2729076) as int) - 1) + 1), None, false) AS version#2729163]
: +- *(3) Generate explode(requestedQuantities#2729157), [shardId#2729076, worklistShardItemId#2729154L], false, [qty#2729159]
: +- *(3) Project [shardId#2729076, item#2729153.worklistShardItemId AS worklistShardItemId#2729154L, item#2729153.requestedQuantities AS requestedQuantities#2729157]
: +- *(3) Filter ((size(item#2729153.requestedQuantities, true) > 0) AND isnotnull(item#2729153.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
6.5 KiB |
0.0 B |
| 201484 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
4.7 KiB |
0.0 B |
| 201552 |
*(3) Project [shardId#2731290, worklistShardItemId#2731368L, version#2731377, product#2731438, plant#2731433, availabilityDateTime#2731440 AS periodStart#2731477, nextAvailabilityDateTime#2731441 AS periodEnd#2731478, qty#2731373]
+- *(3) BroadcastHashJoin [worklistShardItemId#2731368L], [worklistShardItemId#2731452L], LeftOuter, BuildRight, (shardId#2731290 = 0_1_10000001436), false
:- *(3) Project [shardId#2731290, worklistShardItemId#2731368L, qty#2731373, element_at([5], ((cast(array_position([0_1_10000001436], shardId#2731290) as int) - 1) + 1), None, false) AS version#2731377]
: +- *(3) Generate explode(requestedQuantities#2731371), [shardId#2731290, worklistShardItemId#2731368L], false, [qty#2731373]
: +- *(3) Project [shardId#2731290, item#2731367.worklistShardItemId AS worklistShardItemId#2731368L, item#2731367.requestedQuantities AS requestedQuantities#2731371]
: +- *(3) Filter ((size(item#2731367.requestedQuantities, true) > 0) AND isnotnull(item#2731367.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
3.9 KiB |
0.0 B |
| 201624 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
988.6 KiB |
0.0 B |
| 201744 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
3.3 KiB |
0.0 B |
| 201812 |
*(3) Project [shardId#2733504, worklistShardItemId#2733582L, version#2733591, product#2733652, plant#2733647, availabilityDateTime#2733654 AS periodStart#2733691, nextAvailabilityDateTime#2733655 AS periodEnd#2733692, qty#2733587]
+- *(3) BroadcastHashJoin [worklistShardItemId#2733582L], [worklistShardItemId#2733666L], LeftOuter, BuildRight, (shardId#2733504 = 0_1_10000001436), false
:- *(3) Project [shardId#2733504, worklistShardItemId#2733582L, qty#2733587, element_at([6], ((cast(array_position([0_1_10000001436], shardId#2733504) as int) - 1) + 1), None, false) AS version#2733591]
: +- *(3) Generate explode(requestedQuantities#2733585), [shardId#2733504, worklistShardItemId#2733582L], false, [qty#2733587]
: +- *(3) Project [shardId#2733504, item#2733581.worklistShardItemId AS worklistShardItemId#2733582L, item#2733581.requestedQuantities AS requestedQuantities#2733585]
: +- *(3) Filter ((size(item#2733581.requestedQuantities, true) > 0) AND isnotnull(item#2733581.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1990.0 B |
0.0 B |
| 201884 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
983.9 KiB |
0.0 B |
| 202004 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1838.0 B |
0.0 B |
| 202033 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
33.6 KiB |
0.0 B |
| 202072 |
*(3) Project [shardId#2735718, worklistShardItemId#2735796L, version#2735805, product#2735866, plant#2735861, availabilityDateTime#2735868 AS periodStart#2735905, nextAvailabilityDateTime#2735869 AS periodEnd#2735906, qty#2735801]
+- *(3) BroadcastHashJoin [worklistShardItemId#2735796L], [worklistShardItemId#2735880L], LeftOuter, BuildRight, (shardId#2735718 = 0_1_10000001436), false
:- *(3) Project [shardId#2735718, worklistShardItemId#2735796L, qty#2735801, element_at([7], ((cast(array_position([0_1_10000001436], shardId#2735718) as int) - 1) + 1), None, false) AS version#2735805]
: +- *(3) Generate explode(requestedQuantities#2735799), [shardId#2735718, worklistShardItemId#2735796L], false, [qty#2735801]
: +- *(3) Project [shardId#2735718, item#2735795.worklistShardItemId AS worklistShardItemId#2735796L, item#2735795.requestedQuantities AS requestedQuantities#2735799]
: +- *(3) Filter ((size(item#2735795.requestedQuantities, true) > 0) AND isnotnull(item#2735795.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1992.0 B |
0.0 B |
| 202178 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
984.4 KiB |
0.0 B |
| 202298 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1836.0 B |
0.0 B |
| 202327 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
33.4 KiB |
0.0 B |
| 202366 |
*(3) Project [shardId#2738286, worklistShardItemId#2738364L, version#2738373, product#2738434, plant#2738429, availabilityDateTime#2738436 AS periodStart#2738473, nextAvailabilityDateTime#2738437 AS periodEnd#2738474, qty#2738369]
+- *(3) BroadcastHashJoin [worklistShardItemId#2738364L], [worklistShardItemId#2738448L], LeftOuter, BuildRight, (shardId#2738286 = 0_1_10000001436), false
:- *(3) Project [shardId#2738286, worklistShardItemId#2738364L, qty#2738369, element_at([8], ((cast(array_position([0_1_10000001436], shardId#2738286) as int) - 1) + 1), None, false) AS version#2738373]
: +- *(3) Generate explode(requestedQuantities#2738367), [shardId#2738286, worklistShardItemId#2738364L], false, [qty#2738369]
: +- *(3) Project [shardId#2738286, item#2738363.worklistShardItemId AS worklistShardItemId#2738364L, item#2738363.requestedQuantities AS requestedQuantities#2738367]
: +- *(3) Filter ((size(item#2738363.requestedQuantities, true) > 0) AND isnotnull(item#2738363.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1990.0 B |
0.0 B |
| 202438 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
990.1 KiB |
0.0 B |
| 202558 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1818.0 B |
0.0 B |
| 202587 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
33.6 KiB |
0.0 B |
| 202626 |
*(3) Project [shardId#2740500, worklistShardItemId#2740578L, version#2740587, product#2740648, plant#2740643, availabilityDateTime#2740650 AS periodStart#2740687, nextAvailabilityDateTime#2740651 AS periodEnd#2740688, qty#2740583]
+- *(3) BroadcastHashJoin [worklistShardItemId#2740578L], [worklistShardItemId#2740662L], LeftOuter, BuildRight, (shardId#2740500 = 0_1_10000001436), false
:- *(3) Project [shardId#2740500, worklistShardItemId#2740578L, qty#2740583, element_at([9], ((cast(array_position([0_1_10000001436], shardId#2740500) as int) - 1) + 1), None, false) AS version#2740587]
: +- *(3) Generate explode(requestedQuantities#2740581), [shardId#2740500, worklistShardItemId#2740578L], false, [qty#2740583]
: +- *(3) Project [shardId#2740500, item#2740577.worklistShardItemId AS worklistShardItemId#2740578L, item#2740577.requestedQuantities AS requestedQuantities#2740581]
: +- *(3) Filter ((size(item#2740577.requestedQuantities, true) > 0) AND isnotnull(item#2740577.requestedQuantiti...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1990.0 B |
0.0 B |
| 202676 |
Exchange hashpartitioning(worklistShardItemId#2545400L, 30), REPARTITION_BY_NUM, [plan_id=1563870]
+- *(2) HashAggregate(keys=[demandChannel#2545403, shardId#2545399, kpis#2545405, version#2545401, qty#2545402, worklistShardItemId#2545400L, demandStream#2545404], functions=[], output=[shardId#2545399, worklistShardItemId#2545400L, version#2545401, qty#2545402, demandChannel#2545403, demandStream#2545404, kpis#2545405])
+- Exchange hashpartitioning(demandChannel#2545403, shardId#2545399, kpis#2545405, version#2545401, qty#2545402, worklistShardItemId#2545400L, demandStream#2545404, 30), ENSURE_REQUIREMENTS, [plan_id=1563866]
+- HashAggregate(keys=[demandChannel#2545403, shardId#2545399, knownfloatingpointnormalized(transform(kpis#2545405, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#2741397)) null else named_struct(label, lambda arg#2741397.label, dateTime, lambda arg#2741397.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#2741397.value)))), lambda ...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
2.3 KiB |
0.0 B |
| 202698 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
987.0 KiB |
0.0 B |
| 202702 |
*(1) Project [shardId#2741786, item#2741794L AS worklistShardItemId#2741795L]
+- *(1) Generate explode(_extract_worklistShardItemId#2741798), [shardId#2741786], false, [item#2741794L]
+- *(1) Project [shardId#2741786, items#2741788.worklistShardItemId AS _extract_worklistShardItemId#2741798]
+- *(1) Filter ((isnotnull(shardId#2741786) AND ((shardId#2741786 = 0_1_10000001436) AND (isOptimal#2741790 <=> false))) AND ((size(items#2741788.worklistShardItemId, true) > 0) AND isnotnull(items#2741788.worklistShardItemId)))
+- *(1) Scan ExistingRDD[shardId#2741786,orderProposalId#2741787L,items#2741788,optimizationGroups#2741789,isOptimal#2741790,lastModified#2741791,optimizationInsights#2741792]
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1658.0 B |
0.0 B |
| 202731 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
33.6 KiB |
0.0 B |
| 202820 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
1786.0 B |
0.0 B |
| 202849 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
34.6 KiB |
0.0 B |
| 202859 |
*(1) Filter (isnotnull(shardId#2742812) AND (shardId#2742812 = 0_1_10000001436))
+- *(1) Scan ExistingRDD[shardId#2742812,orderProposalId#2742813L,items#2742814,optimizationGroups#2742815,isOptimal#2742816,lastModified#2742817,optimizationInsights#2742818]
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
20.8 KiB |
0.0 B |
| 202873 |
*(1) Filter (isnotnull(shardId#2742812) AND (shardId#2742812 = 0_1_10000001436))
+- InMemoryTableScan [shardId#2742812, orderProposalId#2742813L, items#2742814, optimizationGroups#2742815, isOptimal#2742816, optimizationInsights#2742818], [isnotnull(shardId#2742812), (shardId#2742812 = 0_1_10000001436)]
+- InMemoryRelation [shardId#2742812, orderProposalId#2742813L, items#2742814, optimizationGroups#2742815, isOptimal#2742816, lastModified#2742817, optimizationInsights#2742818], StorageLevel(disk, memory, 2 replicas)
+- *(1) Filter (isnotnull(shardId#2742812) AND (shardId#2742812 = 0_1_10000001436))
+- *(1) Scan ExistingRDD[shardId#2742812,orderProposalId#2742813L,items#2742814,optimizationGroups#2742815,isOptimal#2742816,lastModified#2742817,optimizationInsights#2742818]
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
19.7 KiB |
0.0 B |
| 202990 |
*(15) Project [shardId#2742812, worklistShardItemId#2743324L, quantityAfterProdPlantOptimization#2743325, qty#2743326, orderProposalId#2743525L, originalReplenishmentRunId#2743567L, supplierGroup#2743527, supplier#2743528, supplyingPlant#2743532, productGroup#2743533, product#2743534, plant#2743529, subrange#2743531, orderDateTime#2743535, deliveryDateTime#2743530, availabilityDateTime#2743536, nextAvailabilityDateTime#2743537, constraintValues#2743558, constraintOperators#2743557, constraintLabels#2743556, logisticUnits#2743552, orderQuantityBaseUom#2743553, orderQuantityBaseUomUuid#2743554, splitIndicator#2743544L, netPriceAmount#2743561, ... 17 more fields]
+- *(15) SortMergeJoin [shardId#2742812, worklistShardItemId#2743324L], [shardId#2744250, worklistShardItemId#2744251L], LeftOuter
:- *(12) Project [shardId#2742812, worklistShardItemId#2743324L, quantityAfterProdPlantOptimization#2743325, qty#2743326, orderProposalId#2743525L, originalReplenishmentRunId#2743567L, supplierGroup#2743527, supplier#2...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
922.0 KiB |
0.0 B |
| 203027 |
Project [shardId#2742812, named_struct(orderProposalId, _extract_orderProposalId#2745779L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#2745771L, supplierGroup, _extract_supplierGroup#2745772, optimizationGroups, coalesce(optimizationGroups#2745024, []), supplier, _extract_supplier#2745773, supplyingPlant, _extract_supplyingPlant#2745774, orderDateTime, _extract_orderDateTime#2745775, itemGroups, _extract_itemGroups#2745776, previousOrderProposals, _extract_previousOrderProposals#2745777, parentItems, _extract_parentItems#2745778) AS orderProposal#2745131]
+- SortMergeJoin [coalesce(shardId#2742812, ), isnull(shardId#2742812), coalesce(_extract_orderProposalId#2745779L, 0), isnull(_extract_orderProposalId#2745779L)], [coalesce(shardId#2745027, ), isnull(shardId#2745027), coalesce(orderProposalId#2745028L, 0), isnull(orderProposalId#2745028L)], LeftOuter
:- Sort [coalesce(shardId#2742812, ) ASC NULLS FIRST, isnull(shardId#2742812) ASC NULLS FIRST, coalesce(_extract_orderProposalId#2745...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
78.9 KiB |
0.0 B |
| 203047 |
ObjectHashAggregate(keys=[shardId#2742812, resultSeparationId#2746883L], functions=[collect_list(orderProposal#2745131, 0, 0)], output=[shardId#2742812, resultSeparationId#2746883L, orderProposals#2746887])
+- Exchange hashpartitioning(shardId#2742812, resultSeparationId#2746883L, 30), ENSURE_REQUIREMENTS, [plan_id=1565953]
+- ObjectHashAggregate(keys=[shardId#2742812, resultSeparationId#2746883L], functions=[partial_collect_list(orderProposal#2745131, 0, 0)], output=[shardId#2742812, resultSeparationId#2746883L, buf#2746923])
+- Project [shardId#2742812, orderProposal#2745131, CASE WHEN (size(orderProposal#2745131.parentItems, true) > 2000) THEN xxhash64(orderProposal#2745131.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#2745131.orderProposalId as decimal(20,0)), 1), 42) END AS resultSeparationId#2746883L]
+- InMemoryTableScan [orderProposal#2745131, shardId#2742812]
+- InMemoryRelation [shardId#2742812, orderProposal#2745131], StorageLevel(disk, memory, 2 rep...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
75.4 KiB |
0.0 B |
| 203277 |
Delta Table State #3 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/optimal-quantities-cache/10000001436/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
23.8 KiB |
0.0 B |
| 203300 |
Delta Table State #1 - hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
3.5 KiB |
0.0 B |