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

Submitted Time: 2026/07/21 20:42:16
Duration: 2 s
Succeeded Jobs: 46185 46186 46187

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@6d8aab8e, obj#5474276: org.apache.spark.sql.Row"]; 1 [id="node1" labelType="html" label=" DeserializeToObject " tooltip="DeserializeToObject createexternalrow(invoke(shardId#5473666.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5474065L)), 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#5474218, 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#5474237, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5474239)), 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#5474249, 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#5474250, 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#5474269: 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#5473666 = 0_1_10000001445)"]; 4 [id="node4" labelType="html" label=" Project " tooltip="Project [shardId#5473666, orderProposalId#5474065L, items#5474218, optimizationGroups#5474237, sequenceId#5474239]"]; 5 [id="node5" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [orderProposalId#5474065L], [orderProposalId#5474238L], LeftOuter, BuildRight, (shardId#5473666 = 0_1_10000001445), false"]; } 6 [id="node6" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5473666, orderProposalId#5474065L], functions=[collect_list(struct(worklistShardItemId, worklistShardItemId#5473675L, quantities, quantities#5473900, kpis, kpis#5473914, constraintValues, constraintValues#5474098, constraintOperators, constraintOperators#5474097, constraintLabels, constraintLabels#5474096, constraintRanks, constraintRanks#5474099, constraintIsActive, constraintIsActive#5474100, orderQuantityBaseUom, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5474094, logisticUnits, logisticUnits#5474092, optimizationGroups, optimizationGroups#5474108, measurements, ... 1 more fields), 0, 0)])"]; 7 [id="node7" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5473666, orderProposalId#5474065L, 30), ENSURE_REQUIREMENTS, [plan_id=2834585]"]; 8 [id="node8" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5473666, orderProposalId#5474065L], functions=[partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5473675L, quantities, quantities#5473900, kpis, kpis#5473914, constraintValues, constraintValues#5474098, constraintOperators, constraintOperators#5474097, constraintLabels, constraintLabels#5474096, constraintRanks, constraintRanks#5474099, constraintIsActive, constraintIsActive#5474100, orderQuantityBaseUom, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5474094, logisticUnits, logisticUnits#5474092, optimizationGroups, optimizationGroups#5474108, 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#5473666, worklistShardItemId#5473675L, quantities#5473900, kpis#5473914, constraintValues#5474098, constraintOperators#5474097, constraintLabels#5474096, constraintRanks#5474099, constraintIsActive#5474100, orderProposalId#5474065L, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, logisticUnits#5474092, optimizationGroups#5474108, measurements#5474106]"]; 11 [id="node11" labelType="html" label=" BroadcastHashJoin " tooltip="BroadcastHashJoin [worklistShardItemId#5473675L], [worklistShardItemId#5474088L], LeftOuter, BuildRight, (shardId#5473666 = 0_1_10000001445), false"]; 12 [id="node12" labelType="html" label=" Project " tooltip="Project [shardId#5473666, worklistShardItemId#5473675L, struct_array#5473879.qty AS quantities#5473900, struct(EndOfPeriodVirtualStockQty, struct_array#5473879.kpi:EndOfPeriodVirtualStockQty, OutOfStockProbability, struct_array#5473879.kpi:OutOfStockProbability, PeriodSpoilageQty, struct_array#5473879.kpi:PeriodSpoilageQty, RangeOfCoverage, struct_array#5473879.kpi:RangeOfCoverage, RemainingStockQty, struct_array#5473879.kpi:RemainingStockQty, SalesQty, struct_array#5473879.kpi:SalesQty, ServiceLevel, struct_array#5473879.kpi:ServiceLevel, ServiceLevelAtStartOfDelisting, struct_array#5473879.kpi:ServiceLevelAtStartOfDelisting, ServiceLevelMinimumStock, struct_array#5473879.kpi:ServiceLevelMinimumStock, ShelfCapacityOverrun, struct_array#5473879.kpi:ShelfCapacityOverrun, ShelfCapacityUnderrun, struct_array#5473879.kpi:ShelfCapacityUnderrun, SpoilageQty, struct_array#5473879.kpi:SpoilageQty, UnfulfilledDemandQty, ... 1 more fields) AS kpis#5473914]"]; } 13 [id="node13" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5473666, worklistShardItemId#5473675L], functions=[max(struct#5473878.qty), collect_list(struct#5473878, 0, 0)])"]; 14 [id="node14" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#5473666, worklistShardItemId#5473675L], functions=[partial_max(struct#5473878.qty), partial_collect_list(struct#5473878, 0, 0)])"]; subgraph cluster15 { isCluster="true"; id="cluster15"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [shardId#5473666, worklistShardItemId#5473675L, struct(qty, qty#5473737, kpi:EndOfPeriodVirtualStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[0], kpi:OutOfStockProbability, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[1], kpi:PeriodSpoilageQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[2], kpi:RangeOfCoverage, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[3], kpi:RemainingStockQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[4], kpi:SalesQty, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[5], kpi:ServiceLevel, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[6], kpi:ServiceLevelAtStartOfDelisting, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[7], kpi:ServiceLevelMinimumStock, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[8], kpi:ShelfCapacityOverrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[9], kpi:ShelfCapacityUnderrun, __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838[10], kpi:SpoilageQty, ... 3 more fields) AS struct#5473878]"]; } 17 [id="node17" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5473666, worklistShardItemId#5473675L, qty#5473737], functions=[pivotfirst(label#5473744, max(kpi.`value` AS value)#5473810, 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#5473666, worklistShardItemId#5473675L, knownfloatingpointnormalized(normalizenanandzero(qty#5473737)) AS qty#5473737], functions=[partial_pivotfirst(label#5473744, max(kpi.`value` AS value)#5473810, 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#5473666, worklistShardItemId#5473675L, qty#5473737, label#5473744], functions=[max(_extract_value#5474374)])"]; 21 [id="node21" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#5473666, worklistShardItemId#5473675L, knownfloatingpointnormalized(normalizenanandzero(qty#5473737)) AS qty#5473737, label#5473744], functions=[partial_max(_extract_value#5474374)])"]; 22 [id="node22" labelType="html" label=" Project " tooltip="Project [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, kpi#5473743.value AS _extract_value#5474374, concat(kpi:, kpi#5473743.label) AS label#5473744]"]; 23 [id="node23" labelType="html" label=" Generate " tooltip="Generate explode(kpis#5473741), [shardId#5473666, worklistShardItemId#5473675L, qty#5473737], true, [kpi#5473743]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, coalesce(kpis#5473740, []) AS kpis#5473741]"]; 25 [id="node25" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#5473735, worklistShardItemId#5473736L], [shardId#5473666, worklistShardItemId#5473675L], RightOuter"]; } subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 27 [id="node27" labelType="html" label=" Sort " tooltip="Sort [shardId#5473735 ASC NULLS FIRST, worklistShardItemId#5473736L ASC NULLS FIRST], false, 0"]; } 28 [id="node28" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5473735, worklistShardItemId#5473736L, 30), ENSURE_REQUIREMENTS, [plan_id=2834545]"]; subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 30 [id="node30" labelType="html" label=" Project " tooltip="Project [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, kpis#5473740]"]; 31 [id="node31" labelType="html" label=" Filter " tooltip="Filter (isnotnull(qty#5473737) AND (isnotnull(shardId#5473735) AND isnotnull(worklistShardItemId#5473736L)))"]; 32 [id="node32" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5473735,worklistShardItemId#5473736L,qty#5473737,demandChannel#5473738,demandStream#5473739,kpis#5473740]"]; } subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 34 [id="node34" labelType="html" label=" Sort " tooltip="Sort [shardId#5473666 ASC NULLS FIRST, worklistShardItemId#5473675L ASC NULLS FIRST], false, 0"]; } 35 [id="node35" labelType="html" label="Exchange number of partitions: 30" tooltip="Exchange hashpartitioning(shardId#5473666, worklistShardItemId#5473675L, 30), ENSURE_REQUIREMENTS, [plan_id=2834486]"]; 36 [id="node36" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#5473666, worklistShardItemId#5473675L]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 38 [id="node38" labelType="html" label=" Project " tooltip="Project [shardId#5473666, item#5473674L AS worklistShardItemId#5473675L]"]; 39 [id="node39" labelType="html" label=" Generate " tooltip="Generate explode(_extract_worklistShardItemId#5473678), [shardId#5473666], false, [item#5473674L]"]; 40 [id="node40" labelType="html" label=" Project " tooltip="Project [shardId#5473666, items#5473668.worklistShardItemId AS _extract_worklistShardItemId#5473678]"]; 41 [id="node41" labelType="html" label=" Filter " tooltip="Filter ((isnotnull(shardId#5473666) AND ((shardId#5473666 = 0_1_10000001445) AND (isOptimal#5473670 <=> false))) AND ((size(items#5473668.worklistShardItemId, true) > 0) AND isnotnull(items#5473668.worklistShardItemId)))"]; 42 [id="node42" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#5473666,orderProposalId#5473667L,items#5473668,optimizationGroups#5473669,isOptimal#5473670,lastModified#5473671,optimizationInsights#5473672]"]; } 43 [id="node43" labelType="html" label="BroadcastExchange time to broadcast: 5 ms time to build: 1 ms time to collect: 898 ms number of output rows: 29 data size: 1030.4 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2834579]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n25 ms (0 ms, 0 ms, 4 ms (stage 1302668.0: task 2427648))"; tooltip="WholeStageCodegen (7)"; 45 [id="node45" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#5474088L, orderProposalId#5474065L, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, measurements#5474106, constraintLabels#5474096, constraintOperators#5474097, constraintRanks#5474099, constraintValues#5474098, constraintIsActive#5474100, logisticUnits#5474092, optimizationGroups#5474108]"]; } 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)) 13.6 KiB (553.0 B, 561.0 B, 1114.0 B (stage 1302668.0: task 2427647)) merged fetch fallback count: 0 local blocks read: 23 remote merged chunks fetched: 0 remote blocks read: 4 data size total (min, med, max (stageId: taskId)) 24.2 KiB (808.0 B, 1616.0 B, 2.7 KiB (stage 1302667.0: task 2427558)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 14 ms (0 ms, 0 ms, 6 ms (stage 1302667.0: task 2427561)) 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 1302668.0: task 2427643)) remote bytes read total (min, med, max (stageId: taskId)) 2.4 KiB (558.0 B, 774.0 B, 1119.0 B (stage 1302668.0: task 2427640)) number of partitions: 30 remote reqs duration total (min, med, max (stageId: taskId)) 5 ms (0 ms, 2 ms, 3 ms (stage 1302668.0: task 2427640)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 16.0 KiB (553.0 B, 688.0 B, 1885.0 B (stage 1302667.0: task 2427558))" tooltip="Exchange hashpartitioning(worklistShardItemId#5474088L, 30), REPARTITION_BY_NUM, [plan_id=2834575]"]; subgraph cluster47 { isCluster="true"; id="cluster47"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n1.8 s (93 ms, 104 ms, 141 ms (stage 1302667.0: task 2427565))"; tooltip="WholeStageCodegen (6)"; 48 [id="node48" labelType="html" label=" Project " tooltip="Project [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108]"]; 49 [id="node49" labelType="html" label="Filter number of output rows: 29" tooltip="Filter isnotnull(worklistShardItemId#5474088L)"]; 50 [id="node50" labelType="html" label="ColumnarToRow number of output rows: 29 number of input batches: 17" tooltip="ColumnarToRow"]; } 51 [id="node51" labelType="html" label="Scan parquet number of files read: 17 scan time total (min, med, max (stageId: taskId)) 1.8 s (91 ms, 99 ms, 140 ms (stage 1302667.0: task 2427565)) 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#5474065L,worklistShardItemId#5474088L,logisticUnits#5474092,orderQuantityBaseUom#5474093,orderQuantityBaseUomUuid#5474094,constraintLabels#5474096,constraintOperators#5474097,constraintValues#5474098,constraintRanks#5474099,constraintIsActive#5474100,measurements#5474106,optimizationGroups#5474108,shardId#5474109,sequenceId#5474087] Batched: true, DataFilters: [isnotnull(worklistShardItemId#5474088L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5474109), isnotnull(sequenceId#5474087), (shardId#5474109 = 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: 269 ms number of output rows: 2 data size: 1024.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2834595]"]; 53 [id="node53" labelType="html" label=" Project " tooltip="Project [orderProposalId#5474238L, transform(optimizationGroups#5474240, lambdafunction(if (isnull(lambda x_1039#5474244)) null else named_struct(optGroupId, lambda x_1039#5474244.optGroupId, assignmentDetails, lambda x_1039#5474244.assignmentDetails, minOrderProfile, lambda x_1039#5474244.minOrderProfile, minOrderGoal, if (isnull(lambda x_1039#5474244.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1039#5474244.minOrderGoal.minOrderValue, dimensionType, lambda x_1039#5474244.minOrderGoal.dimensionType, unit, lambda x_1039#5474244.minOrderGoal.unit, unitUuid, lambda x_1039#5474244.minOrderGoal.unitUuid, isoCode, lambda x_1039#5474244.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1039#5474244.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1039#5474244.minOrderGoal.acceptanceThreshold)), lambda x_1039#5474244, false)) AS optimizationGroups#5474237, sequenceId#5474239]"]; 54 [id="node54" labelType="html" label="Exchange shuffle records written: 2 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 2 local bytes read total (min, med, max (stageId: taskId)) 192.0 B (96.0 B, 96.0 B, 96.0 B (stage 1302666.0: task 2427603)) 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 1302665.0: task 2427556)) 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 1302665.0: task 2427557)) 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 1302666.0: task 2427603)) remote bytes read: 0.0 B number of partitions: 30 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 192.0 B (96.0 B, 96.0 B, 96.0 B (stage 1302665.0: task 2427556))" tooltip="Exchange hashpartitioning(orderProposalId#5474238L, 30), REPARTITION_BY_NUM, [plan_id=2834593]"]; subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n235 ms (111 ms, 124 ms, 124 ms (stage 1302665.0: task 2427556))"; tooltip="WholeStageCodegen (9)"; 56 [id="node56" labelType="html" label=" Project " tooltip="Project [orderProposalId#5474238L, sequenceId#5474239, optimizationGroups#5474240]"]; 57 [id="node57" labelType="html" label="Filter number of output rows: 2" tooltip="Filter isnotnull(orderProposalId#5474238L)"]; 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)) 193 ms (90 ms, 103 ms, 103 ms (stage 1302665.0: task 2427556)) 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#5474238L,optimizationGroups#5474240,shardId#5474241,sequenceId#5474239] Batched: true, DataFilters: [isnotnull(orderProposalId#5474238L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5474241), isnotnull(sequenceId#5474239), (shardId#5474241 = 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: 178 ms number of output rows: 1 data size: 1288.0 B" tooltip="BroadcastExchange IdentityBroadcastMode, [plan_id=2834604]"]; 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=2834603]"]; subgraph cluster62 { isCluster="true"; id="cluster62"; label="WholeStageCodegen (10)\n \nduration: 93 ms"; tooltip="WholeStageCodegen (10)"; 63 [id="node63" labelType="html" label=" Project " tooltip="Project [uomCategories#5474249, insightConfigurations#5474250]"]; 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: 90 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#5474249,insightConfigurations#5474250,shardId#5474251] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5474251), (shardId#5474251 = 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#5473735, worklistShardItemId#5473736L, qty#5473737, demandChannel#5473738, demandStream#5473739, kpis#5473740]
Arguments: [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, demandChannel#5473738, demandStream#5473739, kpis#5473740], MapPartitionsRDD[384640] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(2) Filter [codegen id : 1]
Input [6]: [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, demandChannel#5473738, demandStream#5473739, kpis#5473740]
Condition : (isnotnull(qty#5473737) AND (isnotnull(shardId#5473735) AND isnotnull(worklistShardItemId#5473736L)))

(3) Project [codegen id : 1]
Output [4]: [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, kpis#5473740]
Input [6]: [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, demandChannel#5473738, demandStream#5473739, kpis#5473740]

(4) Exchange
Input [4]: [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, kpis#5473740]
Arguments: hashpartitioning(shardId#5473735, worklistShardItemId#5473736L, 30), ENSURE_REQUIREMENTS, [plan_id=2834545]

(5) Sort [codegen id : 2]
Input [4]: [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, kpis#5473740]
Arguments: [shardId#5473735 ASC NULLS FIRST, worklistShardItemId#5473736L ASC NULLS FIRST], false, 0

(6) InMemoryTableScan
Output [2]: [shardId#5473666, worklistShardItemId#5473675L]
Arguments: [shardId#5473666, worklistShardItemId#5473675L]

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

(8) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#5473666, orderProposalId#5473667L, items#5473668, optimizationGroups#5473669, isOptimal#5473670, lastModified#5473671, optimizationInsights#5473672]
Arguments: [shardId#5473666, orderProposalId#5473667L, items#5473668, optimizationGroups#5473669, isOptimal#5473670, lastModified#5473671, optimizationInsights#5473672], MapPartitionsRDD[384628] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)

(9) Filter [codegen id : 1]
Input [7]: [shardId#5473666, orderProposalId#5473667L, items#5473668, optimizationGroups#5473669, isOptimal#5473670, lastModified#5473671, optimizationInsights#5473672]
Condition : ((isnotnull(shardId#5473666) AND ((shardId#5473666 = 0_1_10000001445) AND (isOptimal#5473670 <=> false))) AND ((size(items#5473668.worklistShardItemId, true) > 0) AND isnotnull(items#5473668.worklistShardItemId)))

(10) Project [codegen id : 1]
Output [2]: [shardId#5473666, items#5473668.worklistShardItemId AS _extract_worklistShardItemId#5473678]
Input [7]: [shardId#5473666, orderProposalId#5473667L, items#5473668, optimizationGroups#5473669, isOptimal#5473670, lastModified#5473671, optimizationInsights#5473672]

(11) Generate [codegen id : 1]
Input [2]: [shardId#5473666, _extract_worklistShardItemId#5473678]
Arguments: explode(_extract_worklistShardItemId#5473678), [shardId#5473666], false, [item#5473674L]

(12) Project [codegen id : 1]
Output [2]: [shardId#5473666, item#5473674L AS worklistShardItemId#5473675L]
Input [2]: [shardId#5473666, item#5473674L]

(13) Exchange
Input [2]: [shardId#5473666, worklistShardItemId#5473675L]
Arguments: hashpartitioning(shardId#5473666, worklistShardItemId#5473675L, 30), ENSURE_REQUIREMENTS, [plan_id=2834486]

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

(15) SortMergeJoin [codegen id : 4]
Left keys [2]: [shardId#5473735, worklistShardItemId#5473736L]
Right keys [2]: [shardId#5473666, worklistShardItemId#5473675L]
Join type: RightOuter
Join condition: None

(16) Project [codegen id : 4]
Output [4]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, coalesce(kpis#5473740, []) AS kpis#5473741]
Input [6]: [shardId#5473735, worklistShardItemId#5473736L, qty#5473737, kpis#5473740, shardId#5473666, worklistShardItemId#5473675L]

(17) Generate [codegen id : 4]
Input [4]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, kpis#5473741]
Arguments: explode(kpis#5473741), [shardId#5473666, worklistShardItemId#5473675L, qty#5473737], true, [kpi#5473743]

(18) Project [codegen id : 4]
Output [5]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, kpi#5473743.value AS _extract_value#5474374, concat(kpi:, kpi#5473743.label) AS label#5473744]
Input [4]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, kpi#5473743]

(19) HashAggregate [codegen id : 4]
Input [5]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, _extract_value#5474374, label#5473744]
Keys [4]: [shardId#5473666, worklistShardItemId#5473675L, knownfloatingpointnormalized(normalizenanandzero(qty#5473737)) AS qty#5473737, label#5473744]
Functions [1]: [partial_max(_extract_value#5474374)]
Aggregate Attributes [1]: [max#5474601]
Results [5]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, label#5473744, max#5474602]

(20) HashAggregate [codegen id : 4]
Input [5]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, label#5473744, max#5474602]
Keys [4]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, label#5473744]
Functions [1]: [max(_extract_value#5474374)]
Aggregate Attributes [1]: [max(_extract_value#5474374)#5473809]
Results [5]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, label#5473744, max(_extract_value#5474374)#5473809 AS max(kpi.`value` AS value)#5473810]

(21) HashAggregate
Input [5]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, label#5473744, max(kpi.`value` AS value)#5473810]
Keys [3]: [shardId#5473666, worklistShardItemId#5473675L, knownfloatingpointnormalized(normalizenanandzero(qty#5473737)) AS qty#5473737]
Functions [1]: [partial_pivotfirst(label#5473744, max(kpi.`value` AS value)#5473810, 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#5473811, kpi:OutOfStockProbability#5473812, kpi:PeriodSpoilageQty#5473813, kpi:RangeOfCoverage#5473814, kpi:RemainingStockQty#5473815, kpi:SalesQty#5473816, kpi:ServiceLevel#5473817, kpi:ServiceLevelAtStartOfDelisting#5473818, kpi:ServiceLevelMinimumStock#5473819, kpi:ShelfCapacityOverrun#5473820, kpi:ShelfCapacityUnderrun#5473821, kpi:SpoilageQty#5473822, kpi:UnfulfilledDemandQty#5473823]
Results [16]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, kpi:EndOfPeriodVirtualStockQty#5473824, kpi:OutOfStockProbability#5473825, kpi:PeriodSpoilageQty#5473826, kpi:RangeOfCoverage#5473827, kpi:RemainingStockQty#5473828, kpi:SalesQty#5473829, kpi:ServiceLevel#5473830, kpi:ServiceLevelAtStartOfDelisting#5473831, kpi:ServiceLevelMinimumStock#5473832, kpi:ShelfCapacityOverrun#5473833, kpi:ShelfCapacityUnderrun#5473834, kpi:SpoilageQty#5473835, kpi:UnfulfilledDemandQty#5473836]

(22) HashAggregate
Input [16]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, kpi:EndOfPeriodVirtualStockQty#5473824, kpi:OutOfStockProbability#5473825, kpi:PeriodSpoilageQty#5473826, kpi:RangeOfCoverage#5473827, kpi:RemainingStockQty#5473828, kpi:SalesQty#5473829, kpi:ServiceLevel#5473830, kpi:ServiceLevelAtStartOfDelisting#5473831, kpi:ServiceLevelMinimumStock#5473832, kpi:ShelfCapacityOverrun#5473833, kpi:ShelfCapacityUnderrun#5473834, kpi:SpoilageQty#5473835, kpi:UnfulfilledDemandQty#5473836]
Keys [3]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737]
Functions [1]: [pivotfirst(label#5473744, max(kpi.`value` AS value)#5473810, 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#5473744, max(kpi.`value` AS value)#5473810, 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)#5473837]
Results [4]: [shardId#5473666, worklistShardItemId#5473675L, qty#5473737, pivotfirst(label#5473744, max(kpi.`value` AS value)#5473810, 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)#5473837 AS __pivot_max(kpi.`value` AS value) AS `max(kpi.``value`` AS value)`#5473838]

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

(24) ObjectHashAggregate
Input [3]: [shardId#5473666, worklistShardItemId#5473675L, struct#5473878]
Keys [2]: [shardId#5473666, worklistShardItemId#5473675L]
Functions [2]: [partial_max(struct#5473878.qty), partial_collect_list(struct#5473878, 0, 0)]
Aggregate Attributes [2]: [max#5474597, buf#5474598]
Results [4]: [shardId#5473666, worklistShardItemId#5473675L, max#5474599, buf#5474600]

(25) ObjectHashAggregate
Input [4]: [shardId#5473666, worklistShardItemId#5473675L, max#5474599, buf#5474600]
Keys [2]: [shardId#5473666, worklistShardItemId#5473675L]
Functions [2]: [max(struct#5473878.qty), collect_list(struct#5473878, 0, 0)]
Aggregate Attributes [2]: [max(struct#5473878.qty)#5473898, collect_list(struct#5473878, 0, 0)#5473899]
Results [3]: [shardId#5473666, worklistShardItemId#5473675L, sort_array(CASE WHEN isnull(max(struct#5473878.qty)#5473898) THEN [] ELSE collect_list(struct#5473878, 0, 0)#5473899 END, true) AS struct_array#5473879]

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

(27) Scan parquet 
Output [14]: [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108, shardId#5474109, sequenceId#5474087]
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#5474109), isnotnull(sequenceId#5474087), (shardId#5474109 = 0_1_10000001445), (sequenceId#5474087 = 6)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,worklistShardItemId:bigint,logisticUnits:array<struct<uom:string,uomUuid:string,numerator:int,denominator:int,isOrderUnit:boolean,isPreferred:boolean>>,orderQuantityBaseUom:string,orderQuantityBaseUomUuid:string,constraintLabels:array<string>,constraintOperators:array<string>,constraintValues:array<double>,constraintRanks:array<int>,constraintIsActive:array<boolean>,measurements:array<struct<value:double,dimensionType:int,dimensionCode:string,dimensionCodeUuid:string,isoCode:string>>,optimizationGroups:array<string>>

(28) ColumnarToRow [codegen id : 6]
Input [14]: [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108, shardId#5474109, sequenceId#5474087]

(29) Filter [codegen id : 6]
Input [14]: [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108, shardId#5474109, sequenceId#5474087]
Condition : isnotnull(worklistShardItemId#5474088L)

(30) Project [codegen id : 6]
Output [12]: [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108]
Input [14]: [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108, shardId#5474109, sequenceId#5474087]

(31) Exchange
Input [12]: [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108]
Arguments: hashpartitioning(worklistShardItemId#5474088L, 30), REPARTITION_BY_NUM, [plan_id=2834575]

(32) Project [codegen id : 7]
Output [12]: [worklistShardItemId#5474088L, orderProposalId#5474065L, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, measurements#5474106, constraintLabels#5474096, constraintOperators#5474097, constraintRanks#5474099, constraintValues#5474098, constraintIsActive#5474100, logisticUnits#5474092, optimizationGroups#5474108]
Input [12]: [orderProposalId#5474065L, worklistShardItemId#5474088L, logisticUnits#5474092, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, constraintLabels#5474096, constraintOperators#5474097, constraintValues#5474098, constraintRanks#5474099, constraintIsActive#5474100, measurements#5474106, optimizationGroups#5474108]

(33) BroadcastExchange
Input [12]: [worklistShardItemId#5474088L, orderProposalId#5474065L, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, measurements#5474106, constraintLabels#5474096, constraintOperators#5474097, constraintRanks#5474099, constraintValues#5474098, constraintIsActive#5474100, logisticUnits#5474092, optimizationGroups#5474108]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2834579]

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

(35) Project [codegen id : 8]
Output [15]: [shardId#5473666, worklistShardItemId#5473675L, quantities#5473900, kpis#5473914, constraintValues#5474098, constraintOperators#5474097, constraintLabels#5474096, constraintRanks#5474099, constraintIsActive#5474100, orderProposalId#5474065L, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, logisticUnits#5474092, optimizationGroups#5474108, measurements#5474106]
Input [16]: [shardId#5473666, worklistShardItemId#5473675L, quantities#5473900, kpis#5473914, worklistShardItemId#5474088L, orderProposalId#5474065L, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, measurements#5474106, constraintLabels#5474096, constraintOperators#5474097, constraintRanks#5474099, constraintValues#5474098, constraintIsActive#5474100, logisticUnits#5474092, optimizationGroups#5474108]

(36) ObjectHashAggregate
Input [15]: [shardId#5473666, worklistShardItemId#5473675L, quantities#5473900, kpis#5473914, constraintValues#5474098, constraintOperators#5474097, constraintLabels#5474096, constraintRanks#5474099, constraintIsActive#5474100, orderProposalId#5474065L, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid#5474094, logisticUnits#5474092, optimizationGroups#5474108, measurements#5474106]
Keys [2]: [shardId#5473666, orderProposalId#5474065L]
Functions [1]: [partial_collect_list(struct(worklistShardItemId, worklistShardItemId#5473675L, quantities, quantities#5473900, kpis, kpis#5473914, constraintValues, constraintValues#5474098, constraintOperators, constraintOperators#5474097, constraintLabels, constraintLabels#5474096, constraintRanks, constraintRanks#5474099, constraintIsActive, constraintIsActive#5474100, orderQuantityBaseUom, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5474094, logisticUnits, logisticUnits#5474092, optimizationGroups, optimizationGroups#5474108, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [buf#5474595]
Results [3]: [shardId#5473666, orderProposalId#5474065L, buf#5474596]

(37) Exchange
Input [3]: [shardId#5473666, orderProposalId#5474065L, buf#5474596]
Arguments: hashpartitioning(shardId#5473666, orderProposalId#5474065L, 30), ENSURE_REQUIREMENTS, [plan_id=2834585]

(38) ObjectHashAggregate
Input [3]: [shardId#5473666, orderProposalId#5474065L, buf#5474596]
Keys [2]: [shardId#5473666, orderProposalId#5474065L]
Functions [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5473675L, quantities, quantities#5473900, kpis, kpis#5473914, constraintValues, constraintValues#5474098, constraintOperators, constraintOperators#5474097, constraintLabels, constraintLabels#5474096, constraintRanks, constraintRanks#5474099, constraintIsActive, constraintIsActive#5474100, orderQuantityBaseUom, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5474094, logisticUnits, logisticUnits#5474092, optimizationGroups, optimizationGroups#5474108, measurements, ... 1 more fields), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(worklistShardItemId, worklistShardItemId#5473675L, quantities, quantities#5473900, kpis, kpis#5473914, constraintValues, constraintValues#5474098, constraintOperators, constraintOperators#5474097, constraintLabels, constraintLabels#5474096, constraintRanks, constraintRanks#5474099, constraintIsActive, constraintIsActive#5474100, orderQuantityBaseUom, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5474094, logisticUnits, logisticUnits#5474092, optimizationGroups, optimizationGroups#5474108, measurements, ... 1 more fields), 0, 0)#5474234]
Results [3]: [shardId#5473666, orderProposalId#5474065L, collect_list(struct(worklistShardItemId, worklistShardItemId#5473675L, quantities, quantities#5473900, kpis, kpis#5473914, constraintValues, constraintValues#5474098, constraintOperators, constraintOperators#5474097, constraintLabels, constraintLabels#5474096, constraintRanks, constraintRanks#5474099, constraintIsActive, constraintIsActive#5474100, orderQuantityBaseUom, orderQuantityBaseUom#5474093, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5474094, logisticUnits, logisticUnits#5474092, optimizationGroups, optimizationGroups#5474108, measurements, ... 1 more fields), 0, 0)#5474234 AS items#5474218]

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

(40) ColumnarToRow [codegen id : 9]
Input [4]: [orderProposalId#5474238L, optimizationGroups#5474240, shardId#5474241, sequenceId#5474239]

(41) Filter [codegen id : 9]
Input [4]: [orderProposalId#5474238L, optimizationGroups#5474240, shardId#5474241, sequenceId#5474239]
Condition : isnotnull(orderProposalId#5474238L)

(42) Project [codegen id : 9]
Output [3]: [orderProposalId#5474238L, sequenceId#5474239, optimizationGroups#5474240]
Input [4]: [orderProposalId#5474238L, optimizationGroups#5474240, shardId#5474241, sequenceId#5474239]

(43) Exchange
Input [3]: [orderProposalId#5474238L, sequenceId#5474239, optimizationGroups#5474240]
Arguments: hashpartitioning(orderProposalId#5474238L, 30), REPARTITION_BY_NUM, [plan_id=2834593]

(44) Project
Output [3]: [orderProposalId#5474238L, transform(optimizationGroups#5474240, lambdafunction(if (isnull(lambda x_1039#5474244)) null else named_struct(optGroupId, lambda x_1039#5474244.optGroupId, assignmentDetails, lambda x_1039#5474244.assignmentDetails, minOrderProfile, lambda x_1039#5474244.minOrderProfile, minOrderGoal, if (isnull(lambda x_1039#5474244.minOrderGoal)) null else named_struct(minOrderValue, lambda x_1039#5474244.minOrderGoal.minOrderValue, dimensionType, lambda x_1039#5474244.minOrderGoal.dimensionType, unit, lambda x_1039#5474244.minOrderGoal.unit, unitUuid, lambda x_1039#5474244.minOrderGoal.unitUuid, isoCode, lambda x_1039#5474244.minOrderGoal.isoCode, negligibleQuantitiesThreshold, lambda x_1039#5474244.minOrderGoal.negligibleQuantitiesThreshold, acceptanceThreshold, lambda x_1039#5474244.minOrderGoal.acceptanceThreshold)), lambda x_1039#5474244, false)) AS optimizationGroups#5474237, sequenceId#5474239]
Input [3]: [orderProposalId#5474238L, sequenceId#5474239, optimizationGroups#5474240]

(45) BroadcastExchange
Input [3]: [orderProposalId#5474238L, optimizationGroups#5474237, sequenceId#5474239]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2834595]

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

(47) Project [codegen id : 11]
Output [5]: [shardId#5473666, orderProposalId#5474065L, items#5474218, optimizationGroups#5474237, sequenceId#5474239]
Input [6]: [shardId#5473666, orderProposalId#5474065L, items#5474218, orderProposalId#5474238L, optimizationGroups#5474237, sequenceId#5474239]

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

(50) Project [codegen id : 10]
Output [2]: [uomCategories#5474249, insightConfigurations#5474250]
Input [3]: [uomCategories#5474249, insightConfigurations#5474250, shardId#5474251]

(51) Exchange
Input [2]: [uomCategories#5474249, insightConfigurations#5474250]
Arguments: RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=2834603]

(52) BroadcastExchange
Input [2]: [uomCategories#5474249, insightConfigurations#5474250]
Arguments: IdentityBroadcastMode, [plan_id=2834604]

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

(54) DeserializeToObject
Input [7]: [shardId#5473666, orderProposalId#5474065L, items#5474218, optimizationGroups#5474237, sequenceId#5474239, uomCategories#5474249, insightConfigurations#5474250]
Arguments: createexternalrow(invoke(shardId#5473666.toString()), static_invoke(java.lang.Long.valueOf(orderProposalId#5474065L)), 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#5474218, 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#5474237, Some(class scala.collection.mutable.ArraySeq)), static_invoke(java.lang.Integer.valueOf(sequenceId#5474239)), 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#5474249, 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#5474250, 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#5474269: org.apache.spark.sql.Row

(55) MapPartitions
Input [1]: [obj#5474269]
Arguments: org.apache.spark.sql.internal.ToScalaUDF$$$Lambda/0x000000080248b3a0@6d8aab8e, obj#5474276: org.apache.spark.sql.Row

SQL / DataFrame Properties

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