== Physical Plan ==
AdaptiveSparkPlan (148)
+- == Final Plan ==
Execute InsertIntoHadoopFsRelationCommand (145)
+- WriteFiles (144)
+- TableCacheQueryStage (143), Statistics(sizeInBytes=1513.1 KiB, rowCount=1.20E+3)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (142)
+- == Final Plan ==
* Project (81)
+- * BroadcastHashJoin LeftOuter BuildRight (80)
:- Project (73)
: +- BroadcastHashJoin LeftOuter BuildRight (72)
: :- Project (69)
: : +- BroadcastHashJoin LeftOuter BuildRight (68)
: : :- Project (60)
: : : +- Project (59)
: : : +- Project (58)
: : : +- BroadcastHashJoin LeftOuter BuildRight (57)
: : : :- Project (49)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (48)
: : : : :- 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=471.8 KiB, rowCount=1.20E+3)
: : : : : : : : +- Exchange (5)
: : : : : : : : +- * ColumnarToRow (4)
: : : : : : : : +- Scan parquet (3)
: : : : : : : +- BroadcastQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=3.80E+3)
: : : : : : : +- BroadcastExchange (12)
: : : : : : : +- ShuffleQueryStage (11), Statistics(sizeInBytes=3.6 MiB, rowCount=3.80E+3)
: : : : : : : +- Exchange (10)
: : : : : : : +- * Project (9)
: : : : : : : +- * ColumnarToRow (8)
: : : : : : : +- Scan parquet (7)
: : : : : : +- BroadcastQueryStage (23), Statistics(sizeInBytes=2.1 MiB, rowCount=1.43E+3)
: : : : : : +- BroadcastExchange (22)
: : : : : : +- ShuffleQueryStage (21), Statistics(sizeInBytes=1098.8 KiB, rowCount=1.43E+3)
: : : : : : +- Exchange (20)
: : : : : : +- * Project (19)
: : : : : : +- * Filter (18)
: : : : : : +- * ColumnarToRow (17)
: : : : : : +- Scan parquet (16)
: : : : : +- BroadcastQueryStage (33), Statistics(sizeInBytes=2.0 MiB, rowCount=151)
: : : : : +- BroadcastExchange (32)
: : : : : +- ShuffleQueryStage (31), Statistics(sizeInBytes=259.7 KiB, rowCount=151)
: : : : : +- Exchange (30)
: : : : : +- * Project (29)
: : : : : +- * Filter (28)
: : : : : +- * ColumnarToRow (27)
: : : : : +- Scan parquet (26)
: : : : +- BroadcastQueryStage (47), Statistics(sizeInBytes=2.1 MiB, rowCount=1.20E+3)
: : : : +- BroadcastExchange (46)
: : : : +- ShuffleQueryStage (45), Statistics(sizeInBytes=139.9 KiB, rowCount=1.20E+3)
: : : : +- Exchange (44)
: : : : +- * ColumnarToRow (43)
: : : : +- Scan parquet (42)
: : : +- BroadcastQueryStage (56), Statistics(sizeInBytes=2.0 MiB, rowCount=1)
: : : +- BroadcastExchange (55)
: : : +- ShuffleQueryStage (54), Statistics(sizeInBytes=168.0 B, rowCount=1)
: : : +- Exchange (53)
: : : +- * Project (52)
: : : +- * ColumnarToRow (51)
: : : +- Scan parquet (50)
: : +- BroadcastQueryStage (67), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (66)
: : +- ShuffleQueryStage (65), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (64)
: : +- * Project (63)
: : +- * ColumnarToRow (62)
: : +- Scan parquet (61)
: +- BroadcastQueryStage (71), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (70)
+- BroadcastQueryStage (79), Statistics(sizeInBytes=2.0 MiB, rowCount=179)
+- BroadcastExchange (78)
+- ShuffleQueryStage (77), Statistics(sizeInBytes=24.7 KiB, rowCount=179)
+- Exchange (76)
+- * ColumnarToRow (75)
+- Scan parquet (74)
+- == Initial Plan ==
Project (141)
+- BroadcastHashJoin LeftOuter BuildRight (140)
:- Project (137)
: +- BroadcastHashJoin LeftOuter BuildRight (136)
: :- Project (131)
: : +- BroadcastHashJoin LeftOuter BuildRight (130)
: : :- Project (126)
: : : +- Project (125)
: : : +- Project (124)
: : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : :- Project (119)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : :- Project (115)
: : : : : +- Project (114)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (113)
: : : : : :- Project (107)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (106)
: : : : : : :- Project (100)
: : : : : : : +- Project (99)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (98)
: : : : : : : :- Project (93)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (92)
: : : : : : : : :- Project (87)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (86)
: : : : : : : : : :- Exchange (82)
: : : : : : : : : : +- Scan parquet (3)
: : : : : : : : : +- BroadcastExchange (85)
: : : : : : : : : +- Exchange (84)
: : : : : : : : : +- Project (83)
: : : : : : : : : +- Scan parquet (7)
: : : : : : : : +- BroadcastExchange (91)
: : : : : : : : +- Exchange (90)
: : : : : : : : +- Project (89)
: : : : : : : : +- Filter (88)
: : : : : : : : +- Scan parquet (16)
: : : : : : : +- BroadcastExchange (97)
: : : : : : : +- Exchange (96)
: : : : : : : +- Project (95)
: : : : : : : +- Filter (94)
: : : : : : : +- Scan parquet (26)
: : : : : : +- BroadcastExchange (105)
: : : : : : +- Project (104)
: : : : : : +- InMemoryTableScan (101)
: : : : : : +- InMemoryRelation (102)
: : : : : : +- LocalTableScan (103)
: : : : : +- BroadcastExchange (112)
: : : : : +- Project (111)
: : : : : +- Filter (110)
: : : : : +- InMemoryTableScan (108)
: : : : : +- InMemoryRelation (109)
: : : : : +- LocalTableScan (103)
: : : : +- BroadcastExchange (117)
: : : : +- Exchange (116)
: : : : +- Scan parquet (42)
: : : +- BroadcastExchange (122)
: : : +- Exchange (121)
: : : +- Project (120)
: : : +- Scan parquet (50)
: : +- BroadcastExchange (129)
: : +- Exchange (128)
: : +- Project (127)
: : +- Scan parquet (61)
: +- BroadcastExchange (135)
: +- Exchange (134)
: +- Project (133)
: +- Scan parquet (132)
+- BroadcastExchange (139)
+- Exchange (138)
+- Scan parquet (74)
+- == Initial Plan ==
Execute InsertIntoHadoopFsRelationCommand (147)
+- WriteFiles (146)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (142)
+- == Final Plan ==
* Project (81)
+- * BroadcastHashJoin LeftOuter BuildRight (80)
:- Project (73)
: +- BroadcastHashJoin LeftOuter BuildRight (72)
: :- Project (69)
: : +- BroadcastHashJoin LeftOuter BuildRight (68)
: : :- Project (60)
: : : +- Project (59)
: : : +- Project (58)
: : : +- BroadcastHashJoin LeftOuter BuildRight (57)
: : : :- Project (49)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (48)
: : : : :- 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=471.8 KiB, rowCount=1.20E+3)
: : : : : : : : +- Exchange (5)
: : : : : : : : +- * ColumnarToRow (4)
: : : : : : : : +- Scan parquet (3)
: : : : : : : +- BroadcastQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=3.80E+3)
: : : : : : : +- BroadcastExchange (12)
: : : : : : : +- ShuffleQueryStage (11), Statistics(sizeInBytes=3.6 MiB, rowCount=3.80E+3)
: : : : : : : +- Exchange (10)
: : : : : : : +- * Project (9)
: : : : : : : +- * ColumnarToRow (8)
: : : : : : : +- Scan parquet (7)
: : : : : : +- BroadcastQueryStage (23), Statistics(sizeInBytes=2.1 MiB, rowCount=1.43E+3)
: : : : : : +- BroadcastExchange (22)
: : : : : : +- ShuffleQueryStage (21), Statistics(sizeInBytes=1098.8 KiB, rowCount=1.43E+3)
: : : : : : +- Exchange (20)
: : : : : : +- * Project (19)
: : : : : : +- * Filter (18)
: : : : : : +- * ColumnarToRow (17)
: : : : : : +- Scan parquet (16)
: : : : : +- BroadcastQueryStage (33), Statistics(sizeInBytes=2.0 MiB, rowCount=151)
: : : : : +- BroadcastExchange (32)
: : : : : +- ShuffleQueryStage (31), Statistics(sizeInBytes=259.7 KiB, rowCount=151)
: : : : : +- Exchange (30)
: : : : : +- * Project (29)
: : : : : +- * Filter (28)
: : : : : +- * ColumnarToRow (27)
: : : : : +- Scan parquet (26)
: : : : +- BroadcastQueryStage (47), Statistics(sizeInBytes=2.1 MiB, rowCount=1.20E+3)
: : : : +- BroadcastExchange (46)
: : : : +- ShuffleQueryStage (45), Statistics(sizeInBytes=139.9 KiB, rowCount=1.20E+3)
: : : : +- Exchange (44)
: : : : +- * ColumnarToRow (43)
: : : : +- Scan parquet (42)
: : : +- BroadcastQueryStage (56), Statistics(sizeInBytes=2.0 MiB, rowCount=1)
: : : +- BroadcastExchange (55)
: : : +- ShuffleQueryStage (54), Statistics(sizeInBytes=168.0 B, rowCount=1)
: : : +- Exchange (53)
: : : +- * Project (52)
: : : +- * ColumnarToRow (51)
: : : +- Scan parquet (50)
: : +- BroadcastQueryStage (67), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (66)
: : +- ShuffleQueryStage (65), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (64)
: : +- * Project (63)
: : +- * ColumnarToRow (62)
: : +- Scan parquet (61)
: +- BroadcastQueryStage (71), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (70)
+- BroadcastQueryStage (79), Statistics(sizeInBytes=2.0 MiB, rowCount=179)
+- BroadcastExchange (78)
+- ShuffleQueryStage (77), Statistics(sizeInBytes=24.7 KiB, rowCount=179)
+- Exchange (76)
+- * ColumnarToRow (75)
+- Scan parquet (74)
+- == Initial Plan ==
Project (141)
+- BroadcastHashJoin LeftOuter BuildRight (140)
:- Project (137)
: +- BroadcastHashJoin LeftOuter BuildRight (136)
: :- Project (131)
: : +- BroadcastHashJoin LeftOuter BuildRight (130)
: : :- Project (126)
: : : +- Project (125)
: : : +- Project (124)
: : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : :- Project (119)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : :- Project (115)
: : : : : +- Project (114)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (113)
: : : : : :- Project (107)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (106)
: : : : : : :- Project (100)
: : : : : : : +- Project (99)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (98)
: : : : : : : :- Project (93)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (92)
: : : : : : : : :- Project (87)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (86)
: : : : : : : : : :- Exchange (82)
: : : : : : : : : : +- Scan parquet (3)
: : : : : : : : : +- BroadcastExchange (85)
: : : : : : : : : +- Exchange (84)
: : : : : : : : : +- Project (83)
: : : : : : : : : +- Scan parquet (7)
: : : : : : : : +- BroadcastExchange (91)
: : : : : : : : +- Exchange (90)
: : : : : : : : +- Project (89)
: : : : : : : : +- Filter (88)
: : : : : : : : +- Scan parquet (16)
: : : : : : : +- BroadcastExchange (97)
: : : : : : : +- Exchange (96)
: : : : : : : +- Project (95)
: : : : : : : +- Filter (94)
: : : : : : : +- Scan parquet (26)
: : : : : : +- BroadcastExchange (105)
: : : : : : +- Project (104)
: : : : : : +- InMemoryTableScan (101)
: : : : : : +- InMemoryRelation (102)
: : : : : : +- LocalTableScan (103)
: : : : : +- BroadcastExchange (112)
: : : : : +- Project (111)
: : : : : +- Filter (110)
: : : : : +- InMemoryTableScan (108)
: : : : : +- InMemoryRelation (109)
: : : : : +- LocalTableScan (103)
: : : : +- BroadcastExchange (117)
: : : : +- Exchange (116)
: : : : +- Scan parquet (42)
: : : +- BroadcastExchange (122)
: : : +- Exchange (121)
: : : +- Project (120)
: : : +- Scan parquet (50)
: : +- BroadcastExchange (129)
: : +- Exchange (128)
: : +- Project (127)
: : +- Scan parquet (61)
: +- BroadcastExchange (135)
: +- Exchange (134)
: +- Project (133)
: +- Scan parquet (132)
+- BroadcastExchange (139)
+- Exchange (138)
+- Scan parquet (74)
(1) InMemoryTableScan
Output [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintLabels#48327, constraintOperators#48328, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, originalReplenishmentRunId#49292L, optimizationGroups#49479]
Arguments: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ... 14 more fields]
(2) InMemoryRelation
Arguments: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ... 14 more fields], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@763c116,StorageLevel(disk, memory, 2 replicas),AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
*(14) Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ... 14 more fields]
+- *(14) BroadcastHashJoin [coalesce(supplierGroup#46713, ), isnull(supplierGroup#46713), coalesce(supplier#46714, ), isnull(supplier#46714), coalesce(subrange#46717, ), isnull(subrange#46717), coalesce(plant#46715, ), isnull(plant#46715), coalesce(deliveryDateTime#46716, 1970-01-01 00:00:00), isnull(deliveryDateTime#46716)], [coalesce(supplierGroup#49333, ), isnull(supplierGroup#49333), coalesce(supplier#49334, ), isnull(supplier#49334), coalesce(subrange#49337, ), isnull(subrange#49337), coalesce(plant#49335, ), isnull(plant#49335), coalesce(deliveryDateTime#49336, 1970-01-01 00:00:00), isnull(deliveryDateTime#49336)], LeftOuter, BuildRight, false
:- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ... 10 more fields]
: +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#49091, ), isnull(internalUUID#49091)], LeftOuter, BuildRight, false
: :- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, ... 13 more fields]
: : +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#48880, ), isnull(internalUUID#48880)], LeftOuter, BuildRight, false
: : :- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, productInformation#47280.unitOfMeasures AS _extract_unitOfMeasures#49723, productInformation#47280.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#49724, logisticUnits#47854, ... 12 more fields]
: : : +- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 5 more fields]
: : : +- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 5 more fields]
: : : +- BroadcastHashJoin [coalesce(constraintProfile#47950, ), isnull(constraintProfile#47950)], [coalesce(constraintProfile#48039, ), isnull(constraintProfile#48039)], LeftOuter, BuildRight, false
: : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 4 more fields]
: : : : +- BroadcastHashJoin [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715), coalesce(orderDateTime#46719, 1970-01-01 00:00:00), isnull(orderDateTime#46719)], [coalesce(product#47947, ), isnull(product#47947), coalesce(plant#47948, ), isnull(plant#47948), coalesce(orderDateTime#47949, 1970-01-01 00:00:00), isnull(orderDateTime#47949)], LeftOuter, BuildRight, false
: : : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 3 more fields]
: : : : : +- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47855.uom, uomUuid, lambda x_30#47855.uomUuid, numerator, lambda x_30#47855.numerator, denominator, lambda x_30#47855.denominator, isOrderUnit, lambda x_30#47855.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47855.uomUuid) THEN true ELSE lambda x_30#47855.isPreferred END), lambda x_30#47855, false)), lambdafunction(named_struct(uom, lambda x_32#47856.uom, uomUuid, lambda x_32#47856.uomUuid, numerator, lambda x_32#47856.numerator, denominator, lambda x_32#47856.denominator, isOrderUnit, lambda x_32#47856.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47857.uom, uomUuid, lambda x_30#47857.uomUuid, numerator, lambda x_30#47857.numerator, denominator, lambda x_30#47857.denominator, isOrderUnit, lambda x_30#47857.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47857.uomUuid) THEN true ELSE lambda x_30#47857.isPreferred END), lambda x_30#47857, false)), lambdafunction(lambda x_31#47858.isPreferred, lambda x_31#47858, false)), true) THEN lambda x_32#47856.isPreferred ELSE lambda x_32#47856.isOrderUnit END), lambda x_32#47856, false)) AS logisticUnits#47854, ... 2 more fields]
: : : : : +- *(13) Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, ... 4 more fields]
: : : : : +- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, ... 3 more fields]
: : : : : +- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, ... 5 more fields]
: : : : : +- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(coalesce(transform(filter(productInformation#47280.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#47280.unitOfMeasures, lambdafunction(lambda x_27#47352.measurementUnit.internalRefUUID, lambda x_27#47352, false)), lambda x_26#47349.measurementUnit1.internalRefUUID) AND (lambda x_26#47349.measurementUnit2.internalRefUUID = productInformation#47280.baseUnitOfMeasure.internalRefUUID)), lambda x_26#47349, false)), lambdafunction(struct(uom, lambda x_28#47353.measurementUnit1.code, uomUuid, lambda x_28#47353.measurementUnit1.internalRefUUID, numerator, lambda x_28#47353.quantityNumerator, denominator, lambda x_28#47353.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_28#47353, false)), []), lambdafunction(named_struct(uom, lambda x_29#47437.uom, uomUuid, lambda x_29#47437.uomUuid, numerator, lambda x_29#47437.numerator, denominator, lambda x_29#47437.denominator, isOrderUnit, ((lambda x_29#47437.uomUuid = coalesce(sos#46886.orderQuantityUnit.internalRefUUID, productInformation#47280.procurementAspect.orderUnit.internalRefUUID, productInformation#47280.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_29#47437.isPreferred), lambda x_29#47437, false)) AS logisticUnits#47436, ... 3 more fields]
: : : : : +- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, CASE WHEN isnotnull(internalUUID#47187) THEN struct(systemId, systemId#47186, internalUUID, internalUUID#47187, id, id#47188, displayId, displayId#47189, name, name#47190, baseUnitOfMeasure, baseUnitOfMeasure#47191, unitOfMeasures, unitOfMeasures#47192, unitOfMeasureConversions, unitOfMeasureConversions#47193, productionAspect, productionAspect#47194, salesAspect, salesAspect#47195, procurementAspect, procurementAspect#47196, productGroup, productGroup#47197) END AS productInformation#47280]
: : : : : +- BroadcastHashJoin [product#46718], [internalUUID#47187], LeftOuter, BuildRight, false
: : : : : :- *(12) Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, CASE WHEN isnotnull(productionAspect#46960) THEN struct(systemId, systemId#46955, internalUUID, internalUUID#46956, plant, plant#46957, product, product#46958, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#46959, productionAspect, productionAspect#46960, salesPlant, salesPlant#46961, listing, listing#46962, sourceOfSupplyCategory, sourceOfSupplyCategory#46963) END AS productPlant#47035, product#46958.id AS externalProductId#47066, plant#46957.id AS externalPlantId#47099]
: : : : : : +- *(12) BroadcastHashJoin [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715)], [coalesce(product#46958.internalRefUUID, ), isnull(product#46958.internalRefUUID), coalesce(plant#46957.internalRefUUID, ), isnull(plant#46957.internalRefUUID)], LeftOuter, BuildRight, false
: : : : : : :- *(12) Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, struct(systemId, systemId#46752, internalUUID, internalUUID#46753, supplier, supplier#46754, receiver, receiver#46755, product, product#46756, receivingPlant, receivingPlant#46757, sourceOfSupplyType, sourceOfSupplyType#46758, purchasingGroup, purchasingGroup#46759, purchasingOrganization, purchasingOrganization#46760, productGroup, productGroup#46761, validFrom, validFrom#46762, validTo, validTo#46763, ... 24 more fields) AS sos#46886]
: : : : : : : +- *(12) BroadcastHashJoin [coalesce(sourceOfSupplyUuid#46723, ), isnull(sourceOfSupplyUuid#46723)], [coalesce(internalUUID#46753, ), isnull(internalUUID#46753)], LeftOuter, BuildRight, false
: : : : : : : :- ShuffleQueryStage 0
: : : : : : : : +- Exchange hashpartitioning(product#46718, plant#46715, 25), REPARTITION_BY_NUM, [plan_id=14856]
: : : : : : : : +- *(1) ColumnarToRow
: : : : : : : : +- FileScan parquet [supplierGroup#46713,supplier#46714,plant#46715,deliveryDateTime#46716,subrange#46717,product#46718,orderDateTime#46719,availabilityDateTime#46720,nextAvailabilityDateTime#46721,mrpController#46722,sourceOfSupplyUuid#46723,purchasingOrg#46724,purchasingGroup#46725,orderProposalId#46726L,orderProposalHorizonGroupingId#46727L,splitIndicator#46728L,worklistShardItemId#46729L,orderProposalItemGroupId#46730,orderProposalItemId#46731] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
: : : : : : : +- BroadcastQueryStage 14
: : : : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=15491]
: : : : : : : +- ShuffleQueryStage 1
: : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14875]
: : : : : : : +- *(2) Project [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
: : : : : : : +- *(2) ColumnarToRow
: : : : : : : +- FileScan parquet [internalUUID#46753,supplier#46754,receiver#46755,product#46756,receivingPlant#46757,sourceOfSupplyType#46758,purchasingGroup#46759,purchasingOrganization#46760,productGroup#46761,validFrom#46762,validTo#46763,priority#46764,isPurchasingBlocked#46765,isConsignment#46766,isDeleted#46767,supplierSubrange#46768,plannedDeliveryTimeDays#46769,orderQuantityUnit#46770,purchasingPriceAspect#46771,orderCurrency#46772,minimumOrderQuantity#46773,logisticalRoundingProfile#46774,supplyingPlant#46775,systemId#46752] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<internalUUID:string,supplier:struct<internalRefUUID:string,id:string>,receiver:struct<inte...
: : : : : : +- BroadcastQueryStage 19
: : : : : : +- BroadcastExchange 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=15495]
: : : : : : +- ShuffleQueryStage 2
: : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14902]
: : : : : : +- *(3) Project [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
: : : : : : +- *(3) Filter plant#46957.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
: : : : : : +- *(3) ColumnarToRow
: : : : : : +- FileScan parquet [internalUUID#46956,plant#46957,product#46958,blockedForReplenishmentStartingFrom#46959,productionAspect#46960,salesPlant#46961,listing#46962,sourceOfSupplyCategory#46963,systemId#46955] Batched: true, DataFilters: [plant#46957.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [In(plant.internalRefUUID, [1c037502c75549dc72c6fc87c802bcec,24a9ebb440508219166784d4d1c19eef,25c..., ReadSchema: struct<internalUUID:string,plant:struct<internalRefUUID:string,id:string>,product:struct<internal...
: : : : : +- BroadcastQueryStage 20
: : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=15499]
: : : : : +- ShuffleQueryStage 3
: : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14931]
: : : : : +- *(4) Project [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
: : : : : +- *(4) Filter isnotnull(internalUUID#47187)
: : : : : +- *(4) ColumnarToRow
: : : : : +- FileScan parquet [internalUUID#47187,id#47188,displayId#47189,name#47190,baseUnitOfMeasure#47191,unitOfMeasures#47192,unitOfMeasureConversions#47193,productionAspect#47194,salesAspect#47195,procurementAspect#47196,productGroup#47197,systemId#47186] Batched: true, DataFilters: [isnotnull(internalUUID#47187)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(internalUUID)], ReadSchema: struct<internalUUID:string,id:string,displayId:string,name:array<struct<lang:string,content:strin...
: : : : +- BroadcastQueryStage 15
: : : : +- BroadcastExchange 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=15509]
: : : : +- ShuffleQueryStage 6
: : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14975]
: : : : +- *(5) ColumnarToRow
: : : : +- FileScan parquet [product#47947,plant#47948,orderDateTime#47949,constraintprofile#47950] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<product:string,plant:string,orderDateTime:timestamp,constraintprofile:string>
: : : +- BroadcastQueryStage 16
: : : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=15513]
: : : +- ShuffleQueryStage 7
: : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14996]
: : : +- *(6) Project [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044.isActive AS _extract_isActive#49725, maxRangeCoverage#48044.range AS _extract_range#49726, maxRangeCoverage#48044.rank AS _extract_rank#49727, minOrderQuantity#48045]
: : : +- *(6) ColumnarToRow
: : : +- FileScan parquet [constraintProfile#48039,minServiceLevel#48041,maxServiceLevelEndListing#48043,maxRangeCoverage#48044,minOrderQuantity#48045] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<constraintProfile:string,minServiceLevel:struct<level:double,rank:int,isActive:boolean>,ma...
: : +- BroadcastQueryStage 17
: : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=15519]
: : +- ShuffleQueryStage 8
: : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=15021]
: : +- *(7) Project [internalUUID#48880, isoCode#48884.code AS _extract_code#49701]
: : +- *(7) ColumnarToRow
: : +- FileScan parquet [internalUUID#48880,isoCode#48884,systemId#48879] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<internalUUID:string,isoCode:struct<code:string>>
: +- BroadcastQueryStage 18
: +- ReusedExchange [internalUUID#49091, _extract_code#49700], BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=15519]
+- BroadcastQueryStage 21
+- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[4, string, true], ), isnull(input[4, 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=15527]
+- ShuffleQueryStage 11
+- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=15065]
+- *(9) ColumnarToRow
+- FileScan parquet [supplierGroup#49333,supplier#49334,plant#49335,deliveryDateTime#49336,subrange#49337,optimizationGroups#49338] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
+- == Initial Plan ==
Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ... 14 more fields]
+- BroadcastHashJoin [coalesce(supplierGroup#46713, ), isnull(supplierGroup#46713), coalesce(supplier#46714, ), isnull(supplier#46714), coalesce(subrange#46717, ), isnull(subrange#46717), coalesce(plant#46715, ), isnull(plant#46715), coalesce(deliveryDateTime#46716, 1970-01-01 00:00:00), isnull(deliveryDateTime#46716)], [coalesce(supplierGroup#49333, ), isnull(supplierGroup#49333), coalesce(supplier#49334, ), isnull(supplier#49334), coalesce(subrange#49337, ), isnull(subrange#49337), coalesce(plant#49335, ), isnull(plant#49335), coalesce(deliveryDateTime#49336, 1970-01-01 00:00:00), isnull(deliveryDateTime#49336)], LeftOuter, BuildRight, false
:- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ... 10 more fields]
: +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#49091, ), isnull(internalUUID#49091)], LeftOuter, BuildRight, false
: :- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, ... 13 more fields]
: : +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#48880, ), isnull(internalUUID#48880)], LeftOuter, BuildRight, false
: : :- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, productInformation#47280.unitOfMeasures AS _extract_unitOfMeasures#49723, productInformation#47280.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#49724, logisticUnits#47854, ... 12 more fields]
: : : +- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 5 more fields]
: : : +- Project [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 5 more fields]
: : : +- BroadcastHashJoin [coalesce(constraintProfile#47950, ), isnull(constraintProfile#47950)], [coalesce(constraintProfile#48039, ), isnull(constraintProfile#48039)], LeftOuter, BuildRight, false
: : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 4 more fields]
: : : : +- BroadcastHashJoin [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715), coalesce(orderDateTime#46719, 1970-01-01 00:00:00), isnull(orderDateTime#46719)], [coalesce(product#47947, ), isnull(product#47947), coalesce(plant#47948, ), isnull(plant#47948), coalesce(orderDateTime#47949, 1970-01-01 00:00:00), isnull(orderDateTime#47949)], LeftOuter, BuildRight, false
: : : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, ... 3 more fields]
: : : : : +- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47855.uom, uomUuid, lambda x_30#47855.uomUuid, numerator, lambda x_30#47855.numerator, denominator, lambda x_30#47855.denominator, isOrderUnit, lambda x_30#47855.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47855.uomUuid) THEN true ELSE lambda x_30#47855.isPreferred END), lambda x_30#47855, false)), lambdafunction(named_struct(uom, lambda x_32#47856.uom, uomUuid, lambda x_32#47856.uomUuid, numerator, lambda x_32#47856.numerator, denominator, lambda x_32#47856.denominator, isOrderUnit, lambda x_32#47856.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47857.uom, uomUuid, lambda x_30#47857.uomUuid, numerator, lambda x_30#47857.numerator, denominator, lambda x_30#47857.denominator, isOrderUnit, lambda x_30#47857.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47857.uomUuid) THEN true ELSE lambda x_30#47857.isPreferred END), lambda x_30#47857, false)), lambdafunction(lambda x_31#47858.isPreferred, lambda x_31#47858, false)), true) THEN lambda x_32#47856.isPreferred ELSE lambda x_32#47856.isOrderUnit END), lambda x_32#47856, false)) AS logisticUnits#47854, ... 2 more fields]
: : : : : +- BroadcastHashJoin [coalesce(preferredRoundingProfile#47468, ), isnull(preferredRoundingProfile#47468)], [coalesce(logisticalRoundingProfile#47595, ), isnull(logisticalRoundingProfile#47595)], LeftOuter, BuildRight, false
: : : : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, ... 3 more fields]
: : : : : : +- BroadcastHashJoin [coalesce(preferredRoundingProfile#47468, ), isnull(preferredRoundingProfile#47468), coalesce(plant#46715, ), isnull(plant#46715)], [coalesce(logisticalRoundingProfile#47499, ), isnull(logisticalRoundingProfile#47499), coalesce(_extract_internalRefUUID#49702, ), isnull(_extract_internalRefUUID#49702)], LeftOuter, BuildRight, false
: : : : : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(coalesce(transform(filter(productInformation#47280.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#47280.unitOfMeasures, lambdafunction(lambda x_27#47352.measurementUnit.internalRefUUID, lambda x_27#47352, false)), lambda x_26#47349.measurementUnit1.internalRefUUID) AND (lambda x_26#47349.measurementUnit2.internalRefUUID = productInformation#47280.baseUnitOfMeasure.internalRefUUID)), lambda x_26#47349, false)), lambdafunction(struct(uom, lambda x_28#47353.measurementUnit1.code, uomUuid, lambda x_28#47353.measurementUnit1.internalRefUUID, numerator, lambda x_28#47353.quantityNumerator, denominator, lambda x_28#47353.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_28#47353, false)), []), lambdafunction(named_struct(uom, lambda x_29#47437.uom, uomUuid, lambda x_29#47437.uomUuid, numerator, lambda x_29#47437.numerator, denominator, lambda x_29#47437.denominator, isOrderUnit, ((lambda x_29#47437.uomUuid = coalesce(sos#46886.orderQuantityUnit.internalRefUUID, productInformation#47280.procurementAspect.orderUnit.internalRefUUID, productInformation#47280.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_29#47437.isPreferred), lambda x_29#47437, false)) AS logisticUnits#47436, ... 3 more fields]
: : : : : : : +- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, CASE WHEN isnotnull(internalUUID#47187) THEN struct(systemId, systemId#47186, internalUUID, internalUUID#47187, id, id#47188, displayId, displayId#47189, name, name#47190, baseUnitOfMeasure, baseUnitOfMeasure#47191, unitOfMeasures, unitOfMeasures#47192, unitOfMeasureConversions, unitOfMeasureConversions#47193, productionAspect, productionAspect#47194, salesAspect, salesAspect#47195, procurementAspect, procurementAspect#47196, productGroup, productGroup#47197) END AS productInformation#47280]
: : : : : : : +- BroadcastHashJoin [product#46718], [internalUUID#47187], LeftOuter, BuildRight, false
: : : : : : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, CASE WHEN isnotnull(productionAspect#46960) THEN struct(systemId, systemId#46955, internalUUID, internalUUID#46956, plant, plant#46957, product, product#46958, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#46959, productionAspect, productionAspect#46960, salesPlant, salesPlant#46961, listing, listing#46962, sourceOfSupplyCategory, sourceOfSupplyCategory#46963) END AS productPlant#47035, product#46958.id AS externalProductId#47066, plant#46957.id AS externalPlantId#47099]
: : : : : : : : +- BroadcastHashJoin [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715)], [coalesce(product#46958.internalRefUUID, ), isnull(product#46958.internalRefUUID), coalesce(plant#46957.internalRefUUID, ), isnull(plant#46957.internalRefUUID)], LeftOuter, BuildRight, false
: : : : : : : : :- Project [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, struct(systemId, systemId#46752, internalUUID, internalUUID#46753, supplier, supplier#46754, receiver, receiver#46755, product, product#46756, receivingPlant, receivingPlant#46757, sourceOfSupplyType, sourceOfSupplyType#46758, purchasingGroup, purchasingGroup#46759, purchasingOrganization, purchasingOrganization#46760, productGroup, productGroup#46761, validFrom, validFrom#46762, validTo, validTo#46763, ... 24 more fields) AS sos#46886]
: : : : : : : : : +- BroadcastHashJoin [coalesce(sourceOfSupplyUuid#46723, ), isnull(sourceOfSupplyUuid#46723)], [coalesce(internalUUID#46753, ), isnull(internalUUID#46753)], LeftOuter, BuildRight, false
: : : : : : : : : :- Exchange hashpartitioning(product#46718, plant#46715, 25), REPARTITION_BY_NUM, [plan_id=14315]
: : : : : : : : : : +- FileScan parquet [supplierGroup#46713,supplier#46714,plant#46715,deliveryDateTime#46716,subrange#46717,product#46718,orderDateTime#46719,availabilityDateTime#46720,nextAvailabilityDateTime#46721,mrpController#46722,sourceOfSupplyUuid#46723,purchasingOrg#46724,purchasingGroup#46725,orderProposalId#46726L,orderProposalHorizonGroupingId#46727L,splitIndicator#46728L,worklistShardItemId#46729L,orderProposalItemGroupId#46730,orderProposalItemId#46731] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
: : : : : : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=14370]
: : : : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14318]
: : : : : : : : : +- Project [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
: : : : : : : : : +- FileScan parquet [internalUUID#46753,supplier#46754,receiver#46755,product#46756,receivingPlant#46757,sourceOfSupplyType#46758,purchasingGroup#46759,purchasingOrganization#46760,productGroup#46761,validFrom#46762,validTo#46763,priority#46764,isPurchasingBlocked#46765,isConsignment#46766,isDeleted#46767,supplierSubrange#46768,plannedDeliveryTimeDays#46769,orderQuantityUnit#46770,purchasingPriceAspect#46771,orderCurrency#46772,minimumOrderQuantity#46773,logisticalRoundingProfile#46774,supplyingPlant#46775,systemId#46752] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<internalUUID:string,supplier:struct<internalRefUUID:string,id:string>,receiver:struct<inte...
: : : : : : : : +- BroadcastExchange 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=14374]
: : : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14324]
: : : : : : : : +- Project [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
: : : : : : : : +- Filter plant#46957.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
: : : : : : : : +- FileScan parquet [internalUUID#46956,plant#46957,product#46958,blockedForReplenishmentStartingFrom#46959,productionAspect#46960,salesPlant#46961,listing#46962,sourceOfSupplyCategory#46963,systemId#46955] Batched: true, DataFilters: [plant#46957.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [In(plant.internalRefUUID, [1c037502c75549dc72c6fc87c802bcec,24a9ebb440508219166784d4d1c19eef,25c..., ReadSchema: struct<internalUUID:string,plant:struct<internalRefUUID:string,id:string>,product:struct<internal...
: : : : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=14378]
: : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14330]
: : : : : : : +- Project [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
: : : : : : : +- Filter isnotnull(internalUUID#47187)
: : : : : : : +- FileScan parquet [internalUUID#47187,id#47188,displayId#47189,name#47190,baseUnitOfMeasure#47191,unitOfMeasures#47192,unitOfMeasureConversions#47193,productionAspect#47194,salesAspect#47195,procurementAspect#47196,productGroup#47197,systemId#47186] Batched: true, DataFilters: [isnotnull(internalUUID#47187)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(internalUUID)], ReadSchema: struct<internalUUID:string,id:string,displayId:string,name:array<struct<lang:string,content:strin...
: : : : : : +- BroadcastExchange 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=14383]
: : : : : : +- Project [logisticalRoundingProfile#47499, plant#47500.internalRefUUID AS _extract_internalRefUUID#49702]
: : : : : : +- InMemoryTableScan [logisticalRoundingProfile#47499, plant#47500]
: : : : : : +- InMemoryRelation [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501], StorageLevel(disk, memory, 2 replicas)
: : : : : : +- LocalTableScan <empty>, [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501]
: : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=14387]
: : : : : +- Project [logisticalRoundingProfile#47595]
: : : : : +- Filter isnull(plant#47596.internalRefUUID)
: : : : : +- InMemoryTableScan [logisticalRoundingProfile#47595, plant#47596], [isnull(plant#47596.internalRefUUID)]
: : : : : +- InMemoryRelation [logisticalRoundingProfile#47595, plant#47596, logisticalRoundingRule#47597], StorageLevel(disk, memory, 2 replicas)
: : : : : +- LocalTableScan <empty>, [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501]
: : : : +- BroadcastExchange 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=14392]
: : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14345]
: : : : +- FileScan parquet [product#47947,plant#47948,orderDateTime#47949,constraintprofile#47950] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<product:string,plant:string,orderDateTime:timestamp,constraintprofile:string>
: : : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=14396]
: : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14350]
: : : +- Project [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044.isActive AS _extract_isActive#49725, maxRangeCoverage#48044.range AS _extract_range#49726, maxRangeCoverage#48044.rank AS _extract_rank#49727, minOrderQuantity#48045]
: : : +- FileScan parquet [constraintProfile#48039,minServiceLevel#48041,maxServiceLevelEndListing#48043,maxRangeCoverage#48044,minOrderQuantity#48045] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<constraintProfile:string,minServiceLevel:struct<level:double,rank:int,isActive:boolean>,ma...
: : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=14402]
: : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14357]
: : +- Project [internalUUID#48880, isoCode#48884.code AS _extract_code#49701]
: : +- FileScan parquet [internalUUID#48880,isoCode#48884,systemId#48879] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<internalUUID:string,isoCode:struct<code:string>>
: +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=14406]
: +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14362]
: +- Project [internalUUID#49091, isoCode#49095.code AS _extract_code#49700]
: +- FileScan parquet [internalUUID#49091,isoCode#49095,systemId#49090] Batched: true, DataFilters: [], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<internalUUID:string,isoCode:struct<code:string>>
+- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[4, string, true], ), isnull(input[4, 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=14410]
+- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14366]
+- FileScan parquet [supplierGroup#49333,supplier#49334,plant#49335,deliveryDateTime#49336,subrange#49337,optimizationGroups#49338] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
,None)
(3) Scan parquet
Output [19]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731]
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/10000000096/shardId=0_1_10000000096]
ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,mrpController:string,sourceOfSupplyUuid:string,purchasingOrg:string,purchasingGroup:string,orderProposalId:bigint,orderProposalHorizonGroupingId:bigint,splitIndicator:bigint,worklistShardItemId:bigint,orderProposalItemGroupId:string,orderProposalItemId:string>
(4) ColumnarToRow [codegen id : 1]
Input [19]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731]
(5) Exchange
Input [19]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731]
Arguments: hashpartitioning(product#46718, plant#46715, 25), REPARTITION_BY_NUM, [plan_id=14856]
(6) ShuffleQueryStage
Output [19]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731]
Arguments: 0
(7) Scan parquet
Output [24]: [internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775, systemId#46752]
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#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775, systemId#46752]
(9) Project [codegen id : 2]
Output [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Input [24]: [internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775, systemId#46752]
(10) Exchange
Input [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14875]
(11) ShuffleQueryStage
Output [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Arguments: 1
(12) BroadcastExchange
Input [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=15491]
(13) BroadcastQueryStage
Output [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Arguments: 14
(14) BroadcastHashJoin [codegen id : 12]
Left keys [2]: [coalesce(sourceOfSupplyUuid#46723, ), isnull(sourceOfSupplyUuid#46723)]
Right keys [2]: [coalesce(internalUUID#46753, ), isnull(internalUUID#46753)]
Join type: LeftOuter
Join condition: None
(15) Project [codegen id : 12]
Output [20]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, struct(systemId, systemId#46752, internalUUID, internalUUID#46753, supplier, supplier#46754, receiver, receiver#46755, product, product#46756, receivingPlant, receivingPlant#46757, sourceOfSupplyType, sourceOfSupplyType#46758, purchasingGroup, purchasingGroup#46759, purchasingOrganization, purchasingOrganization#46760, productGroup, productGroup#46761, validFrom, validFrom#46762, validTo, validTo#46763, ... 24 more fields) AS sos#46886]
Input [43]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
(16) Scan parquet
Output [9]: [internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963, systemId#46955]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant]
PushedFilters: [In(plant.internalRefUUID, [1c037502c75549dc72c6fc87c802bcec,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,3d84243e56ebf98292ed5dba2fd51543,45f9c5206af43e1e6acbe19d9a246289,4d233bd0bf112aded9d852448354b078,6d24a939f4bbd79f6acb8684d6e45c97,717937a4d5db853d3359b6a0623cfdf0,f80b06f7b2102a5f5c63b031eb5d8e03,fca7a07ad5f143db2beafbd1d0401ea1])]
ReadSchema: struct<internalUUID:string,plant:struct<internalRefUUID:string,id:string>,product:struct<internalRefUUID:string,id:string>,blockedForReplenishmentStartingFrom:date,productionAspect:struct<productMovementPlants:struct<unitOfIssue:struct<internalRefUUID:string,code:string>>,productPlanningPlants:struct<mrpType:struct<internalRefUUID:string,code:string>,abcIndicator:struct<internalRefUUID:string,code:string>,mrpController:struct<internalRefUUID:string,id:string>,minimumLotSize:double,logisticalRoundingProfile:struct<internalRefUUID:string,logisticalRoundingProfile:string>>>,salesPlant:struct<loadingGroup:struct<internalRefUUID:string,code:string>>,listing:array<struct<validFrom:timestamp,validTo:timestamp,isListed:boolean>>,sourceOfSupplyCategory:struct<internalRefUUID:string,code:string>>
(17) ColumnarToRow [codegen id : 3]
Input [9]: [internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963, systemId#46955]
(18) Filter [codegen id : 3]
Input [9]: [internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963, systemId#46955]
Condition : plant#46957.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
(19) Project [codegen id : 3]
Output [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
Input [9]: [internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963, systemId#46955]
(20) Exchange
Input [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14902]
(21) ShuffleQueryStage
Output [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
Arguments: 2
(22) BroadcastExchange
Input [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
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=15495]
(23) BroadcastQueryStage
Output [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
Arguments: 19
(24) BroadcastHashJoin [codegen id : 12]
Left keys [4]: [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715)]
Right keys [4]: [coalesce(product#46958.internalRefUUID, ), isnull(product#46958.internalRefUUID), coalesce(plant#46957.internalRefUUID, ), isnull(plant#46957.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(25) Project [codegen id : 12]
Output [23]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, CASE WHEN isnotnull(productionAspect#46960) THEN struct(systemId, systemId#46955, internalUUID, internalUUID#46956, plant, plant#46957, product, product#46958, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#46959, productionAspect, productionAspect#46960, salesPlant, salesPlant#46961, listing, listing#46962, sourceOfSupplyCategory, sourceOfSupplyCategory#46963) END AS productPlant#47035, product#46958.id AS externalProductId#47066, plant#46957.id AS externalPlantId#47099]
Input [29]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
(26) Scan parquet
Output [12]: [internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197, systemId#47186]
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#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197, systemId#47186]
(28) Filter [codegen id : 4]
Input [12]: [internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197, systemId#47186]
Condition : isnotnull(internalUUID#47187)
(29) Project [codegen id : 4]
Output [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Input [12]: [internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197, systemId#47186]
(30) Exchange
Input [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14931]
(31) ShuffleQueryStage
Output [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Arguments: 3
(32) BroadcastExchange
Input [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=15499]
(33) BroadcastQueryStage
Output [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Arguments: 20
(34) BroadcastHashJoin
Left keys [1]: [product#46718]
Right keys [1]: [internalUUID#47187]
Join type: LeftOuter
Join condition: None
(35) Project
Output [24]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, CASE WHEN isnotnull(internalUUID#47187) THEN struct(systemId, systemId#47186, internalUUID, internalUUID#47187, id, id#47188, displayId, displayId#47189, name, name#47190, baseUnitOfMeasure, baseUnitOfMeasure#47191, unitOfMeasures, unitOfMeasures#47192, unitOfMeasureConversions, unitOfMeasureConversions#47193, productionAspect, productionAspect#47194, salesAspect, salesAspect#47195, procurementAspect, procurementAspect#47196, productGroup, productGroup#47197) END AS productInformation#47280]
Input [35]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
(36) Project
Output [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(coalesce(transform(filter(productInformation#47280.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#47280.unitOfMeasures, lambdafunction(lambda x_27#47352.measurementUnit.internalRefUUID, lambda x_27#47352, false)), lambda x_26#47349.measurementUnit1.internalRefUUID) AND (lambda x_26#47349.measurementUnit2.internalRefUUID = productInformation#47280.baseUnitOfMeasure.internalRefUUID)), lambda x_26#47349, false)), lambdafunction(struct(uom, lambda x_28#47353.measurementUnit1.code, uomUuid, lambda x_28#47353.measurementUnit1.internalRefUUID, numerator, lambda x_28#47353.quantityNumerator, denominator, lambda x_28#47353.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_28#47353, false)), []), lambdafunction(named_struct(uom, lambda x_29#47437.uom, uomUuid, lambda x_29#47437.uomUuid, numerator, lambda x_29#47437.numerator, denominator, lambda x_29#47437.denominator, isOrderUnit, ((lambda x_29#47437.uomUuid = coalesce(sos#46886.orderQuantityUnit.internalRefUUID, productInformation#47280.procurementAspect.orderUnit.internalRefUUID, productInformation#47280.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_29#47437.isPreferred), lambda x_29#47437, false)) AS logisticUnits#47436, productInformation#47280.baseUnitOfMeasure.code AS orderQuantityBaseUom#47379, productInformation#47280.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#47407, coalesce(sos#46886.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#47035.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) AS preferredRoundingProfile#47468]
Input [24]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, productInformation#47280]
(37) Project
Output [29]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468, cast(null as string) AS logisticalRoundingProfile#47499, cast(null as string) AS _extract_internalRefUUID#49702]
Input [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468]
(38) Project
Output [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468]
Input [29]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468, logisticalRoundingProfile#47499, _extract_internalRefUUID#49702]
(39) Project [codegen id : 13]
Output [28]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468, cast(null as string) AS logisticalRoundingProfile#47595]
Input [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468]
(40) Project
Output [26]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47855.uom, uomUuid, lambda x_30#47855.uomUuid, numerator, lambda x_30#47855.numerator, denominator, lambda x_30#47855.denominator, isOrderUnit, lambda x_30#47855.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47855.uomUuid) THEN true ELSE lambda x_30#47855.isPreferred END), lambda x_30#47855, false)), lambdafunction(named_struct(uom, lambda x_32#47856.uom, uomUuid, lambda x_32#47856.uomUuid, numerator, lambda x_32#47856.numerator, denominator, lambda x_32#47856.denominator, isOrderUnit, lambda x_32#47856.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47857.uom, uomUuid, lambda x_30#47857.uomUuid, numerator, lambda x_30#47857.numerator, denominator, lambda x_30#47857.denominator, isOrderUnit, lambda x_30#47857.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47857.uomUuid) THEN true ELSE lambda x_30#47857.isPreferred END), lambda x_30#47857, false)), lambdafunction(lambda x_31#47858.isPreferred, lambda x_31#47858, false)), true) THEN lambda x_32#47856.isPreferred ELSE lambda x_32#47856.isOrderUnit END), lambda x_32#47856, false)) AS logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407]
Input [28]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468, logisticalRoundingProfile#47595]
(41) Project
Output [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ((sos#46886.minimumOrderQuantity * cast(filter(logisticUnits#47854, lambdafunction(lambda x#47917.isOrderUnit, lambda x#47917, false))[0].numerator as double)) / cast(filter(logisticUnits#47854, lambdafunction(lambda x#47918.isOrderUnit, lambda x#47918, false))[0].denominator as double)) AS minimumOrderQuantity#47915]
Input [26]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407]
(42) Scan parquet
Output [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000000096/0_1_10000000096/constraintprofile]
ReadSchema: struct<product:string,plant:string,orderDateTime:timestamp,constraintprofile:string>
(43) ColumnarToRow [codegen id : 5]
Input [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
(44) Exchange
Input [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14975]
(45) ShuffleQueryStage
Output [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
Arguments: 6
(46) BroadcastExchange
Input [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
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=15509]
(47) BroadcastQueryStage
Output [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
Arguments: 15
(48) BroadcastHashJoin
Left keys [6]: [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715), coalesce(orderDateTime#46719, 1970-01-01 00:00:00), isnull(orderDateTime#46719)]
Right keys [6]: [coalesce(product#47947, ), isnull(product#47947), coalesce(plant#47948, ), isnull(plant#47948), coalesce(orderDateTime#47949, 1970-01-01 00:00:00), isnull(orderDateTime#47949)]
Join type: LeftOuter
Join condition: None
(49) Project
Output [28]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#47915, constraintProfile#47950]
Input [31]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#47915, product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
(50) Scan parquet
Output [5]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044, minOrderQuantity#48045]
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>>
(51) ColumnarToRow [codegen id : 6]
Input [5]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044, minOrderQuantity#48045]
(52) Project [codegen id : 6]
Output [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044.isActive AS _extract_isActive#49725, maxRangeCoverage#48044.range AS _extract_range#49726, maxRangeCoverage#48044.rank AS _extract_rank#49727, minOrderQuantity#48045]
Input [5]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044, minOrderQuantity#48045]
(53) Exchange
Input [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14996]
(54) ShuffleQueryStage
Output [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
Arguments: 7
(55) BroadcastExchange
Input [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=15513]
(56) BroadcastQueryStage
Output [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
Arguments: 16
(57) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#47950, ), isnull(constraintProfile#47950)]
Right keys [2]: [coalesce(constraintProfile#48039, ), isnull(constraintProfile#48039)]
Join type: LeftOuter
Join condition: None
(58) Project
Output [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, array(CASE WHEN (minServiceLevel#48041.isActive <=> true) THEN minServiceLevel#48041.level END, CASE WHEN (_extract_isActive#49725 <=> true) THEN cast(_extract_range#49726 as double) END, coalesce(minimumOrderQuantity#47915, 0.0), CASE WHEN (maxServiceLevelEndListing#48043.isActive <=> true) THEN maxServiceLevelEndListing#48043.level END, null) AS constraintValues#48329, array(CASE WHEN (minServiceLevel#48041.isActive <=> true) THEN minServiceLevel#48041.rank ELSE 0 END, CASE WHEN (_extract_isActive#49725 <=> true) THEN _extract_rank#49727 ELSE 0 END, CASE WHEN (minOrderQuantity#48045.isActive <=> true) THEN minOrderQuantity#48045.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#48043.isActive <=> true) THEN maxServiceLevelEndListing#48043.rank ELSE 0 END, 0) AS constraintRanks#48330, array((minServiceLevel#48041.isActive <=> true), (_extract_isActive#49725 <=> true), (minOrderQuantity#48045.isActive <=> true), (maxServiceLevelEndListing#48043.isActive <=> true), false) AS constraintIsActive#48331]
Input [35]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#47915, constraintProfile#47950, constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
(59) Project
Output [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_40#48546.label = minServiceLevel), lambda x_40#48546, false))[0]) THEN element_at(constraintValues#48329, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_40#48547.label = minServiceLevel), lambda x_40#48547, false))[0].isActive THEN filter(null, lambdafunction((lambda x_40#48548.label = minServiceLevel), lambda x_40#48548, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_41#48549.label = maxRangeCoverage), lambda x_41#48549, false))[0]) THEN element_at(constraintValues#48329, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_41#48550.label = maxRangeCoverage), lambda x_41#48550, false))[0].isActive THEN filter(null, lambdafunction((lambda x_41#48551.label = maxRangeCoverage), lambda x_41#48551, false))[0].value END END, element_at(constraintValues#48329, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_42#48552.label = maxServiceLevelEndListing), lambda x_42#48552, false))[0]) THEN element_at(constraintValues#48329, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_42#48553.label = maxServiceLevelEndListing), lambda x_42#48553, false))[0].isActive THEN filter(null, lambdafunction((lambda x_42#48554.label = maxServiceLevelEndListing), lambda x_42#48554, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_43#48555.label = lockedOrderQuantity), lambda x_43#48555, false))[0].isActive THEN filter(null, lambdafunction((lambda x_43#48556.label = lockedOrderQuantity), lambda x_43#48556, false))[0].value END) AS constraintValues#48545, constraintRanks#48330, array(coalesce(filter(null, lambdafunction((lambda x_35#48506.label = minServiceLevel), lambda x_35#48506, false))[0].isActive, element_at(constraintIsActive#48331, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_36#48507.label = maxRangeCoverage), lambda x_36#48507, false))[0].isActive, element_at(constraintIsActive#48331, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_37#48508.label = minOrderQuantity), lambda x_37#48508, false))[0].isActive, element_at(constraintIsActive#48331, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_38#48509.label = maxServiceLevelEndListing), lambda x_38#48509, false))[0].isActive, element_at(constraintIsActive#48331, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_39#48510.label = lockedOrderQuantity), lambda x_39#48510, false))[0].isActive, false)) AS constraintIsActive#48505]
Input [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, constraintValues#48329, constraintRanks#48330, constraintIsActive#48331]
(60) Project
Output [36]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, productInformation#47280.unitOfMeasures AS _extract_unitOfMeasures#49723, productInformation#47280.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, CASE WHEN element_at(constraintIsActive#48505, 3, None, false) THEN element_at(constraintValues#48545, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, sos#46886.purchasingPriceAspect.netPrice.amount AS netPriceAmount#48659, sos#46886.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#48695, sos#46886.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#48732, sos#46886.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#48770, sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#48809, struct(value, CASE WHEN (sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#47407) THEN (sos#46886.purchasingPriceAspect.netPrice.amount / sos#46886.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#46886.purchasingPriceAspect.netPrice.amount / sos#46886.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#47854, lambdafunction((lambda x_44#48897.uomUuid = sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_44#48897, false))[0].denominator as double)) / cast(filter(logisticUnits#47854, lambdafunction((lambda x_44#48898.uomUuid = sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_44#48898, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#46886.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#48896]
Input [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505]
(61) Scan parquet
Output [3]: [internalUUID#48880, isoCode#48884, systemId#48879]
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>>
(62) ColumnarToRow [codegen id : 7]
Input [3]: [internalUUID#48880, isoCode#48884, systemId#48879]
(63) Project [codegen id : 7]
Output [2]: [internalUUID#48880, isoCode#48884.code AS _extract_code#49701]
Input [3]: [internalUUID#48880, isoCode#48884, systemId#48879]
(64) Exchange
Input [2]: [internalUUID#48880, _extract_code#49701]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=15021]
(65) ShuffleQueryStage
Output [2]: [internalUUID#48880, _extract_code#49701]
Arguments: 8
(66) BroadcastExchange
Input [2]: [internalUUID#48880, _extract_code#49701]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=15519]
(67) BroadcastQueryStage
Output [2]: [internalUUID#48880, _extract_code#49701]
Arguments: 17
(68) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#48880, ), isnull(internalUUID#48880)]
Join type: LeftOuter
Join condition: None
(69) Project
Output [37]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, CURRENCY#48896, struct(value, cast(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#49041.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#49041, false))[0].productDimensions, lambdafunction((lambda x_46#49047.dimensionName.code = VOLUME), lambda x_46#49047, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#49042.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#49042, false))[0].productDimensions, lambdafunction((lambda x_46#49048.dimensionName.code = VOLUME), lambda x_46#49048, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#49043.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#49043, false))[0].productDimensions, lambdafunction((lambda x_46#49049.dimensionName.code = VOLUME), lambda x_46#49049, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#49701) AS VOLUME#49037]
Input [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, CURRENCY#48896, internalUUID#48880, _extract_code#49701]
(70) ReusedExchange [Reuses operator id: 66]
Output [2]: [internalUUID#49091, _extract_code#49700]
(71) BroadcastQueryStage
Output [2]: [internalUUID#49091, _extract_code#49700]
Arguments: 18
(72) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#49091, ), isnull(internalUUID#49091)]
Join type: LeftOuter
Join condition: None
(73) Project
Output [34]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, filter(array(CURRENCY#48896, VOLUME#49037, struct(value, cast(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49201.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49201, false))[0].productDimensions, lambdafunction((lambda x_48#49207.dimensionName.code = GROSS_WT), lambda x_48#49207, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49202.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49202, false))[0].productDimensions, lambdafunction((lambda x_48#49208.dimensionName.code = GROSS_WT), lambda x_48#49208, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49203.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49203, false))[0].productDimensions, lambdafunction((lambda x_48#49209.dimensionName.code = GROSS_WT), lambda x_48#49209, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#49700)), lambdafunction(isnotnull(lambda x_49#49252.value), lambda x_49#49252, false)) AS measurements#49251]
Input [39]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, CURRENCY#48896, VOLUME#49037, internalUUID#49091, _extract_code#49700]
(74) Scan parquet
Output [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000000096/0_1_10000000096/minorderrestrictionprofile/results]
ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,optimizationGroups:array<string>>
(75) ColumnarToRow [codegen id : 9]
Input [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
(76) Exchange
Input [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=15065]
(77) ShuffleQueryStage
Output [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
Arguments: 11
(78) BroadcastExchange
Input [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
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[4, string, true], ), isnull(input[4, 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=15527]
(79) BroadcastQueryStage
Output [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
Arguments: 21
(80) BroadcastHashJoin [codegen id : 14]
Left keys [10]: [coalesce(supplierGroup#46713, ), isnull(supplierGroup#46713), coalesce(supplier#46714, ), isnull(supplier#46714), coalesce(subrange#46717, ), isnull(subrange#46717), coalesce(plant#46715, ), isnull(plant#46715), coalesce(deliveryDateTime#46716, 1970-01-01 00:00:00), isnull(deliveryDateTime#46716)]
Right keys [10]: [coalesce(supplierGroup#49333, ), isnull(supplierGroup#49333), coalesce(supplier#49334, ), isnull(supplier#49334), coalesce(subrange#49337, ), isnull(subrange#49337), coalesce(plant#49335, ), isnull(plant#49335), coalesce(deliveryDateTime#49336, 1970-01-01 00:00:00), isnull(deliveryDateTime#49336)]
Join type: LeftOuter
Join condition: None
(81) Project [codegen id : 14]
Output [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#48327, [GE,LE,GE,LE,EQ] AS constraintOperators#48328, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, null AS originalReplenishmentRunId#49292L, coalesce(optimizationGroups#49338, []) AS optimizationGroups#49479]
Input [40]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
(82) Exchange
Input [19]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731]
Arguments: hashpartitioning(product#46718, plant#46715, 25), REPARTITION_BY_NUM, [plan_id=14315]
(83) Project
Output [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Input [24]: [internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775, systemId#46752]
(84) Exchange
Input [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14318]
(85) BroadcastExchange
Input [24]: [systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=14370]
(86) BroadcastHashJoin
Left keys [2]: [coalesce(sourceOfSupplyUuid#46723, ), isnull(sourceOfSupplyUuid#46723)]
Right keys [2]: [coalesce(internalUUID#46753, ), isnull(internalUUID#46753)]
Join type: LeftOuter
Join condition: None
(87) Project
Output [20]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, struct(systemId, systemId#46752, internalUUID, internalUUID#46753, supplier, supplier#46754, receiver, receiver#46755, product, product#46756, receivingPlant, receivingPlant#46757, sourceOfSupplyType, sourceOfSupplyType#46758, purchasingGroup, purchasingGroup#46759, purchasingOrganization, purchasingOrganization#46760, productGroup, productGroup#46761, validFrom, validFrom#46762, validTo, validTo#46763, ... 24 more fields) AS sos#46886]
Input [43]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, systemId#46752, internalUUID#46753, supplier#46754, receiver#46755, product#46756, receivingPlant#46757, sourceOfSupplyType#46758, purchasingGroup#46759, purchasingOrganization#46760, productGroup#46761, validFrom#46762, validTo#46763, priority#46764, isPurchasingBlocked#46765, isConsignment#46766, isDeleted#46767, supplierSubrange#46768, plannedDeliveryTimeDays#46769, orderQuantityUnit#46770, purchasingPriceAspect#46771, orderCurrency#46772, minimumOrderQuantity#46773, logisticalRoundingProfile#46774, supplyingPlant#46775]
(88) Filter
Input [9]: [internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963, systemId#46955]
Condition : plant#46957.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
(89) Project
Output [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
Input [9]: [internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963, systemId#46955]
(90) Exchange
Input [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14324]
(91) BroadcastExchange
Input [9]: [systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
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=14374]
(92) BroadcastHashJoin
Left keys [4]: [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715)]
Right keys [4]: [coalesce(product#46958.internalRefUUID, ), isnull(product#46958.internalRefUUID), coalesce(plant#46957.internalRefUUID, ), isnull(plant#46957.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(93) Project
Output [23]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, CASE WHEN isnotnull(productionAspect#46960) THEN struct(systemId, systemId#46955, internalUUID, internalUUID#46956, plant, plant#46957, product, product#46958, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#46959, productionAspect, productionAspect#46960, salesPlant, salesPlant#46961, listing, listing#46962, sourceOfSupplyCategory, sourceOfSupplyCategory#46963) END AS productPlant#47035, product#46958.id AS externalProductId#47066, plant#46957.id AS externalPlantId#47099]
Input [29]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, systemId#46955, internalUUID#46956, plant#46957, product#46958, blockedForReplenishmentStartingFrom#46959, productionAspect#46960, salesPlant#46961, listing#46962, sourceOfSupplyCategory#46963]
(94) Filter
Input [12]: [internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197, systemId#47186]
Condition : isnotnull(internalUUID#47187)
(95) Project
Output [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Input [12]: [internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197, systemId#47186]
(96) Exchange
Input [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14330]
(97) BroadcastExchange
Input [12]: [systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=14378]
(98) BroadcastHashJoin
Left keys [1]: [product#46718]
Right keys [1]: [internalUUID#47187]
Join type: LeftOuter
Join condition: None
(99) Project
Output [24]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, CASE WHEN isnotnull(internalUUID#47187) THEN struct(systemId, systemId#47186, internalUUID, internalUUID#47187, id, id#47188, displayId, displayId#47189, name, name#47190, baseUnitOfMeasure, baseUnitOfMeasure#47191, unitOfMeasures, unitOfMeasures#47192, unitOfMeasureConversions, unitOfMeasureConversions#47193, productionAspect, productionAspect#47194, salesAspect, salesAspect#47195, procurementAspect, procurementAspect#47196, productGroup, productGroup#47197) END AS productInformation#47280]
Input [35]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, systemId#47186, internalUUID#47187, id#47188, displayId#47189, name#47190, baseUnitOfMeasure#47191, unitOfMeasures#47192, unitOfMeasureConversions#47193, productionAspect#47194, salesAspect#47195, procurementAspect#47196, productGroup#47197]
(100) Project
Output [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(coalesce(transform(filter(productInformation#47280.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#47280.unitOfMeasures, lambdafunction(lambda x_27#47352.measurementUnit.internalRefUUID, lambda x_27#47352, false)), lambda x_26#47349.measurementUnit1.internalRefUUID) AND (lambda x_26#47349.measurementUnit2.internalRefUUID = productInformation#47280.baseUnitOfMeasure.internalRefUUID)), lambda x_26#47349, false)), lambdafunction(struct(uom, lambda x_28#47353.measurementUnit1.code, uomUuid, lambda x_28#47353.measurementUnit1.internalRefUUID, numerator, lambda x_28#47353.quantityNumerator, denominator, lambda x_28#47353.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_28#47353, false)), []), lambdafunction(named_struct(uom, lambda x_29#47437.uom, uomUuid, lambda x_29#47437.uomUuid, numerator, lambda x_29#47437.numerator, denominator, lambda x_29#47437.denominator, isOrderUnit, ((lambda x_29#47437.uomUuid = coalesce(sos#46886.orderQuantityUnit.internalRefUUID, productInformation#47280.procurementAspect.orderUnit.internalRefUUID, productInformation#47280.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_29#47437.isPreferred), lambda x_29#47437, false)) AS logisticUnits#47436, productInformation#47280.baseUnitOfMeasure.code AS orderQuantityBaseUom#47379, productInformation#47280.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#47407, coalesce(sos#46886.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#47035.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) AS preferredRoundingProfile#47468]
Input [24]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, productPlant#47035, externalProductId#47066, externalPlantId#47099, productInformation#47280]
(101) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#47499, plant#47500]
Arguments: [logisticalRoundingProfile#47499, plant#47500]
(102) InMemoryRelation
Arguments: [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@763c116,StorageLevel(disk, memory, 2 replicas),LocalTableScan <empty>, [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501]
,None)
(103) LocalTableScan
Output [3]: [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501]
Arguments: <empty>, [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501]
(104) Project
Output [2]: [logisticalRoundingProfile#47499, plant#47500.internalRefUUID AS _extract_internalRefUUID#49702]
Input [2]: [logisticalRoundingProfile#47499, plant#47500]
(105) BroadcastExchange
Input [2]: [logisticalRoundingProfile#47499, _extract_internalRefUUID#49702]
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=14383]
(106) BroadcastHashJoin
Left keys [4]: [coalesce(preferredRoundingProfile#47468, ), isnull(preferredRoundingProfile#47468), coalesce(plant#46715, ), isnull(plant#46715)]
Right keys [4]: [coalesce(logisticalRoundingProfile#47499, ), isnull(logisticalRoundingProfile#47499), coalesce(_extract_internalRefUUID#49702, ), isnull(_extract_internalRefUUID#49702)]
Join type: LeftOuter
Join condition: None
(107) Project
Output [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468]
Input [29]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468, logisticalRoundingProfile#47499, _extract_internalRefUUID#49702]
(108) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#47595, plant#47596]
Arguments: [logisticalRoundingProfile#47595, plant#47596], [isnull(plant#47596.internalRefUUID)]
(109) InMemoryRelation
Arguments: [logisticalRoundingProfile#47595, plant#47596, logisticalRoundingRule#47597], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@763c116,StorageLevel(disk, memory, 2 replicas),LocalTableScan <empty>, [logisticalRoundingProfile#47499, plant#47500, logisticalRoundingRule#47501]
,None)
(110) Filter
Input [2]: [logisticalRoundingProfile#47595, plant#47596]
Condition : isnull(plant#47596.internalRefUUID)
(111) Project
Output [1]: [logisticalRoundingProfile#47595]
Input [2]: [logisticalRoundingProfile#47595, plant#47596]
(112) BroadcastExchange
Input [1]: [logisticalRoundingProfile#47595]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=14387]
(113) BroadcastHashJoin
Left keys [2]: [coalesce(preferredRoundingProfile#47468, ), isnull(preferredRoundingProfile#47468)]
Right keys [2]: [coalesce(logisticalRoundingProfile#47595, ), isnull(logisticalRoundingProfile#47595)]
Join type: LeftOuter
Join condition: None
(114) Project
Output [26]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47855.uom, uomUuid, lambda x_30#47855.uomUuid, numerator, lambda x_30#47855.numerator, denominator, lambda x_30#47855.denominator, isOrderUnit, lambda x_30#47855.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47855.uomUuid) THEN true ELSE lambda x_30#47855.isPreferred END), lambda x_30#47855, false)), lambdafunction(named_struct(uom, lambda x_32#47856.uom, uomUuid, lambda x_32#47856.uomUuid, numerator, lambda x_32#47856.numerator, denominator, lambda x_32#47856.denominator, isOrderUnit, lambda x_32#47856.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#47436, lambdafunction(named_struct(uom, lambda x_30#47857.uom, uomUuid, lambda x_30#47857.uomUuid, numerator, lambda x_30#47857.numerator, denominator, lambda x_30#47857.denominator, isOrderUnit, lambda x_30#47857.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_30#47857.uomUuid) THEN true ELSE lambda x_30#47857.isPreferred END), lambda x_30#47857, false)), lambdafunction(lambda x_31#47858.isPreferred, lambda x_31#47858, false)), true) THEN lambda x_32#47856.isPreferred ELSE lambda x_32#47856.isOrderUnit END), lambda x_32#47856, false)) AS logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407]
Input [28]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47436, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, preferredRoundingProfile#47468, logisticalRoundingProfile#47595]
(115) Project
Output [27]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, ((sos#46886.minimumOrderQuantity * cast(filter(logisticUnits#47854, lambdafunction(lambda x#47917.isOrderUnit, lambda x#47917, false))[0].numerator as double)) / cast(filter(logisticUnits#47854, lambdafunction(lambda x#47918.isOrderUnit, lambda x#47918, false))[0].denominator as double)) AS minimumOrderQuantity#47915]
Input [26]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407]
(116) Exchange
Input [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14345]
(117) BroadcastExchange
Input [4]: [product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
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=14392]
(118) BroadcastHashJoin
Left keys [6]: [coalesce(product#46718, ), isnull(product#46718), coalesce(plant#46715, ), isnull(plant#46715), coalesce(orderDateTime#46719, 1970-01-01 00:00:00), isnull(orderDateTime#46719)]
Right keys [6]: [coalesce(product#47947, ), isnull(product#47947), coalesce(plant#47948, ), isnull(plant#47948), coalesce(orderDateTime#47949, 1970-01-01 00:00:00), isnull(orderDateTime#47949)]
Join type: LeftOuter
Join condition: None
(119) Project
Output [28]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#47915, constraintProfile#47950]
Input [31]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#47915, product#47947, plant#47948, orderDateTime#47949, constraintprofile#47950]
(120) Project
Output [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044.isActive AS _extract_isActive#49725, maxRangeCoverage#48044.range AS _extract_range#49726, maxRangeCoverage#48044.rank AS _extract_rank#49727, minOrderQuantity#48045]
Input [5]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, maxRangeCoverage#48044, minOrderQuantity#48045]
(121) Exchange
Input [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14350]
(122) BroadcastExchange
Input [7]: [constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=14396]
(123) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#47950, ), isnull(constraintProfile#47950)]
Right keys [2]: [coalesce(constraintProfile#48039, ), isnull(constraintProfile#48039)]
Join type: LeftOuter
Join condition: None
(124) Project
Output [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, array(CASE WHEN (minServiceLevel#48041.isActive <=> true) THEN minServiceLevel#48041.level END, CASE WHEN (_extract_isActive#49725 <=> true) THEN cast(_extract_range#49726 as double) END, coalesce(minimumOrderQuantity#47915, 0.0), CASE WHEN (maxServiceLevelEndListing#48043.isActive <=> true) THEN maxServiceLevelEndListing#48043.level END, null) AS constraintValues#48329, array(CASE WHEN (minServiceLevel#48041.isActive <=> true) THEN minServiceLevel#48041.rank ELSE 0 END, CASE WHEN (_extract_isActive#49725 <=> true) THEN _extract_rank#49727 ELSE 0 END, CASE WHEN (minOrderQuantity#48045.isActive <=> true) THEN minOrderQuantity#48045.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#48043.isActive <=> true) THEN maxServiceLevelEndListing#48043.rank ELSE 0 END, 0) AS constraintRanks#48330, array((minServiceLevel#48041.isActive <=> true), (_extract_isActive#49725 <=> true), (minOrderQuantity#48045.isActive <=> true), (maxServiceLevelEndListing#48043.isActive <=> true), false) AS constraintIsActive#48331]
Input [35]: [supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalId#46726L, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, orderProposalItemId#46731, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#47915, constraintProfile#47950, constraintProfile#48039, minServiceLevel#48041, maxServiceLevelEndListing#48043, _extract_isActive#49725, _extract_range#49726, _extract_rank#49727, minOrderQuantity#48045]
(125) Project
Output [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_40#48546.label = minServiceLevel), lambda x_40#48546, false))[0]) THEN element_at(constraintValues#48329, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_40#48547.label = minServiceLevel), lambda x_40#48547, false))[0].isActive THEN filter(null, lambdafunction((lambda x_40#48548.label = minServiceLevel), lambda x_40#48548, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_41#48549.label = maxRangeCoverage), lambda x_41#48549, false))[0]) THEN element_at(constraintValues#48329, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_41#48550.label = maxRangeCoverage), lambda x_41#48550, false))[0].isActive THEN filter(null, lambdafunction((lambda x_41#48551.label = maxRangeCoverage), lambda x_41#48551, false))[0].value END END, element_at(constraintValues#48329, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_42#48552.label = maxServiceLevelEndListing), lambda x_42#48552, false))[0]) THEN element_at(constraintValues#48329, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_42#48553.label = maxServiceLevelEndListing), lambda x_42#48553, false))[0].isActive THEN filter(null, lambdafunction((lambda x_42#48554.label = maxServiceLevelEndListing), lambda x_42#48554, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_43#48555.label = lockedOrderQuantity), lambda x_43#48555, false))[0].isActive THEN filter(null, lambdafunction((lambda x_43#48556.label = lockedOrderQuantity), lambda x_43#48556, false))[0].value END) AS constraintValues#48545, constraintRanks#48330, array(coalesce(filter(null, lambdafunction((lambda x_35#48506.label = minServiceLevel), lambda x_35#48506, false))[0].isActive, element_at(constraintIsActive#48331, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_36#48507.label = maxRangeCoverage), lambda x_36#48507, false))[0].isActive, element_at(constraintIsActive#48331, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_37#48508.label = minOrderQuantity), lambda x_37#48508, false))[0].isActive, element_at(constraintIsActive#48331, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_38#48509.label = maxServiceLevelEndListing), lambda x_38#48509, false))[0].isActive, element_at(constraintIsActive#48331, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_39#48510.label = lockedOrderQuantity), lambda x_39#48510, false))[0].isActive, false)) AS constraintIsActive#48505]
Input [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, constraintValues#48329, constraintRanks#48330, constraintIsActive#48331]
(126) Project
Output [36]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, productInformation#47280.unitOfMeasures AS _extract_unitOfMeasures#49723, productInformation#47280.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, CASE WHEN element_at(constraintIsActive#48505, 3, None, false) THEN element_at(constraintValues#48545, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, sos#46886.purchasingPriceAspect.netPrice.amount AS netPriceAmount#48659, sos#46886.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#48695, sos#46886.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#48732, sos#46886.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#48770, sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#48809, struct(value, CASE WHEN (sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#47407) THEN (sos#46886.purchasingPriceAspect.netPrice.amount / sos#46886.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#46886.purchasingPriceAspect.netPrice.amount / sos#46886.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#47854, lambdafunction((lambda x_44#48897.uomUuid = sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_44#48897, false))[0].denominator as double)) / cast(filter(logisticUnits#47854, lambdafunction((lambda x_44#48898.uomUuid = sos#46886.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_44#48898, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#46886.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#48896]
Input [29]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, sos#46886, externalProductId#47066, externalPlantId#47099, productInformation#47280, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505]
(127) Project
Output [2]: [internalUUID#48880, isoCode#48884.code AS _extract_code#49701]
Input [3]: [internalUUID#48880, isoCode#48884, systemId#48879]
(128) Exchange
Input [2]: [internalUUID#48880, _extract_code#49701]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14357]
(129) BroadcastExchange
Input [2]: [internalUUID#48880, _extract_code#49701]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=14402]
(130) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#48939.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#48939, false))[0].productDimensions, lambdafunction((lambda x_46#48941.dimensionName.code = VOLUME), lambda x_46#48941, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#48880, ), isnull(internalUUID#48880)]
Join type: LeftOuter
Join condition: None
(131) Project
Output [37]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, CURRENCY#48896, struct(value, cast(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#49041.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#49041, false))[0].productDimensions, lambdafunction((lambda x_46#49047.dimensionName.code = VOLUME), lambda x_46#49047, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#49042.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#49042, false))[0].productDimensions, lambdafunction((lambda x_46#49048.dimensionName.code = VOLUME), lambda x_46#49048, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_45#49043.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_45#49043, false))[0].productDimensions, lambdafunction((lambda x_46#49049.dimensionName.code = VOLUME), lambda x_46#49049, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#49701) AS VOLUME#49037]
Input [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, CURRENCY#48896, internalUUID#48880, _extract_code#49701]
(132) Scan parquet
Output [3]: [internalUUID#49091, isoCode#49095, systemId#49090]
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>>
(133) Project
Output [2]: [internalUUID#49091, isoCode#49095.code AS _extract_code#49700]
Input [3]: [internalUUID#49091, isoCode#49095, systemId#49090]
(134) Exchange
Input [2]: [internalUUID#49091, _extract_code#49700]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14362]
(135) BroadcastExchange
Input [2]: [internalUUID#49091, _extract_code#49700]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=14406]
(136) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49097.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49097, false))[0].productDimensions, lambdafunction((lambda x_48#49099.dimensionName.code = GROSS_WT), lambda x_48#49099, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#49091, ), isnull(internalUUID#49091)]
Join type: LeftOuter
Join condition: None
(137) Project
Output [34]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, filter(array(CURRENCY#48896, VOLUME#49037, struct(value, cast(filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49201.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49201, false))[0].productDimensions, lambdafunction((lambda x_48#49207.dimensionName.code = GROSS_WT), lambda x_48#49207, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49202.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49202, false))[0].productDimensions, lambdafunction((lambda x_48#49208.dimensionName.code = GROSS_WT), lambda x_48#49208, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#49723, lambdafunction((lambda x_47#49203.measurementUnit.internalRefUUID = _extract_internalRefUUID#49724), lambda x_47#49203, false))[0].productDimensions, lambdafunction((lambda x_48#49209.dimensionName.code = GROSS_WT), lambda x_48#49209, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#49700)), lambdafunction(isnotnull(lambda x_49#49252.value), lambda x_49#49252, false)) AS measurements#49251]
Input [39]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, _extract_unitOfMeasures#49723, _extract_internalRefUUID#49724, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, CURRENCY#48896, VOLUME#49037, internalUUID#49091, _extract_code#49700]
(138) Exchange
Input [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=14366]
(139) BroadcastExchange
Input [6]: [supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
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[4, string, true], ), isnull(input[4, 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=14410]
(140) BroadcastHashJoin
Left keys [10]: [coalesce(supplierGroup#46713, ), isnull(supplierGroup#46713), coalesce(supplier#46714, ), isnull(supplier#46714), coalesce(subrange#46717, ), isnull(subrange#46717), coalesce(plant#46715, ), isnull(plant#46715), coalesce(deliveryDateTime#46716, 1970-01-01 00:00:00), isnull(deliveryDateTime#46716)]
Right keys [10]: [coalesce(supplierGroup#49333, ), isnull(supplierGroup#49333), coalesce(supplier#49334, ), isnull(supplier#49334), coalesce(subrange#49337, ), isnull(subrange#49337), coalesce(plant#49335, ), isnull(plant#49335), coalesce(deliveryDateTime#49336, 1970-01-01 00:00:00), isnull(deliveryDateTime#49336)]
Join type: LeftOuter
Join condition: None
(141) Project
Output [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#48327, [GE,LE,GE,LE,EQ] AS constraintOperators#48328, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, null AS originalReplenishmentRunId#49292L, coalesce(optimizationGroups#49338, []) AS optimizationGroups#49479]
Input [40]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, supplierGroup#49333, supplier#49334, plant#49335, deliveryDateTime#49336, subrange#49337, optimizationGroups#49338]
(142) AdaptiveSparkPlan
Output [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintLabels#48327, constraintOperators#48328, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, originalReplenishmentRunId#49292L, optimizationGroups#49479]
Arguments: isFinalPlan=true
(143) TableCacheQueryStage
Output [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintLabels#48327, constraintOperators#48328, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, originalReplenishmentRunId#49292L, optimizationGroups#49479]
Arguments: 0
(144) WriteFiles
Input [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintLabels#48327, constraintOperators#48328, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, originalReplenishmentRunId#49292L, optimizationGroups#49479]
(145) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000096/shardId=0_1_10000000096, false, Parquet, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000096/shardId=0_1_10000000096], Overwrite, [orderProposalId, orderProposalItemId, supplierGroup, supplier, plant, deliveryDateTime, subrange, product, orderDateTime, availabilityDateTime, nextAvailabilityDateTime, mrpController, sourceOfSupplyUuid, purchasingOrg, purchasingGroup, orderProposalHorizonGroupingId, splitIndicator, worklistShardItemId, orderProposalItemGroupId, externalProductId, externalPlantId, logisticUnits, orderQuantityBaseUom, orderQuantityBaseUomUuid, ... 14 more fields]
(146) WriteFiles
Input [38]: [orderProposalId#46726L, orderProposalItemId#46731, supplierGroup#46713, supplier#46714, plant#46715, deliveryDateTime#46716, subrange#46717, product#46718, orderDateTime#46719, availabilityDateTime#46720, nextAvailabilityDateTime#46721, mrpController#46722, sourceOfSupplyUuid#46723, purchasingOrg#46724, purchasingGroup#46725, orderProposalHorizonGroupingId#46727L, splitIndicator#46728L, worklistShardItemId#46729L, orderProposalItemGroupId#46730, externalProductId#47066, externalPlantId#47099, logisticUnits#47854, orderQuantityBaseUom#47379, orderQuantityBaseUomUuid#47407, minimumOrderQuantity#48591, constraintLabels#48327, constraintOperators#48328, constraintValues#48545, constraintRanks#48330, constraintIsActive#48505, netPriceAmount#48659, netPriceCurrencyCode#48695, netPriceQuantity#48732, netPriceQuantityUom#48770, netPriceQuantityUomUuid#48809, measurements#49251, originalReplenishmentRunId#49292L, optimizationGroups#49479]
(147) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000096/shardId=0_1_10000000096, false, Parquet, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000096/shardId=0_1_10000000096], Overwrite, [orderProposalId, orderProposalItemId, supplierGroup, supplier, plant, deliveryDateTime, subrange, product, orderDateTime, availabilityDateTime, nextAvailabilityDateTime, mrpController, sourceOfSupplyUuid, purchasingOrg, purchasingGroup, orderProposalHorizonGroupingId, splitIndicator, worklistShardItemId, orderProposalItemGroupId, externalProductId, externalPlantId, logisticUnits, orderQuantityBaseUom, orderQuantityBaseUomUuid, ... 14 more fields]
(148) AdaptiveSparkPlan
Output: []
Arguments: isFinalPlan=true