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

Submitted Time: 2026/04/20 07:07:58
Duration: 68 ms

Plan Visualization

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

digraph G { 0 [id="node0" labelType="html" label=" DeserializeToObject " tooltip="DeserializeToObject createexternalrow(invoke(shardId#445.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#446L)), static_invoke(java.lang.Double.valueOf(qty#27283)), invoke(demandChannel#27263.toString()), invoke(demandStream#27264.toString()), mapobjects(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1), createexternalrow(invoke(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).label.toString()), static_invoke(DateTimeUtils.toJavaTimestamp(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).dateTime)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).value)), StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true)), kpis#27292, Some(class scala.collection.mutable.ArraySeq)), StructField(shardId,StringType,true), StructField(worklistShardItemId,LongType,true), StructField(qty,DoubleType,true), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpis,ArrayType(StructType(StructField(label,StringType,true),StructField(dateTime,TimestampType,true),StructField(value,DoubleType,true)),false),true)), obj#27612: org.apache.spark.sql.Row"]; 1 [id="node1" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]"]; 2 [id="node2" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[first(kpis#27292, false)])"]; subgraph cluster3 { isCluster="true"; id="cluster3"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 4 [id="node4" labelType="html" label=" Sort " tooltip="Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0"]; } 5 [id="node5" labelType="html" label="Exchange number of partitions: 37" tooltip="Exchange hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]"]; 6 [id="node6" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[partial_first(kpis#27292, false)])"]; subgraph cluster7 { isCluster="true"; id="cluster7"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 8 [id="node8" labelType="html" label=" Sort " tooltip="Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0"]; 9 [id="node9" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]"]; 10 [id="node10" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [coalesce(product#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257)], [coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449)], Inner, ((qty#27283 <=> qty#452) OR isnull(qty#452))"]; } subgraph cluster11 { isCluster="true"; id="cluster11"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 12 [id="node12" labelType="html" label=" Sort " tooltip="Sort [coalesce(product#27256, ) ASC NULLS FIRST, isnull(product#27256) ASC NULLS FIRST, coalesce(plant#27257, ) ASC NULLS FIRST, isnull(plant#27257) ASC NULLS FIRST], false, 0"]; } 13 [id="node13" labelType="html" label="Exchange number of partitions: 37" tooltip="Exchange hashpartitioning(coalesce(product#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257), 37), ENSURE_REQUIREMENTS, [plan_id=118533]"]; 14 [id="node14" labelType="html" label=" Union " tooltip="Union"]; 15 [id="node15" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27237.productId AS product#27256, prodPlantResults#27237.plantId AS plant#27257, null AS qty#27283, null AS demandChannel#27263, null AS demandStream#27264, transform(prodPlantResults#27237.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27292]"]; 16 [id="node16" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#27237]"]; subgraph cluster17 { isCluster="true"; id="cluster17"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 18 [id="node18" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237]"]; 19 [id="node19" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27230]"]; 20 [id="node20" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))"]; 21 [id="node21" 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#27229, 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#27230]"]; } 22 [id="node22" labelType="html" label=" Scan " tooltip="Scan[obj#27226]"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [_extract_productId#27428 AS product#27243, _extract_plantId#27429 AS plant#27244, quantityKpiResults#27249.quantity AS qty#27250, null AS demandChannel#27252, null AS demandStream#27253, transform(quantityKpiResults#27249.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27426]"]; subgraph cluster24 { isCluster="true"; id="cluster24"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 25 [id="node25" labelType="html" label=" Generate " tooltip="Generate explode(_extract_quantityKpiResults#27430), [_extract_productId#27428, _extract_plantId#27429], false, [quantityKpiResults#27249]"]; 26 [id="node26" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27282.productId AS _extract_productId#27428, prodPlantResults#27282.plantId AS _extract_plantId#27429, prodPlantResults#27282.quantityKpiResults AS _extract_quantityKpiResults#27430]"]; 27 [id="node27" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27282.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#27282.quantityKpiResults))"]; } 28 [id="node28" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#27282], [(size(prodPlantResults#27282.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#27282.quantityKpiResults)]"]; subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 30 [id="node30" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237]"]; 31 [id="node31" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27230]"]; 32 [id="node32" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))"]; 33 [id="node33" 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#27229, 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#27230]"]; } 34 [id="node34" labelType="html" label=" Scan " tooltip="Scan[obj#27226]"]; 35 [id="node35" labelType="html" label=" Project " tooltip="Project [_extract_productId#27431 AS product#27265, _extract_plantId#27432 AS plant#27266, null AS qty#27288, demandChannelStreamKpiResults#27271.demandChannel AS demandChannel#27273, demandChannelStreamKpiResults#27271.demandStream AS demandStream#27275, transform(demandChannelStreamKpiResults#27271.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27427]"]; subgraph cluster36 { isCluster="true"; id="cluster36"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 37 [id="node37" labelType="html" label=" Generate " tooltip="Generate explode(_extract_demandChannelStreamKpiResults#27433), [_extract_productId#27431, _extract_plantId#27432], false, [demandChannelStreamKpiResults#27271]"]; 38 [id="node38" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27287.productId AS _extract_productId#27431, prodPlantResults#27287.plantId AS _extract_plantId#27432, prodPlantResults#27287.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#27433]"]; 39 [id="node39" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27287.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#27287.demandChannelStreamKpiResults))"]; } 40 [id="node40" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#27287], [(size(prodPlantResults#27287.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#27287.demandChannelStreamKpiResults)]"]; subgraph cluster41 { isCluster="true"; id="cluster41"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 42 [id="node42" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237]"]; 43 [id="node43" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27230]"]; 44 [id="node44" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))"]; 45 [id="node45" 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#27229, 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#27230]"]; } 46 [id="node46" labelType="html" label=" Scan " tooltip="Scan[obj#27226]"]; subgraph cluster47 { isCluster="true"; id="cluster47"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 48 [id="node48" labelType="html" label=" Sort " 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"]; } 49 [id="node49" labelType="html" label="Exchange number of partitions: 37" tooltip="Exchange hashpartitioning(coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), 37), ENSURE_REQUIREMENTS, [plan_id=118547]"]; subgraph cluster50 { isCluster="true"; id="cluster50"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 51 [id="node51" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448], functions=[])"]; } 52 [id="node52" labelType="html" label="Exchange number of partitions: 37" tooltip="Exchange hashpartitioning(plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448, 37), ENSURE_REQUIREMENTS, [plan_id=118543]"]; subgraph cluster53 { isCluster="true"; id="cluster53"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 54 [id="node54" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#452)) AS qty#452, worklistShardItemId#446L, product#448], functions=[])"]; 55 [id="node55" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]"]; 56 [id="node56" labelType="html" label=" Filter " tooltip="Filter isNewlyCalculated#24690: boolean"]; } 57 [id="node57" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [isNewlyCalculated#24690, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L], [isNewlyCalculated#24690]"]; 58 [id="node58" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster59 { isCluster="true"; id="cluster59"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 60 [id="node60" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]"]; 61 [id="node61" 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#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti"]; } subgraph cluster62 { isCluster="true"; id="cluster62"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 63 [id="node63" 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"]; } 64 [id="node64" 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=117747]"]; 65 [id="node65" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]"]; 66 [id="node66" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster67 { isCluster="true"; id="cluster67"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 68 [id="node68" 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 cluster69 { isCluster="true"; id="cluster69"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 70 [id="node70" labelType="html" label=" Sort " tooltip="Sort [coalesce(shardId#24679, ) ASC NULLS FIRST, isnull(shardId#24679) ASC NULLS FIRST, coalesce(worklistShardItemId#24680L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#24680L) ASC NULLS FIRST, coalesce(version#24681, 0) ASC NULLS FIRST, isnull(version#24681) ASC NULLS FIRST, coalesce(product#24682, ) ASC NULLS FIRST, isnull(product#24682) ASC NULLS FIRST, coalesce(plant#24683, ) ASC NULLS FIRST, isnull(plant#24683) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))) ASC NULLS FIRST, isnull(qty#24454) ASC NULLS FIRST], false, 0"]; } 71 [id="node71" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454), 37), ENSURE_REQUIREMENTS, [plan_id=117776]"]; 72 [id="node72" labelType="html" label=" Union " tooltip="Union"]; 73 [id="node73" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]"]; subgraph cluster74 { isCluster="true"; id="cluster74"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 75 [id="node75" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 76 [id="node76" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster77 { isCluster="true"; id="cluster77"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 78 [id="node78" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 79 [id="node79" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 80 [id="node80" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 81 [id="node81" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 82 [id="node82" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster83 { isCluster="true"; id="cluster83"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 84 [id="node84" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 85 [id="node85" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster86 { isCluster="true"; id="cluster86"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 87 [id="node87" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 88 [id="node88" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 89 [id="node89" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster90 { isCluster="true"; id="cluster90"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 91 [id="node91" 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 cluster92 { isCluster="true"; id="cluster92"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 93 [id="node93" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 94 [id="node94" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster95 { isCluster="true"; id="cluster95"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 96 [id="node96" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 97 [id="node97" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 98 [id="node98" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster99 { isCluster="true"; id="cluster99"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 100 [id="node100" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 101 [id="node101" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster102 { isCluster="true"; id="cluster102"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 103 [id="node103" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 104 [id="node104" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 105 [id="node105" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } subgraph cluster106 { isCluster="true"; id="cluster106"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 107 [id="node107" labelType="html" label=" Project " tooltip="Project [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]"]; 108 [id="node108" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#24662L, shardId#24661], [cachedWorklistShardItemId#24676L, cachedShardId#24675], Inner"]; } subgraph cluster109 { isCluster="true"; id="cluster109"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 110 [id="node110" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#24662L ASC NULLS FIRST, shardId#24661 ASC NULLS FIRST], false, 0"]; } 111 [id="node111" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#24662L, shardId#24661, 37), ENSURE_REQUIREMENTS, [plan_id=117761]"]; subgraph cluster112 { isCluster="true"; id="cluster112"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 113 [id="node113" labelType="html" label=" Filter " tooltip="Filter ((isnull(qty#24668) AND isnotnull(worklistShardItemId#24662L)) AND isnotnull(shardId#24661))"]; } 114 [id="node114" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668], [isnull(qty#24668), isnotnull(worklistShardItemId#24662L), isnotnull(shardId#24661)]"]; 115 [id="node115" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster116 { isCluster="true"; id="cluster116"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 117 [id="node117" 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 cluster118 { isCluster="true"; id="cluster118"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 119 [id="node119" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#24676L ASC NULLS FIRST, cachedShardId#24675 ASC NULLS FIRST], false, 0"]; } 120 [id="node120" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24676L, cachedShardId#24675, 37), ENSURE_REQUIREMENTS, [plan_id=117767]"]; subgraph cluster121 { isCluster="true"; id="cluster121"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 122 [id="node122" labelType="html" label=" Project " tooltip="Project [shardId#24669 AS cachedShardId#24675, worklistShardItemId#24670L AS cachedWorklistShardItemId#24676L]"]; 123 [id="node123" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#24670L) AND isnotnull(shardId#24669))"]; 124 [id="node124" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#24669,worklistShardItemId#24670L,qty#24671,demandChannel#24672,demandStream#24673,kpis#24674]"]; } subgraph cluster125 { isCluster="true"; id="cluster125"; label="WholeStageCodegen (9)"; tooltip="WholeStageCodegen (9)"; 126 [id="node126" labelType="html" label=" Project " tooltip="Project [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721, false AS isNewlyCalculated#24691]"]; } 127 [id="node127" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]"]; subgraph cluster128 { isCluster="true"; id="cluster128"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 129 [id="node129" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 130 [id="node130" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster131 { isCluster="true"; id="cluster131"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 132 [id="node132" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 133 [id="node133" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 134 [id="node134" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 135 [id="node135" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 136 [id="node136" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster137 { isCluster="true"; id="cluster137"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 138 [id="node138" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 139 [id="node139" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster140 { isCluster="true"; id="cluster140"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 141 [id="node141" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 142 [id="node142" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 143 [id="node143" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster144 { isCluster="true"; id="cluster144"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 145 [id="node145" 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 cluster146 { isCluster="true"; id="cluster146"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 147 [id="node147" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 148 [id="node148" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster149 { isCluster="true"; id="cluster149"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 150 [id="node150" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 151 [id="node151" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 152 [id="node152" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster153 { isCluster="true"; id="cluster153"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 154 [id="node154" labelType="html" label=" Sort " tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 155 [id="node155" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster156 { isCluster="true"; id="cluster156"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 157 [id="node157" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 158 [id="node158" labelType="html" label=" Filter " tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 159 [id="node159" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } 1->0; 2->1; 4->2; 5->4; 6->5; 8->6; 9->8; 10->9; 12->10; 13->12; 14->13; 15->14; 16->15; 18->16; 19->18; 20->19; 21->20; 22->21; 23->14; 25->23; 26->25; 27->26; 28->27; 30->28; 31->30; 32->31; 33->32; 34->33; 35->14; 37->35; 38->37; 39->38; 40->39; 42->40; 43->42; 44->43; 45->44; 46->45; 48->10; 49->48; 51->49; 52->51; 54->52; 55->54; 56->55; 57->56; 58->57; 60->58; 61->60; 63->61; 64->63; 65->64; 66->65; 68->66; 70->61; 71->70; 72->71; 73->72; 75->73; 76->75; 78->76; 79->78; 80->79; 81->80; 82->81; 84->82; 85->84; 87->85; 88->87; 89->88; 91->89; 93->82; 94->93; 96->94; 97->96; 98->97; 100->76; 101->100; 103->101; 104->103; 105->104; 107->72; 108->107; 110->108; 111->110; 113->111; 114->113; 115->114; 117->115; 119->108; 120->119; 122->120; 123->122; 124->123; 126->58; 127->126; 129->127; 130->129; 132->130; 133->132; 134->133; 135->134; 136->135; 138->136; 139->138; 141->139; 142->141; 143->142; 145->143; 147->136; 148->147; 150->148; 151->150; 152->151; 154->130; 155->154; 157->155; 158->157; 159->158; }

Details

== Physical Plan ==
DeserializeToObject (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 [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]

(2) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292], StorageLevel(disk, memory, 2 replicas)

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

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

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

(6) SerializeFromObject [codegen id : 1]
Input [1]: [obj#27226]
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#27229, 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#27230]

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

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

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

(10) Project
Output [6]: [prodPlantResults#27237.productId AS product#27256, prodPlantResults#27237.plantId AS plant#27257, null AS qty#27283, null AS demandChannel#27263, null AS demandStream#27264, transform(prodPlantResults#27237.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27292]
Input [1]: [prodPlantResults#27237]

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

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

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

(14) Project [codegen id : 1]
Output [3]: [prodPlantResults#27282.productId AS _extract_productId#27428, prodPlantResults#27282.plantId AS _extract_plantId#27429, prodPlantResults#27282.quantityKpiResults AS _extract_quantityKpiResults#27430]
Input [1]: [prodPlantResults#27282]

(15) Generate [codegen id : 1]
Input [3]: [_extract_productId#27428, _extract_plantId#27429, _extract_quantityKpiResults#27430]
Arguments: explode(_extract_quantityKpiResults#27430), [_extract_productId#27428, _extract_plantId#27429], false, [quantityKpiResults#27249]

(16) Project
Output [6]: [_extract_productId#27428 AS product#27243, _extract_plantId#27429 AS plant#27244, quantityKpiResults#27249.quantity AS qty#27250, null AS demandChannel#27252, null AS demandStream#27253, transform(quantityKpiResults#27249.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27426]
Input [3]: [_extract_productId#27428, _extract_plantId#27429, quantityKpiResults#27249]

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

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

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

(20) Project [codegen id : 2]
Output [3]: [prodPlantResults#27287.productId AS _extract_productId#27431, prodPlantResults#27287.plantId AS _extract_plantId#27432, prodPlantResults#27287.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#27433]
Input [1]: [prodPlantResults#27287]

(21) Generate [codegen id : 2]
Input [3]: [_extract_productId#27431, _extract_plantId#27432, _extract_demandChannelStreamKpiResults#27433]
Arguments: explode(_extract_demandChannelStreamKpiResults#27433), [_extract_productId#27431, _extract_plantId#27432], false, [demandChannelStreamKpiResults#27271]

(22) Project
Output [6]: [_extract_productId#27431 AS product#27265, _extract_plantId#27432 AS plant#27266, null AS qty#27288, demandChannelStreamKpiResults#27271.demandChannel AS demandChannel#27273, demandChannelStreamKpiResults#27271.demandStream AS demandStream#27275, transform(demandChannelStreamKpiResults#27271.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27427]
Input [3]: [_extract_productId#27431, _extract_plantId#27432, demandChannelStreamKpiResults#27271]

(23) Union

(24) Exchange
Input [6]: [product#27256, plant#27257, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: hashpartitioning(coalesce(product#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257), 37), ENSURE_REQUIREMENTS, [plan_id=118533]

(25) Sort [codegen id : 3]
Input [6]: [product#27256, plant#27257, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: [coalesce(product#27256, ) ASC NULLS FIRST, isnull(product#27256) ASC NULLS FIRST, coalesce(plant#27257, ) ASC NULLS FIRST, isnull(plant#27257) ASC NULLS FIRST], false, 0

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

(27) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, demandChannel#24687, demandStream#24688, kpis#24722, isNewlyCalculated#24690], 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[1452] 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=117521]

(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=117747]

(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#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]
Arguments: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]

(35) InMemoryRelation
Arguments: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454, demandChannel#24447, demandStream#24448, kpis#24455], 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=117630]

(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#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439]
Arguments: [shardId#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439], MapPartitionsRDD[1474] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(42) Filter [codegen id : 3]
Input [6]: [shardId#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439]
Condition : (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))

(43) Project [codegen id : 3]
Output [3]: [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]
Input [6]: [shardId#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439]

(44) Exchange
Input [3]: [cachedShardId#24440, cachedWorklistShardItemId#24441L, cachedQty#24442]
Arguments: hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]

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

(46) SortMergeJoin [codegen id : 5]
Left keys [2]: [worklistShardItemId#446L, shardId#445]
Right keys [2]: [cachedWorklistShardItemId#24441L, cachedShardId#24440]
Join type: Inner
Join condition: ((qty#452 = cachedQty#24442) 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#24440, cachedWorklistShardItemId#24441L, cachedQty#24442]

(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#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449]
Arguments: [shardId#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449], MapPartitionsRDD[1474] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(52) Filter [codegen id : 6]
Input [6]: [shardId#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449]
Condition : (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))

(53) Project [codegen id : 6]
Output [6]: [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]
Input [6]: [shardId#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449]

(54) Exchange
Input [6]: [cachedShardId#24450, cachedWorklistShardItemId#24451L, cachedQty#24452, demandChannel#24447, demandStream#24448, cachedKpis#24453]
Arguments: hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]

(55) Sort [codegen id : 7]
Input [6]: [cachedShardId#24450, cachedWorklistShardItemId#24451L, cachedQty#24452, demandChannel#24447, demandStream#24448, cachedKpis#24453]
Arguments: [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0

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

(57) Project [codegen id : 8]
Output [9]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]
Input [11]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedShardId#24450, cachedWorklistShardItemId#24451L, cachedQty#24452, demandChannel#24447, demandStream#24448, cachedKpis#24453]

(58) InMemoryTableScan
Output [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Arguments: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668], [isnull(qty#24668), isnotnull(worklistShardItemId#24662L), isnotnull(shardId#24661)]

(59) InMemoryRelation
Arguments: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, periodStart#24666, periodEnd#24667, qty#24668], StorageLevel(disk, memory, 2 replicas)

(60) Filter [codegen id : 2]
Input [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Condition : ((isnull(qty#24668) AND isnotnull(worklistShardItemId#24662L)) AND isnotnull(shardId#24661))

(61) Exchange
Input [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Arguments: hashpartitioning(worklistShardItemId#24662L, shardId#24661, 37), ENSURE_REQUIREMENTS, [plan_id=117761]

(62) Sort [codegen id : 3]
Input [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Arguments: [worklistShardItemId#24662L ASC NULLS FIRST, shardId#24661 ASC NULLS FIRST], false, 0

(63) Scan ExistingRDD [codegen id : 4]
Output [6]: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674]
Arguments: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674], MapPartitionsRDD[1474] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(64) Filter [codegen id : 4]
Input [6]: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674]
Condition : (isnotnull(worklistShardItemId#24670L) AND isnotnull(shardId#24669))

(65) Project [codegen id : 4]
Output [2]: [shardId#24669 AS cachedShardId#24675, worklistShardItemId#24670L AS cachedWorklistShardItemId#24676L]
Input [6]: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674]

(66) Exchange
Input [2]: [cachedShardId#24675, cachedWorklistShardItemId#24676L]
Arguments: hashpartitioning(cachedWorklistShardItemId#24676L, cachedShardId#24675, 37), ENSURE_REQUIREMENTS, [plan_id=117767]

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

(68) SortMergeJoin [codegen id : 6]
Left keys [2]: [worklistShardItemId#24662L, shardId#24661]
Right keys [2]: [cachedWorklistShardItemId#24676L, cachedShardId#24675]
Join type: Inner
Join condition: None

(69) Project [codegen id : 6]
Output [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Input [8]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668, cachedShardId#24675, cachedWorklistShardItemId#24676L]

(70) Union

(71) Exchange
Input [6]: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]
Arguments: hashpartitioning(coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454), 37), ENSURE_REQUIREMENTS, [plan_id=117776]

(72) Sort [codegen id : 7]
Input [6]: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]
Arguments: [coalesce(shardId#24679, ) ASC NULLS FIRST, isnull(shardId#24679) ASC NULLS FIRST, coalesce(worklistShardItemId#24680L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#24680L) ASC NULLS FIRST, coalesce(version#24681, 0) ASC NULLS FIRST, isnull(version#24681) ASC NULLS FIRST, coalesce(product#24682, ) ASC NULLS FIRST, isnull(product#24682) ASC NULLS FIRST, coalesce(plant#24683, ) ASC NULLS FIRST, isnull(plant#24683) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))) ASC NULLS FIRST, isnull(qty#24454) 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#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)]
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#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]

(75) InMemoryTableScan
Output [9]: [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]
Arguments: [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]

(76) InMemoryRelation
Arguments: [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721], StorageLevel(disk, memory, 2 replicas)

(77) Project [codegen id : 9]
Output [10]: [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721, false AS isNewlyCalculated#24691]
Input [9]: [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]

(78) Union

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

(80) Project [codegen id : 4]
Output [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Input [6]: [isNewlyCalculated#24690, 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=118543]

(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=118547]

(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#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257)]
Right keys [4]: [coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449)]
Join type: Inner
Join condition: ((qty#27283 <=> qty#452) OR isnull(qty#452))

(87) Project [codegen id : 7]
Output [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Input [11]: [product#27256, plant#27257, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292, shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]

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

(89) SortAggregate
Input [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Keys [5]: [demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264]
Functions [1]: [partial_first(kpis#27292, false)]
Aggregate Attributes [2]: [first#27499, valueSet#27500]
Results [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]

(90) Exchange
Input [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]
Arguments: hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]

(91) Sort [codegen id : 8]
Input [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]
Arguments: [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0

(92) SortAggregate
Input [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]
Keys [5]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264]
Functions [1]: [first(kpis#27292, false)]
Aggregate Attributes [1]: [first(kpis#27292)()#27424]
Results [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, first(kpis#27292)()#27424 AS kpis#27425]

(93) DeserializeToObject
Input [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: createexternalrow(invoke(shardId#445.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#446L)), static_invoke(java.lang.Double.valueOf(qty#27283)), invoke(demandChannel#27263.toString()), invoke(demandStream#27264.toString()), mapobjects(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1), createexternalrow(invoke(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).label.toString()), static_invoke(DateTimeUtils.toJavaTimestamp(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).dateTime)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).value)), StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true)), kpis#27292, Some(class scala.collection.mutable.ArraySeq)), StructField(shardId,StringType,true), StructField(worklistShardItemId,LongType,true), StructField(qty,DoubleType,true), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpis,ArrayType(StructType(StructField(label,StringType,true),StructField(dateTime,TimestampType,true),StructField(value,DoubleType,true)),false),true)), obj#27612: org.apache.spark.sql.Row

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	2
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
temporal.activity.id	bcc6d1d6-5234-362e-a110-b40301899480
temporal.activity.type	RunStreamWithId