== Physical Plan ==
AdaptiveSparkPlan (150)
+- == Current Plan ==
ResultQueryStage (148)
+- * Project (147)
+- TableCacheQueryStage (146), Statistics(sizeInBytes=3.8 MiB, rowCount=2.94E+3)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (145)
+- == Final Plan ==
ResultQueryStage (83)
+- * Project (82)
+- * BroadcastHashJoin LeftOuter BuildRight (81)
:- Project (74)
: +- BroadcastHashJoin LeftOuter BuildRight (73)
: :- Project (70)
: : +- BroadcastHashJoin LeftOuter BuildRight (69)
: : :- Project (61)
: : : +- Project (60)
: : : +- Project (59)
: : : +- BroadcastHashJoin LeftOuter BuildRight (58)
: : : :- Project (50)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (49)
: : : : :- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- Project (36)
: : : : : +- Project (35)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (34)
: : : : : :- * Project (25)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (24)
: : : : : : :- * Project (15)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (14)
: : : : : : : :- ShuffleQueryStage (6), Statistics(sizeInBytes=1299.5 KiB, rowCount=2.94E+3)
: : : : : : : : +- Exchange (5)
: : : : : : : : +- * ColumnarToRow (4)
: : : : : : : : +- Scan parquet (3)
: : : : : : : +- BroadcastQueryStage (13), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (12)
: : : : : : : +- ShuffleQueryStage (11), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (10)
: : : : : : : +- * Project (9)
: : : : : : : +- * ColumnarToRow (8)
: : : : : : : +- Scan parquet (7)
: : : : : : +- BroadcastQueryStage (23), Statistics(sizeInBytes=2.1 MiB, rowCount=1.54E+3)
: : : : : : +- BroadcastExchange (22)
: : : : : : +- ShuffleQueryStage (21), Statistics(sizeInBytes=1254.6 KiB, rowCount=1.54E+3)
: : : : : : +- Exchange (20)
: : : : : : +- * Project (19)
: : : : : : +- * Filter (18)
: : : : : : +- * ColumnarToRow (17)
: : : : : : +- Scan parquet (16)
: : : : : +- BroadcastQueryStage (33), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (32)
: : : : : +- ShuffleQueryStage (31), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (30)
: : : : : +- * Project (29)
: : : : : +- * Filter (28)
: : : : : +- * ColumnarToRow (27)
: : : : : +- Scan parquet (26)
: : : : +- BroadcastQueryStage (48), Statistics(sizeInBytes=2.1 MiB, rowCount=2.94E+3)
: : : : +- BroadcastExchange (47)
: : : : +- ShuffleQueryStage (46), Statistics(sizeInBytes=343.9 KiB, rowCount=2.94E+3)
: : : : +- Exchange (45)
: : : : +- * ColumnarToRow (44)
: : : : +- Scan parquet (43)
: : : +- BroadcastQueryStage (57), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (56)
: : : +- ShuffleQueryStage (55), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (54)
: : : +- * Project (53)
: : : +- * ColumnarToRow (52)
: : : +- Scan parquet (51)
: : +- BroadcastQueryStage (68), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (67)
: : +- ShuffleQueryStage (66), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (65)
: : +- * Project (64)
: : +- * ColumnarToRow (63)
: : +- Scan parquet (62)
: +- BroadcastQueryStage (72), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (71)
+- BroadcastQueryStage (80), Statistics(sizeInBytes=2.0 MiB, rowCount=522)
+- BroadcastExchange (79)
+- ShuffleQueryStage (78), Statistics(sizeInBytes=78.5 KiB, rowCount=522)
+- Exchange (77)
+- * ColumnarToRow (76)
+- Scan parquet (75)
+- == Initial Plan ==
Project (144)
+- BroadcastHashJoin LeftOuter BuildRight (143)
:- Project (140)
: +- BroadcastHashJoin LeftOuter BuildRight (139)
: :- Project (134)
: : +- BroadcastHashJoin LeftOuter BuildRight (133)
: : :- Project (129)
: : : +- Project (128)
: : : +- Project (127)
: : : +- BroadcastHashJoin LeftOuter BuildRight (126)
: : : :- Project (122)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (121)
: : : : :- Project (118)
: : : : : +- Project (117)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (116)
: : : : : :- Project (110)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (109)
: : : : : : :- Project (103)
: : : : : : : +- Project (102)
: : : : : : : +- Project (101)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (100)
: : : : : : : :- Project (95)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (94)
: : : : : : : : :- Project (89)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (88)
: : : : : : : : : :- Exchange (84)
: : : : : : : : : : +- Scan parquet (3)
: : : : : : : : : +- BroadcastExchange (87)
: : : : : : : : : +- Exchange (86)
: : : : : : : : : +- Project (85)
: : : : : : : : : +- Scan parquet (7)
: : : : : : : : +- BroadcastExchange (93)
: : : : : : : : +- Exchange (92)
: : : : : : : : +- Project (91)
: : : : : : : : +- Filter (90)
: : : : : : : : +- Scan parquet (16)
: : : : : : : +- BroadcastExchange (99)
: : : : : : : +- Exchange (98)
: : : : : : : +- Project (97)
: : : : : : : +- Filter (96)
: : : : : : : +- Scan parquet (26)
: : : : : : +- BroadcastExchange (108)
: : : : : : +- Project (107)
: : : : : : +- InMemoryTableScan (104)
: : : : : : +- InMemoryRelation (105)
: : : : : : +- LocalTableScan (106)
: : : : : +- BroadcastExchange (115)
: : : : : +- Project (114)
: : : : : +- Filter (113)
: : : : : +- InMemoryTableScan (111)
: : : : : +- InMemoryRelation (112)
: : : : : +- LocalTableScan (106)
: : : : +- BroadcastExchange (120)
: : : : +- Exchange (119)
: : : : +- Scan parquet (43)
: : : +- BroadcastExchange (125)
: : : +- Exchange (124)
: : : +- Project (123)
: : : +- Scan parquet (51)
: : +- BroadcastExchange (132)
: : +- Exchange (131)
: : +- Project (130)
: : +- Scan parquet (62)
: +- BroadcastExchange (138)
: +- Exchange (137)
: +- Project (136)
: +- Scan parquet (135)
+- BroadcastExchange (142)
+- Exchange (141)
+- Scan parquet (75)
+- == Initial Plan ==
Project (149)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (145)
+- == Final Plan ==
ResultQueryStage (83)
+- * Project (82)
+- * BroadcastHashJoin LeftOuter BuildRight (81)
:- Project (74)
: +- BroadcastHashJoin LeftOuter BuildRight (73)
: :- Project (70)
: : +- BroadcastHashJoin LeftOuter BuildRight (69)
: : :- Project (61)
: : : +- Project (60)
: : : +- Project (59)
: : : +- BroadcastHashJoin LeftOuter BuildRight (58)
: : : :- Project (50)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (49)
: : : : :- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- Project (36)
: : : : : +- Project (35)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (34)
: : : : : :- * Project (25)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (24)
: : : : : : :- * Project (15)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (14)
: : : : : : : :- ShuffleQueryStage (6), Statistics(sizeInBytes=1299.5 KiB, rowCount=2.94E+3)
: : : : : : : : +- Exchange (5)
: : : : : : : : +- * ColumnarToRow (4)
: : : : : : : : +- Scan parquet (3)
: : : : : : : +- BroadcastQueryStage (13), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (12)
: : : : : : : +- ShuffleQueryStage (11), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (10)
: : : : : : : +- * Project (9)
: : : : : : : +- * ColumnarToRow (8)
: : : : : : : +- Scan parquet (7)
: : : : : : +- BroadcastQueryStage (23), Statistics(sizeInBytes=2.1 MiB, rowCount=1.54E+3)
: : : : : : +- BroadcastExchange (22)
: : : : : : +- ShuffleQueryStage (21), Statistics(sizeInBytes=1254.6 KiB, rowCount=1.54E+3)
: : : : : : +- Exchange (20)
: : : : : : +- * Project (19)
: : : : : : +- * Filter (18)
: : : : : : +- * ColumnarToRow (17)
: : : : : : +- Scan parquet (16)
: : : : : +- BroadcastQueryStage (33), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (32)
: : : : : +- ShuffleQueryStage (31), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (30)
: : : : : +- * Project (29)
: : : : : +- * Filter (28)
: : : : : +- * ColumnarToRow (27)
: : : : : +- Scan parquet (26)
: : : : +- BroadcastQueryStage (48), Statistics(sizeInBytes=2.1 MiB, rowCount=2.94E+3)
: : : : +- BroadcastExchange (47)
: : : : +- ShuffleQueryStage (46), Statistics(sizeInBytes=343.9 KiB, rowCount=2.94E+3)
: : : : +- Exchange (45)
: : : : +- * ColumnarToRow (44)
: : : : +- Scan parquet (43)
: : : +- BroadcastQueryStage (57), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (56)
: : : +- ShuffleQueryStage (55), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (54)
: : : +- * Project (53)
: : : +- * ColumnarToRow (52)
: : : +- Scan parquet (51)
: : +- BroadcastQueryStage (68), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (67)
: : +- ShuffleQueryStage (66), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (65)
: : +- * Project (64)
: : +- * ColumnarToRow (63)
: : +- Scan parquet (62)
: +- BroadcastQueryStage (72), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (71)
+- BroadcastQueryStage (80), Statistics(sizeInBytes=2.0 MiB, rowCount=522)
+- BroadcastExchange (79)
+- ShuffleQueryStage (78), Statistics(sizeInBytes=78.5 KiB, rowCount=522)
+- Exchange (77)
+- * ColumnarToRow (76)
+- Scan parquet (75)
+- == Initial Plan ==
Project (144)
+- BroadcastHashJoin LeftOuter BuildRight (143)
:- Project (140)
: +- BroadcastHashJoin LeftOuter BuildRight (139)
: :- Project (134)
: : +- BroadcastHashJoin LeftOuter BuildRight (133)
: : :- Project (129)
: : : +- Project (128)
: : : +- Project (127)
: : : +- BroadcastHashJoin LeftOuter BuildRight (126)
: : : :- Project (122)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (121)
: : : : :- Project (118)
: : : : : +- Project (117)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (116)
: : : : : :- Project (110)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (109)
: : : : : : :- Project (103)
: : : : : : : +- Project (102)
: : : : : : : +- Project (101)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (100)
: : : : : : : :- Project (95)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (94)
: : : : : : : : :- Project (89)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (88)
: : : : : : : : : :- Exchange (84)
: : : : : : : : : : +- Scan parquet (3)
: : : : : : : : : +- BroadcastExchange (87)
: : : : : : : : : +- Exchange (86)
: : : : : : : : : +- Project (85)
: : : : : : : : : +- Scan parquet (7)
: : : : : : : : +- BroadcastExchange (93)
: : : : : : : : +- Exchange (92)
: : : : : : : : +- Project (91)
: : : : : : : : +- Filter (90)
: : : : : : : : +- Scan parquet (16)
: : : : : : : +- BroadcastExchange (99)
: : : : : : : +- Exchange (98)
: : : : : : : +- Project (97)
: : : : : : : +- Filter (96)
: : : : : : : +- Scan parquet (26)
: : : : : : +- BroadcastExchange (108)
: : : : : : +- Project (107)
: : : : : : +- InMemoryTableScan (104)
: : : : : : +- InMemoryRelation (105)
: : : : : : +- LocalTableScan (106)
: : : : : +- BroadcastExchange (115)
: : : : : +- Project (114)
: : : : : +- Filter (113)
: : : : : +- InMemoryTableScan (111)
: : : : : +- InMemoryRelation (112)
: : : : : +- LocalTableScan (106)
: : : : +- BroadcastExchange (120)
: : : : +- Exchange (119)
: : : : +- Scan parquet (43)
: : : +- BroadcastExchange (125)
: : : +- Exchange (124)
: : : +- Project (123)
: : : +- Scan parquet (51)
: : +- BroadcastExchange (132)
: : +- Exchange (131)
: : +- Project (130)
: : +- Scan parquet (62)
: +- BroadcastExchange (138)
: +- Exchange (137)
: +- Project (136)
: +- Scan parquet (135)
+- BroadcastExchange (142)
+- Exchange (141)
+- Scan parquet (75)
(1) InMemoryTableScan
Output [44]: [availabilityDateTime#732284, clusterId#732295L, constraintIsActive#732484, constraintLabels#732450, constraintOperators#732451, constraintRanks#732453, constraintValues#732490, deliveryDateTime#732278, externalPlantId#732344, externalProductId#732342, isFallbackOrderOnly#732290, logisticUnits#732423, measurements#732577, minimumOrderQuantity#732502, mrpController#732286, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, nextAvailabilityDateTime#732285, optimizationGroups#732591, orderDateTime#732283, orderProposalHorizonGroupingId#732292L, orderProposalId#732291L, orderProposalItemGroupId#732298, orderProposalItemId#732299, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, originalReplenishmentRunId#732579L, plant#732277, previousOrderProposal#732294L, product#732282, productGroup#732281, purchasingGroup#732289, purchasingOrg#732288, sequenceId#732296, sourceOfSupplyUuid#732287, splitIndicator#732293L, subrange#732279, supplier#732276, supplierGroup#732275, supplyingPlant#732280, worklistShardItemId#732297L]
Arguments: [availabilityDateTime#732284, clusterId#732295L, constraintIsActive#732484, constraintLabels#732450, constraintOperators#732451, constraintRanks#732453, constraintValues#732490, deliveryDateTime#732278, externalPlantId#732344, externalProductId#732342, isFallbackOrderOnly#732290, logisticUnits#732423, measurements#732577, minimumOrderQuantity#732502, mrpController#732286, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, nextAvailabilityDateTime#732285, optimizationGroups#732591, orderDateTime#732283, orderProposalHorizonGroupingId#732292L, orderProposalId#732291L, ... 19 more fields]
(2) InMemoryRelation
Arguments: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, ... 19 more fields], StorageLevel(disk, memory, 2 replicas)
(3) Scan parquet
Output [25]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-boundary-snapshot/10000002108/shardId=0_1_10000002108]
ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,supplyingPlant:string,productGroup:string,product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,mrpController:string,sourceOfSupplyUuid:string,purchasingOrg:string,purchasingGroup:string,isFallbackOrderOnly:boolean,orderProposalId:bigint,orderProposalHorizonGroupingId:bigint,splitIndicator:bigint,previousOrderProposal:bigint,clusterId:bigint,sequenceId:int,worklistShardItemId:bigint,orderProposalItemGroupId:string,orderProposalItemId:string>
(4) ColumnarToRow [codegen id : 1]
Input [25]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299]
(5) Exchange
Input [25]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299]
Arguments: hashpartitioning(product#732282, plant#732277, 25), REPARTITION_BY_NUM, [plan_id=292019]
(6) ShuffleQueryStage
Output [25]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299]
Arguments: 0
(7) Scan parquet
Output [24]: [internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324, systemId#732301]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply]
ReadSchema: struct<internalUUID:string,supplier:struct<internalRefUUID:string,id:string>,receiver:struct<internalRefUUID:string,id:string>,product:struct<internalRefUUID:string,id:string>,receivingPlant:struct<internalRefUUID:string,id:string>,sourceOfSupplyType:struct<internalRefUUID:string,code:string>,purchasingGroup:struct<internalRefUUID:string,id:string>,purchasingOrganization:struct<internalRefUUID:string,id:string>,productGroup:struct<internalRefUUID:string,id:string>,validFrom:timestamp,validTo:timestamp,priority:int,isPurchasingBlocked:boolean,isConsignment:boolean,isDeleted:boolean,supplierSubrange:string,plannedDeliveryTimeDays:int,orderQuantityUnit:struct<internalRefUUID:string,code:string>,purchasingPriceAspect:struct<netPrice:struct<amount:double,currencyCode:struct<internalRefUUID:string,code:string>>,netPriceQuantity:double,netPriceUnit:struct<internalRefUUID:string,code:string>>,orderCurrency:struct<internalRefUUID:string,code:string>,minimumOrderQuantity:double,logisticalRoundingProfile:struct<logisticalRoundingProfile:string,internalRefUUID:string>,supplyingPlant:struct<internalRefUUID:string,id:string>>
(8) ColumnarToRow [codegen id : 2]
Input [24]: [internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324, systemId#732301]
(9) Project [codegen id : 2]
Output [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Input [24]: [internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324, systemId#732301]
(10) Exchange
Input [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=292038]
(11) ShuffleQueryStage
Output [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Arguments: 1
(12) BroadcastExchange
Input [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=292666]
(13) BroadcastQueryStage
Output [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Arguments: 17
(14) BroadcastHashJoin [codegen id : 12]
Left keys [2]: [coalesce(sourceOfSupplyUuid#732287, ), isnull(sourceOfSupplyUuid#732287)]
Right keys [2]: [coalesce(internalUUID#732302, ), isnull(internalUUID#732302)]
Join type: LeftOuter
Join condition: None
(15) Project [codegen id : 12]
Output [26]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, struct(systemId, systemId#732301, internalUUID, internalUUID#732302, supplier, supplier#732303, receiver, receiver#732304, product, product#732305, receivingPlant, receivingPlant#732306, sourceOfSupplyType, sourceOfSupplyType#732307, purchasingGroup, purchasingGroup#732308, purchasingOrganization, purchasingOrganization#732309, productGroup, productGroup#732310, validFrom, validFrom#732311, validTo, validTo#732312, priority, ... 23 more fields) AS sos#732325]
Input [49]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
(16) Scan parquet
Output [8]: [internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336, systemId#732329]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant]
PushedFilters: [In(plant.internalRefUUID, [1c037502c75549dc72c6fc87c802bcec,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,3d84243e56ebf98292ed5dba2fd51543,45f9c5206af43e1e6acbe19d9a246289,4d233bd0bf112aded9d852448354b078,6d24a939f4bbd79f6acb8684d6e45c97,717937a4d5db853d3359b6a0623cfdf0,f80b06f7b2102a5f5c63b031eb5d8e03,fca7a07ad5f143db2beafbd1d0401ea1])]
ReadSchema: struct<internalUUID:string,plant:struct<internalRefUUID:string,id:string>,product:struct<internalRefUUID:string,id:string>,blockedForReplenishmentStartingFrom:date,productionAspect:struct<productMovementPlants:struct<unitOfIssue:struct<internalRefUUID:string,code:string>>,productPlanningPlants:struct<mrpType:struct<internalRefUUID:string,code:string>,abcIndicator:struct<internalRefUUID:string,code:string>,mrpController:struct<internalRefUUID:string,id:string>,minimumLotSize:double,minimumSafetyStock:double,logisticalRoundingProfile:struct<internalRefUUID:string,logisticalRoundingProfile:string>,sourceOfSupplyCategory:struct<internalRefUUID:string,code:string>>>,salesPlant:struct<loadingGroup:struct<internalRefUUID:string,code:string>>,listing:array<struct<validFrom:timestamp,validTo:timestamp,isListed:boolean>>>
(17) ColumnarToRow [codegen id : 3]
Input [8]: [internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336, systemId#732329]
(18) Filter [codegen id : 3]
Input [8]: [internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336, systemId#732329]
Condition : plant#732331.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,f80b06f7b2102a5f5c63b031eb5d8e03,25c0d9731dd07bb53999d9a8f04398e0)
(19) Project [codegen id : 3]
Output [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Input [8]: [internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336, systemId#732329]
(20) Exchange
Input [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=292065]
(21) ShuffleQueryStage
Output [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Arguments: 2
(22) BroadcastExchange
Input [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID), coalesce(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID)),false), [plan_id=292670]
(23) BroadcastQueryStage
Output [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Arguments: 21
(24) BroadcastHashJoin [codegen id : 12]
Left keys [4]: [coalesce(product#732282, ), isnull(product#732282), coalesce(plant#732277, ), isnull(plant#732277)]
Right keys [4]: [coalesce(product#732332.internalRefUUID, ), isnull(product#732332.internalRefUUID), coalesce(plant#732331.internalRefUUID, ), isnull(plant#732331.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(25) Project [codegen id : 12]
Output [29]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, CASE WHEN isnotnull(productionAspect#732334) THEN struct(systemId, systemId#732329, internalUUID, internalUUID#732330, plant, plant#732331, product, product#732332, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#732333, productionAspect, productionAspect#732334, salesPlant, salesPlant#732335, listing, listing#732336) END AS productPlant#732341, product#732332.id AS externalProductId#732342, plant#732331.id AS externalPlantId#732344]
Input [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
(26) Scan parquet
Output [12]: [internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357, systemId#732346]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-product-v2]
PushedFilters: [IsNotNull(internalUUID)]
ReadSchema: struct<internalUUID:string,id:string,displayId:string,name:array<struct<lang:string,content:string>>,baseUnitOfMeasure:struct<internalRefUUID:string,code:string>,unitOfMeasures:array<struct<measurementUnit:struct<internalRefUUID:string,code:string>,productDimensions:array<struct<dimensionName:struct<internalRefUUID:string,code:string>,dimensionValue:string,measurementUnit:struct<internalRefUUID:string,code:string>>>>>,unitOfMeasureConversions:array<struct<measurementUnit1:struct<internalRefUUID:string,code:string>,measurementUnit2:struct<internalRefUUID:string,code:string>,quantityNumerator:int,quantityDenominator:int>>,productionAspect:struct<minimumRemainingShelfLife:double>,salesAspect:struct<transportationGroup:struct<internalRefUUID:string,code:string>>,procurementAspect:struct<orderUnit:struct<internalRefUUID:string,code:string>>,productGroup:struct<internalRefUUID:string,id:string>>
(27) ColumnarToRow [codegen id : 4]
Input [12]: [internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357, systemId#732346]
(28) Filter [codegen id : 4]
Input [12]: [internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357, systemId#732346]
Condition : isnotnull(internalUUID#732347)
(29) Project [codegen id : 4]
Output [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Input [12]: [internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357, systemId#732346]
(30) Exchange
Input [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=292094]
(31) ShuffleQueryStage
Output [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Arguments: 3
(32) BroadcastExchange
Input [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=292674]
(33) BroadcastQueryStage
Output [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Arguments: 20
(34) BroadcastHashJoin
Left keys [1]: [product#732282]
Right keys [1]: [internalUUID#732347]
Join type: LeftOuter
Join condition: None
(35) Project
Output [30]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, CASE WHEN isnotnull(internalUUID#732347) THEN struct(systemId, systemId#732346, internalUUID, internalUUID#732347, id, id#732348, displayId, displayId#732349, name, name#732350, baseUnitOfMeasure, baseUnitOfMeasure#732351, unitOfMeasures, unitOfMeasures#732352, unitOfMeasureConversions, unitOfMeasureConversions#732353, productionAspect, productionAspect#732354, salesAspect, salesAspect#732355, procurementAspect, procurementAspect#732356, productGroup, productGroup#732357) END AS productInformation#732358]
Input [41]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
(36) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, transform(coalesce(transform(filter(productInformation#732358.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#732358.unitOfMeasures, lambdafunction(lambda x_1919#732370.measurementUnit.internalRefUUID, lambda x_1919#732370, false)), lambda x_1918#732367.measurementUnit1.internalRefUUID) AND (lambda x_1918#732367.measurementUnit2.internalRefUUID = productInformation#732358.baseUnitOfMeasure.internalRefUUID)), lambda x_1918#732367, false)), lambdafunction(struct(uom, lambda x_1920#732371.measurementUnit1.code, uomUuid, lambda x_1920#732371.measurementUnit1.internalRefUUID, numerator, lambda x_1920#732371.quantityNumerator, denominator, lambda x_1920#732371.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_1920#732371, false)), []), lambdafunction(named_struct(uom, lambda x_1921#732377.uom, uomUuid, lambda x_1921#732377.uomUuid, numerator, lambda x_1921#732377.numerator, denominator, lambda x_1921#732377.denominator, isOrderUnit, ((lambda x_1921#732377.uomUuid = coalesce(sos#732325.orderQuantityUnit.internalRefUUID, productInformation#732358.procurementAspect.orderUnit.internalRefUUID, productInformation#732358.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_1921#732377.isPreferred), lambda x_1921#732377, false)) AS logisticUnits#732376, productInformation#732358.baseUnitOfMeasure.code AS orderQuantityBaseUom#732372, productInformation#732358.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#732374, CASE WHEN isnull(supplyingPlant#732280) THEN 5 ELSE 1 END AS preferredUomSourceCode#732381]
Input [30]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358]
(37) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, CASE WHEN (preferredUomSourceCode#732381 = 2) THEN productPlant#732341.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#732381 = 3) THEN sos#732325.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#732381 = 4) THEN coalesce(productPlant#732341.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile, sos#732325.logisticalRoundingProfile.logisticalRoundingProfile) WHEN (preferredUomSourceCode#732381 = 5) THEN coalesce(sos#732325.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#732341.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) END AS preferredRoundingProfile#732382]
Input [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredUomSourceCode#732381]
(38) Project
Output [36]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382, cast(null as string) AS logisticalRoundingProfile#732389, cast(null as string) AS _extract_internalRefUUID#732656]
Input [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382]
(39) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382]
Input [36]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382, logisticalRoundingProfile#732389, _extract_internalRefUUID#732656]
(40) Project
Output [35]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382, cast(null as string) AS logisticalRoundingProfile#732416]
Input [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382]
(41) Project
Output [33]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, transform(transform(logisticUnits#732376, lambdafunction(named_struct(uom, lambda x_1922#732424.uom, uomUuid, lambda x_1922#732424.uomUuid, numerator, lambda x_1922#732424.numerator, denominator, lambda x_1922#732424.denominator, isOrderUnit, lambda x_1922#732424.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_1922#732424.uomUuid) THEN true ELSE lambda x_1922#732424.isPreferred END), lambda x_1922#732424, false)), lambdafunction(named_struct(uom, lambda x_1924#732425.uom, uomUuid, lambda x_1924#732425.uomUuid, numerator, lambda x_1924#732425.numerator, denominator, lambda x_1924#732425.denominator, isOrderUnit, lambda x_1924#732425.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#732376, lambdafunction(named_struct(uom, lambda x_1922#732426.uom, uomUuid, lambda x_1922#732426.uomUuid, numerator, lambda x_1922#732426.numerator, denominator, lambda x_1922#732426.denominator, isOrderUnit, lambda x_1922#732426.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_1922#732426.uomUuid) THEN true ELSE lambda x_1922#732426.isPreferred END), lambda x_1922#732426, false)), lambdafunction(lambda x_1923#732427.isPreferred, lambda x_1923#732427, false)), true) THEN lambda x_1924#732425.isPreferred ELSE lambda x_1924#732425.isOrderUnit END), lambda x_1924#732425, false)) AS logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374]
Input [35]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382, logisticalRoundingProfile#732416]
(42) Project
Output [33]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, CASE WHEN isnotnull(supplyingPlant#732280) THEN productPlant#732341.productionAspect.productPlanningPlants.minimumLotSize ELSE ((sos#732325.minimumOrderQuantity * cast(filter(logisticUnits#732423, lambdafunction(lambda x#732431.isOrderUnit, lambda x#732431, false))[0].numerator as double)) / cast(filter(logisticUnits#732423, lambdafunction(lambda x#732432.isOrderUnit, lambda x#732432, false))[0].denominator as double)) END AS minimumOrderQuantity#732428]
Input [33]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374]
(43) Scan parquet
Output [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000002108/0_1_10000002108/constraintprofile]
ReadSchema: struct<product:string,plant:string,orderDateTime:timestamp,constraintprofile:string>
(44) ColumnarToRow [codegen id : 5]
Input [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
(45) Exchange
Input [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=292139]
(46) ShuffleQueryStage
Output [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
Arguments: 6
(47) BroadcastExchange
Input [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, timestamp, true], 1970-01-01 00:00:00), isnull(input[2, timestamp, true])),false), [plan_id=292685]
(48) BroadcastQueryStage
Output [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
Arguments: 16
(49) BroadcastHashJoin
Left keys [6]: [coalesce(product#732282, ), isnull(product#732282), coalesce(plant#732277, ), isnull(plant#732277), coalesce(orderDateTime#732283, 1970-01-01 00:00:00), isnull(orderDateTime#732283)]
Right keys [6]: [coalesce(product#732433, ), isnull(product#732433), coalesce(plant#732434, ), isnull(plant#732434), coalesce(orderDateTime#732435, 1970-01-01 00:00:00), isnull(orderDateTime#732435)]
Join type: LeftOuter
Join condition: None
(50) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732428, constraintProfile#732436]
Input [37]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732428, product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
(51) Scan parquet
Output [5]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, maxRangeCoverage#732442, minOrderQuantity#732443]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/constraint-profile]
ReadSchema: struct<constraintProfile:string,minServiceLevel:struct<level:double,rank:int,isActive:boolean>,maxServiceLevelEndListing:struct<level:double,rank:int,isActive:boolean>,maxRangeCoverage:struct<range:int,rank:int,isActive:boolean>,minOrderQuantity:struct<rank:int,isActive:boolean>>
(52) ColumnarToRow [codegen id : 6]
Input [5]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, maxRangeCoverage#732442, minOrderQuantity#732443]
(53) Project [codegen id : 6]
Output [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, maxRangeCoverage#732442.isActive AS _extract_isActive#732679, maxRangeCoverage#732442.range AS _extract_range#732680, maxRangeCoverage#732442.rank AS _extract_rank#732681, minOrderQuantity#732443]
Input [5]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, maxRangeCoverage#732442, minOrderQuantity#732443]
(54) Exchange
Input [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=292160]
(55) ShuffleQueryStage
Output [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
Arguments: 7
(56) BroadcastExchange
Input [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=292689]
(57) BroadcastQueryStage
Output [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
Arguments: 19
(58) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#732436, ), isnull(constraintProfile#732436)]
Right keys [2]: [coalesce(constraintProfile#732437, ), isnull(constraintProfile#732437)]
Join type: LeftOuter
Join condition: None
(59) Project
Output [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, array(CASE WHEN (minServiceLevel#732439.isActive <=> true) THEN minServiceLevel#732439.level END, CASE WHEN (_extract_isActive#732679 <=> true) THEN cast(_extract_range#732680 as double) END, coalesce(minimumOrderQuantity#732428, 0.0), CASE WHEN (maxServiceLevelEndListing#732441.isActive <=> true) THEN maxServiceLevelEndListing#732441.level END, null) AS constraintValues#732452, array(CASE WHEN (minServiceLevel#732439.isActive <=> true) THEN minServiceLevel#732439.rank ELSE 0 END, CASE WHEN (_extract_isActive#732679 <=> true) THEN _extract_rank#732681 ELSE 0 END, CASE WHEN (minOrderQuantity#732443.isActive <=> true) THEN minOrderQuantity#732443.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#732441.isActive <=> true) THEN maxServiceLevelEndListing#732441.rank ELSE 0 END, 0) AS constraintRanks#732453, array((minServiceLevel#732439.isActive <=> true), (_extract_isActive#732679 <=> true), (minOrderQuantity#732443.isActive <=> true), (maxServiceLevelEndListing#732441.isActive <=> true), false) AS constraintIsActive#732454]
Input [41]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732428, constraintProfile#732436, constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
(60) Project
Output [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_1932#732491.label = minServiceLevel), lambda x_1932#732491, false))[0]) THEN element_at(constraintValues#732452, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_1932#732492.label = minServiceLevel), lambda x_1932#732492, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1932#732493.label = minServiceLevel), lambda x_1932#732493, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_1933#732494.label = maxRangeCoverage), lambda x_1933#732494, false))[0]) THEN element_at(constraintValues#732452, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_1933#732495.label = maxRangeCoverage), lambda x_1933#732495, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1933#732496.label = maxRangeCoverage), lambda x_1933#732496, false))[0].value END END, element_at(constraintValues#732452, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_1934#732497.label = maxServiceLevelEndListing), lambda x_1934#732497, false))[0]) THEN element_at(constraintValues#732452, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_1934#732498.label = maxServiceLevelEndListing), lambda x_1934#732498, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1934#732499.label = maxServiceLevelEndListing), lambda x_1934#732499, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_1935#732500.label = lockedOrderQuantity), lambda x_1935#732500, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1935#732501.label = lockedOrderQuantity), lambda x_1935#732501, false))[0].value END) AS constraintValues#732490, constraintRanks#732453, array(coalesce(filter(null, lambdafunction((lambda x_1927#732485.label = minServiceLevel), lambda x_1927#732485, false))[0].isActive, element_at(constraintIsActive#732454, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_1928#732486.label = maxRangeCoverage), lambda x_1928#732486, false))[0].isActive, element_at(constraintIsActive#732454, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_1929#732487.label = minOrderQuantity), lambda x_1929#732487, false))[0].isActive, element_at(constraintIsActive#732454, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_1930#732488.label = maxServiceLevelEndListing), lambda x_1930#732488, false))[0].isActive, element_at(constraintIsActive#732454, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_1931#732489.label = lockedOrderQuantity), lambda x_1931#732489, false))[0].isActive, false)) AS constraintIsActive#732484]
Input [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, constraintValues#732452, constraintRanks#732453, constraintIsActive#732454]
(61) Project
Output [42]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, productInformation#732358.unitOfMeasures AS _extract_unitOfMeasures#732677, productInformation#732358.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, CASE WHEN element_at(constraintIsActive#732484, 3, None, false) THEN element_at(constraintValues#732490, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, sos#732325.purchasingPriceAspect.netPrice.amount AS netPriceAmount#732503, sos#732325.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#732505, sos#732325.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#732507, sos#732325.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#732509, sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#732511, struct(value, CASE WHEN (sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#732374) THEN (sos#732325.purchasingPriceAspect.netPrice.amount / sos#732325.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#732325.purchasingPriceAspect.netPrice.amount / sos#732325.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#732423, lambdafunction((lambda x_1936#732525.uomUuid = sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_1936#732525, false))[0].denominator as double)) / cast(filter(logisticUnits#732423, lambdafunction((lambda x_1936#732526.uomUuid = sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_1936#732526, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#732325.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#732524]
Input [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484]
(62) Scan parquet
Output [3]: [internalUUID#732514, isoCode#732518, systemId#732513]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-unitofmeasurecodes-v2]
ReadSchema: struct<internalUUID:string,isoCode:struct<code:string>>
(63) ColumnarToRow [codegen id : 7]
Input [3]: [internalUUID#732514, isoCode#732518, systemId#732513]
(64) Project [codegen id : 7]
Output [2]: [internalUUID#732514, isoCode#732518.code AS _extract_code#732655]
Input [3]: [internalUUID#732514, isoCode#732518, systemId#732513]
(65) Exchange
Input [2]: [internalUUID#732514, _extract_code#732655]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=292185]
(66) ShuffleQueryStage
Output [2]: [internalUUID#732514, _extract_code#732655]
Arguments: 8
(67) BroadcastExchange
Input [2]: [internalUUID#732514, _extract_code#732655]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=292695]
(68) BroadcastQueryStage
Output [2]: [internalUUID#732514, _extract_code#732655]
Arguments: 14
(69) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732528.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732528, false))[0].productDimensions, lambdafunction((lambda x_1938#732530.dimensionName.code = VOLUME), lambda x_1938#732530, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732528.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732528, false))[0].productDimensions, lambdafunction((lambda x_1938#732530.dimensionName.code = VOLUME), lambda x_1938#732530, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#732514, ), isnull(internalUUID#732514)]
Join type: LeftOuter
Join condition: None
(70) Project
Output [43]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, _extract_unitOfMeasures#732677, _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, CURRENCY#732524, struct(value, cast(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732540.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732540, false))[0].productDimensions, lambdafunction((lambda x_1938#732546.dimensionName.code = VOLUME), lambda x_1938#732546, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732541.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732541, false))[0].productDimensions, lambdafunction((lambda x_1938#732547.dimensionName.code = VOLUME), lambda x_1938#732547, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732542.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732542, false))[0].productDimensions, lambdafunction((lambda x_1938#732548.dimensionName.code = VOLUME), lambda x_1938#732548, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#732655) AS VOLUME#732536]
Input [44]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, _extract_unitOfMeasures#732677, _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, CURRENCY#732524, internalUUID#732514, _extract_code#732655]
(71) ReusedExchange [Reuses operator id: 67]
Output [2]: [internalUUID#732550, _extract_code#732654]
(72) BroadcastQueryStage
Output [2]: [internalUUID#732550, _extract_code#732654]
Arguments: 15
(73) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732556.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732556, false))[0].productDimensions, lambdafunction((lambda x_1940#732558.dimensionName.code = GROSS_WT), lambda x_1940#732558, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732556.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732556, false))[0].productDimensions, lambdafunction((lambda x_1940#732558.dimensionName.code = GROSS_WT), lambda x_1940#732558, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#732550, ), isnull(internalUUID#732550)]
Join type: LeftOuter
Join condition: None
(74) Project
Output [40]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, filter(array(CURRENCY#732524, VOLUME#732536, struct(value, cast(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732568.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732568, false))[0].productDimensions, lambdafunction((lambda x_1940#732574.dimensionName.code = GROSS_WT), lambda x_1940#732574, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732569.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732569, false))[0].productDimensions, lambdafunction((lambda x_1940#732575.dimensionName.code = GROSS_WT), lambda x_1940#732575, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732570.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732570, false))[0].productDimensions, lambdafunction((lambda x_1940#732576.dimensionName.code = GROSS_WT), lambda x_1940#732576, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#732654)), lambdafunction(isnotnull(lambda x_1941#732578.value), lambda x_1941#732578, false)) AS measurements#732577]
Input [45]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, _extract_unitOfMeasures#732677, _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, CURRENCY#732524, VOLUME#732536, internalUUID#732550, _extract_code#732654]
(75) Scan parquet
Output [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000002108/SupplyNetworkProfiles/assignments]
ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,supplierGroup:string,optimizationGroups:array<string>>
(76) ColumnarToRow [codegen id : 9]
Input [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
(77) Exchange
Input [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=292229]
(78) ShuffleQueryStage
Output [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
Arguments: 11
(79) BroadcastExchange
Input [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[4, string, true], ), isnull(input[4, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=292703]
(80) BroadcastQueryStage
Output [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
Arguments: 18
(81) BroadcastHashJoin [codegen id : 13]
Left keys [10]: [coalesce(supplierGroup#732275, ), isnull(supplierGroup#732275), coalesce(supplier#732276, ), isnull(supplier#732276), coalesce(subrange#732279, ), isnull(subrange#732279), coalesce(plant#732277, ), isnull(plant#732277), coalesce(deliveryDateTime#732278, 1970-01-01 00:00:00), isnull(deliveryDateTime#732278)]
Right keys [10]: [coalesce(supplierGroup#732585, ), isnull(supplierGroup#732585), coalesce(supplier#732580, ), isnull(supplier#732580), coalesce(subrange#732581, ), isnull(subrange#732581), coalesce(plant#732582, ), isnull(plant#732582), coalesce(deliveryDateTime#732583, 1970-01-01 00:00:00), isnull(deliveryDateTime#732583)]
Join type: LeftOuter
Join condition: (isnull(supplyingPlant#732280) AND isnull(productGroup#732281))
(82) Project [codegen id : 13]
Output [44]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#732450, [GE,LE,GE,LE,EQ] AS constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, null AS originalReplenishmentRunId#732579L, coalesce(optimizationGroups#732587, []) AS optimizationGroups#732591]
Input [46]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
(83) ResultQueryStage
Output [44]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintLabels#732450, constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, originalReplenishmentRunId#732579L, optimizationGroups#732591]
Arguments: 22
(84) Exchange
Input [25]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299]
Arguments: hashpartitioning(product#732282, plant#732277, 25), REPARTITION_BY_NUM, [plan_id=291706]
(85) Project
Output [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Input [24]: [internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324, systemId#732301]
(86) Exchange
Input [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291709]
(87) BroadcastExchange
Input [24]: [systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=291762]
(88) BroadcastHashJoin
Left keys [2]: [coalesce(sourceOfSupplyUuid#732287, ), isnull(sourceOfSupplyUuid#732287)]
Right keys [2]: [coalesce(internalUUID#732302, ), isnull(internalUUID#732302)]
Join type: LeftOuter
Join condition: None
(89) Project
Output [26]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, struct(systemId, systemId#732301, internalUUID, internalUUID#732302, supplier, supplier#732303, receiver, receiver#732304, product, product#732305, receivingPlant, receivingPlant#732306, sourceOfSupplyType, sourceOfSupplyType#732307, purchasingGroup, purchasingGroup#732308, purchasingOrganization, purchasingOrganization#732309, productGroup, productGroup#732310, validFrom, validFrom#732311, validTo, validTo#732312, priority, ... 23 more fields) AS sos#732325]
Input [49]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, systemId#732301, internalUUID#732302, supplier#732303, receiver#732304, product#732305, receivingPlant#732306, sourceOfSupplyType#732307, purchasingGroup#732308, purchasingOrganization#732309, productGroup#732310, validFrom#732311, validTo#732312, priority#732313, isPurchasingBlocked#732314, isConsignment#732315, isDeleted#732316, supplierSubrange#732317, plannedDeliveryTimeDays#732318, orderQuantityUnit#732319, purchasingPriceAspect#732320, orderCurrency#732321, minimumOrderQuantity#732322, logisticalRoundingProfile#732323, supplyingPlant#732324]
(90) Filter
Input [8]: [internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336, systemId#732329]
Condition : plant#732331.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,f80b06f7b2102a5f5c63b031eb5d8e03,25c0d9731dd07bb53999d9a8f04398e0)
(91) Project
Output [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Input [8]: [internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336, systemId#732329]
(92) Exchange
Input [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291715]
(93) BroadcastExchange
Input [8]: [systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID), coalesce(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID)),false), [plan_id=291766]
(94) BroadcastHashJoin
Left keys [4]: [coalesce(product#732282, ), isnull(product#732282), coalesce(plant#732277, ), isnull(plant#732277)]
Right keys [4]: [coalesce(product#732332.internalRefUUID, ), isnull(product#732332.internalRefUUID), coalesce(plant#732331.internalRefUUID, ), isnull(plant#732331.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(95) Project
Output [29]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, CASE WHEN isnotnull(productionAspect#732334) THEN struct(systemId, systemId#732329, internalUUID, internalUUID#732330, plant, plant#732331, product, product#732332, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#732333, productionAspect, productionAspect#732334, salesPlant, salesPlant#732335, listing, listing#732336) END AS productPlant#732341, product#732332.id AS externalProductId#732342, plant#732331.id AS externalPlantId#732344]
Input [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, systemId#732329, internalUUID#732330, plant#732331, product#732332, blockedForReplenishmentStartingFrom#732333, productionAspect#732334, salesPlant#732335, listing#732336]
(96) Filter
Input [12]: [internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357, systemId#732346]
Condition : isnotnull(internalUUID#732347)
(97) Project
Output [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Input [12]: [internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357, systemId#732346]
(98) Exchange
Input [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291721]
(99) BroadcastExchange
Input [12]: [systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=291770]
(100) BroadcastHashJoin
Left keys [1]: [product#732282]
Right keys [1]: [internalUUID#732347]
Join type: LeftOuter
Join condition: None
(101) Project
Output [30]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, CASE WHEN isnotnull(internalUUID#732347) THEN struct(systemId, systemId#732346, internalUUID, internalUUID#732347, id, id#732348, displayId, displayId#732349, name, name#732350, baseUnitOfMeasure, baseUnitOfMeasure#732351, unitOfMeasures, unitOfMeasures#732352, unitOfMeasureConversions, unitOfMeasureConversions#732353, productionAspect, productionAspect#732354, salesAspect, salesAspect#732355, procurementAspect, procurementAspect#732356, productGroup, productGroup#732357) END AS productInformation#732358]
Input [41]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, systemId#732346, internalUUID#732347, id#732348, displayId#732349, name#732350, baseUnitOfMeasure#732351, unitOfMeasures#732352, unitOfMeasureConversions#732353, productionAspect#732354, salesAspect#732355, procurementAspect#732356, productGroup#732357]
(102) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, transform(coalesce(transform(filter(productInformation#732358.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#732358.unitOfMeasures, lambdafunction(lambda x_1919#732370.measurementUnit.internalRefUUID, lambda x_1919#732370, false)), lambda x_1918#732367.measurementUnit1.internalRefUUID) AND (lambda x_1918#732367.measurementUnit2.internalRefUUID = productInformation#732358.baseUnitOfMeasure.internalRefUUID)), lambda x_1918#732367, false)), lambdafunction(struct(uom, lambda x_1920#732371.measurementUnit1.code, uomUuid, lambda x_1920#732371.measurementUnit1.internalRefUUID, numerator, lambda x_1920#732371.quantityNumerator, denominator, lambda x_1920#732371.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_1920#732371, false)), []), lambdafunction(named_struct(uom, lambda x_1921#732377.uom, uomUuid, lambda x_1921#732377.uomUuid, numerator, lambda x_1921#732377.numerator, denominator, lambda x_1921#732377.denominator, isOrderUnit, ((lambda x_1921#732377.uomUuid = coalesce(sos#732325.orderQuantityUnit.internalRefUUID, productInformation#732358.procurementAspect.orderUnit.internalRefUUID, productInformation#732358.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_1921#732377.isPreferred), lambda x_1921#732377, false)) AS logisticUnits#732376, productInformation#732358.baseUnitOfMeasure.code AS orderQuantityBaseUom#732372, productInformation#732358.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#732374, CASE WHEN isnull(supplyingPlant#732280) THEN 5 ELSE 1 END AS preferredUomSourceCode#732381]
Input [30]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358]
(103) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, CASE WHEN (preferredUomSourceCode#732381 = 2) THEN productPlant#732341.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#732381 = 3) THEN sos#732325.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#732381 = 4) THEN coalesce(productPlant#732341.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile, sos#732325.logisticalRoundingProfile.logisticalRoundingProfile) WHEN (preferredUomSourceCode#732381 = 5) THEN coalesce(sos#732325.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#732341.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) END AS preferredRoundingProfile#732382]
Input [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredUomSourceCode#732381]
(104) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#732389, plant#732390]
Arguments: [logisticalRoundingProfile#732389, plant#732390]
(105) InMemoryRelation
Arguments: [logisticalRoundingProfile#732389, plant#732390, logisticalRoundingRule#732391], StorageLevel(disk, memory, 2 replicas)
(106) LocalTableScan
Output [3]: [logisticalRoundingProfile#732389, plant#732390, logisticalRoundingRule#732391]
Arguments: <empty>, [logisticalRoundingProfile#732389, plant#732390, logisticalRoundingRule#732391]
(107) Project
Output [2]: [logisticalRoundingProfile#732389, plant#732390.internalRefUUID AS _extract_internalRefUUID#732656]
Input [2]: [logisticalRoundingProfile#732389, plant#732390]
(108) BroadcastExchange
Input [2]: [logisticalRoundingProfile#732389, _extract_internalRefUUID#732656]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false]), coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=291776]
(109) BroadcastHashJoin
Left keys [4]: [coalesce(preferredRoundingProfile#732382, ), isnull(preferredRoundingProfile#732382), coalesce(plant#732277, ), isnull(plant#732277)]
Right keys [4]: [coalesce(logisticalRoundingProfile#732389, ), isnull(logisticalRoundingProfile#732389), coalesce(_extract_internalRefUUID#732656, ), isnull(_extract_internalRefUUID#732656)]
Join type: LeftOuter
Join condition: None
(110) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382]
Input [36]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382, logisticalRoundingProfile#732389, _extract_internalRefUUID#732656]
(111) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#732416, plant#732417]
Arguments: [logisticalRoundingProfile#732416, plant#732417], [isnull(plant#732417.internalRefUUID)]
(112) InMemoryRelation
Arguments: [logisticalRoundingProfile#732416, plant#732417, logisticalRoundingRule#732418], StorageLevel(disk, memory, 2 replicas)
(113) Filter
Input [2]: [logisticalRoundingProfile#732416, plant#732417]
Condition : isnull(plant#732417.internalRefUUID)
(114) Project
Output [1]: [logisticalRoundingProfile#732416]
Input [2]: [logisticalRoundingProfile#732416, plant#732417]
(115) BroadcastExchange
Input [1]: [logisticalRoundingProfile#732416]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=291780]
(116) BroadcastHashJoin
Left keys [2]: [coalesce(preferredRoundingProfile#732382, ), isnull(preferredRoundingProfile#732382)]
Right keys [2]: [coalesce(logisticalRoundingProfile#732416, ), isnull(logisticalRoundingProfile#732416)]
Join type: LeftOuter
Join condition: None
(117) Project
Output [33]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, transform(transform(logisticUnits#732376, lambdafunction(named_struct(uom, lambda x_1922#732424.uom, uomUuid, lambda x_1922#732424.uomUuid, numerator, lambda x_1922#732424.numerator, denominator, lambda x_1922#732424.denominator, isOrderUnit, lambda x_1922#732424.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_1922#732424.uomUuid) THEN true ELSE lambda x_1922#732424.isPreferred END), lambda x_1922#732424, false)), lambdafunction(named_struct(uom, lambda x_1924#732425.uom, uomUuid, lambda x_1924#732425.uomUuid, numerator, lambda x_1924#732425.numerator, denominator, lambda x_1924#732425.denominator, isOrderUnit, lambda x_1924#732425.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#732376, lambdafunction(named_struct(uom, lambda x_1922#732426.uom, uomUuid, lambda x_1922#732426.uomUuid, numerator, lambda x_1922#732426.numerator, denominator, lambda x_1922#732426.denominator, isOrderUnit, lambda x_1922#732426.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_1922#732426.uomUuid) THEN true ELSE lambda x_1922#732426.isPreferred END), lambda x_1922#732426, false)), lambdafunction(lambda x_1923#732427.isPreferred, lambda x_1923#732427, false)), true) THEN lambda x_1924#732425.isPreferred ELSE lambda x_1924#732425.isOrderUnit END), lambda x_1924#732425, false)) AS logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374]
Input [35]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732376, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, preferredRoundingProfile#732382, logisticalRoundingProfile#732416]
(118) Project
Output [33]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, CASE WHEN isnotnull(supplyingPlant#732280) THEN productPlant#732341.productionAspect.productPlanningPlants.minimumLotSize ELSE ((sos#732325.minimumOrderQuantity * cast(filter(logisticUnits#732423, lambdafunction(lambda x#732431.isOrderUnit, lambda x#732431, false))[0].numerator as double)) / cast(filter(logisticUnits#732423, lambdafunction(lambda x#732432.isOrderUnit, lambda x#732432, false))[0].denominator as double)) END AS minimumOrderQuantity#732428]
Input [33]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, productPlant#732341, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374]
(119) Exchange
Input [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291737]
(120) BroadcastExchange
Input [4]: [product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, timestamp, true], 1970-01-01 00:00:00), isnull(input[2, timestamp, true])),false), [plan_id=291785]
(121) BroadcastHashJoin
Left keys [6]: [coalesce(product#732282, ), isnull(product#732282), coalesce(plant#732277, ), isnull(plant#732277), coalesce(orderDateTime#732283, 1970-01-01 00:00:00), isnull(orderDateTime#732283)]
Right keys [6]: [coalesce(product#732433, ), isnull(product#732433), coalesce(plant#732434, ), isnull(plant#732434), coalesce(orderDateTime#732435, 1970-01-01 00:00:00), isnull(orderDateTime#732435)]
Join type: LeftOuter
Join condition: None
(122) Project
Output [34]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732428, constraintProfile#732436]
Input [37]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732428, product#732433, plant#732434, orderDateTime#732435, constraintprofile#732436]
(123) Project
Output [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, maxRangeCoverage#732442.isActive AS _extract_isActive#732679, maxRangeCoverage#732442.range AS _extract_range#732680, maxRangeCoverage#732442.rank AS _extract_rank#732681, minOrderQuantity#732443]
Input [5]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, maxRangeCoverage#732442, minOrderQuantity#732443]
(124) Exchange
Input [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291742]
(125) BroadcastExchange
Input [7]: [constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=291789]
(126) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#732436, ), isnull(constraintProfile#732436)]
Right keys [2]: [coalesce(constraintProfile#732437, ), isnull(constraintProfile#732437)]
Join type: LeftOuter
Join condition: None
(127) Project
Output [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, array(CASE WHEN (minServiceLevel#732439.isActive <=> true) THEN minServiceLevel#732439.level END, CASE WHEN (_extract_isActive#732679 <=> true) THEN cast(_extract_range#732680 as double) END, coalesce(minimumOrderQuantity#732428, 0.0), CASE WHEN (maxServiceLevelEndListing#732441.isActive <=> true) THEN maxServiceLevelEndListing#732441.level END, null) AS constraintValues#732452, array(CASE WHEN (minServiceLevel#732439.isActive <=> true) THEN minServiceLevel#732439.rank ELSE 0 END, CASE WHEN (_extract_isActive#732679 <=> true) THEN _extract_rank#732681 ELSE 0 END, CASE WHEN (minOrderQuantity#732443.isActive <=> true) THEN minOrderQuantity#732443.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#732441.isActive <=> true) THEN maxServiceLevelEndListing#732441.rank ELSE 0 END, 0) AS constraintRanks#732453, array((minServiceLevel#732439.isActive <=> true), (_extract_isActive#732679 <=> true), (minOrderQuantity#732443.isActive <=> true), (maxServiceLevelEndListing#732441.isActive <=> true), false) AS constraintIsActive#732454]
Input [41]: [supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalId#732291L, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, orderProposalItemId#732299, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732428, constraintProfile#732436, constraintProfile#732437, minServiceLevel#732439, maxServiceLevelEndListing#732441, _extract_isActive#732679, _extract_range#732680, _extract_rank#732681, minOrderQuantity#732443]
(128) Project
Output [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_1932#732491.label = minServiceLevel), lambda x_1932#732491, false))[0]) THEN element_at(constraintValues#732452, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_1932#732492.label = minServiceLevel), lambda x_1932#732492, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1932#732493.label = minServiceLevel), lambda x_1932#732493, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_1933#732494.label = maxRangeCoverage), lambda x_1933#732494, false))[0]) THEN element_at(constraintValues#732452, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_1933#732495.label = maxRangeCoverage), lambda x_1933#732495, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1933#732496.label = maxRangeCoverage), lambda x_1933#732496, false))[0].value END END, element_at(constraintValues#732452, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_1934#732497.label = maxServiceLevelEndListing), lambda x_1934#732497, false))[0]) THEN element_at(constraintValues#732452, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_1934#732498.label = maxServiceLevelEndListing), lambda x_1934#732498, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1934#732499.label = maxServiceLevelEndListing), lambda x_1934#732499, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_1935#732500.label = lockedOrderQuantity), lambda x_1935#732500, false))[0].isActive THEN filter(null, lambdafunction((lambda x_1935#732501.label = lockedOrderQuantity), lambda x_1935#732501, false))[0].value END) AS constraintValues#732490, constraintRanks#732453, array(coalesce(filter(null, lambdafunction((lambda x_1927#732485.label = minServiceLevel), lambda x_1927#732485, false))[0].isActive, element_at(constraintIsActive#732454, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_1928#732486.label = maxRangeCoverage), lambda x_1928#732486, false))[0].isActive, element_at(constraintIsActive#732454, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_1929#732487.label = minOrderQuantity), lambda x_1929#732487, false))[0].isActive, element_at(constraintIsActive#732454, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_1930#732488.label = maxServiceLevelEndListing), lambda x_1930#732488, false))[0].isActive, element_at(constraintIsActive#732454, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_1931#732489.label = lockedOrderQuantity), lambda x_1931#732489, false))[0].isActive, false)) AS constraintIsActive#732484]
Input [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, constraintValues#732452, constraintRanks#732453, constraintIsActive#732454]
(129) Project
Output [42]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, productInformation#732358.unitOfMeasures AS _extract_unitOfMeasures#732677, productInformation#732358.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, CASE WHEN element_at(constraintIsActive#732484, 3, None, false) THEN element_at(constraintValues#732490, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, sos#732325.purchasingPriceAspect.netPrice.amount AS netPriceAmount#732503, sos#732325.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#732505, sos#732325.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#732507, sos#732325.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#732509, sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#732511, struct(value, CASE WHEN (sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#732374) THEN (sos#732325.purchasingPriceAspect.netPrice.amount / sos#732325.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#732325.purchasingPriceAspect.netPrice.amount / sos#732325.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#732423, lambdafunction((lambda x_1936#732525.uomUuid = sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_1936#732525, false))[0].denominator as double)) / cast(filter(logisticUnits#732423, lambdafunction((lambda x_1936#732526.uomUuid = sos#732325.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_1936#732526, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#732325.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#732524]
Input [35]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, sos#732325, externalProductId#732342, externalPlantId#732344, productInformation#732358, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484]
(130) Project
Output [2]: [internalUUID#732514, isoCode#732518.code AS _extract_code#732655]
Input [3]: [internalUUID#732514, isoCode#732518, systemId#732513]
(131) Exchange
Input [2]: [internalUUID#732514, _extract_code#732655]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291749]
(132) BroadcastExchange
Input [2]: [internalUUID#732514, _extract_code#732655]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=291795]
(133) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732528.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732528, false))[0].productDimensions, lambdafunction((lambda x_1938#732530.dimensionName.code = VOLUME), lambda x_1938#732530, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732528.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732528, false))[0].productDimensions, lambdafunction((lambda x_1938#732530.dimensionName.code = VOLUME), lambda x_1938#732530, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#732514, ), isnull(internalUUID#732514)]
Join type: LeftOuter
Join condition: None
(134) Project
Output [43]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, _extract_unitOfMeasures#732677, _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, CURRENCY#732524, struct(value, cast(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732540.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732540, false))[0].productDimensions, lambdafunction((lambda x_1938#732546.dimensionName.code = VOLUME), lambda x_1938#732546, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732541.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732541, false))[0].productDimensions, lambdafunction((lambda x_1938#732547.dimensionName.code = VOLUME), lambda x_1938#732547, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1937#732542.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1937#732542, false))[0].productDimensions, lambdafunction((lambda x_1938#732548.dimensionName.code = VOLUME), lambda x_1938#732548, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#732655) AS VOLUME#732536]
Input [44]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, _extract_unitOfMeasures#732677, _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, CURRENCY#732524, internalUUID#732514, _extract_code#732655]
(135) Scan parquet
Output [3]: [internalUUID#732550, isoCode#732554, systemId#732549]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-unitofmeasurecodes-v2]
ReadSchema: struct<internalUUID:string,isoCode:struct<code:string>>
(136) Project
Output [2]: [internalUUID#732550, isoCode#732554.code AS _extract_code#732654]
Input [3]: [internalUUID#732550, isoCode#732554, systemId#732549]
(137) Exchange
Input [2]: [internalUUID#732550, _extract_code#732654]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291754]
(138) BroadcastExchange
Input [2]: [internalUUID#732550, _extract_code#732654]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=291799]
(139) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732556.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732556, false))[0].productDimensions, lambdafunction((lambda x_1940#732558.dimensionName.code = GROSS_WT), lambda x_1940#732558, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732556.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732556, false))[0].productDimensions, lambdafunction((lambda x_1940#732558.dimensionName.code = GROSS_WT), lambda x_1940#732558, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#732550, ), isnull(internalUUID#732550)]
Join type: LeftOuter
Join condition: None
(140) Project
Output [40]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, filter(array(CURRENCY#732524, VOLUME#732536, struct(value, cast(filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732568.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732568, false))[0].productDimensions, lambdafunction((lambda x_1940#732574.dimensionName.code = GROSS_WT), lambda x_1940#732574, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732569.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732569, false))[0].productDimensions, lambdafunction((lambda x_1940#732575.dimensionName.code = GROSS_WT), lambda x_1940#732575, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#732677, lambdafunction((lambda x_1939#732570.measurementUnit.internalRefUUID = _extract_internalRefUUID#732678), lambda x_1939#732570, false))[0].productDimensions, lambdafunction((lambda x_1940#732576.dimensionName.code = GROSS_WT), lambda x_1940#732576, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#732654)), lambdafunction(isnotnull(lambda x_1941#732578.value), lambda x_1941#732578, false)) AS measurements#732577]
Input [45]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, _extract_unitOfMeasures#732677, _extract_internalRefUUID#732678, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, CURRENCY#732524, VOLUME#732536, internalUUID#732550, _extract_code#732654]
(141) Exchange
Input [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=291758]
(142) BroadcastExchange
Input [6]: [supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[4, string, true], ), isnull(input[4, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=291803]
(143) BroadcastHashJoin
Left keys [10]: [coalesce(supplierGroup#732275, ), isnull(supplierGroup#732275), coalesce(supplier#732276, ), isnull(supplier#732276), coalesce(subrange#732279, ), isnull(subrange#732279), coalesce(plant#732277, ), isnull(plant#732277), coalesce(deliveryDateTime#732278, 1970-01-01 00:00:00), isnull(deliveryDateTime#732278)]
Right keys [10]: [coalesce(supplierGroup#732585, ), isnull(supplierGroup#732585), coalesce(supplier#732580, ), isnull(supplier#732580), coalesce(subrange#732581, ), isnull(subrange#732581), coalesce(plant#732582, ), isnull(plant#732582), coalesce(deliveryDateTime#732583, 1970-01-01 00:00:00), isnull(deliveryDateTime#732583)]
Join type: LeftOuter
Join condition: (isnull(supplyingPlant#732280) AND isnull(productGroup#732281))
(144) Project
Output [44]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#732450, [GE,LE,GE,LE,EQ] AS constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, null AS originalReplenishmentRunId#732579L, coalesce(optimizationGroups#732587, []) AS optimizationGroups#732591]
Input [46]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, supplier#732580, subrange#732581, plant#732582, deliverydatetime#732583, supplierGroup#732585, optimizationGroups#732587]
(145) AdaptiveSparkPlan
Output [44]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintLabels#732450, constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, originalReplenishmentRunId#732579L, optimizationGroups#732591]
Arguments: isFinalPlan=true
(146) TableCacheQueryStage
Output [44]: [availabilityDateTime#732284, clusterId#732295L, constraintIsActive#732484, constraintLabels#732450, constraintOperators#732451, constraintRanks#732453, constraintValues#732490, deliveryDateTime#732278, externalPlantId#732344, externalProductId#732342, isFallbackOrderOnly#732290, logisticUnits#732423, measurements#732577, minimumOrderQuantity#732502, mrpController#732286, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, nextAvailabilityDateTime#732285, optimizationGroups#732591, orderDateTime#732283, orderProposalHorizonGroupingId#732292L, orderProposalId#732291L, orderProposalItemGroupId#732298, orderProposalItemId#732299, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, originalReplenishmentRunId#732579L, plant#732277, previousOrderProposal#732294L, product#732282, productGroup#732281, purchasingGroup#732289, purchasingOrg#732288, sequenceId#732296, sourceOfSupplyUuid#732287, splitIndicator#732293L, subrange#732279, supplier#732276, supplierGroup#732275, supplyingPlant#732280, worklistShardItemId#732297L]
Arguments: 0
(147) Project [codegen id : 1]
Output [45]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintLabels#732450, constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, originalReplenishmentRunId#732579L, optimizationGroups#732591, 0_1_10000002108 AS shardId#736467]
Input [44]: [availabilityDateTime#732284, clusterId#732295L, constraintIsActive#732484, constraintLabels#732450, constraintOperators#732451, constraintRanks#732453, constraintValues#732490, deliveryDateTime#732278, externalPlantId#732344, externalProductId#732342, isFallbackOrderOnly#732290, logisticUnits#732423, measurements#732577, minimumOrderQuantity#732502, mrpController#732286, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, nextAvailabilityDateTime#732285, optimizationGroups#732591, orderDateTime#732283, orderProposalHorizonGroupingId#732292L, orderProposalId#732291L, orderProposalItemGroupId#732298, orderProposalItemId#732299, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, originalReplenishmentRunId#732579L, plant#732277, previousOrderProposal#732294L, product#732282, productGroup#732281, purchasingGroup#732289, purchasingOrg#732288, sequenceId#732296, sourceOfSupplyUuid#732287, splitIndicator#732293L, subrange#732279, supplier#732276, supplierGroup#732275, supplyingPlant#732280, worklistShardItemId#732297L]
(148) ResultQueryStage
Output [45]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintLabels#732450, constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, originalReplenishmentRunId#732579L, optimizationGroups#732591, shardId#736467]
Arguments: 2
(149) Project
Output [45]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintLabels#732450, constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, originalReplenishmentRunId#732579L, optimizationGroups#732591, 0_1_10000002108 AS shardId#736467]
Input [44]: [availabilityDateTime#732284, clusterId#732295L, constraintIsActive#732484, constraintLabels#732450, constraintOperators#732451, constraintRanks#732453, constraintValues#732490, deliveryDateTime#732278, externalPlantId#732344, externalProductId#732342, isFallbackOrderOnly#732290, logisticUnits#732423, measurements#732577, minimumOrderQuantity#732502, mrpController#732286, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, nextAvailabilityDateTime#732285, optimizationGroups#732591, orderDateTime#732283, orderProposalHorizonGroupingId#732292L, orderProposalId#732291L, orderProposalItemGroupId#732298, orderProposalItemId#732299, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, originalReplenishmentRunId#732579L, plant#732277, previousOrderProposal#732294L, product#732282, productGroup#732281, purchasingGroup#732289, purchasingOrg#732288, sequenceId#732296, sourceOfSupplyUuid#732287, splitIndicator#732293L, subrange#732279, supplier#732276, supplierGroup#732275, supplyingPlant#732280, worklistShardItemId#732297L]
(150) AdaptiveSparkPlan
Output [45]: [orderProposalId#732291L, orderProposalItemId#732299, supplierGroup#732275, supplier#732276, plant#732277, deliveryDateTime#732278, subrange#732279, supplyingPlant#732280, productGroup#732281, product#732282, orderDateTime#732283, availabilityDateTime#732284, nextAvailabilityDateTime#732285, mrpController#732286, sourceOfSupplyUuid#732287, purchasingOrg#732288, purchasingGroup#732289, isFallbackOrderOnly#732290, orderProposalHorizonGroupingId#732292L, splitIndicator#732293L, previousOrderProposal#732294L, clusterId#732295L, sequenceId#732296, worklistShardItemId#732297L, orderProposalItemGroupId#732298, externalProductId#732342, externalPlantId#732344, logisticUnits#732423, orderQuantityBaseUom#732372, orderQuantityBaseUomUuid#732374, minimumOrderQuantity#732502, constraintLabels#732450, constraintOperators#732451, constraintValues#732490, constraintRanks#732453, constraintIsActive#732484, netPriceAmount#732503, netPriceCurrencyCode#732505, netPriceQuantity#732507, netPriceQuantityUom#732509, netPriceQuantityUomUuid#732511, measurements#732577, originalReplenishmentRunId#732579L, optimizationGroups#732591, shardId#736467]
Arguments: isFinalPlan=false