crp-order-qty-opt-service - Details for Query 3810

Submitted Time: 2026/08/10 11:33:37
Duration: 1 s
Succeeded Jobs: 5779 5780 5781

Plan Visualization

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

digraph G { 0 [id="node0" labelType="html" label=" MapPartitions " tooltip="MapPartitions org.apache.spark.sql.internal.ToScalaUDF$$$Lambda/0x00000008021bcd18@48ffd2a5, obj#893216: org.apache.spark.sql.Row"]; 1 [id="node1" labelType="html" label=" DeserializeToObject " tooltip="DeserializeToObject createexternalrow(invoke(shardId#892679.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#893023L)), mapobjects(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1), createexternalrow(static_invoke(java.lang.Long.valueOf(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).worklistShardItemId)), mapobjects(lambdavariable(MapObject, DoubleType, true, -2), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -2))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).quantities, Some(class scala.collection.mutable.ArraySeq)), createexternalrow(mapobjects(lambdavariable(MapObject, DoubleType, true, -3), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -3))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.EndOfPeriodVirtualStockQty, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -4), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -4))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.OutOfStockProbability, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -5), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -5))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.RangeOfCoverage, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -6), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -6))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.RemainingStockQty, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -7), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -7))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.ServiceLevel, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -8), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -8))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.ServiceLevelAtStartOfDelisting, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -9), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -9))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.ServiceLevelMinimumStock, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -10), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -10))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.UnfulfilledDemandQty, Some(class scala.collection.mutable.ArraySeq)), StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false), StructField(OutOfStockProbability,ArrayType(DoubleType,true),false), StructField(RangeOfCoverage,ArrayType(DoubleType,true),false), StructField(RemainingStockQty,ArrayType(DoubleType,true),false), StructField(ServiceLevel,ArrayType(DoubleType,true),false), StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false), StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false), StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)), mapobjects(lambdavariable(MapObject, DoubleType, true, -11), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -11))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintValues, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StringType, true, -12), invoke(lambdavariable(MapObject, StringType, true, -12).toString()), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintOperators, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StringType, true, -13), invoke(lambdavariable(MapObject, StringType, true, -13).toString()), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintLabels, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, IntegerType, true, -14), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, IntegerType, true, -14))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintRanks, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, BooleanType, true, -15), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, BooleanType, true, -15))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintIsActive, Some(class scala.collection.mutable.ArraySeq)), invoke(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).orderQuantityBaseUom.toString()), invoke(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).orderQuantityBaseUomUuid.toString()), mapobjects(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16), if (isnull(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).uom.toString()), invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).uomUuid.toString()), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).numerator)), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).denominator)), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).isOrderUnit)), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).isPreferred)), StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true)), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).logisticUnits, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StringType, true, -17), invoke(lambdavariable(MapObject, StringType, true, -17).toString()), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).optimizationGroups, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18), if (isnull(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18))) null else createexternalrow(static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).value)), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).dimensionType)), invoke(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).dimensionCode.toString()), invoke(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).dimensionCodeUuid.toString()), invoke(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).isoCode.toString()), StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true)), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).measurements, Some(class scala.collection.mutable.ArraySeq)), StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), ... 1 more fields), items#893156, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19), if (isnull(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).optGroupId.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).assignmentDetails.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderProfile.toString()), if (isnull(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal)) null else createexternalrow(static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.minOrderValue)), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.dimensionType)), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.unit.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.unitUuid.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.isoCode.toString()), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.negligibleQuantitiesThreshold)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.acceptanceThreshold)), StructField(minOrderValue,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(unit,StringType,true), StructField(unitUuid,StringType,true), StructField(isoCode,StringType,true), StructField(negligibleQuantitiesThreshold,DoubleType,true), StructField(acceptanceThreshold,DoubleType,true)), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).multiplerestrictionprofile.toString()), StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true)), optimizationGroups#893185, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#893177)), mapobjects(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20), if (isnull(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20).uomCategoryName.toString()), mapobjects(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21), if (isnull(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21).uom.toString()), invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21).uomUuid.toString()), StructField(uom,StringType,true), StructField(uomUuid,StringType,true)), lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20).uoms, Some(class scala.collection.mutable.ArraySeq)), StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true)), uomCategories#893189, Some(class scala.collection.mutable.ArraySeq)), catalysttoexternalmap(lambdavariable(CatalystToExternalMap_key, StringType, false, -22), invoke(lambdavariable(CatalystToExternalMap_key, StringType, false, -22).toString()), lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23), if (isnull(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23))) null else createexternalrow(invoke(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).configurationVersion.toString()), invoke(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).name.toString()), mapobjects(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24), if (isnull(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24).name.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24).type.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24).value.toString()), StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true)), lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).settings, Some(class scala.collection.mutable.ArraySeq)), invoke(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).status.toString()), StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true)), insightConfigurations#893190, interface scala.collection.Map), StructField(shardId,StringType,true), StructField(orderProposalId,LongType,true), StructField(items,ArrayType(StructType(StructField(worklistShardItemId,LongType,true),StructField(quantities,ArrayType(DoubleType,true),false),StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false),StructField(constraintValues,ArrayType(DoubleType,true),true),StructField(constraintOperators,ArrayType(StringType,true),true),StructField(constraintLabels,ArrayType(StringType,true),true),StructField(constraintRanks,ArrayType(IntegerType,true),true),StructField(constraintIsActive,ArrayType(BooleanType,true),true),StructField(orderQuantityBaseUom,StringType,true),StructField(orderQuantityBaseUomUuid,StringType,true),StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true),StructField(optimizationGroups,ArrayType(StringType,true),true),StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true)),false),false), StructField(optimizationGroups,ArrayType(StructType(StructField(optGroupId,StringType,true),StructField(assignmentDetails,StringType,true),StructField(minOrderProfile,StringType,true),StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true),StructField(multiplerestrictionprofile,StringType,true)),true),true), StructField(sequenceId,IntegerType,true), StructField(uomCategories,ArrayType(StructType(StructField(uomCategoryName,StringType,true),StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true)),true),true), StructField(insightConfigurations,MapType(StringType,StructType(StructField(configurationVersion,StringType,true),StructField(name,StringType,true),StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true),StructField(status,StringType,true)),true),true)), obj#893209: org.apache.spark.sql.Row"]; subgraph cluster2 { isCluster="true"; id="cluster2"; label="WholeStageCodegen (11)"; tooltip="WholeStageCodegen (11)"; 3 [id="node3" labelType="html" label=" BroadcastNestedLoopJoin " tooltip="BroadcastNestedLoopJoin BuildRight, LeftOuter, (shardId#892679 = 0_1_10000002109)"]; 4 [id="node4" labelType="html" label=" Project " tooltip="Project [shardId#892679, orderProposalId#893023L, items#893156, optimizationGroups#893185, sequenceId#893177]"]; 5 [id="node5" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [orderProposalId#893023L], [orderProposalId#893176L], LeftOuter, BuildRight, (shardId#892679 = 0_1_10000002109), false"]; } 6 [id="node6" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#892679, orderProposalId#893023L], functions=[collect_list(struct(worklistShardItemId, worklistShardItemId#892688L, quantities, quantities#892883, kpis, kpis#892892, constraintValues, constraintValues#893056, constraintOperators, constraintOperators#893055, constraintLabels, constraintLabels#893054, constraintRanks, constraintRanks#893057, constraintIsActive, constraintIsActive#893058, orderQuantityBaseUom, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#893052, logisticUnits, logisticUnits#893050, optimizationGroups, optimizationGroups#893066, measurements, ... 1 more fields), 0, 0)])"]; 7 [id="node7" labelType="html" label="Exchange number of partitions: 20" tooltip="Exchange hashpartitioning(shardId#892679, orderProposalId#893023L, 20), ENSURE_REQUIREMENTS, [plan_id=348690]"]; 8 [id="node8" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#892679, orderProposalId#893023L], functions=[partial_collect_list(struct(worklistShardItemId, worklistShardItemId#892688L, quantities, quantities#892883, kpis, kpis#892892, constraintValues, constraintValues#893056, constraintOperators, constraintOperators#893055, constraintLabels, constraintLabels#893054, constraintRanks, constraintRanks#893057, constraintIsActive, constraintIsActive#893058, orderQuantityBaseUom, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#893052, logisticUnits, logisticUnits#893050, optimizationGroups, optimizationGroups#893066, measurements, ... 1 more fields), 0, 0)])"]; subgraph cluster9 { isCluster="true"; id="cluster9"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 10 [id="node10" labelType="html" label=" Project " tooltip="Project [shardId#892679, worklistShardItemId#892688L, quantities#892883, kpis#892892, constraintValues#893056, constraintOperators#893055, constraintLabels#893054, constraintRanks#893057, constraintIsActive#893058, orderProposalId#893023L, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, logisticUnits#893050, optimizationGroups#893066, measurements#893064]"]; 11 [id="node11" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#892688L], [worklistShardItemId#893046L], LeftOuter, BuildRight, (shardId#892679 = 0_1_10000002109), false"]; 12 [id="node12" labelType="html" label=" Project " tooltip="Project [shardId#892679, worklistShardItemId#892688L, struct_array#892867.qty AS quantities#892883, struct(EndOfPeriodVirtualStockQty, struct_array#892867.kpi:EndOfPeriodVirtualStockQty, OutOfStockProbability, struct_array#892867.kpi:OutOfStockProbability, RangeOfCoverage, struct_array#892867.kpi:RangeOfCoverage, RemainingStockQty, struct_array#892867.kpi:RemainingStockQty, ServiceLevel, struct_array#892867.kpi:ServiceLevel, ServiceLevelAtStartOfDelisting, struct_array#892867.kpi:ServiceLevelAtStartOfDelisting, ServiceLevelMinimumStock, struct_array#892867.kpi:ServiceLevelMinimumStock, UnfulfilledDemandQty, struct_array#892867.kpi:UnfulfilledDemandQty) AS kpis#892892]"]; } 13 [id="node13" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#892679, worklistShardItemId#892688L], functions=[max(struct#892866.qty), collect_list(struct#892866, 0, 0)])"]; 14 [id="node14" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#892679, worklistShardItemId#892688L], functions=[partial_max(struct#892866.qty), partial_collect_list(struct#892866, 0, 0)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [shardId#892679, worklistShardItemId#892688L, struct(qty, qty#892750, kpi:EndOfPeriodVirtualStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[0], kpi:OutOfStockProbability, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[1], kpi:RangeOfCoverage, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[2], kpi:RemainingStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[3], kpi:ServiceLevel, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[4], kpi:ServiceLevelAtStartOfDelisting, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[5], kpi:ServiceLevelMinimumStock, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[6], kpi:UnfulfilledDemandQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[7]) AS struct#892866]"]; } 17 [id="node17" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#892679, worklistShardItemId#892688L, qty#892750], functions=[pivotfirst(label#892757, max(kpi.`value` AS value)#892823, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:UnfulfilledDemandQty, 0, 0)])"]; 18 [id="node18" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#892679, worklistShardItemId#892688L, knownfloatingpointnormalized(normalizenanandzero(qty#892750)) AS qty#892750], functions=[partial_pivotfirst(label#892757, max(kpi.`value` AS value)#892823, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:UnfulfilledDemandQty, 0, 0)])"]; subgraph cluster19 { isCluster="true"; id="cluster19"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 20 [id="node20" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#892679, worklistShardItemId#892688L, qty#892750, label#892757], functions=[max(_extract_value#893294)])"]; 21 [id="node21" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#892679, worklistShardItemId#892688L, knownfloatingpointnormalized(normalizenanandzero(qty#892750)) AS qty#892750, label#892757], functions=[partial_max(_extract_value#893294)])"]; 22 [id="node22" labelType="html" label=" Project " tooltip="Project [shardId#892679, worklistShardItemId#892688L, qty#892750, kpi#892756.value AS _extract_value#893294, concat(kpi:, kpi#892756.label) AS label#892757]"]; 23 [id="node23" labelType="html" label=" Generate " tooltip="Generate explode(kpis#892754), [shardId#892679, worklistShardItemId#892688L, qty#892750], true, [kpi#892756]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [shardId#892679, worklistShardItemId#892688L, qty#892750, coalesce(kpis#892753, []) AS kpis#892754]"]; 25 [id="node25" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#892748, worklistShardItemId#892749L], [shardId#892679, worklistShardItemId#892688L], RightOuter"]; } subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 27 [id="node27" labelType="html" label=" Sort " tooltip="Sort [shardId#892748 ASC NULLS FIRST, worklistShardItemId#892749L ASC NULLS FIRST], false, 0"]; } 28 [id="node28" labelType="html" label="Exchange number of partitions: 20" tooltip="Exchange hashpartitioning(shardId#892748, worklistShardItemId#892749L, 20), ENSURE_REQUIREMENTS, [plan_id=348650]"]; subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 30 [id="node30" labelType="html" label=" Project " tooltip="Project [shardId#892748, worklistShardItemId#892749L, qty#892750, kpis#892753]"]; 31 [id="node31" labelType="html" label=" Filter " tooltip="Filter (isnotnull(qty#892750) AND (isnotnull(shardId#892748) AND isnotnull(worklistShardItemId#892749L)))"]; 32 [id="node32" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#892748,worklistShardItemId#892749L,qty#892750,demandChannel#892751,demandStream#892752,kpis#892753]"]; } subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 34 [id="node34" labelType="html" label=" Sort " tooltip="Sort [shardId#892679 ASC NULLS FIRST, worklistShardItemId#892688L ASC NULLS FIRST], false, 0"]; } 35 [id="node35" labelType="html" label="Exchange number of partitions: 20" tooltip="Exchange hashpartitioning(shardId#892679, worklistShardItemId#892688L, 20), ENSURE_REQUIREMENTS, [plan_id=348591]"]; 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#892679, worklistShardItemId#892688L]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Project " tooltip="Project [shardId#892679, item#892687L AS worklistShardItemId#892688L]"]; 39 [id="node39" labelType="html" label=" Generate " tooltip="Generate explode(_extract_worklistShardItemId#892691), [shardId#892679], false, [item#892687L]"]; 40 [id="node40" labelType="html" label=" Project " tooltip="Project [shardId#892679, items#892681.worklistShardItemId AS _extract_worklistShardItemId#892691]"]; 41 [id="node41" labelType="html" label=" Filter " tooltip="Filter ((isnotnull(shardId#892679) AND ((shardId#892679 = 0_1_10000002109) AND (isOptimal#892683 <=> false))) AND ((size(items#892681.worklistShardItemId, true) > 0) AND isnotnull(items#892681.worklistShardItemId)))"]; 42 [id="node42" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#892679,orderProposalId#892680L,items#892681,optimizationGroups#892682,isOptimal#892683,lastModified#892684,optimizationInsights#892685]"]; } 43 [id="node43" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 282 ms number of output rows: 6 data size: 1024.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=348684]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n3 ms (0 ms, 0 ms, 1 ms (stage 73751.0: task 182955))"; tooltip="WholeStageCodegen (7)"; 45 [id="node45" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#893046L, orderProposalId#893023L, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, measurements#893064, constraintLabels#893054, constraintOperators#893055, constraintRanks#893057, constraintValues#893056, constraintIsActive#893058, logisticUnits#893050, optimizationGroups#893066]"]; } 46 [id="node46" labelType="html" label="Exchange shuffle records written: 6 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 6 local bytes read total (min, med, max (stageId: taskId)) 5.0 KiB (765.0 B, 971.0 B, 1551.0 B (stage 73751.0: task 182951)) merged fetch fallback count: 0 local blocks read: 6 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 7.0 KiB (1128.0 B, 2.2 KiB, 2.3 KiB (stage 73750.0: task 182928)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 1 ms (0 ms, 0 ms, 0 ms (stage 73750.0: task 182927)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 73751.0: task 182953)) remote bytes read: 0.0 B number of partitions: 20 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 5.0 KiB (812.0 B, 1575.0 B, 1714.0 B (stage 73750.0: task 182928))" tooltip="Exchange hashpartitioning(worklistShardItemId#893046L, 20), REPARTITION_BY_NUM, [plan_id=348680]"]; subgraph cluster47 { isCluster="true"; id="cluster47"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n518 ms (104 ms, 137 ms, 151 ms (stage 73750.0: task 182929))"; tooltip="WholeStageCodegen (6)"; 48 [id="node48" labelType="html" label=" Project " tooltip="Project [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066]"]; 49 [id="node49" labelType="html" label="Filter number of output rows: 6" tooltip="Filter isnotnull(worklistShardItemId#893046L)"]; 50 [id="node50" labelType="html" label="ColumnarToRow number of output rows: 6 number of input batches: 4" tooltip="ColumnarToRow"]; } 51 [id="node51" labelType="html" label="Scan parquet number of files read: 4 scan time total (min, med, max (stageId: taskId)) 502 ms (101 ms, 131 ms, 146 ms (stage 73750.0: task 182929)) dynamic partition pruning time: 0 ms metadata time: 0 ms size of files read: 77.1 KiB number of output rows: 6 number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#893023L,worklistShardItemId#893046L,logisticUnits#893050,orderQuantityBaseUom#893051,orderQuantityBaseUomUuid#893052,constraintLabels#893054,constraintOperators#893055,constraintValues#893056,constraintRanks#893057,constraintIsActive#893058,measurements#893064,optimizationGroups#893066,shardId#893067,sequenceId#893045] Batched: true, DataFilters: [isnotnull(worklistShardItemId#893046L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#893067), isnotnull(sequenceId#893045), (shardId#893067 = 0_1_10000002109), (se..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,worklistShardItemId:bigint,logisticUnits:array<struct<uom:string,uo..."]; 52 [id="node52" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 315 ms number of output rows: 4 data size: 1024.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=348700]"]; 53 [id="node53" labelType="html" label=" Project " tooltip="Project [orderProposalId#893176L, transform(optimizationGroups#893178, lambdafunction(if (isnull(lambda x_110#893182)) null else named_struct(optGroupId, lambda x_110#893182.optGroupId, assignmentDetails, lambda x_110#893182.assignmentDetails, minOrderProfile, lambda x_110#893182.minOrderProfile, minOrderGoal, if (isnull(lambda x_110#893182.minOrderGoal)) null else named_struct(minOrderValue, lambda x_110#893182.minOrderGoal.minOrderValue, dimensionType, lambda x_110#893182.minOrderGoal.dimensionType, unit, lambda x_110#893182.minOrderGoal.unit, unitUuid, lambda x_110#893182.minOrderGoal.unitUuid, isoCode, lambda x_110#893182.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_110#893182.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_110#893182.minOrderGoal.acceptanceThreshold), multiplerestrictionprofile, lambda x_110#893182.multiplerestrictionprofile), lambda x_110#893182, false)) AS optimizationGroups#893185, sequenceId#893177]"]; 54 [id="node54" labelType="html" label="Exchange shuffle records written: 4 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 4 local bytes read total (min, med, max (stageId: taskId)) 824.0 B (96.0 B, 316.0 B, 316.0 B (stage 73749.0: task 182962)) merged fetch fallback count: 0 local blocks read: 4 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 736.0 B (40.0 B, 328.0 B, 328.0 B (stage 73748.0: task 182924)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 1 ms (0 ms, 0 ms, 0 ms (stage 73748.0: task 182925)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 73749.0: task 182961)) remote bytes read: 0.0 B number of partitions: 20 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 824.0 B (96.0 B, 316.0 B, 316.0 B (stage 73748.0: task 182924))" tooltip="Exchange hashpartitioning(orderProposalId#893176L, 20), REPARTITION_BY_NUM, [plan_id=348698]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n608 ms (120 ms, 159 ms, 174 ms (stage 73748.0: task 182923))"; tooltip="WholeStageCodegen (9)"; 56 [id="node56" labelType="html" label=" Project " tooltip="Project [orderProposalId#893176L, sequenceId#893177, optimizationGroups#893178]"]; 57 [id="node57" labelType="html" label="Filter number of output rows: 4" tooltip="Filter isnotnull(orderProposalId#893176L)"]; 58 [id="node58" labelType="html" label="ColumnarToRow number of output rows: 4 number of input batches: 4" tooltip="ColumnarToRow"]; } 59 [id="node59" labelType="html" label="Scan parquet number of files read: 4 scan time total (min, med, max (stageId: taskId)) 478 ms (84 ms, 125 ms, 145 ms (stage 73748.0: task 182923)) dynamic partition pruning time: 0 ms metadata time: 0 ms size of files read: 18.6 KiB number of output rows: 4 number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#893176L,optimizationGroups#893178,shardId#893179,sequenceId#893177] Batched: true, DataFilters: [isnotnull(orderProposalId#893176L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#893179), isnotnull(sequenceId#893177), (shardId#893179 = 0_1_10000002109), (se..., PushedFilters: [IsNotNull(orderProposalId)], ReadSchema: struct<orderProposalId:bigint,optimizationGroups:array<struct<optGroupId:string,assignmentDetails..."]; 60 [id="node60" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 232 ms number of output rows: 1 data size: 712.0 B" tooltip="BroadcastExchange IdentityBroadcastMode, [plan_id=348709]"]; 61 [id="node61" labelType="html" label="Exchange shuffle records written: 1 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 481.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 712.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: 20 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 481.0 B" tooltip="Exchange RoundRobinPartitioning(20), REPARTITION_BY_NUM, [plan_id=348708]"]; subgraph cluster62 { isCluster="true"; id="cluster62"; label="WholeStageCodegen (10)\n \nduration: 125 ms"; tooltip="WholeStageCodegen (10)"; 63 [id="node63" labelType="html" label=" Project " tooltip="Project [uomCategories#893189, insightConfigurations#893190]"]; 64 [id="node64" labelType="html" label="ColumnarToRow number of output rows: 1 number of input batches: 1" tooltip="ColumnarToRow"]; } 65 [id="node65" labelType="html" label="Scan parquet number of files read: 1 scan time: 122 ms dynamic partition pruning time: 0 ms metadata time: 0 ms size of files read: 4.6 KiB number of output rows: 1 number of partitions read: 1" tooltip="FileScan parquet [uomCategories#893189,insightConfigurations#893190,shardId#893191] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#893191), (shardId#893191 = 0_1_10000002109)], PushedFilters: [], ReadSchema: struct<uomCategories:array<struct<uomCategoryName:string,uoms:array<struct<uom:string,uomUuid:str..."]; 1->0; 3->1; 4->3; 5->4; 6->5; 7->6; 8->7; 10->8; 11->10; 12->11; 13->12; 14->13; 16->14; 17->16; 18->17; 20->18; 21->20; 22->21; 23->22; 24->23; 25->24; 27->25; 28->27; 30->28; 31->30; 32->31; 34->25; 35->34; 36->35; 38->36; 39->38; 40->39; 41->40; 42->41; 43->11; 45->43; 46->45; 48->46; 49->48; 50->49; 51->50; 52->5; 53->52; 54->53; 56->54; 57->56; 58->57; 59->58; 60->3; 61->60; 63->61; 64->63; 65->64; }

Details

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


(1) Scan ExistingRDD [codegen id : 1]
Output [6]: [shardId#892748, worklistShardItemId#892749L, qty#892750, demandChannel#892751, demandStream#892752, kpis#892753]
Arguments: [shardId#892748, worklistShardItemId#892749L, qty#892750, demandChannel#892751, demandStream#892752, kpis#892753], MapPartitionsRDD[41811] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)

(2) Filter [codegen id : 1]
Input [6]: [shardId#892748, worklistShardItemId#892749L, qty#892750, demandChannel#892751, demandStream#892752, kpis#892753]
Condition : (isnotnull(qty#892750) AND (isnotnull(shardId#892748) AND isnotnull(worklistShardItemId#892749L)))

(3) Project [codegen id : 1]
Output [4]: [shardId#892748, worklistShardItemId#892749L, qty#892750, kpis#892753]
Input [6]: [shardId#892748, worklistShardItemId#892749L, qty#892750, demandChannel#892751, demandStream#892752, kpis#892753]

(4) Exchange
Input [4]: [shardId#892748, worklistShardItemId#892749L, qty#892750, kpis#892753]
Arguments: hashpartitioning(shardId#892748, worklistShardItemId#892749L, 20), ENSURE_REQUIREMENTS, [plan_id=348650]

(5) Sort [codegen id : 2]
Input [4]: [shardId#892748, worklistShardItemId#892749L, qty#892750, kpis#892753]
Arguments: [shardId#892748 ASC NULLS FIRST, worklistShardItemId#892749L ASC NULLS FIRST], false, 0

(6) InMemoryTableScan
Output [2]: [shardId#892679, worklistShardItemId#892688L]
Arguments: [shardId#892679, worklistShardItemId#892688L]

(7) InMemoryRelation
Arguments: [shardId#892679, worklistShardItemId#892688L], StorageLevel(disk, memory, 2 replicas)

(8) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#892679, orderProposalId#892680L, items#892681, optimizationGroups#892682, isOptimal#892683, lastModified#892684, optimizationInsights#892685]
Arguments: [shardId#892679, orderProposalId#892680L, items#892681, optimizationGroups#892682, isOptimal#892683, lastModified#892684, optimizationInsights#892685], MapPartitionsRDD[41799] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)

(9) Filter [codegen id : 1]
Input [7]: [shardId#892679, orderProposalId#892680L, items#892681, optimizationGroups#892682, isOptimal#892683, lastModified#892684, optimizationInsights#892685]
Condition : ((isnotnull(shardId#892679) AND ((shardId#892679 = 0_1_10000002109) AND (isOptimal#892683 <=> false))) AND ((size(items#892681.worklistShardItemId, true) > 0) AND isnotnull(items#892681.worklistShardItemId)))

(10) Project [codegen id : 1]
Output [2]: [shardId#892679, items#892681.worklistShardItemId AS _extract_worklistShardItemId#892691]
Input [7]: [shardId#892679, orderProposalId#892680L, items#892681, optimizationGroups#892682, isOptimal#892683, lastModified#892684, optimizationInsights#892685]

(11) Generate [codegen id : 1]
Input [2]: [shardId#892679, _extract_worklistShardItemId#892691]
Arguments: explode(_extract_worklistShardItemId#892691), [shardId#892679], false, [item#892687L]

(12) Project [codegen id : 1]
Output [2]: [shardId#892679, item#892687L AS worklistShardItemId#892688L]
Input [2]: [shardId#892679, item#892687L]

(13) Exchange
Input [2]: [shardId#892679, worklistShardItemId#892688L]
Arguments: hashpartitioning(shardId#892679, worklistShardItemId#892688L, 20), ENSURE_REQUIREMENTS, [plan_id=348591]

(14) Sort [codegen id : 3]
Input [2]: [shardId#892679, worklistShardItemId#892688L]
Arguments: [shardId#892679 ASC NULLS FIRST, worklistShardItemId#892688L ASC NULLS FIRST], false, 0

(15) SortMergeJoin [codegen id : 4]
Left keys [2]: [shardId#892748, worklistShardItemId#892749L]
Right keys [2]: [shardId#892679, worklistShardItemId#892688L]
Join type: RightOuter
Join condition: None

(16) Project [codegen id : 4]
Output [4]: [shardId#892679, worklistShardItemId#892688L, qty#892750, coalesce(kpis#892753, []) AS kpis#892754]
Input [6]: [shardId#892748, worklistShardItemId#892749L, qty#892750, kpis#892753, shardId#892679, worklistShardItemId#892688L]

(17) Generate [codegen id : 4]
Input [4]: [shardId#892679, worklistShardItemId#892688L, qty#892750, kpis#892754]
Arguments: explode(kpis#892754), [shardId#892679, worklistShardItemId#892688L, qty#892750], true, [kpi#892756]

(18) Project [codegen id : 4]
Output [5]: [shardId#892679, worklistShardItemId#892688L, qty#892750, kpi#892756.value AS _extract_value#893294, concat(kpi:, kpi#892756.label) AS label#892757]
Input [4]: [shardId#892679, worklistShardItemId#892688L, qty#892750, kpi#892756]

(19) HashAggregate [codegen id : 4]
Input [5]: [shardId#892679, worklistShardItemId#892688L, qty#892750, _extract_value#893294, label#892757]
Keys [4]: [shardId#892679, worklistShardItemId#892688L, knownfloatingpointnormalized(normalizenanandzero(qty#892750)) AS qty#892750, label#892757]
Functions [1]: [partial_max(_extract_value#893294)]
Aggregate Attributes [1]: [max#893521]
Results [5]: [shardId#892679, worklistShardItemId#892688L, qty#892750, label#892757, max#893522]

(20) HashAggregate [codegen id : 4]
Input [5]: [shardId#892679, worklistShardItemId#892688L, qty#892750, label#892757, max#893522]
Keys [4]: [shardId#892679, worklistShardItemId#892688L, qty#892750, label#892757]
Functions [1]: [max(_extract_value#893294)]
Aggregate Attributes [1]: [max(_extract_value#893294)#892822]
Results [5]: [shardId#892679, worklistShardItemId#892688L, qty#892750, label#892757, max(_extract_value#893294)#892822 AS max(kpi.`value` AS value)#892823]

(21) HashAggregate
Input [5]: [shardId#892679, worklistShardItemId#892688L, qty#892750, label#892757, max(kpi.`value` AS value)#892823]
Keys [3]: [shardId#892679, worklistShardItemId#892688L, knownfloatingpointnormalized(normalizenanandzero(qty#892750)) AS qty#892750]
Functions [1]: [partial_pivotfirst(label#892757, max(kpi.`value` AS value)#892823, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:UnfulfilledDemandQty, 0, 0)]
Aggregate Attributes [8]: [kpi:EndOfPeriodVirtualStockQty#892824, kpi:OutOfStockProbability#892825, kpi:RangeOfCoverage#892826, kpi:RemainingStockQty#892827, kpi:ServiceLevel#892828, kpi:ServiceLevelAtStartOfDelisting#892829, kpi:ServiceLevelMinimumStock#892830, kpi:UnfulfilledDemandQty#892831]
Results [11]: [shardId#892679, worklistShardItemId#892688L, qty#892750, kpi:EndOfPeriodVirtualStockQty#892832, kpi:OutOfStockProbability#892833, kpi:RangeOfCoverage#892834, kpi:RemainingStockQty#892835, kpi:ServiceLevel#892836, kpi:ServiceLevelAtStartOfDelisting#892837, kpi:ServiceLevelMinimumStock#892838, kpi:UnfulfilledDemandQty#892839]

(22) HashAggregate
Input [11]: [shardId#892679, worklistShardItemId#892688L, qty#892750, kpi:EndOfPeriodVirtualStockQty#892832, kpi:OutOfStockProbability#892833, kpi:RangeOfCoverage#892834, kpi:RemainingStockQty#892835, kpi:ServiceLevel#892836, kpi:ServiceLevelAtStartOfDelisting#892837, kpi:ServiceLevelMinimumStock#892838, kpi:UnfulfilledDemandQty#892839]
Keys [3]: [shardId#892679, worklistShardItemId#892688L, qty#892750]
Functions [1]: [pivotfirst(label#892757, max(kpi.`value` AS value)#892823, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:UnfulfilledDemandQty, 0, 0)]
Aggregate Attributes [1]: [pivotfirst(label#892757, max(kpi.`value` AS value)#892823, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:UnfulfilledDemandQty, 0, 0)#892840]
Results [4]: [shardId#892679, worklistShardItemId#892688L, qty#892750, pivotfirst(label#892757, max(kpi.`value` AS value)#892823, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:UnfulfilledDemandQty, 0, 0)#892840 AS __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841]

(23) Project [codegen id : 5]
Output [3]: [shardId#892679, worklistShardItemId#892688L, struct(qty, qty#892750, kpi:EndOfPeriodVirtualStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[0], kpi:OutOfStockProbability, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[1], kpi:RangeOfCoverage, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[2], kpi:RemainingStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[3], kpi:ServiceLevel, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[4], kpi:ServiceLevelAtStartOfDelisting, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[5], kpi:ServiceLevelMinimumStock, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[6], kpi:UnfulfilledDemandQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841[7]) AS struct#892866]
Input [4]: [shardId#892679, worklistShardItemId#892688L, qty#892750, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#892841]

(24) ObjectHashAggregate
Input [3]: [shardId#892679, worklistShardItemId#892688L, struct#892866]
Keys [2]: [shardId#892679, worklistShardItemId#892688L]
Functions [2]: [partial_max(struct#892866.qty), partial_collect_list(struct#892866, 0, 0)]
Aggregate Attributes [2]: [max#893517, buf#893518]
Results [4]: [shardId#892679, worklistShardItemId#892688L, max#893519, buf#893520]

(25) ObjectHashAggregate
Input [4]: [shardId#892679, worklistShardItemId#892688L, max#893519, buf#893520]
Keys [2]: [shardId#892679, worklistShardItemId#892688L]
Functions [2]: [max(struct#892866.qty), collect_list(struct#892866, 0, 0)]
Aggregate Attributes [2]: [max(struct#892866.qty)#892881, collect_list(struct#892866, 0, 0)#892882]
Results [3]: [shardId#892679, worklistShardItemId#892688L, sort_array(CASE WHEN isnull(max(struct#892866.qty)#892881) THEN [] ELSE collect_list(struct#892866, 0, 0)#892882 END, true) AS struct_array#892867]

(26) Project [codegen id : 8]
Output [4]: [shardId#892679, worklistShardItemId#892688L, struct_array#892867.qty AS quantities#892883, struct(EndOfPeriodVirtualStockQty, struct_array#892867.kpi:EndOfPeriodVirtualStockQty, OutOfStockProbability, struct_array#892867.kpi:OutOfStockProbability, RangeOfCoverage, struct_array#892867.kpi:RangeOfCoverage, RemainingStockQty, struct_array#892867.kpi:RemainingStockQty, ServiceLevel, struct_array#892867.kpi:ServiceLevel, ServiceLevelAtStartOfDelisting, struct_array#892867.kpi:ServiceLevelAtStartOfDelisting, ServiceLevelMinimumStock, struct_array#892867.kpi:ServiceLevelMinimumStock, UnfulfilledDemandQty, struct_array#892867.kpi:UnfulfilledDemandQty) AS kpis#892892]
Input [3]: [shardId#892679, worklistShardItemId#892688L, struct_array#892867]

(27) Scan parquet 
Output [14]: [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066, shardId#893067, sequenceId#893045]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002109]
PartitionFilters: [isnotnull(shardId#893067), isnotnull(sequenceId#893045), (shardId#893067 = 0_1_10000002109), (sequenceId#893045 = 2)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,worklistShardItemId:bigint,logisticUnits:array<struct<uom:string,uomUuid:string,numerator:int,denominator:int,isOrderUnit:boolean,isPreferred:boolean>>,orderQuantityBaseUom:string,orderQuantityBaseUomUuid:string,constraintLabels:array<string>,constraintOperators:array<string>,constraintValues:array<double>,constraintRanks:array<int>,constraintIsActive:array<boolean>,measurements:array<struct<value:double,dimensionType:int,dimensionCode:string,dimensionCodeUuid:string,isoCode:string>>,optimizationGroups:array<string>>

(28) ColumnarToRow [codegen id : 6]
Input [14]: [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066, shardId#893067, sequenceId#893045]

(29) Filter [codegen id : 6]
Input [14]: [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066, shardId#893067, sequenceId#893045]
Condition : isnotnull(worklistShardItemId#893046L)

(30) Project [codegen id : 6]
Output [12]: [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066]
Input [14]: [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066, shardId#893067, sequenceId#893045]

(31) Exchange
Input [12]: [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066]
Arguments: hashpartitioning(worklistShardItemId#893046L, 20), REPARTITION_BY_NUM, [plan_id=348680]

(32) Project [codegen id : 7]
Output [12]: [worklistShardItemId#893046L, orderProposalId#893023L, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, measurements#893064, constraintLabels#893054, constraintOperators#893055, constraintRanks#893057, constraintValues#893056, constraintIsActive#893058, logisticUnits#893050, optimizationGroups#893066]
Input [12]: [orderProposalId#893023L, worklistShardItemId#893046L, logisticUnits#893050, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, constraintLabels#893054, constraintOperators#893055, constraintValues#893056, constraintRanks#893057, constraintIsActive#893058, measurements#893064, optimizationGroups#893066]

(33) BroadcastExchange
Input [12]: [worklistShardItemId#893046L, orderProposalId#893023L, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, measurements#893064, constraintLabels#893054, constraintOperators#893055, constraintRanks#893057, constraintValues#893056, constraintIsActive#893058, logisticUnits#893050, optimizationGroups#893066]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=348684]

(34) BroadcastHashJoin [codegen id : 8]
Left keys [1]: [worklistShardItemId#892688L]
Right keys [1]: [worklistShardItemId#893046L]
Join type: LeftOuter
Join condition: (shardId#892679 = 0_1_10000002109)

(35) Project [codegen id : 8]
Output [15]: [shardId#892679, worklistShardItemId#892688L, quantities#892883, kpis#892892, constraintValues#893056, constraintOperators#893055, constraintLabels#893054, constraintRanks#893057, constraintIsActive#893058, orderProposalId#893023L, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, logisticUnits#893050, optimizationGroups#893066, measurements#893064]
Input [16]: [shardId#892679, worklistShardItemId#892688L, quantities#892883, kpis#892892, worklistShardItemId#893046L, orderProposalId#893023L, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, measurements#893064, constraintLabels#893054, constraintOperators#893055, constraintRanks#893057, constraintValues#893056, constraintIsActive#893058, logisticUnits#893050, optimizationGroups#893066]

(36) ObjectHashAggregate
Input [15]: [shardId#892679, worklistShardItemId#892688L, quantities#892883, kpis#892892, constraintValues#893056, constraintOperators#893055, constraintLabels#893054, constraintRanks#893057, constraintIsActive#893058, orderProposalId#893023L, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid#893052, logisticUnits#893050, optimizationGroups#893066, measurements#893064]
Keys [2]: [shardId#892679, orderProposalId#893023L]
Functions [1]: [partial_collect_list(struct(worklistShardItemId, worklistShardItemId#892688L, quantities, quantities#892883, kpis, kpis#892892, constraintValues, constraintValues#893056, constraintOperators, constraintOperators#893055, constraintLabels, constraintLabels#893054, constraintRanks, constraintRanks#893057, constraintIsActive, constraintIsActive#893058, orderQuantityBaseUom, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#893052, logisticUnits, logisticUnits#893050, optimizationGroups, optimizationGroups#893066, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [buf#893515]
Results [3]: [shardId#892679, orderProposalId#893023L, buf#893516]

(37) Exchange
Input [3]: [shardId#892679, orderProposalId#893023L, buf#893516]
Arguments: hashpartitioning(shardId#892679, orderProposalId#893023L, 20), ENSURE_REQUIREMENTS, [plan_id=348690]

(38) ObjectHashAggregate
Input [3]: [shardId#892679, orderProposalId#893023L, buf#893516]
Keys [2]: [shardId#892679, orderProposalId#893023L]
Functions [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#892688L, quantities, quantities#892883, kpis, kpis#892892, constraintValues, constraintValues#893056, constraintOperators, constraintOperators#893055, constraintLabels, constraintLabels#893054, constraintRanks, constraintRanks#893057, constraintIsActive, constraintIsActive#893058, orderQuantityBaseUom, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#893052, logisticUnits, logisticUnits#893050, optimizationGroups, optimizationGroups#893066, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#892688L, quantities, quantities#892883, kpis, kpis#892892, constraintValues, constraintValues#893056, constraintOperators, constraintOperators#893055, constraintLabels, constraintLabels#893054, constraintRanks, constraintRanks#893057, constraintIsActive, constraintIsActive#893058, orderQuantityBaseUom, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#893052, logisticUnits, logisticUnits#893050, optimizationGroups, optimizationGroups#893066, measurements, ... 1 more fields), 0, 0)#893172]
Results [3]: [shardId#892679, orderProposalId#893023L, collect_list(struct(worklistShardItemId, worklistShardItemId#892688L, quantities, quantities#892883, kpis, kpis#892892, constraintValues, constraintValues#893056, constraintOperators, constraintOperators#893055, constraintLabels, constraintLabels#893054, constraintRanks, constraintRanks#893057, constraintIsActive, constraintIsActive#893058, orderQuantityBaseUom, orderQuantityBaseUom#893051, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#893052, logisticUnits, logisticUnits#893050, optimizationGroups, optimizationGroups#893066, measurements, ... 1 more fields), 0, 0)#893172 AS items#893156]

(39) Scan parquet 
Output [4]: [orderProposalId#893176L, optimizationGroups#893178, shardId#893179, sequenceId#893177]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000002109]
PartitionFilters: [isnotnull(shardId#893179), isnotnull(sequenceId#893177), (shardId#893179 = 0_1_10000002109), (sequenceId#893177 = 2)]
PushedFilters: [IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,optimizationGroups:array<struct<optGroupId:string,assignmentDetails:string,minOrderProfile:string,multiplerestrictionprofile:string,minOrderGoal:struct<minOrderValue:double,dimensionType:int,unit:string,unitUuid:string,negligibleQuantitiesThreshold:double,acceptanceThreshold:double,isoCode:string>>>>

(40) ColumnarToRow [codegen id : 9]
Input [4]: [orderProposalId#893176L, optimizationGroups#893178, shardId#893179, sequenceId#893177]

(41) Filter [codegen id : 9]
Input [4]: [orderProposalId#893176L, optimizationGroups#893178, shardId#893179, sequenceId#893177]
Condition : isnotnull(orderProposalId#893176L)

(42) Project [codegen id : 9]
Output [3]: [orderProposalId#893176L, sequenceId#893177, optimizationGroups#893178]
Input [4]: [orderProposalId#893176L, optimizationGroups#893178, shardId#893179, sequenceId#893177]

(43) Exchange
Input [3]: [orderProposalId#893176L, sequenceId#893177, optimizationGroups#893178]
Arguments: hashpartitioning(orderProposalId#893176L, 20), REPARTITION_BY_NUM, [plan_id=348698]

(44) Project
Output [3]: [orderProposalId#893176L, transform(optimizationGroups#893178, lambdafunction(if (isnull(lambda x_110#893182)) null else named_struct(optGroupId, lambda x_110#893182.optGroupId, assignmentDetails, lambda x_110#893182.assignmentDetails, minOrderProfile, lambda x_110#893182.minOrderProfile, minOrderGoal, if (isnull(lambda x_110#893182.minOrderGoal)) null else named_struct(minOrderValue, lambda x_110#893182.minOrderGoal.minOrderValue, dimensionType, lambda x_110#893182.minOrderGoal.dimensionType, unit, lambda x_110#893182.minOrderGoal.unit, unitUuid, lambda x_110#893182.minOrderGoal.unitUuid, isoCode, lambda x_110#893182.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_110#893182.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_110#893182.minOrderGoal.acceptanceThreshold), multiplerestrictionprofile, lambda x_110#893182.multiplerestrictionprofile), lambda x_110#893182, false)) AS optimizationGroups#893185, sequenceId#893177]
Input [3]: [orderProposalId#893176L, sequenceId#893177, optimizationGroups#893178]

(45) BroadcastExchange
Input [3]: [orderProposalId#893176L, optimizationGroups#893185, sequenceId#893177]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=348700]

(46) BroadcastHashJoin [codegen id : 11]
Left keys [1]: [orderProposalId#893023L]
Right keys [1]: [orderProposalId#893176L]
Join type: LeftOuter
Join condition: (shardId#892679 = 0_1_10000002109)

(47) Project [codegen id : 11]
Output [5]: [shardId#892679, orderProposalId#893023L, items#893156, optimizationGroups#893185, sequenceId#893177]
Input [6]: [shardId#892679, orderProposalId#893023L, items#893156, orderProposalId#893176L, optimizationGroups#893185, sequenceId#893177]

(48) Scan parquet 
Output [3]: [uomCategories#893189, insightConfigurations#893190, shardId#893191]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000002109]
PartitionFilters: [isnotnull(shardId#893191), (shardId#893191 = 0_1_10000002109)]
ReadSchema: struct<uomCategories:array<struct<uomCategoryName:string,uoms:array<struct<uom:string,uomUuid:string>>>>,insightConfigurations:map<string,struct<configurationVersion:string,name:string,settings:array<struct<name:string,type:string,value:string>>,status:string>>>

(49) ColumnarToRow [codegen id : 10]
Input [3]: [uomCategories#893189, insightConfigurations#893190, shardId#893191]

(50) Project [codegen id : 10]
Output [2]: [uomCategories#893189, insightConfigurations#893190]
Input [3]: [uomCategories#893189, insightConfigurations#893190, shardId#893191]

(51) Exchange
Input [2]: [uomCategories#893189, insightConfigurations#893190]
Arguments: RoundRobinPartitioning(20), REPARTITION_BY_NUM, [plan_id=348708]

(52) BroadcastExchange
Input [2]: [uomCategories#893189, insightConfigurations#893190]
Arguments: IdentityBroadcastMode, [plan_id=348709]

(53) BroadcastNestedLoopJoin [codegen id : 11]
Join type: LeftOuter
Join condition: (shardId#892679 = 0_1_10000002109)

(54) DeserializeToObject
Input [7]: [shardId#892679, orderProposalId#893023L, items#893156, optimizationGroups#893185, sequenceId#893177, uomCategories#893189, insightConfigurations#893190]
Arguments: createexternalrow(invoke(shardId#892679.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#893023L)), mapobjects(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1), createexternalrow(static_invoke(java.lang.Long.valueOf(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).worklistShardItemId)), mapobjects(lambdavariable(MapObject, DoubleType, true, -2), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -2))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).quantities, Some(class scala.collection.mutable.ArraySeq)), createexternalrow(mapobjects(lambdavariable(MapObject, DoubleType, true, -3), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -3))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.EndOfPeriodVirtualStockQty, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -4), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -4))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.OutOfStockProbability, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -5), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -5))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.RangeOfCoverage, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -6), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -6))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.RemainingStockQty, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -7), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -7))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.ServiceLevel, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -8), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -8))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.ServiceLevelAtStartOfDelisting, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -9), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -9))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.ServiceLevelMinimumStock, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -10), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -10))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).kpis.UnfulfilledDemandQty, Some(class scala.collection.mutable.ArraySeq)), StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false), StructField(OutOfStockProbability,ArrayType(DoubleType,true),false), StructField(RangeOfCoverage,ArrayType(DoubleType,true),false), StructField(RemainingStockQty,ArrayType(DoubleType,true),false), StructField(ServiceLevel,ArrayType(DoubleType,true),false), StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false), StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false), StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)), mapobjects(lambdavariable(MapObject, DoubleType, true, -11), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -11))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintValues, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StringType, true, -12), invoke(lambdavariable(MapObject, StringType, true, -12).toString()), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintOperators, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StringType, true, -13), invoke(lambdavariable(MapObject, StringType, true, -13).toString()), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintLabels, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, IntegerType, true, -14), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, IntegerType, true, -14))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintRanks, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, BooleanType, true, -15), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, BooleanType, true, -15))), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).constraintIsActive, Some(class scala.collection.mutable.ArraySeq)), invoke(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).orderQuantityBaseUom.toString()), invoke(lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).orderQuantityBaseUomUuid.toString()), mapobjects(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16), if (isnull(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).uom.toString()), invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).uomUuid.toString()), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).numerator)), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).denominator)), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).isOrderUnit)), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true), true, -16).isPreferred)), StructField(uom,StringType,true), StructField(uomUuid,StringType,true), StructField(numerator,IntegerType,true), StructField(denominator,IntegerType,true), StructField(isOrderUnit,BooleanType,true), StructField(isPreferred,BooleanType,true)), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).logisticUnits, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StringType, true, -17), invoke(lambdavariable(MapObject, StringType, true, -17).toString()), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).optimizationGroups, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18), if (isnull(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18))) null else createexternalrow(static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).value)), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).dimensionType)), invoke(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).dimensionCode.toString()), invoke(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).dimensionCodeUuid.toString()), invoke(lambdavariable(MapObject, StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true), true, -18).isoCode.toString()), StructField(value,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(dimensionCode,StringType,true), StructField(dimensionCodeUuid,StringType,true), StructField(isoCode,StringType,true)), lambdavariable(MapObject, StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true), false, -1).measurements, Some(class scala.collection.mutable.ArraySeq)), StructField(worklistShardItemId,LongType,true), StructField(quantities,ArrayType(DoubleType,true),false), StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false), StructField(constraintValues,ArrayType(DoubleType,true),true), StructField(constraintOperators,ArrayType(StringType,true),true), StructField(constraintLabels,ArrayType(StringType,true),true), StructField(constraintRanks,ArrayType(IntegerType,true),true), StructField(constraintIsActive,ArrayType(BooleanType,true),true), StructField(orderQuantityBaseUom,StringType,true), StructField(orderQuantityBaseUomUuid,StringType,true), StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true), StructField(optimizationGroups,ArrayType(StringType,true),true), ... 1 more fields), items#893156, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19), if (isnull(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).optGroupId.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).assignmentDetails.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderProfile.toString()), if (isnull(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal)) null else createexternalrow(static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.minOrderValue)), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.dimensionType)), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.unit.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.unitUuid.toString()), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.isoCode.toString()), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.negligibleQuantitiesThreshold)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).minOrderGoal.acceptanceThreshold)), StructField(minOrderValue,DoubleType,true), StructField(dimensionType,IntegerType,true), StructField(unit,StringType,true), StructField(unitUuid,StringType,true), StructField(isoCode,StringType,true), StructField(negligibleQuantitiesThreshold,DoubleType,true), StructField(acceptanceThreshold,DoubleType,true)), invoke(lambdavariable(MapObject, StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true), true, -19).multiplerestrictionprofile.toString()), StructField(optGroupId,StringType,true), StructField(assignmentDetails,StringType,true), StructField(minOrderProfile,StringType,true), StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true), StructField(multiplerestrictionprofile,StringType,true)), optimizationGroups#893185, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#893177)), mapobjects(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20), if (isnull(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20).uomCategoryName.toString()), mapobjects(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21), if (isnull(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21).uom.toString()), invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -21).uomUuid.toString()), StructField(uom,StringType,true), StructField(uomUuid,StringType,true)), lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -20).uoms, Some(class scala.collection.mutable.ArraySeq)), StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true)), uomCategories#893189, Some(class scala.collection.mutable.ArraySeq)), catalysttoexternalmap(lambdavariable(CatalystToExternalMap_key, StringType, false, -22), invoke(lambdavariable(CatalystToExternalMap_key, StringType, false, -22).toString()), lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23), if (isnull(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23))) null else createexternalrow(invoke(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).configurationVersion.toString()), invoke(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).name.toString()), mapobjects(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24), if (isnull(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24).name.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24).type.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -24).value.toString()), StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true)), lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).settings, Some(class scala.collection.mutable.ArraySeq)), invoke(lambdavariable(CatalystToExternalMap_value, StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true), true, -23).status.toString()), StructField(configurationVersion,StringType,true), StructField(name,StringType,true), StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true), StructField(status,StringType,true)), insightConfigurations#893190, interface scala.collection.Map), StructField(shardId,StringType,true), StructField(orderProposalId,LongType,true), StructField(items,ArrayType(StructType(StructField(worklistShardItemId,LongType,true),StructField(quantities,ArrayType(DoubleType,true),false),StructField(kpis,StructType(StructField(EndOfPeriodVirtualStockQty,ArrayType(DoubleType,true),false),StructField(OutOfStockProbability,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(UnfulfilledDemandQty,ArrayType(DoubleType,true),false)),false),StructField(constraintValues,ArrayType(DoubleType,true),true),StructField(constraintOperators,ArrayType(StringType,true),true),StructField(constraintLabels,ArrayType(StringType,true),true),StructField(constraintRanks,ArrayType(IntegerType,true),true),StructField(constraintIsActive,ArrayType(BooleanType,true),true),StructField(orderQuantityBaseUom,StringType,true),StructField(orderQuantityBaseUomUuid,StringType,true),StructField(logisticUnits,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true),StructField(numerator,IntegerType,true),StructField(denominator,IntegerType,true),StructField(isOrderUnit,BooleanType,true),StructField(isPreferred,BooleanType,true)),true),true),StructField(optimizationGroups,ArrayType(StringType,true),true),StructField(measurements,ArrayType(StructType(StructField(value,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(dimensionCode,StringType,true),StructField(dimensionCodeUuid,StringType,true),StructField(isoCode,StringType,true)),true),true)),false),false), StructField(optimizationGroups,ArrayType(StructType(StructField(optGroupId,StringType,true),StructField(assignmentDetails,StringType,true),StructField(minOrderProfile,StringType,true),StructField(minOrderGoal,StructType(StructField(minOrderValue,DoubleType,true),StructField(dimensionType,IntegerType,true),StructField(unit,StringType,true),StructField(unitUuid,StringType,true),StructField(isoCode,StringType,true),StructField(negligibleQuantitiesThreshold,DoubleType,true),StructField(acceptanceThreshold,DoubleType,true)),true),StructField(multiplerestrictionprofile,StringType,true)),true),true), StructField(sequenceId,IntegerType,true), StructField(uomCategories,ArrayType(StructType(StructField(uomCategoryName,StringType,true),StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true)),true),true), StructField(insightConfigurations,MapType(StringType,StructType(StructField(configurationVersion,StringType,true),StructField(name,StringType,true),StructField(settings,ArrayType(StructType(StructField(name,StringType,true),StructField(type,StringType,true),StructField(value,StringType,true)),true),true),StructField(status,StringType,true)),true),true)), obj#893209: org.apache.spark.sql.Row

(55) MapPartitions
Input [1]: [obj#893209]
Arguments: org.apache.spark.sql.internal.ToScalaUDF$$$Lambda/0x00000008021bcd18@48ffd2a5, obj#893216: org.apache.spark.sql.Row

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	6
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	20
temporal.activity.id	131fcd6d-c8ad-319b-b0d3-c5c4424561c9
temporal.activity.type	RunStreamWithId