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

Submitted Time: 2026/08/31 13:49:56
Duration: 0.8 s
Succeeded Jobs: 52566

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#6828224, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]"]; 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#6828224, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]"]; 3 [id="node3" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [shardId#6552473, worklistShardItemId#6552474L], [shardId#6828229, worklistShardItemId#6828230L], 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=29050807]"]; 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#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762], [isnotnull(shardId#6552473), isnotnull(worklistShardItemId#6552474L)]"]; 10 [id="node10" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734], functions=[first(kpis#6827762, false)])"]; subgraph cluster11 { isCluster="true"; id="cluster11"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 12 [id="node12" labelType="html" label=" Sort " tooltip="Sort [demandChannel#6827733 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, qty#6827753 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6827734 ASC NULLS FIRST], false, 0"]; } 13 [id="node13" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734, 30), ENSURE_REQUIREMENTS, [plan_id=29050699]"]; 14 [id="node14" labelType="html" label=" SortAggregate " tooltip="SortAggregate(key=[demandChannel#6827733, shardId#6552473, knownfloatingpointnormalized(normalizenanandzero(qty#6827753)) AS qty#6827753, worklistShardItemId#6552474L, demandStream#6827734], functions=[partial_first(kpis#6827762, false)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 16 [id="node16" labelType="html" label=" Sort " tooltip="Sort [demandChannel#6827733 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#6827753)) AS qty#6827753 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6827734 ASC NULLS FIRST], false, 0"]; 17 [id="node17" labelType="html" label=" Project " tooltip="Project [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]"]; 18 [id="node18" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [coalesce(product#6827726, ), isnull(product#6827726), coalesce(plant#6827727, ), isnull(plant#6827727)], [coalesce(product#6552476, ), isnull(product#6552476), coalesce(plant#6552477, ), isnull(plant#6552477)], Inner, ((qty#6827753 <=> 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#6827726, ) ASC NULLS FIRST, isnull(product#6827726) ASC NULLS FIRST, coalesce(plant#6827727, ) ASC NULLS FIRST, isnull(plant#6827727) ASC NULLS FIRST], false, 0"]; } 21 [id="node21" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(coalesce(product#6827726, ), isnull(product#6827726), coalesce(plant#6827727, ), isnull(plant#6827727), 30), ENSURE_REQUIREMENTS, [plan_id=29050680]"]; 22 [id="node22" labelType="html" label=" Union " tooltip="Union"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6827707.productId AS product#6827726, prodPlantResults#6827707.plantId AS plant#6827727, null AS qty#6827753, null AS demandChannel#6827733, null AS demandStream#6827734, transform(prodPlantResults#6827707.kpiResults, lambdafunction(struct(label, lambda kpi#6827763.label, dateTime, lambda kpi#6827763.datetime, value, lambda kpi#6827763.value), lambda kpi#6827763, false)) AS kpis#6827762]"]; 24 [id="node24" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6827707]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 26 [id="node26" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6827700), false, [prodPlantResults#6827707]"]; 27 [id="node27" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6827700]"]; 28 [id="node28" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6827700, true) > 0) AND isnotnull(prodPlantResults#6827700))"]; 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#6827699, 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#6827700]"]; } 30 [id="node30" labelType="html" label=" Scan " tooltip="Scan[obj#6827696]"]; 31 [id="node31" labelType="html" label=" Project " tooltip="Project [_extract_productId#6827878 AS product#6827713, _extract_plantId#6827879 AS plant#6827714, quantityKpiResults#6827719.quantity AS qty#6827720, null AS demandChannel#6827722, null AS demandStream#6827723, transform(quantityKpiResults#6827719.kpiResults, lambdafunction(struct(label, lambda kpi#6827763.label, dateTime, lambda kpi#6827763.datetime, value, lambda kpi#6827763.value), lambda kpi#6827763, false)) AS kpis#6827876]"]; subgraph cluster32 { isCluster="true"; id="cluster32"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 33 [id="node33" labelType="html" label=" Generate " tooltip="Generate explode(_extract_quantityKpiResults#6827880), [_extract_productId#6827878, _extract_plantId#6827879], false, [quantityKpiResults#6827719]"]; 34 [id="node34" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6827752.productId AS _extract_productId#6827878, prodPlantResults#6827752.plantId AS _extract_plantId#6827879, prodPlantResults#6827752.quantityKpiResults AS _extract_quantityKpiResults#6827880]"]; 35 [id="node35" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6827752.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#6827752.quantityKpiResults))"]; } 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6827752], [(size(prodPlantResults#6827752.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#6827752.quantityKpiResults)]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6827700), false, [prodPlantResults#6827707]"]; 39 [id="node39" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6827700]"]; 40 [id="node40" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6827700, true) > 0) AND isnotnull(prodPlantResults#6827700))"]; 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#6827699, 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#6827700]"]; } 42 [id="node42" labelType="html" label=" Scan " tooltip="Scan[obj#6827696]"]; 43 [id="node43" labelType="html" label=" Project " tooltip="Project [_extract_productId#6827881 AS product#6827735, _extract_plantId#6827882 AS plant#6827736, null AS qty#6827758, demandChannelStreamKpiResults#6827741.demandChannel AS demandChannel#6827743, demandChannelStreamKpiResults#6827741.demandStream AS demandStream#6827745, transform(demandChannelStreamKpiResults#6827741.kpiResults, lambdafunction(struct(label, lambda kpi#6827763.label, dateTime, lambda kpi#6827763.datetime, value, lambda kpi#6827763.value), lambda kpi#6827763, false)) AS kpis#6827877]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 45 [id="node45" labelType="html" label=" Generate " tooltip="Generate explode(_extract_demandChannelStreamKpiResults#6827883), [_extract_productId#6827881, _extract_plantId#6827882], false, [demandChannelStreamKpiResults#6827741]"]; 46 [id="node46" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6827757.productId AS _extract_productId#6827881, prodPlantResults#6827757.plantId AS _extract_plantId#6827882, prodPlantResults#6827757.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#6827883]"]; 47 [id="node47" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6827757.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#6827757.demandChannelStreamKpiResults))"]; } 48 [id="node48" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [prodPlantResults#6827757], [(size(prodPlantResults#6827757.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#6827757.demandChannelStreamKpiResults)]"]; subgraph cluster49 { isCluster="true"; id="cluster49"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 50 [id="node50" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#6827700), false, [prodPlantResults#6827707]"]; 51 [id="node51" labelType="html" label=" Project " tooltip="Project [prodPlantResults#6827700]"]; 52 [id="node52" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#6827700, true) > 0) AND isnotnull(prodPlantResults#6827700))"]; 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#6827699, 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#6827700]"]; } 54 [id="node54" labelType="html" label=" Scan " tooltip="Scan[obj#6827696]"]; 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=29050689]"]; 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=29048965]"]; 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#6828229 ASC NULLS FIRST, worklistShardItemId#6828230L 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#6828229, worklistShardItemId#6828230L], functions=[max(version#6828231)])"]; } 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#6828229, worklistShardItemId#6828230L, 30), ENSURE_REQUIREMENTS, [plan_id=29050816]"]; 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#6828229, worklistShardItemId#6828230L], functions=[partial_max(version#6828231)])"]; 71 [id="node71" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(shardId#6828229) AND isnotnull(worklistShardItemId#6828230L))"]; } 72 [id="node72" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#6828229, worklistShardItemId#6828230L, version#6828231], [isnotnull(shardId#6828229), isnotnull(worklistShardItemId#6828230L)]"]; 73 [id="node73" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#6552476, plant#6552477, 30), REPARTITION_BY_NUM, [plan_id=29048965]"]; 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#6828224, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Arguments: [shardId#6552473, worklistShardItemId#6552474L, version#6828224, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]

(2) InMemoryRelation
Arguments: [shardId#6552473, worklistShardItemId#6552474L, version#6828224, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Arguments: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762], [isnotnull(shardId#6552473), isnotnull(worklistShardItemId#6552474L)]

(4) InMemoryRelation
Arguments: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762], StorageLevel(disk, memory, 2 replicas)

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

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

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

(8) SerializeFromObject [codegen id : 1]
Input [1]: [obj#6827696]
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#6827699, 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#6827700]

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

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

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

(12) Project
Output [6]: [prodPlantResults#6827707.productId AS product#6827726, prodPlantResults#6827707.plantId AS plant#6827727, null AS qty#6827753, null AS demandChannel#6827733, null AS demandStream#6827734, transform(prodPlantResults#6827707.kpiResults, lambdafunction(struct(label, lambda kpi#6827763.label, dateTime, lambda kpi#6827763.datetime, value, lambda kpi#6827763.value), lambda kpi#6827763, false)) AS kpis#6827762]
Input [1]: [prodPlantResults#6827707]

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

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

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

(16) Project [codegen id : 1]
Output [3]: [prodPlantResults#6827752.productId AS _extract_productId#6827878, prodPlantResults#6827752.plantId AS _extract_plantId#6827879, prodPlantResults#6827752.quantityKpiResults AS _extract_quantityKpiResults#6827880]
Input [1]: [prodPlantResults#6827752]

(17) Generate [codegen id : 1]
Input [3]: [_extract_productId#6827878, _extract_plantId#6827879, _extract_quantityKpiResults#6827880]
Arguments: explode(_extract_quantityKpiResults#6827880), [_extract_productId#6827878, _extract_plantId#6827879], false, [quantityKpiResults#6827719]

(18) Project
Output [6]: [_extract_productId#6827878 AS product#6827713, _extract_plantId#6827879 AS plant#6827714, quantityKpiResults#6827719.quantity AS qty#6827720, null AS demandChannel#6827722, null AS demandStream#6827723, transform(quantityKpiResults#6827719.kpiResults, lambdafunction(struct(label, lambda kpi#6827763.label, dateTime, lambda kpi#6827763.datetime, value, lambda kpi#6827763.value), lambda kpi#6827763, false)) AS kpis#6827876]
Input [3]: [_extract_productId#6827878, _extract_plantId#6827879, quantityKpiResults#6827719]

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

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

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

(22) Project [codegen id : 2]
Output [3]: [prodPlantResults#6827757.productId AS _extract_productId#6827881, prodPlantResults#6827757.plantId AS _extract_plantId#6827882, prodPlantResults#6827757.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#6827883]
Input [1]: [prodPlantResults#6827757]

(23) Generate [codegen id : 2]
Input [3]: [_extract_productId#6827881, _extract_plantId#6827882, _extract_demandChannelStreamKpiResults#6827883]
Arguments: explode(_extract_demandChannelStreamKpiResults#6827883), [_extract_productId#6827881, _extract_plantId#6827882], false, [demandChannelStreamKpiResults#6827741]

(24) Project
Output [6]: [_extract_productId#6827881 AS product#6827735, _extract_plantId#6827882 AS plant#6827736, null AS qty#6827758, demandChannelStreamKpiResults#6827741.demandChannel AS demandChannel#6827743, demandChannelStreamKpiResults#6827741.demandStream AS demandStream#6827745, transform(demandChannelStreamKpiResults#6827741.kpiResults, lambdafunction(struct(label, lambda kpi#6827763.label, dateTime, lambda kpi#6827763.datetime, value, lambda kpi#6827763.value), lambda kpi#6827763, false)) AS kpis#6827877]
Input [3]: [_extract_productId#6827881, _extract_plantId#6827882, demandChannelStreamKpiResults#6827741]

(25) Union

(26) Exchange
Input [6]: [product#6827726, plant#6827727, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Arguments: hashpartitioning(coalesce(product#6827726, ), isnull(product#6827726), coalesce(plant#6827727, ), isnull(plant#6827727), 30), ENSURE_REQUIREMENTS, [plan_id=29050680]

(27) Sort [codegen id : 3]
Input [6]: [product#6827726, plant#6827727, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Arguments: [coalesce(product#6827726, ) ASC NULLS FIRST, isnull(product#6827726) ASC NULLS FIRST, coalesce(plant#6827727, ) ASC NULLS FIRST, isnull(plant#6827727) 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[422970] 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=29048965]

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

(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#6827726, ), isnull(product#6827726), coalesce(plant#6827727, ), isnull(plant#6827727)]
Right keys [4]: [coalesce(product#6552476, ), isnull(product#6552476), coalesce(plant#6552477, ), isnull(plant#6552477)]
Join type: Inner
Join condition: ((qty#6827753 <=> qty#6552480) OR isnull(qty#6552480))

(37) Project [codegen id : 6]
Output [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Input [11]: [product#6827726, plant#6827727, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762, shardId#6552473, worklistShardItemId#6552474L, product#6552476, plant#6552477, qty#6552480]

(38) Sort [codegen id : 6]
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Arguments: [demandChannel#6827733 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#6827753)) AS qty#6827753 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6827734 ASC NULLS FIRST], false, 0

(39) SortAggregate
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Keys [5]: [demandChannel#6827733, shardId#6552473, knownfloatingpointnormalized(normalizenanandzero(qty#6827753)) AS qty#6827753, worklistShardItemId#6552474L, demandStream#6827734]
Functions [1]: [partial_first(kpis#6827762, false)]
Aggregate Attributes [2]: [first#6827939, valueSet#6827940]
Results [7]: [demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734, first#6827941, valueSet#6827942]

(40) Exchange
Input [7]: [demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734, first#6827941, valueSet#6827942]
Arguments: hashpartitioning(demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734, 30), ENSURE_REQUIREMENTS, [plan_id=29050699]

(41) Sort [codegen id : 7]
Input [7]: [demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734, first#6827941, valueSet#6827942]
Arguments: [demandChannel#6827733 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, qty#6827753 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6827734 ASC NULLS FIRST], false, 0

(42) SortAggregate
Input [7]: [demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734, first#6827941, valueSet#6827942]
Keys [5]: [demandChannel#6827733, shardId#6552473, qty#6827753, worklistShardItemId#6552474L, demandStream#6827734]
Functions [1]: [first(kpis#6827762, false)]
Aggregate Attributes [1]: [first(kpis#6827762)()#6827874]
Results [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, first(kpis#6827762)()#6827874 AS kpis#6827875]

(43) Filter [codegen id : 1]
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Condition : (isnotnull(shardId#6552473) AND isnotnull(worklistShardItemId#6552474L))

(44) Exchange
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Arguments: hashpartitioning(shardId#6552473, worklistShardItemId#6552474L, 30), ENSURE_REQUIREMENTS, [plan_id=29050807]

(45) Sort [codegen id : 2]
Input [6]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Arguments: [shardId#6552473 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST], false, 0

(46) InMemoryTableScan
Output [3]: [shardId#6828229, worklistShardItemId#6828230L, version#6828231]
Arguments: [shardId#6828229, worklistShardItemId#6828230L, version#6828231], [isnotnull(shardId#6828229), isnotnull(worklistShardItemId#6828230L)]

(47) InMemoryRelation
Arguments: [shardId#6828229, worklistShardItemId#6828230L, version#6828231, product#6828232, plant#6828233, periodStart#6828234, periodEnd#6828235, qty#6828236], StorageLevel(disk, memory, 2 replicas)

(48) Filter [codegen id : 3]
Input [3]: [shardId#6828229, worklistShardItemId#6828230L, version#6828231]
Condition : (isnotnull(shardId#6828229) AND isnotnull(worklistShardItemId#6828230L))

(49) HashAggregate [codegen id : 3]
Input [3]: [shardId#6828229, worklistShardItemId#6828230L, version#6828231]
Keys [2]: [shardId#6828229, worklistShardItemId#6828230L]
Functions [1]: [partial_max(version#6828231)]
Aggregate Attributes [1]: [max#6828447]
Results [3]: [shardId#6828229, worklistShardItemId#6828230L, max#6828448]

(50) Exchange
Input [3]: [shardId#6828229, worklistShardItemId#6828230L, max#6828448]
Arguments: hashpartitioning(shardId#6828229, worklistShardItemId#6828230L, 30), ENSURE_REQUIREMENTS, [plan_id=29050816]

(51) HashAggregate [codegen id : 4]
Input [3]: [shardId#6828229, worklistShardItemId#6828230L, max#6828448]
Keys [2]: [shardId#6828229, worklistShardItemId#6828230L]
Functions [1]: [max(version#6828231)]
Aggregate Attributes [1]: [max(version#6828231)#6828228]
Results [3]: [shardId#6828229, worklistShardItemId#6828230L, (max(version#6828231)#6828228 + 1) AS version#6828224]

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

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

(54) Project [codegen id : 5]
Output [7]: [shardId#6552473, worklistShardItemId#6552474L, version#6828224, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762]
Input [9]: [shardId#6552473, worklistShardItemId#6552474L, qty#6827753, demandChannel#6827733, demandStream#6827734, kpis#6827762, shardId#6828229, worklistShardItemId#6828230L, version#6828224]

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	17
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