== 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#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintLabels#18867, constraintOperators#18868, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, originalReplenishmentRunId#19832L, optimizationGroups#20019]
Arguments: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 14 more fields]
(2) InMemoryRelation
Arguments: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 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#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 14 more fields]
+- *(14) BroadcastHashJoin [coalesce(supplierGroup#17253, ), isnull(supplierGroup#17253), coalesce(supplier#17254, ), isnull(supplier#17254), coalesce(subrange#17257, ), isnull(subrange#17257), coalesce(plant#17255, ), isnull(plant#17255), coalesce(deliveryDateTime#17256, 1970-01-01 00:00:00), isnull(deliveryDateTime#17256)], [coalesce(supplierGroup#19873, ), isnull(supplierGroup#19873), coalesce(supplier#19874, ), isnull(supplier#19874), coalesce(subrange#19877, ), isnull(subrange#19877), coalesce(plant#19875, ), isnull(plant#19875), coalesce(deliveryDateTime#19876, 1970-01-01 00:00:00), isnull(deliveryDateTime#19876)], LeftOuter, BuildRight, false
:- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 10 more fields]
: +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#19631, ), isnull(internalUUID#19631)], LeftOuter, BuildRight, false
: :- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, ... 13 more fields]
: : +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#19420, ), isnull(internalUUID#19420)], LeftOuter, BuildRight, false
: : :- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, productInformation#17820.unitOfMeasures AS _extract_unitOfMeasures#20263, productInformation#17820.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#20264, logisticUnits#18394, ... 12 more fields]
: : : +- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 5 more fields]
: : : +- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 5 more fields]
: : : +- BroadcastHashJoin [coalesce(constraintProfile#18490, ), isnull(constraintProfile#18490)], [coalesce(constraintProfile#18579, ), isnull(constraintProfile#18579)], LeftOuter, BuildRight, false
: : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 4 more fields]
: : : : +- BroadcastHashJoin [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255), coalesce(orderDateTime#17259, 1970-01-01 00:00:00), isnull(orderDateTime#17259)], [coalesce(product#18487, ), isnull(product#18487), coalesce(plant#18488, ), isnull(plant#18488), coalesce(orderDateTime#18489, 1970-01-01 00:00:00), isnull(orderDateTime#18489)], LeftOuter, BuildRight, false
: : : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 3 more fields]
: : : : : +- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18395.uom, uomUuid, lambda x_4#18395.uomUuid, numerator, lambda x_4#18395.numerator, denominator, lambda x_4#18395.denominator, isOrderUnit, lambda x_4#18395.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18395.uomUuid) THEN true ELSE lambda x_4#18395.isPreferred END), lambda x_4#18395, false)), lambdafunction(named_struct(uom, lambda x_6#18396.uom, uomUuid, lambda x_6#18396.uomUuid, numerator, lambda x_6#18396.numerator, denominator, lambda x_6#18396.denominator, isOrderUnit, lambda x_6#18396.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18397.uom, uomUuid, lambda x_4#18397.uomUuid, numerator, lambda x_4#18397.numerator, denominator, lambda x_4#18397.denominator, isOrderUnit, lambda x_4#18397.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18397.uomUuid) THEN true ELSE lambda x_4#18397.isPreferred END), lambda x_4#18397, false)), lambdafunction(lambda x_5#18398.isPreferred, lambda x_5#18398, false)), true) THEN lambda x_6#18396.isPreferred ELSE lambda x_6#18396.isOrderUnit END), lambda x_6#18396, false)) AS logisticUnits#18394, ... 2 more fields]
: : : : : +- *(13) Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, ... 4 more fields]
: : : : : +- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, ... 3 more fields]
: : : : : +- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, ... 5 more fields]
: : : : : +- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(coalesce(transform(filter(productInformation#17820.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#17820.unitOfMeasures, lambdafunction(lambda x_1#17892.measurementUnit.internalRefUUID, lambda x_1#17892, false)), lambda x_0#17889.measurementUnit1.internalRefUUID) AND (lambda x_0#17889.measurementUnit2.internalRefUUID = productInformation#17820.baseUnitOfMeasure.internalRefUUID)), lambda x_0#17889, false)), lambdafunction(struct(uom, lambda x_2#17893.measurementUnit1.code, uomUuid, lambda x_2#17893.measurementUnit1.internalRefUUID, numerator, lambda x_2#17893.quantityNumerator, denominator, lambda x_2#17893.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2#17893, false)), []), lambdafunction(named_struct(uom, lambda x_3#17977.uom, uomUuid, lambda x_3#17977.uomUuid, numerator, lambda x_3#17977.numerator, denominator, lambda x_3#17977.denominator, isOrderUnit, ((lambda x_3#17977.uomUuid = coalesce(sos#17426.orderQuantityUnit.internalRefUUID, productInformation#17820.procurementAspect.orderUnit.internalRefUUID, productInformation#17820.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_3#17977.isPreferred), lambda x_3#17977, false)) AS logisticUnits#17976, ... 3 more fields]
: : : : : +- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, CASE WHEN isnotnull(internalUUID#17727) THEN struct(systemId, systemId#17726, internalUUID, internalUUID#17727, id, id#17728, displayId, displayId#17729, name, name#17730, baseUnitOfMeasure, baseUnitOfMeasure#17731, unitOfMeasures, unitOfMeasures#17732, unitOfMeasureConversions, unitOfMeasureConversions#17733, productionAspect, productionAspect#17734, salesAspect, salesAspect#17735, procurementAspect, procurementAspect#17736, productGroup, productGroup#17737) END AS productInformation#17820]
: : : : : +- BroadcastHashJoin [product#17258], [internalUUID#17727], LeftOuter, BuildRight, false
: : : : : :- *(12) Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, CASE WHEN isnotnull(productionAspect#17500) THEN struct(systemId, systemId#17495, internalUUID, internalUUID#17496, plant, plant#17497, product, product#17498, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#17499, productionAspect, productionAspect#17500, salesPlant, salesPlant#17501, listing, listing#17502, sourceOfSupplyCategory, sourceOfSupplyCategory#17503) END AS productPlant#17575, product#17498.id AS externalProductId#17606, plant#17497.id AS externalPlantId#17639]
: : : : : : +- *(12) BroadcastHashJoin [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255)], [coalesce(product#17498.internalRefUUID, ), isnull(product#17498.internalRefUUID), coalesce(plant#17497.internalRefUUID, ), isnull(plant#17497.internalRefUUID)], LeftOuter, BuildRight, false
: : : : : : :- *(12) Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, struct(systemId, systemId#17292, internalUUID, internalUUID#17293, supplier, supplier#17294, receiver, receiver#17295, product, product#17296, receivingPlant, receivingPlant#17297, sourceOfSupplyType, sourceOfSupplyType#17298, purchasingGroup, purchasingGroup#17299, purchasingOrganization, purchasingOrganization#17300, productGroup, productGroup#17301, validFrom, validFrom#17302, validTo, validTo#17303, ... 24 more fields) AS sos#17426]
: : : : : : : +- *(12) BroadcastHashJoin [coalesce(sourceOfSupplyUuid#17263, ), isnull(sourceOfSupplyUuid#17263)], [coalesce(internalUUID#17293, ), isnull(internalUUID#17293)], LeftOuter, BuildRight, false
: : : : : : : :- ShuffleQueryStage 0
: : : : : : : : +- Exchange hashpartitioning(product#17258, plant#17255, 25), REPARTITION_BY_NUM, [plan_id=5949]
: : : : : : : : +- *(1) ColumnarToRow
: : : : : : : : +- FileScan parquet [supplierGroup#17253,supplier#17254,plant#17255,deliveryDateTime#17256,subrange#17257,product#17258,orderDateTime#17259,availabilityDateTime#17260,nextAvailabilityDateTime#17261,mrpController#17262,sourceOfSupplyUuid#17263,purchasingOrg#17264,purchasingGroup#17265,orderProposalId#17266L,orderProposalHorizonGroupingId#17267L,splitIndicator#17268L,worklistShardItemId#17269L,orderProposalItemGroupId#17270,orderProposalItemId#17271] 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 17
: : : : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=6746]
: : : : : : : +- ShuffleQueryStage 1
: : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5968]
: : : : : : : +- *(2) Project [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
: : : : : : : +- *(2) ColumnarToRow
: : : : : : : +- FileScan parquet [internalUUID#17293,supplier#17294,receiver#17295,product#17296,receivingPlant#17297,sourceOfSupplyType#17298,purchasingGroup#17299,purchasingOrganization#17300,productGroup#17301,validFrom#17302,validTo#17303,priority#17304,isPurchasingBlocked#17305,isConsignment#17306,isDeleted#17307,supplierSubrange#17308,plannedDeliveryTimeDays#17309,orderQuantityUnit#17310,purchasingPriceAspect#17311,orderCurrency#17312,minimumOrderQuantity#17313,logisticalRoundingProfile#17314,supplyingPlant#17315,systemId#17292] 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 15
: : : : : : +- 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=6005]
: : : : : : +- ShuffleQueryStage 2
: : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5995]
: : : : : : +- *(3) Project [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
: : : : : : +- *(3) Filter plant#17497.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
: : : : : : +- *(3) ColumnarToRow
: : : : : : +- FileScan parquet [internalUUID#17496,plant#17497,product#17498,blockedForReplenishmentStartingFrom#17499,productionAspect#17500,salesPlant#17501,listing#17502,sourceOfSupplyCategory#17503,systemId#17495] Batched: true, DataFilters: [plant#17497.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 18
: : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=6752]
: : : : : +- ShuffleQueryStage 3
: : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6024]
: : : : : +- *(4) Project [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
: : : : : +- *(4) Filter isnotnull(internalUUID#17727)
: : : : : +- *(4) ColumnarToRow
: : : : : +- FileScan parquet [internalUUID#17727,id#17728,displayId#17729,name#17730,baseUnitOfMeasure#17731,unitOfMeasures#17732,unitOfMeasureConversions#17733,productionAspect#17734,salesAspect#17735,procurementAspect#17736,productGroup#17737,systemId#17726] Batched: true, DataFilters: [isnotnull(internalUUID#17727)], 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 14
: : : : +- 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=6074]
: : : : +- ShuffleQueryStage 6
: : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6068]
: : : : +- *(5) ColumnarToRow
: : : : +- FileScan parquet [product#18487,plant#18488,orderDateTime#18489,constraintprofile#18490] 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=6764]
: : : +- ShuffleQueryStage 7
: : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6089]
: : : +- *(6) Project [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584.isActive AS _extract_isActive#20265, maxRangeCoverage#18584.range AS _extract_range#20266, maxRangeCoverage#18584.rank AS _extract_rank#20267, minOrderQuantity#18585]
: : : +- *(6) ColumnarToRow
: : : +- FileScan parquet [constraintProfile#18579,minServiceLevel#18581,maxServiceLevelEndListing#18583,maxRangeCoverage#18584,minOrderQuantity#18585] 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 19
: : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=6770]
: : +- ShuffleQueryStage 8
: : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6114]
: : +- *(7) Project [internalUUID#19420, isoCode#19424.code AS _extract_code#20241]
: : +- *(7) ColumnarToRow
: : +- FileScan parquet [internalUUID#19420,isoCode#19424,systemId#19419] 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 20
: +- ReusedExchange [internalUUID#19631, _extract_code#20240], BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=6770]
+- 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=6778]
+- ShuffleQueryStage 11
+- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6158]
+- *(9) ColumnarToRow
+- FileScan parquet [supplierGroup#19873,supplier#19874,plant#19875,deliveryDateTime#19876,subrange#19877,optimizationGroups#19878] 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#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 14 more fields]
+- BroadcastHashJoin [coalesce(supplierGroup#17253, ), isnull(supplierGroup#17253), coalesce(supplier#17254, ), isnull(supplier#17254), coalesce(subrange#17257, ), isnull(subrange#17257), coalesce(plant#17255, ), isnull(plant#17255), coalesce(deliveryDateTime#17256, 1970-01-01 00:00:00), isnull(deliveryDateTime#17256)], [coalesce(supplierGroup#19873, ), isnull(supplierGroup#19873), coalesce(supplier#19874, ), isnull(supplier#19874), coalesce(subrange#19877, ), isnull(subrange#19877), coalesce(plant#19875, ), isnull(plant#19875), coalesce(deliveryDateTime#19876, 1970-01-01 00:00:00), isnull(deliveryDateTime#19876)], LeftOuter, BuildRight, false
:- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ... 10 more fields]
: +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#19631, ), isnull(internalUUID#19631)], LeftOuter, BuildRight, false
: :- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, ... 13 more fields]
: : +- BroadcastHashJoin [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID)], [coalesce(internalUUID#19420, ), isnull(internalUUID#19420)], LeftOuter, BuildRight, false
: : :- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, productInformation#17820.unitOfMeasures AS _extract_unitOfMeasures#20263, productInformation#17820.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#20264, logisticUnits#18394, ... 12 more fields]
: : : +- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 5 more fields]
: : : +- Project [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 5 more fields]
: : : +- BroadcastHashJoin [coalesce(constraintProfile#18490, ), isnull(constraintProfile#18490)], [coalesce(constraintProfile#18579, ), isnull(constraintProfile#18579)], LeftOuter, BuildRight, false
: : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 4 more fields]
: : : : +- BroadcastHashJoin [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255), coalesce(orderDateTime#17259, 1970-01-01 00:00:00), isnull(orderDateTime#17259)], [coalesce(product#18487, ), isnull(product#18487), coalesce(plant#18488, ), isnull(plant#18488), coalesce(orderDateTime#18489, 1970-01-01 00:00:00), isnull(orderDateTime#18489)], LeftOuter, BuildRight, false
: : : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, ... 3 more fields]
: : : : : +- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18395.uom, uomUuid, lambda x_4#18395.uomUuid, numerator, lambda x_4#18395.numerator, denominator, lambda x_4#18395.denominator, isOrderUnit, lambda x_4#18395.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18395.uomUuid) THEN true ELSE lambda x_4#18395.isPreferred END), lambda x_4#18395, false)), lambdafunction(named_struct(uom, lambda x_6#18396.uom, uomUuid, lambda x_6#18396.uomUuid, numerator, lambda x_6#18396.numerator, denominator, lambda x_6#18396.denominator, isOrderUnit, lambda x_6#18396.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18397.uom, uomUuid, lambda x_4#18397.uomUuid, numerator, lambda x_4#18397.numerator, denominator, lambda x_4#18397.denominator, isOrderUnit, lambda x_4#18397.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18397.uomUuid) THEN true ELSE lambda x_4#18397.isPreferred END), lambda x_4#18397, false)), lambdafunction(lambda x_5#18398.isPreferred, lambda x_5#18398, false)), true) THEN lambda x_6#18396.isPreferred ELSE lambda x_6#18396.isOrderUnit END), lambda x_6#18396, false)) AS logisticUnits#18394, ... 2 more fields]
: : : : : +- BroadcastHashJoin [coalesce(preferredRoundingProfile#18008, ), isnull(preferredRoundingProfile#18008)], [coalesce(logisticalRoundingProfile#18135, ), isnull(logisticalRoundingProfile#18135)], LeftOuter, BuildRight, false
: : : : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, ... 3 more fields]
: : : : : : +- BroadcastHashJoin [coalesce(preferredRoundingProfile#18008, ), isnull(preferredRoundingProfile#18008), coalesce(plant#17255, ), isnull(plant#17255)], [coalesce(logisticalRoundingProfile#18039, ), isnull(logisticalRoundingProfile#18039), coalesce(_extract_internalRefUUID#20242, ), isnull(_extract_internalRefUUID#20242)], LeftOuter, BuildRight, false
: : : : : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(coalesce(transform(filter(productInformation#17820.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#17820.unitOfMeasures, lambdafunction(lambda x_1#17892.measurementUnit.internalRefUUID, lambda x_1#17892, false)), lambda x_0#17889.measurementUnit1.internalRefUUID) AND (lambda x_0#17889.measurementUnit2.internalRefUUID = productInformation#17820.baseUnitOfMeasure.internalRefUUID)), lambda x_0#17889, false)), lambdafunction(struct(uom, lambda x_2#17893.measurementUnit1.code, uomUuid, lambda x_2#17893.measurementUnit1.internalRefUUID, numerator, lambda x_2#17893.quantityNumerator, denominator, lambda x_2#17893.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2#17893, false)), []), lambdafunction(named_struct(uom, lambda x_3#17977.uom, uomUuid, lambda x_3#17977.uomUuid, numerator, lambda x_3#17977.numerator, denominator, lambda x_3#17977.denominator, isOrderUnit, ((lambda x_3#17977.uomUuid = coalesce(sos#17426.orderQuantityUnit.internalRefUUID, productInformation#17820.procurementAspect.orderUnit.internalRefUUID, productInformation#17820.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_3#17977.isPreferred), lambda x_3#17977, false)) AS logisticUnits#17976, ... 3 more fields]
: : : : : : : +- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, CASE WHEN isnotnull(internalUUID#17727) THEN struct(systemId, systemId#17726, internalUUID, internalUUID#17727, id, id#17728, displayId, displayId#17729, name, name#17730, baseUnitOfMeasure, baseUnitOfMeasure#17731, unitOfMeasures, unitOfMeasures#17732, unitOfMeasureConversions, unitOfMeasureConversions#17733, productionAspect, productionAspect#17734, salesAspect, salesAspect#17735, procurementAspect, procurementAspect#17736, productGroup, productGroup#17737) END AS productInformation#17820]
: : : : : : : +- BroadcastHashJoin [product#17258], [internalUUID#17727], LeftOuter, BuildRight, false
: : : : : : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, CASE WHEN isnotnull(productionAspect#17500) THEN struct(systemId, systemId#17495, internalUUID, internalUUID#17496, plant, plant#17497, product, product#17498, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#17499, productionAspect, productionAspect#17500, salesPlant, salesPlant#17501, listing, listing#17502, sourceOfSupplyCategory, sourceOfSupplyCategory#17503) END AS productPlant#17575, product#17498.id AS externalProductId#17606, plant#17497.id AS externalPlantId#17639]
: : : : : : : : +- BroadcastHashJoin [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255)], [coalesce(product#17498.internalRefUUID, ), isnull(product#17498.internalRefUUID), coalesce(plant#17497.internalRefUUID, ), isnull(plant#17497.internalRefUUID)], LeftOuter, BuildRight, false
: : : : : : : : :- Project [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, struct(systemId, systemId#17292, internalUUID, internalUUID#17293, supplier, supplier#17294, receiver, receiver#17295, product, product#17296, receivingPlant, receivingPlant#17297, sourceOfSupplyType, sourceOfSupplyType#17298, purchasingGroup, purchasingGroup#17299, purchasingOrganization, purchasingOrganization#17300, productGroup, productGroup#17301, validFrom, validFrom#17302, validTo, validTo#17303, ... 24 more fields) AS sos#17426]
: : : : : : : : : +- BroadcastHashJoin [coalesce(sourceOfSupplyUuid#17263, ), isnull(sourceOfSupplyUuid#17263)], [coalesce(internalUUID#17293, ), isnull(internalUUID#17293)], LeftOuter, BuildRight, false
: : : : : : : : : :- Exchange hashpartitioning(product#17258, plant#17255, 25), REPARTITION_BY_NUM, [plan_id=5408]
: : : : : : : : : : +- FileScan parquet [supplierGroup#17253,supplier#17254,plant#17255,deliveryDateTime#17256,subrange#17257,product#17258,orderDateTime#17259,availabilityDateTime#17260,nextAvailabilityDateTime#17261,mrpController#17262,sourceOfSupplyUuid#17263,purchasingOrg#17264,purchasingGroup#17265,orderProposalId#17266L,orderProposalHorizonGroupingId#17267L,splitIndicator#17268L,worklistShardItemId#17269L,orderProposalItemGroupId#17270,orderProposalItemId#17271] 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=5463]
: : : : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5411]
: : : : : : : : : +- Project [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
: : : : : : : : : +- FileScan parquet [internalUUID#17293,supplier#17294,receiver#17295,product#17296,receivingPlant#17297,sourceOfSupplyType#17298,purchasingGroup#17299,purchasingOrganization#17300,productGroup#17301,validFrom#17302,validTo#17303,priority#17304,isPurchasingBlocked#17305,isConsignment#17306,isDeleted#17307,supplierSubrange#17308,plannedDeliveryTimeDays#17309,orderQuantityUnit#17310,purchasingPriceAspect#17311,orderCurrency#17312,minimumOrderQuantity#17313,logisticalRoundingProfile#17314,supplyingPlant#17315,systemId#17292] 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=5467]
: : : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5417]
: : : : : : : : +- Project [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
: : : : : : : : +- Filter plant#17497.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
: : : : : : : : +- FileScan parquet [internalUUID#17496,plant#17497,product#17498,blockedForReplenishmentStartingFrom#17499,productionAspect#17500,salesPlant#17501,listing#17502,sourceOfSupplyCategory#17503,systemId#17495] Batched: true, DataFilters: [plant#17497.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=5471]
: : : : : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5423]
: : : : : : : +- Project [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
: : : : : : : +- Filter isnotnull(internalUUID#17727)
: : : : : : : +- FileScan parquet [internalUUID#17727,id#17728,displayId#17729,name#17730,baseUnitOfMeasure#17731,unitOfMeasures#17732,unitOfMeasureConversions#17733,productionAspect#17734,salesAspect#17735,procurementAspect#17736,productGroup#17737,systemId#17726] Batched: true, DataFilters: [isnotnull(internalUUID#17727)], 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=5476]
: : : : : : +- Project [logisticalRoundingProfile#18039, plant#18040.internalRefUUID AS _extract_internalRefUUID#20242]
: : : : : : +- InMemoryTableScan [logisticalRoundingProfile#18039, plant#18040]
: : : : : : +- InMemoryRelation [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041], StorageLevel(disk, memory, 2 replicas)
: : : : : : +- LocalTableScan <empty>, [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041]
: : : : : +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=5480]
: : : : : +- Project [logisticalRoundingProfile#18135]
: : : : : +- Filter isnull(plant#18136.internalRefUUID)
: : : : : +- InMemoryTableScan [logisticalRoundingProfile#18135, plant#18136], [isnull(plant#18136.internalRefUUID)]
: : : : : +- InMemoryRelation [logisticalRoundingProfile#18135, plant#18136, logisticalRoundingRule#18137], StorageLevel(disk, memory, 2 replicas)
: : : : : +- LocalTableScan <empty>, [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041]
: : : : +- 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=5485]
: : : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5438]
: : : : +- FileScan parquet [product#18487,plant#18488,orderDateTime#18489,constraintprofile#18490] 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=5489]
: : : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5443]
: : : +- Project [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584.isActive AS _extract_isActive#20265, maxRangeCoverage#18584.range AS _extract_range#20266, maxRangeCoverage#18584.rank AS _extract_rank#20267, minOrderQuantity#18585]
: : : +- FileScan parquet [constraintProfile#18579,minServiceLevel#18581,maxServiceLevelEndListing#18583,maxRangeCoverage#18584,minOrderQuantity#18585] 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=5495]
: : +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5450]
: : +- Project [internalUUID#19420, isoCode#19424.code AS _extract_code#20241]
: : +- FileScan parquet [internalUUID#19420,isoCode#19424,systemId#19419] 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=5499]
: +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5455]
: +- Project [internalUUID#19631, isoCode#19635.code AS _extract_code#20240]
: +- FileScan parquet [internalUUID#19631,isoCode#19635,systemId#19630] 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=5503]
+- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5459]
+- FileScan parquet [supplierGroup#19873,supplier#19874,plant#19875,deliveryDateTime#19876,subrange#19877,optimizationGroups#19878] 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#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271]
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/10000000095/shardId=0_1_10000000095]
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#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271]
(5) Exchange
Input [19]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271]
Arguments: hashpartitioning(product#17258, plant#17255, 25), REPARTITION_BY_NUM, [plan_id=5949]
(6) ShuffleQueryStage
Output [19]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271]
Arguments: 0
(7) Scan parquet
Output [24]: [internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315, systemId#17292]
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#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315, systemId#17292]
(9) Project [codegen id : 2]
Output [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Input [24]: [internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315, systemId#17292]
(10) Exchange
Input [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5968]
(11) ShuffleQueryStage
Output [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Arguments: 1
(12) BroadcastExchange
Input [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=6746]
(13) BroadcastQueryStage
Output [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Arguments: 17
(14) BroadcastHashJoin [codegen id : 12]
Left keys [2]: [coalesce(sourceOfSupplyUuid#17263, ), isnull(sourceOfSupplyUuid#17263)]
Right keys [2]: [coalesce(internalUUID#17293, ), isnull(internalUUID#17293)]
Join type: LeftOuter
Join condition: None
(15) Project [codegen id : 12]
Output [20]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, struct(systemId, systemId#17292, internalUUID, internalUUID#17293, supplier, supplier#17294, receiver, receiver#17295, product, product#17296, receivingPlant, receivingPlant#17297, sourceOfSupplyType, sourceOfSupplyType#17298, purchasingGroup, purchasingGroup#17299, purchasingOrganization, purchasingOrganization#17300, productGroup, productGroup#17301, validFrom, validFrom#17302, validTo, validTo#17303, ... 24 more fields) AS sos#17426]
Input [43]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
(16) Scan parquet
Output [9]: [internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503, systemId#17495]
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#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503, systemId#17495]
(18) Filter [codegen id : 3]
Input [9]: [internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503, systemId#17495]
Condition : plant#17497.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
(19) Project [codegen id : 3]
Output [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
Input [9]: [internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503, systemId#17495]
(20) Exchange
Input [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5995]
(21) ShuffleQueryStage
Output [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
Arguments: 2
(22) BroadcastExchange
Input [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
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=6005]
(23) BroadcastQueryStage
Output [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
Arguments: 15
(24) BroadcastHashJoin [codegen id : 12]
Left keys [4]: [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255)]
Right keys [4]: [coalesce(product#17498.internalRefUUID, ), isnull(product#17498.internalRefUUID), coalesce(plant#17497.internalRefUUID, ), isnull(plant#17497.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(25) Project [codegen id : 12]
Output [23]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, CASE WHEN isnotnull(productionAspect#17500) THEN struct(systemId, systemId#17495, internalUUID, internalUUID#17496, plant, plant#17497, product, product#17498, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#17499, productionAspect, productionAspect#17500, salesPlant, salesPlant#17501, listing, listing#17502, sourceOfSupplyCategory, sourceOfSupplyCategory#17503) END AS productPlant#17575, product#17498.id AS externalProductId#17606, plant#17497.id AS externalPlantId#17639]
Input [29]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
(26) Scan parquet
Output [12]: [internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737, systemId#17726]
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#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737, systemId#17726]
(28) Filter [codegen id : 4]
Input [12]: [internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737, systemId#17726]
Condition : isnotnull(internalUUID#17727)
(29) Project [codegen id : 4]
Output [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Input [12]: [internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737, systemId#17726]
(30) Exchange
Input [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6024]
(31) ShuffleQueryStage
Output [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Arguments: 3
(32) BroadcastExchange
Input [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=6752]
(33) BroadcastQueryStage
Output [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Arguments: 18
(34) BroadcastHashJoin
Left keys [1]: [product#17258]
Right keys [1]: [internalUUID#17727]
Join type: LeftOuter
Join condition: None
(35) Project
Output [24]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, CASE WHEN isnotnull(internalUUID#17727) THEN struct(systemId, systemId#17726, internalUUID, internalUUID#17727, id, id#17728, displayId, displayId#17729, name, name#17730, baseUnitOfMeasure, baseUnitOfMeasure#17731, unitOfMeasures, unitOfMeasures#17732, unitOfMeasureConversions, unitOfMeasureConversions#17733, productionAspect, productionAspect#17734, salesAspect, salesAspect#17735, procurementAspect, procurementAspect#17736, productGroup, productGroup#17737) END AS productInformation#17820]
Input [35]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
(36) Project
Output [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(coalesce(transform(filter(productInformation#17820.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#17820.unitOfMeasures, lambdafunction(lambda x_1#17892.measurementUnit.internalRefUUID, lambda x_1#17892, false)), lambda x_0#17889.measurementUnit1.internalRefUUID) AND (lambda x_0#17889.measurementUnit2.internalRefUUID = productInformation#17820.baseUnitOfMeasure.internalRefUUID)), lambda x_0#17889, false)), lambdafunction(struct(uom, lambda x_2#17893.measurementUnit1.code, uomUuid, lambda x_2#17893.measurementUnit1.internalRefUUID, numerator, lambda x_2#17893.quantityNumerator, denominator, lambda x_2#17893.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2#17893, false)), []), lambdafunction(named_struct(uom, lambda x_3#17977.uom, uomUuid, lambda x_3#17977.uomUuid, numerator, lambda x_3#17977.numerator, denominator, lambda x_3#17977.denominator, isOrderUnit, ((lambda x_3#17977.uomUuid = coalesce(sos#17426.orderQuantityUnit.internalRefUUID, productInformation#17820.procurementAspect.orderUnit.internalRefUUID, productInformation#17820.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_3#17977.isPreferred), lambda x_3#17977, false)) AS logisticUnits#17976, productInformation#17820.baseUnitOfMeasure.code AS orderQuantityBaseUom#17919, productInformation#17820.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#17947, coalesce(sos#17426.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#17575.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) AS preferredRoundingProfile#18008]
Input [24]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, productInformation#17820]
(37) Project
Output [29]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008, cast(null as string) AS logisticalRoundingProfile#18039, cast(null as string) AS _extract_internalRefUUID#20242]
Input [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008]
(38) Project
Output [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008]
Input [29]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008, logisticalRoundingProfile#18039, _extract_internalRefUUID#20242]
(39) Project [codegen id : 13]
Output [28]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008, cast(null as string) AS logisticalRoundingProfile#18135]
Input [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008]
(40) Project
Output [26]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18395.uom, uomUuid, lambda x_4#18395.uomUuid, numerator, lambda x_4#18395.numerator, denominator, lambda x_4#18395.denominator, isOrderUnit, lambda x_4#18395.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18395.uomUuid) THEN true ELSE lambda x_4#18395.isPreferred END), lambda x_4#18395, false)), lambdafunction(named_struct(uom, lambda x_6#18396.uom, uomUuid, lambda x_6#18396.uomUuid, numerator, lambda x_6#18396.numerator, denominator, lambda x_6#18396.denominator, isOrderUnit, lambda x_6#18396.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18397.uom, uomUuid, lambda x_4#18397.uomUuid, numerator, lambda x_4#18397.numerator, denominator, lambda x_4#18397.denominator, isOrderUnit, lambda x_4#18397.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18397.uomUuid) THEN true ELSE lambda x_4#18397.isPreferred END), lambda x_4#18397, false)), lambdafunction(lambda x_5#18398.isPreferred, lambda x_5#18398, false)), true) THEN lambda x_6#18396.isPreferred ELSE lambda x_6#18396.isOrderUnit END), lambda x_6#18396, false)) AS logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947]
Input [28]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008, logisticalRoundingProfile#18135]
(41) Project
Output [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ((sos#17426.minimumOrderQuantity * cast(filter(logisticUnits#18394, lambdafunction(lambda x#18457.isOrderUnit, lambda x#18457, false))[0].numerator as double)) / cast(filter(logisticUnits#18394, lambdafunction(lambda x#18458.isOrderUnit, lambda x#18458, false))[0].denominator as double)) AS minimumOrderQuantity#18455]
Input [26]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947]
(42) Scan parquet
Output [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000000095/0_1_10000000095/constraintprofile]
ReadSchema: struct<product:string,plant:string,orderDateTime:timestamp,constraintprofile:string>
(43) ColumnarToRow [codegen id : 5]
Input [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
(44) Exchange
Input [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6068]
(45) ShuffleQueryStage
Output [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
Arguments: 6
(46) BroadcastExchange
Input [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
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=6074]
(47) BroadcastQueryStage
Output [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
Arguments: 14
(48) BroadcastHashJoin
Left keys [6]: [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255), coalesce(orderDateTime#17259, 1970-01-01 00:00:00), isnull(orderDateTime#17259)]
Right keys [6]: [coalesce(product#18487, ), isnull(product#18487), coalesce(plant#18488, ), isnull(plant#18488), coalesce(orderDateTime#18489, 1970-01-01 00:00:00), isnull(orderDateTime#18489)]
Join type: LeftOuter
Join condition: None
(49) Project
Output [28]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#18455, constraintProfile#18490]
Input [31]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#18455, product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
(50) Scan parquet
Output [5]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584, minOrderQuantity#18585]
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#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584, minOrderQuantity#18585]
(52) Project [codegen id : 6]
Output [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584.isActive AS _extract_isActive#20265, maxRangeCoverage#18584.range AS _extract_range#20266, maxRangeCoverage#18584.rank AS _extract_rank#20267, minOrderQuantity#18585]
Input [5]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584, minOrderQuantity#18585]
(53) Exchange
Input [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6089]
(54) ShuffleQueryStage
Output [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
Arguments: 7
(55) BroadcastExchange
Input [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=6764]
(56) BroadcastQueryStage
Output [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
Arguments: 16
(57) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#18490, ), isnull(constraintProfile#18490)]
Right keys [2]: [coalesce(constraintProfile#18579, ), isnull(constraintProfile#18579)]
Join type: LeftOuter
Join condition: None
(58) Project
Output [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, array(CASE WHEN (minServiceLevel#18581.isActive <=> true) THEN minServiceLevel#18581.level END, CASE WHEN (_extract_isActive#20265 <=> true) THEN cast(_extract_range#20266 as double) END, coalesce(minimumOrderQuantity#18455, 0.0), CASE WHEN (maxServiceLevelEndListing#18583.isActive <=> true) THEN maxServiceLevelEndListing#18583.level END, null) AS constraintValues#18869, array(CASE WHEN (minServiceLevel#18581.isActive <=> true) THEN minServiceLevel#18581.rank ELSE 0 END, CASE WHEN (_extract_isActive#20265 <=> true) THEN _extract_rank#20267 ELSE 0 END, CASE WHEN (minOrderQuantity#18585.isActive <=> true) THEN minOrderQuantity#18585.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#18583.isActive <=> true) THEN maxServiceLevelEndListing#18583.rank ELSE 0 END, 0) AS constraintRanks#18870, array((minServiceLevel#18581.isActive <=> true), (_extract_isActive#20265 <=> true), (minOrderQuantity#18585.isActive <=> true), (maxServiceLevelEndListing#18583.isActive <=> true), false) AS constraintIsActive#18871]
Input [35]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#18455, constraintProfile#18490, constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
(59) Project
Output [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_14#19086.label = minServiceLevel), lambda x_14#19086, false))[0]) THEN element_at(constraintValues#18869, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_14#19087.label = minServiceLevel), lambda x_14#19087, false))[0].isActive THEN filter(null, lambdafunction((lambda x_14#19088.label = minServiceLevel), lambda x_14#19088, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_15#19089.label = maxRangeCoverage), lambda x_15#19089, false))[0]) THEN element_at(constraintValues#18869, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_15#19090.label = maxRangeCoverage), lambda x_15#19090, false))[0].isActive THEN filter(null, lambdafunction((lambda x_15#19091.label = maxRangeCoverage), lambda x_15#19091, false))[0].value END END, element_at(constraintValues#18869, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_16#19092.label = maxServiceLevelEndListing), lambda x_16#19092, false))[0]) THEN element_at(constraintValues#18869, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_16#19093.label = maxServiceLevelEndListing), lambda x_16#19093, false))[0].isActive THEN filter(null, lambdafunction((lambda x_16#19094.label = maxServiceLevelEndListing), lambda x_16#19094, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_17#19095.label = lockedOrderQuantity), lambda x_17#19095, false))[0].isActive THEN filter(null, lambdafunction((lambda x_17#19096.label = lockedOrderQuantity), lambda x_17#19096, false))[0].value END) AS constraintValues#19085, constraintRanks#18870, array(coalesce(filter(null, lambdafunction((lambda x_9#19046.label = minServiceLevel), lambda x_9#19046, false))[0].isActive, element_at(constraintIsActive#18871, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_10#19047.label = maxRangeCoverage), lambda x_10#19047, false))[0].isActive, element_at(constraintIsActive#18871, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_11#19048.label = minOrderQuantity), lambda x_11#19048, false))[0].isActive, element_at(constraintIsActive#18871, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_12#19049.label = maxServiceLevelEndListing), lambda x_12#19049, false))[0].isActive, element_at(constraintIsActive#18871, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_13#19050.label = lockedOrderQuantity), lambda x_13#19050, false))[0].isActive, false)) AS constraintIsActive#19045]
Input [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, constraintValues#18869, constraintRanks#18870, constraintIsActive#18871]
(60) Project
Output [36]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, productInformation#17820.unitOfMeasures AS _extract_unitOfMeasures#20263, productInformation#17820.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, CASE WHEN element_at(constraintIsActive#19045, 3, None, false) THEN element_at(constraintValues#19085, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, sos#17426.purchasingPriceAspect.netPrice.amount AS netPriceAmount#19199, sos#17426.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#19235, sos#17426.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#19272, sos#17426.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#19310, sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#19349, struct(value, CASE WHEN (sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#17947) THEN (sos#17426.purchasingPriceAspect.netPrice.amount / sos#17426.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#17426.purchasingPriceAspect.netPrice.amount / sos#17426.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#18394, lambdafunction((lambda x_18#19437.uomUuid = sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_18#19437, false))[0].denominator as double)) / cast(filter(logisticUnits#18394, lambdafunction((lambda x_18#19438.uomUuid = sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_18#19438, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#17426.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#19436]
Input [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045]
(61) Scan parquet
Output [3]: [internalUUID#19420, isoCode#19424, systemId#19419]
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#19420, isoCode#19424, systemId#19419]
(63) Project [codegen id : 7]
Output [2]: [internalUUID#19420, isoCode#19424.code AS _extract_code#20241]
Input [3]: [internalUUID#19420, isoCode#19424, systemId#19419]
(64) Exchange
Input [2]: [internalUUID#19420, _extract_code#20241]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6114]
(65) ShuffleQueryStage
Output [2]: [internalUUID#19420, _extract_code#20241]
Arguments: 8
(66) BroadcastExchange
Input [2]: [internalUUID#19420, _extract_code#20241]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=6770]
(67) BroadcastQueryStage
Output [2]: [internalUUID#19420, _extract_code#20241]
Arguments: 19
(68) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#19420, ), isnull(internalUUID#19420)]
Join type: LeftOuter
Join condition: None
(69) Project
Output [37]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, CURRENCY#19436, struct(value, cast(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19581.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19581, false))[0].productDimensions, lambdafunction((lambda x_20#19587.dimensionName.code = VOLUME), lambda x_20#19587, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19582.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19582, false))[0].productDimensions, lambdafunction((lambda x_20#19588.dimensionName.code = VOLUME), lambda x_20#19588, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19583.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19583, false))[0].productDimensions, lambdafunction((lambda x_20#19589.dimensionName.code = VOLUME), lambda x_20#19589, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#20241) AS VOLUME#19577]
Input [38]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, CURRENCY#19436, internalUUID#19420, _extract_code#20241]
(70) ReusedExchange [Reuses operator id: 66]
Output [2]: [internalUUID#19631, _extract_code#20240]
(71) BroadcastQueryStage
Output [2]: [internalUUID#19631, _extract_code#20240]
Arguments: 20
(72) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#19631, ), isnull(internalUUID#19631)]
Join type: LeftOuter
Join condition: None
(73) Project
Output [34]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, filter(array(CURRENCY#19436, VOLUME#19577, struct(value, cast(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19741.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19741, false))[0].productDimensions, lambdafunction((lambda x_22#19747.dimensionName.code = GROSS_WT), lambda x_22#19747, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19742.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19742, false))[0].productDimensions, lambdafunction((lambda x_22#19748.dimensionName.code = GROSS_WT), lambda x_22#19748, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19743.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19743, false))[0].productDimensions, lambdafunction((lambda x_22#19749.dimensionName.code = GROSS_WT), lambda x_22#19749, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#20240)), lambdafunction(isnotnull(lambda x_23#19792.value), lambda x_23#19792, false)) AS measurements#19791]
Input [39]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, CURRENCY#19436, VOLUME#19577, internalUUID#19631, _extract_code#20240]
(74) Scan parquet
Output [6]: [supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000000095/0_1_10000000095/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#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
(76) Exchange
Input [6]: [supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=6158]
(77) ShuffleQueryStage
Output [6]: [supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
Arguments: 11
(78) BroadcastExchange
Input [6]: [supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
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=6778]
(79) BroadcastQueryStage
Output [6]: [supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
Arguments: 21
(80) BroadcastHashJoin [codegen id : 14]
Left keys [10]: [coalesce(supplierGroup#17253, ), isnull(supplierGroup#17253), coalesce(supplier#17254, ), isnull(supplier#17254), coalesce(subrange#17257, ), isnull(subrange#17257), coalesce(plant#17255, ), isnull(plant#17255), coalesce(deliveryDateTime#17256, 1970-01-01 00:00:00), isnull(deliveryDateTime#17256)]
Right keys [10]: [coalesce(supplierGroup#19873, ), isnull(supplierGroup#19873), coalesce(supplier#19874, ), isnull(supplier#19874), coalesce(subrange#19877, ), isnull(subrange#19877), coalesce(plant#19875, ), isnull(plant#19875), coalesce(deliveryDateTime#19876, 1970-01-01 00:00:00), isnull(deliveryDateTime#19876)]
Join type: LeftOuter
Join condition: None
(81) Project [codegen id : 14]
Output [38]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#18867, [GE,LE,GE,LE,EQ] AS constraintOperators#18868, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, null AS originalReplenishmentRunId#19832L, coalesce(optimizationGroups#19878, []) AS optimizationGroups#20019]
Input [40]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
(82) Exchange
Input [19]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271]
Arguments: hashpartitioning(product#17258, plant#17255, 25), REPARTITION_BY_NUM, [plan_id=5408]
(83) Project
Output [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Input [24]: [internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315, systemId#17292]
(84) Exchange
Input [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5411]
(85) BroadcastExchange
Input [24]: [systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=5463]
(86) BroadcastHashJoin
Left keys [2]: [coalesce(sourceOfSupplyUuid#17263, ), isnull(sourceOfSupplyUuid#17263)]
Right keys [2]: [coalesce(internalUUID#17293, ), isnull(internalUUID#17293)]
Join type: LeftOuter
Join condition: None
(87) Project
Output [20]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, struct(systemId, systemId#17292, internalUUID, internalUUID#17293, supplier, supplier#17294, receiver, receiver#17295, product, product#17296, receivingPlant, receivingPlant#17297, sourceOfSupplyType, sourceOfSupplyType#17298, purchasingGroup, purchasingGroup#17299, purchasingOrganization, purchasingOrganization#17300, productGroup, productGroup#17301, validFrom, validFrom#17302, validTo, validTo#17303, ... 24 more fields) AS sos#17426]
Input [43]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, systemId#17292, internalUUID#17293, supplier#17294, receiver#17295, product#17296, receivingPlant#17297, sourceOfSupplyType#17298, purchasingGroup#17299, purchasingOrganization#17300, productGroup#17301, validFrom#17302, validTo#17303, priority#17304, isPurchasingBlocked#17305, isConsignment#17306, isDeleted#17307, supplierSubrange#17308, plannedDeliveryTimeDays#17309, orderQuantityUnit#17310, purchasingPriceAspect#17311, orderCurrency#17312, minimumOrderQuantity#17313, logisticalRoundingProfile#17314, supplyingPlant#17315]
(88) Filter
Input [9]: [internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503, systemId#17495]
Condition : plant#17497.internalRefUUID IN (1c037502c75549dc72c6fc87c802bcec,717937a4d5db853d3359b6a0623cfdf0,4d233bd0bf112aded9d852448354b078,fca7a07ad5f143db2beafbd1d0401ea1,45f9c5206af43e1e6acbe19d9a246289,6d24a939f4bbd79f6acb8684d6e45c97,3d84243e56ebf98292ed5dba2fd51543,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,f80b06f7b2102a5f5c63b031eb5d8e03)
(89) Project
Output [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
Input [9]: [internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503, systemId#17495]
(90) Exchange
Input [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5417]
(91) BroadcastExchange
Input [9]: [systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
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=5467]
(92) BroadcastHashJoin
Left keys [4]: [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255)]
Right keys [4]: [coalesce(product#17498.internalRefUUID, ), isnull(product#17498.internalRefUUID), coalesce(plant#17497.internalRefUUID, ), isnull(plant#17497.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(93) Project
Output [23]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, CASE WHEN isnotnull(productionAspect#17500) THEN struct(systemId, systemId#17495, internalUUID, internalUUID#17496, plant, plant#17497, product, product#17498, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#17499, productionAspect, productionAspect#17500, salesPlant, salesPlant#17501, listing, listing#17502, sourceOfSupplyCategory, sourceOfSupplyCategory#17503) END AS productPlant#17575, product#17498.id AS externalProductId#17606, plant#17497.id AS externalPlantId#17639]
Input [29]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, systemId#17495, internalUUID#17496, plant#17497, product#17498, blockedForReplenishmentStartingFrom#17499, productionAspect#17500, salesPlant#17501, listing#17502, sourceOfSupplyCategory#17503]
(94) Filter
Input [12]: [internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737, systemId#17726]
Condition : isnotnull(internalUUID#17727)
(95) Project
Output [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Input [12]: [internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737, systemId#17726]
(96) Exchange
Input [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5423]
(97) BroadcastExchange
Input [12]: [systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=5471]
(98) BroadcastHashJoin
Left keys [1]: [product#17258]
Right keys [1]: [internalUUID#17727]
Join type: LeftOuter
Join condition: None
(99) Project
Output [24]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, CASE WHEN isnotnull(internalUUID#17727) THEN struct(systemId, systemId#17726, internalUUID, internalUUID#17727, id, id#17728, displayId, displayId#17729, name, name#17730, baseUnitOfMeasure, baseUnitOfMeasure#17731, unitOfMeasures, unitOfMeasures#17732, unitOfMeasureConversions, unitOfMeasureConversions#17733, productionAspect, productionAspect#17734, salesAspect, salesAspect#17735, procurementAspect, procurementAspect#17736, productGroup, productGroup#17737) END AS productInformation#17820]
Input [35]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, systemId#17726, internalUUID#17727, id#17728, displayId#17729, name#17730, baseUnitOfMeasure#17731, unitOfMeasures#17732, unitOfMeasureConversions#17733, productionAspect#17734, salesAspect#17735, procurementAspect#17736, productGroup#17737]
(100) Project
Output [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(coalesce(transform(filter(productInformation#17820.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#17820.unitOfMeasures, lambdafunction(lambda x_1#17892.measurementUnit.internalRefUUID, lambda x_1#17892, false)), lambda x_0#17889.measurementUnit1.internalRefUUID) AND (lambda x_0#17889.measurementUnit2.internalRefUUID = productInformation#17820.baseUnitOfMeasure.internalRefUUID)), lambda x_0#17889, false)), lambdafunction(struct(uom, lambda x_2#17893.measurementUnit1.code, uomUuid, lambda x_2#17893.measurementUnit1.internalRefUUID, numerator, lambda x_2#17893.quantityNumerator, denominator, lambda x_2#17893.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2#17893, false)), []), lambdafunction(named_struct(uom, lambda x_3#17977.uom, uomUuid, lambda x_3#17977.uomUuid, numerator, lambda x_3#17977.numerator, denominator, lambda x_3#17977.denominator, isOrderUnit, ((lambda x_3#17977.uomUuid = coalesce(sos#17426.orderQuantityUnit.internalRefUUID, productInformation#17820.procurementAspect.orderUnit.internalRefUUID, productInformation#17820.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_3#17977.isPreferred), lambda x_3#17977, false)) AS logisticUnits#17976, productInformation#17820.baseUnitOfMeasure.code AS orderQuantityBaseUom#17919, productInformation#17820.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#17947, coalesce(sos#17426.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#17575.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) AS preferredRoundingProfile#18008]
Input [24]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, productPlant#17575, externalProductId#17606, externalPlantId#17639, productInformation#17820]
(101) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#18039, plant#18040]
Arguments: [logisticalRoundingProfile#18039, plant#18040]
(102) InMemoryRelation
Arguments: [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@763c116,StorageLevel(disk, memory, 2 replicas),LocalTableScan <empty>, [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041]
,None)
(103) LocalTableScan
Output [3]: [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041]
Arguments: <empty>, [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041]
(104) Project
Output [2]: [logisticalRoundingProfile#18039, plant#18040.internalRefUUID AS _extract_internalRefUUID#20242]
Input [2]: [logisticalRoundingProfile#18039, plant#18040]
(105) BroadcastExchange
Input [2]: [logisticalRoundingProfile#18039, _extract_internalRefUUID#20242]
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=5476]
(106) BroadcastHashJoin
Left keys [4]: [coalesce(preferredRoundingProfile#18008, ), isnull(preferredRoundingProfile#18008), coalesce(plant#17255, ), isnull(plant#17255)]
Right keys [4]: [coalesce(logisticalRoundingProfile#18039, ), isnull(logisticalRoundingProfile#18039), coalesce(_extract_internalRefUUID#20242, ), isnull(_extract_internalRefUUID#20242)]
Join type: LeftOuter
Join condition: None
(107) Project
Output [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008]
Input [29]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008, logisticalRoundingProfile#18039, _extract_internalRefUUID#20242]
(108) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#18135, plant#18136]
Arguments: [logisticalRoundingProfile#18135, plant#18136], [isnull(plant#18136.internalRefUUID)]
(109) InMemoryRelation
Arguments: [logisticalRoundingProfile#18135, plant#18136, logisticalRoundingRule#18137], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@763c116,StorageLevel(disk, memory, 2 replicas),LocalTableScan <empty>, [logisticalRoundingProfile#18039, plant#18040, logisticalRoundingRule#18041]
,None)
(110) Filter
Input [2]: [logisticalRoundingProfile#18135, plant#18136]
Condition : isnull(plant#18136.internalRefUUID)
(111) Project
Output [1]: [logisticalRoundingProfile#18135]
Input [2]: [logisticalRoundingProfile#18135, plant#18136]
(112) BroadcastExchange
Input [1]: [logisticalRoundingProfile#18135]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=5480]
(113) BroadcastHashJoin
Left keys [2]: [coalesce(preferredRoundingProfile#18008, ), isnull(preferredRoundingProfile#18008)]
Right keys [2]: [coalesce(logisticalRoundingProfile#18135, ), isnull(logisticalRoundingProfile#18135)]
Join type: LeftOuter
Join condition: None
(114) Project
Output [26]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18395.uom, uomUuid, lambda x_4#18395.uomUuid, numerator, lambda x_4#18395.numerator, denominator, lambda x_4#18395.denominator, isOrderUnit, lambda x_4#18395.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18395.uomUuid) THEN true ELSE lambda x_4#18395.isPreferred END), lambda x_4#18395, false)), lambdafunction(named_struct(uom, lambda x_6#18396.uom, uomUuid, lambda x_6#18396.uomUuid, numerator, lambda x_6#18396.numerator, denominator, lambda x_6#18396.denominator, isOrderUnit, lambda x_6#18396.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#17976, lambdafunction(named_struct(uom, lambda x_4#18397.uom, uomUuid, lambda x_4#18397.uomUuid, numerator, lambda x_4#18397.numerator, denominator, lambda x_4#18397.denominator, isOrderUnit, lambda x_4#18397.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_4#18397.uomUuid) THEN true ELSE lambda x_4#18397.isPreferred END), lambda x_4#18397, false)), lambdafunction(lambda x_5#18398.isPreferred, lambda x_5#18398, false)), true) THEN lambda x_6#18396.isPreferred ELSE lambda x_6#18396.isOrderUnit END), lambda x_6#18396, false)) AS logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947]
Input [28]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#17976, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, preferredRoundingProfile#18008, logisticalRoundingProfile#18135]
(115) Project
Output [27]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, ((sos#17426.minimumOrderQuantity * cast(filter(logisticUnits#18394, lambdafunction(lambda x#18457.isOrderUnit, lambda x#18457, false))[0].numerator as double)) / cast(filter(logisticUnits#18394, lambdafunction(lambda x#18458.isOrderUnit, lambda x#18458, false))[0].denominator as double)) AS minimumOrderQuantity#18455]
Input [26]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947]
(116) Exchange
Input [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5438]
(117) BroadcastExchange
Input [4]: [product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
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=5485]
(118) BroadcastHashJoin
Left keys [6]: [coalesce(product#17258, ), isnull(product#17258), coalesce(plant#17255, ), isnull(plant#17255), coalesce(orderDateTime#17259, 1970-01-01 00:00:00), isnull(orderDateTime#17259)]
Right keys [6]: [coalesce(product#18487, ), isnull(product#18487), coalesce(plant#18488, ), isnull(plant#18488), coalesce(orderDateTime#18489, 1970-01-01 00:00:00), isnull(orderDateTime#18489)]
Join type: LeftOuter
Join condition: None
(119) Project
Output [28]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#18455, constraintProfile#18490]
Input [31]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#18455, product#18487, plant#18488, orderDateTime#18489, constraintprofile#18490]
(120) Project
Output [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584.isActive AS _extract_isActive#20265, maxRangeCoverage#18584.range AS _extract_range#20266, maxRangeCoverage#18584.rank AS _extract_rank#20267, minOrderQuantity#18585]
Input [5]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, maxRangeCoverage#18584, minOrderQuantity#18585]
(121) Exchange
Input [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5443]
(122) BroadcastExchange
Input [7]: [constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=5489]
(123) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#18490, ), isnull(constraintProfile#18490)]
Right keys [2]: [coalesce(constraintProfile#18579, ), isnull(constraintProfile#18579)]
Join type: LeftOuter
Join condition: None
(124) Project
Output [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, array(CASE WHEN (minServiceLevel#18581.isActive <=> true) THEN minServiceLevel#18581.level END, CASE WHEN (_extract_isActive#20265 <=> true) THEN cast(_extract_range#20266 as double) END, coalesce(minimumOrderQuantity#18455, 0.0), CASE WHEN (maxServiceLevelEndListing#18583.isActive <=> true) THEN maxServiceLevelEndListing#18583.level END, null) AS constraintValues#18869, array(CASE WHEN (minServiceLevel#18581.isActive <=> true) THEN minServiceLevel#18581.rank ELSE 0 END, CASE WHEN (_extract_isActive#20265 <=> true) THEN _extract_rank#20267 ELSE 0 END, CASE WHEN (minOrderQuantity#18585.isActive <=> true) THEN minOrderQuantity#18585.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#18583.isActive <=> true) THEN maxServiceLevelEndListing#18583.rank ELSE 0 END, 0) AS constraintRanks#18870, array((minServiceLevel#18581.isActive <=> true), (_extract_isActive#20265 <=> true), (minOrderQuantity#18585.isActive <=> true), (maxServiceLevelEndListing#18583.isActive <=> true), false) AS constraintIsActive#18871]
Input [35]: [supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalId#17266L, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, orderProposalItemId#17271, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#18455, constraintProfile#18490, constraintProfile#18579, minServiceLevel#18581, maxServiceLevelEndListing#18583, _extract_isActive#20265, _extract_range#20266, _extract_rank#20267, minOrderQuantity#18585]
(125) Project
Output [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_14#19086.label = minServiceLevel), lambda x_14#19086, false))[0]) THEN element_at(constraintValues#18869, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_14#19087.label = minServiceLevel), lambda x_14#19087, false))[0].isActive THEN filter(null, lambdafunction((lambda x_14#19088.label = minServiceLevel), lambda x_14#19088, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_15#19089.label = maxRangeCoverage), lambda x_15#19089, false))[0]) THEN element_at(constraintValues#18869, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_15#19090.label = maxRangeCoverage), lambda x_15#19090, false))[0].isActive THEN filter(null, lambdafunction((lambda x_15#19091.label = maxRangeCoverage), lambda x_15#19091, false))[0].value END END, element_at(constraintValues#18869, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_16#19092.label = maxServiceLevelEndListing), lambda x_16#19092, false))[0]) THEN element_at(constraintValues#18869, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_16#19093.label = maxServiceLevelEndListing), lambda x_16#19093, false))[0].isActive THEN filter(null, lambdafunction((lambda x_16#19094.label = maxServiceLevelEndListing), lambda x_16#19094, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_17#19095.label = lockedOrderQuantity), lambda x_17#19095, false))[0].isActive THEN filter(null, lambdafunction((lambda x_17#19096.label = lockedOrderQuantity), lambda x_17#19096, false))[0].value END) AS constraintValues#19085, constraintRanks#18870, array(coalesce(filter(null, lambdafunction((lambda x_9#19046.label = minServiceLevel), lambda x_9#19046, false))[0].isActive, element_at(constraintIsActive#18871, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_10#19047.label = maxRangeCoverage), lambda x_10#19047, false))[0].isActive, element_at(constraintIsActive#18871, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_11#19048.label = minOrderQuantity), lambda x_11#19048, false))[0].isActive, element_at(constraintIsActive#18871, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_12#19049.label = maxServiceLevelEndListing), lambda x_12#19049, false))[0].isActive, element_at(constraintIsActive#18871, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_13#19050.label = lockedOrderQuantity), lambda x_13#19050, false))[0].isActive, false)) AS constraintIsActive#19045]
Input [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, constraintValues#18869, constraintRanks#18870, constraintIsActive#18871]
(126) Project
Output [36]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, productInformation#17820.unitOfMeasures AS _extract_unitOfMeasures#20263, productInformation#17820.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, CASE WHEN element_at(constraintIsActive#19045, 3, None, false) THEN element_at(constraintValues#19085, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, sos#17426.purchasingPriceAspect.netPrice.amount AS netPriceAmount#19199, sos#17426.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#19235, sos#17426.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#19272, sos#17426.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#19310, sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#19349, struct(value, CASE WHEN (sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#17947) THEN (sos#17426.purchasingPriceAspect.netPrice.amount / sos#17426.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#17426.purchasingPriceAspect.netPrice.amount / sos#17426.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#18394, lambdafunction((lambda x_18#19437.uomUuid = sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_18#19437, false))[0].denominator as double)) / cast(filter(logisticUnits#18394, lambdafunction((lambda x_18#19438.uomUuid = sos#17426.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_18#19438, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#17426.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#19436]
Input [29]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, sos#17426, externalProductId#17606, externalPlantId#17639, productInformation#17820, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045]
(127) Project
Output [2]: [internalUUID#19420, isoCode#19424.code AS _extract_code#20241]
Input [3]: [internalUUID#19420, isoCode#19424, systemId#19419]
(128) Exchange
Input [2]: [internalUUID#19420, _extract_code#20241]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5450]
(129) BroadcastExchange
Input [2]: [internalUUID#19420, _extract_code#20241]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=5495]
(130) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19479.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19479, false))[0].productDimensions, lambdafunction((lambda x_20#19481.dimensionName.code = VOLUME), lambda x_20#19481, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#19420, ), isnull(internalUUID#19420)]
Join type: LeftOuter
Join condition: None
(131) Project
Output [37]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, CURRENCY#19436, struct(value, cast(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19581.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19581, false))[0].productDimensions, lambdafunction((lambda x_20#19587.dimensionName.code = VOLUME), lambda x_20#19587, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19582.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19582, false))[0].productDimensions, lambdafunction((lambda x_20#19588.dimensionName.code = VOLUME), lambda x_20#19588, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_19#19583.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_19#19583, false))[0].productDimensions, lambdafunction((lambda x_20#19589.dimensionName.code = VOLUME), lambda x_20#19589, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#20241) AS VOLUME#19577]
Input [38]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, CURRENCY#19436, internalUUID#19420, _extract_code#20241]
(132) Scan parquet
Output [3]: [internalUUID#19631, isoCode#19635, systemId#19630]
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#19631, isoCode#19635.code AS _extract_code#20240]
Input [3]: [internalUUID#19631, isoCode#19635, systemId#19630]
(134) Exchange
Input [2]: [internalUUID#19631, _extract_code#20240]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5455]
(135) BroadcastExchange
Input [2]: [internalUUID#19631, _extract_code#20240]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=5499]
(136) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19637.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19637, false))[0].productDimensions, lambdafunction((lambda x_22#19639.dimensionName.code = GROSS_WT), lambda x_22#19639, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#19631, ), isnull(internalUUID#19631)]
Join type: LeftOuter
Join condition: None
(137) Project
Output [34]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, filter(array(CURRENCY#19436, VOLUME#19577, struct(value, cast(filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19741.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19741, false))[0].productDimensions, lambdafunction((lambda x_22#19747.dimensionName.code = GROSS_WT), lambda x_22#19747, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19742.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19742, false))[0].productDimensions, lambdafunction((lambda x_22#19748.dimensionName.code = GROSS_WT), lambda x_22#19748, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#20263, lambdafunction((lambda x_21#19743.measurementUnit.internalRefUUID = _extract_internalRefUUID#20264), lambda x_21#19743, false))[0].productDimensions, lambdafunction((lambda x_22#19749.dimensionName.code = GROSS_WT), lambda x_22#19749, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#20240)), lambdafunction(isnotnull(lambda x_23#19792.value), lambda x_23#19792, false)) AS measurements#19791]
Input [39]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, _extract_unitOfMeasures#20263, _extract_internalRefUUID#20264, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, CURRENCY#19436, VOLUME#19577, internalUUID#19631, _extract_code#20240]
(138) Exchange
Input [6]: [supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=5459]
(139) BroadcastExchange
Input [6]: [supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
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=5503]
(140) BroadcastHashJoin
Left keys [10]: [coalesce(supplierGroup#17253, ), isnull(supplierGroup#17253), coalesce(supplier#17254, ), isnull(supplier#17254), coalesce(subrange#17257, ), isnull(subrange#17257), coalesce(plant#17255, ), isnull(plant#17255), coalesce(deliveryDateTime#17256, 1970-01-01 00:00:00), isnull(deliveryDateTime#17256)]
Right keys [10]: [coalesce(supplierGroup#19873, ), isnull(supplierGroup#19873), coalesce(supplier#19874, ), isnull(supplier#19874), coalesce(subrange#19877, ), isnull(subrange#19877), coalesce(plant#19875, ), isnull(plant#19875), coalesce(deliveryDateTime#19876, 1970-01-01 00:00:00), isnull(deliveryDateTime#19876)]
Join type: LeftOuter
Join condition: None
(141) Project
Output [38]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#18867, [GE,LE,GE,LE,EQ] AS constraintOperators#18868, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, null AS originalReplenishmentRunId#19832L, coalesce(optimizationGroups#19878, []) AS optimizationGroups#20019]
Input [40]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, supplierGroup#19873, supplier#19874, plant#19875, deliveryDateTime#19876, subrange#19877, optimizationGroups#19878]
(142) AdaptiveSparkPlan
Output [38]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintLabels#18867, constraintOperators#18868, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, originalReplenishmentRunId#19832L, optimizationGroups#20019]
Arguments: isFinalPlan=true
(143) TableCacheQueryStage
Output [38]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintLabels#18867, constraintOperators#18868, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, originalReplenishmentRunId#19832L, optimizationGroups#20019]
Arguments: 0
(144) WriteFiles
Input [38]: [orderProposalId#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintLabels#18867, constraintOperators#18868, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, originalReplenishmentRunId#19832L, optimizationGroups#20019]
(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/10000000095/shardId=0_1_10000000095, 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/10000000095/shardId=0_1_10000000095], 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#17266L, orderProposalItemId#17271, supplierGroup#17253, supplier#17254, plant#17255, deliveryDateTime#17256, subrange#17257, product#17258, orderDateTime#17259, availabilityDateTime#17260, nextAvailabilityDateTime#17261, mrpController#17262, sourceOfSupplyUuid#17263, purchasingOrg#17264, purchasingGroup#17265, orderProposalHorizonGroupingId#17267L, splitIndicator#17268L, worklistShardItemId#17269L, orderProposalItemGroupId#17270, externalProductId#17606, externalPlantId#17639, logisticUnits#18394, orderQuantityBaseUom#17919, orderQuantityBaseUomUuid#17947, minimumOrderQuantity#19131, constraintLabels#18867, constraintOperators#18868, constraintValues#19085, constraintRanks#18870, constraintIsActive#19045, netPriceAmount#19199, netPriceCurrencyCode#19235, netPriceQuantity#19272, netPriceQuantityUom#19310, netPriceQuantityUomUuid#19349, measurements#19791, originalReplenishmentRunId#19832L, optimizationGroups#20019]
(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/10000000095/shardId=0_1_10000000095, 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/10000000095/shardId=0_1_10000000095], 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