== Physical Plan ==
CollectLimit (101)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- Project (100)
+- Exchange (99)
+- InMemoryTableScan (3)
+- InMemoryRelation (4)
+- ObjectHashAggregate (98)
+- Exchange (97)
+- ObjectHashAggregate (96)
+- Project (95)
+- InMemoryTableScan (5)
+- InMemoryRelation (6)
+- Project (94)
+- BroadcastHashJoin LeftOuter BuildRight (93)
:- Project (67)
: +- Project (66)
: +- ObjectHashAggregate (65)
: +- Exchange (64)
: +- ObjectHashAggregate (63)
: +- ObjectHashAggregate (62)
: +- Exchange (61)
: +- ObjectHashAggregate (60)
: +- Project (59)
: +- Project (58)
: +- Project (57)
: +- * Project (56)
: +- * Filter (55)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Project (54)
: +- * SortMergeJoin LeftOuter (53)
: :- * Project (45)
: : +- * SortMergeJoin LeftOuter (44)
: : :- * Project (36)
: : : +- * SortMergeJoin LeftOuter (35)
: : : :- * Sort (29)
: : : : +- Exchange (28)
: : : : +- * Project (27)
: : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : :- * Project (18)
: : : : : +- * Generate (17)
: : : : : +- * Filter (16)
: : : : : +- InMemoryTableScan (9)
: : : : : +- InMemoryRelation (10)
: : : : : +- * Filter (15)
: : : : : +- InMemoryTableScan (11)
: : : : : +- InMemoryRelation (12)
: : : : : +- * Filter (14)
: : : : : +- * Scan ExistingRDD (13)
: : : : +- BroadcastExchange (25)
: : : : +- * Project (24)
: : : : +- Exchange (23)
: : : : +- * Project (22)
: : : : +- * Filter (21)
: : : : +- * ColumnarToRow (20)
: : : : +- Scan parquet (19)
: : : +- * Sort (34)
: : : +- Exchange (33)
: : : +- * Project (32)
: : : +- * Filter (31)
: : : +- * Scan ExistingRDD (30)
: : +- * Sort (43)
: : +- ObjectHashAggregate (42)
: : +- Exchange (41)
: : +- ObjectHashAggregate (40)
: : +- * Project (39)
: : +- * Filter (38)
: : +- * Scan ExistingRDD (37)
: +- * Sort (52)
: +- ObjectHashAggregate (51)
: +- Exchange (50)
: +- ObjectHashAggregate (49)
: +- * Project (48)
: +- * Filter (47)
: +- * Scan ExistingRDD (46)
+- BroadcastExchange (92)
+- Project (91)
+- * BroadcastHashJoin Inner BuildLeft (90)
:- BroadcastExchange (71)
: +- * Filter (70)
: +- InMemoryTableScan (68)
: +- InMemoryRelation (69)
: +- * Filter (15)
: +- InMemoryTableScan (11)
: +- InMemoryRelation (12)
: +- * Filter (14)
: +- * Scan ExistingRDD (13)
+- * HashAggregate (89)
+- Exchange (88)
+- * HashAggregate (87)
+- * Project (86)
+- * BroadcastHashJoin Inner BuildLeft (85)
:- BroadcastExchange (78)
: +- * Project (77)
: +- * Generate (76)
: +- * Project (75)
: +- * Filter (74)
: +- InMemoryTableScan (72)
: +- InMemoryRelation (73)
: +- * Filter (15)
: +- InMemoryTableScan (11)
: +- InMemoryRelation (12)
: +- * Filter (14)
: +- * Scan ExistingRDD (13)
+- * Project (84)
+- Exchange (83)
+- * Project (82)
+- * Filter (81)
+- * ColumnarToRow (80)
+- Scan parquet (79)
(1) InMemoryTableScan
Output: []
(2) InMemoryRelation
Arguments: [shardId#5543988, orderProposals#5548047], StorageLevel(disk, memory, 2 replicas)
(3) InMemoryTableScan
Output [3]: [shardId#5543988, resultSeparationId#5548043L, orderProposals#5548047]
Arguments: [shardId#5543988, resultSeparationId#5548043L, orderProposals#5548047]
(4) InMemoryRelation
Arguments: [shardId#5543988, resultSeparationId#5548043L, orderProposals#5548047], StorageLevel(disk, memory, 2 replicas)
(5) InMemoryTableScan
Output [2]: [orderProposal#5546307, shardId#5543988]
Arguments: [orderProposal#5546307, shardId#5543988]
(6) InMemoryRelation
Arguments: [shardId#5543988, orderProposal#5546307], StorageLevel(disk, memory, 2 replicas)
(7) InMemoryTableScan
Output [39]: [availabilityDateTime#5544678, channelStreamSpecificKpis#5545419, constraintLabels#5544690, constraintOperators#5544691, constraintValues#5544693, deliveryDateTime#5544677, isFallbackOrderOnly#5544680, logisticUnits#5544695, measurements#5544688, minimumOrderQuantity#5544689, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, nextAvailabilityDateTime#5544679, optimizationGroups#5544696, orderDateTime#5544676, orderProposalId#5544658L, orderProposalItemGroupId#5544660, orderProposalItemId#5544659, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, originalReplenishmentRunId#5544661L, plant#5544672, previousOrderProposal#5544664L, prodLocSpecificKpis#5545404, product#5544671, productGroup#5544700, qty#5544502, quantityAfterProdPlantOptimization#5544501, quantityKpis#5545432, shardId#5543988, sourceOfSupplyUuid#5544667, splitIndicator#5544663L, subrange#5544670, supplier#5544669, supplierGroup#5544668, supplyingPlant#5544699]
Arguments: [availabilityDateTime#5544678, channelStreamSpecificKpis#5545419, constraintLabels#5544690, constraintOperators#5544691, constraintValues#5544693, deliveryDateTime#5544677, isFallbackOrderOnly#5544680, logisticUnits#5544695, measurements#5544688, minimumOrderQuantity#5544689, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, nextAvailabilityDateTime#5544679, optimizationGroups#5544696, orderDateTime#5544676, orderProposalId#5544658L, orderProposalItemGroupId#5544660, orderProposalItemId#5544659, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, originalReplenishmentRunId#5544661L, plant#5544672, ... 14 more fields], [NOT (isFallbackOrderOnly#5544680 <=> true)]
(8) InMemoryRelation
Arguments: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, nextAvailabilityDateTime#5544679, constraintValues#5544693, constraintOperators#5544691, constraintLabels#5544690, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, netPriceAmount#5544686, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)
(9) InMemoryTableScan
Output [2]: [shardId#5543988, items#5543990]
Arguments: [shardId#5543988, items#5543990], [(size(items#5543990, true) > 0), isnotnull(items#5543990)]
(10) InMemoryRelation
Arguments: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, optimizationInsights#5543994], StorageLevel(disk, memory, 2 replicas)
(11) InMemoryTableScan
Output [6]: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, optimizationInsights#5543994]
Arguments: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, optimizationInsights#5543994], [isnotnull(shardId#5543988), (shardId#5543988 = 0_1_10000001445)]
(12) InMemoryRelation
Arguments: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, lastModified#5543993, optimizationInsights#5543994], StorageLevel(disk, memory, 2 replicas)
(13) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, lastModified#5543993, optimizationInsights#5543994]
Arguments: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, lastModified#5543993, optimizationInsights#5543994], MapPartitionsRDD[390845] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(14) Filter [codegen id : 1]
Input [7]: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, lastModified#5543993, optimizationInsights#5543994]
Condition : (isnotnull(shardId#5543988) AND (shardId#5543988 = 0_1_10000001445))
(15) Filter [codegen id : 1]
Input [6]: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, optimizationInsights#5543994]
Condition : (isnotnull(shardId#5543988) AND (shardId#5543988 = 0_1_10000001445))
(16) Filter [codegen id : 3]
Input [2]: [shardId#5543988, items#5543990]
Condition : ((size(items#5543990, true) > 0) AND isnotnull(items#5543990))
(17) Generate [codegen id : 3]
Input [2]: [shardId#5543988, items#5543990]
Arguments: explode(items#5543990), [shardId#5543988], false, [item#5544499]
(18) Project [codegen id : 3]
Output [4]: [shardId#5543988, item#5544499.worklistShardItemId AS worklistShardItemId#5544500L, item#5544499.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5544501, item#5544499.qty AS qty#5544502]
Input [2]: [shardId#5543988, item#5544499]
(19) Scan parquet
Output [38]: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, sourceOfSupplyUuid#5544715, isFallbackOrderOnly#5544718, splitIndicator#5544720L, previousOrderProposal#5544721L, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, externalProductId#5544726, externalPlantId#5544727, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, measurements#5544742, originalReplenishmentRunId#5544743L, optimizationGroups#5544744, shardId#5544745, sequenceId#5544723]
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#5544745), isnotnull(sequenceId#5544723), (shardId#5544745 = 0_1_10000001445), (sequenceId#5544723 = 7)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,supplyingPlant:string,productGroup:string,product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,sourceOfSupplyUuid:string,isFallbackOrderOnly:boolean,splitIndicator:bigint,previousOrderProposal:bigint,worklistShardItemId:bigint,orderProposalItemGroupId:string,externalProductId:string,externalPlantId:string,logisticUnits:array<struct<uom:string,uomUuid:string,numerator:int,denominator:int,isOrderUnit:boolean,isPreferred:boolean>>,orderQuantityBaseUom:string,orderQuantityBaseUomUuid:string,minimumOrderQuantity:double,constraintLabels:array<string>,constraintOperators:array<string>,constraintValues:array<double>,netPriceAmount:double,netPriceCurrencyCode:string,netPriceQuantity:double,netPriceQuantityUom:string,netPriceQuantityUomUuid:string,measurements:array<struct<value:double,dimensionType:int,dimensionCode:string,dimensionCodeUuid:string,isoCode:string>>,originalReplenishmentRunId:bigint,optimizationGroups:array<string>>
(20) ColumnarToRow [codegen id : 1]
Input [38]: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, sourceOfSupplyUuid#5544715, isFallbackOrderOnly#5544718, splitIndicator#5544720L, previousOrderProposal#5544721L, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, externalProductId#5544726, externalPlantId#5544727, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, measurements#5544742, originalReplenishmentRunId#5544743L, optimizationGroups#5544744, shardId#5544745, sequenceId#5544723]
(21) Filter [codegen id : 1]
Input [38]: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, sourceOfSupplyUuid#5544715, isFallbackOrderOnly#5544718, splitIndicator#5544720L, previousOrderProposal#5544721L, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, externalProductId#5544726, externalPlantId#5544727, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, measurements#5544742, originalReplenishmentRunId#5544743L, optimizationGroups#5544744, shardId#5544745, sequenceId#5544723]
Condition : isnotnull(worklistShardItemId#5544724L)
(22) Project [codegen id : 1]
Output [36]: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, sourceOfSupplyUuid#5544715, isFallbackOrderOnly#5544718, splitIndicator#5544720L, previousOrderProposal#5544721L, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, externalProductId#5544726, externalPlantId#5544727, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, measurements#5544742, originalReplenishmentRunId#5544743L, optimizationGroups#5544744]
Input [38]: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, sourceOfSupplyUuid#5544715, isFallbackOrderOnly#5544718, splitIndicator#5544720L, previousOrderProposal#5544721L, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, externalProductId#5544726, externalPlantId#5544727, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, measurements#5544742, originalReplenishmentRunId#5544743L, optimizationGroups#5544744, shardId#5544745, sequenceId#5544723]
(23) Exchange
Input [36]: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, sourceOfSupplyUuid#5544715, isFallbackOrderOnly#5544718, splitIndicator#5544720L, previousOrderProposal#5544721L, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, externalProductId#5544726, externalPlantId#5544727, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, measurements#5544742, originalReplenishmentRunId#5544743L, optimizationGroups#5544744]
Arguments: hashpartitioning(worklistShardItemId#5544724L, 30), REPARTITION_BY_NUM, [plan_id=2877045]
(24) Project [codegen id : 2]
Output [36]: [worklistShardItemId#5544724L, orderProposalId#5544701L, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, originalReplenishmentRunId#5544743L, splitIndicator#5544720L, previousOrderProposal#5544721L, sourceOfSupplyUuid#5544715, supplierGroup#5544703, supplier#5544704, subrange#5544707, product#5544710, plant#5544705, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, isFallbackOrderOnly#5544718, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, netPriceAmount#5544737, netPriceCurrencyCode#5544738, measurements#5544742, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, logisticUnits#5544728, optimizationGroups#5544744, externalProductId#5544726, externalPlantId#5544727, supplyingPlant#5544708, productGroup#5544709]
Input [36]: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, sourceOfSupplyUuid#5544715, isFallbackOrderOnly#5544718, splitIndicator#5544720L, previousOrderProposal#5544721L, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, externalProductId#5544726, externalPlantId#5544727, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, measurements#5544742, originalReplenishmentRunId#5544743L, optimizationGroups#5544744]
(25) BroadcastExchange
Input [36]: [worklistShardItemId#5544724L, orderProposalId#5544701L, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, originalReplenishmentRunId#5544743L, splitIndicator#5544720L, previousOrderProposal#5544721L, sourceOfSupplyUuid#5544715, supplierGroup#5544703, supplier#5544704, subrange#5544707, product#5544710, plant#5544705, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, isFallbackOrderOnly#5544718, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, netPriceAmount#5544737, netPriceCurrencyCode#5544738, measurements#5544742, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, logisticUnits#5544728, optimizationGroups#5544744, externalProductId#5544726, externalPlantId#5544727, supplyingPlant#5544708, productGroup#5544709]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2877049]
(26) BroadcastHashJoin [codegen id : 3]
Left keys [1]: [worklistShardItemId#5544500L]
Right keys [1]: [worklistShardItemId#5544724L]
Join type: LeftOuter
Join condition: (shardId#5543988 = 0_1_10000001445)
(27) Project [codegen id : 3]
Output [39]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718]
Input [40]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, worklistShardItemId#5544724L, orderProposalId#5544701L, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, originalReplenishmentRunId#5544743L, splitIndicator#5544720L, previousOrderProposal#5544721L, sourceOfSupplyUuid#5544715, supplierGroup#5544703, supplier#5544704, subrange#5544707, product#5544710, plant#5544705, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, isFallbackOrderOnly#5544718, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, netPriceAmount#5544737, netPriceCurrencyCode#5544738, measurements#5544742, minimumOrderQuantity#5544731, constraintLabels#5544732, constraintOperators#5544733, constraintValues#5544734, logisticUnits#5544728, optimizationGroups#5544744, externalProductId#5544726, externalPlantId#5544727, supplyingPlant#5544708, productGroup#5544709]
(28) Exchange
Input [39]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718]
Arguments: hashpartitioning(shardId#5543988, worklistShardItemId#5544500L, 30), ENSURE_REQUIREMENTS, [plan_id=2877054]
(29) Sort [codegen id : 4]
Input [39]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718]
Arguments: [shardId#5543988 ASC NULLS FIRST, worklistShardItemId#5544500L ASC NULLS FIRST], false, 0
(30) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#5545397, worklistShardItemId#5545398L, qty#5545399, demandChannel#5545400, demandStream#5545401, kpis#5545402]
Arguments: [shardId#5545397, worklistShardItemId#5545398L, qty#5545399, demandChannel#5545400, demandStream#5545401, kpis#5545402], MapPartitionsRDD[390919] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(31) Filter [codegen id : 5]
Input [6]: [shardId#5545397, worklistShardItemId#5545398L, qty#5545399, demandChannel#5545400, demandStream#5545401, kpis#5545402]
Condition : (((isnull(qty#5545399) AND isnull(demandChannel#5545400)) AND isnull(demandStream#5545401)) AND (isnotnull(shardId#5545397) AND isnotnull(worklistShardItemId#5545398L)))
(32) Project [codegen id : 5]
Output [3]: [shardId#5545397, worklistShardItemId#5545398L, coalesce(kpis#5545402, []) AS prodLocSpecificKpis#5545403]
Input [6]: [shardId#5545397, worklistShardItemId#5545398L, qty#5545399, demandChannel#5545400, demandStream#5545401, kpis#5545402]
(33) Exchange
Input [3]: [shardId#5545397, worklistShardItemId#5545398L, prodLocSpecificKpis#5545403]
Arguments: hashpartitioning(shardId#5545397, worklistShardItemId#5545398L, 30), ENSURE_REQUIREMENTS, [plan_id=2877060]
(34) Sort [codegen id : 6]
Input [3]: [shardId#5545397, worklistShardItemId#5545398L, prodLocSpecificKpis#5545403]
Arguments: [shardId#5545397 ASC NULLS FIRST, worklistShardItemId#5545398L ASC NULLS FIRST], false, 0
(35) SortMergeJoin [codegen id : 7]
Left keys [2]: [shardId#5543988, worklistShardItemId#5544500L]
Right keys [2]: [shardId#5545397, worklistShardItemId#5545398L]
Join type: LeftOuter
Join condition: None
(36) Project [codegen id : 7]
Output [40]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718, coalesce(prodLocSpecificKpis#5545403, []) AS prodLocSpecificKpis#5545404]
Input [42]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718, shardId#5545397, worklistShardItemId#5545398L, prodLocSpecificKpis#5545403]
(37) Scan ExistingRDD [codegen id : 8]
Output [6]: [shardId#5545413, worklistShardItemId#5545414L, qty#5545415, demandChannel#5545416, demandStream#5545417, kpis#5545418]
Arguments: [shardId#5545413, worklistShardItemId#5545414L, qty#5545415, demandChannel#5545416, demandStream#5545417, kpis#5545418], MapPartitionsRDD[390919] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(38) Filter [codegen id : 8]
Input [6]: [shardId#5545413, worklistShardItemId#5545414L, qty#5545415, demandChannel#5545416, demandStream#5545417, kpis#5545418]
Condition : ((((isnull(qty#5545415) AND isnotnull(demandChannel#5545416)) AND isnotnull(demandStream#5545417)) AND (size(kpis#5545418, true) > 0)) AND (isnotnull(shardId#5545413) AND isnotnull(worklistShardItemId#5545414L)))
(39) Project [codegen id : 8]
Output [5]: [shardId#5545413, worklistShardItemId#5545414L, demandChannel#5545416, demandStream#5545417, kpis#5545418]
Input [6]: [shardId#5545413, worklistShardItemId#5545414L, qty#5545415, demandChannel#5545416, demandStream#5545417, kpis#5545418]
(40) ObjectHashAggregate
Input [5]: [shardId#5545413, worklistShardItemId#5545414L, demandChannel#5545416, demandStream#5545417, kpis#5545418]
Keys [2]: [shardId#5545413, worklistShardItemId#5545414L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#5545416, demandStream, demandStream#5545417, kpis, kpis#5545418), 0, 0)]
Aggregate Attributes [1]: [buf#5545593]
Results [3]: [shardId#5545413, worklistShardItemId#5545414L, buf#5545594]
(41) Exchange
Input [3]: [shardId#5545413, worklistShardItemId#5545414L, buf#5545594]
Arguments: hashpartitioning(shardId#5545413, worklistShardItemId#5545414L, 30), ENSURE_REQUIREMENTS, [plan_id=2877071]
(42) ObjectHashAggregate
Input [3]: [shardId#5545413, worklistShardItemId#5545414L, buf#5545594]
Keys [2]: [shardId#5545413, worklistShardItemId#5545414L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#5545416, demandStream, demandStream#5545417, kpis, kpis#5545418), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#5545416, demandStream, demandStream#5545417, kpis, kpis#5545418), 0, 0)#5545412]
Results [3]: [shardId#5545413, worklistShardItemId#5545414L, collect_list(struct(demandChannel, demandChannel#5545416, demandStream, demandStream#5545417, kpis, kpis#5545418), 0, 0)#5545412 AS channelStreamSpecificKpis#5545405]
(43) Sort [codegen id : 9]
Input [3]: [shardId#5545413, worklistShardItemId#5545414L, channelStreamSpecificKpis#5545405]
Arguments: [shardId#5545413 ASC NULLS FIRST, worklistShardItemId#5545414L ASC NULLS FIRST], false, 0
(44) SortMergeJoin [codegen id : 10]
Left keys [2]: [shardId#5543988, worklistShardItemId#5544500L]
Right keys [2]: [shardId#5545413, worklistShardItemId#5545414L]
Join type: LeftOuter
Join condition: None
(45) Project [codegen id : 10]
Output [41]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718, prodLocSpecificKpis#5545404, coalesce(channelStreamSpecificKpis#5545405, []) AS channelStreamSpecificKpis#5545419]
Input [43]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718, prodLocSpecificKpis#5545404, shardId#5545413, worklistShardItemId#5545414L, channelStreamSpecificKpis#5545405]
(46) Scan ExistingRDD [codegen id : 11]
Output [6]: [shardId#5545426, worklistShardItemId#5545427L, qty#5545428, demandChannel#5545429, demandStream#5545430, kpis#5545431]
Arguments: [shardId#5545426, worklistShardItemId#5545427L, qty#5545428, demandChannel#5545429, demandStream#5545430, kpis#5545431], MapPartitionsRDD[390919] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(47) Filter [codegen id : 11]
Input [6]: [shardId#5545426, worklistShardItemId#5545427L, qty#5545428, demandChannel#5545429, demandStream#5545430, kpis#5545431]
Condition : ((isnotnull(qty#5545428) AND isnotnull(kpis#5545431)) AND (isnotnull(shardId#5545426) AND isnotnull(worklistShardItemId#5545427L)))
(48) Project [codegen id : 11]
Output [4]: [shardId#5545426, worklistShardItemId#5545427L, qty#5545428, kpis#5545431]
Input [6]: [shardId#5545426, worklistShardItemId#5545427L, qty#5545428, demandChannel#5545429, demandStream#5545430, kpis#5545431]
(49) ObjectHashAggregate
Input [4]: [shardId#5545426, worklistShardItemId#5545427L, qty#5545428, kpis#5545431]
Keys [2]: [shardId#5545426, worklistShardItemId#5545427L]
Functions [1]: [partial_collect_list(struct(qty, qty#5545428, kpis, kpis#5545431), 0, 0)]
Aggregate Attributes [1]: [buf#5545595]
Results [3]: [shardId#5545426, worklistShardItemId#5545427L, buf#5545596]
(50) Exchange
Input [3]: [shardId#5545426, worklistShardItemId#5545427L, buf#5545596]
Arguments: hashpartitioning(shardId#5545426, worklistShardItemId#5545427L, 30), ENSURE_REQUIREMENTS, [plan_id=2877083]
(51) ObjectHashAggregate
Input [3]: [shardId#5545426, worklistShardItemId#5545427L, buf#5545596]
Keys [2]: [shardId#5545426, worklistShardItemId#5545427L]
Functions [1]: [collect_list(struct(qty, qty#5545428, kpis, kpis#5545431), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#5545428, kpis, kpis#5545431), 0, 0)#5545425]
Results [3]: [shardId#5545426, worklistShardItemId#5545427L, map_from_entries(collect_list(struct(qty, qty#5545428, kpis, kpis#5545431), 0, 0)#5545425) AS quantityKpis#5545420]
(52) Sort [codegen id : 12]
Input [3]: [shardId#5545426, worklistShardItemId#5545427L, quantityKpis#5545420]
Arguments: [shardId#5545426 ASC NULLS FIRST, worklistShardItemId#5545427L ASC NULLS FIRST], false, 0
(53) SortMergeJoin [codegen id : 13]
Left keys [2]: [shardId#5543988, worklistShardItemId#5544500L]
Right keys [2]: [shardId#5545426, worklistShardItemId#5545427L]
Join type: LeftOuter
Join condition: None
(54) Project [codegen id : 13]
Output [42]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718, prodLocSpecificKpis#5545404, channelStreamSpecificKpis#5545419, coalesce(quantityKpis#5545420, map(keys: [], values: [])) AS quantityKpis#5545432]
Input [44]: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544701L, originalReplenishmentRunId#5544743L, supplierGroup#5544703, supplier#5544704, supplyingPlant#5544708, productGroup#5544709, product#5544710, plant#5544705, subrange#5544707, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, constraintValues#5544734, constraintOperators#5544733, constraintLabels#5544732, logisticUnits#5544728, orderQuantityBaseUom#5544729, orderQuantityBaseUomUuid#5544730, splitIndicator#5544720L, netPriceAmount#5544737, netPriceCurrencyCode#5544738, netPriceQuantity#5544739, netPriceQuantityUom#5544740, netPriceQuantityUomUuid#5544741, sourceOfSupplyUuid#5544715, minimumOrderQuantity#5544731, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, optimizationGroups#5544744, measurements#5544742, externalProductId#5544726, externalPlantId#5544727, previousOrderProposal#5544721L, isFallbackOrderOnly#5544718, prodLocSpecificKpis#5545404, channelStreamSpecificKpis#5545419, shardId#5545426, worklistShardItemId#5545427L, quantityKpis#5545420]
(55) Filter [codegen id : 1]
Input [39]: [availabilityDateTime#5544678, channelStreamSpecificKpis#5545419, constraintLabels#5544690, constraintOperators#5544691, constraintValues#5544693, deliveryDateTime#5544677, isFallbackOrderOnly#5544680, logisticUnits#5544695, measurements#5544688, minimumOrderQuantity#5544689, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, nextAvailabilityDateTime#5544679, optimizationGroups#5544696, orderDateTime#5544676, orderProposalId#5544658L, orderProposalItemGroupId#5544660, orderProposalItemId#5544659, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, originalReplenishmentRunId#5544661L, plant#5544672, previousOrderProposal#5544664L, prodLocSpecificKpis#5545404, product#5544671, productGroup#5544700, qty#5544502, quantityAfterProdPlantOptimization#5544501, quantityKpis#5545432, shardId#5543988, sourceOfSupplyUuid#5544667, splitIndicator#5544663L, subrange#5544670, supplier#5544669, supplierGroup#5544668, supplyingPlant#5544699]
Condition : NOT (isFallbackOrderOnly#5544680 <=> true)
(56) Project [codegen id : 1]
Output [36]: [shardId#5543988, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, nextAvailabilityDateTime#5544679, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, sourceOfSupplyUuid#5544667, minimumOrderQuantity#5544689, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, optimizationGroups#5544696, measurements#5544688, previousOrderProposal#5544664L, prodLocSpecificKpis#5545404, channelStreamSpecificKpis#5545419, quantityKpis#5545432, arrays_zip(constraintLabels#5544690, constraintOperators#5544691, constraintValues#5544693, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#5545846]
Input [39]: [availabilityDateTime#5544678, channelStreamSpecificKpis#5545419, constraintLabels#5544690, constraintOperators#5544691, constraintValues#5544693, deliveryDateTime#5544677, isFallbackOrderOnly#5544680, logisticUnits#5544695, measurements#5544688, minimumOrderQuantity#5544689, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, nextAvailabilityDateTime#5544679, optimizationGroups#5544696, orderDateTime#5544676, orderProposalId#5544658L, orderProposalItemGroupId#5544660, orderProposalItemId#5544659, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, originalReplenishmentRunId#5544661L, plant#5544672, previousOrderProposal#5544664L, prodLocSpecificKpis#5545404, product#5544671, productGroup#5544700, qty#5544502, quantityAfterProdPlantOptimization#5544501, quantityKpis#5545432, shardId#5543988, sourceOfSupplyUuid#5544667, splitIndicator#5544663L, subrange#5544670, supplier#5544669, supplierGroup#5544668, supplyingPlant#5544699]
(57) Project
Output [37]: [shardId#5543988, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, nextAvailabilityDateTime#5544679, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, sourceOfSupplyUuid#5544667, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, optimizationGroups#5544696, measurements#5544688, previousOrderProposal#5544664L, prodLocSpecificKpis#5545404, channelStreamSpecificKpis#5545419, quantityKpis#5545432, struct(minServiceLevel, array_min(filter(constraintStructArray#5545846, lambdafunction((lambda x_10931#5545853.constraintLabels = ServiceLevel), lambda x_10931#5545853, false)).constraintValues), minServiceLevelMinStock, null, maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#5545846, lambdafunction((lambda x_10932#5545854.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_10932#5545854, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#5545846, lambdafunction((lambda x_10933#5545855.constraintLabels = RangeOfCoverage), lambda x_10933#5545855, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#5544689, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#5545404, lambdafunction((lambda x_10934#5545856.label = NonListingStartTimestamp), lambda x_10934#5545856, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#5545852, CASE WHEN (qty#5544502 <=> quantityAfterProdPlantOptimization#5544501) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#5544502 * (cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545924.isOrderUnit, lambda x_10935#5545924, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545925.isOrderUnit, lambda x_10935#5545925, false)), 1, None, false).numerator as double))), qty#5544502), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545926.isOrderUnit, lambda x_10935#5545926, false)), 1, None, false).uom, orderQuantityBaseUom#5544681), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545927.isOrderUnit, lambda x_10935#5545927, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5544682), candidateOrderQuantityInBaseUnit, qty#5544502, orderQuantityBaseUom, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5544682, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10937#5545928.isPreferred AND (((qty#5544502 * cast(lambda x_10937#5545928.denominator as double)) % cast(lambda x_10937#5545928.numerator as double)) = 0.0)), lambda x_10937#5545928, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5544502 * cast(lambda x_10938#5545966.denominator as double)) / cast(lambda x_10938#5545966.numerator as double)), uom, lambda x_10938#5545966.uom, uomUuid, lambda x_10938#5545966.uomUuid), lambda x_10938#5545966, false))).inPreferredQuantity, coalesce((qty#5544502 * (cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545929.isOrderUnit, lambda x_10936#5545929, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545930.isOrderUnit, lambda x_10936#5545930, false)), 1, None, false).numerator as double))), qty#5544502)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10937#5545931.isPreferred AND (((qty#5544502 * cast(lambda x_10937#5545931.denominator as double)) % cast(lambda x_10937#5545931.numerator as double)) = 0.0)), lambda x_10937#5545931, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5544502 * cast(lambda x_10938#5545967.denominator as double)) / cast(lambda x_10938#5545967.numerator as double)), uom, lambda x_10938#5545967.uom, uomUuid, lambda x_10938#5545967.uomUuid), lambda x_10938#5545967, false))).uom, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545932.isOrderUnit, lambda x_10936#5545932, false)), 1, None, false).uom, orderQuantityBaseUom#5544681)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10937#5545933.isPreferred AND (((qty#5544502 * cast(lambda x_10937#5545933.denominator as double)) % cast(lambda x_10937#5545933.numerator as double)) = 0.0)), lambda x_10937#5545933, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5544502 * cast(lambda x_10938#5545968.denominator as double)) / cast(lambda x_10938#5545968.numerator as double)), uom, lambda x_10938#5545968.uom, uomUuid, lambda x_10938#5545968.uomUuid), lambda x_10938#5545968, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545934.isOrderUnit, lambda x_10936#5545934, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5544682)), serviceLevel, coalesce(filter(element_at(quantityKpis#5545432, qty#5544502, None, false), lambdafunction((lambda x_10943#5545935.label = ServiceLevel), lambda x_10943#5545935, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#5544502 * (cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545938.isOrderUnit, lambda x_10935#5545938, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545939.isOrderUnit, lambda x_10935#5545939, false)), 1, None, false).numerator as double))), qty#5544502), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545940.isOrderUnit, lambda x_10935#5545940, false)), 1, None, false).uom, orderQuantityBaseUom#5544681), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10935#5545941.isOrderUnit, lambda x_10935#5545941, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5544682), candidateOrderQuantityInBaseUnit, qty#5544502, orderQuantityBaseUom, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5544682, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10937#5545942.isPreferred AND (((qty#5544502 * cast(lambda x_10937#5545942.denominator as double)) % cast(lambda x_10937#5545942.numerator as double)) = 0.0)), lambda x_10937#5545942, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5544502 * cast(lambda x_10938#5545969.denominator as double)) / cast(lambda x_10938#5545969.numerator as double)), uom, lambda x_10938#5545969.uom, uomUuid, lambda x_10938#5545969.uomUuid), lambda x_10938#5545969, false))).inPreferredQuantity, coalesce((qty#5544502 * (cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545943.isOrderUnit, lambda x_10936#5545943, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545944.isOrderUnit, lambda x_10936#5545944, false)), 1, None, false).numerator as double))), qty#5544502)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10937#5545945.isPreferred AND (((qty#5544502 * cast(lambda x_10937#5545945.denominator as double)) % cast(lambda x_10937#5545945.numerator as double)) = 0.0)), lambda x_10937#5545945, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5544502 * cast(lambda x_10938#5545970.denominator as double)) / cast(lambda x_10938#5545970.numerator as double)), uom, lambda x_10938#5545970.uom, uomUuid, lambda x_10938#5545970.uomUuid), lambda x_10938#5545970, false))).uom, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545946.isOrderUnit, lambda x_10936#5545946, false)), 1, None, false).uom, orderQuantityBaseUom#5544681)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10937#5545947.isPreferred AND (((qty#5544502 * cast(lambda x_10937#5545947.denominator as double)) % cast(lambda x_10937#5545947.numerator as double)) = 0.0)), lambda x_10937#5545947, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5544502 * cast(lambda x_10938#5545971.denominator as double)) / cast(lambda x_10938#5545971.numerator as double)), uom, lambda x_10938#5545971.uom, uomUuid, lambda x_10938#5545971.uomUuid), lambda x_10938#5545971, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10936#5545948.isOrderUnit, lambda x_10936#5545948, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5544682)), serviceLevel, coalesce(filter(element_at(quantityKpis#5545432, qty#5544502, None, false), lambdafunction((lambda x_10946#5545949.label = ServiceLevel), lambda x_10946#5545949, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#5544501 * (cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10939#5545952.isOrderUnit, lambda x_10939#5545952, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10939#5545953.isOrderUnit, lambda x_10939#5545953, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#5544501), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10939#5545954.isOrderUnit, lambda x_10939#5545954, false)), 1, None, false).uom, orderQuantityBaseUom#5544681), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10939#5545955.isOrderUnit, lambda x_10939#5545955, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5544682), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#5544501, orderQuantityBaseUom, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5544682, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10941#5545956.isPreferred AND (((quantityAfterProdPlantOptimization#5544501 * cast(lambda x_10941#5545956.denominator as double)) % cast(lambda x_10941#5545956.numerator as double)) = 0.0)), lambda x_10941#5545956, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5544501 * cast(lambda x_10942#5545972.denominator as double)) / cast(lambda x_10942#5545972.numerator as double)), uom, lambda x_10942#5545972.uom, uomUuid, lambda x_10942#5545972.uomUuid), lambda x_10942#5545972, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#5544501 * (cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10940#5545957.isOrderUnit, lambda x_10940#5545957, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10940#5545958.isOrderUnit, lambda x_10940#5545958, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#5544501)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10941#5545959.isPreferred AND (((quantityAfterProdPlantOptimization#5544501 * cast(lambda x_10941#5545959.denominator as double)) % cast(lambda x_10941#5545959.numerator as double)) = 0.0)), lambda x_10941#5545959, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5544501 * cast(lambda x_10942#5545973.denominator as double)) / cast(lambda x_10942#5545973.numerator as double)), uom, lambda x_10942#5545973.uom, uomUuid, lambda x_10942#5545973.uomUuid), lambda x_10942#5545973, false))).uom, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10940#5545960.isOrderUnit, lambda x_10940#5545960, false)), 1, None, false).uom, orderQuantityBaseUom#5544681)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5544695, lambdafunction((lambda x_10941#5545961.isPreferred AND (((quantityAfterProdPlantOptimization#5544501 * cast(lambda x_10941#5545961.denominator as double)) % cast(lambda x_10941#5545961.numerator as double)) = 0.0)), lambda x_10941#5545961, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5544501 * cast(lambda x_10942#5545974.denominator as double)) / cast(lambda x_10942#5545974.numerator as double)), uom, lambda x_10942#5545974.uom, uomUuid, lambda x_10942#5545974.uomUuid), lambda x_10942#5545974, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10940#5545962.isOrderUnit, lambda x_10940#5545962, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5544682)), serviceLevel, coalesce(filter(element_at(quantityKpis#5545432, quantityAfterProdPlantOptimization#5544501, None, false), lambdafunction((lambda x_10949#5545963.label = ServiceLevel), lambda x_10949#5545963, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#5545923, coalesce(filter(prodLocSpecificKpis#5545404, lambdafunction((lambda x_10952#5545976.label = InitialStockQty), lambda x_10952#5545976, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#5545975, coalesce(filter(prodLocSpecificKpis#5545404, lambdafunction((lambda x_10953#5545978.label = DemandPeriodEndTimestamp), lambda x_10953#5545978, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#5545977]
Input [36]: [shardId#5543988, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, nextAvailabilityDateTime#5544679, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, sourceOfSupplyUuid#5544667, minimumOrderQuantity#5544689, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, optimizationGroups#5544696, measurements#5544688, previousOrderProposal#5544664L, prodLocSpecificKpis#5545404, channelStreamSpecificKpis#5545419, quantityKpis#5545432, constraintStructArray#5545846]
(58) Project
Output [21]: [shardId#5543988, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, previousOrderProposal#5544664L, struct(supplier, supplier#5544669, supplyingPlant, supplyingPlant#5544699, productGroup, productGroup#5544700, product, product#5544671, plant, plant#5544672, supplierSubRange, subrange#5544670, sourceOfSupplyUuid, sourceOfSupplyUuid#5544667, deliveryDateTime, deliveryDateTime#5544677, unitPrice, netPriceAmount#5544686, unitPriceCurrency, netPriceCurrencyCode#5544687, unitPriceQuantity, netPriceQuantity#5544683, unitPriceQuantityUom, netPriceQuantityUom#5544684, unitPriceQuantityUomUuid, ... 31 more fields) AS parentItem#5546048]
Input [37]: [shardId#5543988, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, nextAvailabilityDateTime#5544679, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, netPriceAmount#5544686, netPriceCurrencyCode#5544687, netPriceQuantity#5544683, netPriceQuantityUom#5544684, netPriceQuantityUomUuid#5544685, sourceOfSupplyUuid#5544667, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, optimizationGroups#5544696, measurements#5544688, previousOrderProposal#5544664L, prodLocSpecificKpis#5545404, channelStreamSpecificKpis#5545419, quantityKpis#5545432, constraintBenchmark#5545852, calculationAnalysis#5545923, inventoryDateTime#5545975, demandPeriodEndDateTime#5545977]
(59) Project
Output [12]: [shardId#5543988, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, orderDateTime#5544676, splitIndicator#5544663L, orderProposalItemGroupId#5544660, previousOrderProposal#5544664L, parentItem#5546048, struct(itemId, orderProposalItemId#5544659, supplier, supplier#5544669, supplyingPlant, supplyingPlant#5544699, productGroup, productGroup#5544700, product, product#5544671, plant, plant#5544672, supplierSubRange, subrange#5544670, deliveryDateTime, deliveryDateTime#5544677, orderQuantity, coalesce((qty#5544502 * (cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10977#5546082.isOrderUnit, lambda x_10977#5546082, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10977#5546083.isOrderUnit, lambda x_10977#5546083, false)), 1, None, false).numerator as double))), qty#5544502), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10977#5546084.isOrderUnit, lambda x_10977#5546084, false)), 1, None, false).uom, orderQuantityBaseUom#5544681), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5544695, lambdafunction(lambda x_10977#5546085.isOrderUnit, lambda x_10977#5546085, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5544682), orderQuantityInBaseUnit, qty#5544502, orderQuantityBaseUom, ... 13 more fields) AS item#5546079]
Input [21]: [shardId#5543988, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, previousOrderProposal#5544664L, parentItem#5546048]
(60) ObjectHashAggregate
Input [12]: [shardId#5543988, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, orderDateTime#5544676, splitIndicator#5544663L, orderProposalItemGroupId#5544660, previousOrderProposal#5544664L, parentItem#5546048, item#5546079]
Keys [4]: [shardId#5543988, orderProposalId#5544658L, splitIndicator#5544663L, orderProposalItemGroupId#5544660]
Functions [8]: [partial_max(originalReplenishmentRunId#5544661L), partial_max(supplierGroup#5544668), partial_max(supplier#5544669), partial_max(supplyingPlant#5544699), partial_max(orderDateTime#5544676), partial_collect_list(parentItem#5546048, 0, 0), partial_collect_set(previousOrderProposal#5544664L, 0, 0), partial_collect_list(item#5546079, 0, 0)]
Aggregate Attributes [8]: [max#5547330L, max#5547331, max#5547332, max#5547333, max#5547334, buf#5547335, buf#5547336, buf#5547337]
Results [12]: [shardId#5543988, orderProposalId#5544658L, splitIndicator#5544663L, orderProposalItemGroupId#5544660, max#5547338L, max#5547339, max#5547340, max#5547341, max#5547342, buf#5547343, buf#5547344, buf#5547345]
(61) Exchange
Input [12]: [shardId#5543988, orderProposalId#5544658L, splitIndicator#5544663L, orderProposalItemGroupId#5544660, max#5547338L, max#5547339, max#5547340, max#5547341, max#5547342, buf#5547343, buf#5547344, buf#5547345]
Arguments: hashpartitioning(shardId#5543988, orderProposalId#5544658L, splitIndicator#5544663L, orderProposalItemGroupId#5544660, 30), ENSURE_REQUIREMENTS, [plan_id=2877321]
(62) ObjectHashAggregate
Input [12]: [shardId#5543988, orderProposalId#5544658L, splitIndicator#5544663L, orderProposalItemGroupId#5544660, max#5547338L, max#5547339, max#5547340, max#5547341, max#5547342, buf#5547343, buf#5547344, buf#5547345]
Keys [4]: [shardId#5543988, orderProposalId#5544658L, splitIndicator#5544663L, orderProposalItemGroupId#5544660]
Functions [8]: [max(originalReplenishmentRunId#5544661L), max(supplierGroup#5544668), max(supplier#5544669), max(supplyingPlant#5544699), max(orderDateTime#5544676), collect_list(parentItem#5546048, 0, 0), collect_set(previousOrderProposal#5544664L, 0, 0), collect_list(item#5546079, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#5544661L)#5546148L, max(supplierGroup#5544668)#5546149, max(supplier#5544669)#5546150, max(supplyingPlant#5544699)#5546151, max(orderDateTime#5544676)#5546152, collect_list(parentItem#5546048, 0, 0)#5546153, collect_set(previousOrderProposal#5544664L, 0, 0)#5546155, collect_list(item#5546079, 0, 0)#5546154]
Results [10]: [shardId#5543988, orderProposalId#5544658L, max(originalReplenishmentRunId#5544661L)#5546148L AS originalReplenishmentRunId#5546096L, max(supplierGroup#5544668)#5546149 AS supplierGroup#5546097, max(supplier#5544669)#5546150 AS supplier#5546098, max(supplyingPlant#5544699)#5546151 AS supplyingPlant#5546099, max(orderDateTime#5544676)#5546152 AS orderDateTime#5546100, collect_list(parentItem#5546048, 0, 0)#5546153 AS parentItems#5546101, collect_set(previousOrderProposal#5544664L, 0, 0)#5546155 AS previousOrderProposals#5546103, struct(itemGroupId, coalesce(orderProposalItemGroupId#5544660, cast((monotonically_increasing_id() % 9999999999) as string)), items, collect_list(item#5546079, 0, 0)#5546154) AS itemGroup#5546157]
(63) ObjectHashAggregate
Input [10]: [shardId#5543988, orderProposalId#5544658L, originalReplenishmentRunId#5546096L, supplierGroup#5546097, supplier#5546098, supplyingPlant#5546099, orderDateTime#5546100, parentItems#5546101, previousOrderProposals#5546103, itemGroup#5546157]
Keys [2]: [shardId#5543988, orderProposalId#5544658L]
Functions [8]: [partial_max(originalReplenishmentRunId#5546096L), partial_max(supplierGroup#5546097), partial_max(supplier#5546098), partial_max(supplyingPlant#5546099), partial_max(orderDateTime#5546100), partial_collect_list(itemGroup#5546157, 0, 0), partial_collect_list(parentItems#5546101, 0, 0), partial_collect_set(previousOrderProposals#5546103, 0, 0)]
Aggregate Attributes [8]: [max#5547314L, max#5547315, max#5547316, max#5547317, max#5547318, buf#5547319, buf#5547320, buf#5547321]
Results [10]: [shardId#5543988, orderProposalId#5544658L, max#5547322L, max#5547323, max#5547324, max#5547325, max#5547326, buf#5547327, buf#5547328, buf#5547329]
(64) Exchange
Input [10]: [shardId#5543988, orderProposalId#5544658L, max#5547322L, max#5547323, max#5547324, max#5547325, max#5547326, buf#5547327, buf#5547328, buf#5547329]
Arguments: hashpartitioning(shardId#5543988, orderProposalId#5544658L, 30), ENSURE_REQUIREMENTS, [plan_id=2877324]
(65) ObjectHashAggregate
Input [10]: [shardId#5543988, orderProposalId#5544658L, max#5547322L, max#5547323, max#5547324, max#5547325, max#5547326, buf#5547327, buf#5547328, buf#5547329]
Keys [2]: [shardId#5543988, orderProposalId#5544658L]
Functions [8]: [max(originalReplenishmentRunId#5546096L), max(supplierGroup#5546097), max(supplier#5546098), max(supplyingPlant#5546099), max(orderDateTime#5546100), collect_list(itemGroup#5546157, 0, 0), collect_list(parentItems#5546101, 0, 0), collect_set(previousOrderProposals#5546103, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#5546096L)#5546179L, max(supplierGroup#5546097)#5546180, max(supplier#5546098)#5546181, max(supplyingPlant#5546099)#5546182, max(orderDateTime#5546100)#5546183, collect_list(itemGroup#5546157, 0, 0)#5546184, collect_list(parentItems#5546101, 0, 0)#5546185, collect_set(previousOrderProposals#5546103, 0, 0)#5546186]
Results [10]: [shardId#5543988, orderProposalId#5544658L, max(originalReplenishmentRunId#5546096L)#5546179L AS originalReplenishmentRunId#5546158L, max(supplierGroup#5546097)#5546180 AS supplierGroup#5546159, max(supplier#5546098)#5546181 AS supplier#5546160, max(supplyingPlant#5546099)#5546182 AS supplyingPlant#5546161, max(orderDateTime#5546100)#5546183 AS orderDateTime#5546162, collect_list(itemGroup#5546157, 0, 0)#5546184 AS itemGroups#5546163, flatten(collect_list(parentItems#5546101, 0, 0)#5546185) AS parentItems#5546164, flatten(collect_set(previousOrderProposals#5546103, 0, 0)#5546186) AS previousOrderProposals#5546165]
(66) Project
Output [2]: [shardId#5543988, struct(orderProposalId, orderProposalId#5544658L, originalReplenishmentRunId, originalReplenishmentRunId#5546158L, supplierGroup, supplierGroup#5546159, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#5546159) THEN supplier#5546160 END, supplyingPlant, supplyingPlant#5546161, orderDateTime, orderDateTime#5546162, itemGroups, itemGroups#5546163, previousOrderProposals, array_distinct(previousOrderProposals#5546165), parentItems, parentItems#5546164) AS orderProposal#5546190]
Input [10]: [shardId#5543988, orderProposalId#5544658L, originalReplenishmentRunId#5546158L, supplierGroup#5546159, supplier#5546160, supplyingPlant#5546161, orderDateTime#5546162, itemGroups#5546163, parentItems#5546164, previousOrderProposals#5546165]
(67) Project
Output [11]: [shardId#5543988, orderProposal#5546190.orderProposalId AS _extract_orderProposalId#5546946L, orderProposal#5546190.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#5546947L, orderProposal#5546190.supplierGroup AS _extract_supplierGroup#5546948, orderProposal#5546190.supplier AS _extract_supplier#5546949, orderProposal#5546190.supplyingPlant AS _extract_supplyingPlant#5546950, orderProposal#5546190.orderDateTime AS _extract_orderDateTime#5546951, orderProposal#5546190.itemGroups AS _extract_itemGroups#5546952, orderProposal#5546190.previousOrderProposals AS _extract_previousOrderProposals#5546953, orderProposal#5546190.parentItems AS _extract_parentItems#5546954, orderProposal#5546190.orderProposalId AS _extract_orderProposalId#5546955L]
Input [2]: [shardId#5543988, orderProposal#5546190]
(68) InMemoryTableScan
Output [3]: [shardId#5546203, orderProposalId#5546204L, optimizationGroups#5546206]
Arguments: [shardId#5546203, orderProposalId#5546204L, optimizationGroups#5546206], [isnotnull(orderProposalId#5546204L)]
(69) InMemoryRelation
Arguments: [shardId#5546203, orderProposalId#5546204L, items#5546205, optimizationGroups#5546206, isOptimal#5546207, optimizationInsights#5546209], StorageLevel(disk, memory, 2 replicas)
(70) Filter [codegen id : 2]
Input [3]: [shardId#5546203, orderProposalId#5546204L, optimizationGroups#5546206]
Condition : isnotnull(orderProposalId#5546204L)
(71) BroadcastExchange
Input [3]: [shardId#5546203, orderProposalId#5546204L, optimizationGroups#5546206]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=2877331]
(72) InMemoryTableScan
Output [2]: [items#5545841, shardId#5545839]
Arguments: [items#5545841, shardId#5545839], [(size(items#5545841.worklistShardItemId, true) > 0), isnotnull(items#5545841.worklistShardItemId), (shardId#5545839 = 0_1_10000001445)]
(73) InMemoryRelation
Arguments: [shardId#5545839, orderProposalId#5545840L, items#5545841, optimizationGroups#5545842, isOptimal#5545843, optimizationInsights#5545845], StorageLevel(disk, memory, 2 replicas)
(74) Filter [codegen id : 3]
Input [2]: [items#5545841, shardId#5545839]
Condition : (((size(items#5545841.worklistShardItemId, true) > 0) AND isnotnull(items#5545841.worklistShardItemId)) AND (shardId#5545839 = 0_1_10000001445))
(75) Project [codegen id : 3]
Output [1]: [items#5545841.worklistShardItemId AS _extract_worklistShardItemId#5546851]
Input [2]: [items#5545841, shardId#5545839]
(76) Generate [codegen id : 3]
Input [1]: [_extract_worklistShardItemId#5546851]
Arguments: explode(_extract_worklistShardItemId#5546851), false, [item#5546210L]
(77) Project [codegen id : 3]
Output [1]: [item#5546210L AS worklistShardItemId#5546211L]
Input [1]: [item#5546210L]
(78) BroadcastExchange
Input [1]: [worklistShardItemId#5546211L]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2877339]
(79) Scan parquet
Output [5]: [orderProposalId#5546259L, isFallbackOrderOnly#5546276, worklistShardItemId#5546282L, shardId#5546303, sequenceId#5546281]
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#5546303), isnotnull(sequenceId#5546281), (shardId#5546303 = 0_1_10000001445), (sequenceId#5546281 = 7)]
PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>
(80) ColumnarToRow [codegen id : 4]
Input [5]: [orderProposalId#5546259L, isFallbackOrderOnly#5546276, worklistShardItemId#5546282L, shardId#5546303, sequenceId#5546281]
(81) Filter [codegen id : 4]
Input [5]: [orderProposalId#5546259L, isFallbackOrderOnly#5546276, worklistShardItemId#5546282L, shardId#5546303, sequenceId#5546281]
Condition : ((isnotnull(worklistShardItemId#5546282L) AND NOT (isFallbackOrderOnly#5546276 <=> true)) AND isnotnull(orderProposalId#5546259L))
(82) Project [codegen id : 4]
Output [2]: [orderProposalId#5546259L, worklistShardItemId#5546282L]
Input [5]: [orderProposalId#5546259L, isFallbackOrderOnly#5546276, worklistShardItemId#5546282L, shardId#5546303, sequenceId#5546281]
(83) Exchange
Input [2]: [orderProposalId#5546259L, worklistShardItemId#5546282L]
Arguments: hashpartitioning(worklistShardItemId#5546282L, 30), REPARTITION_BY_NUM, [plan_id=2877346]
(84) Project
Output [2]: [worklistShardItemId#5546282L, orderProposalId#5546259L]
Input [2]: [orderProposalId#5546259L, worklistShardItemId#5546282L]
(85) BroadcastHashJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#5546211L]
Right keys [1]: [worklistShardItemId#5546282L]
Join type: Inner
Join condition: None
(86) Project [codegen id : 5]
Output [1]: [orderProposalId#5546259L]
Input [3]: [worklistShardItemId#5546211L, worklistShardItemId#5546282L, orderProposalId#5546259L]
(87) HashAggregate [codegen id : 5]
Input [1]: [orderProposalId#5546259L]
Keys [1]: [orderProposalId#5546259L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#5546259L]
(88) Exchange
Input [1]: [orderProposalId#5546259L]
Arguments: hashpartitioning(orderProposalId#5546259L, 30), ENSURE_REQUIREMENTS, [plan_id=2877353]
(89) HashAggregate
Input [1]: [orderProposalId#5546259L]
Keys [1]: [orderProposalId#5546259L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#5546259L]
(90) BroadcastHashJoin [codegen id : 6]
Left keys [1]: [orderProposalId#5546204L]
Right keys [1]: [orderProposalId#5546259L]
Join type: Inner
Join condition: None
(91) Project
Output [3]: [orderProposalId#5546204L, shardId#5546203, coalesce(transform(optimizationGroups#5546206, lambdafunction(struct(optGroupId, lambda x_10981#5546201.optGroupId, minOrderProfile, lambda x_10981#5546201.minOrderProfile, assignmentDetails, lambda x_10981#5546201.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_10981#5546201.minOrderGoal.dimensionType, unit, lambda x_10981#5546201.minOrderGoal.unit, unitUuid, lambda x_10981#5546201.minOrderGoal.unitUuid, goalValue, lambda x_10981#5546201.minOrderGoal.minOrderValue, calcValue, lambda x_10981#5546201.minOrderGoal.calculatedOrderValue)), lambda x_10981#5546201, false)), []) AS optimizationGroups#5546200]
Input [4]: [shardId#5546203, orderProposalId#5546204L, optimizationGroups#5546206, orderProposalId#5546259L]
(92) BroadcastExchange
Input [3]: [orderProposalId#5546204L, shardId#5546203, optimizationGroups#5546200]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[0, bigint, true], 0), isnull(input[0, bigint, true])),false), [plan_id=2877359]
(93) BroadcastHashJoin
Left keys [4]: [coalesce(shardId#5543988, ), isnull(shardId#5543988), coalesce(_extract_orderProposalId#5546955L, 0), isnull(_extract_orderProposalId#5546955L)]
Right keys [4]: [coalesce(shardId#5546203, ), isnull(shardId#5546203), coalesce(orderProposalId#5546204L, 0), isnull(orderProposalId#5546204L)]
Join type: LeftOuter
Join condition: None
(94) Project
Output [2]: [shardId#5543988, named_struct(orderProposalId, _extract_orderProposalId#5546955L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#5546947L, supplierGroup, _extract_supplierGroup#5546948, optimizationGroups, coalesce(optimizationGroups#5546200, []), supplier, _extract_supplier#5546949, supplyingPlant, _extract_supplyingPlant#5546950, orderDateTime, _extract_orderDateTime#5546951, itemGroups, _extract_itemGroups#5546952, previousOrderProposals, _extract_previousOrderProposals#5546953, parentItems, _extract_parentItems#5546954) AS orderProposal#5546307]
Input [14]: [shardId#5543988, _extract_orderProposalId#5546946L, _extract_originalReplenishmentRunId#5546947L, _extract_supplierGroup#5546948, _extract_supplier#5546949, _extract_supplyingPlant#5546950, _extract_orderDateTime#5546951, _extract_itemGroups#5546952, _extract_previousOrderProposals#5546953, _extract_parentItems#5546954, _extract_orderProposalId#5546955L, orderProposalId#5546204L, shardId#5546203, optimizationGroups#5546200]
(95) Project
Output [3]: [shardId#5543988, orderProposal#5546307, CASE WHEN (size(orderProposal#5546307.parentItems, true) > 2000) THEN xxhash64(orderProposal#5546307.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#5546307.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#5548043L]
Input [2]: [orderProposal#5546307, shardId#5543988]
(96) ObjectHashAggregate
Input [3]: [shardId#5543988, orderProposal#5546307, resultSeparationId#5548043L]
Keys [2]: [shardId#5543988, resultSeparationId#5548043L]
Functions [1]: [partial_collect_list(orderProposal#5546307, 0, 0)]
Aggregate Attributes [1]: [buf#5548082]
Results [3]: [shardId#5543988, resultSeparationId#5548043L, buf#5548083]
(97) Exchange
Input [3]: [shardId#5543988, resultSeparationId#5548043L, buf#5548083]
Arguments: hashpartitioning(shardId#5543988, resultSeparationId#5548043L, 30), ENSURE_REQUIREMENTS, [plan_id=2877494]
(98) ObjectHashAggregate
Input [3]: [shardId#5543988, resultSeparationId#5548043L, buf#5548083]
Keys [2]: [shardId#5543988, resultSeparationId#5548043L]
Functions [1]: [collect_list(orderProposal#5546307, 0, 0)]
Aggregate Attributes [1]: [collect_list(orderProposal#5546307, 0, 0)#5548051]
Results [3]: [shardId#5543988, resultSeparationId#5548043L, collect_list(orderProposal#5546307, 0, 0)#5548051 AS orderProposals#5548047]
(99) Exchange
Input [3]: [shardId#5543988, resultSeparationId#5548043L, orderProposals#5548047]
Arguments: SinglePartition, REPARTITION_BY_NUM, [plan_id=2877537]
(100) Project
Output [2]: [shardId#5543988, orderProposals#5548047]
Input [3]: [shardId#5543988, resultSeparationId#5548043L, orderProposals#5548047]
(101) CollectLimit
Input: []
Arguments: 1