| 54921 |
Delta Table State #1 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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.4 KiB |
0.0 B |
| 54940 |
Delta Table State #1 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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% |
2.8 KiB |
0.0 B |
| 54944 |
Delta Table State with Stats #1 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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% |
1905.0 B |
0.0 B |
| 54995 |
Delta Table State with Stats #1 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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 |
| 55034 |
Delta Table State #308 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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% |
45.4 KiB |
0.0 B |
| 55038 |
Delta Table State with Stats #308 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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% |
29.7 KiB |
0.0 B |
| 55081 |
Delta Table State #1 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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 |
| 55085 |
Delta Table State with Stats #1 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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% |
1621.0 B |
0.0 B |
| 55102 |
Delta Table State #2 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.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% |
3.0 KiB |
0.0 B |
| 55382 |
Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
7.6 KiB |
0.0 B |
| 55386 |
Delta Table State with Stats #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000350/0_1_10000000350/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
4.3 KiB |
0.0 B |
| 55424 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1111580 AS qty#1111582, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581 AS kpis#1111583]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1111579L, cachedShardId#1111578], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1750595]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 55441 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1111815, null AS demandStream#1111816, [] AS kpis#1111850, true AS isNewlyCalculated#1111818]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1111807, ), isnull(shardId#1111807), coalesce(worklistShardItemId#1111808L, 0), isnull(worklistShardItemId#1111808L), coalesce(version#1111809, 0), isnull(version#1111809), coalesce(product#1111810, ), isnull(product#1111810), coalesce(plant#1111811, ), isnull(plant#1111811), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
123.1 KiB |
0.0 B |
| 55506 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
616.4 KiB |
0.0 B |
| 55518 |
*(1) Generate explode(prodPlantResults#1114486), false, [prodPlantResults#1114493]
+- *(1) Project [prodPlantResults#1114486]
+- *(1) Filter ((size(prodPlantResults#1114486, true) > 0) AND isnotnull(prodPlantResults#1114486))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
702.4 KiB |
0.0 B |
| 55541 |
SortAggregate(key=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[first(kpis#1114548, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114681])
+- *(6) Sort [demandChannel#1114519 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1114539 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1114520 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, 37), ENSURE_REQUIREMENTS, [plan_id=1751587]
+- SortAggregate(key=[demandChannel#1114519, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1114539)) AS qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[partial_first(kpis#1114548, false)], output=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
510.9 KiB |
0.0 B |
| 55590 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1115352, qty#1100464, demandChannel#1111815, demandStream#1111816, kpis#1111850]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1115449, worklistShardItemId#1115450L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1111815, demandStream#1111816, kpis#1111850]
: : +- *(1) Filter ((NOT isNewlyCalculated#1111818 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1111815, demandStream#1111816, isNewlyCalculated#1111818, kpis#1111850, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1111818, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
516.4 KiB |
0.0 B |
| 55688 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1117306 AS qty#1117308, demandChannel#1117301, demandStream#1117302, cachedKpis#1117307 AS kpis#1117309]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1117305L, cachedShardId#1117304], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1752232]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 55705 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1117541, null AS demandStream#1117542, [] AS kpis#1117576, true AS isNewlyCalculated#1117544]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1117533, ), isnull(shardId#1117533), coalesce(worklistShardItemId#1117534L, 0), isnull(worklistShardItemId#1117534L), coalesce(version#1117535, 0), isnull(version#1117535), coalesce(product#1117536, ), isnull(product#1117536), coalesce(plant#1117537, ), isnull(plant#1117537), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
77.7 KiB |
0.0 B |
| 55770 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
160.6 KiB |
0.0 B |
| 55782 |
*(1) Generate explode(prodPlantResults#1120044), false, [prodPlantResults#1120051]
+- *(1) Project [prodPlantResults#1120044]
+- *(1) Filter ((size(prodPlantResults#1120044, true) > 0) AND isnotnull(prodPlantResults#1120044))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
177.9 KiB |
0.0 B |
| 55805 |
SortAggregate(key=[demandChannel#1120077, shardId#1100457, qty#1120097, worklistShardItemId#1100458L, demandStream#1120078], functions=[first(kpis#1120106, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1120097, demandChannel#1120077, demandStream#1120078, kpis#1120239])
+- *(6) Sort [demandChannel#1120077 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1120097 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1120078 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1120077, shardId#1100457, qty#1120097, worklistShardItemId#1100458L, demandStream#1120078, 37), ENSURE_REQUIREMENTS, [plan_id=1753162]
+- SortAggregate(key=[demandChannel#1120077, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1120097)) AS qty#1120097, worklistShardItemId#1100458L, demandStream#1120078], functions=[partial_first(kpis#1120106, false)], output=[demandChannel#1120077, shardId#1100457, qty#1120097, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
95.0 KiB |
0.0 B |
| 55854 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1120910, qty#1100464, demandChannel#1117541, demandStream#1117542, kpis#1117576]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1121007, worklistShardItemId#1121008L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1117541, demandStream#1117542, kpis#1117576]
: : +- *(1) Filter ((NOT isNewlyCalculated#1117544 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1117541, demandStream#1117542, isNewlyCalculated#1117544, kpis#1117576, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1117544, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
99.9 KiB |
0.0 B |
| 55956 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1122886 AS qty#1122888, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887 AS kpis#1122889]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1122885L, cachedShardId#1122884], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1753792]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 55973 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1123121, null AS demandStream#1123122, [] AS kpis#1123156, true AS isNewlyCalculated#1123124]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1123113, ), isnull(shardId#1123113), coalesce(worklistShardItemId#1123114L, 0), isnull(worklistShardItemId#1123114L), coalesce(version#1123115, 0), isnull(version#1123115), coalesce(product#1123116, ), isnull(product#1123116), coalesce(plant#1123117, ), isnull(plant#1123117), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
51.5 KiB |
0.0 B |
| 56038 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
75.0 KiB |
0.0 B |
| 56050 |
*(1) Generate explode(prodPlantResults#1125624), false, [prodPlantResults#1125631]
+- *(1) Project [prodPlantResults#1125624]
+- *(1) Filter ((size(prodPlantResults#1125624, true) > 0) AND isnotnull(prodPlantResults#1125624))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
82.2 KiB |
0.0 B |
| 56073 |
SortAggregate(key=[demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658], functions=[first(kpis#1125686, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125819])
+- *(6) Sort [demandChannel#1125657 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1125677 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1125658 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, 37), ENSURE_REQUIREMENTS, [plan_id=1754722]
+- SortAggregate(key=[demandChannel#1125657, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1125677)) AS qty#1125677, worklistShardItemId#1100458L, demandStream#1125658], functions=[partial_first(kpis#1125686, false)], output=[demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
64.9 KiB |
0.0 B |
| 56122 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1126490, qty#1100464, demandChannel#1123121, demandStream#1123122, kpis#1123156]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1126587, worklistShardItemId#1126588L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1123121, demandStream#1123122, kpis#1123156]
: : +- *(1) Filter ((NOT isNewlyCalculated#1123124 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1123121, demandStream#1123122, isNewlyCalculated#1123124, kpis#1123156, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1123124, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
69.4 KiB |
0.0 B |
| 56220 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 56237 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1128679, null AS demandStream#1128680, [] AS kpis#1128714, true AS isNewlyCalculated#1128682]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
44.0 KiB |
0.0 B |
| 56302 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
62.3 KiB |
0.0 B |
| 56314 |
*(1) Generate explode(prodPlantResults#1131182), false, [prodPlantResults#1131189]
+- *(1) Project [prodPlantResults#1131182]
+- *(1) Filter ((size(prodPlantResults#1131182, true) > 0) AND isnotnull(prodPlantResults#1131182))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
68.1 KiB |
0.0 B |
| 56337 |
SortAggregate(key=[demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216], functions=[first(kpis#1131244, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131377])
+- *(6) Sort [demandChannel#1131215 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1131235 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1131216 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, 37), ENSURE_REQUIREMENTS, [plan_id=1756312]
+- SortAggregate(key=[demandChannel#1131215, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1131235)) AS qty#1131235, worklistShardItemId#1100458L, demandStream#1131216], functions=[partial_first(kpis#1131244, false)], output=[demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
52.2 KiB |
0.0 B |
| 56388 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1132145, worklistShardItemId#1132146L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]
: : +- *(1) Filter ((NOT isNewlyCalculated#1128682 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1128679, demandStream#1128680, isNewlyCalculated#1128682, kpis#1128714, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1128682, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
56.9 KiB |
0.0 B |
| 56486 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1134002 AS qty#1134004, demandChannel#1133997, demandStream#1133998, cachedKpis#1134003 AS kpis#1134005]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1134001L, cachedShardId#1134000], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1756957]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 56503 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1134237, null AS demandStream#1134238, [] AS kpis#1134272, true AS isNewlyCalculated#1134240]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1134229, ), isnull(shardId#1134229), coalesce(worklistShardItemId#1134230L, 0), isnull(worklistShardItemId#1134230L), coalesce(version#1134231, 0), isnull(version#1134231), coalesce(product#1134232, ), isnull(product#1134232), coalesce(plant#1134233, ), isnull(plant#1134233), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
44.3 KiB |
0.0 B |
| 56568 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
61.4 KiB |
0.0 B |
| 56580 |
*(1) Generate explode(prodPlantResults#1136740), false, [prodPlantResults#1136747]
+- *(1) Project [prodPlantResults#1136740]
+- *(1) Filter ((size(prodPlantResults#1136740, true) > 0) AND isnotnull(prodPlantResults#1136740))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
66.5 KiB |
0.0 B |
| 56603 |
SortAggregate(key=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[first(kpis#1136802, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1136793, demandChannel#1136773, demandStream#1136774, kpis#1136935])
+- *(6) Sort [demandChannel#1136773 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1136793 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1136774 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774, 37), ENSURE_REQUIREMENTS, [plan_id=1757887]
+- SortAggregate(key=[demandChannel#1136773, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1136793)) AS qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[partial_first(kpis#1136802, false)], output=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
52.2 KiB |
0.0 B |
| 56652 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1137606, qty#1100464, demandChannel#1134237, demandStream#1134238, kpis#1134272]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1137703, worklistShardItemId#1137704L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1134237, demandStream#1134238, kpis#1134272]
: : +- *(1) Filter ((NOT isNewlyCalculated#1134240 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1134237, demandStream#1134238, isNewlyCalculated#1134240, kpis#1134272, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1134240, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
56.9 KiB |
0.0 B |
| 56750 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1139560 AS qty#1139562, demandChannel#1139555, demandStream#1139556, cachedKpis#1139561 AS kpis#1139563]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1139559L, cachedShardId#1139558], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1758547]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 56767 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1139795, null AS demandStream#1139796, [] AS kpis#1139830, true AS isNewlyCalculated#1139798]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1139787, ), isnull(shardId#1139787), coalesce(worklistShardItemId#1139788L, 0), isnull(worklistShardItemId#1139788L), coalesce(version#1139789, 0), isnull(version#1139789), coalesce(product#1139790, ), isnull(product#1139790), coalesce(plant#1139791, ), isnull(plant#1139791), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
43.0 KiB |
0.0 B |
| 56832 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
59.9 KiB |
0.0 B |
| 56844 |
*(1) Generate explode(prodPlantResults#1142298), false, [prodPlantResults#1142305]
+- *(1) Project [prodPlantResults#1142298]
+- *(1) Filter ((size(prodPlantResults#1142298, true) > 0) AND isnotnull(prodPlantResults#1142298))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
64.8 KiB |
0.0 B |
| 56867 |
SortAggregate(key=[demandChannel#1142331, shardId#1100457, qty#1142351, worklistShardItemId#1100458L, demandStream#1142332], functions=[first(kpis#1142360, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1142351, demandChannel#1142331, demandStream#1142332, kpis#1142493])
+- *(6) Sort [demandChannel#1142331 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1142351 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1142332 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1142331, shardId#1100457, qty#1142351, worklistShardItemId#1100458L, demandStream#1142332, 37), ENSURE_REQUIREMENTS, [plan_id=1759477]
+- SortAggregate(key=[demandChannel#1142331, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1142351)) AS qty#1142351, worklistShardItemId#1100458L, demandStream#1142332], functions=[partial_first(kpis#1142360, false)], output=[demandChannel#1142331, shardId#1100457, qty#1142351, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
49.7 KiB |
0.0 B |
| 56916 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1143164, qty#1100464, demandChannel#1139795, demandStream#1139796, kpis#1139830]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1143261, worklistShardItemId#1143262L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1139795, demandStream#1139796, kpis#1139830]
: : +- *(1) Filter ((NOT isNewlyCalculated#1139798 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1139795, demandStream#1139796, isNewlyCalculated#1139798, kpis#1139830, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1139798, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
54.4 KiB |
0.0 B |
| 57014 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1145118 AS qty#1145120, demandChannel#1145113, demandStream#1145114, cachedKpis#1145119 AS kpis#1145121]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1145117L, cachedShardId#1145116], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1760137]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 57031 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1145353, null AS demandStream#1145354, [] AS kpis#1145388, true AS isNewlyCalculated#1145356]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1145345, ), isnull(shardId#1145345), coalesce(worklistShardItemId#1145346L, 0), isnull(worklistShardItemId#1145346L), coalesce(version#1145347, 0), isnull(version#1145347), coalesce(product#1145348, ), isnull(product#1145348), coalesce(plant#1145349, ), isnull(plant#1145349), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
42.1 KiB |
0.0 B |
| 57096 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
56.0 KiB |
0.0 B |
| 57108 |
*(1) Generate explode(prodPlantResults#1147856), false, [prodPlantResults#1147863]
+- *(1) Project [prodPlantResults#1147856]
+- *(1) Filter ((size(prodPlantResults#1147856, true) > 0) AND isnotnull(prodPlantResults#1147856))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
61.8 KiB |
0.0 B |
| 57131 |
SortAggregate(key=[demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[first(kpis#1147918, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1147909, demandChannel#1147889, demandStream#1147890, kpis#1148051])
+- *(6) Sort [demandChannel#1147889 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1147909 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1147890 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890, 37), ENSURE_REQUIREMENTS, [plan_id=1761067]
+- SortAggregate(key=[demandChannel#1147889, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1147909)) AS qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[partial_first(kpis#1147918, false)], output=[demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
50.1 KiB |
0.0 B |
| 57180 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1148722, qty#1100464, demandChannel#1145353, demandStream#1145354, kpis#1145388]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1148819, worklistShardItemId#1148820L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1145353, demandStream#1145354, kpis#1145388]
: : +- *(1) Filter ((NOT isNewlyCalculated#1145356 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1145353, demandStream#1145354, isNewlyCalculated#1145356, kpis#1145388, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1145356, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
54.7 KiB |
0.0 B |
| 57278 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1150676 AS qty#1150678, demandChannel#1150671, demandStream#1150672, cachedKpis#1150677 AS kpis#1150679]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1150675L, cachedShardId#1150674], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1761686]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 57295 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1150911, null AS demandStream#1150912, [] AS kpis#1150946, true AS isNewlyCalculated#1150914]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1150903, ), isnull(shardId#1150903), coalesce(worklistShardItemId#1150904L, 0), isnull(worklistShardItemId#1150904L), coalesce(version#1150905, 0), isnull(version#1150905), coalesce(product#1150906, ), isnull(product#1150906), coalesce(plant#1150907, ), isnull(plant#1150907), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
21.7 KiB |
0.0 B |
| 57360 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
27.7 KiB |
0.0 B |
| 57372 |
*(1) Generate explode(prodPlantResults#1153414), false, [prodPlantResults#1153421]
+- *(1) Project [prodPlantResults#1153414]
+- *(1) Filter ((size(prodPlantResults#1153414, true) > 0) AND isnotnull(prodPlantResults#1153414))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
30.5 KiB |
0.0 B |
| 57395 |
SortAggregate(key=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[first(kpis#1153476, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1153467, demandChannel#1153447, demandStream#1153448, kpis#1153609])
+- *(6) Sort [demandChannel#1153447 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1153467 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1153448 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448, 37), ENSURE_REQUIREMENTS, [plan_id=1762616]
+- SortAggregate(key=[demandChannel#1153447, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1153467)) AS qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[partial_first(kpis#1153476, false)], output=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
28.0 KiB |
0.0 B |
| 57444 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1154280, qty#1100464, demandChannel#1150911, demandStream#1150912, kpis#1150946]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1154377, worklistShardItemId#1154378L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1150911, demandStream#1150912, kpis#1150946]
: : +- *(1) Filter ((NOT isNewlyCalculated#1150914 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1150911, demandStream#1150912, isNewlyCalculated#1150914, kpis#1150946, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1150914, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
32.1 KiB |
0.0 B |
| 57542 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1156234 AS qty#1156236, demandChannel#1156229, demandStream#1156230, cachedKpis#1156235 AS kpis#1156237]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1156233L, cachedShardId#1156232], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1763276]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 57559 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1156469, null AS demandStream#1156470, [] AS kpis#1156504, true AS isNewlyCalculated#1156472]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1156461, ), isnull(shardId#1156461), coalesce(worklistShardItemId#1156462L, 0), isnull(worklistShardItemId#1156462L), coalesce(version#1156463, 0), isnull(version#1156463), coalesce(product#1156464, ), isnull(product#1156464), coalesce(plant#1156465, ), isnull(plant#1156465), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
12.0 KiB |
0.0 B |
| 57624 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
12.1 KiB |
0.0 B |
| 57636 |
*(1) Generate explode(prodPlantResults#1158972), false, [prodPlantResults#1158979]
+- *(1) Project [prodPlantResults#1158972]
+- *(1) Filter ((size(prodPlantResults#1158972, true) > 0) AND isnotnull(prodPlantResults#1158972))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
13.4 KiB |
0.0 B |
| 57659 |
SortAggregate(key=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[first(kpis#1159034, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1159025, demandChannel#1159005, demandStream#1159006, kpis#1159167])
+- *(6) Sort [demandChannel#1159005 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1159025 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1159006 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006, 37), ENSURE_REQUIREMENTS, [plan_id=1764206]
+- SortAggregate(key=[demandChannel#1159005, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1159025)) AS qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[partial_first(kpis#1159034, false)], output=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
11.6 KiB |
0.0 B |
| 57708 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1159838, qty#1100464, demandChannel#1156469, demandStream#1156470, kpis#1156504]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1159935, worklistShardItemId#1159936L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1156469, demandStream#1156470, kpis#1156504]
: : +- *(1) Filter ((NOT isNewlyCalculated#1156472 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1156469, demandStream#1156470, isNewlyCalculated#1156472, kpis#1156504, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1156472, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
15.1 KiB |
0.0 B |
| 57806 |
*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1161792 AS qty#1161794, demandChannel#1161787, demandStream#1161788, cachedKpis#1161793 AS kpis#1161795]
+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1161791L, cachedShardId#1161790], Inner
:- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0
: +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1764825]
: +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])
: +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
1554.0 B |
0.0 B |
| 57823 |
Union
:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1162027, null AS demandStream#1162028, [] AS kpis#1162062, true AS isNewlyCalculated#1162030]
: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1162019, ), isnull(shardId#1162019), coalesce(worklistShardItemId#1162020L, 0), isnull(worklistShardItemId#1162020L), coalesce(version#1162021, 0), isnull(version#1162021), coalesce(product#1162022, ), isnull(product#1162022), coalesce(plant#1162023, ), isnull(plant#1162023), knownfloatingpointnormalized(normalizenanandzero(coalesce...
|
Disk Memory Serialized 2x Replicated
|
74 |
100.00% |
3.7 KiB |
0.0 B |
| 57888 |
MapPartitionsRDD
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
3.2 KiB |
0.0 B |
| 57900 |
*(1) Generate explode(prodPlantResults#1164530), false, [prodPlantResults#1164537]
+- *(1) Project [prodPlantResults#1164530]
+- *(1) Filter ((size(prodPlantResults#1164530, true) > 0) AND isnotnull(prodPlantResults#1164530))
+- *(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,String...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
3.4 KiB |
0.0 B |
| 57923 |
SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725])
+- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755]
+- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L,...
|
Disk Memory Serialized 2x Replicated
|
37 |
100.00% |
2.5 KiB |
0.0 B |
| 57972 |
*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1165396, qty#1100464, demandChannel#1162027, demandStream#1162028, kpis#1162062]
+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1165493, worklistShardItemId#1165494L], Inner, BuildRight, false
:- Union
: :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1162027, demandStream#1162028, kpis#1162062]
: : +- *(1) Filter ((NOT isNewlyCalculated#1162030 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))
: : +- InMemoryTableScan [demandChannel#1162027, demandStream#1162028, isNewlyCalculated#1162030, kpis#1162062, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1162030, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]
: : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman...
|
Disk Memory Serialized 2x Replicated
|
111 |
100.00% |
5.6 KiB |
0.0 B |
| 57994 |
Delta Table State #10 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000350/stream-10000000350-1/_delta_log
|
Disk Memory Serialized 1x Replicated
|
50 |
100.00% |
46.4 KiB |
0.0 B |