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

Submitted Time: 2026/08/31 14:16:47
Duration: 0.9 s
Succeeded Jobs: 52792

Plan Visualization

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

digraph G { 0 [id="node0" labelType="html" label="InMemoryTableScan number of output rows: 351,756" tooltip="InMemoryTableScan [shardId#6552497, worklistShardItemId#6552498L, version#6873779, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]"]; subgraph cluster1 { isCluster="true"; id="cluster1"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 2 [id="node2" labelType="html" label=" Project " tooltip="Project [shardId#6552497, worklistShardItemId#6552498L, version#6873779, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]"]; 3 [id="node3" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [shardId#6552497, worklistShardItemId#6552498L], [shardId#6873784, worklistShardItemId#6873785L], Inner"]; } subgraph cluster4 { isCluster="true"; id="cluster4"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 5 [id="node5" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [shardId#6552497 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST], false, 0"]; } 6 [id="node6" 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(shardId#6552497, worklistShardItemId#6552498L, 30), ENSURE_REQUIREMENTS, [plan_id=29068970]"]; subgraph cluster7 { isCluster="true"; id="cluster7"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 8 [id="node8" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(shardId#6552497) AND isnotnull(worklistShardItemId#6552498L))"]; } 9 [id="node9" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317], [isnotnull(shardId#6552497), isnotnull(worklistShardItemId#6552498L)]"]; 10 [id="node10" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289], functions=[first(kpis#6873317, false)])"]; subgraph cluster11 { isCluster="true"; id="cluster11"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 12 [id="node12" labelType="html" label=" Sort " tooltip="Sort [demandChannel#6873288 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6873308 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6873289 ASC NULLS FIRST], false, 0"]; } 13 [id="node13" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, 30), ENSURE_REQUIREMENTS, [plan_id=29068862]"]; 14 [id="node14" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#6873288, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6873308)) AS qty#6873308, worklistShardItemId#6552498L, demandStream#6873289], functions=[partial_first(kpis#6873317, false)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 16 [id="node16" labelType="html" label=" Sort " tooltip="Sort [demandChannel#6873288 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#6873308)) AS qty#6873308 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6873289 ASC NULLS FIRST], false, 0"]; 17 [id="node17" labelType="html" label=" Project " tooltip="Project [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]"]; 18 [id="node18" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [coalesce(product#6873281, ), isnull(product#6873281), coalesce(plant#6873282, ), isnull(plant#6873282)], [coalesce(product#6552500, ), isnull(product#6552500), coalesce(plant#6552501, ), isnull(plant#6552501)], Inner, ((qty#6873308 <=> qty#6552504) OR isnull(qty#6552504))"]; } subgraph cluster19 { isCluster="true"; id="cluster19"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 20 [id="node20" labelType="html" label=" Sort " tooltip="Sort [coalesce(product#6873281, ) ASC NULLS FIRST, isnull(product#6873281) ASC NULLS FIRST, coalesce(plant#6873282, ) ASC NULLS FIRST, isnull(plant#6873282) ASC NULLS FIRST], false, 0"]; } 21 [id="node21" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(product#6873281, ), isnull(product#6873281), coalesce(plant#6873282, ), isnull(plant#6873282), 30), ENSURE_REQUIREMENTS, [plan_id=29068843]"]; 22 [id="node22" labelType="html" label=" Union " tooltip="Union"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6873262.productId AS product#6873281, prodPlantResults#6873262.plantId AS plant#6873282, null AS qty#6873308, null AS demandChannel#6873288, null AS demandStream#6873289, transform(prodPlantResults#6873262.kpiResults, lambdafunction(struct(label, lambda kpi#6873318.label, dateTime, lambda kpi#6873318.datetime, value, lambda kpi#6873318.value), lambda kpi#6873318, false)) AS kpis#6873317]"]; 24 [id="node24" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6873262]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 26 [id="node26" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6873255), false, [prodPlantResults#6873262]"]; 27 [id="node27" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6873255]"]; 28 [id="node28" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6873255, true) > 0) AND isnotnull(prodPlantResults#6873255))"]; 29 [id="node29" 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#6873254, 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#6873255]"]; } 30 [id="node30" labelType="html" label=" Scan " tooltip="Scan[obj#6873251]"]; 31 [id="node31" labelType="html" label=" Project " tooltip="Project [_extract_productId#6873433 AS product#6873268, _extract_plantId#6873434 AS plant#6873269, quantityKpiResults#6873274.quantity AS qty#6873275, null AS demandChannel#6873277, null AS demandStream#6873278, transform(quantityKpiResults#6873274.kpiResults, lambdafunction(struct(label, lambda kpi#6873318.label, dateTime, lambda kpi#6873318.datetime, value, lambda kpi#6873318.value), lambda kpi#6873318, false)) AS kpis#6873431]"]; subgraph cluster32 { isCluster="true"; id="cluster32"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 33 [id="node33" labelType="html" label=" Generate " tooltip="Generate explode(_extract_quantityKpiResults#6873435), [_extract_productId#6873433, _extract_plantId#6873434], false, [quantityKpiResults#6873274]"]; 34 [id="node34" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6873307.productId AS _extract_productId#6873433, prodPlantResults#6873307.plantId AS _extract_plantId#6873434, prodPlantResults#6873307.quantityKpiResults AS _extract_quantityKpiResults#6873435]"]; 35 [id="node35" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6873307.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#6873307.quantityKpiResults))"]; } 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6873307], [(size(prodPlantResults#6873307.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#6873307.quantityKpiResults)]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6873255), false, [prodPlantResults#6873262]"]; 39 [id="node39" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6873255]"]; 40 [id="node40" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6873255, true) > 0) AND isnotnull(prodPlantResults#6873255))"]; 41 [id="node41" 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#6873254, 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#6873255]"]; } 42 [id="node42" labelType="html" label=" Scan " tooltip="Scan[obj#6873251]"]; 43 [id="node43" labelType="html" label=" Project " tooltip="Project [_extract_productId#6873436 AS product#6873290, _extract_plantId#6873437 AS plant#6873291, null AS qty#6873313, demandChannelStreamKpiResults#6873296.demandChannel AS demandChannel#6873298, demandChannelStreamKpiResults#6873296.demandStream AS demandStream#6873300, transform(demandChannelStreamKpiResults#6873296.kpiResults, lambdafunction(struct(label, lambda kpi#6873318.label, dateTime, lambda kpi#6873318.datetime, value, lambda kpi#6873318.value), lambda kpi#6873318, false)) AS kpis#6873432]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 45 [id="node45" labelType="html" label=" Generate " tooltip="Generate explode(_extract_demandChannelStreamKpiResults#6873438), [_extract_productId#6873436, _extract_plantId#6873437], false, [demandChannelStreamKpiResults#6873296]"]; 46 [id="node46" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6873312.productId AS _extract_productId#6873436, prodPlantResults#6873312.plantId AS _extract_plantId#6873437, prodPlantResults#6873312.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#6873438]"]; 47 [id="node47" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6873312.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#6873312.demandChannelStreamKpiResults))"]; } 48 [id="node48" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6873312], [(size(prodPlantResults#6873312.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#6873312.demandChannelStreamKpiResults)]"]; subgraph cluster49 { isCluster="true"; id="cluster49"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 50 [id="node50" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6873255), false, [prodPlantResults#6873262]"]; 51 [id="node51" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6873255]"]; 52 [id="node52" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6873255, true) > 0) AND isnotnull(prodPlantResults#6873255))"]; 53 [id="node53" 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#6873254, 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#6873255]"]; } 54 [id="node54" labelType="html" label=" Scan " tooltip="Scan[obj#6873251]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 56 [id="node56" labelType="html" label=" Sort " tooltip="Sort [coalesce(product#6552500, ) ASC NULLS FIRST, isnull(product#6552500) ASC NULLS FIRST, coalesce(plant#6552501, ) ASC NULLS FIRST, isnull(plant#6552501) ASC NULLS FIRST], false, 0"]; } 57 [id="node57" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(product#6552500, ), isnull(product#6552500), coalesce(plant#6552501, ), isnull(plant#6552501), 30), ENSURE_REQUIREMENTS, [plan_id=29068852]"]; subgraph cluster58 { isCluster="true"; id="cluster58"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 59 [id="node59" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#6552501, shardId#6552497, qty#6552504, worklistShardItemId#6552498L, product#6552500], functions=[])"]; 60 [id="node60" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#6552501, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6552504)) AS qty#6552504, worklistShardItemId#6552498L, product#6552500], functions=[])"]; } 61 [id="node61" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]"]; 62 [id="node62" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#6552500, plant#6552501, 30), REPARTITION_BY_NUM, [plan_id=29067735]"]; subgraph cluster63 { isCluster="true"; id="cluster63"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 64 [id="node64" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#6552497,worklistShardItemId#6552498L,version#6552499,product#6552500,plant#6552501,periodStart#6552502,periodEnd#6552503,qty#6552504]"]; } subgraph cluster65 { isCluster="true"; id="cluster65"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 66 [id="node66" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [shardId#6873784 ASC NULLS FIRST, worklistShardItemId#6873785L ASC NULLS FIRST], false, 0"]; 67 [id="node67" 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=[shardId#6873784, worklistShardItemId#6873785L], functions=[max(version#6873786)])"]; } 68 [id="node68" 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(shardId#6873784, worklistShardItemId#6873785L, 30), ENSURE_REQUIREMENTS, [plan_id=29068979]"]; subgraph cluster69 { isCluster="true"; id="cluster69"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 70 [id="node70" 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=[shardId#6873784, worklistShardItemId#6873785L], functions=[partial_max(version#6873786)])"]; 71 [id="node71" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(shardId#6873784) AND isnotnull(worklistShardItemId#6873785L))"]; } 72 [id="node72" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#6873784, worklistShardItemId#6873785L, version#6873786], [isnotnull(shardId#6873784), isnotnull(worklistShardItemId#6873785L)]"]; 73 [id="node73" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#6552500, plant#6552501, 30), REPARTITION_BY_NUM, [plan_id=29067735]"]; subgraph cluster74 { isCluster="true"; id="cluster74"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 75 [id="node75" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#6552497,worklistShardItemId#6552498L,version#6552499,product#6552500,plant#6552501,periodStart#6552502,periodEnd#6552503,qty#6552504]"]; } 2->0; 3->2; 5->3; 6->5; 8->6; 9->8; 10->9; 12->10; 13->12; 14->13; 16->14; 17->16; 18->17; 20->18; 21->20; 22->21; 23->22; 24->23; 26->24; 27->26; 28->27; 29->28; 30->29; 31->22; 33->31; 34->33; 35->34; 36->35; 38->36; 39->38; 40->39; 41->40; 42->41; 43->22; 45->43; 46->45; 47->46; 48->47; 50->48; 51->50; 52->51; 53->52; 54->53; 56->18; 57->56; 59->57; 60->59; 61->60; 62->61; 64->62; 66->3; 67->66; 68->67; 70->68; 71->70; 72->71; 73->72; 75->73; }

Details

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


(1) InMemoryTableScan
Output [7]: [shardId#6552497, worklistShardItemId#6552498L, version#6873779, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Arguments: [shardId#6552497, worklistShardItemId#6552498L, version#6873779, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]

(2) InMemoryRelation
Arguments: [shardId#6552497, worklistShardItemId#6552498L, version#6873779, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Arguments: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317], [isnotnull(shardId#6552497), isnotnull(worklistShardItemId#6552498L)]

(4) InMemoryRelation
Arguments: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317], StorageLevel(disk, memory, 2 replicas)

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

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

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

(8) SerializeFromObject [codegen id : 1]
Input [1]: [obj#6873251]
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#6873254, 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#6873255]

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

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

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

(12) Project
Output [6]: [prodPlantResults#6873262.productId AS product#6873281, prodPlantResults#6873262.plantId AS plant#6873282, null AS qty#6873308, null AS demandChannel#6873288, null AS demandStream#6873289, transform(prodPlantResults#6873262.kpiResults, lambdafunction(struct(label, lambda kpi#6873318.label, dateTime, lambda kpi#6873318.datetime, value, lambda kpi#6873318.value), lambda kpi#6873318, false)) AS kpis#6873317]
Input [1]: [prodPlantResults#6873262]

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

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

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

(16) Project [codegen id : 1]
Output [3]: [prodPlantResults#6873307.productId AS _extract_productId#6873433, prodPlantResults#6873307.plantId AS _extract_plantId#6873434, prodPlantResults#6873307.quantityKpiResults AS _extract_quantityKpiResults#6873435]
Input [1]: [prodPlantResults#6873307]

(17) Generate [codegen id : 1]
Input [3]: [_extract_productId#6873433, _extract_plantId#6873434, _extract_quantityKpiResults#6873435]
Arguments: explode(_extract_quantityKpiResults#6873435), [_extract_productId#6873433, _extract_plantId#6873434], false, [quantityKpiResults#6873274]

(18) Project
Output [6]: [_extract_productId#6873433 AS product#6873268, _extract_plantId#6873434 AS plant#6873269, quantityKpiResults#6873274.quantity AS qty#6873275, null AS demandChannel#6873277, null AS demandStream#6873278, transform(quantityKpiResults#6873274.kpiResults, lambdafunction(struct(label, lambda kpi#6873318.label, dateTime, lambda kpi#6873318.datetime, value, lambda kpi#6873318.value), lambda kpi#6873318, false)) AS kpis#6873431]
Input [3]: [_extract_productId#6873433, _extract_plantId#6873434, quantityKpiResults#6873274]

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

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

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

(22) Project [codegen id : 2]
Output [3]: [prodPlantResults#6873312.productId AS _extract_productId#6873436, prodPlantResults#6873312.plantId AS _extract_plantId#6873437, prodPlantResults#6873312.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#6873438]
Input [1]: [prodPlantResults#6873312]

(23) Generate [codegen id : 2]
Input [3]: [_extract_productId#6873436, _extract_plantId#6873437, _extract_demandChannelStreamKpiResults#6873438]
Arguments: explode(_extract_demandChannelStreamKpiResults#6873438), [_extract_productId#6873436, _extract_plantId#6873437], false, [demandChannelStreamKpiResults#6873296]

(24) Project
Output [6]: [_extract_productId#6873436 AS product#6873290, _extract_plantId#6873437 AS plant#6873291, null AS qty#6873313, demandChannelStreamKpiResults#6873296.demandChannel AS demandChannel#6873298, demandChannelStreamKpiResults#6873296.demandStream AS demandStream#6873300, transform(demandChannelStreamKpiResults#6873296.kpiResults, lambdafunction(struct(label, lambda kpi#6873318.label, dateTime, lambda kpi#6873318.datetime, value, lambda kpi#6873318.value), lambda kpi#6873318, false)) AS kpis#6873432]
Input [3]: [_extract_productId#6873436, _extract_plantId#6873437, demandChannelStreamKpiResults#6873296]

(25) Union

(26) Exchange
Input [6]: [product#6873281, plant#6873282, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Arguments: hashpartitioning(coalesce(product#6873281, ), isnull(product#6873281), coalesce(plant#6873282, ), isnull(plant#6873282), 30), ENSURE_REQUIREMENTS, [plan_id=29068843]

(27) Sort [codegen id : 3]
Input [6]: [product#6873281, plant#6873282, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Arguments: [coalesce(product#6873281, ) ASC NULLS FIRST, isnull(product#6873281) ASC NULLS FIRST, coalesce(plant#6873282, ) ASC NULLS FIRST, isnull(plant#6873282) ASC NULLS FIRST], false, 0

(28) InMemoryTableScan
Output [5]: [shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]
Arguments: [shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]

(29) InMemoryRelation
Arguments: [shardId#6552497, worklistShardItemId#6552498L, version#6552499, product#6552500, plant#6552501, periodStart#6552502, periodEnd#6552503, qty#6552504], StorageLevel(disk, memory, 2 replicas)

(30) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#6552497, worklistShardItemId#6552498L, version#6552499, product#6552500, plant#6552501, periodStart#6552502, periodEnd#6552503, qty#6552504]
Arguments: [shardId#6552497, worklistShardItemId#6552498L, version#6552499, product#6552500, plant#6552501, periodStart#6552502, periodEnd#6552503, qty#6552504], SQLExecutionRDD[426005] at start at FileStorageAdapterImpl.java:179, ExistingRDD, UnknownPartitioning(0)

(31) Exchange
Input [8]: [shardId#6552497, worklistShardItemId#6552498L, version#6552499, product#6552500, plant#6552501, periodStart#6552502, periodEnd#6552503, qty#6552504]
Arguments: hashpartitioning(product#6552500, plant#6552501, 30), REPARTITION_BY_NUM, [plan_id=29067735]

(32) HashAggregate [codegen id : 4]
Input [5]: [shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]
Keys [5]: [plant#6552501, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6552504)) AS qty#6552504, worklistShardItemId#6552498L, product#6552500]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#6552501, shardId#6552497, qty#6552504, worklistShardItemId#6552498L, product#6552500]

(33) HashAggregate [codegen id : 4]
Input [5]: [plant#6552501, shardId#6552497, qty#6552504, worklistShardItemId#6552498L, product#6552500]
Keys [5]: [plant#6552501, shardId#6552497, qty#6552504, worklistShardItemId#6552498L, product#6552500]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]

(34) Exchange
Input [5]: [shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]
Arguments: hashpartitioning(coalesce(product#6552500, ), isnull(product#6552500), coalesce(plant#6552501, ), isnull(plant#6552501), 30), ENSURE_REQUIREMENTS, [plan_id=29068852]

(35) Sort [codegen id : 5]
Input [5]: [shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]
Arguments: [coalesce(product#6552500, ) ASC NULLS FIRST, isnull(product#6552500) ASC NULLS FIRST, coalesce(plant#6552501, ) ASC NULLS FIRST, isnull(plant#6552501) ASC NULLS FIRST], false, 0

(36) SortMergeJoin [codegen id : 6]
Left keys [4]: [coalesce(product#6873281, ), isnull(product#6873281), coalesce(plant#6873282, ), isnull(plant#6873282)]
Right keys [4]: [coalesce(product#6552500, ), isnull(product#6552500), coalesce(plant#6552501, ), isnull(plant#6552501)]
Join type: Inner
Join condition: ((qty#6873308 <=> qty#6552504) OR isnull(qty#6552504))

(37) Project [codegen id : 6]
Output [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Input [11]: [product#6873281, plant#6873282, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317, shardId#6552497, worklistShardItemId#6552498L, product#6552500, plant#6552501, qty#6552504]

(38) Sort [codegen id : 6]
Input [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Arguments: [demandChannel#6873288 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#6873308)) AS qty#6873308 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6873289 ASC NULLS FIRST], false, 0

(39) SortAggregate
Input [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Keys [5]: [demandChannel#6873288, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6873308)) AS qty#6873308, worklistShardItemId#6552498L, demandStream#6873289]
Functions [1]: [partial_first(kpis#6873317, false)]
Aggregate Attributes [2]: [first#6873494, valueSet#6873495]
Results [7]: [demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, first#6873496, valueSet#6873497]

(40) Exchange
Input [7]: [demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, first#6873496, valueSet#6873497]
Arguments: hashpartitioning(demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, 30), ENSURE_REQUIREMENTS, [plan_id=29068862]

(41) Sort [codegen id : 7]
Input [7]: [demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, first#6873496, valueSet#6873497]
Arguments: [demandChannel#6873288 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6873308 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6873289 ASC NULLS FIRST], false, 0

(42) SortAggregate
Input [7]: [demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, first#6873496, valueSet#6873497]
Keys [5]: [demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289]
Functions [1]: [first(kpis#6873317, false)]
Aggregate Attributes [1]: [first(kpis#6873317)()#6873429]
Results [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, first(kpis#6873317)()#6873429 AS kpis#6873430]

(43) Filter [codegen id : 1]
Input [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Condition : (isnotnull(shardId#6552497) AND isnotnull(worklistShardItemId#6552498L))

(44) Exchange
Input [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Arguments: hashpartitioning(shardId#6552497, worklistShardItemId#6552498L, 30), ENSURE_REQUIREMENTS, [plan_id=29068970]

(45) Sort [codegen id : 2]
Input [6]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Arguments: [shardId#6552497 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST], false, 0

(46) InMemoryTableScan
Output [3]: [shardId#6873784, worklistShardItemId#6873785L, version#6873786]
Arguments: [shardId#6873784, worklistShardItemId#6873785L, version#6873786], [isnotnull(shardId#6873784), isnotnull(worklistShardItemId#6873785L)]

(47) InMemoryRelation
Arguments: [shardId#6873784, worklistShardItemId#6873785L, version#6873786, product#6873787, plant#6873788, periodStart#6873789, periodEnd#6873790, qty#6873791], StorageLevel(disk, memory, 2 replicas)

(48) Filter [codegen id : 3]
Input [3]: [shardId#6873784, worklistShardItemId#6873785L, version#6873786]
Condition : (isnotnull(shardId#6873784) AND isnotnull(worklistShardItemId#6873785L))

(49) HashAggregate [codegen id : 3]
Input [3]: [shardId#6873784, worklistShardItemId#6873785L, version#6873786]
Keys [2]: [shardId#6873784, worklistShardItemId#6873785L]
Functions [1]: [partial_max(version#6873786)]
Aggregate Attributes [1]: [max#6874002]
Results [3]: [shardId#6873784, worklistShardItemId#6873785L, max#6874003]

(50) Exchange
Input [3]: [shardId#6873784, worklistShardItemId#6873785L, max#6874003]
Arguments: hashpartitioning(shardId#6873784, worklistShardItemId#6873785L, 30), ENSURE_REQUIREMENTS, [plan_id=29068979]

(51) HashAggregate [codegen id : 4]
Input [3]: [shardId#6873784, worklistShardItemId#6873785L, max#6874003]
Keys [2]: [shardId#6873784, worklistShardItemId#6873785L]
Functions [1]: [max(version#6873786)]
Aggregate Attributes [1]: [max(version#6873786)#6873783]
Results [3]: [shardId#6873784, worklistShardItemId#6873785L, (max(version#6873786)#6873783 + 1) AS version#6873779]

(52) Sort [codegen id : 4]
Input [3]: [shardId#6873784, worklistShardItemId#6873785L, version#6873779]
Arguments: [shardId#6873784 ASC NULLS FIRST, worklistShardItemId#6873785L ASC NULLS FIRST], false, 0

(53) SortMergeJoin [codegen id : 5]
Left keys [2]: [shardId#6552497, worklistShardItemId#6552498L]
Right keys [2]: [shardId#6873784, worklistShardItemId#6873785L]
Join type: Inner
Join condition: None

(54) Project [codegen id : 5]
Output [7]: [shardId#6552497, worklistShardItemId#6552498L, version#6873779, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317]
Input [9]: [shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873317, shardId#6873784, worklistShardItemId#6873785L, version#6873779]

SQL / DataFrame Properties

Name	Value
spark.activity.clearDeltaLogCache	false
spark.activity.clearSqlCache	false
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	20
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
spark.sql.shuffle.partitions	30
temporal.activity.id	380b254d-cd08-376f-a8ea-0fb4ce69f6c0
temporal.activity.type	RunStreamWithId