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

Submitted Time: 2026/03/21 01:11:00
Duration: 0.2 s
Succeeded Jobs: 6389

Plan Visualization

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

digraph G { subgraph cluster0 { isCluster="true"; id="cluster0"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n57 ms (0 ms, 0 ms, 9 ms (stage 116148.0: task 385985))"; tooltip="WholeStageCodegen (2)"; 1 [id="node1" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 11 ms (0 ms, 0 ms, 5 ms (stage 116148.0: task 385985)) peak memory total (min, med, max (stageId: taskId)) 9.3 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 116148.0: task 385999)) number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#1100457], functions=[])"]; } 2 [id="node2" labelType="html" label="Exchange shuffle records written: 37 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 37 local bytes read: 1380.0 B merged fetch fallback count: 0 local blocks read: 15 remote merged chunks fetched: 0 remote blocks read: 22 data size total (min, med, max (stageId: taskId)) 1184.0 B (32.0 B, 32.0 B, 32.0 B (stage 116147.0: task 385948)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 22 ms (0 ms, 0 ms, 0 ms (stage 116147.0: task 385955)) 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: 2024.0 B number of partitions: 37 remote reqs duration: 4 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 3.3 KiB (92.0 B, 92.0 B, 92.0 B (stage 116147.0: task 385948))" tooltip="Exchange hashpartitioning(shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1754811]"]; subgraph cluster3 { isCluster="true"; id="cluster3"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n528 ms (0 ms, 1 ms, 51 ms (stage 116147.0: task 385950))"; tooltip="WholeStageCodegen (1)"; 4 [id="node4" 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, 2 ms (stage 116147.0: task 385962)) peak memory total (min, med, max (stageId: taskId)) 9.3 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 116147.0: task 385948)) number of output rows: 37 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#1100457], functions=[])"]; } 5 [id="node5" labelType="html" label="InMemoryTableScan number of output rows: 238" tooltip="InMemoryTableScan [shardId#1100457]"]; 6 [id="node6" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658], functions=[first(kpis#1125686, false)])"]; subgraph cluster7 { isCluster="true"; id="cluster7"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 8 [id="node8" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#1125657 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1125677 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1125658 ASC NULLS FIRST], false, 0"]; } 9 [id="node9" 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#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, 37), ENSURE_REQUIREMENTS, [plan_id=1754722]"]; 10 [id="node10" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#1125657, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1125677)) AS qty#1125677, worklistShardItemId#1100458L, demandStream#1125658], functions=[partial_first(kpis#1125686, false)])"]; subgraph cluster11 { isCluster="true"; id="cluster11"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 12 [id="node12" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#1125657 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#1125677)) AS qty#1125677 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1125658 ASC NULLS FIRST], false, 0"]; 13 [id="node13" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125686]"]; 14 [id="node14" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [coalesce(product#1125650, ), isnull(product#1125650), coalesce(plant#1125651, ), isnull(plant#1125651)], [coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461)], Inner, BuildRight, ((qty#1125677 <=> qty#1100464) OR isnull(qty#1100464)), false"]; } 15 [id="node15" labelType="html" label=" Union " tooltip="Union"]; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1125631.productId AS product#1125650, prodPlantResults#1125631.plantId AS plant#1125651, null AS qty#1125677, null AS demandChannel#1125657, null AS demandStream#1125658, transform(prodPlantResults#1125631.kpiResults, lambdafunction(struct(label, lambda kpi#1125687.label, dateTime, lambda kpi#1125687.datetime, value, lambda kpi#1125687.value), lambda kpi#1125687, false)) AS kpis#1125686]"]; 17 [id="node17" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1125631]"]; subgraph cluster18 { isCluster="true"; id="cluster18"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 19 [id="node19" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1125624), false, [prodPlantResults#1125631]"]; 20 [id="node20" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1125624]"]; 21 [id="node21" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1125624, true) > 0) AND isnotnull(prodPlantResults#1125624))"]; 22 [id="node22" 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#1125623, 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#1125624]"]; } 23 [id="node23" labelType="html" label=" Scan " tooltip="Scan[obj#1125620]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [_extract_productId#1125822 AS product#1125637, _extract_plantId#1125823 AS plant#1125638, quantityKpiResults#1125643.quantity AS qty#1125644, null AS demandChannel#1125646, null AS demandStream#1125647, transform(quantityKpiResults#1125643.kpiResults, lambdafunction(struct(label, lambda kpi#1125687.label, dateTime, lambda kpi#1125687.datetime, value, lambda kpi#1125687.value), lambda kpi#1125687, false)) AS kpis#1125820]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 26 [id="node26" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_quantityKpiResults#1125824), [_extract_productId#1125822, _extract_plantId#1125823], false, [quantityKpiResults#1125643]"]; 27 [id="node27" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1125676.productId AS _extract_productId#1125822, prodPlantResults#1125676.plantId AS _extract_plantId#1125823, prodPlantResults#1125676.quantityKpiResults AS _extract_quantityKpiResults#1125824]"]; 28 [id="node28" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#1125676.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#1125676.quantityKpiResults))"]; } 29 [id="node29" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1125676], [(size(prodPlantResults#1125676.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#1125676.quantityKpiResults)]"]; subgraph cluster30 { isCluster="true"; id="cluster30"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 31 [id="node31" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1125624), false, [prodPlantResults#1125631]"]; 32 [id="node32" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1125624]"]; 33 [id="node33" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1125624, true) > 0) AND isnotnull(prodPlantResults#1125624))"]; 34 [id="node34" 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#1125623, 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#1125624]"]; } 35 [id="node35" labelType="html" label=" Scan " tooltip="Scan[obj#1125620]"]; 36 [id="node36" labelType="html" label=" Project " tooltip="Project [_extract_productId#1125825 AS product#1125659, _extract_plantId#1125826 AS plant#1125660, null AS qty#1125682, demandChannelStreamKpiResults#1125665.demandChannel AS demandChannel#1125667, demandChannelStreamKpiResults#1125665.demandStream AS demandStream#1125669, transform(demandChannelStreamKpiResults#1125665.kpiResults, lambdafunction(struct(label, lambda kpi#1125687.label, dateTime, lambda kpi#1125687.datetime, value, lambda kpi#1125687.value), lambda kpi#1125687, false)) AS kpis#1125821]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 38 [id="node38" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_demandChannelStreamKpiResults#1125827), [_extract_productId#1125825, _extract_plantId#1125826], false, [demandChannelStreamKpiResults#1125665]"]; 39 [id="node39" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1125681.productId AS _extract_productId#1125825, prodPlantResults#1125681.plantId AS _extract_plantId#1125826, prodPlantResults#1125681.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1125827]"]; 40 [id="node40" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#1125681.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#1125681.demandChannelStreamKpiResults))"]; } 41 [id="node41" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1125681], [(size(prodPlantResults#1125681.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#1125681.demandChannelStreamKpiResults)]"]; subgraph cluster42 { isCluster="true"; id="cluster42"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 43 [id="node43" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1125624), false, [prodPlantResults#1125631]"]; 44 [id="node44" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1125624]"]; 45 [id="node45" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1125624, true) > 0) AND isnotnull(prodPlantResults#1125624))"]; 46 [id="node46" 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#1125623, 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#1125624]"]; } 47 [id="node47" labelType="html" label=" Scan " tooltip="Scan[obj#1125620]"]; 48 [id="node48" 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=1754715]"]; subgraph cluster49 { isCluster="true"; id="cluster49"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 50 [id="node50" 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#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 51 [id="node51" 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(plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1754711]"]; subgraph cluster52 { isCluster="true"; id="cluster52"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 53 [id="node53" 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#1100461, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1100464)) AS qty#1100464, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 54 [id="node54" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]"]; 55 [id="node55" labelType="html" label="Filter number of output rows: 0" tooltip="Filter isNewlyCalculated#1123124: boolean"]; } 56 [id="node56" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [isNewlyCalculated#1123124, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [isNewlyCalculated#1123124]"]; 57 [id="node57" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster58 { isCluster="true"; id="cluster58"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 59 [id="node59" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1123121, null AS demandStream#1123122, [] AS kpis#1123156, true AS isNewlyCalculated#1123124]"]; 60 [id="node60" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1123113, ), isnull(shardId#1123113), coalesce(worklistShardItemId#1123114L, 0), isnull(worklistShardItemId#1123114L), coalesce(version#1123115, 0), isnull(version#1123115), coalesce(product#1123116, ), isnull(product#1123116), coalesce(plant#1123117, ), isnull(plant#1123117), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1122888, 0.0))), isnull(qty#1122888)], LeftAnti"]; } subgraph cluster61 { isCluster="true"; id="cluster61"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 62 [id="node62" labelType="html" label=" Sort " tooltip="Sort [coalesce(shardId#1100457, ) ASC NULLS FIRST, isnull(shardId#1100457) ASC NULLS FIRST, coalesce(worklistShardItemId#1100458L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1100458L) ASC NULLS FIRST, coalesce(version#1100459, 0) ASC NULLS FIRST, isnull(version#1100459) ASC NULLS FIRST, coalesce(product#1100460, ) ASC NULLS FIRST, isnull(product#1100460) ASC NULLS FIRST, coalesce(plant#1100461, ) ASC NULLS FIRST, isnull(plant#1100461) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))) ASC NULLS FIRST, isnull(qty#1100464) ASC NULLS FIRST], false, 0"]; } 63 [id="node63" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464), 37), ENSURE_REQUIREMENTS, [plan_id=1753904]"]; 64 [id="node64" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]"]; 65 [id="node65" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1753674]"]; subgraph cluster66 { isCluster="true"; id="cluster66"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 67 [id="node67" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster68 { isCluster="true"; id="cluster68"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 69 [id="node69" labelType="html" label=" Sort " tooltip="Sort [coalesce(shardId#1123113, ) ASC NULLS FIRST, isnull(shardId#1123113) ASC NULLS FIRST, coalesce(worklistShardItemId#1123114L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1123114L) ASC NULLS FIRST, coalesce(version#1123115, 0) ASC NULLS FIRST, isnull(version#1123115) ASC NULLS FIRST, coalesce(product#1123116, ) ASC NULLS FIRST, isnull(product#1123116) ASC NULLS FIRST, coalesce(plant#1123117, ) ASC NULLS FIRST, isnull(plant#1123117) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1122888, 0.0))) ASC NULLS FIRST, isnull(qty#1122888) ASC NULLS FIRST], false, 0"]; } 70 [id="node70" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(shardId#1123113, ), isnull(shardId#1123113), coalesce(worklistShardItemId#1123114L, 0), isnull(worklistShardItemId#1123114L), coalesce(version#1123115, 0), isnull(version#1123115), coalesce(product#1123116, ), isnull(product#1123116), coalesce(plant#1123117, ), isnull(plant#1123117), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1122888, 0.0))), isnull(qty#1122888), 37), ENSURE_REQUIREMENTS, [plan_id=1753924]"]; 71 [id="node71" labelType="html" label=" Union " tooltip="Union"]; 72 [id="node72" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#1123113, worklistShardItemId#1123114L, version#1123115, product#1123116, plant#1123117, qty#1122888]"]; subgraph cluster73 { isCluster="true"; id="cluster73"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 74 [id="node74" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1122886 AS qty#1122888, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887 AS kpis#1122889]"]; 75 [id="node75" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1122885L, cachedShardId#1122884], Inner"]; } subgraph cluster76 { isCluster="true"; id="cluster76"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 77 [id="node77" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 78 [id="node78" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1753792]"]; subgraph cluster79 { isCluster="true"; id="cluster79"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 80 [id="node80" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 81 [id="node81" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1753788]"]; subgraph cluster82 { isCluster="true"; id="cluster82"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 83 [id="node83" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 84 [id="node84" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 85 [id="node85" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1122875L, cachedShardId#1122874], Inner, BuildLeft, ((qty#1100464 = cachedQty#1122876) OR isnull(qty#1100464)), false"]; 93 [id="node93" labelType="html" label=" Project " tooltip="Project [shardId#1122868 AS cachedShardId#1122874, worklistShardItemId#1122869L AS cachedWorklistShardItemId#1122875L, qty#1122870 AS cachedQty#1122876]"]; 94 [id="node94" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#1122869L) AND isnotnull(shardId#1122868))"]; 95 [id="node95" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1122868,worklistShardItemId#1122869L,qty#1122870,demandChannel#1122871,demandStream#1122872,kpis#1122873]"]; } 86 [id="node86" labelType="html" label=" BroadcastExchange " tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1753782]"]; subgraph cluster87 { isCluster="true"; id="cluster87"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 88 [id="node88" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 89 [id="node89" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 90 [id="node90" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1753674]"]; subgraph cluster91 { isCluster="true"; id="cluster91"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 92 [id="node92" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster96 { isCluster="true"; id="cluster96"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 97 [id="node97" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#1122885L ASC NULLS FIRST, cachedShardId#1122884 ASC NULLS FIRST], false, 0"]; } 98 [id="node98" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#1122885L, cachedShardId#1122884, 37), ENSURE_REQUIREMENTS, [plan_id=1753798]"]; subgraph cluster99 { isCluster="true"; id="cluster99"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 100 [id="node100" labelType="html" label=" Project " tooltip="Project [shardId#1122878 AS cachedShardId#1122884, worklistShardItemId#1122879L AS cachedWorklistShardItemId#1122885L, qty#1122880 AS cachedQty#1122886, demandChannel#1122881, demandStream#1122882, kpis#1122883 AS cachedKpis#1122887]"]; 101 [id="node101" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#1122879L) AND isnotnull(shardId#1122878))"]; 102 [id="node102" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1122878,worklistShardItemId#1122879L,qty#1122880,demandChannel#1122881,demandStream#1122882,kpis#1122883]"]; } subgraph cluster103 { isCluster="true"; id="cluster103"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 104 [id="node104" labelType="html" label=" Project " tooltip="Project [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102]"]; 105 [id="node105" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#1123096L, shardId#1123095], [cachedWorklistShardItemId#1123110L, cachedShardId#1123109], Inner, BuildLeft, false"]; 113 [id="node113" labelType="html" label=" Project " tooltip="Project [shardId#1123103 AS cachedShardId#1123109, worklistShardItemId#1123104L AS cachedWorklistShardItemId#1123110L]"]; 114 [id="node114" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#1123104L) AND isnotnull(shardId#1123103))"]; 115 [id="node115" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1123103,worklistShardItemId#1123104L,qty#1123105,demandChannel#1123106,demandStream#1123107,kpis#1123108]"]; } 106 [id="node106" labelType="html" label=" BroadcastExchange " tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1753918]"]; subgraph cluster107 { isCluster="true"; id="cluster107"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 108 [id="node108" labelType="html" label=" Filter " tooltip="Filter ((isnull(qty#1123102) AND isnotnull(worklistShardItemId#1123096L)) AND isnotnull(shardId#1123095))"]; } 109 [id="node109" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102], [isnull(qty#1123102), isnotnull(worklistShardItemId#1123096L), isnotnull(shardId#1123095)]"]; 110 [id="node110" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1753674]"]; subgraph cluster111 { isCluster="true"; id="cluster111"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 112 [id="node112" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster116 { isCluster="true"; id="cluster116"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 117 [id="node117" labelType="html" label=" Project " tooltip="Project [shardId#1123126, worklistShardItemId#1123127L, version#1123128, product#1123129, plant#1123130, qty#1123154, demandChannel#1123147, demandStream#1123148, kpis#1123155, false AS isNewlyCalculated#1123125]"]; } 118 [id="node118" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [demandChannel#1123147, demandStream#1123148, kpis#1123155, plant#1123130, product#1123129, qty#1123154, shardId#1123126, version#1123128, worklistShardItemId#1123127L]"]; subgraph cluster119 { isCluster="true"; id="cluster119"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 120 [id="node120" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1122886 AS qty#1122888, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887 AS kpis#1122889]"]; 121 [id="node121" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1122885L, cachedShardId#1122884], Inner"]; } subgraph cluster122 { isCluster="true"; id="cluster122"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 123 [id="node123" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 124 [id="node124" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1753792]"]; subgraph cluster125 { isCluster="true"; id="cluster125"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 126 [id="node126" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 127 [id="node127" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1753788]"]; subgraph cluster128 { isCluster="true"; id="cluster128"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 129 [id="node129" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 130 [id="node130" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 131 [id="node131" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1122875L, cachedShardId#1122874], Inner, BuildLeft, ((qty#1100464 = cachedQty#1122876) OR isnull(qty#1100464)), false"]; 139 [id="node139" labelType="html" label=" Project " tooltip="Project [shardId#1122868 AS cachedShardId#1122874, worklistShardItemId#1122869L AS cachedWorklistShardItemId#1122875L, qty#1122870 AS cachedQty#1122876]"]; 140 [id="node140" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#1122869L) AND isnotnull(shardId#1122868))"]; 141 [id="node141" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1122868,worklistShardItemId#1122869L,qty#1122870,demandChannel#1122871,demandStream#1122872,kpis#1122873]"]; } 132 [id="node132" labelType="html" label=" BroadcastExchange " tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1753782]"]; subgraph cluster133 { isCluster="true"; id="cluster133"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 134 [id="node134" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 135 [id="node135" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 136 [id="node136" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1753674]"]; subgraph cluster137 { isCluster="true"; id="cluster137"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 138 [id="node138" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster142 { isCluster="true"; id="cluster142"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 143 [id="node143" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#1122885L ASC NULLS FIRST, cachedShardId#1122884 ASC NULLS FIRST], false, 0"]; } 144 [id="node144" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#1122885L, cachedShardId#1122884, 37), ENSURE_REQUIREMENTS, [plan_id=1753798]"]; subgraph cluster145 { isCluster="true"; id="cluster145"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 146 [id="node146" labelType="html" label=" Project " tooltip="Project [shardId#1122878 AS cachedShardId#1122884, worklistShardItemId#1122879L AS cachedWorklistShardItemId#1122885L, qty#1122880 AS cachedQty#1122886, demandChannel#1122881, demandStream#1122882, kpis#1122883 AS cachedKpis#1122887]"]; 147 [id="node147" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#1122879L) AND isnotnull(shardId#1122878))"]; 148 [id="node148" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1122878,worklistShardItemId#1122879L,qty#1122880,demandChannel#1122881,demandStream#1122882,kpis#1122883]"]; } 2->1; 4->2; 5->4; 6->5; 8->6; 9->8; 10->9; 12->10; 13->12; 14->13; 15->14; 16->15; 17->16; 19->17; 20->19; 21->20; 22->21; 23->22; 24->15; 26->24; 27->26; 28->27; 29->28; 31->29; 32->31; 33->32; 34->33; 35->34; 36->15; 38->36; 39->38; 40->39; 41->40; 43->41; 44->43; 45->44; 46->45; 47->46; 48->14; 50->48; 51->50; 53->51; 54->53; 55->54; 56->55; 57->56; 59->57; 60->59; 62->60; 63->62; 64->63; 65->64; 67->65; 69->60; 70->69; 71->70; 72->71; 74->72; 75->74; 77->75; 78->77; 80->78; 81->80; 83->81; 84->83; 85->84; 86->85; 88->86; 89->88; 90->89; 92->90; 93->85; 94->93; 95->94; 97->75; 98->97; 100->98; 101->100; 102->101; 104->71; 105->104; 106->105; 108->106; 109->108; 110->109; 112->110; 113->105; 114->113; 115->114; 117->57; 118->117; 120->118; 121->120; 123->121; 124->123; 126->124; 127->126; 129->127; 130->129; 131->130; 132->131; 134->132; 135->134; 136->135; 138->136; 139->131; 140->139; 141->140; 143->121; 144->143; 146->144; 147->146; 148->147; }

Details

== Physical Plan ==
* HashAggregate (88)
+- Exchange (87)
   +- * HashAggregate (86)
      +- InMemoryTableScan (1)
            +- InMemoryRelation (2)
                  +- SortAggregate (85)
                     +- * Sort (84)
                        +- Exchange (83)
                           +- SortAggregate (82)
                              +- * Sort (81)
                                 +- * Project (80)
                                    +- * BroadcastHashJoin Inner BuildRight (79)
                                       :- Union (23)
                                       :  :- Project (10)
                                       :  :  +- InMemoryTableScan (3)
                                       :  :        +- InMemoryRelation (4)
                                       :  :              +- * Generate (9)
                                       :  :                 +- * Project (8)
                                       :  :                    +- * Filter (7)
                                       :  :                       +- * SerializeFromObject (6)
                                       :  :                          +- Scan (5)
                                       :  :- Project (16)
                                       :  :  +- * Generate (15)
                                       :  :     +- * Project (14)
                                       :  :        +- * Filter (13)
                                       :  :           +- InMemoryTableScan (11)
                                       :  :                 +- InMemoryRelation (12)
                                       :  :                       +- * Generate (9)
                                       :  :                          +- * Project (8)
                                       :  :                             +- * Filter (7)
                                       :  :                                +- * SerializeFromObject (6)
                                       :  :                                   +- Scan (5)
                                       :  +- Project (22)
                                       :     +- * Generate (21)
                                       :        +- * Project (20)
                                       :           +- * Filter (19)
                                       :              +- InMemoryTableScan (17)
                                       :                    +- InMemoryRelation (18)
                                       :                          +- * Generate (9)
                                       :                             +- * Project (8)
                                       :                                +- * Filter (7)
                                       :                                   +- * SerializeFromObject (6)
                                       :                                      +- Scan (5)
                                       +- BroadcastExchange (78)
                                          +- * HashAggregate (77)
                                             +- Exchange (76)
                                                +- * HashAggregate (75)
                                                   +- * Project (74)
                                                      +- * Filter (73)
                                                         +- InMemoryTableScan (24)
                                                               +- InMemoryRelation (25)
                                                                     +- Union (72)
                                                                        :- * Project (68)
                                                                        :  +- * SortMergeJoin LeftAnti (67)
                                                                        :     :- * Sort (31)
                                                                        :     :  +- Exchange (30)
                                                                        :     :     +- InMemoryTableScan (26)
                                                                        :     :           +- InMemoryRelation (27)
                                                                        :     :                 +- Exchange (29)
                                                                        :     :                    +- * Scan ExistingRDD (28)
                                                                        :     +- * Sort (66)
                                                                        :        +- Exchange (65)
                                                                        :           +- Union (64)
                                                                        :              :- InMemoryTableScan (32)
                                                                        :              :     +- InMemoryRelation (33)
                                                                        :              :           +- * Project (54)
                                                                        :              :              +- * SortMergeJoin Inner (53)
                                                                        :              :                 :- * Sort (47)
                                                                        :              :                 :  +- Exchange (46)
                                                                        :              :                 :     +- * HashAggregate (45)
                                                                        :              :                 :        +- Exchange (44)
                                                                        :              :                 :           +- * HashAggregate (43)
                                                                        :              :                 :              +- * Project (42)
                                                                        :              :                 :                 +- * BroadcastHashJoin Inner BuildLeft (41)
                                                                        :              :                 :                    :- BroadcastExchange (37)
                                                                        :              :                 :                    :  +- * Filter (36)
                                                                        :              :                 :                    :     +- InMemoryTableScan (34)
                                                                        :              :                 :                    :           +- InMemoryRelation (35)
                                                                        :              :                 :                    :                 +- Exchange (29)
                                                                        :              :                 :                    :                    +- * Scan ExistingRDD (28)
                                                                        :              :                 :                    +- * Project (40)
                                                                        :              :                 :                       +- * Filter (39)
                                                                        :              :                 :                          +- * Scan ExistingRDD (38)
                                                                        :              :                 +- * Sort (52)
                                                                        :              :                    +- Exchange (51)
                                                                        :              :                       +- * Project (50)
                                                                        :              :                          +- * Filter (49)
                                                                        :              :                             +- * Scan ExistingRDD (48)
                                                                        :              +- * Project (63)
                                                                        :                 +- * BroadcastHashJoin Inner BuildLeft (62)
                                                                        :                    :- BroadcastExchange (58)
                                                                        :                    :  +- * Filter (57)
                                                                        :                    :     +- InMemoryTableScan (55)
                                                                        :                    :           +- InMemoryRelation (56)
                                                                        :                    :                 +- Exchange (29)
                                                                        :                    :                    +- * Scan ExistingRDD (28)
                                                                        :                    +- * Project (61)
                                                                        :                       +- * Filter (60)
                                                                        :                          +- * Scan ExistingRDD (59)
                                                                        +- * Project (71)
                                                                           +- InMemoryTableScan (69)
                                                                                 +- InMemoryRelation (70)
                                                                                       +- * Project (54)
                                                                                          +- * SortMergeJoin Inner (53)
                                                                                             :- * Sort (47)
                                                                                             :  +- Exchange (46)
                                                                                             :     +- * HashAggregate (45)
                                                                                             :        +- Exchange (44)
                                                                                             :           +- * HashAggregate (43)
                                                                                             :              +- * Project (42)
                                                                                             :                 +- * BroadcastHashJoin Inner BuildLeft (41)
                                                                                             :                    :- BroadcastExchange (37)
                                                                                             :                    :  +- * Filter (36)
                                                                                             :                    :     +- InMemoryTableScan (34)
                                                                                             :                    :           +- InMemoryRelation (35)
                                                                                             :                    :                 +- Exchange (29)
                                                                                             :                    :                    +- * Scan ExistingRDD (28)
                                                                                             :                    +- * Project (40)
                                                                                             :                       +- * Filter (39)
                                                                                             :                          +- * Scan ExistingRDD (38)
                                                                                             +- * Sort (52)
                                                                                                +- Exchange (51)
                                                                                                   +- * Project (50)
                                                                                                      +- * Filter (49)
                                                                                                         +- * Scan ExistingRDD (48)


(1) InMemoryTableScan
Output [1]: [shardId#1100457]
Arguments: [shardId#1100457]

(2) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125686], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [1]: [prodPlantResults#1125631]
Arguments: [prodPlantResults#1125631]

(4) InMemoryRelation
Arguments: [prodPlantResults#1125631], StorageLevel(disk, memory, 2 replicas)

(5) Scan
Output [1]: [obj#1125620]
Arguments: obj#1125620: com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, MapPartitionsRDD[56038] at start at FileStorageAdapterImpl.java:171

(6) SerializeFromObject [codegen id : 1]
Input [1]: [obj#1125620]
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#1125623, 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#1125624]

(7) Filter [codegen id : 1]
Input [2]: [performanceMeasurements#1125623, prodPlantResults#1125624]
Condition : ((size(prodPlantResults#1125624, true) > 0) AND isnotnull(prodPlantResults#1125624))

(8) Project [codegen id : 1]
Output [1]: [prodPlantResults#1125624]
Input [2]: [performanceMeasurements#1125623, prodPlantResults#1125624]

(9) Generate [codegen id : 1]
Input [1]: [prodPlantResults#1125624]
Arguments: explode(prodPlantResults#1125624), false, [prodPlantResults#1125631]

(10) Project
Output [6]: [prodPlantResults#1125631.productId AS product#1125650, prodPlantResults#1125631.plantId AS plant#1125651, null AS qty#1125677, null AS demandChannel#1125657, null AS demandStream#1125658, transform(prodPlantResults#1125631.kpiResults, lambdafunction(struct(label, lambda kpi#1125687.label, dateTime, lambda kpi#1125687.datetime, value, lambda kpi#1125687.value), lambda kpi#1125687, false)) AS kpis#1125686]
Input [1]: [prodPlantResults#1125631]

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

(12) InMemoryRelation
Arguments: [prodPlantResults#1125676], StorageLevel(disk, memory, 2 replicas)

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

(14) Project [codegen id : 1]
Output [3]: [prodPlantResults#1125676.productId AS _extract_productId#1125822, prodPlantResults#1125676.plantId AS _extract_plantId#1125823, prodPlantResults#1125676.quantityKpiResults AS _extract_quantityKpiResults#1125824]
Input [1]: [prodPlantResults#1125676]

(15) Generate [codegen id : 1]
Input [3]: [_extract_productId#1125822, _extract_plantId#1125823, _extract_quantityKpiResults#1125824]
Arguments: explode(_extract_quantityKpiResults#1125824), [_extract_productId#1125822, _extract_plantId#1125823], false, [quantityKpiResults#1125643]

(16) Project
Output [6]: [_extract_productId#1125822 AS product#1125637, _extract_plantId#1125823 AS plant#1125638, quantityKpiResults#1125643.quantity AS qty#1125644, null AS demandChannel#1125646, null AS demandStream#1125647, transform(quantityKpiResults#1125643.kpiResults, lambdafunction(struct(label, lambda kpi#1125687.label, dateTime, lambda kpi#1125687.datetime, value, lambda kpi#1125687.value), lambda kpi#1125687, false)) AS kpis#1125820]
Input [3]: [_extract_productId#1125822, _extract_plantId#1125823, quantityKpiResults#1125643]

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

(18) InMemoryRelation
Arguments: [prodPlantResults#1125681], StorageLevel(disk, memory, 2 replicas)

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

(20) Project [codegen id : 2]
Output [3]: [prodPlantResults#1125681.productId AS _extract_productId#1125825, prodPlantResults#1125681.plantId AS _extract_plantId#1125826, prodPlantResults#1125681.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1125827]
Input [1]: [prodPlantResults#1125681]

(21) Generate [codegen id : 2]
Input [3]: [_extract_productId#1125825, _extract_plantId#1125826, _extract_demandChannelStreamKpiResults#1125827]
Arguments: explode(_extract_demandChannelStreamKpiResults#1125827), [_extract_productId#1125825, _extract_plantId#1125826], false, [demandChannelStreamKpiResults#1125665]

(22) Project
Output [6]: [_extract_productId#1125825 AS product#1125659, _extract_plantId#1125826 AS plant#1125660, null AS qty#1125682, demandChannelStreamKpiResults#1125665.demandChannel AS demandChannel#1125667, demandChannelStreamKpiResults#1125665.demandStream AS demandStream#1125669, transform(demandChannelStreamKpiResults#1125665.kpiResults, lambdafunction(struct(label, lambda kpi#1125687.label, dateTime, lambda kpi#1125687.datetime, value, lambda kpi#1125687.value), lambda kpi#1125687, false)) AS kpis#1125821]
Input [3]: [_extract_productId#1125825, _extract_plantId#1125826, demandChannelStreamKpiResults#1125665]

(23) Union

(24) InMemoryTableScan
Output [6]: [isNewlyCalculated#1123124, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]
Arguments: [isNewlyCalculated#1123124, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [isNewlyCalculated#1123124]

(25) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, demandChannel#1123121, demandStream#1123122, kpis#1123156, isNewlyCalculated#1123124], StorageLevel(disk, memory, 2 replicas)

(26) InMemoryTableScan
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]

(27) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464], StorageLevel(disk, memory, 2 replicas)

(28) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464], SQLExecutionRDD[55896] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(29) Exchange
Input [8]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464]
Arguments: hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1753674]

(30) Exchange
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: hashpartitioning(coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464), 37), ENSURE_REQUIREMENTS, [plan_id=1753904]

(31) Sort [codegen id : 1]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: [coalesce(shardId#1100457, ) ASC NULLS FIRST, isnull(shardId#1100457) ASC NULLS FIRST, coalesce(worklistShardItemId#1100458L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1100458L) ASC NULLS FIRST, coalesce(version#1100459, 0) ASC NULLS FIRST, isnull(version#1100459) ASC NULLS FIRST, coalesce(product#1100460, ) ASC NULLS FIRST, isnull(product#1100460) ASC NULLS FIRST, coalesce(plant#1100461, ) ASC NULLS FIRST, isnull(plant#1100461) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))) ASC NULLS FIRST, isnull(qty#1100464) ASC NULLS FIRST], false, 0

(32) InMemoryTableScan
Output [6]: [shardId#1123113, worklistShardItemId#1123114L, version#1123115, product#1123116, plant#1123117, qty#1122888]
Arguments: [shardId#1123113, worklistShardItemId#1123114L, version#1123115, product#1123116, plant#1123117, qty#1122888]

(33) InMemoryRelation
Arguments: [shardId#1123113, worklistShardItemId#1123114L, version#1123115, product#1123116, plant#1123117, qty#1122888, demandChannel#1122881, demandStream#1122882, kpis#1122889], StorageLevel(disk, memory, 2 replicas)

(34) InMemoryTableScan
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]

(35) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464], StorageLevel(disk, memory, 2 replicas)

(36) Filter [codegen id : 1]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Condition : (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))

(37) BroadcastExchange
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1753782]

(38) Scan ExistingRDD
Output [6]: [shardId#1122868, worklistShardItemId#1122869L, qty#1122870, demandChannel#1122871, demandStream#1122872, kpis#1122873]
Arguments: [shardId#1122868, worklistShardItemId#1122869L, qty#1122870, demandChannel#1122871, demandStream#1122872, kpis#1122873], MapPartitionsRDD[55918] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(39) Filter
Input [6]: [shardId#1122868, worklistShardItemId#1122869L, qty#1122870, demandChannel#1122871, demandStream#1122872, kpis#1122873]
Condition : (isnotnull(worklistShardItemId#1122869L) AND isnotnull(shardId#1122868))

(40) Project
Output [3]: [shardId#1122868 AS cachedShardId#1122874, worklistShardItemId#1122869L AS cachedWorklistShardItemId#1122875L, qty#1122870 AS cachedQty#1122876]
Input [6]: [shardId#1122868, worklistShardItemId#1122869L, qty#1122870, demandChannel#1122871, demandStream#1122872, kpis#1122873]

(41) BroadcastHashJoin [codegen id : 2]
Left keys [2]: [worklistShardItemId#1100458L, shardId#1100457]
Right keys [2]: [cachedWorklistShardItemId#1122875L, cachedShardId#1122874]
Join type: Inner
Join condition: ((qty#1100464 = cachedQty#1122876) OR isnull(qty#1100464))

(42) Project [codegen id : 2]
Output [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Input [9]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, cachedShardId#1122874, cachedWorklistShardItemId#1122875L, cachedQty#1122876]

(43) HashAggregate [codegen id : 2]
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Keys [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]

(44) Exchange
Input [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Arguments: hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1753788]

(45) HashAggregate [codegen id : 3]
Input [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Keys [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]

(46) Exchange
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Arguments: hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1753792]

(47) Sort [codegen id : 4]
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Arguments: [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0

(48) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#1122878, worklistShardItemId#1122879L, qty#1122880, demandChannel#1122881, demandStream#1122882, kpis#1122883]
Arguments: [shardId#1122878, worklistShardItemId#1122879L, qty#1122880, demandChannel#1122881, demandStream#1122882, kpis#1122883], MapPartitionsRDD[55918] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(49) Filter [codegen id : 5]
Input [6]: [shardId#1122878, worklistShardItemId#1122879L, qty#1122880, demandChannel#1122881, demandStream#1122882, kpis#1122883]
Condition : (isnotnull(worklistShardItemId#1122879L) AND isnotnull(shardId#1122878))

(50) Project [codegen id : 5]
Output [6]: [shardId#1122878 AS cachedShardId#1122884, worklistShardItemId#1122879L AS cachedWorklistShardItemId#1122885L, qty#1122880 AS cachedQty#1122886, demandChannel#1122881, demandStream#1122882, kpis#1122883 AS cachedKpis#1122887]
Input [6]: [shardId#1122878, worklistShardItemId#1122879L, qty#1122880, demandChannel#1122881, demandStream#1122882, kpis#1122883]

(51) Exchange
Input [6]: [cachedShardId#1122884, cachedWorklistShardItemId#1122885L, cachedQty#1122886, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887]
Arguments: hashpartitioning(cachedWorklistShardItemId#1122885L, cachedShardId#1122884, 37), ENSURE_REQUIREMENTS, [plan_id=1753798]

(52) Sort [codegen id : 6]
Input [6]: [cachedShardId#1122884, cachedWorklistShardItemId#1122885L, cachedQty#1122886, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887]
Arguments: [cachedWorklistShardItemId#1122885L ASC NULLS FIRST, cachedShardId#1122884 ASC NULLS FIRST], false, 0

(53) SortMergeJoin [codegen id : 7]
Left keys [2]: [worklistShardItemId#1100458L, shardId#1100457]
Right keys [2]: [cachedWorklistShardItemId#1122885L, cachedShardId#1122884]
Join type: Inner
Join condition: None

(54) Project [codegen id : 7]
Output [9]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1122886 AS qty#1122888, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887 AS kpis#1122889]
Input [11]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedShardId#1122884, cachedWorklistShardItemId#1122885L, cachedQty#1122886, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887]

(55) InMemoryTableScan
Output [6]: [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102]
Arguments: [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102], [isnull(qty#1123102), isnotnull(worklistShardItemId#1123096L), isnotnull(shardId#1123095)]

(56) InMemoryRelation
Arguments: [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, periodStart#1123100, periodEnd#1123101, qty#1123102], StorageLevel(disk, memory, 2 replicas)

(57) Filter [codegen id : 2]
Input [6]: [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102]
Condition : ((isnull(qty#1123102) AND isnotnull(worklistShardItemId#1123096L)) AND isnotnull(shardId#1123095))

(58) BroadcastExchange
Input [6]: [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1753918]

(59) Scan ExistingRDD
Output [6]: [shardId#1123103, worklistShardItemId#1123104L, qty#1123105, demandChannel#1123106, demandStream#1123107, kpis#1123108]
Arguments: [shardId#1123103, worklistShardItemId#1123104L, qty#1123105, demandChannel#1123106, demandStream#1123107, kpis#1123108], MapPartitionsRDD[55918] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(60) Filter
Input [6]: [shardId#1123103, worklistShardItemId#1123104L, qty#1123105, demandChannel#1123106, demandStream#1123107, kpis#1123108]
Condition : (isnotnull(worklistShardItemId#1123104L) AND isnotnull(shardId#1123103))

(61) Project
Output [2]: [shardId#1123103 AS cachedShardId#1123109, worklistShardItemId#1123104L AS cachedWorklistShardItemId#1123110L]
Input [6]: [shardId#1123103, worklistShardItemId#1123104L, qty#1123105, demandChannel#1123106, demandStream#1123107, kpis#1123108]

(62) BroadcastHashJoin [codegen id : 3]
Left keys [2]: [worklistShardItemId#1123096L, shardId#1123095]
Right keys [2]: [cachedWorklistShardItemId#1123110L, cachedShardId#1123109]
Join type: Inner
Join condition: None

(63) Project [codegen id : 3]
Output [6]: [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102]
Input [8]: [shardId#1123095, worklistShardItemId#1123096L, version#1123097, product#1123098, plant#1123099, qty#1123102, cachedShardId#1123109, cachedWorklistShardItemId#1123110L]

(64) Union

(65) Exchange
Input [6]: [shardId#1123113, worklistShardItemId#1123114L, version#1123115, product#1123116, plant#1123117, qty#1122888]
Arguments: hashpartitioning(coalesce(shardId#1123113, ), isnull(shardId#1123113), coalesce(worklistShardItemId#1123114L, 0), isnull(worklistShardItemId#1123114L), coalesce(version#1123115, 0), isnull(version#1123115), coalesce(product#1123116, ), isnull(product#1123116), coalesce(plant#1123117, ), isnull(plant#1123117), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1122888, 0.0))), isnull(qty#1122888), 37), ENSURE_REQUIREMENTS, [plan_id=1753924]

(66) Sort [codegen id : 4]
Input [6]: [shardId#1123113, worklistShardItemId#1123114L, version#1123115, product#1123116, plant#1123117, qty#1122888]
Arguments: [coalesce(shardId#1123113, ) ASC NULLS FIRST, isnull(shardId#1123113) ASC NULLS FIRST, coalesce(worklistShardItemId#1123114L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1123114L) ASC NULLS FIRST, coalesce(version#1123115, 0) ASC NULLS FIRST, isnull(version#1123115) ASC NULLS FIRST, coalesce(product#1123116, ) ASC NULLS FIRST, isnull(product#1123116) ASC NULLS FIRST, coalesce(plant#1123117, ) ASC NULLS FIRST, isnull(plant#1123117) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1122888, 0.0))) ASC NULLS FIRST, isnull(qty#1122888) ASC NULLS FIRST], false, 0

(67) SortMergeJoin [codegen id : 5]
Left keys [12]: [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)]
Right keys [12]: [coalesce(shardId#1123113, ), isnull(shardId#1123113), coalesce(worklistShardItemId#1123114L, 0), isnull(worklistShardItemId#1123114L), coalesce(version#1123115, 0), isnull(version#1123115), coalesce(product#1123116, ), isnull(product#1123116), coalesce(plant#1123117, ), isnull(plant#1123117), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1122888, 0.0))), isnull(qty#1122888)]
Join type: LeftAnti
Join condition: None

(68) Project [codegen id : 5]
Output [10]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1123121, null AS demandStream#1123122, [] AS kpis#1123156, true AS isNewlyCalculated#1123124]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]

(69) InMemoryTableScan
Output [9]: [demandChannel#1123147, demandStream#1123148, kpis#1123155, plant#1123130, product#1123129, qty#1123154, shardId#1123126, version#1123128, worklistShardItemId#1123127L]
Arguments: [demandChannel#1123147, demandStream#1123148, kpis#1123155, plant#1123130, product#1123129, qty#1123154, shardId#1123126, version#1123128, worklistShardItemId#1123127L]

(70) InMemoryRelation
Arguments: [shardId#1123126, worklistShardItemId#1123127L, version#1123128, product#1123129, plant#1123130, qty#1123154, demandChannel#1123147, demandStream#1123148, kpis#1123155], StorageLevel(disk, memory, 2 replicas)

(71) Project [codegen id : 6]
Output [10]: [shardId#1123126, worklistShardItemId#1123127L, version#1123128, product#1123129, plant#1123130, qty#1123154, demandChannel#1123147, demandStream#1123148, kpis#1123155, false AS isNewlyCalculated#1123125]
Input [9]: [demandChannel#1123147, demandStream#1123148, kpis#1123155, plant#1123130, product#1123129, qty#1123154, shardId#1123126, version#1123128, worklistShardItemId#1123127L]

(72) Union

(73) Filter [codegen id : 3]
Input [6]: [isNewlyCalculated#1123124, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]
Condition : isNewlyCalculated#1123124

(74) Project [codegen id : 3]
Output [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]
Input [6]: [isNewlyCalculated#1123124, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]

(75) HashAggregate [codegen id : 3]
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]
Keys [5]: [plant#1100461, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1100464)) AS qty#1100464, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]

(76) Exchange
Input [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]
Arguments: hashpartitioning(plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1754711]

(77) HashAggregate [codegen id : 4]
Input [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]
Keys [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]

(78) BroadcastExchange
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]
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=1754715]

(79) BroadcastHashJoin [codegen id : 5]
Left keys [4]: [coalesce(product#1125650, ), isnull(product#1125650), coalesce(plant#1125651, ), isnull(plant#1125651)]
Right keys [4]: [coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461)]
Join type: Inner
Join condition: ((qty#1125677 <=> qty#1100464) OR isnull(qty#1100464))

(80) Project [codegen id : 5]
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125686]
Input [11]: [product#1125650, plant#1125651, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125686, shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]

(81) Sort [codegen id : 5]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125686]
Arguments: [demandChannel#1125657 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#1125677)) AS qty#1125677 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1125658 ASC NULLS FIRST], false, 0

(82) SortAggregate
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125686]
Keys [5]: [demandChannel#1125657, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1125677)) AS qty#1125677, worklistShardItemId#1100458L, demandStream#1125658]
Functions [1]: [partial_first(kpis#1125686, false)]
Aggregate Attributes [2]: [first#1125893, valueSet#1125894]
Results [7]: [demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, first#1125895, valueSet#1125896]

(83) Exchange
Input [7]: [demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, first#1125895, valueSet#1125896]
Arguments: hashpartitioning(demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, 37), ENSURE_REQUIREMENTS, [plan_id=1754722]

(84) Sort [codegen id : 6]
Input [7]: [demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, first#1125895, valueSet#1125896]
Arguments: [demandChannel#1125657 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1125677 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1125658 ASC NULLS FIRST], false, 0

(85) SortAggregate
Input [7]: [demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, first#1125895, valueSet#1125896]
Keys [5]: [demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658]
Functions [1]: [first(kpis#1125686, false)]
Aggregate Attributes [1]: [first(kpis#1125686)()#1125818]
Results [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, first(kpis#1125686)()#1125818 AS kpis#1125819]

(86) HashAggregate [codegen id : 1]
Input [1]: [shardId#1100457]
Keys [1]: [shardId#1100457]
Functions: []
Aggregate Attributes: []
Results [1]: [shardId#1100457]

(87) Exchange
Input [1]: [shardId#1100457]
Arguments: hashpartitioning(shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1754811]

(88) HashAggregate [codegen id : 2]
Input [1]: [shardId#1100457]
Keys [1]: [shardId#1100457]
Functions: []
Aggregate Attributes: []
Results [1]: [shardId#1100457]

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	2
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
temporal.activity.id	2fe7819b-828a-3eaa-98c4-d5f04113b6b3
temporal.activity.type	RunStreamWithId