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

Submitted Time: 2026/04/20 06:20:40
Duration: 1.0 min
Succeeded Jobs: 191

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))\n1.8 s (2 ms, 5 ms, 213 ms (stage 584.0: task 6133))"; 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)) 27 ms (0 ms, 0 ms, 10 ms (stage 584.0: task 6177)) peak memory total (min, med, max (stageId: taskId)) 9.3 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 584.0: task 6133)) number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#445], 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: 1564.0 B merged fetch fallback count: 0 local blocks read: 17 remote merged chunks fetched: 0 remote blocks read: 20 data size total (min, med, max (stageId: taskId)) 1184.0 B (32.0 B, 32.0 B, 32.0 B (stage 583.0: task 6093)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 18 ms (0 ms, 0 ms, 0 ms (stage 583.0: task 6114)) 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: 1840.0 B number of partitions: 37 remote reqs duration: 1 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 583.0: task 6093))" tooltip="Exchange hashpartitioning(shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=115477]"]; subgraph cluster3 { isCluster="true"; id="cluster3"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n180 ms (2 ms, 2 ms, 58 ms (stage 583.0: task 6092))"; 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)) 16 ms (0 ms, 0 ms, 3 ms (stage 583.0: task 6092)) peak memory total (min, med, max (stageId: taskId)) 9.3 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 583.0: task 6093)) number of output rows: 37 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#445], functions=[])"]; } 5 [id="node5" labelType="html" label="InMemoryTableScan number of output rows: 39,996" tooltip="InMemoryTableScan [shardId#445]"]; 6 [id="node6" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[first(kpis#16018, false)])"]; subgraph cluster7 { isCluster="true"; id="cluster7"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 8 [id="node8" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 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#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, 37), ENSURE_REQUIREMENTS, [plan_id=115377]"]; 10 [id="node10" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#15989, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[partial_first(kpis#16018, false)])"]; subgraph cluster11 { isCluster="true"; id="cluster11"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 12 [id="node12" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0"]; 13 [id="node13" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018]"]; 14 [id="node14" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(product#15982, ), isnull(product#15982), coalesce(plant#15983, ), isnull(plant#15983)], [coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449)], Inner, ((qty#16009 <=> qty#452) OR isnull(qty#452))"]; } subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 16 [id="node16" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(product#15982, ) ASC NULLS FIRST, isnull(product#15982) ASC NULLS FIRST, coalesce(plant#15983, ) ASC NULLS FIRST, isnull(plant#15983) ASC NULLS FIRST], false, 0"]; } 17 [id="node17" 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(coalesce(product#15982, ), isnull(product#15982), coalesce(plant#15983, ), isnull(plant#15983), 37), ENSURE_REQUIREMENTS, [plan_id=115353]"]; 18 [id="node18" labelType="html" label=" Union " tooltip="Union"]; 19 [id="node19" labelType="html" label=" Project " tooltip="Project [prodPlantResults#15963.productId AS product#15982, prodPlantResults#15963.plantId AS plant#15983, null AS qty#16009, null AS demandChannel#15989, null AS demandStream#15990, transform(prodPlantResults#15963.kpiResults, lambdafunction(struct(label, lambda kpi#16019.label, dateTime, lambda kpi#16019.datetime, value, lambda kpi#16019.value), lambda kpi#16019, false)) AS kpis#16018]"]; 20 [id="node20" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#15963]"]; subgraph cluster21 { isCluster="true"; id="cluster21"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 22 [id="node22" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#15956), false, [prodPlantResults#15963]"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [prodPlantResults#15956]"]; 24 [id="node24" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#15956, true) > 0) AND isnotnull(prodPlantResults#15956))"]; 25 [id="node25" 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#15955, 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#15956]"]; } 26 [id="node26" labelType="html" label=" Scan " tooltip="Scan[obj#15952]"]; 27 [id="node27" labelType="html" label=" Project " tooltip="Project [_extract_productId#16154 AS product#15969, _extract_plantId#16155 AS plant#15970, quantityKpiResults#15975.quantity AS qty#15976, null AS demandChannel#15978, null AS demandStream#15979, transform(quantityKpiResults#15975.kpiResults, lambdafunction(struct(label, lambda kpi#16019.label, dateTime, lambda kpi#16019.datetime, value, lambda kpi#16019.value), lambda kpi#16019, false)) AS kpis#16152]"]; subgraph cluster28 { isCluster="true"; id="cluster28"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 29 [id="node29" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_quantityKpiResults#16156), [_extract_productId#16154, _extract_plantId#16155], false, [quantityKpiResults#15975]"]; 30 [id="node30" labelType="html" label=" Project " tooltip="Project [prodPlantResults#16008.productId AS _extract_productId#16154, prodPlantResults#16008.plantId AS _extract_plantId#16155, prodPlantResults#16008.quantityKpiResults AS _extract_quantityKpiResults#16156]"]; 31 [id="node31" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#16008.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#16008.quantityKpiResults))"]; } 32 [id="node32" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#16008], [(size(prodPlantResults#16008.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#16008.quantityKpiResults)]"]; subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 34 [id="node34" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#15956), false, [prodPlantResults#15963]"]; 35 [id="node35" labelType="html" label=" Project " tooltip="Project [prodPlantResults#15956]"]; 36 [id="node36" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#15956, true) > 0) AND isnotnull(prodPlantResults#15956))"]; 37 [id="node37" 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#15955, 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#15956]"]; } 38 [id="node38" labelType="html" label=" Scan " tooltip="Scan[obj#15952]"]; 39 [id="node39" labelType="html" label=" Project " tooltip="Project [_extract_productId#16157 AS product#15991, _extract_plantId#16158 AS plant#15992, null AS qty#16014, demandChannelStreamKpiResults#15997.demandChannel AS demandChannel#15999, demandChannelStreamKpiResults#15997.demandStream AS demandStream#16001, transform(demandChannelStreamKpiResults#15997.kpiResults, lambdafunction(struct(label, lambda kpi#16019.label, dateTime, lambda kpi#16019.datetime, value, lambda kpi#16019.value), lambda kpi#16019, false)) AS kpis#16153]"]; subgraph cluster40 { isCluster="true"; id="cluster40"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 41 [id="node41" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_demandChannelStreamKpiResults#16159), [_extract_productId#16157, _extract_plantId#16158], false, [demandChannelStreamKpiResults#15997]"]; 42 [id="node42" labelType="html" label=" Project " tooltip="Project [prodPlantResults#16013.productId AS _extract_productId#16157, prodPlantResults#16013.plantId AS _extract_plantId#16158, prodPlantResults#16013.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#16159]"]; 43 [id="node43" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#16013.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#16013.demandChannelStreamKpiResults))"]; } 44 [id="node44" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#16013], [(size(prodPlantResults#16013.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#16013.demandChannelStreamKpiResults)]"]; subgraph cluster45 { isCluster="true"; id="cluster45"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 46 [id="node46" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#15956), false, [prodPlantResults#15963]"]; 47 [id="node47" labelType="html" label=" Project " tooltip="Project [prodPlantResults#15956]"]; 48 [id="node48" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#15956, true) > 0) AND isnotnull(prodPlantResults#15956))"]; 49 [id="node49" 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#15955, 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#15956]"]; } 50 [id="node50" labelType="html" label=" Scan " tooltip="Scan[obj#15952]"]; subgraph cluster51 { isCluster="true"; id="cluster51"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 52 [id="node52" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST], false, 0"]; } 53 [id="node53" 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(coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), 37), ENSURE_REQUIREMENTS, [plan_id=115367]"]; subgraph cluster54 { isCluster="true"; id="cluster54"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 55 [id="node55" 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#449, shardId#445, qty#452, worklistShardItemId#446L, product#448], functions=[])"]; } 56 [id="node56" 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#449, shardId#445, qty#452, worklistShardItemId#446L, product#448, 37), ENSURE_REQUIREMENTS, [plan_id=115363]"]; subgraph cluster57 { isCluster="true"; id="cluster57"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 58 [id="node58" 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#449, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#452)) AS qty#452, worklistShardItemId#446L, product#448], functions=[])"]; 59 [id="node59" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]"]; 60 [id="node60" labelType="html" label="Filter number of output rows: 0" tooltip="Filter isNewlyCalculated#13248: boolean"]; } 61 [id="node61" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [isNewlyCalculated#13248, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L], [isNewlyCalculated#13248]"]; 62 [id="node62" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster63 { isCluster="true"; id="cluster63"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 64 [id="node64" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248]"]; 65 [id="node65" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti"]; } subgraph cluster66 { isCluster="true"; id="cluster66"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 67 [id="node67" labelType="html" label=" Sort " tooltip="Sort [coalesce(shardId#445, ) ASC NULLS FIRST, isnull(shardId#445) ASC NULLS FIRST, coalesce(worklistShardItemId#446L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#446L) ASC NULLS FIRST, coalesce(version#447, 0) ASC NULLS FIRST, isnull(version#447) ASC NULLS FIRST, coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))) ASC NULLS FIRST, isnull(qty#452) ASC NULLS FIRST], false, 0"]; } 68 [id="node68" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452), 37), ENSURE_REQUIREMENTS, [plan_id=114079]"]; 69 [id="node69" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]"]; 70 [id="node70" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]"]; subgraph cluster71 { isCluster="true"; id="cluster71"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 72 [id="node72" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster73 { isCluster="true"; id="cluster73"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 74 [id="node74" labelType="html" label=" Sort " tooltip="Sort [coalesce(shardId#13237, ) ASC NULLS FIRST, isnull(shardId#13237) ASC NULLS FIRST, coalesce(worklistShardItemId#13238L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#13238L) ASC NULLS FIRST, coalesce(version#13239, 0) ASC NULLS FIRST, isnull(version#13239) ASC NULLS FIRST, coalesce(product#13240, ) ASC NULLS FIRST, isnull(product#13240) ASC NULLS FIRST, coalesce(plant#13241, ) ASC NULLS FIRST, isnull(plant#13241) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))) ASC NULLS FIRST, isnull(qty#13012) ASC NULLS FIRST], false, 0"]; } 75 [id="node75" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012), 37), ENSURE_REQUIREMENTS, [plan_id=114108]"]; 76 [id="node76" labelType="html" label=" Union " tooltip="Union"]; 77 [id="node77" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#13237, worklistShardItemId#13238L, version#13239, product#13240, plant#13241, qty#13012]"]; subgraph cluster78 { isCluster="true"; id="cluster78"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 79 [id="node79" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]"]; 80 [id="node80" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], Inner"]; } subgraph cluster81 { isCluster="true"; id="cluster81"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 82 [id="node82" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 83 [id="node83" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 84 [id="node84" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 85 [id="node85" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 86 [id="node86" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#12999L, cachedShardId#12998], Inner, ((qty#452 = cachedQty#13000) OR isnull(qty#452))"]; } subgraph cluster87 { isCluster="true"; id="cluster87"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 88 [id="node88" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 89 [id="node89" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=113962]"]; subgraph cluster90 { isCluster="true"; id="cluster90"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 91 [id="node91" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 92 [id="node92" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 93 [id="node93" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]"]; subgraph cluster94 { isCluster="true"; id="cluster94"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 95 [id="node95" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster96 { isCluster="true"; id="cluster96"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 97 [id="node97" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#12999L ASC NULLS FIRST, cachedShardId#12998 ASC NULLS FIRST], false, 0"]; } 98 [id="node98" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#12999L, cachedShardId#12998, 37), ENSURE_REQUIREMENTS, [plan_id=113968]"]; subgraph cluster99 { isCluster="true"; id="cluster99"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 100 [id="node100" labelType="html" label=" Project " tooltip="Project [shardId#12992 AS cachedShardId#12998, worklistShardItemId#12993L AS cachedWorklistShardItemId#12999L, qty#12994 AS cachedQty#13000]"]; 101 [id="node101" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#12993L) AND isnotnull(shardId#12992))"]; 102 [id="node102" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#12992,worklistShardItemId#12993L,qty#12994,demandChannel#12995,demandStream#12996,kpis#12997]"]; } subgraph cluster103 { isCluster="true"; id="cluster103"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 104 [id="node104" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#13009L ASC NULLS FIRST, cachedShardId#13008 ASC NULLS FIRST], false, 0"]; } 105 [id="node105" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#13009L, cachedShardId#13008, 37), ENSURE_REQUIREMENTS, [plan_id=113981]"]; subgraph cluster106 { isCluster="true"; id="cluster106"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 107 [id="node107" labelType="html" label=" Project " tooltip="Project [shardId#13002 AS cachedShardId#13008, worklistShardItemId#13003L AS cachedWorklistShardItemId#13009L, qty#13004 AS cachedQty#13010, demandChannel#13005, demandStream#13006, kpis#13007 AS cachedKpis#13011]"]; 108 [id="node108" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#13003L) AND isnotnull(shardId#13002))"]; 109 [id="node109" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#13002,worklistShardItemId#13003L,qty#13004,demandChannel#13005,demandStream#13006,kpis#13007]"]; } subgraph cluster110 { isCluster="true"; id="cluster110"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 111 [id="node111" labelType="html" label=" Project " tooltip="Project [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226]"]; 112 [id="node112" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#13220L, shardId#13219], [cachedWorklistShardItemId#13234L, cachedShardId#13233], Inner"]; } subgraph cluster113 { isCluster="true"; id="cluster113"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 114 [id="node114" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#13220L ASC NULLS FIRST, shardId#13219 ASC NULLS FIRST], false, 0"]; } 115 [id="node115" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#13220L, shardId#13219, 37), ENSURE_REQUIREMENTS, [plan_id=114093]"]; subgraph cluster116 { isCluster="true"; id="cluster116"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 117 [id="node117" labelType="html" label=" Filter " tooltip="Filter ((isnull(qty#13226) AND isnotnull(worklistShardItemId#13220L)) AND isnotnull(shardId#13219))"]; } 118 [id="node118" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226], [isnull(qty#13226), isnotnull(worklistShardItemId#13220L), isnotnull(shardId#13219)]"]; 119 [id="node119" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]"]; subgraph cluster120 { isCluster="true"; id="cluster120"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 121 [id="node121" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster122 { isCluster="true"; id="cluster122"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 123 [id="node123" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#13234L ASC NULLS FIRST, cachedShardId#13233 ASC NULLS FIRST], false, 0"]; } 124 [id="node124" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#13234L, cachedShardId#13233, 37), ENSURE_REQUIREMENTS, [plan_id=114099]"]; subgraph cluster125 { isCluster="true"; id="cluster125"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 126 [id="node126" labelType="html" label=" Project " tooltip="Project [shardId#13227 AS cachedShardId#13233, worklistShardItemId#13228L AS cachedWorklistShardItemId#13234L]"]; 127 [id="node127" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#13228L) AND isnotnull(shardId#13227))"]; 128 [id="node128" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#13227,worklistShardItemId#13228L,qty#13229,demandChannel#13230,demandStream#13231,kpis#13232]"]; } subgraph cluster129 { isCluster="true"; id="cluster129"; label="WholeStageCodegen (9)"; tooltip="WholeStageCodegen (9)"; 130 [id="node130" labelType="html" label=" Project " tooltip="Project [shardId#13250, worklistShardItemId#13251L, version#13252, product#13253, plant#13254, qty#13278, demandChannel#13271, demandStream#13272, kpis#13279, false AS isNewlyCalculated#13249]"]; } 131 [id="node131" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [demandChannel#13271, demandStream#13272, kpis#13279, plant#13254, product#13253, qty#13278, shardId#13250, version#13252, worklistShardItemId#13251L]"]; subgraph cluster132 { isCluster="true"; id="cluster132"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 133 [id="node133" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]"]; 134 [id="node134" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], Inner"]; } subgraph cluster135 { isCluster="true"; id="cluster135"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 136 [id="node136" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 137 [id="node137" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 138 [id="node138" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 139 [id="node139" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 140 [id="node140" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#12999L, cachedShardId#12998], Inner, ((qty#452 = cachedQty#13000) OR isnull(qty#452))"]; } subgraph cluster141 { isCluster="true"; id="cluster141"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 142 [id="node142" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 143 [id="node143" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=113962]"]; subgraph cluster144 { isCluster="true"; id="cluster144"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 145 [id="node145" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 146 [id="node146" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 147 [id="node147" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]"]; subgraph cluster148 { isCluster="true"; id="cluster148"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 149 [id="node149" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster150 { isCluster="true"; id="cluster150"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 151 [id="node151" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#12999L ASC NULLS FIRST, cachedShardId#12998 ASC NULLS FIRST], false, 0"]; } 152 [id="node152" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#12999L, cachedShardId#12998, 37), ENSURE_REQUIREMENTS, [plan_id=113968]"]; subgraph cluster153 { isCluster="true"; id="cluster153"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 154 [id="node154" labelType="html" label=" Project " tooltip="Project [shardId#12992 AS cachedShardId#12998, worklistShardItemId#12993L AS cachedWorklistShardItemId#12999L, qty#12994 AS cachedQty#13000]"]; 155 [id="node155" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#12993L) AND isnotnull(shardId#12992))"]; 156 [id="node156" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#12992,worklistShardItemId#12993L,qty#12994,demandChannel#12995,demandStream#12996,kpis#12997]"]; } subgraph cluster157 { isCluster="true"; id="cluster157"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 158 [id="node158" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#13009L ASC NULLS FIRST, cachedShardId#13008 ASC NULLS FIRST], false, 0"]; } 159 [id="node159" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#13009L, cachedShardId#13008, 37), ENSURE_REQUIREMENTS, [plan_id=113981]"]; subgraph cluster160 { isCluster="true"; id="cluster160"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 161 [id="node161" labelType="html" label=" Project " tooltip="Project [shardId#13002 AS cachedShardId#13008, worklistShardItemId#13003L AS cachedWorklistShardItemId#13009L, qty#13004 AS cachedQty#13010, demandChannel#13005, demandStream#13006, kpis#13007 AS cachedKpis#13011]"]; 162 [id="node162" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#13003L) AND isnotnull(shardId#13002))"]; 163 [id="node163" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#13002,worklistShardItemId#13003L,qty#13004,demandChannel#13005,demandStream#13006,kpis#13007]"]; } 2->1; 4->2; 5->4; 6->5; 8->6; 9->8; 10->9; 12->10; 13->12; 14->13; 16->14; 17->16; 18->17; 19->18; 20->19; 22->20; 23->22; 24->23; 25->24; 26->25; 27->18; 29->27; 30->29; 31->30; 32->31; 34->32; 35->34; 36->35; 37->36; 38->37; 39->18; 41->39; 42->41; 43->42; 44->43; 46->44; 47->46; 48->47; 49->48; 50->49; 52->14; 53->52; 55->53; 56->55; 58->56; 59->58; 60->59; 61->60; 62->61; 64->62; 65->64; 67->65; 68->67; 69->68; 70->69; 72->70; 74->65; 75->74; 76->75; 77->76; 79->77; 80->79; 82->80; 83->82; 84->83; 85->84; 86->85; 88->86; 89->88; 91->89; 92->91; 93->92; 95->93; 97->86; 98->97; 100->98; 101->100; 102->101; 104->80; 105->104; 107->105; 108->107; 109->108; 111->76; 112->111; 114->112; 115->114; 117->115; 118->117; 119->118; 121->119; 123->112; 124->123; 126->124; 127->126; 128->127; 130->62; 131->130; 133->131; 134->133; 136->134; 137->136; 138->137; 139->138; 140->139; 142->140; 143->142; 145->143; 146->145; 147->146; 149->147; 151->140; 152->151; 154->152; 155->154; 156->155; 158->134; 159->158; 161->159; 162->161; 163->162; }

Details

== Physical Plan ==
* HashAggregate (95)
+- Exchange (94)
   +- * HashAggregate (93)
      +- InMemoryTableScan (1)
            +- InMemoryRelation (2)
                  +- SortAggregate (92)
                     +- * Sort (91)
                        +- Exchange (90)
                           +- SortAggregate (89)
                              +- * Sort (88)
                                 +- * Project (87)
                                    +- * SortMergeJoin Inner (86)
                                       :- * Sort (25)
                                       :  +- Exchange (24)
                                       :     +- 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)
                                       +- * Sort (85)
                                          +- Exchange (84)
                                             +- * HashAggregate (83)
                                                +- Exchange (82)
                                                   +- * HashAggregate (81)
                                                      +- * Project (80)
                                                         +- * Filter (79)
                                                            +- InMemoryTableScan (26)
                                                                  +- InMemoryRelation (27)
                                                                        +- Union (78)
                                                                           :- * Project (74)
                                                                           :  +- * SortMergeJoin LeftAnti (73)
                                                                           :     :- * Sort (33)
                                                                           :     :  +- Exchange (32)
                                                                           :     :     +- InMemoryTableScan (28)
                                                                           :     :           +- InMemoryRelation (29)
                                                                           :     :                 +- Exchange (31)
                                                                           :     :                    +- * Scan ExistingRDD (30)
                                                                           :     +- * Sort (72)
                                                                           :        +- Exchange (71)
                                                                           :           +- Union (70)
                                                                           :              :- InMemoryTableScan (34)
                                                                           :              :     +- InMemoryRelation (35)
                                                                           :              :           +- * Project (57)
                                                                           :              :              +- * SortMergeJoin Inner (56)
                                                                           :              :                 :- * Sort (50)
                                                                           :              :                 :  +- * HashAggregate (49)
                                                                           :              :                 :     +- * HashAggregate (48)
                                                                           :              :                 :        +- * Project (47)
                                                                           :              :                 :           +- * SortMergeJoin Inner (46)
                                                                           :              :                 :              :- * Sort (40)
                                                                           :              :                 :              :  +- Exchange (39)
                                                                           :              :                 :              :     +- * Filter (38)
                                                                           :              :                 :              :        +- InMemoryTableScan (36)
                                                                           :              :                 :              :              +- InMemoryRelation (37)
                                                                           :              :                 :              :                    +- Exchange (31)
                                                                           :              :                 :              :                       +- * Scan ExistingRDD (30)
                                                                           :              :                 :              +- * Sort (45)
                                                                           :              :                 :                 +- Exchange (44)
                                                                           :              :                 :                    +- * Project (43)
                                                                           :              :                 :                       +- * Filter (42)
                                                                           :              :                 :                          +- * Scan ExistingRDD (41)
                                                                           :              :                 +- * Sort (55)
                                                                           :              :                    +- Exchange (54)
                                                                           :              :                       +- * Project (53)
                                                                           :              :                          +- * Filter (52)
                                                                           :              :                             +- * Scan ExistingRDD (51)
                                                                           :              +- * Project (69)
                                                                           :                 +- * SortMergeJoin Inner (68)
                                                                           :                    :- * Sort (62)
                                                                           :                    :  +- Exchange (61)
                                                                           :                    :     +- * Filter (60)
                                                                           :                    :        +- InMemoryTableScan (58)
                                                                           :                    :              +- InMemoryRelation (59)
                                                                           :                    :                    +- Exchange (31)
                                                                           :                    :                       +- * Scan ExistingRDD (30)
                                                                           :                    +- * Sort (67)
                                                                           :                       +- Exchange (66)
                                                                           :                          +- * Project (65)
                                                                           :                             +- * Filter (64)
                                                                           :                                +- * Scan ExistingRDD (63)
                                                                           +- * Project (77)
                                                                              +- InMemoryTableScan (75)
                                                                                    +- InMemoryRelation (76)
                                                                                          +- * Project (57)
                                                                                             +- * SortMergeJoin Inner (56)
                                                                                                :- * Sort (50)
                                                                                                :  +- * HashAggregate (49)
                                                                                                :     +- * HashAggregate (48)
                                                                                                :        +- * Project (47)
                                                                                                :           +- * SortMergeJoin Inner (46)
                                                                                                :              :- * Sort (40)
                                                                                                :              :  +- Exchange (39)
                                                                                                :              :     +- * Filter (38)
                                                                                                :              :        +- InMemoryTableScan (36)
                                                                                                :              :              +- InMemoryRelation (37)
                                                                                                :              :                    +- Exchange (31)
                                                                                                :              :                       +- * Scan ExistingRDD (30)
                                                                                                :              +- * Sort (45)
                                                                                                :                 +- Exchange (44)
                                                                                                :                    +- * Project (43)
                                                                                                :                       +- * Filter (42)
                                                                                                :                          +- * Scan ExistingRDD (41)
                                                                                                +- * Sort (55)
                                                                                                   +- Exchange (54)
                                                                                                      +- * Project (53)
                                                                                                         +- * Filter (52)
                                                                                                            +- * Scan ExistingRDD (51)


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

(2) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018], StorageLevel(disk, memory, 2 replicas)

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

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

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

(6) SerializeFromObject [codegen id : 1]
Input [1]: [obj#15952]
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#15955, 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#15956]

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

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

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

(10) Project
Output [6]: [prodPlantResults#15963.productId AS product#15982, prodPlantResults#15963.plantId AS plant#15983, null AS qty#16009, null AS demandChannel#15989, null AS demandStream#15990, transform(prodPlantResults#15963.kpiResults, lambdafunction(struct(label, lambda kpi#16019.label, dateTime, lambda kpi#16019.datetime, value, lambda kpi#16019.value), lambda kpi#16019, false)) AS kpis#16018]
Input [1]: [prodPlantResults#15963]

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

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

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

(14) Project [codegen id : 1]
Output [3]: [prodPlantResults#16008.productId AS _extract_productId#16154, prodPlantResults#16008.plantId AS _extract_plantId#16155, prodPlantResults#16008.quantityKpiResults AS _extract_quantityKpiResults#16156]
Input [1]: [prodPlantResults#16008]

(15) Generate [codegen id : 1]
Input [3]: [_extract_productId#16154, _extract_plantId#16155, _extract_quantityKpiResults#16156]
Arguments: explode(_extract_quantityKpiResults#16156), [_extract_productId#16154, _extract_plantId#16155], false, [quantityKpiResults#15975]

(16) Project
Output [6]: [_extract_productId#16154 AS product#15969, _extract_plantId#16155 AS plant#15970, quantityKpiResults#15975.quantity AS qty#15976, null AS demandChannel#15978, null AS demandStream#15979, transform(quantityKpiResults#15975.kpiResults, lambdafunction(struct(label, lambda kpi#16019.label, dateTime, lambda kpi#16019.datetime, value, lambda kpi#16019.value), lambda kpi#16019, false)) AS kpis#16152]
Input [3]: [_extract_productId#16154, _extract_plantId#16155, quantityKpiResults#15975]

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

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

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

(20) Project [codegen id : 2]
Output [3]: [prodPlantResults#16013.productId AS _extract_productId#16157, prodPlantResults#16013.plantId AS _extract_plantId#16158, prodPlantResults#16013.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#16159]
Input [1]: [prodPlantResults#16013]

(21) Generate [codegen id : 2]
Input [3]: [_extract_productId#16157, _extract_plantId#16158, _extract_demandChannelStreamKpiResults#16159]
Arguments: explode(_extract_demandChannelStreamKpiResults#16159), [_extract_productId#16157, _extract_plantId#16158], false, [demandChannelStreamKpiResults#15997]

(22) Project
Output [6]: [_extract_productId#16157 AS product#15991, _extract_plantId#16158 AS plant#15992, null AS qty#16014, demandChannelStreamKpiResults#15997.demandChannel AS demandChannel#15999, demandChannelStreamKpiResults#15997.demandStream AS demandStream#16001, transform(demandChannelStreamKpiResults#15997.kpiResults, lambdafunction(struct(label, lambda kpi#16019.label, dateTime, lambda kpi#16019.datetime, value, lambda kpi#16019.value), lambda kpi#16019, false)) AS kpis#16153]
Input [3]: [_extract_productId#16157, _extract_plantId#16158, demandChannelStreamKpiResults#15997]

(23) Union

(24) Exchange
Input [6]: [product#15982, plant#15983, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018]
Arguments: hashpartitioning(coalesce(product#15982, ), isnull(product#15982), coalesce(plant#15983, ), isnull(plant#15983), 37), ENSURE_REQUIREMENTS, [plan_id=115353]

(25) Sort [codegen id : 3]
Input [6]: [product#15982, plant#15983, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018]
Arguments: [coalesce(product#15982, ) ASC NULLS FIRST, isnull(product#15982) ASC NULLS FIRST, coalesce(plant#15983, ) ASC NULLS FIRST, isnull(plant#15983) ASC NULLS FIRST], false, 0

(26) InMemoryTableScan
Output [6]: [isNewlyCalculated#13248, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L]
Arguments: [isNewlyCalculated#13248, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L], [isNewlyCalculated#13248]

(27) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, demandChannel#13245, demandStream#13246, kpis#13280, isNewlyCalculated#13248], StorageLevel(disk, memory, 2 replicas)

(28) InMemoryTableScan
Output [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]

(29) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452], StorageLevel(disk, memory, 2 replicas)

(30) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452]
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452], SQLExecutionRDD[839] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(31) Exchange
Input [8]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452]
Arguments: hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=113634]

(32) Exchange
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: hashpartitioning(coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452), 37), ENSURE_REQUIREMENTS, [plan_id=114079]

(33) Sort [codegen id : 1]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [coalesce(shardId#445, ) ASC NULLS FIRST, isnull(shardId#445) ASC NULLS FIRST, coalesce(worklistShardItemId#446L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#446L) ASC NULLS FIRST, coalesce(version#447, 0) ASC NULLS FIRST, isnull(version#447) ASC NULLS FIRST, coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))) ASC NULLS FIRST, isnull(qty#452) ASC NULLS FIRST], false, 0

(34) InMemoryTableScan
Output [6]: [shardId#13237, worklistShardItemId#13238L, version#13239, product#13240, plant#13241, qty#13012]
Arguments: [shardId#13237, worklistShardItemId#13238L, version#13239, product#13240, plant#13241, qty#13012]

(35) InMemoryRelation
Arguments: [shardId#13237, worklistShardItemId#13238L, version#13239, product#13240, plant#13241, qty#13012, demandChannel#13005, demandStream#13006, kpis#13013], StorageLevel(disk, memory, 2 replicas)

(36) InMemoryTableScan
Output [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]

(37) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452], StorageLevel(disk, memory, 2 replicas)

(38) Filter [codegen id : 1]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Condition : (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))

(39) Exchange
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=113962]

(40) Sort [codegen id : 2]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0

(41) Scan ExistingRDD [codegen id : 3]
Output [6]: [shardId#12992, worklistShardItemId#12993L, qty#12994, demandChannel#12995, demandStream#12996, kpis#12997]
Arguments: [shardId#12992, worklistShardItemId#12993L, qty#12994, demandChannel#12995, demandStream#12996, kpis#12997], MapPartitionsRDD[867] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(42) Filter [codegen id : 3]
Input [6]: [shardId#12992, worklistShardItemId#12993L, qty#12994, demandChannel#12995, demandStream#12996, kpis#12997]
Condition : (isnotnull(worklistShardItemId#12993L) AND isnotnull(shardId#12992))

(43) Project [codegen id : 3]
Output [3]: [shardId#12992 AS cachedShardId#12998, worklistShardItemId#12993L AS cachedWorklistShardItemId#12999L, qty#12994 AS cachedQty#13000]
Input [6]: [shardId#12992, worklistShardItemId#12993L, qty#12994, demandChannel#12995, demandStream#12996, kpis#12997]

(44) Exchange
Input [3]: [cachedShardId#12998, cachedWorklistShardItemId#12999L, cachedQty#13000]
Arguments: hashpartitioning(cachedWorklistShardItemId#12999L, cachedShardId#12998, 37), ENSURE_REQUIREMENTS, [plan_id=113968]

(45) Sort [codegen id : 4]
Input [3]: [cachedShardId#12998, cachedWorklistShardItemId#12999L, cachedQty#13000]
Arguments: [cachedWorklistShardItemId#12999L ASC NULLS FIRST, cachedShardId#12998 ASC NULLS FIRST], false, 0

(46) SortMergeJoin [codegen id : 5]
Left keys [2]: [worklistShardItemId#446L, shardId#445]
Right keys [2]: [cachedWorklistShardItemId#12999L, cachedShardId#12998]
Join type: Inner
Join condition: ((qty#452 = cachedQty#13000) OR isnull(qty#452))

(47) Project [codegen id : 5]
Output [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]
Input [9]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, cachedShardId#12998, cachedWorklistShardItemId#12999L, cachedQty#13000]

(48) HashAggregate [codegen id : 5]
Input [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]
Keys [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]

(49) HashAggregate [codegen id : 5]
Input [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]
Keys [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]

(50) Sort [codegen id : 5]
Input [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]
Arguments: [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0

(51) Scan ExistingRDD [codegen id : 6]
Output [6]: [shardId#13002, worklistShardItemId#13003L, qty#13004, demandChannel#13005, demandStream#13006, kpis#13007]
Arguments: [shardId#13002, worklistShardItemId#13003L, qty#13004, demandChannel#13005, demandStream#13006, kpis#13007], MapPartitionsRDD[867] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(52) Filter [codegen id : 6]
Input [6]: [shardId#13002, worklistShardItemId#13003L, qty#13004, demandChannel#13005, demandStream#13006, kpis#13007]
Condition : (isnotnull(worklistShardItemId#13003L) AND isnotnull(shardId#13002))

(53) Project [codegen id : 6]
Output [6]: [shardId#13002 AS cachedShardId#13008, worklistShardItemId#13003L AS cachedWorklistShardItemId#13009L, qty#13004 AS cachedQty#13010, demandChannel#13005, demandStream#13006, kpis#13007 AS cachedKpis#13011]
Input [6]: [shardId#13002, worklistShardItemId#13003L, qty#13004, demandChannel#13005, demandStream#13006, kpis#13007]

(54) Exchange
Input [6]: [cachedShardId#13008, cachedWorklistShardItemId#13009L, cachedQty#13010, demandChannel#13005, demandStream#13006, cachedKpis#13011]
Arguments: hashpartitioning(cachedWorklistShardItemId#13009L, cachedShardId#13008, 37), ENSURE_REQUIREMENTS, [plan_id=113981]

(55) Sort [codegen id : 7]
Input [6]: [cachedShardId#13008, cachedWorklistShardItemId#13009L, cachedQty#13010, demandChannel#13005, demandStream#13006, cachedKpis#13011]
Arguments: [cachedWorklistShardItemId#13009L ASC NULLS FIRST, cachedShardId#13008 ASC NULLS FIRST], false, 0

(56) SortMergeJoin [codegen id : 8]
Left keys [2]: [worklistShardItemId#446L, shardId#445]
Right keys [2]: [cachedWorklistShardItemId#13009L, cachedShardId#13008]
Join type: Inner
Join condition: None

(57) Project [codegen id : 8]
Output [9]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]
Input [11]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedShardId#13008, cachedWorklistShardItemId#13009L, cachedQty#13010, demandChannel#13005, demandStream#13006, cachedKpis#13011]

(58) InMemoryTableScan
Output [6]: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226]
Arguments: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226], [isnull(qty#13226), isnotnull(worklistShardItemId#13220L), isnotnull(shardId#13219)]

(59) InMemoryRelation
Arguments: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, periodStart#13224, periodEnd#13225, qty#13226], StorageLevel(disk, memory, 2 replicas)

(60) Filter [codegen id : 2]
Input [6]: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226]
Condition : ((isnull(qty#13226) AND isnotnull(worklistShardItemId#13220L)) AND isnotnull(shardId#13219))

(61) Exchange
Input [6]: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226]
Arguments: hashpartitioning(worklistShardItemId#13220L, shardId#13219, 37), ENSURE_REQUIREMENTS, [plan_id=114093]

(62) Sort [codegen id : 3]
Input [6]: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226]
Arguments: [worklistShardItemId#13220L ASC NULLS FIRST, shardId#13219 ASC NULLS FIRST], false, 0

(63) Scan ExistingRDD [codegen id : 4]
Output [6]: [shardId#13227, worklistShardItemId#13228L, qty#13229, demandChannel#13230, demandStream#13231, kpis#13232]
Arguments: [shardId#13227, worklistShardItemId#13228L, qty#13229, demandChannel#13230, demandStream#13231, kpis#13232], MapPartitionsRDD[867] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(64) Filter [codegen id : 4]
Input [6]: [shardId#13227, worklistShardItemId#13228L, qty#13229, demandChannel#13230, demandStream#13231, kpis#13232]
Condition : (isnotnull(worklistShardItemId#13228L) AND isnotnull(shardId#13227))

(65) Project [codegen id : 4]
Output [2]: [shardId#13227 AS cachedShardId#13233, worklistShardItemId#13228L AS cachedWorklistShardItemId#13234L]
Input [6]: [shardId#13227, worklistShardItemId#13228L, qty#13229, demandChannel#13230, demandStream#13231, kpis#13232]

(66) Exchange
Input [2]: [cachedShardId#13233, cachedWorklistShardItemId#13234L]
Arguments: hashpartitioning(cachedWorklistShardItemId#13234L, cachedShardId#13233, 37), ENSURE_REQUIREMENTS, [plan_id=114099]

(67) Sort [codegen id : 5]
Input [2]: [cachedShardId#13233, cachedWorklistShardItemId#13234L]
Arguments: [cachedWorklistShardItemId#13234L ASC NULLS FIRST, cachedShardId#13233 ASC NULLS FIRST], false, 0

(68) SortMergeJoin [codegen id : 6]
Left keys [2]: [worklistShardItemId#13220L, shardId#13219]
Right keys [2]: [cachedWorklistShardItemId#13234L, cachedShardId#13233]
Join type: Inner
Join condition: None

(69) Project [codegen id : 6]
Output [6]: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226]
Input [8]: [shardId#13219, worklistShardItemId#13220L, version#13221, product#13222, plant#13223, qty#13226, cachedShardId#13233, cachedWorklistShardItemId#13234L]

(70) Union

(71) Exchange
Input [6]: [shardId#13237, worklistShardItemId#13238L, version#13239, product#13240, plant#13241, qty#13012]
Arguments: hashpartitioning(coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012), 37), ENSURE_REQUIREMENTS, [plan_id=114108]

(72) Sort [codegen id : 7]
Input [6]: [shardId#13237, worklistShardItemId#13238L, version#13239, product#13240, plant#13241, qty#13012]
Arguments: [coalesce(shardId#13237, ) ASC NULLS FIRST, isnull(shardId#13237) ASC NULLS FIRST, coalesce(worklistShardItemId#13238L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#13238L) ASC NULLS FIRST, coalesce(version#13239, 0) ASC NULLS FIRST, isnull(version#13239) ASC NULLS FIRST, coalesce(product#13240, ) ASC NULLS FIRST, isnull(product#13240) ASC NULLS FIRST, coalesce(plant#13241, ) ASC NULLS FIRST, isnull(plant#13241) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))) ASC NULLS FIRST, isnull(qty#13012) ASC NULLS FIRST], false, 0

(73) SortMergeJoin [codegen id : 8]
Left keys [12]: [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)]
Right keys [12]: [coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)]
Join type: LeftAnti
Join condition: None

(74) Project [codegen id : 8]
Output [10]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]

(75) InMemoryTableScan
Output [9]: [demandChannel#13271, demandStream#13272, kpis#13279, plant#13254, product#13253, qty#13278, shardId#13250, version#13252, worklistShardItemId#13251L]
Arguments: [demandChannel#13271, demandStream#13272, kpis#13279, plant#13254, product#13253, qty#13278, shardId#13250, version#13252, worklistShardItemId#13251L]

(76) InMemoryRelation
Arguments: [shardId#13250, worklistShardItemId#13251L, version#13252, product#13253, plant#13254, qty#13278, demandChannel#13271, demandStream#13272, kpis#13279], StorageLevel(disk, memory, 2 replicas)

(77) Project [codegen id : 9]
Output [10]: [shardId#13250, worklistShardItemId#13251L, version#13252, product#13253, plant#13254, qty#13278, demandChannel#13271, demandStream#13272, kpis#13279, false AS isNewlyCalculated#13249]
Input [9]: [demandChannel#13271, demandStream#13272, kpis#13279, plant#13254, product#13253, qty#13278, shardId#13250, version#13252, worklistShardItemId#13251L]

(78) Union

(79) Filter [codegen id : 4]
Input [6]: [isNewlyCalculated#13248, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L]
Condition : isNewlyCalculated#13248

(80) Project [codegen id : 4]
Output [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Input [6]: [isNewlyCalculated#13248, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L]

(81) HashAggregate [codegen id : 4]
Input [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Keys [5]: [plant#449, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#452)) AS qty#452, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]

(82) Exchange
Input [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]
Arguments: hashpartitioning(plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448, 37), ENSURE_REQUIREMENTS, [plan_id=115363]

(83) HashAggregate [codegen id : 5]
Input [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]
Keys [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]

(84) Exchange
Input [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Arguments: hashpartitioning(coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), 37), ENSURE_REQUIREMENTS, [plan_id=115367]

(85) Sort [codegen id : 6]
Input [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Arguments: [coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST], false, 0

(86) SortMergeJoin [codegen id : 7]
Left keys [4]: [coalesce(product#15982, ), isnull(product#15982), coalesce(plant#15983, ), isnull(plant#15983)]
Right keys [4]: [coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449)]
Join type: Inner
Join condition: ((qty#16009 <=> qty#452) OR isnull(qty#452))

(87) Project [codegen id : 7]
Output [6]: [shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018]
Input [11]: [product#15982, plant#15983, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018, shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]

(88) Sort [codegen id : 7]
Input [6]: [shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018]
Arguments: [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0

(89) SortAggregate
Input [6]: [shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16018]
Keys [5]: [demandChannel#15989, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009, worklistShardItemId#446L, demandStream#15990]
Functions [1]: [partial_first(kpis#16018, false)]
Aggregate Attributes [2]: [first#16225, valueSet#16226]
Results [7]: [demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228]

(90) Exchange
Input [7]: [demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228]
Arguments: hashpartitioning(demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, 37), ENSURE_REQUIREMENTS, [plan_id=115377]

(91) Sort [codegen id : 8]
Input [7]: [demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228]
Arguments: [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0

(92) SortAggregate
Input [7]: [demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228]
Keys [5]: [demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990]
Functions [1]: [first(kpis#16018, false)]
Aggregate Attributes [1]: [first(kpis#16018)()#16150]
Results [6]: [shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, first(kpis#16018)()#16150 AS kpis#16151]

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

(94) Exchange
Input [1]: [shardId#445]
Arguments: hashpartitioning(shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=115477]

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

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
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	bcc6d1d6-5234-362e-a110-b40301899480
temporal.activity.type	RunStreamWithId