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

Submitted Time: 2026/07/21 20:53:44
Duration: 2 s
Succeeded Jobs: 46958 46959 46960

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@5d718e3d, obj#5564618: org.apache.spark.sql.Row"]; 1 [id="node1" labelType="html" label=" DeserializeToObject " tooltip="DeserializeToObject createexternalrow(invoke(shardId#5564008.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5564407L)), 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#5564560, 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#5564579, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5564581)), 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#5564591, 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#5564592, 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#5564611: 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#5564008 = 0_1_10000001445)"]; 4 [id="node4" labelType="html" label=" Project " tooltip="Project [shardId#5564008, orderProposalId#5564407L, items#5564560, optimizationGroups#5564579, sequenceId#5564581]"]; 5 [id="node5" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [orderProposalId#5564407L], [orderProposalId#5564580L], LeftOuter, BuildRight, (shardId#5564008 = 0_1_10000001445), false"]; } 6 [id="node6" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5564008, orderProposalId#5564407L], functions=[collect_list(struct(worklistShardItemId, worklistShardItemId#5564017L, quantities, quantities#5564242, kpis, kpis#5564256, constraintValues, constraintValues#5564440, constraintOperators, constraintOperators#5564439, constraintLabels, constraintLabels#5564438, constraintRanks, constraintRanks#5564441, constraintIsActive, constraintIsActive#5564442, orderQuantityBaseUom, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5564436, logisticUnits, logisticUnits#5564434, optimizationGroups, optimizationGroups#5564450, measurements, ... 1 more fields), 0, 0)])"]; 7 [id="node7" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5564008, orderProposalId#5564407L, 30), ENSURE_REQUIREMENTS, [plan_id=2881248]"]; 8 [id="node8" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5564008, orderProposalId#5564407L], functions=[partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5564017L, quantities, quantities#5564242, kpis, kpis#5564256, constraintValues, constraintValues#5564440, constraintOperators, constraintOperators#5564439, constraintLabels, constraintLabels#5564438, constraintRanks, constraintRanks#5564441, constraintIsActive, constraintIsActive#5564442, orderQuantityBaseUom, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5564436, logisticUnits, logisticUnits#5564434, optimizationGroups, optimizationGroups#5564450, 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#5564008, worklistShardItemId#5564017L, quantities#5564242, kpis#5564256, constraintValues#5564440, constraintOperators#5564439, constraintLabels#5564438, constraintRanks#5564441, constraintIsActive#5564442, orderProposalId#5564407L, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, logisticUnits#5564434, optimizationGroups#5564450, measurements#5564448]"]; 11 [id="node11" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#5564017L], [worklistShardItemId#5564430L], LeftOuter, BuildRight, (shardId#5564008 = 0_1_10000001445), false"]; 12 [id="node12" labelType="html" label=" Project " tooltip="Project [shardId#5564008, worklistShardItemId#5564017L, struct_array#5564221.qty AS quantities#5564242, struct(EndOfPeriodVirtualStockQty, struct_array#5564221.kpi:EndOfPeriodVirtualStockQty, OutOfStockProbability, struct_array#5564221.kpi:OutOfStockProbability, PeriodSpoilageQty, struct_array#5564221.kpi:PeriodSpoilageQty, RangeOfCoverage, struct_array#5564221.kpi:RangeOfCoverage, RemainingStockQty, struct_array#5564221.kpi:RemainingStockQty, SalesQty, struct_array#5564221.kpi:SalesQty, ServiceLevel, struct_array#5564221.kpi:ServiceLevel, ServiceLevelAtStartOfDelisting, struct_array#5564221.kpi:ServiceLevelAtStartOfDelisting, ServiceLevelMinimumStock, struct_array#5564221.kpi:ServiceLevelMinimumStock, ShelfCapacityOverrun, struct_array#5564221.kpi:ShelfCapacityOverrun, ShelfCapacityUnderrun, struct_array#5564221.kpi:ShelfCapacityUnderrun, SpoilageQty, struct_array#5564221.kpi:SpoilageQty, UnfulfilledDemandQty, ... 1 more fields) AS kpis#5564256]"]; } 13 [id="node13" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5564008, worklistShardItemId#5564017L], functions=[max(struct#5564220.qty), collect_list(struct#5564220, 0, 0)])"]; 14 [id="node14" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5564008, worklistShardItemId#5564017L], functions=[partial_max(struct#5564220.qty), partial_collect_list(struct#5564220, 0, 0)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [shardId#5564008, worklistShardItemId#5564017L, struct(qty, qty#5564079, kpi:EndOfPeriodVirtualStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[0], kpi:OutOfStockProbability, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[1], kpi:PeriodSpoilageQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[2], kpi:RangeOfCoverage, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[3], kpi:RemainingStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[4], kpi:SalesQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[5], kpi:ServiceLevel, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[6], kpi:ServiceLevelAtStartOfDelisting, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[7], kpi:ServiceLevelMinimumStock, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[8], kpi:ShelfCapacityOverrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[9], kpi:ShelfCapacityUnderrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180[10], kpi:SpoilageQty, ... 3 more fields) AS struct#5564220]"]; } 17 [id="node17" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5564008, worklistShardItemId#5564017L, qty#5564079], functions=[pivotfirst(label#5564086, max(kpi.`value` AS value)#5564152, 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#5564008, worklistShardItemId#5564017L, knownfloatingpointnormalized(normalizenanandzero(qty#5564079)) AS qty#5564079], functions=[partial_pivotfirst(label#5564086, max(kpi.`value` AS value)#5564152, 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#5564008, worklistShardItemId#5564017L, qty#5564079, label#5564086], functions=[max(_extract_value#5564716)])"]; 21 [id="node21" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5564008, worklistShardItemId#5564017L, knownfloatingpointnormalized(normalizenanandzero(qty#5564079)) AS qty#5564079, label#5564086], functions=[partial_max(_extract_value#5564716)])"]; 22 [id="node22" labelType="html" label=" Project " tooltip="Project [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, kpi#5564085.value AS _extract_value#5564716, concat(kpi:, kpi#5564085.label) AS label#5564086]"]; 23 [id="node23" labelType="html" label=" Generate " tooltip="Generate explode(kpis#5564083), [shardId#5564008, worklistShardItemId#5564017L, qty#5564079], true, [kpi#5564085]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, coalesce(kpis#5564082, []) AS kpis#5564083]"]; 25 [id="node25" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#5564077, worklistShardItemId#5564078L], [shardId#5564008, worklistShardItemId#5564017L], RightOuter"]; } subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 27 [id="node27" labelType="html" label=" Sort " tooltip="Sort [shardId#5564077 ASC NULLS FIRST, worklistShardItemId#5564078L ASC NULLS FIRST], false, 0"]; } 28 [id="node28" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5564077, worklistShardItemId#5564078L, 30), ENSURE_REQUIREMENTS, [plan_id=2881208]"]; subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 30 [id="node30" labelType="html" label=" Project " tooltip="Project [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, kpis#5564082]"]; 31 [id="node31" labelType="html" label=" Filter " tooltip="Filter (isnotnull(qty#5564079) AND (isnotnull(shardId#5564077) AND isnotnull(worklistShardItemId#5564078L)))"]; 32 [id="node32" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5564077,worklistShardItemId#5564078L,qty#5564079,demandChannel#5564080,demandStream#5564081,kpis#5564082]"]; } subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 34 [id="node34" labelType="html" label=" Sort " tooltip="Sort [shardId#5564008 ASC NULLS FIRST, worklistShardItemId#5564017L ASC NULLS FIRST], false, 0"]; } 35 [id="node35" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5564008, worklistShardItemId#5564017L, 30), ENSURE_REQUIREMENTS, [plan_id=2881149]"]; 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#5564008, worklistShardItemId#5564017L]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Project " tooltip="Project [shardId#5564008, item#5564016L AS worklistShardItemId#5564017L]"]; 39 [id="node39" labelType="html" label=" Generate " tooltip="Generate explode(_extract_worklistShardItemId#5564020), [shardId#5564008], false, [item#5564016L]"]; 40 [id="node40" labelType="html" label=" Project " tooltip="Project [shardId#5564008, items#5564010.worklistShardItemId AS _extract_worklistShardItemId#5564020]"]; 41 [id="node41" labelType="html" label=" Filter " tooltip="Filter ((isnotnull(shardId#5564008) AND ((shardId#5564008 = 0_1_10000001445) AND (isOptimal#5564012 <=> false))) AND ((size(items#5564010.worklistShardItemId, true) > 0) AND isnotnull(items#5564010.worklistShardItemId)))"]; 42 [id="node42" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5564008,orderProposalId#5564009L,items#5564010,optimizationGroups#5564011,isOptimal#5564012,lastModified#5564013,optimizationInsights#5564014]"]; } 43 [id="node43" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 456 ms number of output rows: 29 data size: 1030.4 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2881242]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n25 ms (0 ms, 1 ms, 3 ms (stage 1330121.0: task 2471551))"; tooltip="WholeStageCodegen (7)"; 45 [id="node45" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#5564430L, orderProposalId#5564407L, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, measurements#5564448, constraintLabels#5564438, constraintOperators#5564439, constraintRanks#5564441, constraintValues#5564440, constraintIsActive#5564442, logisticUnits#5564434, optimizationGroups#5564450]"]; } 46 [id="node46" labelType="html" label="Exchange shuffle records written: 29 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 29 local bytes read total (min, med, max (stageId: taskId)) 14.9 KiB (510.0 B, 558.0 B, 1260.0 B (stage 1330121.0: task 2471548)) merged fetch fallback count: 0 local blocks read: 25 remote merged chunks fetched: 0 remote blocks read: 2 data size total (min, med, max (stageId: taskId)) 24.2 KiB (808.0 B, 1616.0 B, 2.7 KiB (stage 1330120.0: task 2471465)) 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 1330120.0: task 2471469)) 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 1330121.0: task 2471553)) remote bytes read total (min, med, max (stageId: taskId)) 1111.0 B (553.0 B, 558.0 B, 558.0 B (stage 1330121.0: task 2471556)) number of partitions: 30 remote reqs duration total (min, med, max (stageId: taskId)) 2 ms (0 ms, 2 ms, 2 ms (stage 1330121.0: task 2471550)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 16.0 KiB (553.0 B, 722.0 B, 1841.0 B (stage 1330120.0: task 2471466))" tooltip="Exchange hashpartitioning(worklistShardItemId#5564430L, 30), REPARTITION_BY_NUM, [plan_id=2881238]"]; subgraph cluster47 { isCluster="true"; id="cluster47"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n2.1 s (85 ms, 120 ms, 163 ms (stage 1330120.0: task 2471476))"; tooltip="WholeStageCodegen (6)"; 48 [id="node48" labelType="html" label=" Project " tooltip="Project [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450]"]; 49 [id="node49" labelType="html" label="Filter number of output rows: 29" tooltip="Filter isnotnull(worklistShardItemId#5564430L)"]; 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.0 s (84 ms, 117 ms, 159 ms (stage 1330120.0: task 2471476)) 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#5564407L,worklistShardItemId#5564430L,logisticUnits#5564434,orderQuantityBaseUom#5564435,orderQuantityBaseUomUuid#5564436,constraintLabels#5564438,constraintOperators#5564439,constraintValues#5564440,constraintRanks#5564441,constraintIsActive#5564442,measurements#5564448,optimizationGroups#5564450,shardId#5564451,sequenceId#5564429] Batched: true, DataFilters: [isnotnull(worklistShardItemId#5564430L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5564451), isnotnull(sequenceId#5564429), (shardId#5564451 = 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: 277 ms number of output rows: 2 data size: 1024.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2881258]"]; 53 [id="node53" labelType="html" label=" Project " tooltip="Project [orderProposalId#5564580L, transform(optimizationGroups#5564582, lambdafunction(if (isnull(lambda x_1061#5564586)) null else named_struct(optGroupId, lambda x_1061#5564586.optGroupId, assignmentDetails, lambda x_1061#5564586.assignmentDetails, minOrderProfile, lambda x_1061#5564586.minOrderProfile, minOrderGoal, if (isnull(lambda x_1061#5564586.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1061#5564586.minOrderGoal.minOrderValue, dimensionType, lambda x_1061#5564586.minOrderGoal.dimensionType, unit, lambda x_1061#5564586.minOrderGoal.unit, unitUuid, lambda x_1061#5564586.minOrderGoal.unitUuid, isoCode, lambda x_1061#5564586.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1061#5564586.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1061#5564586.minOrderGoal.acceptanceThreshold)), lambda x_1061#5564586, false)) AS optimizationGroups#5564579, sequenceId#5564581]"]; 54 [id="node54" labelType="html" label="Exchange shuffle records written: 2 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 2 local bytes read total (min, med, max (stageId: taskId)) 188.0 B (94.0 B, 94.0 B, 94.0 B (stage 1330119.0: task 2471485)) 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 1330118.0: task 2471464)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 1330118.0: task 2471463)) 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 1330119.0: task 2471485)) remote bytes read: 0.0 B number of partitions: 30 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 188.0 B (94.0 B, 94.0 B, 94.0 B (stage 1330118.0: task 2471464))" tooltip="Exchange hashpartitioning(orderProposalId#5564580L, 30), REPARTITION_BY_NUM, [plan_id=2881256]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n277 ms (134 ms, 143 ms, 143 ms (stage 1330118.0: task 2471463))"; tooltip="WholeStageCodegen (9)"; 56 [id="node56" labelType="html" label=" Project " tooltip="Project [orderProposalId#5564580L, sequenceId#5564581, optimizationGroups#5564582]"]; 57 [id="node57" labelType="html" label="Filter number of output rows: 2" tooltip="Filter isnotnull(orderProposalId#5564580L)"]; 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)) 217 ms (105 ms, 112 ms, 112 ms (stage 1330118.0: task 2471463)) 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#5564580L,optimizationGroups#5564582,shardId#5564583,sequenceId#5564581] Batched: true, DataFilters: [isnotnull(orderProposalId#5564580L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5564583), isnotnull(sequenceId#5564581), (shardId#5564583 = 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: 243 ms number of output rows: 1 data size: 1288.0 B" tooltip="BroadcastExchange IdentityBroadcastMode, [plan_id=2881267]"]; 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=2881266]"]; subgraph cluster62 { isCluster="true"; id="cluster62"; label="WholeStageCodegen (10)\n \nduration: 118 ms"; tooltip="WholeStageCodegen (10)"; 63 [id="node63" labelType="html" label=" Project " tooltip="Project [uomCategories#5564591, insightConfigurations#5564592]"]; 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: 115 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#5564591,insightConfigurations#5564592,shardId#5564593] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5564593), (shardId#5564593 = 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#5564077, worklistShardItemId#5564078L, qty#5564079, demandChannel#5564080, demandStream#5564081, kpis#5564082]
Arguments: [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, demandChannel#5564080, demandStream#5564081, kpis#5564082], MapPartitionsRDD[391512] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(2) Filter [codegen id : 1]
Input [6]: [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, demandChannel#5564080, demandStream#5564081, kpis#5564082]
Condition : (isnotnull(qty#5564079) AND (isnotnull(shardId#5564077) AND isnotnull(worklistShardItemId#5564078L)))

(3) Project [codegen id : 1]
Output [4]: [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, kpis#5564082]
Input [6]: [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, demandChannel#5564080, demandStream#5564081, kpis#5564082]

(4) Exchange
Input [4]: [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, kpis#5564082]
Arguments: hashpartitioning(shardId#5564077, worklistShardItemId#5564078L, 30), ENSURE_REQUIREMENTS, [plan_id=2881208]

(5) Sort [codegen id : 2]
Input [4]: [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, kpis#5564082]
Arguments: [shardId#5564077 ASC NULLS FIRST, worklistShardItemId#5564078L ASC NULLS FIRST], false, 0

(6) InMemoryTableScan
Output [2]: [shardId#5564008, worklistShardItemId#5564017L]
Arguments: [shardId#5564008, worklistShardItemId#5564017L]

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

(8) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014]
Arguments: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014], MapPartitionsRDD[391500] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(9) Filter [codegen id : 1]
Input [7]: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014]
Condition : ((isnotnull(shardId#5564008) AND ((shardId#5564008 = 0_1_10000001445) AND (isOptimal#5564012 <=> false))) AND ((size(items#5564010.worklistShardItemId, true) > 0) AND isnotnull(items#5564010.worklistShardItemId)))

(10) Project [codegen id : 1]
Output [2]: [shardId#5564008, items#5564010.worklistShardItemId AS _extract_worklistShardItemId#5564020]
Input [7]: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014]

(11) Generate [codegen id : 1]
Input [2]: [shardId#5564008, _extract_worklistShardItemId#5564020]
Arguments: explode(_extract_worklistShardItemId#5564020), [shardId#5564008], false, [item#5564016L]

(12) Project [codegen id : 1]
Output [2]: [shardId#5564008, item#5564016L AS worklistShardItemId#5564017L]
Input [2]: [shardId#5564008, item#5564016L]

(13) Exchange
Input [2]: [shardId#5564008, worklistShardItemId#5564017L]
Arguments: hashpartitioning(shardId#5564008, worklistShardItemId#5564017L, 30), ENSURE_REQUIREMENTS, [plan_id=2881149]

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

(15) SortMergeJoin [codegen id : 4]
Left keys [2]: [shardId#5564077, worklistShardItemId#5564078L]
Right keys [2]: [shardId#5564008, worklistShardItemId#5564017L]
Join type: RightOuter
Join condition: None

(16) Project [codegen id : 4]
Output [4]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, coalesce(kpis#5564082, []) AS kpis#5564083]
Input [6]: [shardId#5564077, worklistShardItemId#5564078L, qty#5564079, kpis#5564082, shardId#5564008, worklistShardItemId#5564017L]

(17) Generate [codegen id : 4]
Input [4]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, kpis#5564083]
Arguments: explode(kpis#5564083), [shardId#5564008, worklistShardItemId#5564017L, qty#5564079], true, [kpi#5564085]

(18) Project [codegen id : 4]
Output [5]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, kpi#5564085.value AS _extract_value#5564716, concat(kpi:, kpi#5564085.label) AS label#5564086]
Input [4]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, kpi#5564085]

(19) HashAggregate [codegen id : 4]
Input [5]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, _extract_value#5564716, label#5564086]
Keys [4]: [shardId#5564008, worklistShardItemId#5564017L, knownfloatingpointnormalized(normalizenanandzero(qty#5564079)) AS qty#5564079, label#5564086]
Functions [1]: [partial_max(_extract_value#5564716)]
Aggregate Attributes [1]: [max#5564943]
Results [5]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, label#5564086, max#5564944]

(20) HashAggregate [codegen id : 4]
Input [5]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, label#5564086, max#5564944]
Keys [4]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, label#5564086]
Functions [1]: [max(_extract_value#5564716)]
Aggregate Attributes [1]: [max(_extract_value#5564716)#5564151]
Results [5]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, label#5564086, max(_extract_value#5564716)#5564151 AS max(kpi.`value` AS value)#5564152]

(21) HashAggregate
Input [5]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, label#5564086, max(kpi.`value` AS value)#5564152]
Keys [3]: [shardId#5564008, worklistShardItemId#5564017L, knownfloatingpointnormalized(normalizenanandzero(qty#5564079)) AS qty#5564079]
Functions [1]: [partial_pivotfirst(label#5564086, max(kpi.`value` AS value)#5564152, 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#5564153, kpi:OutOfStockProbability#5564154, kpi:PeriodSpoilageQty#5564155, kpi:RangeOfCoverage#5564156, kpi:RemainingStockQty#5564157, kpi:SalesQty#5564158, kpi:ServiceLevel#5564159, kpi:ServiceLevelAtStartOfDelisting#5564160, kpi:ServiceLevelMinimumStock#5564161, kpi:ShelfCapacityOverrun#5564162, kpi:ShelfCapacityUnderrun#5564163, kpi:SpoilageQty#5564164, kpi:UnfulfilledDemandQty#5564165]
Results [16]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, kpi:EndOfPeriodVirtualStockQty#5564166, kpi:OutOfStockProbability#5564167, kpi:PeriodSpoilageQty#5564168, kpi:RangeOfCoverage#5564169, kpi:RemainingStockQty#5564170, kpi:SalesQty#5564171, kpi:ServiceLevel#5564172, kpi:ServiceLevelAtStartOfDelisting#5564173, kpi:ServiceLevelMinimumStock#5564174, kpi:ShelfCapacityOverrun#5564175, kpi:ShelfCapacityUnderrun#5564176, kpi:SpoilageQty#5564177, kpi:UnfulfilledDemandQty#5564178]

(22) HashAggregate
Input [16]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, kpi:EndOfPeriodVirtualStockQty#5564166, kpi:OutOfStockProbability#5564167, kpi:PeriodSpoilageQty#5564168, kpi:RangeOfCoverage#5564169, kpi:RemainingStockQty#5564170, kpi:SalesQty#5564171, kpi:ServiceLevel#5564172, kpi:ServiceLevelAtStartOfDelisting#5564173, kpi:ServiceLevelMinimumStock#5564174, kpi:ShelfCapacityOverrun#5564175, kpi:ShelfCapacityUnderrun#5564176, kpi:SpoilageQty#5564177, kpi:UnfulfilledDemandQty#5564178]
Keys [3]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079]
Functions [1]: [pivotfirst(label#5564086, max(kpi.`value` AS value)#5564152, 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#5564086, max(kpi.`value` AS value)#5564152, 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)#5564179]
Results [4]: [shardId#5564008, worklistShardItemId#5564017L, qty#5564079, pivotfirst(label#5564086, max(kpi.`value` AS value)#5564152, 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)#5564179 AS __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5564180]

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

(24) ObjectHashAggregate
Input [3]: [shardId#5564008, worklistShardItemId#5564017L, struct#5564220]
Keys [2]: [shardId#5564008, worklistShardItemId#5564017L]
Functions [2]: [partial_max(struct#5564220.qty), partial_collect_list(struct#5564220, 0, 0)]
Aggregate Attributes [2]: [max#5564939, buf#5564940]
Results [4]: [shardId#5564008, worklistShardItemId#5564017L, max#5564941, buf#5564942]

(25) ObjectHashAggregate
Input [4]: [shardId#5564008, worklistShardItemId#5564017L, max#5564941, buf#5564942]
Keys [2]: [shardId#5564008, worklistShardItemId#5564017L]
Functions [2]: [max(struct#5564220.qty), collect_list(struct#5564220, 0, 0)]
Aggregate Attributes [2]: [max(struct#5564220.qty)#5564240, collect_list(struct#5564220, 0, 0)#5564241]
Results [3]: [shardId#5564008, worklistShardItemId#5564017L, sort_array(CASE WHEN isnull(max(struct#5564220.qty)#5564240) THEN [] ELSE collect_list(struct#5564220, 0, 0)#5564241 END, true) AS struct_array#5564221]

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

(27) Scan parquet 
Output [14]: [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450, shardId#5564451, sequenceId#5564429]
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#5564451), isnotnull(sequenceId#5564429), (shardId#5564451 = 0_1_10000001445), (sequenceId#5564429 = 8)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,worklistShardItemId:bigint,logisticUnits:array<struct<uom:string,uomUuid:string,numerator:int,denominator:int,isOrderUnit:boolean,isPreferred:boolean>>,orderQuantityBaseUom:string,orderQuantityBaseUomUuid:string,constraintLabels:array<string>,constraintOperators:array<string>,constraintValues:array<double>,constraintRanks:array<int>,constraintIsActive:array<boolean>,measurements:array<struct<value:double,dimensionType:int,dimensionCode:string,dimensionCodeUuid:string,isoCode:string>>,optimizationGroups:array<string>>

(28) ColumnarToRow [codegen id : 6]
Input [14]: [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450, shardId#5564451, sequenceId#5564429]

(29) Filter [codegen id : 6]
Input [14]: [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450, shardId#5564451, sequenceId#5564429]
Condition : isnotnull(worklistShardItemId#5564430L)

(30) Project [codegen id : 6]
Output [12]: [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450]
Input [14]: [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450, shardId#5564451, sequenceId#5564429]

(31) Exchange
Input [12]: [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450]
Arguments: hashpartitioning(worklistShardItemId#5564430L, 30), REPARTITION_BY_NUM, [plan_id=2881238]

(32) Project [codegen id : 7]
Output [12]: [worklistShardItemId#5564430L, orderProposalId#5564407L, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, measurements#5564448, constraintLabels#5564438, constraintOperators#5564439, constraintRanks#5564441, constraintValues#5564440, constraintIsActive#5564442, logisticUnits#5564434, optimizationGroups#5564450]
Input [12]: [orderProposalId#5564407L, worklistShardItemId#5564430L, logisticUnits#5564434, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, constraintLabels#5564438, constraintOperators#5564439, constraintValues#5564440, constraintRanks#5564441, constraintIsActive#5564442, measurements#5564448, optimizationGroups#5564450]

(33) BroadcastExchange
Input [12]: [worklistShardItemId#5564430L, orderProposalId#5564407L, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, measurements#5564448, constraintLabels#5564438, constraintOperators#5564439, constraintRanks#5564441, constraintValues#5564440, constraintIsActive#5564442, logisticUnits#5564434, optimizationGroups#5564450]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2881242]

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

(35) Project [codegen id : 8]
Output [15]: [shardId#5564008, worklistShardItemId#5564017L, quantities#5564242, kpis#5564256, constraintValues#5564440, constraintOperators#5564439, constraintLabels#5564438, constraintRanks#5564441, constraintIsActive#5564442, orderProposalId#5564407L, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, logisticUnits#5564434, optimizationGroups#5564450, measurements#5564448]
Input [16]: [shardId#5564008, worklistShardItemId#5564017L, quantities#5564242, kpis#5564256, worklistShardItemId#5564430L, orderProposalId#5564407L, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, measurements#5564448, constraintLabels#5564438, constraintOperators#5564439, constraintRanks#5564441, constraintValues#5564440, constraintIsActive#5564442, logisticUnits#5564434, optimizationGroups#5564450]

(36) ObjectHashAggregate
Input [15]: [shardId#5564008, worklistShardItemId#5564017L, quantities#5564242, kpis#5564256, constraintValues#5564440, constraintOperators#5564439, constraintLabels#5564438, constraintRanks#5564441, constraintIsActive#5564442, orderProposalId#5564407L, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid#5564436, logisticUnits#5564434, optimizationGroups#5564450, measurements#5564448]
Keys [2]: [shardId#5564008, orderProposalId#5564407L]
Functions [1]: [partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5564017L, quantities, quantities#5564242, kpis, kpis#5564256, constraintValues, constraintValues#5564440, constraintOperators, constraintOperators#5564439, constraintLabels, constraintLabels#5564438, constraintRanks, constraintRanks#5564441, constraintIsActive, constraintIsActive#5564442, orderQuantityBaseUom, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5564436, logisticUnits, logisticUnits#5564434, optimizationGroups, optimizationGroups#5564450, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [buf#5564937]
Results [3]: [shardId#5564008, orderProposalId#5564407L, buf#5564938]

(37) Exchange
Input [3]: [shardId#5564008, orderProposalId#5564407L, buf#5564938]
Arguments: hashpartitioning(shardId#5564008, orderProposalId#5564407L, 30), ENSURE_REQUIREMENTS, [plan_id=2881248]

(38) ObjectHashAggregate
Input [3]: [shardId#5564008, orderProposalId#5564407L, buf#5564938]
Keys [2]: [shardId#5564008, orderProposalId#5564407L]
Functions [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5564017L, quantities, quantities#5564242, kpis, kpis#5564256, constraintValues, constraintValues#5564440, constraintOperators, constraintOperators#5564439, constraintLabels, constraintLabels#5564438, constraintRanks, constraintRanks#5564441, constraintIsActive, constraintIsActive#5564442, orderQuantityBaseUom, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5564436, logisticUnits, logisticUnits#5564434, optimizationGroups, optimizationGroups#5564450, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5564017L, quantities, quantities#5564242, kpis, kpis#5564256, constraintValues, constraintValues#5564440, constraintOperators, constraintOperators#5564439, constraintLabels, constraintLabels#5564438, constraintRanks, constraintRanks#5564441, constraintIsActive, constraintIsActive#5564442, orderQuantityBaseUom, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5564436, logisticUnits, logisticUnits#5564434, optimizationGroups, optimizationGroups#5564450, measurements, ... 1 more fields), 0, 0)#5564576]
Results [3]: [shardId#5564008, orderProposalId#5564407L, collect_list(struct(worklistShardItemId, worklistShardItemId#5564017L, quantities, quantities#5564242, kpis, kpis#5564256, constraintValues, constraintValues#5564440, constraintOperators, constraintOperators#5564439, constraintLabels, constraintLabels#5564438, constraintRanks, constraintRanks#5564441, constraintIsActive, constraintIsActive#5564442, orderQuantityBaseUom, orderQuantityBaseUom#5564435, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5564436, logisticUnits, logisticUnits#5564434, optimizationGroups, optimizationGroups#5564450, measurements, ... 1 more fields), 0, 0)#5564576 AS items#5564560]

(39) Scan parquet 
Output [4]: [orderProposalId#5564580L, optimizationGroups#5564582, shardId#5564583, sequenceId#5564581]
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#5564583), isnotnull(sequenceId#5564581), (shardId#5564583 = 0_1_10000001445), (sequenceId#5564581 = 8)]
PushedFilters: [IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,optimizationGroups:array<struct<optGroupId:string,minOrderProfile:string,assignmentDetails:string,minOrderGoal:struct<minOrderValue:double,dimensionType:int,unit:string,unitUuid:string,negligibleQuantitiesThreshold:double,acceptanceThreshold:double,isoCode:string>>>>

(40) ColumnarToRow [codegen id : 9]
Input [4]: [orderProposalId#5564580L, optimizationGroups#5564582, shardId#5564583, sequenceId#5564581]

(41) Filter [codegen id : 9]
Input [4]: [orderProposalId#5564580L, optimizationGroups#5564582, shardId#5564583, sequenceId#5564581]
Condition : isnotnull(orderProposalId#5564580L)

(42) Project [codegen id : 9]
Output [3]: [orderProposalId#5564580L, sequenceId#5564581, optimizationGroups#5564582]
Input [4]: [orderProposalId#5564580L, optimizationGroups#5564582, shardId#5564583, sequenceId#5564581]

(43) Exchange
Input [3]: [orderProposalId#5564580L, sequenceId#5564581, optimizationGroups#5564582]
Arguments: hashpartitioning(orderProposalId#5564580L, 30), REPARTITION_BY_NUM, [plan_id=2881256]

(44) Project
Output [3]: [orderProposalId#5564580L, transform(optimizationGroups#5564582, lambdafunction(if (isnull(lambda x_1061#5564586)) null else named_struct(optGroupId, lambda x_1061#5564586.optGroupId, assignmentDetails, lambda x_1061#5564586.assignmentDetails, minOrderProfile, lambda x_1061#5564586.minOrderProfile, minOrderGoal, if (isnull(lambda x_1061#5564586.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1061#5564586.minOrderGoal.minOrderValue, dimensionType, lambda x_1061#5564586.minOrderGoal.dimensionType, unit, lambda x_1061#5564586.minOrderGoal.unit, unitUuid, lambda x_1061#5564586.minOrderGoal.unitUuid, isoCode, lambda x_1061#5564586.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1061#5564586.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1061#5564586.minOrderGoal.acceptanceThreshold)), lambda x_1061#5564586, false)) AS optimizationGroups#5564579, sequenceId#5564581]
Input [3]: [orderProposalId#5564580L, sequenceId#5564581, optimizationGroups#5564582]

(45) BroadcastExchange
Input [3]: [orderProposalId#5564580L, optimizationGroups#5564579, sequenceId#5564581]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2881258]

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

(47) Project [codegen id : 11]
Output [5]: [shardId#5564008, orderProposalId#5564407L, items#5564560, optimizationGroups#5564579, sequenceId#5564581]
Input [6]: [shardId#5564008, orderProposalId#5564407L, items#5564560, orderProposalId#5564580L, optimizationGroups#5564579, sequenceId#5564581]

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

(50) Project [codegen id : 10]
Output [2]: [uomCategories#5564591, insightConfigurations#5564592]
Input [3]: [uomCategories#5564591, insightConfigurations#5564592, shardId#5564593]

(51) Exchange
Input [2]: [uomCategories#5564591, insightConfigurations#5564592]
Arguments: RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=2881266]

(52) BroadcastExchange
Input [2]: [uomCategories#5564591, insightConfigurations#5564592]
Arguments: IdentityBroadcastMode, [plan_id=2881267]

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

(54) DeserializeToObject
Input [7]: [shardId#5564008, orderProposalId#5564407L, items#5564560, optimizationGroups#5564579, sequenceId#5564581, uomCategories#5564591, insightConfigurations#5564592]
Arguments: createexternalrow(invoke(shardId#5564008.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5564407L)), 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#5564560, 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#5564579, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5564581)), 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#5564591, 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#5564592, 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#5564611: org.apache.spark.sql.Row

(55) MapPartitions
Input [1]: [obj#5564611]
Arguments: org.apache.spark.sql.internal.ToScalaUDF$$$Lambda/0x000000080248b3a0@5d718e3d, obj#5564618: org.apache.spark.sql.Row

SQL / DataFrame Properties

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