== Physical Plan ==
AdaptiveSparkPlan (150)
+- == Current Plan ==
ResultQueryStage (148)
+- * Project (147)
+- TableCacheQueryStage (146), Statistics(sizeInBytes=235.3 KiB, rowCount=170)
+- 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=75.7 KiB, rowCount=170)
: : : : : : : : +- 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.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (22)
: : : : : : +- ShuffleQueryStage (21), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- 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.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (47)
: : : : +- ShuffleQueryStage (46), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- 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=40)
+- BroadcastExchange (79)
+- ShuffleQueryStage (78), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- 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=75.7 KiB, rowCount=170)
: : : : : : : : +- 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.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (22)
: : : : : : +- ShuffleQueryStage (21), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- 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.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (47)
: : : : +- ShuffleQueryStage (46), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- 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=40)
+- BroadcastExchange (79)
+- ShuffleQueryStage (78), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- 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#1000979, clusterId#1000990L, constraintIsActive#1001179, constraintLabels#1001145, constraintOperators#1001146, constraintRanks#1001148, constraintValues#1001185, deliveryDateTime#1000973, externalPlantId#1001039, externalProductId#1001037, isFallbackOrderOnly#1000985, logisticUnits#1001118, measurements#1001272, minimumOrderQuantity#1001197, mrpController#1000981, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, nextAvailabilityDateTime#1000980, optimizationGroups#1001286, orderDateTime#1000978, orderProposalHorizonGroupingId#1000987L, orderProposalId#1000986L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, originalReplenishmentRunId#1001274L, plant#1000972, previousOrderProposal#1000989L, product#1000977, productGroup#1000976, purchasingGroup#1000984, purchasingOrg#1000983, sequenceId#1000991, sourceOfSupplyUuid#1000982, splitIndicator#1000988L, subrange#1000974, supplier#1000971, supplierGroup#1000970, supplyingPlant#1000975, worklistShardItemId#1000992L]
Arguments: [availabilityDateTime#1000979, clusterId#1000990L, constraintIsActive#1001179, constraintLabels#1001145, constraintOperators#1001146, constraintRanks#1001148, constraintValues#1001185, deliveryDateTime#1000973, externalPlantId#1001039, externalProductId#1001037, isFallbackOrderOnly#1000985, logisticUnits#1001118, measurements#1001272, minimumOrderQuantity#1001197, mrpController#1000981, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, nextAvailabilityDateTime#1000980, optimizationGroups#1001286, orderDateTime#1000978, orderProposalHorizonGroupingId#1000987L, orderProposalId#1000986L, ... 19 more fields]
(2) InMemoryRelation
Arguments: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, ... 19 more fields], StorageLevel(disk, memory, 2 replicas)
(3) Scan parquet
Output [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
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/10000002111/shardId=0_1_10000002111]
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#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
(5) Exchange
Input [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
Arguments: hashpartitioning(product#1000977, plant#1000972, 25), REPARTITION_BY_NUM, [plan_id=390356]
(6) ShuffleQueryStage
Output [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
Arguments: 0
(7) Scan parquet
Output [24]: [internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
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#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
(9) Project [codegen id : 2]
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Input [24]: [internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
(10) Exchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390375]
(11) ShuffleQueryStage
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: 1
(12) BroadcastExchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=391003]
(13) BroadcastQueryStage
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: 20
(14) BroadcastHashJoin [codegen id : 12]
Left keys [2]: [coalesce(sourceOfSupplyUuid#1000982, ), isnull(sourceOfSupplyUuid#1000982)]
Right keys [2]: [coalesce(internalUUID#1000997, ), isnull(internalUUID#1000997)]
Join type: LeftOuter
Join condition: None
(15) Project [codegen id : 12]
Output [26]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, struct(systemId, systemId#1000996, internalUUID, internalUUID#1000997, supplier, supplier#1000998, receiver, receiver#1000999, product, product#1001000, receivingPlant, receivingPlant#1001001, sourceOfSupplyType, sourceOfSupplyType#1001002, purchasingGroup, purchasingGroup#1001003, purchasingOrganization, purchasingOrganization#1001004, productGroup, productGroup#1001005, validFrom, validFrom#1001006, validTo, validTo#1001007, priority, ... 23 more fields) AS sos#1001020]
Input [49]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
(16) Scan parquet
Output [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
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,45f9c5206af43e1e6acbe19d9a246289])]
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#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
(18) Filter [codegen id : 3]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
Condition : plant#1001026.internalRefUUID IN (25c0d9731dd07bb53999d9a8f04398e0,1c037502c75549dc72c6fc87c802bcec,45f9c5206af43e1e6acbe19d9a246289,24a9ebb440508219166784d4d1c19eef)
(19) Project [codegen id : 3]
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
(20) Exchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390402]
(21) ShuffleQueryStage
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: 2
(22) BroadcastExchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
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=391007]
(23) BroadcastQueryStage
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: 21
(24) BroadcastHashJoin [codegen id : 12]
Left keys [4]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972)]
Right keys [4]: [coalesce(product#1001027.internalRefUUID, ), isnull(product#1001027.internalRefUUID), coalesce(plant#1001026.internalRefUUID, ), isnull(plant#1001026.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(25) Project [codegen id : 12]
Output [29]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, CASE WHEN isnotnull(productionAspect#1001029) THEN struct(systemId, systemId#1001024, internalUUID, internalUUID#1001025, plant, plant#1001026, product, product#1001027, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1001028, productionAspect, productionAspect#1001029, salesPlant, salesPlant#1001030, listing, listing#1001031) END AS productPlant#1001036, product#1001027.id AS externalProductId#1001037, plant#1001026.id AS externalPlantId#1001039]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
(26) Scan parquet
Output [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
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#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
(28) Filter [codegen id : 4]
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
Condition : isnotnull(internalUUID#1001042)
(29) Project [codegen id : 4]
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
(30) Exchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390431]
(31) ShuffleQueryStage
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: 3
(32) BroadcastExchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=391011]
(33) BroadcastQueryStage
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: 16
(34) BroadcastHashJoin
Left keys [1]: [product#1000977]
Right keys [1]: [internalUUID#1001042]
Join type: LeftOuter
Join condition: None
(35) Project
Output [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, CASE WHEN isnotnull(internalUUID#1001042) THEN struct(systemId, systemId#1001041, internalUUID, internalUUID#1001042, id, id#1001043, displayId, displayId#1001044, name, name#1001045, baseUnitOfMeasure, baseUnitOfMeasure#1001046, unitOfMeasures, unitOfMeasures#1001047, unitOfMeasureConversions, unitOfMeasureConversions#1001048, productionAspect, productionAspect#1001049, salesAspect, salesAspect#1001050, procurementAspect, procurementAspect#1001051, productGroup, productGroup#1001052) END AS productInformation#1001053]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
(36) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(coalesce(transform(filter(productInformation#1001053.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#1001053.unitOfMeasures, lambdafunction(lambda x_2600#1001065.measurementUnit.internalRefUUID, lambda x_2600#1001065, false)), lambda x_2599#1001062.measurementUnit1.internalRefUUID) AND (lambda x_2599#1001062.measurementUnit2.internalRefUUID = productInformation#1001053.baseUnitOfMeasure.internalRefUUID)), lambda x_2599#1001062, false)), lambdafunction(struct(uom, lambda x_2601#1001066.measurementUnit1.code, uomUuid, lambda x_2601#1001066.measurementUnit1.internalRefUUID, numerator, lambda x_2601#1001066.quantityNumerator, denominator, lambda x_2601#1001066.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2601#1001066, false)), []), lambdafunction(named_struct(uom, lambda x_2602#1001072.uom, uomUuid, lambda x_2602#1001072.uomUuid, numerator, lambda x_2602#1001072.numerator, denominator, lambda x_2602#1001072.denominator, isOrderUnit, ((lambda x_2602#1001072.uomUuid = coalesce(sos#1001020.orderQuantityUnit.internalRefUUID, productInformation#1001053.procurementAspect.orderUnit.internalRefUUID, productInformation#1001053.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_2602#1001072.isPreferred), lambda x_2602#1001072, false)) AS logisticUnits#1001071, productInformation#1001053.baseUnitOfMeasure.code AS orderQuantityBaseUom#1001067, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#1001069, CASE WHEN isnull(supplyingPlant#1000975) THEN 4 ELSE 1 END AS preferredUomSourceCode#1001076]
Input [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053]
(37) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN (preferredUomSourceCode#1001076 = 2) THEN productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 3) THEN sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 4) THEN coalesce(productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile, sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile) WHEN (preferredUomSourceCode#1001076 = 5) THEN coalesce(sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) END AS preferredRoundingProfile#1001077]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredUomSourceCode#1001076]
(38) Project
Output [36]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, cast(null as string) AS logisticalRoundingProfile#1001084, cast(null as string) AS _extract_internalRefUUID#1001351]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
(39) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
Input [36]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001084, _extract_internalRefUUID#1001351]
(40) Project
Output [35]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, cast(null as string) AS logisticalRoundingProfile#1001111]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
(41) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001119.uom, uomUuid, lambda x_2603#1001119.uomUuid, numerator, lambda x_2603#1001119.numerator, denominator, lambda x_2603#1001119.denominator, isOrderUnit, lambda x_2603#1001119.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001119.uomUuid) THEN true ELSE lambda x_2603#1001119.isPreferred END), lambda x_2603#1001119, false)), lambdafunction(named_struct(uom, lambda x_2605#1001120.uom, uomUuid, lambda x_2605#1001120.uomUuid, numerator, lambda x_2605#1001120.numerator, denominator, lambda x_2605#1001120.denominator, isOrderUnit, lambda x_2605#1001120.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001121.uom, uomUuid, lambda x_2603#1001121.uomUuid, numerator, lambda x_2603#1001121.numerator, denominator, lambda x_2603#1001121.denominator, isOrderUnit, lambda x_2603#1001121.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001121.uomUuid) THEN true ELSE lambda x_2603#1001121.isPreferred END), lambda x_2603#1001121, false)), lambdafunction(lambda x_2604#1001122.isPreferred, lambda x_2604#1001122, false)), true) THEN lambda x_2605#1001120.isPreferred ELSE lambda x_2605#1001120.isOrderUnit END), lambda x_2605#1001120, false)) AS logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
Input [35]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001111]
(42) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN isnotnull(supplyingPlant#1000975) THEN productPlant#1001036.productionAspect.productPlanningPlants.minimumLotSize ELSE ((sos#1001020.minimumOrderQuantity * cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001126.isOrderUnit, lambda x#1001126, false))[0].numerator as double)) / cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001127.isOrderUnit, lambda x#1001127, false))[0].denominator as double)) END AS minimumOrderQuantity#1001123]
Input [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
(43) Scan parquet
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000002111/0_1_10000002111/constraintprofile]
ReadSchema: struct<product:string,plant:string,orderDateTime:timestamp,constraintprofile:string>
(44) ColumnarToRow [codegen id : 5]
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
(45) Exchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390476]
(46) ShuffleQueryStage
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: 6
(47) BroadcastExchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
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=391022]
(48) BroadcastQueryStage
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: 14
(49) BroadcastHashJoin
Left keys [6]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(orderDateTime#1000978, 1970-01-01 00:00:00), isnull(orderDateTime#1000978)]
Right keys [6]: [coalesce(product#1001128, ), isnull(product#1001128), coalesce(plant#1001129, ), isnull(plant#1001129), coalesce(orderDateTime#1001130, 1970-01-01 00:00:00), isnull(orderDateTime#1001130)]
Join type: LeftOuter
Join condition: None
(50) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131]
Input [37]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
(51) Scan parquet
Output [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
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#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
(53) Project [codegen id : 6]
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137.isActive AS _extract_isActive#1001374, maxRangeCoverage#1001137.range AS _extract_range#1001375, maxRangeCoverage#1001137.rank AS _extract_rank#1001376, minOrderQuantity#1001138]
Input [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
(54) Exchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390497]
(55) ShuffleQueryStage
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: 7
(56) BroadcastExchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=391026]
(57) BroadcastQueryStage
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: 17
(58) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#1001131, ), isnull(constraintProfile#1001131)]
Right keys [2]: [coalesce(constraintProfile#1001132, ), isnull(constraintProfile#1001132)]
Join type: LeftOuter
Join condition: None
(59) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.level END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN cast(_extract_range#1001375 as double) END, coalesce(minimumOrderQuantity#1001123, 0.0), CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.level END, null) AS constraintValues#1001147, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.rank ELSE 0 END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN _extract_rank#1001376 ELSE 0 END, CASE WHEN (minOrderQuantity#1001138.isActive <=> true) THEN minOrderQuantity#1001138.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.rank ELSE 0 END, 0) AS constraintRanks#1001148, array((minServiceLevel#1001134.isActive <=> true), (_extract_isActive#1001374 <=> true), (minOrderQuantity#1001138.isActive <=> true), (maxServiceLevelEndListing#1001136.isActive <=> true), false) AS constraintIsActive#1001149]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131, constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
(60) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_2613#1001186.label = minServiceLevel), lambda x_2613#1001186, false))[0]) THEN element_at(constraintValues#1001147, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2613#1001187.label = minServiceLevel), lambda x_2613#1001187, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2613#1001188.label = minServiceLevel), lambda x_2613#1001188, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_2614#1001189.label = maxRangeCoverage), lambda x_2614#1001189, false))[0]) THEN element_at(constraintValues#1001147, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2614#1001190.label = maxRangeCoverage), lambda x_2614#1001190, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2614#1001191.label = maxRangeCoverage), lambda x_2614#1001191, false))[0].value END END, element_at(constraintValues#1001147, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_2615#1001192.label = maxServiceLevelEndListing), lambda x_2615#1001192, false))[0]) THEN element_at(constraintValues#1001147, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2615#1001193.label = maxServiceLevelEndListing), lambda x_2615#1001193, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2615#1001194.label = maxServiceLevelEndListing), lambda x_2615#1001194, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_2616#1001195.label = lockedOrderQuantity), lambda x_2616#1001195, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2616#1001196.label = lockedOrderQuantity), lambda x_2616#1001196, false))[0].value END) AS constraintValues#1001185, constraintRanks#1001148, array(coalesce(filter(null, lambdafunction((lambda x_2608#1001180.label = minServiceLevel), lambda x_2608#1001180, false))[0].isActive, element_at(constraintIsActive#1001149, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_2609#1001181.label = maxRangeCoverage), lambda x_2609#1001181, false))[0].isActive, element_at(constraintIsActive#1001149, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_2610#1001182.label = minOrderQuantity), lambda x_2610#1001182, false))[0].isActive, element_at(constraintIsActive#1001149, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_2611#1001183.label = maxServiceLevelEndListing), lambda x_2611#1001183, false))[0].isActive, element_at(constraintIsActive#1001149, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_2612#1001184.label = lockedOrderQuantity), lambda x_2612#1001184, false))[0].isActive, false)) AS constraintIsActive#1001179]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001147, constraintRanks#1001148, constraintIsActive#1001149]
(61) Project
Output [42]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053.unitOfMeasures AS _extract_unitOfMeasures#1001372, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN element_at(constraintIsActive#1001179, 3, None, false) THEN element_at(constraintValues#1001185, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, sos#1001020.purchasingPriceAspect.netPrice.amount AS netPriceAmount#1001198, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#1001200, sos#1001020.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#1001202, sos#1001020.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#1001204, sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#1001206, struct(value, CASE WHEN (sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#1001069) THEN (sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001220.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001220, false))[0].denominator as double)) / cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001221.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001221, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#1001219]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179]
(62) Scan parquet
Output [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
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#1001209, isoCode#1001213, systemId#1001208]
(64) Project [codegen id : 7]
Output [2]: [internalUUID#1001209, isoCode#1001213.code AS _extract_code#1001350]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(65) Exchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390522]
(66) ShuffleQueryStage
Output [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: 8
(67) BroadcastExchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=391032]
(68) BroadcastQueryStage
Output [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: 18
(69) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001209, ), isnull(internalUUID#1001209)]
Join type: LeftOuter
Join condition: None
(70) Project
Output [43]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001235.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001235, false))[0].productDimensions, lambdafunction((lambda x_2619#1001241.dimensionName.code = VOLUME), lambda x_2619#1001241, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001236.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001236, false))[0].productDimensions, lambdafunction((lambda x_2619#1001242.dimensionName.code = VOLUME), lambda x_2619#1001242, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001237.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001237, false))[0].productDimensions, lambdafunction((lambda x_2619#1001243.dimensionName.code = VOLUME), lambda x_2619#1001243, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001350) AS VOLUME#1001231]
Input [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, internalUUID#1001209, _extract_code#1001350]
(71) ReusedExchange [Reuses operator id: 67]
Output [2]: [internalUUID#1001245, _extract_code#1001347]
(72) BroadcastQueryStage
Output [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: 19
(73) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001245, ), isnull(internalUUID#1001245)]
Join type: LeftOuter
Join condition: None
(74) Project
Output [40]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, filter(array(CURRENCY#1001219, VOLUME#1001231, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001263.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001263, false))[0].productDimensions, lambdafunction((lambda x_2621#1001269.dimensionName.code = GROSS_WT), lambda x_2621#1001269, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001264.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001264, false))[0].productDimensions, lambdafunction((lambda x_2621#1001270.dimensionName.code = GROSS_WT), lambda x_2621#1001270, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001265.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001265, false))[0].productDimensions, lambdafunction((lambda x_2621#1001271.dimensionName.code = GROSS_WT), lambda x_2621#1001271, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001347)), lambdafunction(isnotnull(lambda x_2622#1001273.value), lambda x_2622#1001273, false)) AS measurements#1001272]
Input [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, VOLUME#1001231, internalUUID#1001245, _extract_code#1001347]
(75) Scan parquet
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000002111/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#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
(77) Exchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390566]
(78) ShuffleQueryStage
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: 11
(79) BroadcastExchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
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=391040]
(80) BroadcastQueryStage
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: 15
(81) BroadcastHashJoin [codegen id : 13]
Left keys [10]: [coalesce(supplierGroup#1000970, ), isnull(supplierGroup#1000970), coalesce(supplier#1000971, ), isnull(supplier#1000971), coalesce(subrange#1000974, ), isnull(subrange#1000974), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(deliveryDateTime#1000973, 1970-01-01 00:00:00), isnull(deliveryDateTime#1000973)]
Right keys [10]: [coalesce(supplierGroup#1001280, ), isnull(supplierGroup#1001280), coalesce(supplier#1001275, ), isnull(supplier#1001275), coalesce(subrange#1001276, ), isnull(subrange#1001276), coalesce(plant#1001277, ), isnull(plant#1001277), coalesce(deliveryDateTime#1001278, 1970-01-01 00:00:00), isnull(deliveryDateTime#1001278)]
Join type: LeftOuter
Join condition: (isnull(supplyingPlant#1000975) AND isnull(productGroup#1000976))
(82) Project [codegen id : 13]
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#1001145, [GE,LE,GE,LE,EQ] AS constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, null AS originalReplenishmentRunId#1001274L, coalesce(optimizationGroups#1001282, []) AS optimizationGroups#1001286]
Input [46]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
(83) ResultQueryStage
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286]
Arguments: 22
(84) Exchange
Input [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
Arguments: hashpartitioning(product#1000977, plant#1000972, 25), REPARTITION_BY_NUM, [plan_id=390043]
(85) Project
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Input [24]: [internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
(86) Exchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390046]
(87) BroadcastExchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=390099]
(88) BroadcastHashJoin
Left keys [2]: [coalesce(sourceOfSupplyUuid#1000982, ), isnull(sourceOfSupplyUuid#1000982)]
Right keys [2]: [coalesce(internalUUID#1000997, ), isnull(internalUUID#1000997)]
Join type: LeftOuter
Join condition: None
(89) Project
Output [26]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, struct(systemId, systemId#1000996, internalUUID, internalUUID#1000997, supplier, supplier#1000998, receiver, receiver#1000999, product, product#1001000, receivingPlant, receivingPlant#1001001, sourceOfSupplyType, sourceOfSupplyType#1001002, purchasingGroup, purchasingGroup#1001003, purchasingOrganization, purchasingOrganization#1001004, productGroup, productGroup#1001005, validFrom, validFrom#1001006, validTo, validTo#1001007, priority, ... 23 more fields) AS sos#1001020]
Input [49]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
(90) Filter
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
Condition : plant#1001026.internalRefUUID IN (25c0d9731dd07bb53999d9a8f04398e0,1c037502c75549dc72c6fc87c802bcec,45f9c5206af43e1e6acbe19d9a246289,24a9ebb440508219166784d4d1c19eef)
(91) Project
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
(92) Exchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390052]
(93) BroadcastExchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
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=390103]
(94) BroadcastHashJoin
Left keys [4]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972)]
Right keys [4]: [coalesce(product#1001027.internalRefUUID, ), isnull(product#1001027.internalRefUUID), coalesce(plant#1001026.internalRefUUID, ), isnull(plant#1001026.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(95) Project
Output [29]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, CASE WHEN isnotnull(productionAspect#1001029) THEN struct(systemId, systemId#1001024, internalUUID, internalUUID#1001025, plant, plant#1001026, product, product#1001027, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1001028, productionAspect, productionAspect#1001029, salesPlant, salesPlant#1001030, listing, listing#1001031) END AS productPlant#1001036, product#1001027.id AS externalProductId#1001037, plant#1001026.id AS externalPlantId#1001039]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
(96) Filter
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
Condition : isnotnull(internalUUID#1001042)
(97) Project
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
(98) Exchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390058]
(99) BroadcastExchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=390107]
(100) BroadcastHashJoin
Left keys [1]: [product#1000977]
Right keys [1]: [internalUUID#1001042]
Join type: LeftOuter
Join condition: None
(101) Project
Output [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, CASE WHEN isnotnull(internalUUID#1001042) THEN struct(systemId, systemId#1001041, internalUUID, internalUUID#1001042, id, id#1001043, displayId, displayId#1001044, name, name#1001045, baseUnitOfMeasure, baseUnitOfMeasure#1001046, unitOfMeasures, unitOfMeasures#1001047, unitOfMeasureConversions, unitOfMeasureConversions#1001048, productionAspect, productionAspect#1001049, salesAspect, salesAspect#1001050, procurementAspect, procurementAspect#1001051, productGroup, productGroup#1001052) END AS productInformation#1001053]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
(102) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(coalesce(transform(filter(productInformation#1001053.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#1001053.unitOfMeasures, lambdafunction(lambda x_2600#1001065.measurementUnit.internalRefUUID, lambda x_2600#1001065, false)), lambda x_2599#1001062.measurementUnit1.internalRefUUID) AND (lambda x_2599#1001062.measurementUnit2.internalRefUUID = productInformation#1001053.baseUnitOfMeasure.internalRefUUID)), lambda x_2599#1001062, false)), lambdafunction(struct(uom, lambda x_2601#1001066.measurementUnit1.code, uomUuid, lambda x_2601#1001066.measurementUnit1.internalRefUUID, numerator, lambda x_2601#1001066.quantityNumerator, denominator, lambda x_2601#1001066.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2601#1001066, false)), []), lambdafunction(named_struct(uom, lambda x_2602#1001072.uom, uomUuid, lambda x_2602#1001072.uomUuid, numerator, lambda x_2602#1001072.numerator, denominator, lambda x_2602#1001072.denominator, isOrderUnit, ((lambda x_2602#1001072.uomUuid = coalesce(sos#1001020.orderQuantityUnit.internalRefUUID, productInformation#1001053.procurementAspect.orderUnit.internalRefUUID, productInformation#1001053.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_2602#1001072.isPreferred), lambda x_2602#1001072, false)) AS logisticUnits#1001071, productInformation#1001053.baseUnitOfMeasure.code AS orderQuantityBaseUom#1001067, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#1001069, CASE WHEN isnull(supplyingPlant#1000975) THEN 4 ELSE 1 END AS preferredUomSourceCode#1001076]
Input [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053]
(103) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN (preferredUomSourceCode#1001076 = 2) THEN productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 3) THEN sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 4) THEN coalesce(productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile, sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile) WHEN (preferredUomSourceCode#1001076 = 5) THEN coalesce(sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) END AS preferredRoundingProfile#1001077]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredUomSourceCode#1001076]
(104) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#1001084, plant#1001085]
Arguments: [logisticalRoundingProfile#1001084, plant#1001085]
(105) InMemoryRelation
Arguments: [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086], StorageLevel(disk, memory, 2 replicas)
(106) LocalTableScan
Output [3]: [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086]
Arguments: <empty>, [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086]
(107) Project
Output [2]: [logisticalRoundingProfile#1001084, plant#1001085.internalRefUUID AS _extract_internalRefUUID#1001351]
Input [2]: [logisticalRoundingProfile#1001084, plant#1001085]
(108) BroadcastExchange
Input [2]: [logisticalRoundingProfile#1001084, _extract_internalRefUUID#1001351]
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=390113]
(109) BroadcastHashJoin
Left keys [4]: [coalesce(preferredRoundingProfile#1001077, ), isnull(preferredRoundingProfile#1001077), coalesce(plant#1000972, ), isnull(plant#1000972)]
Right keys [4]: [coalesce(logisticalRoundingProfile#1001084, ), isnull(logisticalRoundingProfile#1001084), coalesce(_extract_internalRefUUID#1001351, ), isnull(_extract_internalRefUUID#1001351)]
Join type: LeftOuter
Join condition: None
(110) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
Input [36]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001084, _extract_internalRefUUID#1001351]
(111) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#1001111, plant#1001112]
Arguments: [logisticalRoundingProfile#1001111, plant#1001112], [isnull(plant#1001112.internalRefUUID)]
(112) InMemoryRelation
Arguments: [logisticalRoundingProfile#1001111, plant#1001112, logisticalRoundingRule#1001113], StorageLevel(disk, memory, 2 replicas)
(113) Filter
Input [2]: [logisticalRoundingProfile#1001111, plant#1001112]
Condition : isnull(plant#1001112.internalRefUUID)
(114) Project
Output [1]: [logisticalRoundingProfile#1001111]
Input [2]: [logisticalRoundingProfile#1001111, plant#1001112]
(115) BroadcastExchange
Input [1]: [logisticalRoundingProfile#1001111]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=390117]
(116) BroadcastHashJoin
Left keys [2]: [coalesce(preferredRoundingProfile#1001077, ), isnull(preferredRoundingProfile#1001077)]
Right keys [2]: [coalesce(logisticalRoundingProfile#1001111, ), isnull(logisticalRoundingProfile#1001111)]
Join type: LeftOuter
Join condition: None
(117) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001119.uom, uomUuid, lambda x_2603#1001119.uomUuid, numerator, lambda x_2603#1001119.numerator, denominator, lambda x_2603#1001119.denominator, isOrderUnit, lambda x_2603#1001119.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001119.uomUuid) THEN true ELSE lambda x_2603#1001119.isPreferred END), lambda x_2603#1001119, false)), lambdafunction(named_struct(uom, lambda x_2605#1001120.uom, uomUuid, lambda x_2605#1001120.uomUuid, numerator, lambda x_2605#1001120.numerator, denominator, lambda x_2605#1001120.denominator, isOrderUnit, lambda x_2605#1001120.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001121.uom, uomUuid, lambda x_2603#1001121.uomUuid, numerator, lambda x_2603#1001121.numerator, denominator, lambda x_2603#1001121.denominator, isOrderUnit, lambda x_2603#1001121.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001121.uomUuid) THEN true ELSE lambda x_2603#1001121.isPreferred END), lambda x_2603#1001121, false)), lambdafunction(lambda x_2604#1001122.isPreferred, lambda x_2604#1001122, false)), true) THEN lambda x_2605#1001120.isPreferred ELSE lambda x_2605#1001120.isOrderUnit END), lambda x_2605#1001120, false)) AS logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
Input [35]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001111]
(118) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN isnotnull(supplyingPlant#1000975) THEN productPlant#1001036.productionAspect.productPlanningPlants.minimumLotSize ELSE ((sos#1001020.minimumOrderQuantity * cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001126.isOrderUnit, lambda x#1001126, false))[0].numerator as double)) / cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001127.isOrderUnit, lambda x#1001127, false))[0].denominator as double)) END AS minimumOrderQuantity#1001123]
Input [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
(119) Exchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390074]
(120) BroadcastExchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
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=390122]
(121) BroadcastHashJoin
Left keys [6]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(orderDateTime#1000978, 1970-01-01 00:00:00), isnull(orderDateTime#1000978)]
Right keys [6]: [coalesce(product#1001128, ), isnull(product#1001128), coalesce(plant#1001129, ), isnull(plant#1001129), coalesce(orderDateTime#1001130, 1970-01-01 00:00:00), isnull(orderDateTime#1001130)]
Join type: LeftOuter
Join condition: None
(122) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131]
Input [37]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
(123) Project
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137.isActive AS _extract_isActive#1001374, maxRangeCoverage#1001137.range AS _extract_range#1001375, maxRangeCoverage#1001137.rank AS _extract_rank#1001376, minOrderQuantity#1001138]
Input [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
(124) Exchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390079]
(125) BroadcastExchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390126]
(126) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#1001131, ), isnull(constraintProfile#1001131)]
Right keys [2]: [coalesce(constraintProfile#1001132, ), isnull(constraintProfile#1001132)]
Join type: LeftOuter
Join condition: None
(127) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.level END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN cast(_extract_range#1001375 as double) END, coalesce(minimumOrderQuantity#1001123, 0.0), CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.level END, null) AS constraintValues#1001147, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.rank ELSE 0 END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN _extract_rank#1001376 ELSE 0 END, CASE WHEN (minOrderQuantity#1001138.isActive <=> true) THEN minOrderQuantity#1001138.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.rank ELSE 0 END, 0) AS constraintRanks#1001148, array((minServiceLevel#1001134.isActive <=> true), (_extract_isActive#1001374 <=> true), (minOrderQuantity#1001138.isActive <=> true), (maxServiceLevelEndListing#1001136.isActive <=> true), false) AS constraintIsActive#1001149]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131, constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
(128) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_2613#1001186.label = minServiceLevel), lambda x_2613#1001186, false))[0]) THEN element_at(constraintValues#1001147, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2613#1001187.label = minServiceLevel), lambda x_2613#1001187, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2613#1001188.label = minServiceLevel), lambda x_2613#1001188, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_2614#1001189.label = maxRangeCoverage), lambda x_2614#1001189, false))[0]) THEN element_at(constraintValues#1001147, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2614#1001190.label = maxRangeCoverage), lambda x_2614#1001190, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2614#1001191.label = maxRangeCoverage), lambda x_2614#1001191, false))[0].value END END, element_at(constraintValues#1001147, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_2615#1001192.label = maxServiceLevelEndListing), lambda x_2615#1001192, false))[0]) THEN element_at(constraintValues#1001147, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2615#1001193.label = maxServiceLevelEndListing), lambda x_2615#1001193, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2615#1001194.label = maxServiceLevelEndListing), lambda x_2615#1001194, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_2616#1001195.label = lockedOrderQuantity), lambda x_2616#1001195, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2616#1001196.label = lockedOrderQuantity), lambda x_2616#1001196, false))[0].value END) AS constraintValues#1001185, constraintRanks#1001148, array(coalesce(filter(null, lambdafunction((lambda x_2608#1001180.label = minServiceLevel), lambda x_2608#1001180, false))[0].isActive, element_at(constraintIsActive#1001149, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_2609#1001181.label = maxRangeCoverage), lambda x_2609#1001181, false))[0].isActive, element_at(constraintIsActive#1001149, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_2610#1001182.label = minOrderQuantity), lambda x_2610#1001182, false))[0].isActive, element_at(constraintIsActive#1001149, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_2611#1001183.label = maxServiceLevelEndListing), lambda x_2611#1001183, false))[0].isActive, element_at(constraintIsActive#1001149, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_2612#1001184.label = lockedOrderQuantity), lambda x_2612#1001184, false))[0].isActive, false)) AS constraintIsActive#1001179]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001147, constraintRanks#1001148, constraintIsActive#1001149]
(129) Project
Output [42]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053.unitOfMeasures AS _extract_unitOfMeasures#1001372, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN element_at(constraintIsActive#1001179, 3, None, false) THEN element_at(constraintValues#1001185, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, sos#1001020.purchasingPriceAspect.netPrice.amount AS netPriceAmount#1001198, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#1001200, sos#1001020.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#1001202, sos#1001020.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#1001204, sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#1001206, struct(value, CASE WHEN (sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#1001069) THEN (sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001220.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001220, false))[0].denominator as double)) / cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001221.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001221, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#1001219]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179]
(130) Project
Output [2]: [internalUUID#1001209, isoCode#1001213.code AS _extract_code#1001350]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(131) Exchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390086]
(132) BroadcastExchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390132]
(133) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001209, ), isnull(internalUUID#1001209)]
Join type: LeftOuter
Join condition: None
(134) Project
Output [43]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001235.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001235, false))[0].productDimensions, lambdafunction((lambda x_2619#1001241.dimensionName.code = VOLUME), lambda x_2619#1001241, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001236.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001236, false))[0].productDimensions, lambdafunction((lambda x_2619#1001242.dimensionName.code = VOLUME), lambda x_2619#1001242, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001237.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001237, false))[0].productDimensions, lambdafunction((lambda x_2619#1001243.dimensionName.code = VOLUME), lambda x_2619#1001243, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001350) AS VOLUME#1001231]
Input [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, internalUUID#1001209, _extract_code#1001350]
(135) Scan parquet
Output [3]: [internalUUID#1001245, isoCode#1001249, systemId#1001244]
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#1001245, isoCode#1001249.code AS _extract_code#1001347]
Input [3]: [internalUUID#1001245, isoCode#1001249, systemId#1001244]
(137) Exchange
Input [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390091]
(138) BroadcastExchange
Input [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390136]
(139) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001245, ), isnull(internalUUID#1001245)]
Join type: LeftOuter
Join condition: None
(140) Project
Output [40]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, filter(array(CURRENCY#1001219, VOLUME#1001231, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001263.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001263, false))[0].productDimensions, lambdafunction((lambda x_2621#1001269.dimensionName.code = GROSS_WT), lambda x_2621#1001269, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001264.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001264, false))[0].productDimensions, lambdafunction((lambda x_2621#1001270.dimensionName.code = GROSS_WT), lambda x_2621#1001270, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001265.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001265, false))[0].productDimensions, lambdafunction((lambda x_2621#1001271.dimensionName.code = GROSS_WT), lambda x_2621#1001271, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001347)), lambdafunction(isnotnull(lambda x_2622#1001273.value), lambda x_2622#1001273, false)) AS measurements#1001272]
Input [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, VOLUME#1001231, internalUUID#1001245, _extract_code#1001347]
(141) Exchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390095]
(142) BroadcastExchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
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=390140]
(143) BroadcastHashJoin
Left keys [10]: [coalesce(supplierGroup#1000970, ), isnull(supplierGroup#1000970), coalesce(supplier#1000971, ), isnull(supplier#1000971), coalesce(subrange#1000974, ), isnull(subrange#1000974), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(deliveryDateTime#1000973, 1970-01-01 00:00:00), isnull(deliveryDateTime#1000973)]
Right keys [10]: [coalesce(supplierGroup#1001280, ), isnull(supplierGroup#1001280), coalesce(supplier#1001275, ), isnull(supplier#1001275), coalesce(subrange#1001276, ), isnull(subrange#1001276), coalesce(plant#1001277, ), isnull(plant#1001277), coalesce(deliveryDateTime#1001278, 1970-01-01 00:00:00), isnull(deliveryDateTime#1001278)]
Join type: LeftOuter
Join condition: (isnull(supplyingPlant#1000975) AND isnull(productGroup#1000976))
(144) Project
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#1001145, [GE,LE,GE,LE,EQ] AS constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, null AS originalReplenishmentRunId#1001274L, coalesce(optimizationGroups#1001282, []) AS optimizationGroups#1001286]
Input [46]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
(145) AdaptiveSparkPlan
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286]
Arguments: isFinalPlan=true
(146) TableCacheQueryStage
Output [44]: [availabilityDateTime#1000979, clusterId#1000990L, constraintIsActive#1001179, constraintLabels#1001145, constraintOperators#1001146, constraintRanks#1001148, constraintValues#1001185, deliveryDateTime#1000973, externalPlantId#1001039, externalProductId#1001037, isFallbackOrderOnly#1000985, logisticUnits#1001118, measurements#1001272, minimumOrderQuantity#1001197, mrpController#1000981, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, nextAvailabilityDateTime#1000980, optimizationGroups#1001286, orderDateTime#1000978, orderProposalHorizonGroupingId#1000987L, orderProposalId#1000986L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, originalReplenishmentRunId#1001274L, plant#1000972, previousOrderProposal#1000989L, product#1000977, productGroup#1000976, purchasingGroup#1000984, purchasingOrg#1000983, sequenceId#1000991, sourceOfSupplyUuid#1000982, splitIndicator#1000988L, subrange#1000974, supplier#1000971, supplierGroup#1000970, supplyingPlant#1000975, worklistShardItemId#1000992L]
Arguments: 0
(147) Project [codegen id : 1]
Output [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286, 0_1_10000002111 AS shardId#1005162]
Input [44]: [availabilityDateTime#1000979, clusterId#1000990L, constraintIsActive#1001179, constraintLabels#1001145, constraintOperators#1001146, constraintRanks#1001148, constraintValues#1001185, deliveryDateTime#1000973, externalPlantId#1001039, externalProductId#1001037, isFallbackOrderOnly#1000985, logisticUnits#1001118, measurements#1001272, minimumOrderQuantity#1001197, mrpController#1000981, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, nextAvailabilityDateTime#1000980, optimizationGroups#1001286, orderDateTime#1000978, orderProposalHorizonGroupingId#1000987L, orderProposalId#1000986L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, originalReplenishmentRunId#1001274L, plant#1000972, previousOrderProposal#1000989L, product#1000977, productGroup#1000976, purchasingGroup#1000984, purchasingOrg#1000983, sequenceId#1000991, sourceOfSupplyUuid#1000982, splitIndicator#1000988L, subrange#1000974, supplier#1000971, supplierGroup#1000970, supplyingPlant#1000975, worklistShardItemId#1000992L]
(148) ResultQueryStage
Output [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286, shardId#1005162]
Arguments: 2
(149) Project
Output [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286, 0_1_10000002111 AS shardId#1005162]
Input [44]: [availabilityDateTime#1000979, clusterId#1000990L, constraintIsActive#1001179, constraintLabels#1001145, constraintOperators#1001146, constraintRanks#1001148, constraintValues#1001185, deliveryDateTime#1000973, externalPlantId#1001039, externalProductId#1001037, isFallbackOrderOnly#1000985, logisticUnits#1001118, measurements#1001272, minimumOrderQuantity#1001197, mrpController#1000981, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, nextAvailabilityDateTime#1000980, optimizationGroups#1001286, orderDateTime#1000978, orderProposalHorizonGroupingId#1000987L, orderProposalId#1000986L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, originalReplenishmentRunId#1001274L, plant#1000972, previousOrderProposal#1000989L, product#1000977, productGroup#1000976, purchasingGroup#1000984, purchasingOrg#1000983, sequenceId#1000991, sourceOfSupplyUuid#1000982, splitIndicator#1000988L, subrange#1000974, supplier#1000971, supplierGroup#1000970, supplyingPlant#1000975, worklistShardItemId#1000992L]
(150) AdaptiveSparkPlan
Output [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286, shardId#1005162]
Arguments: isFinalPlan=false