crp-order-quantity-kpi-service - Details for Query 100508

Submitted Time: 2026/06/09 15:54:01
Duration: 0.7 s
Succeeded Jobs: 154858 154859

Plan Visualization

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [id="node0" labelType="html" label="CollectLimit shuffle records written: 20 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 868.0 B merged fetch fallback count: 0 local blocks read: 14 remote merged chunks fetched: 0 remote blocks read: 0 local merged bytes read: 0.0 B remote reqs duration: 0 ms local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 3 ms (0 ms, 0 ms, 0 ms (stage 446307.0: task 5181939)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 1240.0 B (62.0 B, 62.0 B, 62.0 B (stage 446307.0: task 5181931))" tooltip="CollectLimit 1"]; 1 [id="node1" labelType="html" label="InMemoryTableScan number of output rows: 256" tooltip="InMemoryTableScan"]; subgraph cluster2 { isCluster="true"; id="cluster2"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n1.9 s (0 ms, 6 ms, 832 ms (stage 446307.0: task 5181937))"; tooltip="WholeStageCodegen (3)"; 3 [id="node3" labelType="html" label=" Project " tooltip="Project [shardId#21517301, worklistShardItemId#21517302L, version#21556769, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]"]; 4 [id="node4" labelType="html" label="BroadcastHashJoin number of output rows: 256" tooltip="BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21556774, worklistShardItemId#21556775L], Inner, BuildRight, false"]; 5 [id="node5" labelType="html" label="Filter number of output rows: 256" tooltip="Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))"]; } 6 [id="node6" labelType="html" label="InMemoryTableScan number of output rows: 256" tooltip="InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]"]; 7 [id="node7" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279], functions=[first(kpis#21556307, false)])"]; subgraph cluster8 { isCluster="true"; id="cluster8"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 9 [id="node9" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#21556278 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21556298 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21556279 ASC NULLS FIRST], false, 0"]; } 10 [id="node10" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, 20), ENSURE_REQUIREMENTS, [plan_id=21360184]"]; 11 [id="node11" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#21556278, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21556298)) AS qty#21556298, worklistShardItemId#21517302L, demandStream#21556279], functions=[partial_first(kpis#21556307, false)])"]; subgraph cluster12 { isCluster="true"; id="cluster12"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 13 [id="node13" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#21556278 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#21556298)) AS qty#21556298 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21556279 ASC NULLS FIRST], false, 0"]; 14 [id="node14" labelType="html" label=" Project " tooltip="Project [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]"]; 15 [id="node15" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [coalesce(product#21556271, ), isnull(product#21556271), coalesce(plant#21556272, ), isnull(plant#21556272)], [coalesce(product#21517304, ), isnull(product#21517304), coalesce(plant#21517305, ), isnull(plant#21517305)], Inner, BuildRight, ((qty#21556298 <=> qty#21517308) OR isnull(qty#21517308)), false"]; } 16 [id="node16" labelType="html" label=" Union " tooltip="Union"]; 17 [id="node17" labelType="html" label=" Project " tooltip="Project [prodPlantResults#21556252.productId AS product#21556271, prodPlantResults#21556252.plantId AS plant#21556272, null AS qty#21556298, null AS demandChannel#21556278, null AS demandStream#21556279, transform(prodPlantResults#21556252.kpiResults, lambdafunction(struct(label, lambda kpi#21556308.label, dateTime, lambda kpi#21556308.datetime, value, lambda kpi#21556308.value), lambda kpi#21556308, false)) AS kpis#21556307]"]; 18 [id="node18" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#21556252]"]; subgraph cluster19 { isCluster="true"; id="cluster19"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 20 [id="node20" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#21556245), false, [prodPlantResults#21556252]"]; 21 [id="node21" labelType="html" label=" Project " tooltip="Project [prodPlantResults#21556245]"]; 22 [id="node22" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#21556245, true) > 0) AND isnotnull(prodPlantResults#21556245))"]; 23 [id="node23" labelType="html" label=" SerializeFromObject " tooltip="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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(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))).getNumberOfCalls()), parent, 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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(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))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#21556244, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#21556245]"]; } 24 [id="node24" labelType="html" label=" Scan " tooltip="Scan[obj#21556241]"]; 25 [id="node25" labelType="html" label=" Project " tooltip="Project [_extract_productId#21556423 AS product#21556258, _extract_plantId#21556424 AS plant#21556259, quantityKpiResults#21556264.quantity AS qty#21556265, null AS demandChannel#21556267, null AS demandStream#21556268, transform(quantityKpiResults#21556264.kpiResults, lambdafunction(struct(label, lambda kpi#21556308.label, dateTime, lambda kpi#21556308.datetime, value, lambda kpi#21556308.value), lambda kpi#21556308, false)) AS kpis#21556421]"]; subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 27 [id="node27" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_quantityKpiResults#21556425), [_extract_productId#21556423, _extract_plantId#21556424], false, [quantityKpiResults#21556264]"]; 28 [id="node28" labelType="html" label=" Project " tooltip="Project [prodPlantResults#21556297.productId AS _extract_productId#21556423, prodPlantResults#21556297.plantId AS _extract_plantId#21556424, prodPlantResults#21556297.quantityKpiResults AS _extract_quantityKpiResults#21556425]"]; 29 [id="node29" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#21556297.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#21556297.quantityKpiResults))"]; } 30 [id="node30" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#21556297], [(size(prodPlantResults#21556297.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#21556297.quantityKpiResults)]"]; subgraph cluster31 { isCluster="true"; id="cluster31"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 32 [id="node32" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#21556245), false, [prodPlantResults#21556252]"]; 33 [id="node33" labelType="html" label=" Project " tooltip="Project [prodPlantResults#21556245]"]; 34 [id="node34" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#21556245, true) > 0) AND isnotnull(prodPlantResults#21556245))"]; 35 [id="node35" labelType="html" label=" SerializeFromObject " tooltip="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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(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))).getNumberOfCalls()), parent, 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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(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))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#21556244, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#21556245]"]; } 36 [id="node36" labelType="html" label=" Scan " tooltip="Scan[obj#21556241]"]; 37 [id="node37" labelType="html" label=" Project " tooltip="Project [_extract_productId#21556426 AS product#21556280, _extract_plantId#21556427 AS plant#21556281, null AS qty#21556303, demandChannelStreamKpiResults#21556286.demandChannel AS demandChannel#21556288, demandChannelStreamKpiResults#21556286.demandStream AS demandStream#21556290, transform(demandChannelStreamKpiResults#21556286.kpiResults, lambdafunction(struct(label, lambda kpi#21556308.label, dateTime, lambda kpi#21556308.datetime, value, lambda kpi#21556308.value), lambda kpi#21556308, false)) AS kpis#21556422]"]; subgraph cluster38 { isCluster="true"; id="cluster38"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 39 [id="node39" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_demandChannelStreamKpiResults#21556428), [_extract_productId#21556426, _extract_plantId#21556427], false, [demandChannelStreamKpiResults#21556286]"]; 40 [id="node40" labelType="html" label=" Project " tooltip="Project [prodPlantResults#21556302.productId AS _extract_productId#21556426, prodPlantResults#21556302.plantId AS _extract_plantId#21556427, prodPlantResults#21556302.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#21556428]"]; 41 [id="node41" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#21556302.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#21556302.demandChannelStreamKpiResults))"]; } 42 [id="node42" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#21556302], [(size(prodPlantResults#21556302.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#21556302.demandChannelStreamKpiResults)]"]; subgraph cluster43 { isCluster="true"; id="cluster43"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 44 [id="node44" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#21556245), false, [prodPlantResults#21556252]"]; 45 [id="node45" labelType="html" label=" Project " tooltip="Project [prodPlantResults#21556245]"]; 46 [id="node46" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#21556245, true) > 0) AND isnotnull(prodPlantResults#21556245))"]; 47 [id="node47" labelType="html" label=" SerializeFromObject " tooltip="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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(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))).getNumberOfCalls()), parent, 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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(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))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#21556244, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#21556245]"]; } 48 [id="node48" labelType="html" label=" Scan " tooltip="Scan[obj#21556241]"]; 49 [id="node49" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, string, true], ), isnull(input[3, string, true])),false), [plan_id=21360177]"]; subgraph cluster50 { isCluster="true"; id="cluster50"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 51 [id="node51" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#21517305, shardId#21517301, qty#21517308, worklistShardItemId#21517302L, product#21517304], functions=[])"]; 52 [id="node52" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#21517305, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21517308)) AS qty#21517308, worklistShardItemId#21517302L, product#21517304], functions=[])"]; } 53 [id="node53" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, product#21517304, plant#21517305, qty#21517308]"]; 54 [id="node54" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(product#21517304, plant#21517305, 20), REPARTITION_BY_NUM, [plan_id=21359101]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 56 [id="node56" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#21517301,worklistShardItemId#21517302L,version#21517303,product#21517304,plant#21517305,periodStart#21517306,periodEnd#21517307,qty#21517308]"]; } 57 [id="node57" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 1 ms time to collect: 233 ms number of output rows: 64 data size: 2.0 MiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, true], input[1, bigint, true]),false), [plan_id=21360285]"]; subgraph cluster58 { isCluster="true"; id="cluster58"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n28 ms (0 ms, 2 ms, 2 ms (stage 446300.0: task 5181909))"; tooltip="WholeStageCodegen (2)"; 59 [id="node59" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 12 ms (0 ms, 1 ms, 1 ms (stage 446300.0: task 5181909)) peak memory total (min, med, max (stageId: taskId)) 45.0 MiB (2.3 MiB, 2.3 MiB, 2.3 MiB (stage 446300.0: task 5181909)) number of output rows: 64 number of sort fallback tasks: 0 avg hash probes per key (min, med, max (stageId: taskId)): (1, 1, 1 (stage 446300.0: task 5181909))" tooltip="HashAggregate(keys=[shardId#21556774, worklistShardItemId#21556775L], functions=[max(version#21556776)])"]; } 60 [id="node60" labelType="html" label="Exchange shuffle records written: 64 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 64 local bytes read total (min, med, max (stageId: taskId)) 4.4 KiB (99.0 B, 198.0 B, 594.0 B (stage 446300.0: task 5181914)) merged fetch fallback count: 0 local blocks read: 45 remote merged chunks fetched: 0 remote blocks read: 19 data size total (min, med, max (stageId: taskId)) 3.0 KiB (48.0 B, 144.0 B, 288.0 B (stage 446299.0: task 5181882)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 8 ms (0 ms, 0 ms, 0 ms (stage 446299.0: task 5181898)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 446300.0: task 5181909)) remote bytes read total (min, med, max (stageId: taskId)) 1884.0 B (99.0 B, 100.0 B, 397.0 B (stage 446300.0: task 5181918)) number of partitions: 20 remote reqs duration total (min, med, max (stageId: taskId)) 11 ms (1 ms, 1 ms, 1 ms (stage 446300.0: task 5181905)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 6.2 KiB (100.0 B, 297.0 B, 594.0 B (stage 446299.0: task 5181882))" tooltip="Exchange hashpartitioning(shardId#21556774, worklistShardItemId#21556775L, 20), ENSURE_REQUIREMENTS, [plan_id=21360281]"]; subgraph cluster61 { isCluster="true"; id="cluster61"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n656 ms (1 ms, 56 ms, 73 ms (stage 446299.0: task 5181885))"; tooltip="WholeStageCodegen (1)"; 62 [id="node62" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 7 ms (0 ms, 0 ms, 1 ms (stage 446299.0: task 5181888)) peak memory total (min, med, max (stageId: taskId)) 5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 446299.0: task 5181884)) number of output rows: 64 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#21556774, worklistShardItemId#21556775L], functions=[partial_max(version#21556776)])"]; 63 [id="node63" labelType="html" label="Filter number of output rows: 64" tooltip="Filter (isnotnull(shardId#21556774) AND isnotnull(worklistShardItemId#21556775L))"]; } 64 [id="node64" labelType="html" label="InMemoryTableScan number of output rows: 64" tooltip="InMemoryTableScan [shardId#21556774, worklistShardItemId#21556775L, version#21556776], [isnotnull(shardId#21556774), isnotnull(worklistShardItemId#21556775L)]"]; 65 [id="node65" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(product#21517304, plant#21517305, 20), REPARTITION_BY_NUM, [plan_id=21359101]"]; subgraph cluster66 { isCluster="true"; id="cluster66"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 67 [id="node67" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#21517301,worklistShardItemId#21517302L,version#21517303,product#21517304,plant#21517305,periodStart#21517306,periodEnd#21517307,qty#21517308]"]; } 1->0; 3->1; 4->3; 5->4; 6->5; 7->6; 9->7; 10->9; 11->10; 13->11; 14->13; 15->14; 16->15; 17->16; 18->17; 20->18; 21->20; 22->21; 23->22; 24->23; 25->16; 27->25; 28->27; 29->28; 30->29; 32->30; 33->32; 34->33; 35->34; 36->35; 37->16; 39->37; 40->39; 41->40; 42->41; 44->42; 45->44; 46->45; 47->46; 48->47; 49->15; 51->49; 52->51; 53->52; 54->53; 56->54; 57->4; 59->57; 60->59; 62->60; 63->62; 64->63; 65->64; 67->65; }

Details

== Physical Plan ==
CollectLimit (50)
+- InMemoryTableScan (1)
      +- InMemoryRelation (2)
            +- * Project (49)
               +- * BroadcastHashJoin Inner BuildRight (48)
                  :- * Filter (40)
                  :  +- InMemoryTableScan (3)
                  :        +- InMemoryRelation (4)
                  :              +- SortAggregate (39)
                  :                 +- * Sort (38)
                  :                    +- Exchange (37)
                  :                       +- SortAggregate (36)
                  :                          +- * Sort (35)
                  :                             +- * Project (34)
                  :                                +- * BroadcastHashJoin Inner BuildRight (33)
                  :                                   :- Union (25)
                  :                                   :  :- Project (12)
                  :                                   :  :  +- InMemoryTableScan (5)
                  :                                   :  :        +- InMemoryRelation (6)
                  :                                   :  :              +- * Generate (11)
                  :                                   :  :                 +- * Project (10)
                  :                                   :  :                    +- * Filter (9)
                  :                                   :  :                       +- * SerializeFromObject (8)
                  :                                   :  :                          +- Scan (7)
                  :                                   :  :- Project (18)
                  :                                   :  :  +- * Generate (17)
                  :                                   :  :     +- * Project (16)
                  :                                   :  :        +- * Filter (15)
                  :                                   :  :           +- InMemoryTableScan (13)
                  :                                   :  :                 +- InMemoryRelation (14)
                  :                                   :  :                       +- * Generate (11)
                  :                                   :  :                          +- * Project (10)
                  :                                   :  :                             +- * Filter (9)
                  :                                   :  :                                +- * SerializeFromObject (8)
                  :                                   :  :                                   +- Scan (7)
                  :                                   :  +- Project (24)
                  :                                   :     +- * Generate (23)
                  :                                   :        +- * Project (22)
                  :                                   :           +- * Filter (21)
                  :                                   :              +- InMemoryTableScan (19)
                  :                                   :                    +- InMemoryRelation (20)
                  :                                   :                          +- * Generate (11)
                  :                                   :                             +- * Project (10)
                  :                                   :                                +- * Filter (9)
                  :                                   :                                   +- * SerializeFromObject (8)
                  :                                   :                                      +- Scan (7)
                  :                                   +- BroadcastExchange (32)
                  :                                      +- * HashAggregate (31)
                  :                                         +- * HashAggregate (30)
                  :                                            +- InMemoryTableScan (26)
                  :                                                  +- InMemoryRelation (27)
                  :                                                        +- Exchange (29)
                  :                                                           +- * Scan ExistingRDD (28)
                  +- BroadcastExchange (47)
                     +- * HashAggregate (46)
                        +- Exchange (45)
                           +- * HashAggregate (44)
                              +- * Filter (43)
                                 +- InMemoryTableScan (41)
                                       +- InMemoryRelation (42)
                                             +- Exchange (29)
                                                +- * Scan ExistingRDD (28)


(1) InMemoryTableScan
Output: []

(2) InMemoryRelation
Arguments: [shardId#21517301, worklistShardItemId#21517302L, version#21556769, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [6]: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]
Arguments: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]

(4) InMemoryRelation
Arguments: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307], StorageLevel(disk, memory, 2 replicas)

(5) InMemoryTableScan
Output [1]: [prodPlantResults#21556252]
Arguments: [prodPlantResults#21556252]

(6) InMemoryRelation
Arguments: [prodPlantResults#21556252], StorageLevel(disk, memory, 2 replicas)

(7) Scan
Output [1]: [obj#21556241]
Arguments: obj#21556241: com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, MapPartitionsRDD[1243452] at start at FileStorageAdapterImpl.java:174

(8) SerializeFromObject [codegen id : 1]
Input [1]: [obj#21556241]
Arguments: [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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(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))).getNumberOfCalls()), parent, 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,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(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))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#21556244, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#21556245]

(9) Filter [codegen id : 1]
Input [2]: [performanceMeasurements#21556244, prodPlantResults#21556245]
Condition : ((size(prodPlantResults#21556245, true) > 0) AND isnotnull(prodPlantResults#21556245))

(10) Project [codegen id : 1]
Output [1]: [prodPlantResults#21556245]
Input [2]: [performanceMeasurements#21556244, prodPlantResults#21556245]

(11) Generate [codegen id : 1]
Input [1]: [prodPlantResults#21556245]
Arguments: explode(prodPlantResults#21556245), false, [prodPlantResults#21556252]

(12) Project
Output [6]: [prodPlantResults#21556252.productId AS product#21556271, prodPlantResults#21556252.plantId AS plant#21556272, null AS qty#21556298, null AS demandChannel#21556278, null AS demandStream#21556279, transform(prodPlantResults#21556252.kpiResults, lambdafunction(struct(label, lambda kpi#21556308.label, dateTime, lambda kpi#21556308.datetime, value, lambda kpi#21556308.value), lambda kpi#21556308, false)) AS kpis#21556307]
Input [1]: [prodPlantResults#21556252]

(13) InMemoryTableScan
Output [1]: [prodPlantResults#21556297]
Arguments: [prodPlantResults#21556297], [(size(prodPlantResults#21556297.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#21556297.quantityKpiResults)]

(14) InMemoryRelation
Arguments: [prodPlantResults#21556297], StorageLevel(disk, memory, 2 replicas)

(15) Filter [codegen id : 1]
Input [1]: [prodPlantResults#21556297]
Condition : ((size(prodPlantResults#21556297.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#21556297.quantityKpiResults))

(16) Project [codegen id : 1]
Output [3]: [prodPlantResults#21556297.productId AS _extract_productId#21556423, prodPlantResults#21556297.plantId AS _extract_plantId#21556424, prodPlantResults#21556297.quantityKpiResults AS _extract_quantityKpiResults#21556425]
Input [1]: [prodPlantResults#21556297]

(17) Generate [codegen id : 1]
Input [3]: [_extract_productId#21556423, _extract_plantId#21556424, _extract_quantityKpiResults#21556425]
Arguments: explode(_extract_quantityKpiResults#21556425), [_extract_productId#21556423, _extract_plantId#21556424], false, [quantityKpiResults#21556264]

(18) Project
Output [6]: [_extract_productId#21556423 AS product#21556258, _extract_plantId#21556424 AS plant#21556259, quantityKpiResults#21556264.quantity AS qty#21556265, null AS demandChannel#21556267, null AS demandStream#21556268, transform(quantityKpiResults#21556264.kpiResults, lambdafunction(struct(label, lambda kpi#21556308.label, dateTime, lambda kpi#21556308.datetime, value, lambda kpi#21556308.value), lambda kpi#21556308, false)) AS kpis#21556421]
Input [3]: [_extract_productId#21556423, _extract_plantId#21556424, quantityKpiResults#21556264]

(19) InMemoryTableScan
Output [1]: [prodPlantResults#21556302]
Arguments: [prodPlantResults#21556302], [(size(prodPlantResults#21556302.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#21556302.demandChannelStreamKpiResults)]

(20) InMemoryRelation
Arguments: [prodPlantResults#21556302], StorageLevel(disk, memory, 2 replicas)

(21) Filter [codegen id : 2]
Input [1]: [prodPlantResults#21556302]
Condition : ((size(prodPlantResults#21556302.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#21556302.demandChannelStreamKpiResults))

(22) Project [codegen id : 2]
Output [3]: [prodPlantResults#21556302.productId AS _extract_productId#21556426, prodPlantResults#21556302.plantId AS _extract_plantId#21556427, prodPlantResults#21556302.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#21556428]
Input [1]: [prodPlantResults#21556302]

(23) Generate [codegen id : 2]
Input [3]: [_extract_productId#21556426, _extract_plantId#21556427, _extract_demandChannelStreamKpiResults#21556428]
Arguments: explode(_extract_demandChannelStreamKpiResults#21556428), [_extract_productId#21556426, _extract_plantId#21556427], false, [demandChannelStreamKpiResults#21556286]

(24) Project
Output [6]: [_extract_productId#21556426 AS product#21556280, _extract_plantId#21556427 AS plant#21556281, null AS qty#21556303, demandChannelStreamKpiResults#21556286.demandChannel AS demandChannel#21556288, demandChannelStreamKpiResults#21556286.demandStream AS demandStream#21556290, transform(demandChannelStreamKpiResults#21556286.kpiResults, lambdafunction(struct(label, lambda kpi#21556308.label, dateTime, lambda kpi#21556308.datetime, value, lambda kpi#21556308.value), lambda kpi#21556308, false)) AS kpis#21556422]
Input [3]: [_extract_productId#21556426, _extract_plantId#21556427, demandChannelStreamKpiResults#21556286]

(25) Union

(26) InMemoryTableScan
Output [5]: [shardId#21517301, worklistShardItemId#21517302L, product#21517304, plant#21517305, qty#21517308]
Arguments: [shardId#21517301, worklistShardItemId#21517302L, product#21517304, plant#21517305, qty#21517308]

(27) InMemoryRelation
Arguments: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308], StorageLevel(disk, memory, 2 replicas)

(28) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308]
Arguments: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308], SQLExecutionRDD[1243307] at start at FileStorageAdapterImpl.java:174, ExistingRDD, UnknownPartitioning(0)

(29) Exchange
Input [8]: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308]
Arguments: hashpartitioning(product#21517304, plant#21517305, 20), REPARTITION_BY_NUM, [plan_id=21359101]

(30) HashAggregate [codegen id : 3]
Input [5]: [shardId#21517301, worklistShardItemId#21517302L, product#21517304, plant#21517305, qty#21517308]
Keys [5]: [plant#21517305, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21517308)) AS qty#21517308, worklistShardItemId#21517302L, product#21517304]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#21517305, shardId#21517301, qty#21517308, worklistShardItemId#21517302L, product#21517304]

(31) HashAggregate [codegen id : 3]
Input [5]: [plant#21517305, shardId#21517301, qty#21517308, worklistShardItemId#21517302L, product#21517304]
Keys [5]: [plant#21517305, shardId#21517301, qty#21517308, worklistShardItemId#21517302L, product#21517304]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#21517301, worklistShardItemId#21517302L, product#21517304, plant#21517305, qty#21517308]

(32) BroadcastExchange
Input [5]: [shardId#21517301, worklistShardItemId#21517302L, product#21517304, plant#21517305, qty#21517308]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, string, true], ), isnull(input[3, string, true])),false), [plan_id=21360177]

(33) BroadcastHashJoin [codegen id : 4]
Left keys [4]: [coalesce(product#21556271, ), isnull(product#21556271), coalesce(plant#21556272, ), isnull(plant#21556272)]
Right keys [4]: [coalesce(product#21517304, ), isnull(product#21517304), coalesce(plant#21517305, ), isnull(plant#21517305)]
Join type: Inner
Join condition: ((qty#21556298 <=> qty#21517308) OR isnull(qty#21517308))

(34) Project [codegen id : 4]
Output [6]: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]
Input [11]: [product#21556271, plant#21556272, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307, shardId#21517301, worklistShardItemId#21517302L, product#21517304, plant#21517305, qty#21517308]

(35) Sort [codegen id : 4]
Input [6]: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]
Arguments: [demandChannel#21556278 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#21556298)) AS qty#21556298 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21556279 ASC NULLS FIRST], false, 0

(36) SortAggregate
Input [6]: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]
Keys [5]: [demandChannel#21556278, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21556298)) AS qty#21556298, worklistShardItemId#21517302L, demandStream#21556279]
Functions [1]: [partial_first(kpis#21556307, false)]
Aggregate Attributes [2]: [first#21556484, valueSet#21556485]
Results [7]: [demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, first#21556486, valueSet#21556487]

(37) Exchange
Input [7]: [demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, first#21556486, valueSet#21556487]
Arguments: hashpartitioning(demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, 20), ENSURE_REQUIREMENTS, [plan_id=21360184]

(38) Sort [codegen id : 5]
Input [7]: [demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, first#21556486, valueSet#21556487]
Arguments: [demandChannel#21556278 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21556298 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21556279 ASC NULLS FIRST], false, 0

(39) SortAggregate
Input [7]: [demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, first#21556486, valueSet#21556487]
Keys [5]: [demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279]
Functions [1]: [first(kpis#21556307, false)]
Aggregate Attributes [1]: [first(kpis#21556307)()#21556419]
Results [6]: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, first(kpis#21556307)()#21556419 AS kpis#21556420]

(40) Filter [codegen id : 3]
Input [6]: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]
Condition : (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))

(41) InMemoryTableScan
Output [3]: [shardId#21556774, worklistShardItemId#21556775L, version#21556776]
Arguments: [shardId#21556774, worklistShardItemId#21556775L, version#21556776], [isnotnull(shardId#21556774), isnotnull(worklistShardItemId#21556775L)]

(42) InMemoryRelation
Arguments: [shardId#21556774, worklistShardItemId#21556775L, version#21556776, product#21556777, plant#21556778, periodStart#21556779, periodEnd#21556780, qty#21556781], StorageLevel(disk, memory, 2 replicas)

(43) Filter [codegen id : 1]
Input [3]: [shardId#21556774, worklistShardItemId#21556775L, version#21556776]
Condition : (isnotnull(shardId#21556774) AND isnotnull(worklistShardItemId#21556775L))

(44) HashAggregate [codegen id : 1]
Input [3]: [shardId#21556774, worklistShardItemId#21556775L, version#21556776]
Keys [2]: [shardId#21556774, worklistShardItemId#21556775L]
Functions [1]: [partial_max(version#21556776)]
Aggregate Attributes [1]: [max#21556992]
Results [3]: [shardId#21556774, worklistShardItemId#21556775L, max#21556993]

(45) Exchange
Input [3]: [shardId#21556774, worklistShardItemId#21556775L, max#21556993]
Arguments: hashpartitioning(shardId#21556774, worklistShardItemId#21556775L, 20), ENSURE_REQUIREMENTS, [plan_id=21360281]

(46) HashAggregate [codegen id : 2]
Input [3]: [shardId#21556774, worklistShardItemId#21556775L, max#21556993]
Keys [2]: [shardId#21556774, worklistShardItemId#21556775L]
Functions [1]: [max(version#21556776)]
Aggregate Attributes [1]: [max(version#21556776)#21556773]
Results [3]: [shardId#21556774, worklistShardItemId#21556775L, (max(version#21556776)#21556773 + 1) AS version#21556769]

(47) BroadcastExchange
Input [3]: [shardId#21556774, worklistShardItemId#21556775L, version#21556769]
Arguments: HashedRelationBroadcastMode(List(input[0, string, true], input[1, bigint, true]),false), [plan_id=21360285]

(48) BroadcastHashJoin [codegen id : 3]
Left keys [2]: [shardId#21517301, worklistShardItemId#21517302L]
Right keys [2]: [shardId#21556774, worklistShardItemId#21556775L]
Join type: Inner
Join condition: None

(49) Project [codegen id : 3]
Output [7]: [shardId#21517301, worklistShardItemId#21517302L, version#21556769, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]
Input [9]: [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307, shardId#21556774, worklistShardItemId#21556775L, version#21556769]

(50) CollectLimit
Input: []
Arguments: 1

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	6
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
spark.sql.shuffle.partitions	20
temporal.activity.id	35e014e4-9b78-3af5-884c-68a492deac4b
temporal.activity.type	RunStreamWithId