| 820330 |
Delta Table State #6 - 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.5 KiB |
0.0 B |
| 820334 |
Delta Table State with Stats #6 - 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% |
1960.0 B |
0.0 B |
| 820426 |
Delta Table State #17 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-inventory-inventorysnapshot-v2/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.3 KiB |
0.0 B |
| 820430 |
Delta Table State with Stats #17 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-inventory-inventorysnapshot-v2/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1628.0 B |
0.0 B |
| 820468 |
Delta Table State #12 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-plant-plant/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
4.4 KiB |
0.0 B |
| 820487 |
Delta Table State #4 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-procurement-purchaseorder/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.7 KiB |
0.0 B |
| 820491 |
Delta Table State with Stats #4 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-procurement-purchaseorder/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1730.0 B |
0.0 B |
| 821018 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000236/0_1_10000000236/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
19.9 KiB |
0.0 B |
| 821022 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000236/0_1_10000000236/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
11.9 KiB |
0.0 B |
| 827523 |
Delta Table State #60 - 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.5 KiB |
0.0 B |
| 827582 |
Delta Table State with Stats #60 - 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.4 KiB |
0.0 B |
| 828136 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000237/0_1_10000000237/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
22.8 KiB |
0.0 B |
| 828140 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000237/0_1_10000000237/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
13.1 KiB |
0.0 B |
| 829597 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000238/0_1_10000000238/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.6 KiB |
0.0 B |
| 829601 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000238/0_1_10000000238/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1429.0 B |
0.0 B |
| 837684 |
Delta Table State #8 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000237/stream-10000000237-1/shardId=0_1_10000000237/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
69.4 KiB |
0.0 B |
| 837709 |
Delta Table State with Stats #8 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000237/stream-10000000237-1/shardId=0_1_10000000237/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
51.8 KiB |
0.0 B |
| 840381 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000239/0_1_10000000239/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
15.9 KiB |
0.0 B |
| 840385 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000239/0_1_10000000239/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
8.7 KiB |
0.0 B |
| 847302 |
Delta Table State #75 - 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% |
11.3 KiB |
0.0 B |
| 847306 |
Delta Table State with Stats #75 - 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% |
4.8 KiB |
0.0 B |
| 848244 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000240/0_1_10000000240/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.6 KiB |
0.0 B |
| 848248 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000240/0_1_10000000240/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1389.0 B |
0.0 B |
| 852934 |
Delta Table State #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000241/0_1_10000000241/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.6 KiB |
0.0 B |
| 852938 |
Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000241/0_1_10000000241/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1392.0 B |
0.0 B |
| 853613 |
Delta Table State #3 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000240/stream-10000000240-1/shardId=0_1_10000000240/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
3.1 KiB |
0.0 B |
| 853655 |
Delta Table State with Stats #3 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000240/stream-10000000240-1/shardId=0_1_10000000240/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.1 KiB |
0.0 B |
| 857143 |
Delta Table State #3 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000241/stream-10000000241-1/shardId=0_1_10000000241/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
3.1 KiB |
0.0 B |
| 857168 |
Delta Table State with Stats #3 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000241/stream-10000000241-1/shardId=0_1_10000000241/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
2.1 KiB |
0.0 B |
| 859632 |
Delta Table State #0 - hdlfs://e7aa9586-1364-4d7d-9a56-c2d423fc6b57.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000251/stream-10000000251-1/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
1485.0 B |
0.0 B |
| 859647 |
Delta Source Snapshot #0 - hdlfs://e7aa9586-1364-4d7d-9a56-c2d423fc6b57.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000251/stream-10000000251-1/_delta_log
|
Disk Memory Serialized 1x Replicated
|
1 |
100.00% |
21.0 B |
0.0 B |
| 860828 |
Delta Table State #8 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000239/stream-10000000239-1/shardId=0_1_10000000239/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
13.2 KiB |
0.0 B |
| 860870 |
Delta Table State with Stats #8 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000239/stream-10000000239-1/shardId=0_1_10000000239/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
8.9 KiB |
0.0 B |
| 861517 |
Delta Table State #9 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000238/stream-10000000238-1/shardId=0_1_10000000238/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
17.9 KiB |
0.0 B |
| 861542 |
Delta Table State with Stats #9 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000238/stream-10000000238-1/shardId=0_1_10000000238/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
12.0 KiB |
0.0 B |
| 862787 |
Exchange hashpartitioning(product#14480993, plant#14480994, 30), REPARTITION_BY_NUM, [plan_id=21326571]
+- *(1) Scan ExistingRDD[shardId#14480990,worklistShardItemId#14480991L,version#14480992,product#14480993,plant#14480994,periodStart#14480995,periodEnd#14480996,qty#14480997]
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
3.5 KiB |
0.0 B |
| 862906 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
9.0 KiB |
0.0 B |
| 862915 |
*(1) Generate explode(prodPlantResults#15077253), false, [prodPlantResults#15077260]
+- *(1) Project [prodPlantResults#15077253]
+- *(1) Filter ((size(prodPlantResults#15077253, true) > 0) AND isnotnull(prodPlantResults#15077253))
+- *(1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,S...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
9.8 KiB |
0.0 B |
| 862938 |
SortAggregate(key=[demandChannel#15077286, shardId#14480990, qty#15077306, worklistShardItemId#14480991L, demandStream#15077287], functions=[first(kpis#15077315, false)], output=[shardId#14480990, worklistShardItemId#14480991L, qty#15077306, demandChannel#15077286, demandStream#15077287, kpis#15077428])
+- *(5) Sort [demandChannel#15077286 ASC NULLS FIRST, shardId#14480990 ASC NULLS FIRST, qty#15077306 ASC NULLS FIRST, worklistShardItemId#14480991L ASC NULLS FIRST, demandStream#15077287 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#15077286, shardId#14480990, qty#15077306, worklistShardItemId#14480991L, demandStream#15077287, 30), ENSURE_REQUIREMENTS, [plan_id=21327564]
+- SortAggregate(key=[demandChannel#15077286, shardId#14480990, knownfloatingpointnormalized(normalizenanandzero(qty#15077306)) AS qty#15077306, worklistShardItemId#14480991L, demandStream#15077287], functions=[partial_first(kpis#15077315, false)], output=[demandChannel#15077286, shardId#14480990, qty#150773...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
10.3 KiB |
0.0 B |
| 862958 |
*(3) Project [shardId#14480990, worklistShardItemId#14480991L, version#15077777, qty#15077306, demandChannel#15077286, demandStream#15077287, kpis#15077315]
+- *(3) BroadcastHashJoin [shardId#14480990, worklistShardItemId#14480991L], [shardId#15077782, worklistShardItemId#15077783L], Inner, BuildRight, false
:- *(3) Filter (isnotnull(shardId#14480990) AND isnotnull(worklistShardItemId#14480991L))
: +- InMemoryTableScan [shardId#14480990, worklistShardItemId#14480991L, qty#15077306, demandChannel#15077286, demandStream#15077287, kpis#15077315], [isnotnull(shardId#14480990), isnotnull(worklistShardItemId#14480991L)]
: +- InMemoryRelation [shardId#14480990, worklistShardItemId#14480991L, qty#15077306, demandChannel#15077286, demandStream#15077287, kpis#15077315], StorageLevel(disk, memory, 2 replicas)
: +- SortAggregate(key=[demandChannel#15077286, shardId#14480990, qty#15077306, worklistShardItemId#14480991L, demandStream#15077287], functions=[first(kpis#15077315, false)], ou...
|
Disk Memory Serialized 2x Replicated
|
30 |
100.00% |
10.6 KiB |
0.0 B |