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

Submitted Time: 2026/07/21 20:46:48
Duration: 1 s
Succeeded Jobs: 46471 46472 46473

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@3c583f49, obj#5498422: org.apache.spark.sql.Row"]; 1 [id="node1" labelType="html" label=" DeserializeToObject " tooltip="DeserializeToObject createexternalrow(invoke(shardId#5497812.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5498211L)), 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#5498364, 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#5498383, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5498385)), 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#5498395, 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#5498396, 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#5498415: 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#5497812 = 0_1_10000001445)"]; 4 [id="node4" labelType="html" label=" Project " tooltip="Project [shardId#5497812, orderProposalId#5498211L, items#5498364, optimizationGroups#5498383, sequenceId#5498385]"]; 5 [id="node5" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [orderProposalId#5498211L], [orderProposalId#5498384L], LeftOuter, BuildRight, (shardId#5497812 = 0_1_10000001445), false"]; } 6 [id="node6" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5497812, orderProposalId#5498211L], functions=[collect_list(struct(worklistShardItemId, worklistShardItemId#5497821L, quantities, quantities#5498046, kpis, kpis#5498060, constraintValues, constraintValues#5498244, constraintOperators, constraintOperators#5498243, constraintLabels, constraintLabels#5498242, constraintRanks, constraintRanks#5498245, constraintIsActive, constraintIsActive#5498246, orderQuantityBaseUom, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5498240, logisticUnits, logisticUnits#5498238, optimizationGroups, optimizationGroups#5498254, measurements, ... 1 more fields), 0, 0)])"]; 7 [id="node7" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5497812, orderProposalId#5498211L, 30), ENSURE_REQUIREMENTS, [plan_id=2852891]"]; 8 [id="node8" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5497812, orderProposalId#5498211L], functions=[partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5497821L, quantities, quantities#5498046, kpis, kpis#5498060, constraintValues, constraintValues#5498244, constraintOperators, constraintOperators#5498243, constraintLabels, constraintLabels#5498242, constraintRanks, constraintRanks#5498245, constraintIsActive, constraintIsActive#5498246, orderQuantityBaseUom, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5498240, logisticUnits, logisticUnits#5498238, optimizationGroups, optimizationGroups#5498254, 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#5497812, worklistShardItemId#5497821L, quantities#5498046, kpis#5498060, constraintValues#5498244, constraintOperators#5498243, constraintLabels#5498242, constraintRanks#5498245, constraintIsActive#5498246, orderProposalId#5498211L, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, logisticUnits#5498238, optimizationGroups#5498254, measurements#5498252]"]; 11 [id="node11" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#5497821L], [worklistShardItemId#5498234L], LeftOuter, BuildRight, (shardId#5497812 = 0_1_10000001445), false"]; 12 [id="node12" labelType="html" label=" Project " tooltip="Project [shardId#5497812, worklistShardItemId#5497821L, struct_array#5498025.qty AS quantities#5498046, struct(EndOfPeriodVirtualStockQty, struct_array#5498025.kpi:EndOfPeriodVirtualStockQty, OutOfStockProbability, struct_array#5498025.kpi:OutOfStockProbability, PeriodSpoilageQty, struct_array#5498025.kpi:PeriodSpoilageQty, RangeOfCoverage, struct_array#5498025.kpi:RangeOfCoverage, RemainingStockQty, struct_array#5498025.kpi:RemainingStockQty, SalesQty, struct_array#5498025.kpi:SalesQty, ServiceLevel, struct_array#5498025.kpi:ServiceLevel, ServiceLevelAtStartOfDelisting, struct_array#5498025.kpi:ServiceLevelAtStartOfDelisting, ServiceLevelMinimumStock, struct_array#5498025.kpi:ServiceLevelMinimumStock, ShelfCapacityOverrun, struct_array#5498025.kpi:ShelfCapacityOverrun, ShelfCapacityUnderrun, struct_array#5498025.kpi:ShelfCapacityUnderrun, SpoilageQty, struct_array#5498025.kpi:SpoilageQty, UnfulfilledDemandQty, ... 1 more fields) AS kpis#5498060]"]; } 13 [id="node13" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5497812, worklistShardItemId#5497821L], functions=[max(struct#5498024.qty), collect_list(struct#5498024, 0, 0)])"]; 14 [id="node14" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5497812, worklistShardItemId#5497821L], functions=[partial_max(struct#5498024.qty), partial_collect_list(struct#5498024, 0, 0)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [shardId#5497812, worklistShardItemId#5497821L, struct(qty, qty#5497883, kpi:EndOfPeriodVirtualStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[0], kpi:OutOfStockProbability, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[1], kpi:PeriodSpoilageQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[2], kpi:RangeOfCoverage, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[3], kpi:RemainingStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[4], kpi:SalesQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[5], kpi:ServiceLevel, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[6], kpi:ServiceLevelAtStartOfDelisting, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[7], kpi:ServiceLevelMinimumStock, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[8], kpi:ShelfCapacityOverrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[9], kpi:ShelfCapacityUnderrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984[10], kpi:SpoilageQty, ... 3 more fields) AS struct#5498024]"]; } 17 [id="node17" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5497812, worklistShardItemId#5497821L, qty#5497883], functions=[pivotfirst(label#5497890, max(kpi.`value` AS value)#5497956, 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#5497812, worklistShardItemId#5497821L, knownfloatingpointnormalized(normalizenanandzero(qty#5497883)) AS qty#5497883], functions=[partial_pivotfirst(label#5497890, max(kpi.`value` AS value)#5497956, 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#5497812, worklistShardItemId#5497821L, qty#5497883, label#5497890], functions=[max(_extract_value#5498520)])"]; 21 [id="node21" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5497812, worklistShardItemId#5497821L, knownfloatingpointnormalized(normalizenanandzero(qty#5497883)) AS qty#5497883, label#5497890], functions=[partial_max(_extract_value#5498520)])"]; 22 [id="node22" labelType="html" label=" Project " tooltip="Project [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, kpi#5497889.value AS _extract_value#5498520, concat(kpi:, kpi#5497889.label) AS label#5497890]"]; 23 [id="node23" labelType="html" label=" Generate " tooltip="Generate explode(kpis#5497887), [shardId#5497812, worklistShardItemId#5497821L, qty#5497883], true, [kpi#5497889]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, coalesce(kpis#5497886, []) AS kpis#5497887]"]; 25 [id="node25" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#5497881, worklistShardItemId#5497882L], [shardId#5497812, worklistShardItemId#5497821L], RightOuter"]; } subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 27 [id="node27" labelType="html" label=" Sort " tooltip="Sort [shardId#5497881 ASC NULLS FIRST, worklistShardItemId#5497882L ASC NULLS FIRST], false, 0"]; } 28 [id="node28" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5497881, worklistShardItemId#5497882L, 30), ENSURE_REQUIREMENTS, [plan_id=2852851]"]; subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 30 [id="node30" labelType="html" label=" Project " tooltip="Project [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, kpis#5497886]"]; 31 [id="node31" labelType="html" label=" Filter " tooltip="Filter (isnotnull(qty#5497883) AND (isnotnull(shardId#5497881) AND isnotnull(worklistShardItemId#5497882L)))"]; 32 [id="node32" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5497881,worklistShardItemId#5497882L,qty#5497883,demandChannel#5497884,demandStream#5497885,kpis#5497886]"]; } subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 34 [id="node34" labelType="html" label=" Sort " tooltip="Sort [shardId#5497812 ASC NULLS FIRST, worklistShardItemId#5497821L ASC NULLS FIRST], false, 0"]; } 35 [id="node35" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5497812, worklistShardItemId#5497821L, 30), ENSURE_REQUIREMENTS, [plan_id=2852792]"]; 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#5497812, worklistShardItemId#5497821L]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Project " tooltip="Project [shardId#5497812, item#5497820L AS worklistShardItemId#5497821L]"]; 39 [id="node39" labelType="html" label=" Generate " tooltip="Generate explode(_extract_worklistShardItemId#5497824), [shardId#5497812], false, [item#5497820L]"]; 40 [id="node40" labelType="html" label=" Project " tooltip="Project [shardId#5497812, items#5497814.worklistShardItemId AS _extract_worklistShardItemId#5497824]"]; 41 [id="node41" labelType="html" label=" Filter " tooltip="Filter ((isnotnull(shardId#5497812) AND ((shardId#5497812 = 0_1_10000001445) AND (isOptimal#5497816 <=> false))) AND ((size(items#5497814.worklistShardItemId, true) > 0) AND isnotnull(items#5497814.worklistShardItemId)))"]; 42 [id="node42" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5497812,orderProposalId#5497813L,items#5497814,optimizationGroups#5497815,isOptimal#5497816,lastModified#5497817,optimizationInsights#5497818]"]; } 43 [id="node43" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 309 ms number of output rows: 29 data size: 1030.4 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2852885]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n14 ms (0 ms, 0 ms, 3 ms (stage 1310529.0: task 2444749))"; tooltip="WholeStageCodegen (7)"; 45 [id="node45" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#5498234L, orderProposalId#5498211L, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, measurements#5498252, constraintLabels#5498242, constraintOperators#5498243, constraintRanks#5498245, constraintValues#5498244, constraintIsActive#5498246, logisticUnits#5498238, optimizationGroups#5498254]"]; } 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)) 12.7 KiB (510.0 B, 558.0 B, 1115.0 B (stage 1310529.0: task 2444762)) merged fetch fallback count: 0 local blocks read: 22 remote merged chunks fetched: 0 remote blocks read: 5 data size total (min, med, max (stageId: taskId)) 24.2 KiB (808.0 B, 1616.0 B, 2.7 KiB (stage 1310528.0: task 2444672)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 9 ms (0 ms, 0 ms, 0 ms (stage 1310528.0: task 2444679)) 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)) 5 ms (0 ms, 0 ms, 2 ms (stage 1310529.0: task 2444749)) remote bytes read total (min, med, max (stageId: taskId)) 3.3 KiB (553.0 B, 774.0 B, 1475.0 B (stage 1310529.0: task 2444755)) number of partitions: 30 remote reqs duration total (min, med, max (stageId: taskId)) 7 ms (0 ms, 2 ms, 3 ms (stage 1310529.0: task 2444750)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 16.0 KiB (553.0 B, 688.0 B, 1885.0 B (stage 1310528.0: task 2444672))" tooltip="Exchange hashpartitioning(worklistShardItemId#5498234L, 30), REPARTITION_BY_NUM, [plan_id=2852881]"]; subgraph cluster47 { isCluster="true"; id="cluster47"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n2.2 s (85 ms, 133 ms, 166 ms (stage 1310528.0: task 2444675))"; tooltip="WholeStageCodegen (6)"; 48 [id="node48" labelType="html" label=" Project " tooltip="Project [orderProposalId#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254]"]; 49 [id="node49" labelType="html" label="Filter number of output rows: 29" tooltip="Filter isnotnull(worklistShardItemId#5498234L)"]; 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)) 2.2 s (84 ms, 131 ms, 165 ms (stage 1310528.0: task 2444675)) 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#5498211L,worklistShardItemId#5498234L,logisticUnits#5498238,orderQuantityBaseUom#5498239,orderQuantityBaseUomUuid#5498240,constraintLabels#5498242,constraintOperators#5498243,constraintValues#5498244,constraintRanks#5498245,constraintIsActive#5498246,measurements#5498252,optimizationGroups#5498254,shardId#5498255,sequenceId#5498233] Batched: true, DataFilters: [isnotnull(worklistShardItemId#5498234L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5498255), isnotnull(sequenceId#5498233), (shardId#5498255 = 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: 249 ms number of output rows: 2 data size: 1024.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2852901]"]; 53 [id="node53" labelType="html" label=" Project " tooltip="Project [orderProposalId#5498384L, transform(optimizationGroups#5498386, lambdafunction(if (isnull(lambda x_1049#5498390)) null else named_struct(optGroupId, lambda x_1049#5498390.optGroupId, assignmentDetails, lambda x_1049#5498390.assignmentDetails, minOrderProfile, lambda x_1049#5498390.minOrderProfile, minOrderGoal, if (isnull(lambda x_1049#5498390.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1049#5498390.minOrderGoal.minOrderValue, dimensionType, lambda x_1049#5498390.minOrderGoal.dimensionType, unit, lambda x_1049#5498390.minOrderGoal.unit, unitUuid, lambda x_1049#5498390.minOrderGoal.unitUuid, isoCode, lambda x_1049#5498390.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1049#5498390.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1049#5498390.minOrderGoal.acceptanceThreshold)), lambda x_1049#5498390, false)) AS optimizationGroups#5498383, sequenceId#5498385]"]; 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)) 192.0 B (96.0 B, 96.0 B, 96.0 B (stage 1310525.0: task 2444689)) 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 1310524.0: task 2444670)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 1 ms (0 ms, 0 ms, 0 ms (stage 1310524.0: task 2444670)) 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 1310525.0: task 2444689)) 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)) 192.0 B (96.0 B, 96.0 B, 96.0 B (stage 1310524.0: task 2444670))" tooltip="Exchange hashpartitioning(orderProposalId#5498384L, 30), REPARTITION_BY_NUM, [plan_id=2852899]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n255 ms (98 ms, 157 ms, 157 ms (stage 1310524.0: task 2444669))"; tooltip="WholeStageCodegen (9)"; 56 [id="node56" labelType="html" label=" Project " tooltip="Project [orderProposalId#5498384L, sequenceId#5498385, optimizationGroups#5498386]"]; 57 [id="node57" labelType="html" label="Filter number of output rows: 2" tooltip="Filter isnotnull(orderProposalId#5498384L)"]; 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)) 232 ms (95 ms, 137 ms, 137 ms (stage 1310524.0: task 2444669)) 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#5498384L,optimizationGroups#5498386,shardId#5498387,sequenceId#5498385] Batched: true, DataFilters: [isnotnull(orderProposalId#5498384L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5498387), isnotnull(sequenceId#5498385), (shardId#5498387 = 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: 249 ms number of output rows: 1 data size: 1288.0 B" tooltip="BroadcastExchange IdentityBroadcastMode, [plan_id=2852910]"]; 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=2852909]"]; subgraph cluster62 { isCluster="true"; id="cluster62"; label="WholeStageCodegen (10)\n \nduration: 108 ms"; tooltip="WholeStageCodegen (10)"; 63 [id="node63" labelType="html" label=" Project " tooltip="Project [uomCategories#5498395, insightConfigurations#5498396]"]; 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: 100 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#5498395,insightConfigurations#5498396,shardId#5498397] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5498397), (shardId#5498397 = 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#5497881, worklistShardItemId#5497882L, qty#5497883, demandChannel#5497884, demandStream#5497885, kpis#5497886]
Arguments: [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, demandChannel#5497884, demandStream#5497885, kpis#5497886], MapPartitionsRDD[387286] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(2) Filter [codegen id : 1]
Input [6]: [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, demandChannel#5497884, demandStream#5497885, kpis#5497886]
Condition : (isnotnull(qty#5497883) AND (isnotnull(shardId#5497881) AND isnotnull(worklistShardItemId#5497882L)))

(3) Project [codegen id : 1]
Output [4]: [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, kpis#5497886]
Input [6]: [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, demandChannel#5497884, demandStream#5497885, kpis#5497886]

(4) Exchange
Input [4]: [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, kpis#5497886]
Arguments: hashpartitioning(shardId#5497881, worklistShardItemId#5497882L, 30), ENSURE_REQUIREMENTS, [plan_id=2852851]

(5) Sort [codegen id : 2]
Input [4]: [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, kpis#5497886]
Arguments: [shardId#5497881 ASC NULLS FIRST, worklistShardItemId#5497882L ASC NULLS FIRST], false, 0

(6) InMemoryTableScan
Output [2]: [shardId#5497812, worklistShardItemId#5497821L]
Arguments: [shardId#5497812, worklistShardItemId#5497821L]

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

(8) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#5497812, orderProposalId#5497813L, items#5497814, optimizationGroups#5497815, isOptimal#5497816, lastModified#5497817, optimizationInsights#5497818]
Arguments: [shardId#5497812, orderProposalId#5497813L, items#5497814, optimizationGroups#5497815, isOptimal#5497816, lastModified#5497817, optimizationInsights#5497818], MapPartitionsRDD[387274] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(9) Filter [codegen id : 1]
Input [7]: [shardId#5497812, orderProposalId#5497813L, items#5497814, optimizationGroups#5497815, isOptimal#5497816, lastModified#5497817, optimizationInsights#5497818]
Condition : ((isnotnull(shardId#5497812) AND ((shardId#5497812 = 0_1_10000001445) AND (isOptimal#5497816 <=> false))) AND ((size(items#5497814.worklistShardItemId, true) > 0) AND isnotnull(items#5497814.worklistShardItemId)))

(10) Project [codegen id : 1]
Output [2]: [shardId#5497812, items#5497814.worklistShardItemId AS _extract_worklistShardItemId#5497824]
Input [7]: [shardId#5497812, orderProposalId#5497813L, items#5497814, optimizationGroups#5497815, isOptimal#5497816, lastModified#5497817, optimizationInsights#5497818]

(11) Generate [codegen id : 1]
Input [2]: [shardId#5497812, _extract_worklistShardItemId#5497824]
Arguments: explode(_extract_worklistShardItemId#5497824), [shardId#5497812], false, [item#5497820L]

(12) Project [codegen id : 1]
Output [2]: [shardId#5497812, item#5497820L AS worklistShardItemId#5497821L]
Input [2]: [shardId#5497812, item#5497820L]

(13) Exchange
Input [2]: [shardId#5497812, worklistShardItemId#5497821L]
Arguments: hashpartitioning(shardId#5497812, worklistShardItemId#5497821L, 30), ENSURE_REQUIREMENTS, [plan_id=2852792]

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

(15) SortMergeJoin [codegen id : 4]
Left keys [2]: [shardId#5497881, worklistShardItemId#5497882L]
Right keys [2]: [shardId#5497812, worklistShardItemId#5497821L]
Join type: RightOuter
Join condition: None

(16) Project [codegen id : 4]
Output [4]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, coalesce(kpis#5497886, []) AS kpis#5497887]
Input [6]: [shardId#5497881, worklistShardItemId#5497882L, qty#5497883, kpis#5497886, shardId#5497812, worklistShardItemId#5497821L]

(17) Generate [codegen id : 4]
Input [4]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, kpis#5497887]
Arguments: explode(kpis#5497887), [shardId#5497812, worklistShardItemId#5497821L, qty#5497883], true, [kpi#5497889]

(18) Project [codegen id : 4]
Output [5]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, kpi#5497889.value AS _extract_value#5498520, concat(kpi:, kpi#5497889.label) AS label#5497890]
Input [4]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, kpi#5497889]

(19) HashAggregate [codegen id : 4]
Input [5]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, _extract_value#5498520, label#5497890]
Keys [4]: [shardId#5497812, worklistShardItemId#5497821L, knownfloatingpointnormalized(normalizenanandzero(qty#5497883)) AS qty#5497883, label#5497890]
Functions [1]: [partial_max(_extract_value#5498520)]
Aggregate Attributes [1]: [max#5498747]
Results [5]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, label#5497890, max#5498748]

(20) HashAggregate [codegen id : 4]
Input [5]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, label#5497890, max#5498748]
Keys [4]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, label#5497890]
Functions [1]: [max(_extract_value#5498520)]
Aggregate Attributes [1]: [max(_extract_value#5498520)#5497955]
Results [5]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, label#5497890, max(_extract_value#5498520)#5497955 AS max(kpi.`value` AS value)#5497956]

(21) HashAggregate
Input [5]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, label#5497890, max(kpi.`value` AS value)#5497956]
Keys [3]: [shardId#5497812, worklistShardItemId#5497821L, knownfloatingpointnormalized(normalizenanandzero(qty#5497883)) AS qty#5497883]
Functions [1]: [partial_pivotfirst(label#5497890, max(kpi.`value` AS value)#5497956, 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#5497957, kpi:OutOfStockProbability#5497958, kpi:PeriodSpoilageQty#5497959, kpi:RangeOfCoverage#5497960, kpi:RemainingStockQty#5497961, kpi:SalesQty#5497962, kpi:ServiceLevel#5497963, kpi:ServiceLevelAtStartOfDelisting#5497964, kpi:ServiceLevelMinimumStock#5497965, kpi:ShelfCapacityOverrun#5497966, kpi:ShelfCapacityUnderrun#5497967, kpi:SpoilageQty#5497968, kpi:UnfulfilledDemandQty#5497969]
Results [16]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, kpi:EndOfPeriodVirtualStockQty#5497970, kpi:OutOfStockProbability#5497971, kpi:PeriodSpoilageQty#5497972, kpi:RangeOfCoverage#5497973, kpi:RemainingStockQty#5497974, kpi:SalesQty#5497975, kpi:ServiceLevel#5497976, kpi:ServiceLevelAtStartOfDelisting#5497977, kpi:ServiceLevelMinimumStock#5497978, kpi:ShelfCapacityOverrun#5497979, kpi:ShelfCapacityUnderrun#5497980, kpi:SpoilageQty#5497981, kpi:UnfulfilledDemandQty#5497982]

(22) HashAggregate
Input [16]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, kpi:EndOfPeriodVirtualStockQty#5497970, kpi:OutOfStockProbability#5497971, kpi:PeriodSpoilageQty#5497972, kpi:RangeOfCoverage#5497973, kpi:RemainingStockQty#5497974, kpi:SalesQty#5497975, kpi:ServiceLevel#5497976, kpi:ServiceLevelAtStartOfDelisting#5497977, kpi:ServiceLevelMinimumStock#5497978, kpi:ShelfCapacityOverrun#5497979, kpi:ShelfCapacityUnderrun#5497980, kpi:SpoilageQty#5497981, kpi:UnfulfilledDemandQty#5497982]
Keys [3]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883]
Functions [1]: [pivotfirst(label#5497890, max(kpi.`value` AS value)#5497956, 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#5497890, max(kpi.`value` AS value)#5497956, 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)#5497983]
Results [4]: [shardId#5497812, worklistShardItemId#5497821L, qty#5497883, pivotfirst(label#5497890, max(kpi.`value` AS value)#5497956, 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)#5497983 AS __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5497984]

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

(24) ObjectHashAggregate
Input [3]: [shardId#5497812, worklistShardItemId#5497821L, struct#5498024]
Keys [2]: [shardId#5497812, worklistShardItemId#5497821L]
Functions [2]: [partial_max(struct#5498024.qty), partial_collect_list(struct#5498024, 0, 0)]
Aggregate Attributes [2]: [max#5498743, buf#5498744]
Results [4]: [shardId#5497812, worklistShardItemId#5497821L, max#5498745, buf#5498746]

(25) ObjectHashAggregate
Input [4]: [shardId#5497812, worklistShardItemId#5497821L, max#5498745, buf#5498746]
Keys [2]: [shardId#5497812, worklistShardItemId#5497821L]
Functions [2]: [max(struct#5498024.qty), collect_list(struct#5498024, 0, 0)]
Aggregate Attributes [2]: [max(struct#5498024.qty)#5498044, collect_list(struct#5498024, 0, 0)#5498045]
Results [3]: [shardId#5497812, worklistShardItemId#5497821L, sort_array(CASE WHEN isnull(max(struct#5498024.qty)#5498044) THEN [] ELSE collect_list(struct#5498024, 0, 0)#5498045 END, true) AS struct_array#5498025]

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

(27) Scan parquet 
Output [14]: [orderProposalId#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254, shardId#5498255, sequenceId#5498233]
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#5498255), isnotnull(sequenceId#5498233), (shardId#5498255 = 0_1_10000001445), (sequenceId#5498233 = 6)]
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#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254, shardId#5498255, sequenceId#5498233]

(29) Filter [codegen id : 6]
Input [14]: [orderProposalId#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254, shardId#5498255, sequenceId#5498233]
Condition : isnotnull(worklistShardItemId#5498234L)

(30) Project [codegen id : 6]
Output [12]: [orderProposalId#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254]
Input [14]: [orderProposalId#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254, shardId#5498255, sequenceId#5498233]

(31) Exchange
Input [12]: [orderProposalId#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254]
Arguments: hashpartitioning(worklistShardItemId#5498234L, 30), REPARTITION_BY_NUM, [plan_id=2852881]

(32) Project [codegen id : 7]
Output [12]: [worklistShardItemId#5498234L, orderProposalId#5498211L, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, measurements#5498252, constraintLabels#5498242, constraintOperators#5498243, constraintRanks#5498245, constraintValues#5498244, constraintIsActive#5498246, logisticUnits#5498238, optimizationGroups#5498254]
Input [12]: [orderProposalId#5498211L, worklistShardItemId#5498234L, logisticUnits#5498238, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, constraintLabels#5498242, constraintOperators#5498243, constraintValues#5498244, constraintRanks#5498245, constraintIsActive#5498246, measurements#5498252, optimizationGroups#5498254]

(33) BroadcastExchange
Input [12]: [worklistShardItemId#5498234L, orderProposalId#5498211L, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, measurements#5498252, constraintLabels#5498242, constraintOperators#5498243, constraintRanks#5498245, constraintValues#5498244, constraintIsActive#5498246, logisticUnits#5498238, optimizationGroups#5498254]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2852885]

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

(35) Project [codegen id : 8]
Output [15]: [shardId#5497812, worklistShardItemId#5497821L, quantities#5498046, kpis#5498060, constraintValues#5498244, constraintOperators#5498243, constraintLabels#5498242, constraintRanks#5498245, constraintIsActive#5498246, orderProposalId#5498211L, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, logisticUnits#5498238, optimizationGroups#5498254, measurements#5498252]
Input [16]: [shardId#5497812, worklistShardItemId#5497821L, quantities#5498046, kpis#5498060, worklistShardItemId#5498234L, orderProposalId#5498211L, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, measurements#5498252, constraintLabels#5498242, constraintOperators#5498243, constraintRanks#5498245, constraintValues#5498244, constraintIsActive#5498246, logisticUnits#5498238, optimizationGroups#5498254]

(36) ObjectHashAggregate
Input [15]: [shardId#5497812, worklistShardItemId#5497821L, quantities#5498046, kpis#5498060, constraintValues#5498244, constraintOperators#5498243, constraintLabels#5498242, constraintRanks#5498245, constraintIsActive#5498246, orderProposalId#5498211L, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid#5498240, logisticUnits#5498238, optimizationGroups#5498254, measurements#5498252]
Keys [2]: [shardId#5497812, orderProposalId#5498211L]
Functions [1]: [partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5497821L, quantities, quantities#5498046, kpis, kpis#5498060, constraintValues, constraintValues#5498244, constraintOperators, constraintOperators#5498243, constraintLabels, constraintLabels#5498242, constraintRanks, constraintRanks#5498245, constraintIsActive, constraintIsActive#5498246, orderQuantityBaseUom, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5498240, logisticUnits, logisticUnits#5498238, optimizationGroups, optimizationGroups#5498254, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [buf#5498741]
Results [3]: [shardId#5497812, orderProposalId#5498211L, buf#5498742]

(37) Exchange
Input [3]: [shardId#5497812, orderProposalId#5498211L, buf#5498742]
Arguments: hashpartitioning(shardId#5497812, orderProposalId#5498211L, 30), ENSURE_REQUIREMENTS, [plan_id=2852891]

(38) ObjectHashAggregate
Input [3]: [shardId#5497812, orderProposalId#5498211L, buf#5498742]
Keys [2]: [shardId#5497812, orderProposalId#5498211L]
Functions [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5497821L, quantities, quantities#5498046, kpis, kpis#5498060, constraintValues, constraintValues#5498244, constraintOperators, constraintOperators#5498243, constraintLabels, constraintLabels#5498242, constraintRanks, constraintRanks#5498245, constraintIsActive, constraintIsActive#5498246, orderQuantityBaseUom, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5498240, logisticUnits, logisticUnits#5498238, optimizationGroups, optimizationGroups#5498254, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5497821L, quantities, quantities#5498046, kpis, kpis#5498060, constraintValues, constraintValues#5498244, constraintOperators, constraintOperators#5498243, constraintLabels, constraintLabels#5498242, constraintRanks, constraintRanks#5498245, constraintIsActive, constraintIsActive#5498246, orderQuantityBaseUom, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5498240, logisticUnits, logisticUnits#5498238, optimizationGroups, optimizationGroups#5498254, measurements, ... 1 more fields), 0, 0)#5498380]
Results [3]: [shardId#5497812, orderProposalId#5498211L, collect_list(struct(worklistShardItemId, worklistShardItemId#5497821L, quantities, quantities#5498046, kpis, kpis#5498060, constraintValues, constraintValues#5498244, constraintOperators, constraintOperators#5498243, constraintLabels, constraintLabels#5498242, constraintRanks, constraintRanks#5498245, constraintIsActive, constraintIsActive#5498246, orderQuantityBaseUom, orderQuantityBaseUom#5498239, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5498240, logisticUnits, logisticUnits#5498238, optimizationGroups, optimizationGroups#5498254, measurements, ... 1 more fields), 0, 0)#5498380 AS items#5498364]

(39) Scan parquet 
Output [4]: [orderProposalId#5498384L, optimizationGroups#5498386, shardId#5498387, sequenceId#5498385]
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#5498387), isnotnull(sequenceId#5498385), (shardId#5498387 = 0_1_10000001445), (sequenceId#5498385 = 6)]
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#5498384L, optimizationGroups#5498386, shardId#5498387, sequenceId#5498385]

(41) Filter [codegen id : 9]
Input [4]: [orderProposalId#5498384L, optimizationGroups#5498386, shardId#5498387, sequenceId#5498385]
Condition : isnotnull(orderProposalId#5498384L)

(42) Project [codegen id : 9]
Output [3]: [orderProposalId#5498384L, sequenceId#5498385, optimizationGroups#5498386]
Input [4]: [orderProposalId#5498384L, optimizationGroups#5498386, shardId#5498387, sequenceId#5498385]

(43) Exchange
Input [3]: [orderProposalId#5498384L, sequenceId#5498385, optimizationGroups#5498386]
Arguments: hashpartitioning(orderProposalId#5498384L, 30), REPARTITION_BY_NUM, [plan_id=2852899]

(44) Project
Output [3]: [orderProposalId#5498384L, transform(optimizationGroups#5498386, lambdafunction(if (isnull(lambda x_1049#5498390)) null else named_struct(optGroupId, lambda x_1049#5498390.optGroupId, assignmentDetails, lambda x_1049#5498390.assignmentDetails, minOrderProfile, lambda x_1049#5498390.minOrderProfile, minOrderGoal, if (isnull(lambda x_1049#5498390.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1049#5498390.minOrderGoal.minOrderValue, dimensionType, lambda x_1049#5498390.minOrderGoal.dimensionType, unit, lambda x_1049#5498390.minOrderGoal.unit, unitUuid, lambda x_1049#5498390.minOrderGoal.unitUuid, isoCode, lambda x_1049#5498390.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1049#5498390.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1049#5498390.minOrderGoal.acceptanceThreshold)), lambda x_1049#5498390, false)) AS optimizationGroups#5498383, sequenceId#5498385]
Input [3]: [orderProposalId#5498384L, sequenceId#5498385, optimizationGroups#5498386]

(45) BroadcastExchange
Input [3]: [orderProposalId#5498384L, optimizationGroups#5498383, sequenceId#5498385]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2852901]

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

(47) Project [codegen id : 11]
Output [5]: [shardId#5497812, orderProposalId#5498211L, items#5498364, optimizationGroups#5498383, sequenceId#5498385]
Input [6]: [shardId#5497812, orderProposalId#5498211L, items#5498364, orderProposalId#5498384L, optimizationGroups#5498383, sequenceId#5498385]

(48) Scan parquet 
Output [3]: [uomCategories#5498395, insightConfigurations#5498396, shardId#5498397]
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#5498397), (shardId#5498397 = 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#5498395, insightConfigurations#5498396, shardId#5498397]

(50) Project [codegen id : 10]
Output [2]: [uomCategories#5498395, insightConfigurations#5498396]
Input [3]: [uomCategories#5498395, insightConfigurations#5498396, shardId#5498397]

(51) Exchange
Input [2]: [uomCategories#5498395, insightConfigurations#5498396]
Arguments: RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=2852909]

(52) BroadcastExchange
Input [2]: [uomCategories#5498395, insightConfigurations#5498396]
Arguments: IdentityBroadcastMode, [plan_id=2852910]

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

(54) DeserializeToObject
Input [7]: [shardId#5497812, orderProposalId#5498211L, items#5498364, optimizationGroups#5498383, sequenceId#5498385, uomCategories#5498395, insightConfigurations#5498396]
Arguments: createexternalrow(invoke(shardId#5497812.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5498211L)), 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#5498364, 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#5498383, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5498385)), 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#5498395, 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#5498396, 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#5498415: org.apache.spark.sql.Row

(55) MapPartitions
Input [1]: [obj#5498415]
Arguments: org.apache.spark.sql.internal.ToScalaUDF$$$Lambda/0x000000080248b3a0@3c583f49, obj#5498422: org.apache.spark.sql.Row

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	78
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