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

Submitted Time: 2026/07/21 20:56:57
Duration: 1 s
Succeeded Jobs: 47154 47155 47156

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/0x000000080248b3a0@34218b4b, obj#5581250: org.apache.spark.sql.Row"]; 1 [id="node1" labelType="html" label=" DeserializeToObject " tooltip="DeserializeToObject createexternalrow(invoke(shardId#5580640.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5581039L)), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.PeriodSpoilageQty, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.SalesQty, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -12), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -12))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.ShelfCapacityOverrun, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -13), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -13))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.ShelfCapacityUnderrun, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -14), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.SpoilageQty, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -15), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false), StructField(RangeOfCoverage,ArrayType(DoubleType,true),false), StructField(RemainingStockQty,ArrayType(DoubleType,true),false), StructField(SalesQty,ArrayType(DoubleType,true),false), StructField(ServiceLevel,ArrayType(DoubleType,true),false), StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false), StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false), StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false), StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false), StructField(SpoilageQty,ArrayType(DoubleType,true),false), ... 1 more fields), mapobjects(lambdavariable(MapObject, DoubleType, true, -16), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -16))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -18), invoke(lambdavariable(MapObject, StringType, true, -18).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -19), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, IntegerType, true, -19))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -20), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, BooleanType, true, -20))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -21), 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, -21))) 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, -21).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, -21).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, -21).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, -21).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, -21).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, -21).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -22), invoke(lambdavariable(MapObject, StringType, true, -22).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -23), 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, -23))) 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, -23).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, -23).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, -23).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, -23).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, -23).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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#5581192, 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), true, -24), 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), true, -24))) 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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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)), 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)), optimizationGroups#5581211, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5581213)), mapobjects(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -25), if (isnull(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -25))) 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, -25).uomCategoryName.toString()), mapobjects(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26), if (isnull(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26).uom.toString()), invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26).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, -25).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#5581223, Some(class scala.collection.mutable.ArraySeq)), catalysttoexternalmap(lambdavariable(CatalystToExternalMap_key, StringType, false, -27), invoke(lambdavariable(CatalystToExternalMap_key, StringType, false, -27).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, -28), 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, -28))) 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, -28).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, -28).name.toString()), mapobjects(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29), if (isnull(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29).name.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29).type.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29).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, -28).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, -28).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#5581224, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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)),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#5581243: 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#5580640 = 0_1_10000001445)"]; 4 [id="node4" labelType="html" label=" Project " tooltip="Project [shardId#5580640, orderProposalId#5581039L, items#5581192, optimizationGroups#5581211, sequenceId#5581213]"]; 5 [id="node5" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [orderProposalId#5581039L], [orderProposalId#5581212L], LeftOuter, BuildRight, (shardId#5580640 = 0_1_10000001445), false"]; } 6 [id="node6" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5580640, orderProposalId#5581039L], functions=[collect_list(struct(worklistShardItemId, worklistShardItemId#5580649L, quantities, quantities#5580874, kpis, kpis#5580888, constraintValues, constraintValues#5581072, constraintOperators, constraintOperators#5581071, constraintLabels, constraintLabels#5581070, constraintRanks, constraintRanks#5581073, constraintIsActive, constraintIsActive#5581074, orderQuantityBaseUom, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5581068, logisticUnits, logisticUnits#5581066, optimizationGroups, optimizationGroups#5581082, measurements, ... 1 more fields), 0, 0)])"]; 7 [id="node7" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5580640, orderProposalId#5581039L, 30), ENSURE_REQUIREMENTS, [plan_id=2893961]"]; 8 [id="node8" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5580640, orderProposalId#5581039L], functions=[partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5580649L, quantities, quantities#5580874, kpis, kpis#5580888, constraintValues, constraintValues#5581072, constraintOperators, constraintOperators#5581071, constraintLabels, constraintLabels#5581070, constraintRanks, constraintRanks#5581073, constraintIsActive, constraintIsActive#5581074, orderQuantityBaseUom, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5581068, logisticUnits, logisticUnits#5581066, optimizationGroups, optimizationGroups#5581082, 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#5580640, worklistShardItemId#5580649L, quantities#5580874, kpis#5580888, constraintValues#5581072, constraintOperators#5581071, constraintLabels#5581070, constraintRanks#5581073, constraintIsActive#5581074, orderProposalId#5581039L, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, logisticUnits#5581066, optimizationGroups#5581082, measurements#5581080]"]; 11 [id="node11" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#5580649L], [worklistShardItemId#5581062L], LeftOuter, BuildRight, (shardId#5580640 = 0_1_10000001445), false"]; 12 [id="node12" labelType="html" label=" Project " tooltip="Project [shardId#5580640, worklistShardItemId#5580649L, struct_array#5580853.qty AS quantities#5580874, struct(EndOfPeriodVirtualStockQty, struct_array#5580853.kpi:EndOfPeriodVirtualStockQty, OutOfStockProbability, struct_array#5580853.kpi:OutOfStockProbability, PeriodSpoilageQty, struct_array#5580853.kpi:PeriodSpoilageQty, RangeOfCoverage, struct_array#5580853.kpi:RangeOfCoverage, RemainingStockQty, struct_array#5580853.kpi:RemainingStockQty, SalesQty, struct_array#5580853.kpi:SalesQty, ServiceLevel, struct_array#5580853.kpi:ServiceLevel, ServiceLevelAtStartOfDelisting, struct_array#5580853.kpi:ServiceLevelAtStartOfDelisting, ServiceLevelMinimumStock, struct_array#5580853.kpi:ServiceLevelMinimumStock, ShelfCapacityOverrun, struct_array#5580853.kpi:ShelfCapacityOverrun, ShelfCapacityUnderrun, struct_array#5580853.kpi:ShelfCapacityUnderrun, SpoilageQty, struct_array#5580853.kpi:SpoilageQty, UnfulfilledDemandQty, ... 1 more fields) AS kpis#5580888]"]; } 13 [id="node13" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5580640, worklistShardItemId#5580649L], functions=[max(struct#5580852.qty), collect_list(struct#5580852, 0, 0)])"]; 14 [id="node14" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5580640, worklistShardItemId#5580649L], functions=[partial_max(struct#5580852.qty), partial_collect_list(struct#5580852, 0, 0)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [shardId#5580640, worklistShardItemId#5580649L, struct(qty, qty#5580711, kpi:EndOfPeriodVirtualStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[0], kpi:OutOfStockProbability, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[1], kpi:PeriodSpoilageQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[2], kpi:RangeOfCoverage, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[3], kpi:RemainingStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[4], kpi:SalesQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[5], kpi:ServiceLevel, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[6], kpi:ServiceLevelAtStartOfDelisting, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[7], kpi:ServiceLevelMinimumStock, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[8], kpi:ShelfCapacityOverrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[9], kpi:ShelfCapacityUnderrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[10], kpi:SpoilageQty, ... 3 more fields) AS struct#5580852]"]; } 17 [id="node17" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5580640, worklistShardItemId#5580649L, qty#5580711], functions=[pivotfirst(label#5580718, max(kpi.`value` AS value)#5580784, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:PeriodSpoilageQty, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:SalesQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:ShelfCapacityOverrun, kpi:ShelfCapacityUnderrun, kpi:SpoilageQty, kpi:UnfulfilledDemandQty, 0, 0)])"]; 18 [id="node18" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5580640, worklistShardItemId#5580649L, knownfloatingpointnormalized(normalizenanandzero(qty#5580711)) AS qty#5580711], functions=[partial_pivotfirst(label#5580718, max(kpi.`value` AS value)#5580784, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:PeriodSpoilageQty, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:SalesQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:ShelfCapacityOverrun, kpi:ShelfCapacityUnderrun, kpi:SpoilageQty, 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#5580640, worklistShardItemId#5580649L, qty#5580711, label#5580718], functions=[max(_extract_value#5581348)])"]; 21 [id="node21" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5580640, worklistShardItemId#5580649L, knownfloatingpointnormalized(normalizenanandzero(qty#5580711)) AS qty#5580711, label#5580718], functions=[partial_max(_extract_value#5581348)])"]; 22 [id="node22" labelType="html" label=" Project " tooltip="Project [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, kpi#5580717.value AS _extract_value#5581348, concat(kpi:, kpi#5580717.label) AS label#5580718]"]; 23 [id="node23" labelType="html" label=" Generate " tooltip="Generate explode(kpis#5580715), [shardId#5580640, worklistShardItemId#5580649L, qty#5580711], true, [kpi#5580717]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, coalesce(kpis#5580714, []) AS kpis#5580715]"]; 25 [id="node25" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#5580709, worklistShardItemId#5580710L], [shardId#5580640, worklistShardItemId#5580649L], RightOuter"]; } subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 27 [id="node27" labelType="html" label=" Sort " tooltip="Sort [shardId#5580709 ASC NULLS FIRST, worklistShardItemId#5580710L ASC NULLS FIRST], false, 0"]; } 28 [id="node28" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5580709, worklistShardItemId#5580710L, 30), ENSURE_REQUIREMENTS, [plan_id=2893921]"]; subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 30 [id="node30" labelType="html" label=" Project " tooltip="Project [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, kpis#5580714]"]; 31 [id="node31" labelType="html" label=" Filter " tooltip="Filter (isnotnull(qty#5580711) AND (isnotnull(shardId#5580709) AND isnotnull(worklistShardItemId#5580710L)))"]; 32 [id="node32" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5580709,worklistShardItemId#5580710L,qty#5580711,demandChannel#5580712,demandStream#5580713,kpis#5580714]"]; } subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 34 [id="node34" labelType="html" label=" Sort " tooltip="Sort [shardId#5580640 ASC NULLS FIRST, worklistShardItemId#5580649L ASC NULLS FIRST], false, 0"]; } 35 [id="node35" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5580640, worklistShardItemId#5580649L, 30), ENSURE_REQUIREMENTS, [plan_id=2893862]"]; 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#5580640, worklistShardItemId#5580649L]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Project " tooltip="Project [shardId#5580640, item#5580648L AS worklistShardItemId#5580649L]"]; 39 [id="node39" labelType="html" label=" Generate " tooltip="Generate explode(_extract_worklistShardItemId#5580652), [shardId#5580640], false, [item#5580648L]"]; 40 [id="node40" labelType="html" label=" Project " tooltip="Project [shardId#5580640, items#5580642.worklistShardItemId AS _extract_worklistShardItemId#5580652]"]; 41 [id="node41" labelType="html" label=" Filter " tooltip="Filter ((isnotnull(shardId#5580640) AND ((shardId#5580640 = 0_1_10000001445) AND (isOptimal#5580644 <=> false))) AND ((size(items#5580642.worklistShardItemId, true) > 0) AND isnotnull(items#5580642.worklistShardItemId)))"]; 42 [id="node42" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5580640,orderProposalId#5580641L,items#5580642,optimizationGroups#5580643,isOptimal#5580644,lastModified#5580645,optimizationInsights#5580646]"]; } 43 [id="node43" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 255 ms number of output rows: 29 data size: 1030.4 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2893955]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n6 ms (0 ms, 0 ms, 3 ms (stage 1334790.0: task 2483478))"; tooltip="WholeStageCodegen (7)"; 45 [id="node45" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#5581062L, orderProposalId#5581039L, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, measurements#5581080, constraintLabels#5581070, constraintOperators#5581071, constraintRanks#5581073, constraintValues#5581072, constraintIsActive#5581074, logisticUnits#5581066, optimizationGroups#5581082]"]; } 46 [id="node46" labelType="html" label="Exchange shuffle records written: 29 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 29 local bytes read total (min, med, max (stageId: taskId)) 14.0 KiB (510.0 B, 558.0 B, 1115.0 B (stage 1334790.0: task 2483475)) merged fetch fallback count: 0 local blocks read: 24 remote merged chunks fetched: 0 remote blocks read: 3 data size total (min, med, max (stageId: taskId)) 24.2 KiB (808.0 B, 1616.0 B, 2.7 KiB (stage 1334789.0: task 2483383)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 8 ms (0 ms, 0 ms, 0 ms (stage 1334789.0: task 2483384)) 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)) 4 ms (0 ms, 0 ms, 2 ms (stage 1334790.0: task 2483478)) remote bytes read total (min, med, max (stageId: taskId)) 1977.0 B (553.0 B, 702.0 B, 722.0 B (stage 1334790.0: task 2483478)) number of partitions: 30 remote reqs duration total (min, med, max (stageId: taskId)) 6 ms (0 ms, 3 ms, 3 ms (stage 1334790.0: task 2483478)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 16.0 KiB (553.0 B, 722.0 B, 1841.0 B (stage 1334789.0: task 2483384))" tooltip="Exchange hashpartitioning(worklistShardItemId#5581062L, 30), REPARTITION_BY_NUM, [plan_id=2893951]"]; subgraph cluster47 { isCluster="true"; id="cluster47"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n1.7 s (79 ms, 103 ms, 126 ms (stage 1334789.0: task 2483385))"; tooltip="WholeStageCodegen (6)"; 48 [id="node48" labelType="html" label=" Project " tooltip="Project [orderProposalId#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082]"]; 49 [id="node49" labelType="html" label="Filter number of output rows: 29" tooltip="Filter isnotnull(worklistShardItemId#5581062L)"]; 50 [id="node50" labelType="html" label="ColumnarToRow number of output rows: 29 number of input batches: 17" tooltip="ColumnarToRow"]; } 51 [id="node51" labelType="html" label="Scan parquet number of files read: 17 scan time total (min, med, max (stageId: taskId)) 1.7 s (78 ms, 102 ms, 125 ms (stage 1334789.0: task 2483385)) dynamic partition pruning time: 0 ms metadata time: 0 ms size of files read: 319.0 KiB number of output rows: 29 number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#5581039L,worklistShardItemId#5581062L,logisticUnits#5581066,orderQuantityBaseUom#5581067,orderQuantityBaseUomUuid#5581068,constraintLabels#5581070,constraintOperators#5581071,constraintValues#5581072,constraintRanks#5581073,constraintIsActive#5581074,measurements#5581080,optimizationGroups#5581082,shardId#5581083,sequenceId#5581061] Batched: true, DataFilters: [isnotnull(worklistShardItemId#5581062L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5581083), isnotnull(sequenceId#5581061), (shardId#5581083 = 0_1_10000001445), ..., 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: 206 ms number of output rows: 2 data size: 1024.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2893971]"]; 53 [id="node53" labelType="html" label=" Project " tooltip="Project [orderProposalId#5581212L, transform(optimizationGroups#5581214, lambdafunction(if (isnull(lambda x_1068#5581218)) null else named_struct(optGroupId, lambda x_1068#5581218.optGroupId, assignmentDetails, lambda x_1068#5581218.assignmentDetails, minOrderProfile, lambda x_1068#5581218.minOrderProfile, minOrderGoal, if (isnull(lambda x_1068#5581218.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1068#5581218.minOrderGoal.minOrderValue, dimensionType, lambda x_1068#5581218.minOrderGoal.dimensionType, unit, lambda x_1068#5581218.minOrderGoal.unit, unitUuid, lambda x_1068#5581218.minOrderGoal.unitUuid, isoCode, lambda x_1068#5581218.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1068#5581218.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1068#5581218.minOrderGoal.acceptanceThreshold)), lambda x_1068#5581218, false)) AS optimizationGroups#5581211, sequenceId#5581213]"]; 54 [id="node54" labelType="html" label="Exchange shuffle records written: 2 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 2 local bytes read total (min, med, max (stageId: taskId)) 188.0 B (94.0 B, 94.0 B, 94.0 B (stage 1334786.0: task 2483431)) merged fetch fallback count: 0 local blocks read: 2 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 80.0 B (40.0 B, 40.0 B, 40.0 B (stage 1334785.0: task 2483380)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 1334785.0: task 2483380)) 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 1334786.0: task 2483431)) remote bytes read: 0.0 B number of partitions: 30 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 188.0 B (94.0 B, 94.0 B, 94.0 B (stage 1334785.0: task 2483380))" tooltip="Exchange hashpartitioning(orderProposalId#5581212L, 30), REPARTITION_BY_NUM, [plan_id=2893969]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n232 ms (106 ms, 126 ms, 126 ms (stage 1334785.0: task 2483381))"; tooltip="WholeStageCodegen (9)"; 56 [id="node56" labelType="html" label=" Project " tooltip="Project [orderProposalId#5581212L, sequenceId#5581213, optimizationGroups#5581214]"]; 57 [id="node57" labelType="html" label="Filter number of output rows: 2" tooltip="Filter isnotnull(orderProposalId#5581212L)"]; 58 [id="node58" labelType="html" label="ColumnarToRow number of output rows: 2 number of input batches: 2" tooltip="ColumnarToRow"]; } 59 [id="node59" labelType="html" label="Scan parquet number of files read: 2 scan time total (min, med, max (stageId: taskId)) 210 ms (105 ms, 105 ms, 105 ms (stage 1334785.0: task 2483380)) dynamic partition pruning time: 0 ms metadata time: 0 ms size of files read: 7.4 KiB number of output rows: 2 number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#5581212L,optimizationGroups#5581214,shardId#5581215,sequenceId#5581213] Batched: true, DataFilters: [isnotnull(orderProposalId#5581212L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5581215), isnotnull(sequenceId#5581213), (shardId#5581215 = 0_1_10000001445), ..., PushedFilters: [IsNotNull(orderProposalId)], ReadSchema: struct<orderProposalId:bigint,optimizationGroups:array<struct<optGroupId:string,minOrderProfile:s..."]; 60 [id="node60" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 159 ms number of output rows: 1 data size: 1288.0 B" tooltip="BroadcastExchange IdentityBroadcastMode, [plan_id=2893980]"]; 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: 851.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 1288.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: 30 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 851.0 B" tooltip="Exchange RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=2893979]"]; subgraph cluster62 { isCluster="true"; id="cluster62"; label="WholeStageCodegen (10)\n \nduration: 87 ms"; tooltip="WholeStageCodegen (10)"; 63 [id="node63" labelType="html" label=" Project " tooltip="Project [uomCategories#5581223, insightConfigurations#5581224]"]; 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: 82 ms dynamic partition pruning time: 0 ms metadata time: 0 ms size of files read: 5.0 KiB number of output rows: 1 number of partitions read: 1" tooltip="FileScan parquet [uomCategories#5581223,insightConfigurations#5581224,shardId#5581225] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5581225), (shardId#5581225 = 0_1_10000001445)], 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#5580709, worklistShardItemId#5580710L, qty#5580711, demandChannel#5580712, demandStream#5580713, kpis#5580714]
Arguments: [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, demandChannel#5580712, demandStream#5580713, kpis#5580714], MapPartitionsRDD[393332] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(2) Filter [codegen id : 1]
Input [6]: [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, demandChannel#5580712, demandStream#5580713, kpis#5580714]
Condition : (isnotnull(qty#5580711) AND (isnotnull(shardId#5580709) AND isnotnull(worklistShardItemId#5580710L)))

(3) Project [codegen id : 1]
Output [4]: [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, kpis#5580714]
Input [6]: [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, demandChannel#5580712, demandStream#5580713, kpis#5580714]

(4) Exchange
Input [4]: [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, kpis#5580714]
Arguments: hashpartitioning(shardId#5580709, worklistShardItemId#5580710L, 30), ENSURE_REQUIREMENTS, [plan_id=2893921]

(5) Sort [codegen id : 2]
Input [4]: [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, kpis#5580714]
Arguments: [shardId#5580709 ASC NULLS FIRST, worklistShardItemId#5580710L ASC NULLS FIRST], false, 0

(6) InMemoryTableScan
Output [2]: [shardId#5580640, worklistShardItemId#5580649L]
Arguments: [shardId#5580640, worklistShardItemId#5580649L]

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

(8) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#5580640, orderProposalId#5580641L, items#5580642, optimizationGroups#5580643, isOptimal#5580644, lastModified#5580645, optimizationInsights#5580646]
Arguments: [shardId#5580640, orderProposalId#5580641L, items#5580642, optimizationGroups#5580643, isOptimal#5580644, lastModified#5580645, optimizationInsights#5580646], MapPartitionsRDD[393320] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(9) Filter [codegen id : 1]
Input [7]: [shardId#5580640, orderProposalId#5580641L, items#5580642, optimizationGroups#5580643, isOptimal#5580644, lastModified#5580645, optimizationInsights#5580646]
Condition : ((isnotnull(shardId#5580640) AND ((shardId#5580640 = 0_1_10000001445) AND (isOptimal#5580644 <=> false))) AND ((size(items#5580642.worklistShardItemId, true) > 0) AND isnotnull(items#5580642.worklistShardItemId)))

(10) Project [codegen id : 1]
Output [2]: [shardId#5580640, items#5580642.worklistShardItemId AS _extract_worklistShardItemId#5580652]
Input [7]: [shardId#5580640, orderProposalId#5580641L, items#5580642, optimizationGroups#5580643, isOptimal#5580644, lastModified#5580645, optimizationInsights#5580646]

(11) Generate [codegen id : 1]
Input [2]: [shardId#5580640, _extract_worklistShardItemId#5580652]
Arguments: explode(_extract_worklistShardItemId#5580652), [shardId#5580640], false, [item#5580648L]

(12) Project [codegen id : 1]
Output [2]: [shardId#5580640, item#5580648L AS worklistShardItemId#5580649L]
Input [2]: [shardId#5580640, item#5580648L]

(13) Exchange
Input [2]: [shardId#5580640, worklistShardItemId#5580649L]
Arguments: hashpartitioning(shardId#5580640, worklistShardItemId#5580649L, 30), ENSURE_REQUIREMENTS, [plan_id=2893862]

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

(15) SortMergeJoin [codegen id : 4]
Left keys [2]: [shardId#5580709, worklistShardItemId#5580710L]
Right keys [2]: [shardId#5580640, worklistShardItemId#5580649L]
Join type: RightOuter
Join condition: None

(16) Project [codegen id : 4]
Output [4]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, coalesce(kpis#5580714, []) AS kpis#5580715]
Input [6]: [shardId#5580709, worklistShardItemId#5580710L, qty#5580711, kpis#5580714, shardId#5580640, worklistShardItemId#5580649L]

(17) Generate [codegen id : 4]
Input [4]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, kpis#5580715]
Arguments: explode(kpis#5580715), [shardId#5580640, worklistShardItemId#5580649L, qty#5580711], true, [kpi#5580717]

(18) Project [codegen id : 4]
Output [5]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, kpi#5580717.value AS _extract_value#5581348, concat(kpi:, kpi#5580717.label) AS label#5580718]
Input [4]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, kpi#5580717]

(19) HashAggregate [codegen id : 4]
Input [5]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, _extract_value#5581348, label#5580718]
Keys [4]: [shardId#5580640, worklistShardItemId#5580649L, knownfloatingpointnormalized(normalizenanandzero(qty#5580711)) AS qty#5580711, label#5580718]
Functions [1]: [partial_max(_extract_value#5581348)]
Aggregate Attributes [1]: [max#5581575]
Results [5]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, label#5580718, max#5581576]

(20) HashAggregate [codegen id : 4]
Input [5]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, label#5580718, max#5581576]
Keys [4]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, label#5580718]
Functions [1]: [max(_extract_value#5581348)]
Aggregate Attributes [1]: [max(_extract_value#5581348)#5580783]
Results [5]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, label#5580718, max(_extract_value#5581348)#5580783 AS max(kpi.`value` AS value)#5580784]

(21) HashAggregate
Input [5]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, label#5580718, max(kpi.`value` AS value)#5580784]
Keys [3]: [shardId#5580640, worklistShardItemId#5580649L, knownfloatingpointnormalized(normalizenanandzero(qty#5580711)) AS qty#5580711]
Functions [1]: [partial_pivotfirst(label#5580718, max(kpi.`value` AS value)#5580784, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:PeriodSpoilageQty, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:SalesQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:ShelfCapacityOverrun, kpi:ShelfCapacityUnderrun, kpi:SpoilageQty, kpi:UnfulfilledDemandQty, 0, 0)]
Aggregate Attributes [13]: [kpi:EndOfPeriodVirtualStockQty#5580785, kpi:OutOfStockProbability#5580786, kpi:PeriodSpoilageQty#5580787, kpi:RangeOfCoverage#5580788, kpi:RemainingStockQty#5580789, kpi:SalesQty#5580790, kpi:ServiceLevel#5580791, kpi:ServiceLevelAtStartOfDelisting#5580792, kpi:ServiceLevelMinimumStock#5580793, kpi:ShelfCapacityOverrun#5580794, kpi:ShelfCapacityUnderrun#5580795, kpi:SpoilageQty#5580796, kpi:UnfulfilledDemandQty#5580797]
Results [16]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, kpi:EndOfPeriodVirtualStockQty#5580798, kpi:OutOfStockProbability#5580799, kpi:PeriodSpoilageQty#5580800, kpi:RangeOfCoverage#5580801, kpi:RemainingStockQty#5580802, kpi:SalesQty#5580803, kpi:ServiceLevel#5580804, kpi:ServiceLevelAtStartOfDelisting#5580805, kpi:ServiceLevelMinimumStock#5580806, kpi:ShelfCapacityOverrun#5580807, kpi:ShelfCapacityUnderrun#5580808, kpi:SpoilageQty#5580809, kpi:UnfulfilledDemandQty#5580810]

(22) HashAggregate
Input [16]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, kpi:EndOfPeriodVirtualStockQty#5580798, kpi:OutOfStockProbability#5580799, kpi:PeriodSpoilageQty#5580800, kpi:RangeOfCoverage#5580801, kpi:RemainingStockQty#5580802, kpi:SalesQty#5580803, kpi:ServiceLevel#5580804, kpi:ServiceLevelAtStartOfDelisting#5580805, kpi:ServiceLevelMinimumStock#5580806, kpi:ShelfCapacityOverrun#5580807, kpi:ShelfCapacityUnderrun#5580808, kpi:SpoilageQty#5580809, kpi:UnfulfilledDemandQty#5580810]
Keys [3]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711]
Functions [1]: [pivotfirst(label#5580718, max(kpi.`value` AS value)#5580784, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:PeriodSpoilageQty, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:SalesQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:ShelfCapacityOverrun, kpi:ShelfCapacityUnderrun, kpi:SpoilageQty, kpi:UnfulfilledDemandQty, 0, 0)]
Aggregate Attributes [1]: [pivotfirst(label#5580718, max(kpi.`value` AS value)#5580784, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:PeriodSpoilageQty, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:SalesQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:ShelfCapacityOverrun, kpi:ShelfCapacityUnderrun, kpi:SpoilageQty, kpi:UnfulfilledDemandQty, 0, 0)#5580811]
Results [4]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, pivotfirst(label#5580718, max(kpi.`value` AS value)#5580784, kpi:EndOfPeriodVirtualStockQty, kpi:OutOfStockProbability, kpi:PeriodSpoilageQty, kpi:RangeOfCoverage, kpi:RemainingStockQty, kpi:SalesQty, kpi:ServiceLevel, kpi:ServiceLevelAtStartOfDelisting, kpi:ServiceLevelMinimumStock, kpi:ShelfCapacityOverrun, kpi:ShelfCapacityUnderrun, kpi:SpoilageQty, kpi:UnfulfilledDemandQty, 0, 0)#5580811 AS __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812]

(23) Project [codegen id : 5]
Output [3]: [shardId#5580640, worklistShardItemId#5580649L, struct(qty, qty#5580711, kpi:EndOfPeriodVirtualStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[0], kpi:OutOfStockProbability, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[1], kpi:PeriodSpoilageQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[2], kpi:RangeOfCoverage, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[3], kpi:RemainingStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[4], kpi:SalesQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[5], kpi:ServiceLevel, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[6], kpi:ServiceLevelAtStartOfDelisting, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[7], kpi:ServiceLevelMinimumStock, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[8], kpi:ShelfCapacityOverrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[9], kpi:ShelfCapacityUnderrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812[10], kpi:SpoilageQty, ... 3 more fields) AS struct#5580852]
Input [4]: [shardId#5580640, worklistShardItemId#5580649L, qty#5580711, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5580812]

(24) ObjectHashAggregate
Input [3]: [shardId#5580640, worklistShardItemId#5580649L, struct#5580852]
Keys [2]: [shardId#5580640, worklistShardItemId#5580649L]
Functions [2]: [partial_max(struct#5580852.qty), partial_collect_list(struct#5580852, 0, 0)]
Aggregate Attributes [2]: [max#5581571, buf#5581572]
Results [4]: [shardId#5580640, worklistShardItemId#5580649L, max#5581573, buf#5581574]

(25) ObjectHashAggregate
Input [4]: [shardId#5580640, worklistShardItemId#5580649L, max#5581573, buf#5581574]
Keys [2]: [shardId#5580640, worklistShardItemId#5580649L]
Functions [2]: [max(struct#5580852.qty), collect_list(struct#5580852, 0, 0)]
Aggregate Attributes [2]: [max(struct#5580852.qty)#5580872, collect_list(struct#5580852, 0, 0)#5580873]
Results [3]: [shardId#5580640, worklistShardItemId#5580649L, sort_array(CASE WHEN isnull(max(struct#5580852.qty)#5580872) THEN [] ELSE collect_list(struct#5580852, 0, 0)#5580873 END, true) AS struct_array#5580853]

(26) Project [codegen id : 8]
Output [4]: [shardId#5580640, worklistShardItemId#5580649L, struct_array#5580853.qty AS quantities#5580874, struct(EndOfPeriodVirtualStockQty, struct_array#5580853.kpi:EndOfPeriodVirtualStockQty, OutOfStockProbability, struct_array#5580853.kpi:OutOfStockProbability, PeriodSpoilageQty, struct_array#5580853.kpi:PeriodSpoilageQty, RangeOfCoverage, struct_array#5580853.kpi:RangeOfCoverage, RemainingStockQty, struct_array#5580853.kpi:RemainingStockQty, SalesQty, struct_array#5580853.kpi:SalesQty, ServiceLevel, struct_array#5580853.kpi:ServiceLevel, ServiceLevelAtStartOfDelisting, struct_array#5580853.kpi:ServiceLevelAtStartOfDelisting, ServiceLevelMinimumStock, struct_array#5580853.kpi:ServiceLevelMinimumStock, ShelfCapacityOverrun, struct_array#5580853.kpi:ShelfCapacityOverrun, ShelfCapacityUnderrun, struct_array#5580853.kpi:ShelfCapacityUnderrun, SpoilageQty, struct_array#5580853.kpi:SpoilageQty, UnfulfilledDemandQty, ... 1 more fields) AS kpis#5580888]
Input [3]: [shardId#5580640, worklistShardItemId#5580649L, struct_array#5580853]

(27) Scan parquet 
Output [14]: [orderProposalId#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082, shardId#5581083, sequenceId#5581061]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000001445]
PartitionFilters: [isnotnull(shardId#5581083), isnotnull(sequenceId#5581061), (shardId#5581083 = 0_1_10000001445), (sequenceId#5581061 = 8)]
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#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082, shardId#5581083, sequenceId#5581061]

(29) Filter [codegen id : 6]
Input [14]: [orderProposalId#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082, shardId#5581083, sequenceId#5581061]
Condition : isnotnull(worklistShardItemId#5581062L)

(30) Project [codegen id : 6]
Output [12]: [orderProposalId#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082]
Input [14]: [orderProposalId#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082, shardId#5581083, sequenceId#5581061]

(31) Exchange
Input [12]: [orderProposalId#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082]
Arguments: hashpartitioning(worklistShardItemId#5581062L, 30), REPARTITION_BY_NUM, [plan_id=2893951]

(32) Project [codegen id : 7]
Output [12]: [worklistShardItemId#5581062L, orderProposalId#5581039L, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, measurements#5581080, constraintLabels#5581070, constraintOperators#5581071, constraintRanks#5581073, constraintValues#5581072, constraintIsActive#5581074, logisticUnits#5581066, optimizationGroups#5581082]
Input [12]: [orderProposalId#5581039L, worklistShardItemId#5581062L, logisticUnits#5581066, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, constraintLabels#5581070, constraintOperators#5581071, constraintValues#5581072, constraintRanks#5581073, constraintIsActive#5581074, measurements#5581080, optimizationGroups#5581082]

(33) BroadcastExchange
Input [12]: [worklistShardItemId#5581062L, orderProposalId#5581039L, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, measurements#5581080, constraintLabels#5581070, constraintOperators#5581071, constraintRanks#5581073, constraintValues#5581072, constraintIsActive#5581074, logisticUnits#5581066, optimizationGroups#5581082]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2893955]

(34) BroadcastHashJoin [codegen id : 8]
Left keys [1]: [worklistShardItemId#5580649L]
Right keys [1]: [worklistShardItemId#5581062L]
Join type: LeftOuter
Join condition: (shardId#5580640 = 0_1_10000001445)

(35) Project [codegen id : 8]
Output [15]: [shardId#5580640, worklistShardItemId#5580649L, quantities#5580874, kpis#5580888, constraintValues#5581072, constraintOperators#5581071, constraintLabels#5581070, constraintRanks#5581073, constraintIsActive#5581074, orderProposalId#5581039L, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, logisticUnits#5581066, optimizationGroups#5581082, measurements#5581080]
Input [16]: [shardId#5580640, worklistShardItemId#5580649L, quantities#5580874, kpis#5580888, worklistShardItemId#5581062L, orderProposalId#5581039L, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, measurements#5581080, constraintLabels#5581070, constraintOperators#5581071, constraintRanks#5581073, constraintValues#5581072, constraintIsActive#5581074, logisticUnits#5581066, optimizationGroups#5581082]

(36) ObjectHashAggregate
Input [15]: [shardId#5580640, worklistShardItemId#5580649L, quantities#5580874, kpis#5580888, constraintValues#5581072, constraintOperators#5581071, constraintLabels#5581070, constraintRanks#5581073, constraintIsActive#5581074, orderProposalId#5581039L, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid#5581068, logisticUnits#5581066, optimizationGroups#5581082, measurements#5581080]
Keys [2]: [shardId#5580640, orderProposalId#5581039L]
Functions [1]: [partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5580649L, quantities, quantities#5580874, kpis, kpis#5580888, constraintValues, constraintValues#5581072, constraintOperators, constraintOperators#5581071, constraintLabels, constraintLabels#5581070, constraintRanks, constraintRanks#5581073, constraintIsActive, constraintIsActive#5581074, orderQuantityBaseUom, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5581068, logisticUnits, logisticUnits#5581066, optimizationGroups, optimizationGroups#5581082, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [buf#5581569]
Results [3]: [shardId#5580640, orderProposalId#5581039L, buf#5581570]

(37) Exchange
Input [3]: [shardId#5580640, orderProposalId#5581039L, buf#5581570]
Arguments: hashpartitioning(shardId#5580640, orderProposalId#5581039L, 30), ENSURE_REQUIREMENTS, [plan_id=2893961]

(38) ObjectHashAggregate
Input [3]: [shardId#5580640, orderProposalId#5581039L, buf#5581570]
Keys [2]: [shardId#5580640, orderProposalId#5581039L]
Functions [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5580649L, quantities, quantities#5580874, kpis, kpis#5580888, constraintValues, constraintValues#5581072, constraintOperators, constraintOperators#5581071, constraintLabels, constraintLabels#5581070, constraintRanks, constraintRanks#5581073, constraintIsActive, constraintIsActive#5581074, orderQuantityBaseUom, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5581068, logisticUnits, logisticUnits#5581066, optimizationGroups, optimizationGroups#5581082, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5580649L, quantities, quantities#5580874, kpis, kpis#5580888, constraintValues, constraintValues#5581072, constraintOperators, constraintOperators#5581071, constraintLabels, constraintLabels#5581070, constraintRanks, constraintRanks#5581073, constraintIsActive, constraintIsActive#5581074, orderQuantityBaseUom, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5581068, logisticUnits, logisticUnits#5581066, optimizationGroups, optimizationGroups#5581082, measurements, ... 1 more fields), 0, 0)#5581208]
Results [3]: [shardId#5580640, orderProposalId#5581039L, collect_list(struct(worklistShardItemId, worklistShardItemId#5580649L, quantities, quantities#5580874, kpis, kpis#5580888, constraintValues, constraintValues#5581072, constraintOperators, constraintOperators#5581071, constraintLabels, constraintLabels#5581070, constraintRanks, constraintRanks#5581073, constraintIsActive, constraintIsActive#5581074, orderQuantityBaseUom, orderQuantityBaseUom#5581067, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5581068, logisticUnits, logisticUnits#5581066, optimizationGroups, optimizationGroups#5581082, measurements, ... 1 more fields), 0, 0)#5581208 AS items#5581192]

(39) Scan parquet 
Output [4]: [orderProposalId#5581212L, optimizationGroups#5581214, shardId#5581215, sequenceId#5581213]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/order-proposal-snapshot/10000001445]
PartitionFilters: [isnotnull(shardId#5581215), isnotnull(sequenceId#5581213), (shardId#5581215 = 0_1_10000001445), (sequenceId#5581213 = 8)]
PushedFilters: [IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,optimizationGroups:array<struct<optGroupId:string,minOrderProfile:string,assignmentDetails: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#5581212L, optimizationGroups#5581214, shardId#5581215, sequenceId#5581213]

(41) Filter [codegen id : 9]
Input [4]: [orderProposalId#5581212L, optimizationGroups#5581214, shardId#5581215, sequenceId#5581213]
Condition : isnotnull(orderProposalId#5581212L)

(42) Project [codegen id : 9]
Output [3]: [orderProposalId#5581212L, sequenceId#5581213, optimizationGroups#5581214]
Input [4]: [orderProposalId#5581212L, optimizationGroups#5581214, shardId#5581215, sequenceId#5581213]

(43) Exchange
Input [3]: [orderProposalId#5581212L, sequenceId#5581213, optimizationGroups#5581214]
Arguments: hashpartitioning(orderProposalId#5581212L, 30), REPARTITION_BY_NUM, [plan_id=2893969]

(44) Project
Output [3]: [orderProposalId#5581212L, transform(optimizationGroups#5581214, lambdafunction(if (isnull(lambda x_1068#5581218)) null else named_struct(optGroupId, lambda x_1068#5581218.optGroupId, assignmentDetails, lambda x_1068#5581218.assignmentDetails, minOrderProfile, lambda x_1068#5581218.minOrderProfile, minOrderGoal, if (isnull(lambda x_1068#5581218.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1068#5581218.minOrderGoal.minOrderValue, dimensionType, lambda x_1068#5581218.minOrderGoal.dimensionType, unit, lambda x_1068#5581218.minOrderGoal.unit, unitUuid, lambda x_1068#5581218.minOrderGoal.unitUuid, isoCode, lambda x_1068#5581218.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1068#5581218.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1068#5581218.minOrderGoal.acceptanceThreshold)), lambda x_1068#5581218, false)) AS optimizationGroups#5581211, sequenceId#5581213]
Input [3]: [orderProposalId#5581212L, sequenceId#5581213, optimizationGroups#5581214]

(45) BroadcastExchange
Input [3]: [orderProposalId#5581212L, optimizationGroups#5581211, sequenceId#5581213]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2893971]

(46) BroadcastHashJoin [codegen id : 11]
Left keys [1]: [orderProposalId#5581039L]
Right keys [1]: [orderProposalId#5581212L]
Join type: LeftOuter
Join condition: (shardId#5580640 = 0_1_10000001445)

(47) Project [codegen id : 11]
Output [5]: [shardId#5580640, orderProposalId#5581039L, items#5581192, optimizationGroups#5581211, sequenceId#5581213]
Input [6]: [shardId#5580640, orderProposalId#5581039L, items#5581192, orderProposalId#5581212L, optimizationGroups#5581211, sequenceId#5581213]

(48) Scan parquet 
Output [3]: [uomCategories#5581223, insightConfigurations#5581224, shardId#5581225]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000001445]
PartitionFilters: [isnotnull(shardId#5581225), (shardId#5581225 = 0_1_10000001445)]
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#5581223, insightConfigurations#5581224, shardId#5581225]

(50) Project [codegen id : 10]
Output [2]: [uomCategories#5581223, insightConfigurations#5581224]
Input [3]: [uomCategories#5581223, insightConfigurations#5581224, shardId#5581225]

(51) Exchange
Input [2]: [uomCategories#5581223, insightConfigurations#5581224]
Arguments: RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=2893979]

(52) BroadcastExchange
Input [2]: [uomCategories#5581223, insightConfigurations#5581224]
Arguments: IdentityBroadcastMode, [plan_id=2893980]

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

(54) DeserializeToObject
Input [7]: [shardId#5580640, orderProposalId#5581039L, items#5581192, optimizationGroups#5581211, sequenceId#5581213, uomCategories#5581223, insightConfigurations#5581224]
Arguments: createexternalrow(invoke(shardId#5580640.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5581039L)), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.PeriodSpoilageQty, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.SalesQty, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -12), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -12))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.ShelfCapacityOverrun, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -13), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -13))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.ShelfCapacityUnderrun, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -14), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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.SpoilageQty, Some(class scala.collection.mutable.ArraySeq)), mapobjects(lambdavariable(MapObject, DoubleType, true, -15), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false), StructField(RangeOfCoverage,ArrayType(DoubleType,true),false), StructField(RemainingStockQty,ArrayType(DoubleType,true),false), StructField(SalesQty,ArrayType(DoubleType,true),false), StructField(ServiceLevel,ArrayType(DoubleType,true),false), StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false), StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false), StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false), StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false), StructField(SpoilageQty,ArrayType(DoubleType,true),false), ... 1 more fields), mapobjects(lambdavariable(MapObject, DoubleType, true, -16), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, DoubleType, true, -16))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -18), invoke(lambdavariable(MapObject, StringType, true, -18).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -19), static_invoke(java.lang.Integer.valueOf(lambdavariable(MapObject, IntegerType, true, -19))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -20), static_invoke(java.lang.Boolean.valueOf(lambdavariable(MapObject, BooleanType, true, -20))), 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -21), 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, -21))) 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, -21).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, -21).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, -21).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, -21).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, -21).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, -21).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -22), invoke(lambdavariable(MapObject, StringType, true, -22).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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, -23), 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, -23))) 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, -23).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, -23).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, -23).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, -23).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, -23).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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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#5581192, 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), true, -24), 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), true, -24))) 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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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), true, -24).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)), 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)), optimizationGroups#5581211, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5581213)), mapobjects(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -25), if (isnull(lambdavariable(MapObject, StructField(uomCategoryName,StringType,true), StructField(uoms,ArrayType(StructType(StructField(uom,StringType,true),StructField(uomUuid,StringType,true)),true),true), true, -25))) 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, -25).uomCategoryName.toString()), mapobjects(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26), if (isnull(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26).uom.toString()), invoke(lambdavariable(MapObject, StructField(uom,StringType,true), StructField(uomUuid,StringType,true), true, -26).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, -25).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#5581223, Some(class scala.collection.mutable.ArraySeq)), catalysttoexternalmap(lambdavariable(CatalystToExternalMap_key, StringType, false, -27), invoke(lambdavariable(CatalystToExternalMap_key, StringType, false, -27).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, -28), 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, -28))) 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, -28).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, -28).name.toString()), mapobjects(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29), if (isnull(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29))) null else createexternalrow(invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29).name.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29).type.toString()), invoke(lambdavariable(MapObject, StructField(name,StringType,true), StructField(type,StringType,true), StructField(value,StringType,true), true, -29).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, -28).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, -28).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#5581224, 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(PeriodSpoilageQty,ArrayType(DoubleType,true),false),StructField(RangeOfCoverage,ArrayType(DoubleType,true),false),StructField(RemainingStockQty,ArrayType(DoubleType,true),false),StructField(SalesQty,ArrayType(DoubleType,true),false),StructField(ServiceLevel,ArrayType(DoubleType,true),false),StructField(ServiceLevelAtStartOfDelisting,ArrayType(DoubleType,true),false),StructField(ServiceLevelMinimumStock,ArrayType(DoubleType,true),false),StructField(ShelfCapacityOverrun,ArrayType(DoubleType,true),false),StructField(ShelfCapacityUnderrun,ArrayType(DoubleType,true),false),StructField(SpoilageQty,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)),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#5581243: org.apache.spark.sql.Row

(55) MapPartitions
Input [1]: [obj#5581243]
Arguments: org.apache.spark.sql.internal.ToScalaUDF$$$Lambda/0x000000080248b3a0@34218b4b, obj#5581250: org.apache.spark.sql.Row

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	97
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
spark.sql.shuffle.partitions	30
temporal.activity.id	ad458d20-d9c7-36d3-8134-433c400366bc
temporal.activity.type	RunStreamWithId