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

Submitted Time: 2026/08/31 13:45:46
Duration: 0.7 s
Succeeded Jobs: 52486

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: 159,872" tooltip="InMemoryTableScan [shardId#6552473, worklistShardItemId#6552474L, version#6811912, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]"]; 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#6552473, worklistShardItemId#6552474L, version#6811912, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]"]; 3 [id="node3" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [shardId#6552473, worklistShardItemId#6552474L], [shardId#6811917, worklistShardItemId#6811918L], 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#6552473 ASC NULLS FIRST, worklistShardItemId#6552474L 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#6552473, worklistShardItemId#6552474L, 30), ENSURE_REQUIREMENTS, [plan_id=29044338]"]; 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#6552473) AND isnotnull(worklistShardItemId#6552474L))"]; } 9 [id="node9" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450], [isnotnull(shardId#6552473), isnotnull(worklistShardItemId#6552474L)]"]; 10 [id="node10" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422], functions=[first(kpis#6811450, false)])"]; subgraph cluster11 { isCluster="true"; id="cluster11"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 12 [id="node12" labelType="html" label=" Sort " tooltip="Sort [demandChannel#6811421 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, qty#6811441 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6811422 ASC NULLS FIRST], false, 0"]; } 13 [id="node13" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422, 30), ENSURE_REQUIREMENTS, [plan_id=29044230]"]; 14 [id="node14" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#6811421, shardId#6552473, knownfloatingpointnormalized(normalizenanandzero(qty#6811441)) AS qty#6811441, worklistShardItemId#6552474L, demandStream#6811422], functions=[partial_first(kpis#6811450, false)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 16 [id="node16" labelType="html" label=" Sort " tooltip="Sort [demandChannel#6811421 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#6811441)) AS qty#6811441 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6811422 ASC NULLS FIRST], false, 0"]; 17 [id="node17" labelType="html" label=" Project " tooltip="Project [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]"]; 18 [id="node18" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [coalesce(product#6811414, ), isnull(product#6811414), coalesce(plant#6811415, ), isnull(plant#6811415)], [coalesce(product#6552476, ), isnull(product#6552476), coalesce(plant#6552477, ), isnull(plant#6552477)], Inner, ((qty#6811441 <=> qty#6552480) OR isnull(qty#6552480))"]; } subgraph cluster19 { isCluster="true"; id="cluster19"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 20 [id="node20" labelType="html" label=" Sort " tooltip="Sort [coalesce(product#6811414, ) ASC NULLS FIRST, isnull(product#6811414) ASC NULLS FIRST, coalesce(plant#6811415, ) ASC NULLS FIRST, isnull(plant#6811415) ASC NULLS FIRST], false, 0"]; } 21 [id="node21" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(product#6811414, ), isnull(product#6811414), coalesce(plant#6811415, ), isnull(plant#6811415), 30), ENSURE_REQUIREMENTS, [plan_id=29044211]"]; 22 [id="node22" labelType="html" label=" Union " tooltip="Union"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6811395.productId AS product#6811414, prodPlantResults#6811395.plantId AS plant#6811415, null AS qty#6811441, null AS demandChannel#6811421, null AS demandStream#6811422, transform(prodPlantResults#6811395.kpiResults, lambdafunction(struct(label, lambda kpi#6811451.label, dateTime, lambda kpi#6811451.datetime, value, lambda kpi#6811451.value), lambda kpi#6811451, false)) AS kpis#6811450]"]; 24 [id="node24" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6811395]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 26 [id="node26" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6811388), false, [prodPlantResults#6811395]"]; 27 [id="node27" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6811388]"]; 28 [id="node28" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6811388, true) > 0) AND isnotnull(prodPlantResults#6811388))"]; 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#6811387, 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#6811388]"]; } 30 [id="node30" labelType="html" label=" Scan " tooltip="Scan[obj#6811384]"]; 31 [id="node31" labelType="html" label=" Project " tooltip="Project [_extract_productId#6811566 AS product#6811401, _extract_plantId#6811567 AS plant#6811402, quantityKpiResults#6811407.quantity AS qty#6811408, null AS demandChannel#6811410, null AS demandStream#6811411, transform(quantityKpiResults#6811407.kpiResults, lambdafunction(struct(label, lambda kpi#6811451.label, dateTime, lambda kpi#6811451.datetime, value, lambda kpi#6811451.value), lambda kpi#6811451, false)) AS kpis#6811564]"]; subgraph cluster32 { isCluster="true"; id="cluster32"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 33 [id="node33" labelType="html" label=" Generate " tooltip="Generate explode(_extract_quantityKpiResults#6811568), [_extract_productId#6811566, _extract_plantId#6811567], false, [quantityKpiResults#6811407]"]; 34 [id="node34" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6811440.productId AS _extract_productId#6811566, prodPlantResults#6811440.plantId AS _extract_plantId#6811567, prodPlantResults#6811440.quantityKpiResults AS _extract_quantityKpiResults#6811568]"]; 35 [id="node35" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6811440.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#6811440.quantityKpiResults))"]; } 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6811440], [(size(prodPlantResults#6811440.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#6811440.quantityKpiResults)]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6811388), false, [prodPlantResults#6811395]"]; 39 [id="node39" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6811388]"]; 40 [id="node40" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6811388, true) > 0) AND isnotnull(prodPlantResults#6811388))"]; 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#6811387, 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#6811388]"]; } 42 [id="node42" labelType="html" label=" Scan " tooltip="Scan[obj#6811384]"]; 43 [id="node43" labelType="html" label=" Project " tooltip="Project [_extract_productId#6811569 AS product#6811423, _extract_plantId#6811570 AS plant#6811424, null AS qty#6811446, demandChannelStreamKpiResults#6811429.demandChannel AS demandChannel#6811431, demandChannelStreamKpiResults#6811429.demandStream AS demandStream#6811433, transform(demandChannelStreamKpiResults#6811429.kpiResults, lambdafunction(struct(label, lambda kpi#6811451.label, dateTime, lambda kpi#6811451.datetime, value, lambda kpi#6811451.value), lambda kpi#6811451, false)) AS kpis#6811565]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 45 [id="node45" labelType="html" label=" Generate " tooltip="Generate explode(_extract_demandChannelStreamKpiResults#6811571), [_extract_productId#6811569, _extract_plantId#6811570], false, [demandChannelStreamKpiResults#6811429]"]; 46 [id="node46" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6811445.productId AS _extract_productId#6811569, prodPlantResults#6811445.plantId AS _extract_plantId#6811570, prodPlantResults#6811445.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#6811571]"]; 47 [id="node47" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6811445.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#6811445.demandChannelStreamKpiResults))"]; } 48 [id="node48" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6811445], [(size(prodPlantResults#6811445.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#6811445.demandChannelStreamKpiResults)]"]; subgraph cluster49 { isCluster="true"; id="cluster49"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 50 [id="node50" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6811388), false, [prodPlantResults#6811395]"]; 51 [id="node51" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6811388]"]; 52 [id="node52" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6811388, true) > 0) AND isnotnull(prodPlantResults#6811388))"]; 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#6811387, 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#6811388]"]; } 54 [id="node54" labelType="html" label=" Scan " tooltip="Scan[obj#6811384]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 56 [id="node56" labelType="html" label=" Sort " tooltip="Sort [coalesce(product#6552476, ) ASC NULLS FIRST, isnull(product#6552476) ASC NULLS FIRST, coalesce(plant#6552477, ) ASC NULLS FIRST, isnull(plant#6552477) ASC NULLS FIRST], false, 0"]; } 57 [id="node57" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(product#6552476, ), isnull(product#6552476), coalesce(plant#6552477, ), isnull(plant#6552477), 30), ENSURE_REQUIREMENTS, [plan_id=29044220]"]; subgraph cluster58 { isCluster="true"; id="cluster58"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 59 [id="node59" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#6552477, shardId#6552473, qty#6552480, worklistShardItemId#6552474L, product#6552476], functions=[])"]; 60 [id="node60" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[plant#6552477, shardId#6552473, knownfloatingpointnormalized(normalizenanandzero(qty#6552480)) AS qty#6552480, worklistShardItemId#6552474L, product#6552476], functions=[])"]; } 61 [id="node61" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]"]; 62 [id="node62" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#6552476, plant#6552477, 30), REPARTITION_BY_NUM, [plan_id=29043113]"]; subgraph cluster63 { isCluster="true"; id="cluster63"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 64 [id="node64" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#6552473,worklistShardItemId#6552474L,version#6552475,product#6552476,plant#6552477,periodStart#6552478,periodEnd#6552479,qty#6552480]"]; } 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#6811917 ASC NULLS FIRST, worklistShardItemId#6811918L 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#6811917, worklistShardItemId#6811918L], functions=[max(version#6811919)])"]; } 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#6811917, worklistShardItemId#6811918L, 30), ENSURE_REQUIREMENTS, [plan_id=29044347]"]; 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#6811917, worklistShardItemId#6811918L], functions=[partial_max(version#6811919)])"]; 71 [id="node71" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(shardId#6811917) AND isnotnull(worklistShardItemId#6811918L))"]; } 72 [id="node72" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#6811917, worklistShardItemId#6811918L, version#6811919], [isnotnull(shardId#6811917), isnotnull(worklistShardItemId#6811918L)]"]; 73 [id="node73" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#6552476, plant#6552477, 30), REPARTITION_BY_NUM, [plan_id=29043113]"]; subgraph cluster74 { isCluster="true"; id="cluster74"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 75 [id="node75" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#6552473,worklistShardItemId#6552474L,version#6552475,product#6552476,plant#6552477,periodStart#6552478,periodEnd#6552479,qty#6552480]"]; } 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#6552473, worklistShardItemId#6552474L, version#6811912, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Arguments: [shardId#6552473, worklistShardItemId#6552474L, version#6811912, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]

(2) InMemoryRelation
Arguments: [shardId#6552473, worklistShardItemId#6552474L, version#6811912, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Arguments: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450], [isnotnull(shardId#6552473), isnotnull(worklistShardItemId#6552474L)]

(4) InMemoryRelation
Arguments: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450], StorageLevel(disk, memory, 2 replicas)

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

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

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

(8) SerializeFromObject [codegen id : 1]
Input [1]: [obj#6811384]
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#6811387, 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#6811388]

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

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

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

(12) Project
Output [6]: [prodPlantResults#6811395.productId AS product#6811414, prodPlantResults#6811395.plantId AS plant#6811415, null AS qty#6811441, null AS demandChannel#6811421, null AS demandStream#6811422, transform(prodPlantResults#6811395.kpiResults, lambdafunction(struct(label, lambda kpi#6811451.label, dateTime, lambda kpi#6811451.datetime, value, lambda kpi#6811451.value), lambda kpi#6811451, false)) AS kpis#6811450]
Input [1]: [prodPlantResults#6811395]

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

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

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

(16) Project [codegen id : 1]
Output [3]: [prodPlantResults#6811440.productId AS _extract_productId#6811566, prodPlantResults#6811440.plantId AS _extract_plantId#6811567, prodPlantResults#6811440.quantityKpiResults AS _extract_quantityKpiResults#6811568]
Input [1]: [prodPlantResults#6811440]

(17) Generate [codegen id : 1]
Input [3]: [_extract_productId#6811566, _extract_plantId#6811567, _extract_quantityKpiResults#6811568]
Arguments: explode(_extract_quantityKpiResults#6811568), [_extract_productId#6811566, _extract_plantId#6811567], false, [quantityKpiResults#6811407]

(18) Project
Output [6]: [_extract_productId#6811566 AS product#6811401, _extract_plantId#6811567 AS plant#6811402, quantityKpiResults#6811407.quantity AS qty#6811408, null AS demandChannel#6811410, null AS demandStream#6811411, transform(quantityKpiResults#6811407.kpiResults, lambdafunction(struct(label, lambda kpi#6811451.label, dateTime, lambda kpi#6811451.datetime, value, lambda kpi#6811451.value), lambda kpi#6811451, false)) AS kpis#6811564]
Input [3]: [_extract_productId#6811566, _extract_plantId#6811567, quantityKpiResults#6811407]

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

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

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

(22) Project [codegen id : 2]
Output [3]: [prodPlantResults#6811445.productId AS _extract_productId#6811569, prodPlantResults#6811445.plantId AS _extract_plantId#6811570, prodPlantResults#6811445.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#6811571]
Input [1]: [prodPlantResults#6811445]

(23) Generate [codegen id : 2]
Input [3]: [_extract_productId#6811569, _extract_plantId#6811570, _extract_demandChannelStreamKpiResults#6811571]
Arguments: explode(_extract_demandChannelStreamKpiResults#6811571), [_extract_productId#6811569, _extract_plantId#6811570], false, [demandChannelStreamKpiResults#6811429]

(24) Project
Output [6]: [_extract_productId#6811569 AS product#6811423, _extract_plantId#6811570 AS plant#6811424, null AS qty#6811446, demandChannelStreamKpiResults#6811429.demandChannel AS demandChannel#6811431, demandChannelStreamKpiResults#6811429.demandStream AS demandStream#6811433, transform(demandChannelStreamKpiResults#6811429.kpiResults, lambdafunction(struct(label, lambda kpi#6811451.label, dateTime, lambda kpi#6811451.datetime, value, lambda kpi#6811451.value), lambda kpi#6811451, false)) AS kpis#6811565]
Input [3]: [_extract_productId#6811569, _extract_plantId#6811570, demandChannelStreamKpiResults#6811429]

(25) Union

(26) Exchange
Input [6]: [product#6811414, plant#6811415, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Arguments: hashpartitioning(coalesce(product#6811414, ), isnull(product#6811414), coalesce(plant#6811415, ), isnull(plant#6811415), 30), ENSURE_REQUIREMENTS, [plan_id=29044211]

(27) Sort [codegen id : 3]
Input [6]: [product#6811414, plant#6811415, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Arguments: [coalesce(product#6811414, ) ASC NULLS FIRST, isnull(product#6811414) ASC NULLS FIRST, coalesce(plant#6811415, ) ASC NULLS FIRST, isnull(plant#6811415) ASC NULLS FIRST], false, 0

(28) InMemoryTableScan
Output [5]: [shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]
Arguments: [shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]

(29) InMemoryRelation
Arguments: [shardId#6552473, worklistShardItemId#6552474L, version#6552475, product#6552476, plant#6552477, periodStart#6552478, periodEnd#6552479, qty#6552480], StorageLevel(disk, memory, 2 replicas)

(30) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#6552473, worklistShardItemId#6552474L, version#6552475, product#6552476, plant#6552477, periodStart#6552478, periodEnd#6552479, qty#6552480]
Arguments: [shardId#6552473, worklistShardItemId#6552474L, version#6552475, product#6552476, plant#6552477, periodStart#6552478, periodEnd#6552479, qty#6552480], SQLExecutionRDD[422022] at start at FileStorageAdapterImpl.java:179, ExistingRDD, UnknownPartitioning(0)

(31) Exchange
Input [8]: [shardId#6552473, worklistShardItemId#6552474L, version#6552475, product#6552476, plant#6552477, periodStart#6552478, periodEnd#6552479, qty#6552480]
Arguments: hashpartitioning(product#6552476, plant#6552477, 30), REPARTITION_BY_NUM, [plan_id=29043113]

(32) HashAggregate [codegen id : 4]
Input [5]: [shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]
Keys [5]: [plant#6552477, shardId#6552473, knownfloatingpointnormalized(normalizenanandzero(qty#6552480)) AS qty#6552480, worklistShardItemId#6552474L, product#6552476]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#6552477, shardId#6552473, qty#6552480, worklistShardItemId#6552474L, product#6552476]

(33) HashAggregate [codegen id : 4]
Input [5]: [plant#6552477, shardId#6552473, qty#6552480, worklistShardItemId#6552474L, product#6552476]
Keys [5]: [plant#6552477, shardId#6552473, qty#6552480, worklistShardItemId#6552474L, product#6552476]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]

(34) Exchange
Input [5]: [shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]
Arguments: hashpartitioning(coalesce(product#6552476, ), isnull(product#6552476), coalesce(plant#6552477, ), isnull(plant#6552477), 30), ENSURE_REQUIREMENTS, [plan_id=29044220]

(35) Sort [codegen id : 5]
Input [5]: [shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]
Arguments: [coalesce(product#6552476, ) ASC NULLS FIRST, isnull(product#6552476) ASC NULLS FIRST, coalesce(plant#6552477, ) ASC NULLS FIRST, isnull(plant#6552477) ASC NULLS FIRST], false, 0

(36) SortMergeJoin [codegen id : 6]
Left keys [4]: [coalesce(product#6811414, ), isnull(product#6811414), coalesce(plant#6811415, ), isnull(plant#6811415)]
Right keys [4]: [coalesce(product#6552476, ), isnull(product#6552476), coalesce(plant#6552477, ), isnull(plant#6552477)]
Join type: Inner
Join condition: ((qty#6811441 <=> qty#6552480) OR isnull(qty#6552480))

(37) Project [codegen id : 6]
Output [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Input [11]: [product#6811414, plant#6811415, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450, shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]

(38) Sort [codegen id : 6]
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Arguments: [demandChannel#6811421 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#6811441)) AS qty#6811441 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6811422 ASC NULLS FIRST], false, 0

(39) SortAggregate
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Keys [5]: [demandChannel#6811421, shardId#6552473, knownfloatingpointnormalized(normalizenanandzero(qty#6811441)) AS qty#6811441, worklistShardItemId#6552474L, demandStream#6811422]
Functions [1]: [partial_first(kpis#6811450, false)]
Aggregate Attributes [2]: [first#6811627, valueSet#6811628]
Results [7]: [demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422, first#6811629, valueSet#6811630]

(40) Exchange
Input [7]: [demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422, first#6811629, valueSet#6811630]
Arguments: hashpartitioning(demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422, 30), ENSURE_REQUIREMENTS, [plan_id=29044230]

(41) Sort [codegen id : 7]
Input [7]: [demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422, first#6811629, valueSet#6811630]
Arguments: [demandChannel#6811421 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, qty#6811441 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6811422 ASC NULLS FIRST], false, 0

(42) SortAggregate
Input [7]: [demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422, first#6811629, valueSet#6811630]
Keys [5]: [demandChannel#6811421, shardId#6552473, qty#6811441, worklistShardItemId#6552474L, demandStream#6811422]
Functions [1]: [first(kpis#6811450, false)]
Aggregate Attributes [1]: [first(kpis#6811450)()#6811562]
Results [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, first(kpis#6811450)()#6811562 AS kpis#6811563]

(43) Filter [codegen id : 1]
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Condition : (isnotnull(shardId#6552473) AND isnotnull(worklistShardItemId#6552474L))

(44) Exchange
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Arguments: hashpartitioning(shardId#6552473, worklistShardItemId#6552474L, 30), ENSURE_REQUIREMENTS, [plan_id=29044338]

(45) Sort [codegen id : 2]
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Arguments: [shardId#6552473 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST], false, 0

(46) InMemoryTableScan
Output [3]: [shardId#6811917, worklistShardItemId#6811918L, version#6811919]
Arguments: [shardId#6811917, worklistShardItemId#6811918L, version#6811919], [isnotnull(shardId#6811917), isnotnull(worklistShardItemId#6811918L)]

(47) InMemoryRelation
Arguments: [shardId#6811917, worklistShardItemId#6811918L, version#6811919, product#6811920, plant#6811921, periodStart#6811922, periodEnd#6811923, qty#6811924], StorageLevel(disk, memory, 2 replicas)

(48) Filter [codegen id : 3]
Input [3]: [shardId#6811917, worklistShardItemId#6811918L, version#6811919]
Condition : (isnotnull(shardId#6811917) AND isnotnull(worklistShardItemId#6811918L))

(49) HashAggregate [codegen id : 3]
Input [3]: [shardId#6811917, worklistShardItemId#6811918L, version#6811919]
Keys [2]: [shardId#6811917, worklistShardItemId#6811918L]
Functions [1]: [partial_max(version#6811919)]
Aggregate Attributes [1]: [max#6812135]
Results [3]: [shardId#6811917, worklistShardItemId#6811918L, max#6812136]

(50) Exchange
Input [3]: [shardId#6811917, worklistShardItemId#6811918L, max#6812136]
Arguments: hashpartitioning(shardId#6811917, worklistShardItemId#6811918L, 30), ENSURE_REQUIREMENTS, [plan_id=29044347]

(51) HashAggregate [codegen id : 4]
Input [3]: [shardId#6811917, worklistShardItemId#6811918L, max#6812136]
Keys [2]: [shardId#6811917, worklistShardItemId#6811918L]
Functions [1]: [max(version#6811919)]
Aggregate Attributes [1]: [max(version#6811919)#6811916]
Results [3]: [shardId#6811917, worklistShardItemId#6811918L, (max(version#6811919)#6811916 + 1) AS version#6811912]

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

(53) SortMergeJoin [codegen id : 5]
Left keys [2]: [shardId#6552473, worklistShardItemId#6552474L]
Right keys [2]: [shardId#6811917, worklistShardItemId#6811918L]
Join type: Inner
Join condition: None

(54) Project [codegen id : 5]
Output [7]: [shardId#6552473, worklistShardItemId#6552474L, version#6811912, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450]
Input [9]: [shardId#6552473, worklistShardItemId#6552474L, qty#6811441, demandChannel#6811421, demandStream#6811422, kpis#6811450, shardId#6811917, worklistShardItemId#6811918L, version#6811912]

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	15
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	fc963591-2a40-3f0d-8c9b-7f805f547a86
temporal.activity.type	RunStreamWithId