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

Submitted Time: 2026/03/21 01:08:36
Duration: 0.8 s
Succeeded Jobs: 6344

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#1100457.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#1100458L)), static_invoke(java.lang.Double.valueOf(qty#1114539)), invoke(demandChannel#1114519.toString()), invoke(demandStream#1114520.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#1114548, 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#1114868: org.apache.spark.sql.Row"]; 1 [id="node1" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548]"]; 2 [id="node2" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[first(kpis#1114548, false)])"]; subgraph cluster3 { isCluster="true"; id="cluster3"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 4 [id="node4" labelType="html" label=" Sort " tooltip="Sort [demandChannel#1114519 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1114539 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1114520 ASC NULLS FIRST], false, 0"]; } 5 [id="node5" labelType="html" label="Exchange number of partitions: 37" tooltip="Exchange hashpartitioning(demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, 37), ENSURE_REQUIREMENTS, [plan_id=1751587]"]; 6 [id="node6" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#1114519, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1114539)) AS qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[partial_first(kpis#1114548, false)])"]; subgraph cluster7 { isCluster="true"; id="cluster7"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 8 [id="node8" labelType="html" label=" Sort " tooltip="Sort [demandChannel#1114519 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#1114539)) AS qty#1114539 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1114520 ASC NULLS FIRST], false, 0"]; 9 [id="node9" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548]"]; 10 [id="node10" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [coalesce(product#1114512, ), isnull(product#1114512), coalesce(plant#1114513, ), isnull(plant#1114513)], [coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461)], Inner, BuildRight, ((qty#1114539 <=> qty#1100464) OR isnull(qty#1100464)), false"]; } 11 [id="node11" labelType="html" label=" Union " tooltip="Union"]; 12 [id="node12" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1114493.productId AS product#1114512, prodPlantResults#1114493.plantId AS plant#1114513, null AS qty#1114539, null AS demandChannel#1114519, null AS demandStream#1114520, transform(prodPlantResults#1114493.kpiResults, lambdafunction(struct(label, lambda kpi#1114549.label, dateTime, lambda kpi#1114549.datetime, value, lambda kpi#1114549.value), lambda kpi#1114549, false)) AS kpis#1114548]"]; 13 [id="node13" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#1114493]"]; subgraph cluster14 { isCluster="true"; id="cluster14"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 15 [id="node15" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1114486), false, [prodPlantResults#1114493]"]; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1114486]"]; 17 [id="node17" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1114486, true) > 0) AND isnotnull(prodPlantResults#1114486))"]; 18 [id="node18" 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#1114485, 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#1114486]"]; } 19 [id="node19" labelType="html" label=" Scan " tooltip="Scan[obj#1114482]"]; 20 [id="node20" labelType="html" label=" Project " tooltip="Project [_extract_productId#1114684 AS product#1114499, _extract_plantId#1114685 AS plant#1114500, quantityKpiResults#1114505.quantity AS qty#1114506, null AS demandChannel#1114508, null AS demandStream#1114509, transform(quantityKpiResults#1114505.kpiResults, lambdafunction(struct(label, lambda kpi#1114549.label, dateTime, lambda kpi#1114549.datetime, value, lambda kpi#1114549.value), lambda kpi#1114549, false)) AS kpis#1114682]"]; subgraph cluster21 { isCluster="true"; id="cluster21"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 22 [id="node22" labelType="html" label=" Generate " tooltip="Generate explode(_extract_quantityKpiResults#1114686), [_extract_productId#1114684, _extract_plantId#1114685], false, [quantityKpiResults#1114505]"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1114538.productId AS _extract_productId#1114684, prodPlantResults#1114538.plantId AS _extract_plantId#1114685, prodPlantResults#1114538.quantityKpiResults AS _extract_quantityKpiResults#1114686]"]; 24 [id="node24" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1114538.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#1114538.quantityKpiResults))"]; } 25 [id="node25" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#1114538], [(size(prodPlantResults#1114538.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#1114538.quantityKpiResults)]"]; subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 27 [id="node27" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1114486), false, [prodPlantResults#1114493]"]; 28 [id="node28" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1114486]"]; 29 [id="node29" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1114486, true) > 0) AND isnotnull(prodPlantResults#1114486))"]; 30 [id="node30" 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#1114485, 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#1114486]"]; } 31 [id="node31" labelType="html" label=" Scan " tooltip="Scan[obj#1114482]"]; 32 [id="node32" labelType="html" label=" Project " tooltip="Project [_extract_productId#1114687 AS product#1114521, _extract_plantId#1114688 AS plant#1114522, null AS qty#1114544, demandChannelStreamKpiResults#1114527.demandChannel AS demandChannel#1114529, demandChannelStreamKpiResults#1114527.demandStream AS demandStream#1114531, transform(demandChannelStreamKpiResults#1114527.kpiResults, lambdafunction(struct(label, lambda kpi#1114549.label, dateTime, lambda kpi#1114549.datetime, value, lambda kpi#1114549.value), lambda kpi#1114549, false)) AS kpis#1114683]"]; subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 34 [id="node34" labelType="html" label=" Generate " tooltip="Generate explode(_extract_demandChannelStreamKpiResults#1114689), [_extract_productId#1114687, _extract_plantId#1114688], false, [demandChannelStreamKpiResults#1114527]"]; 35 [id="node35" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1114543.productId AS _extract_productId#1114687, prodPlantResults#1114543.plantId AS _extract_plantId#1114688, prodPlantResults#1114543.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1114689]"]; 36 [id="node36" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1114543.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#1114543.demandChannelStreamKpiResults))"]; } 37 [id="node37" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#1114543], [(size(prodPlantResults#1114543.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#1114543.demandChannelStreamKpiResults)]"]; subgraph cluster38 { isCluster="true"; id="cluster38"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 39 [id="node39" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1114486), false, [prodPlantResults#1114493]"]; 40 [id="node40" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1114486]"]; 41 [id="node41" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1114486, true) > 0) AND isnotnull(prodPlantResults#1114486))"]; 42 [id="node42" 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#1114485, 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#1114486]"]; } 43 [id="node43" labelType="html" label=" Scan " tooltip="Scan[obj#1114482]"]; 44 [id="node44" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 2 ms time to collect: 686 ms number of output rows: 990 data size: 2.0 MiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, string, true], ), isnull(input[3, string, true])),false), [plan_id=1751580]"]; subgraph cluster45 { isCluster="true"; id="cluster45"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n220 ms (2 ms, 4 ms, 15 ms (stage 115462.0: task 381802))"; tooltip="WholeStageCodegen (4)"; 46 [id="node46" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 102 ms (1 ms, 2 ms, 5 ms (stage 115462.0: task 381802)) peak memory total (min, med, max (stageId: taskId)) 83.3 MiB (2.3 MiB, 2.3 MiB, 2.3 MiB (stage 115462.0: task 381809)) number of output rows: 990 number of sort fallback tasks: 0 avg hash probes per key (min, med, max (stageId: taskId)): (1, 1, 1 (stage 115462.0: task 381809))" tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 47 [id="node47" labelType="html" label="Exchange shuffle records written: 990 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 990 local bytes read total (min, med, max (stageId: taskId)) 58.5 KiB (752.0 B, 1656.0 B, 2.7 KiB (stage 115462.0: task 381813)) merged fetch fallback count: 0 local blocks read: 292 remote merged chunks fetched: 0 remote blocks read: 422 data size total (min, med, max (stageId: taskId)) 123.8 KiB (2.0 KiB, 3.4 KiB, 4.5 KiB (stage 115461.0: task 381740)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 49 ms (0 ms, 1 ms, 1 ms (stage 115461.0: task 381735)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time total (min, med, max (stageId: taskId)) 9 ms (0 ms, 0 ms, 2 ms (stage 115462.0: task 381833)) remote bytes read total (min, med, max (stageId: taskId)) 85.5 KiB (1398.0 B, 2.2 KiB, 3.3 KiB (stage 115462.0: task 381809)) number of partitions: 37 remote reqs duration total (min, med, max (stageId: taskId)) 164 ms (1 ms, 4 ms, 8 ms (stage 115462.0: task 381802)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 144.1 KiB (2.5 KiB, 3.9 KiB, 5.1 KiB (stage 115461.0: task 381740))" tooltip="Exchange hashpartitioning(plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1751576]"]; subgraph cluster48 { isCluster="true"; id="cluster48"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n1.5 s (0 ms, 2 ms, 165 ms (stage 115461.0: task 381731))"; tooltip="WholeStageCodegen (3)"; 49 [id="node49" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 47 ms (0 ms, 0 ms, 6 ms (stage 115461.0: task 381734)) peak memory total (min, med, max (stageId: taskId)) 92.5 MiB (256.0 KiB, 2.3 MiB, 2.3 MiB (stage 115461.0: task 381730)) number of output rows: 990 number of sort fallback tasks: 0 avg hash probes per key (min, med, max (stageId: taskId)): (1, 1, 1 (stage 115461.0: task 381730))" tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1100464)) AS qty#1100464, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 50 [id="node50" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]"]; 51 [id="node51" labelType="html" label="Filter number of output rows: 990" tooltip="Filter isNewlyCalculated#1111818: boolean"]; } 52 [id="node52" labelType="html" label="InMemoryTableScan number of output rows: 990" tooltip="InMemoryTableScan [isNewlyCalculated#1111818, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [isNewlyCalculated#1111818]"]; 53 [id="node53" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster54 { isCluster="true"; id="cluster54"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 55 [id="node55" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1111815, null AS demandStream#1111816, [] AS kpis#1111850, true AS isNewlyCalculated#1111818]"]; 56 [id="node56" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1111807, ), isnull(shardId#1111807), coalesce(worklistShardItemId#1111808L, 0), isnull(worklistShardItemId#1111808L), coalesce(version#1111809, 0), isnull(version#1111809), coalesce(product#1111810, ), isnull(product#1111810), coalesce(plant#1111811, ), isnull(plant#1111811), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1111582, 0.0))), isnull(qty#1111582)], LeftAnti"]; } subgraph cluster57 { isCluster="true"; id="cluster57"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 58 [id="node58" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1100457, ) ASC NULLS FIRST, isnull(shardId#1100457) ASC NULLS FIRST, coalesce(worklistShardItemId#1100458L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1100458L) ASC NULLS FIRST, coalesce(version#1100459, 0) ASC NULLS FIRST, isnull(version#1100459) ASC NULLS FIRST, coalesce(product#1100460, ) ASC NULLS FIRST, isnull(product#1100460) ASC NULLS FIRST, coalesce(plant#1100461, ) ASC NULLS FIRST, isnull(plant#1100461) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))) ASC NULLS FIRST, isnull(qty#1100464) ASC NULLS FIRST], false, 0"]; } 59 [id="node59" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464), 37), ENSURE_REQUIREMENTS, [plan_id=1750707]"]; 60 [id="node60" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]"]; 61 [id="node61" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1750477]"]; subgraph cluster62 { isCluster="true"; id="cluster62"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 63 [id="node63" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster64 { isCluster="true"; id="cluster64"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 65 [id="node65" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1111807, ) ASC NULLS FIRST, isnull(shardId#1111807) ASC NULLS FIRST, coalesce(worklistShardItemId#1111808L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1111808L) ASC NULLS FIRST, coalesce(version#1111809, 0) ASC NULLS FIRST, isnull(version#1111809) ASC NULLS FIRST, coalesce(product#1111810, ) ASC NULLS FIRST, isnull(product#1111810) ASC NULLS FIRST, coalesce(plant#1111811, ) ASC NULLS FIRST, isnull(plant#1111811) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1111582, 0.0))) ASC NULLS FIRST, isnull(qty#1111582) ASC NULLS FIRST], false, 0"]; } 66 [id="node66" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#1111807, ), isnull(shardId#1111807), coalesce(worklistShardItemId#1111808L, 0), isnull(worklistShardItemId#1111808L), coalesce(version#1111809, 0), isnull(version#1111809), coalesce(product#1111810, ), isnull(product#1111810), coalesce(plant#1111811, ), isnull(plant#1111811), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1111582, 0.0))), isnull(qty#1111582), 37), ENSURE_REQUIREMENTS, [plan_id=1750727]"]; 67 [id="node67" labelType="html" label=" Union " tooltip="Union"]; 68 [id="node68" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1111807, worklistShardItemId#1111808L, version#1111809, product#1111810, plant#1111811, qty#1111582]"]; subgraph cluster69 { isCluster="true"; id="cluster69"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 70 [id="node70" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1111580 AS qty#1111582, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581 AS kpis#1111583]"]; 71 [id="node71" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1111579L, cachedShardId#1111578], Inner"]; } subgraph cluster72 { isCluster="true"; id="cluster72"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 73 [id="node73" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 74 [id="node74" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1750595]"]; subgraph cluster75 { isCluster="true"; id="cluster75"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 76 [id="node76" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 77 [id="node77" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1750591]"]; subgraph cluster78 { isCluster="true"; id="cluster78"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 79 [id="node79" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 80 [id="node80" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 81 [id="node81" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1111569L, cachedShardId#1111568], Inner, BuildLeft, ((qty#1100464 = cachedQty#1111570) OR isnull(qty#1100464)), false"]; 89 [id="node89" labelType="html" label=" Project " tooltip="Project [shardId#1111562 AS cachedShardId#1111568, worklistShardItemId#1111563L AS cachedWorklistShardItemId#1111569L, qty#1111564 AS cachedQty#1111570]"]; 90 [id="node90" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1111563L) AND isnotnull(shardId#1111562))"]; 91 [id="node91" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1111562,worklistShardItemId#1111563L,qty#1111564,demandChannel#1111565,demandStream#1111566,kpis#1111567]"]; } 82 [id="node82" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1750585]"]; subgraph cluster83 { isCluster="true"; id="cluster83"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 84 [id="node84" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 85 [id="node85" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 86 [id="node86" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1750477]"]; subgraph cluster87 { isCluster="true"; id="cluster87"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 88 [id="node88" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster92 { isCluster="true"; id="cluster92"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 93 [id="node93" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1111579L ASC NULLS FIRST, cachedShardId#1111578 ASC NULLS FIRST], false, 0"]; } 94 [id="node94" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#1111579L, cachedShardId#1111578, 37), ENSURE_REQUIREMENTS, [plan_id=1750601]"]; subgraph cluster95 { isCluster="true"; id="cluster95"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 96 [id="node96" labelType="html" label=" Project " tooltip="Project [shardId#1111572 AS cachedShardId#1111578, worklistShardItemId#1111573L AS cachedWorklistShardItemId#1111579L, qty#1111574 AS cachedQty#1111580, demandChannel#1111575, demandStream#1111576, kpis#1111577 AS cachedKpis#1111581]"]; 97 [id="node97" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1111573L) AND isnotnull(shardId#1111572))"]; 98 [id="node98" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1111572,worklistShardItemId#1111573L,qty#1111574,demandChannel#1111575,demandStream#1111576,kpis#1111577]"]; } subgraph cluster99 { isCluster="true"; id="cluster99"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 100 [id="node100" labelType="html" label=" Project " tooltip="Project [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796]"]; 101 [id="node101" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1111790L, shardId#1111789], [cachedWorklistShardItemId#1111804L, cachedShardId#1111803], Inner, BuildLeft, false"]; 109 [id="node109" labelType="html" label=" Project " tooltip="Project [shardId#1111797 AS cachedShardId#1111803, worklistShardItemId#1111798L AS cachedWorklistShardItemId#1111804L]"]; 110 [id="node110" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1111798L) AND isnotnull(shardId#1111797))"]; 111 [id="node111" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1111797,worklistShardItemId#1111798L,qty#1111799,demandChannel#1111800,demandStream#1111801,kpis#1111802]"]; } 102 [id="node102" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1750721]"]; subgraph cluster103 { isCluster="true"; id="cluster103"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 104 [id="node104" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#1111796) AND isnotnull(worklistShardItemId#1111790L)) AND isnotnull(shardId#1111789))"]; } 105 [id="node105" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796], [isnull(qty#1111796), isnotnull(worklistShardItemId#1111790L), isnotnull(shardId#1111789)]"]; 106 [id="node106" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1750477]"]; subgraph cluster107 { isCluster="true"; id="cluster107"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 108 [id="node108" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster112 { isCluster="true"; id="cluster112"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 113 [id="node113" labelType="html" label=" Project " tooltip="Project [shardId#1111820, worklistShardItemId#1111821L, version#1111822, product#1111823, plant#1111824, qty#1111848, demandChannel#1111841, demandStream#1111842, kpis#1111849, false AS isNewlyCalculated#1111819]"]; } 114 [id="node114" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1111841, demandStream#1111842, kpis#1111849, plant#1111824, product#1111823, qty#1111848, shardId#1111820, version#1111822, worklistShardItemId#1111821L]"]; subgraph cluster115 { isCluster="true"; id="cluster115"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 116 [id="node116" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1111580 AS qty#1111582, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581 AS kpis#1111583]"]; 117 [id="node117" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1111579L, cachedShardId#1111578], Inner"]; } subgraph cluster118 { isCluster="true"; id="cluster118"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 119 [id="node119" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 120 [id="node120" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1750595]"]; subgraph cluster121 { isCluster="true"; id="cluster121"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 122 [id="node122" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 123 [id="node123" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1750591]"]; subgraph cluster124 { isCluster="true"; id="cluster124"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 125 [id="node125" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 126 [id="node126" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 127 [id="node127" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1111569L, cachedShardId#1111568], Inner, BuildLeft, ((qty#1100464 = cachedQty#1111570) OR isnull(qty#1100464)), false"]; 135 [id="node135" labelType="html" label=" Project " tooltip="Project [shardId#1111562 AS cachedShardId#1111568, worklistShardItemId#1111563L AS cachedWorklistShardItemId#1111569L, qty#1111564 AS cachedQty#1111570]"]; 136 [id="node136" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1111563L) AND isnotnull(shardId#1111562))"]; 137 [id="node137" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1111562,worklistShardItemId#1111563L,qty#1111564,demandChannel#1111565,demandStream#1111566,kpis#1111567]"]; } 128 [id="node128" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1750585]"]; subgraph cluster129 { isCluster="true"; id="cluster129"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 130 [id="node130" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 131 [id="node131" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 132 [id="node132" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1750477]"]; subgraph cluster133 { isCluster="true"; id="cluster133"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 134 [id="node134" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster138 { isCluster="true"; id="cluster138"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 139 [id="node139" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1111579L ASC NULLS FIRST, cachedShardId#1111578 ASC NULLS FIRST], false, 0"]; } 140 [id="node140" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#1111579L, cachedShardId#1111578, 37), ENSURE_REQUIREMENTS, [plan_id=1750601]"]; subgraph cluster141 { isCluster="true"; id="cluster141"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 142 [id="node142" labelType="html" label=" Project " tooltip="Project [shardId#1111572 AS cachedShardId#1111578, worklistShardItemId#1111573L AS cachedWorklistShardItemId#1111579L, qty#1111574 AS cachedQty#1111580, demandChannel#1111575, demandStream#1111576, kpis#1111577 AS cachedKpis#1111581]"]; 143 [id="node143" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1111573L) AND isnotnull(shardId#1111572))"]; 144 [id="node144" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1111572,worklistShardItemId#1111573L,qty#1111574,demandChannel#1111575,demandStream#1111576,kpis#1111577]"]; } 1->0; 2->1; 4->2; 5->4; 6->5; 8->6; 9->8; 10->9; 11->10; 12->11; 13->12; 15->13; 16->15; 17->16; 18->17; 19->18; 20->11; 22->20; 23->22; 24->23; 25->24; 27->25; 28->27; 29->28; 30->29; 31->30; 32->11; 34->32; 35->34; 36->35; 37->36; 39->37; 40->39; 41->40; 42->41; 43->42; 44->10; 46->44; 47->46; 49->47; 50->49; 51->50; 52->51; 53->52; 55->53; 56->55; 58->56; 59->58; 60->59; 61->60; 63->61; 65->56; 66->65; 67->66; 68->67; 70->68; 71->70; 73->71; 74->73; 76->74; 77->76; 79->77; 80->79; 81->80; 82->81; 84->82; 85->84; 86->85; 88->86; 89->81; 90->89; 91->90; 93->71; 94->93; 96->94; 97->96; 98->97; 100->67; 101->100; 102->101; 104->102; 105->104; 106->105; 108->106; 109->101; 110->109; 111->110; 113->53; 114->113; 116->114; 117->116; 119->117; 120->119; 122->120; 123->122; 125->123; 126->125; 127->126; 128->127; 130->128; 131->130; 132->131; 134->132; 135->127; 136->135; 137->136; 139->117; 140->139; 142->140; 143->142; 144->143; }

Details

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


(1) InMemoryTableScan
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548]

(2) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548], StorageLevel(disk, memory, 2 replicas)

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

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

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

(6) SerializeFromObject [codegen id : 1]
Input [1]: [obj#1114482]
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#1114485, 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#1114486]

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

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

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

(10) Project
Output [6]: [prodPlantResults#1114493.productId AS product#1114512, prodPlantResults#1114493.plantId AS plant#1114513, null AS qty#1114539, null AS demandChannel#1114519, null AS demandStream#1114520, transform(prodPlantResults#1114493.kpiResults, lambdafunction(struct(label, lambda kpi#1114549.label, dateTime, lambda kpi#1114549.datetime, value, lambda kpi#1114549.value), lambda kpi#1114549, false)) AS kpis#1114548]
Input [1]: [prodPlantResults#1114493]

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

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

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

(14) Project [codegen id : 1]
Output [3]: [prodPlantResults#1114538.productId AS _extract_productId#1114684, prodPlantResults#1114538.plantId AS _extract_plantId#1114685, prodPlantResults#1114538.quantityKpiResults AS _extract_quantityKpiResults#1114686]
Input [1]: [prodPlantResults#1114538]

(15) Generate [codegen id : 1]
Input [3]: [_extract_productId#1114684, _extract_plantId#1114685, _extract_quantityKpiResults#1114686]
Arguments: explode(_extract_quantityKpiResults#1114686), [_extract_productId#1114684, _extract_plantId#1114685], false, [quantityKpiResults#1114505]

(16) Project
Output [6]: [_extract_productId#1114684 AS product#1114499, _extract_plantId#1114685 AS plant#1114500, quantityKpiResults#1114505.quantity AS qty#1114506, null AS demandChannel#1114508, null AS demandStream#1114509, transform(quantityKpiResults#1114505.kpiResults, lambdafunction(struct(label, lambda kpi#1114549.label, dateTime, lambda kpi#1114549.datetime, value, lambda kpi#1114549.value), lambda kpi#1114549, false)) AS kpis#1114682]
Input [3]: [_extract_productId#1114684, _extract_plantId#1114685, quantityKpiResults#1114505]

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

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

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

(20) Project [codegen id : 2]
Output [3]: [prodPlantResults#1114543.productId AS _extract_productId#1114687, prodPlantResults#1114543.plantId AS _extract_plantId#1114688, prodPlantResults#1114543.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1114689]
Input [1]: [prodPlantResults#1114543]

(21) Generate [codegen id : 2]
Input [3]: [_extract_productId#1114687, _extract_plantId#1114688, _extract_demandChannelStreamKpiResults#1114689]
Arguments: explode(_extract_demandChannelStreamKpiResults#1114689), [_extract_productId#1114687, _extract_plantId#1114688], false, [demandChannelStreamKpiResults#1114527]

(22) Project
Output [6]: [_extract_productId#1114687 AS product#1114521, _extract_plantId#1114688 AS plant#1114522, null AS qty#1114544, demandChannelStreamKpiResults#1114527.demandChannel AS demandChannel#1114529, demandChannelStreamKpiResults#1114527.demandStream AS demandStream#1114531, transform(demandChannelStreamKpiResults#1114527.kpiResults, lambdafunction(struct(label, lambda kpi#1114549.label, dateTime, lambda kpi#1114549.datetime, value, lambda kpi#1114549.value), lambda kpi#1114549, false)) AS kpis#1114683]
Input [3]: [_extract_productId#1114687, _extract_plantId#1114688, demandChannelStreamKpiResults#1114527]

(23) Union

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

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

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

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

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

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

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

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

(32) InMemoryTableScan
Output [6]: [shardId#1111807, worklistShardItemId#1111808L, version#1111809, product#1111810, plant#1111811, qty#1111582]
Arguments: [shardId#1111807, worklistShardItemId#1111808L, version#1111809, product#1111810, plant#1111811, qty#1111582]

(33) InMemoryRelation
Arguments: [shardId#1111807, worklistShardItemId#1111808L, version#1111809, product#1111810, plant#1111811, qty#1111582, demandChannel#1111575, demandStream#1111576, kpis#1111583], StorageLevel(disk, memory, 2 replicas)

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

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

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

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

(38) Scan ExistingRDD
Output [6]: [shardId#1111562, worklistShardItemId#1111563L, qty#1111564, demandChannel#1111565, demandStream#1111566, kpis#1111567]
Arguments: [shardId#1111562, worklistShardItemId#1111563L, qty#1111564, demandChannel#1111565, demandStream#1111566, kpis#1111567], MapPartitionsRDD[55371] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(39) Filter
Input [6]: [shardId#1111562, worklistShardItemId#1111563L, qty#1111564, demandChannel#1111565, demandStream#1111566, kpis#1111567]
Condition : (isnotnull(worklistShardItemId#1111563L) AND isnotnull(shardId#1111562))

(40) Project
Output [3]: [shardId#1111562 AS cachedShardId#1111568, worklistShardItemId#1111563L AS cachedWorklistShardItemId#1111569L, qty#1111564 AS cachedQty#1111570]
Input [6]: [shardId#1111562, worklistShardItemId#1111563L, qty#1111564, demandChannel#1111565, demandStream#1111566, kpis#1111567]

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

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

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

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

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

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

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

(48) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#1111572, worklistShardItemId#1111573L, qty#1111574, demandChannel#1111575, demandStream#1111576, kpis#1111577]
Arguments: [shardId#1111572, worklistShardItemId#1111573L, qty#1111574, demandChannel#1111575, demandStream#1111576, kpis#1111577], MapPartitionsRDD[55371] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(49) Filter [codegen id : 5]
Input [6]: [shardId#1111572, worklistShardItemId#1111573L, qty#1111574, demandChannel#1111575, demandStream#1111576, kpis#1111577]
Condition : (isnotnull(worklistShardItemId#1111573L) AND isnotnull(shardId#1111572))

(50) Project [codegen id : 5]
Output [6]: [shardId#1111572 AS cachedShardId#1111578, worklistShardItemId#1111573L AS cachedWorklistShardItemId#1111579L, qty#1111574 AS cachedQty#1111580, demandChannel#1111575, demandStream#1111576, kpis#1111577 AS cachedKpis#1111581]
Input [6]: [shardId#1111572, worklistShardItemId#1111573L, qty#1111574, demandChannel#1111575, demandStream#1111576, kpis#1111577]

(51) Exchange
Input [6]: [cachedShardId#1111578, cachedWorklistShardItemId#1111579L, cachedQty#1111580, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581]
Arguments: hashpartitioning(cachedWorklistShardItemId#1111579L, cachedShardId#1111578, 37), ENSURE_REQUIREMENTS, [plan_id=1750601]

(52) Sort [codegen id : 6]
Input [6]: [cachedShardId#1111578, cachedWorklistShardItemId#1111579L, cachedQty#1111580, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581]
Arguments: [cachedWorklistShardItemId#1111579L ASC NULLS FIRST, cachedShardId#1111578 ASC NULLS FIRST], false, 0

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

(54) Project [codegen id : 7]
Output [9]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1111580 AS qty#1111582, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581 AS kpis#1111583]
Input [11]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedShardId#1111578, cachedWorklistShardItemId#1111579L, cachedQty#1111580, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581]

(55) InMemoryTableScan
Output [6]: [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796]
Arguments: [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796], [isnull(qty#1111796), isnotnull(worklistShardItemId#1111790L), isnotnull(shardId#1111789)]

(56) InMemoryRelation
Arguments: [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, periodStart#1111794, periodEnd#1111795, qty#1111796], StorageLevel(disk, memory, 2 replicas)

(57) Filter [codegen id : 2]
Input [6]: [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796]
Condition : ((isnull(qty#1111796) AND isnotnull(worklistShardItemId#1111790L)) AND isnotnull(shardId#1111789))

(58) BroadcastExchange
Input [6]: [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1750721]

(59) Scan ExistingRDD
Output [6]: [shardId#1111797, worklistShardItemId#1111798L, qty#1111799, demandChannel#1111800, demandStream#1111801, kpis#1111802]
Arguments: [shardId#1111797, worklistShardItemId#1111798L, qty#1111799, demandChannel#1111800, demandStream#1111801, kpis#1111802], MapPartitionsRDD[55371] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(60) Filter
Input [6]: [shardId#1111797, worklistShardItemId#1111798L, qty#1111799, demandChannel#1111800, demandStream#1111801, kpis#1111802]
Condition : (isnotnull(worklistShardItemId#1111798L) AND isnotnull(shardId#1111797))

(61) Project
Output [2]: [shardId#1111797 AS cachedShardId#1111803, worklistShardItemId#1111798L AS cachedWorklistShardItemId#1111804L]
Input [6]: [shardId#1111797, worklistShardItemId#1111798L, qty#1111799, demandChannel#1111800, demandStream#1111801, kpis#1111802]

(62) BroadcastHashJoin [codegen id : 3]
Left keys [2]: [worklistShardItemId#1111790L, shardId#1111789]
Right keys [2]: [cachedWorklistShardItemId#1111804L, cachedShardId#1111803]
Join type: Inner
Join condition: None

(63) Project [codegen id : 3]
Output [6]: [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796]
Input [8]: [shardId#1111789, worklistShardItemId#1111790L, version#1111791, product#1111792, plant#1111793, qty#1111796, cachedShardId#1111803, cachedWorklistShardItemId#1111804L]

(64) Union

(65) Exchange
Input [6]: [shardId#1111807, worklistShardItemId#1111808L, version#1111809, product#1111810, plant#1111811, qty#1111582]
Arguments: hashpartitioning(coalesce(shardId#1111807, ), isnull(shardId#1111807), coalesce(worklistShardItemId#1111808L, 0), isnull(worklistShardItemId#1111808L), coalesce(version#1111809, 0), isnull(version#1111809), coalesce(product#1111810, ), isnull(product#1111810), coalesce(plant#1111811, ), isnull(plant#1111811), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1111582, 0.0))), isnull(qty#1111582), 37), ENSURE_REQUIREMENTS, [plan_id=1750727]

(66) Sort [codegen id : 4]
Input [6]: [shardId#1111807, worklistShardItemId#1111808L, version#1111809, product#1111810, plant#1111811, qty#1111582]
Arguments: [coalesce(shardId#1111807, ) ASC NULLS FIRST, isnull(shardId#1111807) ASC NULLS FIRST, coalesce(worklistShardItemId#1111808L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1111808L) ASC NULLS FIRST, coalesce(version#1111809, 0) ASC NULLS FIRST, isnull(version#1111809) ASC NULLS FIRST, coalesce(product#1111810, ) ASC NULLS FIRST, isnull(product#1111810) ASC NULLS FIRST, coalesce(plant#1111811, ) ASC NULLS FIRST, isnull(plant#1111811) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1111582, 0.0))) ASC NULLS FIRST, isnull(qty#1111582) ASC NULLS FIRST], false, 0

(67) SortMergeJoin [codegen id : 5]
Left keys [12]: [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)]
Right keys [12]: [coalesce(shardId#1111807, ), isnull(shardId#1111807), coalesce(worklistShardItemId#1111808L, 0), isnull(worklistShardItemId#1111808L), coalesce(version#1111809, 0), isnull(version#1111809), coalesce(product#1111810, ), isnull(product#1111810), coalesce(plant#1111811, ), isnull(plant#1111811), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1111582, 0.0))), isnull(qty#1111582)]
Join type: LeftAnti
Join condition: None

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

(69) InMemoryTableScan
Output [9]: [demandChannel#1111841, demandStream#1111842, kpis#1111849, plant#1111824, product#1111823, qty#1111848, shardId#1111820, version#1111822, worklistShardItemId#1111821L]
Arguments: [demandChannel#1111841, demandStream#1111842, kpis#1111849, plant#1111824, product#1111823, qty#1111848, shardId#1111820, version#1111822, worklistShardItemId#1111821L]

(70) InMemoryRelation
Arguments: [shardId#1111820, worklistShardItemId#1111821L, version#1111822, product#1111823, plant#1111824, qty#1111848, demandChannel#1111841, demandStream#1111842, kpis#1111849], StorageLevel(disk, memory, 2 replicas)

(71) Project [codegen id : 6]
Output [10]: [shardId#1111820, worklistShardItemId#1111821L, version#1111822, product#1111823, plant#1111824, qty#1111848, demandChannel#1111841, demandStream#1111842, kpis#1111849, false AS isNewlyCalculated#1111819]
Input [9]: [demandChannel#1111841, demandStream#1111842, kpis#1111849, plant#1111824, product#1111823, qty#1111848, shardId#1111820, version#1111822, worklistShardItemId#1111821L]

(72) Union

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

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

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

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

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

(78) BroadcastExchange
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, string, true], ), isnull(input[3, string, true])),false), [plan_id=1751580]

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

(80) Project [codegen id : 5]
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548]
Input [11]: [product#1114512, plant#1114513, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548, shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]

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

(82) SortAggregate
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548]
Keys [5]: [demandChannel#1114519, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1114539)) AS qty#1114539, worklistShardItemId#1100458L, demandStream#1114520]
Functions [1]: [partial_first(kpis#1114548, false)]
Aggregate Attributes [2]: [first#1114755, valueSet#1114756]
Results [7]: [demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, first#1114757, valueSet#1114758]

(83) Exchange
Input [7]: [demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, first#1114757, valueSet#1114758]
Arguments: hashpartitioning(demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, 37), ENSURE_REQUIREMENTS, [plan_id=1751587]

(84) Sort [codegen id : 6]
Input [7]: [demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, first#1114757, valueSet#1114758]
Arguments: [demandChannel#1114519 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1114539 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1114520 ASC NULLS FIRST], false, 0

(85) SortAggregate
Input [7]: [demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, first#1114757, valueSet#1114758]
Keys [5]: [demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520]
Functions [1]: [first(kpis#1114548, false)]
Aggregate Attributes [1]: [first(kpis#1114548)()#1114680]
Results [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, first(kpis#1114548)()#1114680 AS kpis#1114681]

(86) DeserializeToObject
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114548]
Arguments: createexternalrow(invoke(shardId#1100457.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#1100458L)), static_invoke(java.lang.Double.valueOf(qty#1114539)), invoke(demandChannel#1114519.toString()), invoke(demandStream#1114520.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#1114548, 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#1114868: org.apache.spark.sql.Row

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
temporal.activity.id	2fe7819b-828a-3eaa-98c4-d5f04113b6b3
temporal.activity.type	RunStreamWithId