== Physical Plan ==
AdaptiveSparkPlan (268)
+- == Current Plan ==
ResultQueryStage (29)
+- * Project (28)
+- * BroadcastNestedLoopJoin Cross BuildLeft (27)
:- BroadcastQueryStage (8), Statistics(sizeInBytes=24.0 B, rowCount=1)
: +- BroadcastExchange (7)
: +- * Project (6)
: +- BroadcastNestedLoopJoin LeftOuter BuildLeft (5)
: :- BroadcastQueryStage (3), Statistics(sizeInBytes=24.0 B, rowCount=1)
: : +- BroadcastExchange (2)
: : +- LocalTableScan (1)
: +- EmptyRelation (4)
: +- LogicalQueryStage (unknown)
+- ObjectHashAggregate (26)
+- ShuffleQueryStage (25), Statistics(sizeInBytes=368.0 B, rowCount=1)
+- Exchange (24)
+- ObjectHashAggregate (23)
+- * Project (22)
+- * Filter (21)
+- SortAggregate (20)
+- * Sort (19)
+- AQEShuffleRead (18)
+- ShuffleQueryStage (17), Statistics(sizeInBytes=912.0 B, rowCount=5)
+- Exchange (16)
+- SortAggregate (15)
+- * Sort (14)
+- ShuffleQueryStage (13), Statistics(sizeInBytes=832.0 B, rowCount=5)
+- Exchange (12)
+- * Filter (11)
+- * ColumnarToRow (10)
+- Scan parquet (9)
+- == Initial Plan ==
Project (267)
+- BroadcastNestedLoopJoin Cross BuildRight (266)
:- Project (252)
: +- BroadcastNestedLoopJoin LeftOuter BuildLeft (251)
: :- BroadcastExchange (2)
: : +- LocalTableScan (1)
: +- ObjectHashAggregate (250)
: +- Exchange (249)
: +- ObjectHashAggregate (248)
: +- Project (247)
: +- BroadcastHashJoin LeftOuter BuildRight (246)
: :- Project (241)
: : +- Filter (240)
: : +- Generate (239)
: : +- Project (238)
: : +- Filter (237)
: : +- InMemoryTableScan (30)
: : +- InMemoryRelation (31)
: : +- AdaptiveSparkPlan (236)
+- == Final Plan ==
ResultQueryStage (189)
+- ObjectHashAggregate (188)
+- ObjectHashAggregate (187)
+- * Project (186)
+- * Project (185)
+- ShuffleQueryStage (184), Statistics(sizeInBytes=600.0 B, rowCount=25)
+- Exchange (183)
+- * HashAggregate (182)
+- AQEShuffleRead (181)
+- ShuffleQueryStage (180), Statistics(sizeInBytes=3.6 KiB, rowCount=155)
+- Exchange (179)
+- * HashAggregate (178)
+- TableCacheQueryStage (177), Statistics(sizeInBytes=235.3 KiB, rowCount=170)
+- InMemoryTableScan (32)
+- InMemoryRelation (33)
+- AdaptiveSparkPlan (176)
+- == Final Plan ==
ResultQueryStage (114)
+- * Project (113)
+- * BroadcastHashJoin LeftOuter BuildRight (112)
:- Project (105)
: +- BroadcastHashJoin LeftOuter BuildRight (104)
: :- Project (101)
: : +- BroadcastHashJoin LeftOuter BuildRight (100)
: : :- Project (92)
: : : +- Project (91)
: : : +- Project (90)
: : : +- BroadcastHashJoin LeftOuter BuildRight (89)
: : : :- Project (81)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (80)
: : : : :- Project (73)
: : : : : +- Project (72)
: : : : : +- Project (71)
: : : : : +- Project (70)
: : : : : +- Project (69)
: : : : : +- Project (68)
: : : : : +- Project (67)
: : : : : +- Project (66)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (65)
: : : : : :- * Project (56)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (55)
: : : : : : :- * Project (46)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (45)
: : : : : : : :- ShuffleQueryStage (37), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (36)
: : : : : : : : +- * ColumnarToRow (35)
: : : : : : : : +- Scan parquet (34)
: : : : : : : +- BroadcastQueryStage (44), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (43)
: : : : : : : +- ShuffleQueryStage (42), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (41)
: : : : : : : +- * Project (40)
: : : : : : : +- * ColumnarToRow (39)
: : : : : : : +- Scan parquet (38)
: : : : : : +- BroadcastQueryStage (54), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (53)
: : : : : : +- ShuffleQueryStage (52), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (51)
: : : : : : +- * Project (50)
: : : : : : +- * Filter (49)
: : : : : : +- * ColumnarToRow (48)
: : : : : : +- Scan parquet (47)
: : : : : +- BroadcastQueryStage (64), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (63)
: : : : : +- ShuffleQueryStage (62), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (61)
: : : : : +- * Project (60)
: : : : : +- * Filter (59)
: : : : : +- * ColumnarToRow (58)
: : : : : +- Scan parquet (57)
: : : : +- BroadcastQueryStage (79), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (78)
: : : : +- ShuffleQueryStage (77), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (76)
: : : : +- * ColumnarToRow (75)
: : : : +- Scan parquet (74)
: : : +- BroadcastQueryStage (88), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (87)
: : : +- ShuffleQueryStage (86), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (85)
: : : +- * Project (84)
: : : +- * ColumnarToRow (83)
: : : +- Scan parquet (82)
: : +- BroadcastQueryStage (99), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (98)
: : +- ShuffleQueryStage (97), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (96)
: : +- * Project (95)
: : +- * ColumnarToRow (94)
: : +- Scan parquet (93)
: +- BroadcastQueryStage (103), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (102)
+- BroadcastQueryStage (111), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (110)
+- ShuffleQueryStage (109), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (108)
+- * ColumnarToRow (107)
+- Scan parquet (106)
+- == Initial Plan ==
Project (175)
+- BroadcastHashJoin LeftOuter BuildRight (174)
:- Project (171)
: +- BroadcastHashJoin LeftOuter BuildRight (170)
: :- Project (165)
: : +- BroadcastHashJoin LeftOuter BuildRight (164)
: : :- Project (160)
: : : +- Project (159)
: : : +- Project (158)
: : : +- BroadcastHashJoin LeftOuter BuildRight (157)
: : : :- Project (153)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (152)
: : : : :- Project (149)
: : : : : +- Project (148)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (147)
: : : : : :- Project (141)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (140)
: : : : : : :- Project (134)
: : : : : : : +- Project (133)
: : : : : : : +- Project (132)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (131)
: : : : : : : :- Project (126)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (125)
: : : : : : : : :- Project (120)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (119)
: : : : : : : : : :- Exchange (115)
: : : : : : : : : : +- Scan parquet (34)
: : : : : : : : : +- BroadcastExchange (118)
: : : : : : : : : +- Exchange (117)
: : : : : : : : : +- Project (116)
: : : : : : : : : +- Scan parquet (38)
: : : : : : : : +- BroadcastExchange (124)
: : : : : : : : +- Exchange (123)
: : : : : : : : +- Project (122)
: : : : : : : : +- Filter (121)
: : : : : : : : +- Scan parquet (47)
: : : : : : : +- BroadcastExchange (130)
: : : : : : : +- Exchange (129)
: : : : : : : +- Project (128)
: : : : : : : +- Filter (127)
: : : : : : : +- Scan parquet (57)
: : : : : : +- BroadcastExchange (139)
: : : : : : +- Project (138)
: : : : : : +- InMemoryTableScan (135)
: : : : : : +- InMemoryRelation (136)
: : : : : : +- LocalTableScan (137)
: : : : : +- BroadcastExchange (146)
: : : : : +- Project (145)
: : : : : +- Filter (144)
: : : : : +- InMemoryTableScan (142)
: : : : : +- InMemoryRelation (143)
: : : : : +- LocalTableScan (137)
: : : : +- BroadcastExchange (151)
: : : : +- Exchange (150)
: : : : +- Scan parquet (74)
: : : +- BroadcastExchange (156)
: : : +- Exchange (155)
: : : +- Project (154)
: : : +- Scan parquet (82)
: : +- BroadcastExchange (163)
: : +- Exchange (162)
: : +- Project (161)
: : +- Scan parquet (93)
: +- BroadcastExchange (169)
: +- Exchange (168)
: +- Project (167)
: +- Scan parquet (166)
+- BroadcastExchange (173)
+- Exchange (172)
+- Scan parquet (106)
+- == Initial Plan ==
ObjectHashAggregate (235)
+- ObjectHashAggregate (234)
+- Project (233)
+- SortMergeJoin LeftOuter (232)
:- Sort (194)
: +- Exchange (193)
: +- HashAggregate (192)
: +- Exchange (191)
: +- HashAggregate (190)
: +- InMemoryTableScan (32)
: +- InMemoryRelation (33)
: +- AdaptiveSparkPlan (176)
+- == Final Plan ==
ResultQueryStage (114)
+- * Project (113)
+- * BroadcastHashJoin LeftOuter BuildRight (112)
:- Project (105)
: +- BroadcastHashJoin LeftOuter BuildRight (104)
: :- Project (101)
: : +- BroadcastHashJoin LeftOuter BuildRight (100)
: : :- Project (92)
: : : +- Project (91)
: : : +- Project (90)
: : : +- BroadcastHashJoin LeftOuter BuildRight (89)
: : : :- Project (81)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (80)
: : : : :- Project (73)
: : : : : +- Project (72)
: : : : : +- Project (71)
: : : : : +- Project (70)
: : : : : +- Project (69)
: : : : : +- Project (68)
: : : : : +- Project (67)
: : : : : +- Project (66)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (65)
: : : : : :- * Project (56)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (55)
: : : : : : :- * Project (46)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (45)
: : : : : : : :- ShuffleQueryStage (37), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (36)
: : : : : : : : +- * ColumnarToRow (35)
: : : : : : : : +- Scan parquet (34)
: : : : : : : +- BroadcastQueryStage (44), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (43)
: : : : : : : +- ShuffleQueryStage (42), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (41)
: : : : : : : +- * Project (40)
: : : : : : : +- * ColumnarToRow (39)
: : : : : : : +- Scan parquet (38)
: : : : : : +- BroadcastQueryStage (54), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (53)
: : : : : : +- ShuffleQueryStage (52), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (51)
: : : : : : +- * Project (50)
: : : : : : +- * Filter (49)
: : : : : : +- * ColumnarToRow (48)
: : : : : : +- Scan parquet (47)
: : : : : +- BroadcastQueryStage (64), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (63)
: : : : : +- ShuffleQueryStage (62), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (61)
: : : : : +- * Project (60)
: : : : : +- * Filter (59)
: : : : : +- * ColumnarToRow (58)
: : : : : +- Scan parquet (57)
: : : : +- BroadcastQueryStage (79), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (78)
: : : : +- ShuffleQueryStage (77), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (76)
: : : : +- * ColumnarToRow (75)
: : : : +- Scan parquet (74)
: : : +- BroadcastQueryStage (88), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (87)
: : : +- ShuffleQueryStage (86), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (85)
: : : +- * Project (84)
: : : +- * ColumnarToRow (83)
: : : +- Scan parquet (82)
: : +- BroadcastQueryStage (99), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (98)
: : +- ShuffleQueryStage (97), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (96)
: : +- * Project (95)
: : +- * ColumnarToRow (94)
: : +- Scan parquet (93)
: +- BroadcastQueryStage (103), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (102)
+- BroadcastQueryStage (111), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (110)
+- ShuffleQueryStage (109), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (108)
+- * ColumnarToRow (107)
+- Scan parquet (106)
+- == Initial Plan ==
Project (175)
+- BroadcastHashJoin LeftOuter BuildRight (174)
:- Project (171)
: +- BroadcastHashJoin LeftOuter BuildRight (170)
: :- Project (165)
: : +- BroadcastHashJoin LeftOuter BuildRight (164)
: : :- Project (160)
: : : +- Project (159)
: : : +- Project (158)
: : : +- BroadcastHashJoin LeftOuter BuildRight (157)
: : : :- Project (153)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (152)
: : : : :- Project (149)
: : : : : +- Project (148)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (147)
: : : : : :- Project (141)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (140)
: : : : : : :- Project (134)
: : : : : : : +- Project (133)
: : : : : : : +- Project (132)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (131)
: : : : : : : :- Project (126)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (125)
: : : : : : : : :- Project (120)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (119)
: : : : : : : : : :- Exchange (115)
: : : : : : : : : : +- Scan parquet (34)
: : : : : : : : : +- BroadcastExchange (118)
: : : : : : : : : +- Exchange (117)
: : : : : : : : : +- Project (116)
: : : : : : : : : +- Scan parquet (38)
: : : : : : : : +- BroadcastExchange (124)
: : : : : : : : +- Exchange (123)
: : : : : : : : +- Project (122)
: : : : : : : : +- Filter (121)
: : : : : : : : +- Scan parquet (47)
: : : : : : : +- BroadcastExchange (130)
: : : : : : : +- Exchange (129)
: : : : : : : +- Project (128)
: : : : : : : +- Filter (127)
: : : : : : : +- Scan parquet (57)
: : : : : : +- BroadcastExchange (139)
: : : : : : +- Project (138)
: : : : : : +- InMemoryTableScan (135)
: : : : : : +- InMemoryRelation (136)
: : : : : : +- LocalTableScan (137)
: : : : : +- BroadcastExchange (146)
: : : : : +- Project (145)
: : : : : +- Filter (144)
: : : : : +- InMemoryTableScan (142)
: : : : : +- InMemoryRelation (143)
: : : : : +- LocalTableScan (137)
: : : : +- BroadcastExchange (151)
: : : : +- Exchange (150)
: : : : +- Scan parquet (74)
: : : +- BroadcastExchange (156)
: : : +- Exchange (155)
: : : +- Project (154)
: : : +- Scan parquet (82)
: : +- BroadcastExchange (163)
: : +- Exchange (162)
: : +- Project (161)
: : +- Scan parquet (93)
: +- BroadcastExchange (169)
: +- Exchange (168)
: +- Project (167)
: +- Scan parquet (166)
+- BroadcastExchange (173)
+- Exchange (172)
+- Scan parquet (106)
+- Project (231)
+- BroadcastHashJoin LeftOuter BuildRight (230)
:- Project (225)
: +- BroadcastHashJoin Inner BuildRight (224)
: :- Project (220)
: : +- SortMergeJoin LeftOuter (219)
: : :- Sort (202)
: : : +- Exchange (201)
: : : +- HashAggregate (200)
: : : +- Exchange (199)
: : : +- HashAggregate (198)
: : : +- Filter (197)
: : : +- InMemoryTableScan (195)
: : : +- InMemoryRelation (196)
: : : +- AdaptiveSparkPlan (176)
+- == Final Plan ==
ResultQueryStage (114)
+- * Project (113)
+- * BroadcastHashJoin LeftOuter BuildRight (112)
:- Project (105)
: +- BroadcastHashJoin LeftOuter BuildRight (104)
: :- Project (101)
: : +- BroadcastHashJoin LeftOuter BuildRight (100)
: : :- Project (92)
: : : +- Project (91)
: : : +- Project (90)
: : : +- BroadcastHashJoin LeftOuter BuildRight (89)
: : : :- Project (81)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (80)
: : : : :- Project (73)
: : : : : +- Project (72)
: : : : : +- Project (71)
: : : : : +- Project (70)
: : : : : +- Project (69)
: : : : : +- Project (68)
: : : : : +- Project (67)
: : : : : +- Project (66)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (65)
: : : : : :- * Project (56)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (55)
: : : : : : :- * Project (46)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (45)
: : : : : : : :- ShuffleQueryStage (37), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (36)
: : : : : : : : +- * ColumnarToRow (35)
: : : : : : : : +- Scan parquet (34)
: : : : : : : +- BroadcastQueryStage (44), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (43)
: : : : : : : +- ShuffleQueryStage (42), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (41)
: : : : : : : +- * Project (40)
: : : : : : : +- * ColumnarToRow (39)
: : : : : : : +- Scan parquet (38)
: : : : : : +- BroadcastQueryStage (54), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (53)
: : : : : : +- ShuffleQueryStage (52), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (51)
: : : : : : +- * Project (50)
: : : : : : +- * Filter (49)
: : : : : : +- * ColumnarToRow (48)
: : : : : : +- Scan parquet (47)
: : : : : +- BroadcastQueryStage (64), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (63)
: : : : : +- ShuffleQueryStage (62), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (61)
: : : : : +- * Project (60)
: : : : : +- * Filter (59)
: : : : : +- * ColumnarToRow (58)
: : : : : +- Scan parquet (57)
: : : : +- BroadcastQueryStage (79), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (78)
: : : : +- ShuffleQueryStage (77), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (76)
: : : : +- * ColumnarToRow (75)
: : : : +- Scan parquet (74)
: : : +- BroadcastQueryStage (88), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (87)
: : : +- ShuffleQueryStage (86), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (85)
: : : +- * Project (84)
: : : +- * ColumnarToRow (83)
: : : +- Scan parquet (82)
: : +- BroadcastQueryStage (99), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (98)
: : +- ShuffleQueryStage (97), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (96)
: : +- * Project (95)
: : +- * ColumnarToRow (94)
: : +- Scan parquet (93)
: +- BroadcastQueryStage (103), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (102)
+- BroadcastQueryStage (111), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (110)
+- ShuffleQueryStage (109), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (108)
+- * ColumnarToRow (107)
+- Scan parquet (106)
+- == Initial Plan ==
Project (175)
+- BroadcastHashJoin LeftOuter BuildRight (174)
:- Project (171)
: +- BroadcastHashJoin LeftOuter BuildRight (170)
: :- Project (165)
: : +- BroadcastHashJoin LeftOuter BuildRight (164)
: : :- Project (160)
: : : +- Project (159)
: : : +- Project (158)
: : : +- BroadcastHashJoin LeftOuter BuildRight (157)
: : : :- Project (153)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (152)
: : : : :- Project (149)
: : : : : +- Project (148)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (147)
: : : : : :- Project (141)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (140)
: : : : : : :- Project (134)
: : : : : : : +- Project (133)
: : : : : : : +- Project (132)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (131)
: : : : : : : :- Project (126)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (125)
: : : : : : : : :- Project (120)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (119)
: : : : : : : : : :- Exchange (115)
: : : : : : : : : : +- Scan parquet (34)
: : : : : : : : : +- BroadcastExchange (118)
: : : : : : : : : +- Exchange (117)
: : : : : : : : : +- Project (116)
: : : : : : : : : +- Scan parquet (38)
: : : : : : : : +- BroadcastExchange (124)
: : : : : : : : +- Exchange (123)
: : : : : : : : +- Project (122)
: : : : : : : : +- Filter (121)
: : : : : : : : +- Scan parquet (47)
: : : : : : : +- BroadcastExchange (130)
: : : : : : : +- Exchange (129)
: : : : : : : +- Project (128)
: : : : : : : +- Filter (127)
: : : : : : : +- Scan parquet (57)
: : : : : : +- BroadcastExchange (139)
: : : : : : +- Project (138)
: : : : : : +- InMemoryTableScan (135)
: : : : : : +- InMemoryRelation (136)
: : : : : : +- LocalTableScan (137)
: : : : : +- BroadcastExchange (146)
: : : : : +- Project (145)
: : : : : +- Filter (144)
: : : : : +- InMemoryTableScan (142)
: : : : : +- InMemoryRelation (143)
: : : : : +- LocalTableScan (137)
: : : : +- BroadcastExchange (151)
: : : : +- Exchange (150)
: : : : +- Scan parquet (74)
: : : +- BroadcastExchange (156)
: : : +- Exchange (155)
: : : +- Project (154)
: : : +- Scan parquet (82)
: : +- BroadcastExchange (163)
: : +- Exchange (162)
: : +- Project (161)
: : +- Scan parquet (93)
: +- BroadcastExchange (169)
: +- Exchange (168)
: +- Project (167)
: +- Scan parquet (166)
+- BroadcastExchange (173)
+- Exchange (172)
+- Scan parquet (106)
: : +- Sort (218)
: : +- Exchange (217)
: : +- Project (216)
: : +- BroadcastHashJoin Inner BuildRight (215)
: : :- HashAggregate (210)
: : : +- Exchange (209)
: : : +- HashAggregate (208)
: : : +- Filter (207)
: : : +- Generate (206)
: : : +- Filter (205)
: : : +- InMemoryTableScan (203)
: : : +- InMemoryRelation (204)
: : : +- AdaptiveSparkPlan (176)
+- == Final Plan ==
ResultQueryStage (114)
+- * Project (113)
+- * BroadcastHashJoin LeftOuter BuildRight (112)
:- Project (105)
: +- BroadcastHashJoin LeftOuter BuildRight (104)
: :- Project (101)
: : +- BroadcastHashJoin LeftOuter BuildRight (100)
: : :- Project (92)
: : : +- Project (91)
: : : +- Project (90)
: : : +- BroadcastHashJoin LeftOuter BuildRight (89)
: : : :- Project (81)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (80)
: : : : :- Project (73)
: : : : : +- Project (72)
: : : : : +- Project (71)
: : : : : +- Project (70)
: : : : : +- Project (69)
: : : : : +- Project (68)
: : : : : +- Project (67)
: : : : : +- Project (66)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (65)
: : : : : :- * Project (56)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (55)
: : : : : : :- * Project (46)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (45)
: : : : : : : :- ShuffleQueryStage (37), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (36)
: : : : : : : : +- * ColumnarToRow (35)
: : : : : : : : +- Scan parquet (34)
: : : : : : : +- BroadcastQueryStage (44), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (43)
: : : : : : : +- ShuffleQueryStage (42), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (41)
: : : : : : : +- * Project (40)
: : : : : : : +- * ColumnarToRow (39)
: : : : : : : +- Scan parquet (38)
: : : : : : +- BroadcastQueryStage (54), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (53)
: : : : : : +- ShuffleQueryStage (52), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (51)
: : : : : : +- * Project (50)
: : : : : : +- * Filter (49)
: : : : : : +- * ColumnarToRow (48)
: : : : : : +- Scan parquet (47)
: : : : : +- BroadcastQueryStage (64), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (63)
: : : : : +- ShuffleQueryStage (62), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (61)
: : : : : +- * Project (60)
: : : : : +- * Filter (59)
: : : : : +- * ColumnarToRow (58)
: : : : : +- Scan parquet (57)
: : : : +- BroadcastQueryStage (79), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (78)
: : : : +- ShuffleQueryStage (77), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (76)
: : : : +- * ColumnarToRow (75)
: : : : +- Scan parquet (74)
: : : +- BroadcastQueryStage (88), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (87)
: : : +- ShuffleQueryStage (86), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (85)
: : : +- * Project (84)
: : : +- * ColumnarToRow (83)
: : : +- Scan parquet (82)
: : +- BroadcastQueryStage (99), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (98)
: : +- ShuffleQueryStage (97), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (96)
: : +- * Project (95)
: : +- * ColumnarToRow (94)
: : +- Scan parquet (93)
: +- BroadcastQueryStage (103), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (102)
+- BroadcastQueryStage (111), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (110)
+- ShuffleQueryStage (109), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (108)
+- * ColumnarToRow (107)
+- Scan parquet (106)
+- == Initial Plan ==
Project (175)
+- BroadcastHashJoin LeftOuter BuildRight (174)
:- Project (171)
: +- BroadcastHashJoin LeftOuter BuildRight (170)
: :- Project (165)
: : +- BroadcastHashJoin LeftOuter BuildRight (164)
: : :- Project (160)
: : : +- Project (159)
: : : +- Project (158)
: : : +- BroadcastHashJoin LeftOuter BuildRight (157)
: : : :- Project (153)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (152)
: : : : :- Project (149)
: : : : : +- Project (148)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (147)
: : : : : :- Project (141)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (140)
: : : : : : :- Project (134)
: : : : : : : +- Project (133)
: : : : : : : +- Project (132)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (131)
: : : : : : : :- Project (126)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (125)
: : : : : : : : :- Project (120)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (119)
: : : : : : : : : :- Exchange (115)
: : : : : : : : : : +- Scan parquet (34)
: : : : : : : : : +- BroadcastExchange (118)
: : : : : : : : : +- Exchange (117)
: : : : : : : : : +- Project (116)
: : : : : : : : : +- Scan parquet (38)
: : : : : : : : +- BroadcastExchange (124)
: : : : : : : : +- Exchange (123)
: : : : : : : : +- Project (122)
: : : : : : : : +- Filter (121)
: : : : : : : : +- Scan parquet (47)
: : : : : : : +- BroadcastExchange (130)
: : : : : : : +- Exchange (129)
: : : : : : : +- Project (128)
: : : : : : : +- Filter (127)
: : : : : : : +- Scan parquet (57)
: : : : : : +- BroadcastExchange (139)
: : : : : : +- Project (138)
: : : : : : +- InMemoryTableScan (135)
: : : : : : +- InMemoryRelation (136)
: : : : : : +- LocalTableScan (137)
: : : : : +- BroadcastExchange (146)
: : : : : +- Project (145)
: : : : : +- Filter (144)
: : : : : +- InMemoryTableScan (142)
: : : : : +- InMemoryRelation (143)
: : : : : +- LocalTableScan (137)
: : : : +- BroadcastExchange (151)
: : : : +- Exchange (150)
: : : : +- Scan parquet (74)
: : : +- BroadcastExchange (156)
: : : +- Exchange (155)
: : : +- Project (154)
: : : +- Scan parquet (82)
: : +- BroadcastExchange (163)
: : +- Exchange (162)
: : +- Project (161)
: : +- Scan parquet (93)
: +- BroadcastExchange (169)
: +- Exchange (168)
: +- Project (167)
: +- Scan parquet (166)
+- BroadcastExchange (173)
+- Exchange (172)
+- Scan parquet (106)
: : +- BroadcastExchange (214)
: : +- Exchange (213)
: : +- Filter (212)
: : +- Scan parquet (211)
: +- BroadcastExchange (223)
: +- Exchange (222)
: +- Scan parquet (221)
+- BroadcastExchange (229)
+- Exchange (228)
+- Project (227)
+- Scan parquet (226)
: +- BroadcastExchange (245)
: +- Exchange (244)
: +- Filter (243)
: +- Scan parquet (242)
+- BroadcastExchange (265)
+- ObjectHashAggregate (264)
+- Exchange (263)
+- ObjectHashAggregate (262)
+- Project (261)
+- Filter (260)
+- SortAggregate (259)
+- Sort (258)
+- Exchange (257)
+- SortAggregate (256)
+- Sort (255)
+- Exchange (254)
+- Filter (253)
+- Scan parquet (9)
(1) LocalTableScan
Output [1]: [dummy#1005130]
Arguments: [dummy#1005130]
(2) BroadcastExchange
Input [1]: [dummy#1005130]
Arguments: IdentityBroadcastMode, [plan_id=393559]
(3) BroadcastQueryStage
Output [1]: [dummy#1005130]
Arguments: 0
(4) EmptyRelation
Output [1]: [uomCategories#1005121]
Arguments: [plan_id=394389]
(5) BroadcastNestedLoopJoin
Join type: LeftOuter
Join condition: (dummy#1005130 = dummy)
(6) Project [codegen id : 7]
Output [1]: [coalesce(uomCategories#1005121, []) AS uomCategories#1005131]
Input [2]: [dummy#1005130, uomCategories#1005121]
(7) BroadcastExchange
Input [1]: [uomCategories#1005131]
Arguments: IdentityBroadcastMode, [plan_id=394408]
(8) BroadcastQueryStage
Output [1]: [uomCategories#1005131]
Arguments: 8
(9) Scan parquet
Output [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/insight-configuration]
PushedFilters: [IsNotNull(configurationVersion), IsNotNull(name)]
ReadSchema: struct<name:string,status:string,configurationVersion:string,settings:array<struct<name:string,type:string,value:string>>>
(10) ColumnarToRow [codegen id : 2]
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
(11) Filter [codegen id : 2]
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Condition : (isnotnull(configurationVersion#1005135) AND isnotnull(name#1005132))
(12) Exchange
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=393667]
(13) ShuffleQueryStage
Output [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Arguments: 3
(14) Sort [codegen id : 3]
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Arguments: [name#1005132 ASC NULLS FIRST], false, 0
(15) SortAggregate
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Keys [1]: [name#1005132]
Functions [1]: [partial_max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))]
Aggregate Attributes [1]: [max#1008432]
Results [2]: [name#1005132, max#1008433]
(16) Exchange
Input [2]: [name#1005132, max#1008433]
Arguments: hashpartitioning(name#1005132, 25), ENSURE_REQUIREMENTS, [plan_id=394160]
(17) ShuffleQueryStage
Output [2]: [name#1005132, max#1008433]
Arguments: 5
(18) AQEShuffleRead
Input [2]: [name#1005132, max#1008433]
Arguments: coalesced
(19) Sort [codegen id : 5]
Input [2]: [name#1005132, max#1008433]
Arguments: [name#1005132 ASC NULLS FIRST], false, 0
(20) SortAggregate
Input [2]: [name#1005132, max#1008433]
Keys [1]: [name#1005132]
Functions [1]: [max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))]
Aggregate Attributes [1]: [max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))#1005150]
Results [2]: [name#1005132, max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))#1005150 AS best#1005141]
(21) Filter [codegen id : 6]
Input [2]: [name#1005132, best#1005141]
Condition : (isnotnull(best#1005141.status) AND (best#1005141.status = ACTIVE))
(22) Project [codegen id : 6]
Output [3]: [name#1005132, best#1005141.settings AS settings#1005152, best#1005141.configurationVersion AS configurationVersion#1005153]
Input [2]: [name#1005132, best#1005141]
(23) ObjectHashAggregate
Input [3]: [name#1005132, settings#1005152, configurationVersion#1005153]
Keys: []
Functions [1]: [partial_collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)]
Aggregate Attributes [1]: [buf#1008430]
Results [1]: [buf#1008431]
(24) Exchange
Input [1]: [buf#1008431]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=394356]
(25) ShuffleQueryStage
Output [1]: [buf#1008431]
Arguments: 7
(26) ObjectHashAggregate
Input [1]: [buf#1008431]
Keys: []
Functions [1]: [collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)#1005160]
Results [1]: [map_from_entries(collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)#1005160) AS insightConfigurations#1005156]
(27) BroadcastNestedLoopJoin [codegen id : 8]
Join type: Cross
Join condition: None
(28) Project [codegen id : 8]
Output [3]: [uomCategories#1005131, insightConfigurations#1005156, 0_1_10000002111 AS shardId#1008226]
Input [2]: [uomCategories#1005131, insightConfigurations#1005156]
(29) ResultQueryStage
Output [3]: [uomCategories#1005131, insightConfigurations#1005156, shardId#1008226]
Arguments: 10
(30) InMemoryTableScan
Output [1]: [optimizationGroups#1002519]
Arguments: [optimizationGroups#1002519], [(size(optimizationGroups#1002519.minOrderGoal, true) > 0)]
(31) InMemoryRelation
Arguments: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519], StorageLevel(disk, memory, 2 replicas)
(32) InMemoryTableScan
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: [orderProposalId#1000986L, sequenceId#1000991]
(33) InMemoryRelation
Arguments: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, ... 19 more fields], StorageLevel(disk, memory, 2 replicas)
(34) Scan parquet
Output [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-boundary-snapshot/10000002111/shardId=0_1_10000002111]
ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,supplyingPlant:string,productGroup:string,product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,mrpController:string,sourceOfSupplyUuid:string,purchasingOrg:string,purchasingGroup:string,isFallbackOrderOnly:boolean,orderProposalId:bigint,orderProposalHorizonGroupingId:bigint,splitIndicator:bigint,previousOrderProposal:bigint,clusterId:bigint,sequenceId:int,worklistShardItemId:bigint,orderProposalItemGroupId:string,orderProposalItemId:string>
(35) ColumnarToRow [codegen id : 1]
Input [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
(36) Exchange
Input [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
Arguments: hashpartitioning(product#1000977, plant#1000972, 25), REPARTITION_BY_NUM, [plan_id=390356]
(37) ShuffleQueryStage
Output [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
Arguments: 0
(38) Scan parquet
Output [24]: [internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply]
ReadSchema: struct<internalUUID:string,supplier:struct<internalRefUUID:string,id:string>,receiver:struct<internalRefUUID:string,id:string>,product:struct<internalRefUUID:string,id:string>,receivingPlant:struct<internalRefUUID:string,id:string>,sourceOfSupplyType:struct<internalRefUUID:string,code:string>,purchasingGroup:struct<internalRefUUID:string,id:string>,purchasingOrganization:struct<internalRefUUID:string,id:string>,productGroup:struct<internalRefUUID:string,id:string>,validFrom:timestamp,validTo:timestamp,priority:int,isPurchasingBlocked:boolean,isConsignment:boolean,isDeleted:boolean,supplierSubrange:string,plannedDeliveryTimeDays:int,orderQuantityUnit:struct<internalRefUUID:string,code:string>,purchasingPriceAspect:struct<netPrice:struct<amount:double,currencyCode:struct<internalRefUUID:string,code:string>>,netPriceQuantity:double,netPriceUnit:struct<internalRefUUID:string,code:string>>,orderCurrency:struct<internalRefUUID:string,code:string>,minimumOrderQuantity:double,logisticalRoundingProfile:struct<logisticalRoundingProfile:string,internalRefUUID:string>,supplyingPlant:struct<internalRefUUID:string,id:string>>
(39) ColumnarToRow [codegen id : 2]
Input [24]: [internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
(40) Project [codegen id : 2]
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Input [24]: [internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
(41) Exchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390375]
(42) ShuffleQueryStage
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: 1
(43) BroadcastExchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=391003]
(44) BroadcastQueryStage
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: 20
(45) BroadcastHashJoin [codegen id : 12]
Left keys [2]: [coalesce(sourceOfSupplyUuid#1000982, ), isnull(sourceOfSupplyUuid#1000982)]
Right keys [2]: [coalesce(internalUUID#1000997, ), isnull(internalUUID#1000997)]
Join type: LeftOuter
Join condition: None
(46) Project [codegen id : 12]
Output [26]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, struct(systemId, systemId#1000996, internalUUID, internalUUID#1000997, supplier, supplier#1000998, receiver, receiver#1000999, product, product#1001000, receivingPlant, receivingPlant#1001001, sourceOfSupplyType, sourceOfSupplyType#1001002, purchasingGroup, purchasingGroup#1001003, purchasingOrganization, purchasingOrganization#1001004, productGroup, productGroup#1001005, validFrom, validFrom#1001006, validTo, validTo#1001007, priority, ... 23 more fields) AS sos#1001020]
Input [49]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
(47) Scan parquet
Output [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant]
PushedFilters: [In(plant.internalRefUUID, [1c037502c75549dc72c6fc87c802bcec,24a9ebb440508219166784d4d1c19eef,25c0d9731dd07bb53999d9a8f04398e0,45f9c5206af43e1e6acbe19d9a246289])]
ReadSchema: struct<internalUUID:string,plant:struct<internalRefUUID:string,id:string>,product:struct<internalRefUUID:string,id:string>,blockedForReplenishmentStartingFrom:date,productionAspect:struct<productMovementPlants:struct<unitOfIssue:struct<internalRefUUID:string,code:string>>,productPlanningPlants:struct<mrpType:struct<internalRefUUID:string,code:string>,abcIndicator:struct<internalRefUUID:string,code:string>,mrpController:struct<internalRefUUID:string,id:string>,minimumLotSize:double,minimumSafetyStock:double,logisticalRoundingProfile:struct<internalRefUUID:string,logisticalRoundingProfile:string>,sourceOfSupplyCategory:struct<internalRefUUID:string,code:string>>>,salesPlant:struct<loadingGroup:struct<internalRefUUID:string,code:string>>,listing:array<struct<validFrom:timestamp,validTo:timestamp,isListed:boolean>>>
(48) ColumnarToRow [codegen id : 3]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
(49) Filter [codegen id : 3]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
Condition : plant#1001026.internalRefUUID IN (25c0d9731dd07bb53999d9a8f04398e0,1c037502c75549dc72c6fc87c802bcec,45f9c5206af43e1e6acbe19d9a246289,24a9ebb440508219166784d4d1c19eef)
(50) Project [codegen id : 3]
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
(51) Exchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390402]
(52) ShuffleQueryStage
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: 2
(53) BroadcastExchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID), coalesce(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID)),false), [plan_id=391007]
(54) BroadcastQueryStage
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: 21
(55) BroadcastHashJoin [codegen id : 12]
Left keys [4]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972)]
Right keys [4]: [coalesce(product#1001027.internalRefUUID, ), isnull(product#1001027.internalRefUUID), coalesce(plant#1001026.internalRefUUID, ), isnull(plant#1001026.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(56) Project [codegen id : 12]
Output [29]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, CASE WHEN isnotnull(productionAspect#1001029) THEN struct(systemId, systemId#1001024, internalUUID, internalUUID#1001025, plant, plant#1001026, product, product#1001027, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1001028, productionAspect, productionAspect#1001029, salesPlant, salesPlant#1001030, listing, listing#1001031) END AS productPlant#1001036, product#1001027.id AS externalProductId#1001037, plant#1001026.id AS externalPlantId#1001039]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
(57) Scan parquet
Output [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-product-v2]
PushedFilters: [IsNotNull(internalUUID)]
ReadSchema: struct<internalUUID:string,id:string,displayId:string,name:array<struct<lang:string,content:string>>,baseUnitOfMeasure:struct<internalRefUUID:string,code:string>,unitOfMeasures:array<struct<measurementUnit:struct<internalRefUUID:string,code:string>,productDimensions:array<struct<dimensionName:struct<internalRefUUID:string,code:string>,dimensionValue:string,measurementUnit:struct<internalRefUUID:string,code:string>>>>>,unitOfMeasureConversions:array<struct<measurementUnit1:struct<internalRefUUID:string,code:string>,measurementUnit2:struct<internalRefUUID:string,code:string>,quantityNumerator:int,quantityDenominator:int>>,productionAspect:struct<minimumRemainingShelfLife:double>,salesAspect:struct<transportationGroup:struct<internalRefUUID:string,code:string>>,procurementAspect:struct<orderUnit:struct<internalRefUUID:string,code:string>>,productGroup:struct<internalRefUUID:string,id:string>>
(58) ColumnarToRow [codegen id : 4]
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
(59) Filter [codegen id : 4]
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
Condition : isnotnull(internalUUID#1001042)
(60) Project [codegen id : 4]
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
(61) Exchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390431]
(62) ShuffleQueryStage
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: 3
(63) BroadcastExchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=391011]
(64) BroadcastQueryStage
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: 16
(65) BroadcastHashJoin
Left keys [1]: [product#1000977]
Right keys [1]: [internalUUID#1001042]
Join type: LeftOuter
Join condition: None
(66) Project
Output [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, CASE WHEN isnotnull(internalUUID#1001042) THEN struct(systemId, systemId#1001041, internalUUID, internalUUID#1001042, id, id#1001043, displayId, displayId#1001044, name, name#1001045, baseUnitOfMeasure, baseUnitOfMeasure#1001046, unitOfMeasures, unitOfMeasures#1001047, unitOfMeasureConversions, unitOfMeasureConversions#1001048, productionAspect, productionAspect#1001049, salesAspect, salesAspect#1001050, procurementAspect, procurementAspect#1001051, productGroup, productGroup#1001052) END AS productInformation#1001053]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
(67) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(coalesce(transform(filter(productInformation#1001053.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#1001053.unitOfMeasures, lambdafunction(lambda x_2600#1001065.measurementUnit.internalRefUUID, lambda x_2600#1001065, false)), lambda x_2599#1001062.measurementUnit1.internalRefUUID) AND (lambda x_2599#1001062.measurementUnit2.internalRefUUID = productInformation#1001053.baseUnitOfMeasure.internalRefUUID)), lambda x_2599#1001062, false)), lambdafunction(struct(uom, lambda x_2601#1001066.measurementUnit1.code, uomUuid, lambda x_2601#1001066.measurementUnit1.internalRefUUID, numerator, lambda x_2601#1001066.quantityNumerator, denominator, lambda x_2601#1001066.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2601#1001066, false)), []), lambdafunction(named_struct(uom, lambda x_2602#1001072.uom, uomUuid, lambda x_2602#1001072.uomUuid, numerator, lambda x_2602#1001072.numerator, denominator, lambda x_2602#1001072.denominator, isOrderUnit, ((lambda x_2602#1001072.uomUuid = coalesce(sos#1001020.orderQuantityUnit.internalRefUUID, productInformation#1001053.procurementAspect.orderUnit.internalRefUUID, productInformation#1001053.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_2602#1001072.isPreferred), lambda x_2602#1001072, false)) AS logisticUnits#1001071, productInformation#1001053.baseUnitOfMeasure.code AS orderQuantityBaseUom#1001067, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#1001069, CASE WHEN isnull(supplyingPlant#1000975) THEN 4 ELSE 1 END AS preferredUomSourceCode#1001076]
Input [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053]
(68) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN (preferredUomSourceCode#1001076 = 2) THEN productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 3) THEN sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 4) THEN coalesce(productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile, sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile) WHEN (preferredUomSourceCode#1001076 = 5) THEN coalesce(sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) END AS preferredRoundingProfile#1001077]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredUomSourceCode#1001076]
(69) Project
Output [36]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, cast(null as string) AS logisticalRoundingProfile#1001084, cast(null as string) AS _extract_internalRefUUID#1001351]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
(70) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
Input [36]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001084, _extract_internalRefUUID#1001351]
(71) Project
Output [35]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, cast(null as string) AS logisticalRoundingProfile#1001111]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
(72) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001119.uom, uomUuid, lambda x_2603#1001119.uomUuid, numerator, lambda x_2603#1001119.numerator, denominator, lambda x_2603#1001119.denominator, isOrderUnit, lambda x_2603#1001119.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001119.uomUuid) THEN true ELSE lambda x_2603#1001119.isPreferred END), lambda x_2603#1001119, false)), lambdafunction(named_struct(uom, lambda x_2605#1001120.uom, uomUuid, lambda x_2605#1001120.uomUuid, numerator, lambda x_2605#1001120.numerator, denominator, lambda x_2605#1001120.denominator, isOrderUnit, lambda x_2605#1001120.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001121.uom, uomUuid, lambda x_2603#1001121.uomUuid, numerator, lambda x_2603#1001121.numerator, denominator, lambda x_2603#1001121.denominator, isOrderUnit, lambda x_2603#1001121.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001121.uomUuid) THEN true ELSE lambda x_2603#1001121.isPreferred END), lambda x_2603#1001121, false)), lambdafunction(lambda x_2604#1001122.isPreferred, lambda x_2604#1001122, false)), true) THEN lambda x_2605#1001120.isPreferred ELSE lambda x_2605#1001120.isOrderUnit END), lambda x_2605#1001120, false)) AS logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
Input [35]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001111]
(73) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN isnotnull(supplyingPlant#1000975) THEN productPlant#1001036.productionAspect.productPlanningPlants.minimumLotSize ELSE ((sos#1001020.minimumOrderQuantity * cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001126.isOrderUnit, lambda x#1001126, false))[0].numerator as double)) / cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001127.isOrderUnit, lambda x#1001127, false))[0].denominator as double)) END AS minimumOrderQuantity#1001123]
Input [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
(74) Scan parquet
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000002111/0_1_10000002111/constraintprofile]
ReadSchema: struct<product:string,plant:string,orderDateTime:timestamp,constraintprofile:string>
(75) ColumnarToRow [codegen id : 5]
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
(76) Exchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390476]
(77) ShuffleQueryStage
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: 6
(78) BroadcastExchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, timestamp, true], 1970-01-01 00:00:00), isnull(input[2, timestamp, true])),false), [plan_id=391022]
(79) BroadcastQueryStage
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: 14
(80) BroadcastHashJoin
Left keys [6]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(orderDateTime#1000978, 1970-01-01 00:00:00), isnull(orderDateTime#1000978)]
Right keys [6]: [coalesce(product#1001128, ), isnull(product#1001128), coalesce(plant#1001129, ), isnull(plant#1001129), coalesce(orderDateTime#1001130, 1970-01-01 00:00:00), isnull(orderDateTime#1001130)]
Join type: LeftOuter
Join condition: None
(81) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131]
Input [37]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
(82) Scan parquet
Output [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/constraint-profile]
ReadSchema: struct<constraintProfile:string,minServiceLevel:struct<level:double,rank:int,isActive:boolean>,maxServiceLevelEndListing:struct<level:double,rank:int,isActive:boolean>,maxRangeCoverage:struct<range:int,rank:int,isActive:boolean>,minOrderQuantity:struct<rank:int,isActive:boolean>>
(83) ColumnarToRow [codegen id : 6]
Input [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
(84) Project [codegen id : 6]
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137.isActive AS _extract_isActive#1001374, maxRangeCoverage#1001137.range AS _extract_range#1001375, maxRangeCoverage#1001137.rank AS _extract_rank#1001376, minOrderQuantity#1001138]
Input [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
(85) Exchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390497]
(86) ShuffleQueryStage
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: 7
(87) BroadcastExchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=391026]
(88) BroadcastQueryStage
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: 17
(89) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#1001131, ), isnull(constraintProfile#1001131)]
Right keys [2]: [coalesce(constraintProfile#1001132, ), isnull(constraintProfile#1001132)]
Join type: LeftOuter
Join condition: None
(90) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.level END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN cast(_extract_range#1001375 as double) END, coalesce(minimumOrderQuantity#1001123, 0.0), CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.level END, null) AS constraintValues#1001147, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.rank ELSE 0 END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN _extract_rank#1001376 ELSE 0 END, CASE WHEN (minOrderQuantity#1001138.isActive <=> true) THEN minOrderQuantity#1001138.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.rank ELSE 0 END, 0) AS constraintRanks#1001148, array((minServiceLevel#1001134.isActive <=> true), (_extract_isActive#1001374 <=> true), (minOrderQuantity#1001138.isActive <=> true), (maxServiceLevelEndListing#1001136.isActive <=> true), false) AS constraintIsActive#1001149]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131, constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
(91) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_2613#1001186.label = minServiceLevel), lambda x_2613#1001186, false))[0]) THEN element_at(constraintValues#1001147, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2613#1001187.label = minServiceLevel), lambda x_2613#1001187, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2613#1001188.label = minServiceLevel), lambda x_2613#1001188, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_2614#1001189.label = maxRangeCoverage), lambda x_2614#1001189, false))[0]) THEN element_at(constraintValues#1001147, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2614#1001190.label = maxRangeCoverage), lambda x_2614#1001190, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2614#1001191.label = maxRangeCoverage), lambda x_2614#1001191, false))[0].value END END, element_at(constraintValues#1001147, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_2615#1001192.label = maxServiceLevelEndListing), lambda x_2615#1001192, false))[0]) THEN element_at(constraintValues#1001147, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2615#1001193.label = maxServiceLevelEndListing), lambda x_2615#1001193, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2615#1001194.label = maxServiceLevelEndListing), lambda x_2615#1001194, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_2616#1001195.label = lockedOrderQuantity), lambda x_2616#1001195, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2616#1001196.label = lockedOrderQuantity), lambda x_2616#1001196, false))[0].value END) AS constraintValues#1001185, constraintRanks#1001148, array(coalesce(filter(null, lambdafunction((lambda x_2608#1001180.label = minServiceLevel), lambda x_2608#1001180, false))[0].isActive, element_at(constraintIsActive#1001149, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_2609#1001181.label = maxRangeCoverage), lambda x_2609#1001181, false))[0].isActive, element_at(constraintIsActive#1001149, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_2610#1001182.label = minOrderQuantity), lambda x_2610#1001182, false))[0].isActive, element_at(constraintIsActive#1001149, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_2611#1001183.label = maxServiceLevelEndListing), lambda x_2611#1001183, false))[0].isActive, element_at(constraintIsActive#1001149, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_2612#1001184.label = lockedOrderQuantity), lambda x_2612#1001184, false))[0].isActive, false)) AS constraintIsActive#1001179]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001147, constraintRanks#1001148, constraintIsActive#1001149]
(92) Project
Output [42]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053.unitOfMeasures AS _extract_unitOfMeasures#1001372, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN element_at(constraintIsActive#1001179, 3, None, false) THEN element_at(constraintValues#1001185, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, sos#1001020.purchasingPriceAspect.netPrice.amount AS netPriceAmount#1001198, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#1001200, sos#1001020.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#1001202, sos#1001020.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#1001204, sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#1001206, struct(value, CASE WHEN (sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#1001069) THEN (sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001220.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001220, false))[0].denominator as double)) / cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001221.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001221, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#1001219]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179]
(93) Scan parquet
Output [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-unitofmeasurecodes-v2]
ReadSchema: struct<internalUUID:string,isoCode:struct<code:string>>
(94) ColumnarToRow [codegen id : 7]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(95) Project [codegen id : 7]
Output [2]: [internalUUID#1001209, isoCode#1001213.code AS _extract_code#1001350]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(96) Exchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390522]
(97) ShuffleQueryStage
Output [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: 8
(98) BroadcastExchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=391032]
(99) BroadcastQueryStage
Output [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: 18
(100) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001209, ), isnull(internalUUID#1001209)]
Join type: LeftOuter
Join condition: None
(101) Project
Output [43]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001235.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001235, false))[0].productDimensions, lambdafunction((lambda x_2619#1001241.dimensionName.code = VOLUME), lambda x_2619#1001241, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001236.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001236, false))[0].productDimensions, lambdafunction((lambda x_2619#1001242.dimensionName.code = VOLUME), lambda x_2619#1001242, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001237.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001237, false))[0].productDimensions, lambdafunction((lambda x_2619#1001243.dimensionName.code = VOLUME), lambda x_2619#1001243, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001350) AS VOLUME#1001231]
Input [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, internalUUID#1001209, _extract_code#1001350]
(102) ReusedExchange [Reuses operator id: 98]
Output [2]: [internalUUID#1001245, _extract_code#1001347]
(103) BroadcastQueryStage
Output [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: 19
(104) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001245, ), isnull(internalUUID#1001245)]
Join type: LeftOuter
Join condition: None
(105) Project
Output [40]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, filter(array(CURRENCY#1001219, VOLUME#1001231, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001263.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001263, false))[0].productDimensions, lambdafunction((lambda x_2621#1001269.dimensionName.code = GROSS_WT), lambda x_2621#1001269, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001264.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001264, false))[0].productDimensions, lambdafunction((lambda x_2621#1001270.dimensionName.code = GROSS_WT), lambda x_2621#1001270, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001265.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001265, false))[0].productDimensions, lambdafunction((lambda x_2621#1001271.dimensionName.code = GROSS_WT), lambda x_2621#1001271, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001347)), lambdafunction(isnotnull(lambda x_2622#1001273.value), lambda x_2622#1001273, false)) AS measurements#1001272]
Input [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, VOLUME#1001231, internalUUID#1001245, _extract_code#1001347]
(106) Scan parquet
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000002111/SupplyNetworkProfiles/assignments]
ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,supplierGroup:string,optimizationGroups:array<string>>
(107) ColumnarToRow [codegen id : 9]
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
(108) Exchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390566]
(109) ShuffleQueryStage
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: 11
(110) BroadcastExchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[4, string, true], ), isnull(input[4, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=391040]
(111) BroadcastQueryStage
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: 15
(112) BroadcastHashJoin [codegen id : 13]
Left keys [10]: [coalesce(supplierGroup#1000970, ), isnull(supplierGroup#1000970), coalesce(supplier#1000971, ), isnull(supplier#1000971), coalesce(subrange#1000974, ), isnull(subrange#1000974), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(deliveryDateTime#1000973, 1970-01-01 00:00:00), isnull(deliveryDateTime#1000973)]
Right keys [10]: [coalesce(supplierGroup#1001280, ), isnull(supplierGroup#1001280), coalesce(supplier#1001275, ), isnull(supplier#1001275), coalesce(subrange#1001276, ), isnull(subrange#1001276), coalesce(plant#1001277, ), isnull(plant#1001277), coalesce(deliveryDateTime#1001278, 1970-01-01 00:00:00), isnull(deliveryDateTime#1001278)]
Join type: LeftOuter
Join condition: (isnull(supplyingPlant#1000975) AND isnull(productGroup#1000976))
(113) Project [codegen id : 13]
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#1001145, [GE,LE,GE,LE,EQ] AS constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, null AS originalReplenishmentRunId#1001274L, coalesce(optimizationGroups#1001282, []) AS optimizationGroups#1001286]
Input [46]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
(114) ResultQueryStage
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286]
Arguments: 22
(115) Exchange
Input [25]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994]
Arguments: hashpartitioning(product#1000977, plant#1000972, 25), REPARTITION_BY_NUM, [plan_id=390043]
(116) Project
Output [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Input [24]: [internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019, systemId#1000996]
(117) Exchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390046]
(118) BroadcastExchange
Input [24]: [systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=390099]
(119) BroadcastHashJoin
Left keys [2]: [coalesce(sourceOfSupplyUuid#1000982, ), isnull(sourceOfSupplyUuid#1000982)]
Right keys [2]: [coalesce(internalUUID#1000997, ), isnull(internalUUID#1000997)]
Join type: LeftOuter
Join condition: None
(120) Project
Output [26]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, struct(systemId, systemId#1000996, internalUUID, internalUUID#1000997, supplier, supplier#1000998, receiver, receiver#1000999, product, product#1001000, receivingPlant, receivingPlant#1001001, sourceOfSupplyType, sourceOfSupplyType#1001002, purchasingGroup, purchasingGroup#1001003, purchasingOrganization, purchasingOrganization#1001004, productGroup, productGroup#1001005, validFrom, validFrom#1001006, validTo, validTo#1001007, priority, ... 23 more fields) AS sos#1001020]
Input [49]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, systemId#1000996, internalUUID#1000997, supplier#1000998, receiver#1000999, product#1001000, receivingPlant#1001001, sourceOfSupplyType#1001002, purchasingGroup#1001003, purchasingOrganization#1001004, productGroup#1001005, validFrom#1001006, validTo#1001007, priority#1001008, isPurchasingBlocked#1001009, isConsignment#1001010, isDeleted#1001011, supplierSubrange#1001012, plannedDeliveryTimeDays#1001013, orderQuantityUnit#1001014, purchasingPriceAspect#1001015, orderCurrency#1001016, minimumOrderQuantity#1001017, logisticalRoundingProfile#1001018, supplyingPlant#1001019]
(121) Filter
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
Condition : plant#1001026.internalRefUUID IN (25c0d9731dd07bb53999d9a8f04398e0,1c037502c75549dc72c6fc87c802bcec,45f9c5206af43e1e6acbe19d9a246289,24a9ebb440508219166784d4d1c19eef)
(122) Project
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
(123) Exchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390052]
(124) BroadcastExchange
Input [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[3, struct<internalRefUUID:string,id:string>, true].internalRefUUID), coalesce(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID, ), isnull(input[2, struct<internalRefUUID:string,id:string>, true].internalRefUUID)),false), [plan_id=390103]
(125) BroadcastHashJoin
Left keys [4]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972)]
Right keys [4]: [coalesce(product#1001027.internalRefUUID, ), isnull(product#1001027.internalRefUUID), coalesce(plant#1001026.internalRefUUID, ), isnull(plant#1001026.internalRefUUID)]
Join type: LeftOuter
Join condition: None
(126) Project
Output [29]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, CASE WHEN isnotnull(productionAspect#1001029) THEN struct(systemId, systemId#1001024, internalUUID, internalUUID#1001025, plant, plant#1001026, product, product#1001027, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1001028, productionAspect, productionAspect#1001029, salesPlant, salesPlant#1001030, listing, listing#1001031) END AS productPlant#1001036, product#1001027.id AS externalProductId#1001037, plant#1001026.id AS externalPlantId#1001039]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
(127) Filter
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
Condition : isnotnull(internalUUID#1001042)
(128) Project
Output [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Input [12]: [internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052, systemId#1001041]
(129) Exchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390058]
(130) BroadcastExchange
Input [12]: [systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
Arguments: HashedRelationBroadcastMode(List(input[1, string, true]),false), [plan_id=390107]
(131) BroadcastHashJoin
Left keys [1]: [product#1000977]
Right keys [1]: [internalUUID#1001042]
Join type: LeftOuter
Join condition: None
(132) Project
Output [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, CASE WHEN isnotnull(internalUUID#1001042) THEN struct(systemId, systemId#1001041, internalUUID, internalUUID#1001042, id, id#1001043, displayId, displayId#1001044, name, name#1001045, baseUnitOfMeasure, baseUnitOfMeasure#1001046, unitOfMeasures, unitOfMeasures#1001047, unitOfMeasureConversions, unitOfMeasureConversions#1001048, productionAspect, productionAspect#1001049, salesAspect, salesAspect#1001050, procurementAspect, procurementAspect#1001051, productGroup, productGroup#1001052) END AS productInformation#1001053]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, systemId#1001041, internalUUID#1001042, id#1001043, displayId#1001044, name#1001045, baseUnitOfMeasure#1001046, unitOfMeasures#1001047, unitOfMeasureConversions#1001048, productionAspect#1001049, salesAspect#1001050, procurementAspect#1001051, productGroup#1001052]
(133) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(coalesce(transform(filter(productInformation#1001053.unitOfMeasureConversions, lambdafunction((array_contains(transform(productInformation#1001053.unitOfMeasures, lambdafunction(lambda x_2600#1001065.measurementUnit.internalRefUUID, lambda x_2600#1001065, false)), lambda x_2599#1001062.measurementUnit1.internalRefUUID) AND (lambda x_2599#1001062.measurementUnit2.internalRefUUID = productInformation#1001053.baseUnitOfMeasure.internalRefUUID)), lambda x_2599#1001062, false)), lambdafunction(struct(uom, lambda x_2601#1001066.measurementUnit1.code, uomUuid, lambda x_2601#1001066.measurementUnit1.internalRefUUID, numerator, lambda x_2601#1001066.quantityNumerator, denominator, lambda x_2601#1001066.quantityDenominator, isOrderUnit, false, isPreferred, false), lambda x_2601#1001066, false)), []), lambdafunction(named_struct(uom, lambda x_2602#1001072.uom, uomUuid, lambda x_2602#1001072.uomUuid, numerator, lambda x_2602#1001072.numerator, denominator, lambda x_2602#1001072.denominator, isOrderUnit, ((lambda x_2602#1001072.uomUuid = coalesce(sos#1001020.orderQuantityUnit.internalRefUUID, productInformation#1001053.procurementAspect.orderUnit.internalRefUUID, productInformation#1001053.baseUnitOfMeasure.internalRefUUID)) <=> true), isPreferred, lambda x_2602#1001072.isPreferred), lambda x_2602#1001072, false)) AS logisticUnits#1001071, productInformation#1001053.baseUnitOfMeasure.code AS orderQuantityBaseUom#1001067, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS orderQuantityBaseUomUuid#1001069, CASE WHEN isnull(supplyingPlant#1000975) THEN 4 ELSE 1 END AS preferredUomSourceCode#1001076]
Input [30]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053]
(134) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN (preferredUomSourceCode#1001076 = 2) THEN productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 3) THEN sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile WHEN (preferredUomSourceCode#1001076 = 4) THEN coalesce(productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile, sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile) WHEN (preferredUomSourceCode#1001076 = 5) THEN coalesce(sos#1001020.logisticalRoundingProfile.logisticalRoundingProfile, productPlant#1001036.productionAspect.productPlanningPlants.logisticalRoundingProfile.logisticalRoundingProfile) END AS preferredRoundingProfile#1001077]
Input [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredUomSourceCode#1001076]
(135) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#1001084, plant#1001085]
Arguments: [logisticalRoundingProfile#1001084, plant#1001085]
(136) InMemoryRelation
Arguments: [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086], StorageLevel(disk, memory, 2 replicas)
(137) LocalTableScan
Output [3]: [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086]
Arguments: <empty>, [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086]
(138) Project
Output [2]: [logisticalRoundingProfile#1001084, plant#1001085.internalRefUUID AS _extract_internalRefUUID#1001351]
Input [2]: [logisticalRoundingProfile#1001084, plant#1001085]
(139) BroadcastExchange
Input [2]: [logisticalRoundingProfile#1001084, _extract_internalRefUUID#1001351]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false]), coalesce(input[1, string, true], ), isnull(input[1, string, true])),false), [plan_id=390113]
(140) BroadcastHashJoin
Left keys [4]: [coalesce(preferredRoundingProfile#1001077, ), isnull(preferredRoundingProfile#1001077), coalesce(plant#1000972, ), isnull(plant#1000972)]
Right keys [4]: [coalesce(logisticalRoundingProfile#1001084, ), isnull(logisticalRoundingProfile#1001084), coalesce(_extract_internalRefUUID#1001351, ), isnull(_extract_internalRefUUID#1001351)]
Join type: LeftOuter
Join condition: None
(141) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077]
Input [36]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001084, _extract_internalRefUUID#1001351]
(142) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#1001111, plant#1001112]
Arguments: [logisticalRoundingProfile#1001111, plant#1001112], [isnull(plant#1001112.internalRefUUID)]
(143) InMemoryRelation
Arguments: [logisticalRoundingProfile#1001111, plant#1001112, logisticalRoundingRule#1001113], StorageLevel(disk, memory, 2 replicas)
(144) Filter
Input [2]: [logisticalRoundingProfile#1001111, plant#1001112]
Condition : isnull(plant#1001112.internalRefUUID)
(145) Project
Output [1]: [logisticalRoundingProfile#1001111]
Input [2]: [logisticalRoundingProfile#1001111, plant#1001112]
(146) BroadcastExchange
Input [1]: [logisticalRoundingProfile#1001111]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=390117]
(147) BroadcastHashJoin
Left keys [2]: [coalesce(preferredRoundingProfile#1001077, ), isnull(preferredRoundingProfile#1001077)]
Right keys [2]: [coalesce(logisticalRoundingProfile#1001111, ), isnull(logisticalRoundingProfile#1001111)]
Join type: LeftOuter
Join condition: None
(148) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001119.uom, uomUuid, lambda x_2603#1001119.uomUuid, numerator, lambda x_2603#1001119.numerator, denominator, lambda x_2603#1001119.denominator, isOrderUnit, lambda x_2603#1001119.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001119.uomUuid) THEN true ELSE lambda x_2603#1001119.isPreferred END), lambda x_2603#1001119, false)), lambdafunction(named_struct(uom, lambda x_2605#1001120.uom, uomUuid, lambda x_2605#1001120.uomUuid, numerator, lambda x_2605#1001120.numerator, denominator, lambda x_2605#1001120.denominator, isOrderUnit, lambda x_2605#1001120.isOrderUnit, isPreferred, CASE WHEN array_contains(transform(transform(logisticUnits#1001071, lambdafunction(named_struct(uom, lambda x_2603#1001121.uom, uomUuid, lambda x_2603#1001121.uomUuid, numerator, lambda x_2603#1001121.numerator, denominator, lambda x_2603#1001121.denominator, isOrderUnit, lambda x_2603#1001121.isOrderUnit, isPreferred, CASE WHEN array_contains([], lambda x_2603#1001121.uomUuid) THEN true ELSE lambda x_2603#1001121.isPreferred END), lambda x_2603#1001121, false)), lambdafunction(lambda x_2604#1001122.isPreferred, lambda x_2604#1001122, false)), true) THEN lambda x_2605#1001120.isPreferred ELSE lambda x_2605#1001120.isOrderUnit END), lambda x_2605#1001120, false)) AS logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
Input [35]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, preferredRoundingProfile#1001077, logisticalRoundingProfile#1001111]
(149) Project
Output [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN isnotnull(supplyingPlant#1000975) THEN productPlant#1001036.productionAspect.productPlanningPlants.minimumLotSize ELSE ((sos#1001020.minimumOrderQuantity * cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001126.isOrderUnit, lambda x#1001126, false))[0].numerator as double)) / cast(filter(logisticUnits#1001118, lambdafunction(lambda x#1001127.isOrderUnit, lambda x#1001127, false))[0].denominator as double)) END AS minimumOrderQuantity#1001123]
Input [33]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069]
(150) Exchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390074]
(151) BroadcastExchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, timestamp, true], 1970-01-01 00:00:00), isnull(input[2, timestamp, true])),false), [plan_id=390122]
(152) BroadcastHashJoin
Left keys [6]: [coalesce(product#1000977, ), isnull(product#1000977), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(orderDateTime#1000978, 1970-01-01 00:00:00), isnull(orderDateTime#1000978)]
Right keys [6]: [coalesce(product#1001128, ), isnull(product#1001128), coalesce(plant#1001129, ), isnull(plant#1001129), coalesce(orderDateTime#1001130, 1970-01-01 00:00:00), isnull(orderDateTime#1001130)]
Join type: LeftOuter
Join condition: None
(153) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131]
Input [37]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
(154) Project
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137.isActive AS _extract_isActive#1001374, maxRangeCoverage#1001137.range AS _extract_range#1001375, maxRangeCoverage#1001137.rank AS _extract_rank#1001376, minOrderQuantity#1001138]
Input [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
(155) Exchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390079]
(156) BroadcastExchange
Input [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390126]
(157) BroadcastHashJoin
Left keys [2]: [coalesce(constraintProfile#1001131, ), isnull(constraintProfile#1001131)]
Right keys [2]: [coalesce(constraintProfile#1001132, ), isnull(constraintProfile#1001132)]
Join type: LeftOuter
Join condition: None
(158) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.level END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN cast(_extract_range#1001375 as double) END, coalesce(minimumOrderQuantity#1001123, 0.0), CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.level END, null) AS constraintValues#1001147, array(CASE WHEN (minServiceLevel#1001134.isActive <=> true) THEN minServiceLevel#1001134.rank ELSE 0 END, CASE WHEN (_extract_isActive#1001374 <=> true) THEN _extract_rank#1001376 ELSE 0 END, CASE WHEN (minOrderQuantity#1001138.isActive <=> true) THEN minOrderQuantity#1001138.rank ELSE 0 END, CASE WHEN (maxServiceLevelEndListing#1001136.isActive <=> true) THEN maxServiceLevelEndListing#1001136.rank ELSE 0 END, 0) AS constraintRanks#1001148, array((minServiceLevel#1001134.isActive <=> true), (_extract_isActive#1001374 <=> true), (minOrderQuantity#1001138.isActive <=> true), (maxServiceLevelEndListing#1001136.isActive <=> true), false) AS constraintIsActive#1001149]
Input [41]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001123, constraintProfile#1001131, constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
(159) Project
Output [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, array(CASE WHEN isnull(filter(null, lambdafunction((lambda x_2613#1001186.label = minServiceLevel), lambda x_2613#1001186, false))[0]) THEN element_at(constraintValues#1001147, 1, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2613#1001187.label = minServiceLevel), lambda x_2613#1001187, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2613#1001188.label = minServiceLevel), lambda x_2613#1001188, false))[0].value END END, CASE WHEN isnull(filter(null, lambdafunction((lambda x_2614#1001189.label = maxRangeCoverage), lambda x_2614#1001189, false))[0]) THEN element_at(constraintValues#1001147, 2, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2614#1001190.label = maxRangeCoverage), lambda x_2614#1001190, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2614#1001191.label = maxRangeCoverage), lambda x_2614#1001191, false))[0].value END END, element_at(constraintValues#1001147, 3, None, false), CASE WHEN isnull(filter(null, lambdafunction((lambda x_2615#1001192.label = maxServiceLevelEndListing), lambda x_2615#1001192, false))[0]) THEN element_at(constraintValues#1001147, 4, None, false) ELSE CASE WHEN filter(null, lambdafunction((lambda x_2615#1001193.label = maxServiceLevelEndListing), lambda x_2615#1001193, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2615#1001194.label = maxServiceLevelEndListing), lambda x_2615#1001194, false))[0].value END END, CASE WHEN filter(null, lambdafunction((lambda x_2616#1001195.label = lockedOrderQuantity), lambda x_2616#1001195, false))[0].isActive THEN filter(null, lambdafunction((lambda x_2616#1001196.label = lockedOrderQuantity), lambda x_2616#1001196, false))[0].value END) AS constraintValues#1001185, constraintRanks#1001148, array(coalesce(filter(null, lambdafunction((lambda x_2608#1001180.label = minServiceLevel), lambda x_2608#1001180, false))[0].isActive, element_at(constraintIsActive#1001149, 1, None, false)), coalesce(filter(null, lambdafunction((lambda x_2609#1001181.label = maxRangeCoverage), lambda x_2609#1001181, false))[0].isActive, element_at(constraintIsActive#1001149, 2, None, false)), coalesce(filter(null, lambdafunction((lambda x_2610#1001182.label = minOrderQuantity), lambda x_2610#1001182, false))[0].isActive, element_at(constraintIsActive#1001149, 3, None, false)), coalesce(filter(null, lambdafunction((lambda x_2611#1001183.label = maxServiceLevelEndListing), lambda x_2611#1001183, false))[0].isActive, element_at(constraintIsActive#1001149, 4, None, false)), coalesce(filter(null, lambdafunction((lambda x_2612#1001184.label = lockedOrderQuantity), lambda x_2612#1001184, false))[0].isActive, false)) AS constraintIsActive#1001179]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001147, constraintRanks#1001148, constraintIsActive#1001149]
(160) Project
Output [42]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053.unitOfMeasures AS _extract_unitOfMeasures#1001372, productInformation#1001053.baseUnitOfMeasure.internalRefUUID AS _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, CASE WHEN element_at(constraintIsActive#1001179, 3, None, false) THEN element_at(constraintValues#1001185, 3, None, false) ELSE -1.0 END AS minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, sos#1001020.purchasingPriceAspect.netPrice.amount AS netPriceAmount#1001198, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code AS netPriceCurrencyCode#1001200, sos#1001020.purchasingPriceAspect.netPriceQuantity AS netPriceQuantity#1001202, sos#1001020.purchasingPriceAspect.netPriceUnit.code AS netPriceQuantityUom#1001204, sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID AS netPriceQuantityUomUuid#1001206, struct(value, CASE WHEN (sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID <=> orderQuantityBaseUomUuid#1001069) THEN (sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) ELSE (((sos#1001020.purchasingPriceAspect.netPrice.amount / sos#1001020.purchasingPriceAspect.netPriceQuantity) * cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001220.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001220, false))[0].denominator as double)) / cast(filter(logisticUnits#1001118, lambdafunction((lambda x_2617#1001221.uomUuid = sos#1001020.purchasingPriceAspect.netPriceUnit.internalRefUUID), lambda x_2617#1001221, false))[0].numerator as double)) END, dimensionType, 0, dimensionCode, sos#1001020.purchasingPriceAspect.netPrice.currencyCode.code, dimensionCodeUuid, null, isoCode, null) AS CURRENCY#1001219]
Input [35]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, sos#1001020, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179]
(161) Project
Output [2]: [internalUUID#1001209, isoCode#1001213.code AS _extract_code#1001350]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(162) Exchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390086]
(163) BroadcastExchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390132]
(164) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001223.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001223, false))[0].productDimensions, lambdafunction((lambda x_2619#1001225.dimensionName.code = VOLUME), lambda x_2619#1001225, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001209, ), isnull(internalUUID#1001209)]
Join type: LeftOuter
Join condition: None
(165) Project
Output [43]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001235.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001235, false))[0].productDimensions, lambdafunction((lambda x_2619#1001241.dimensionName.code = VOLUME), lambda x_2619#1001241, false))[0].dimensionValue as double), dimensionType, 1, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001236.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001236, false))[0].productDimensions, lambdafunction((lambda x_2619#1001242.dimensionName.code = VOLUME), lambda x_2619#1001242, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2618#1001237.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2618#1001237, false))[0].productDimensions, lambdafunction((lambda x_2619#1001243.dimensionName.code = VOLUME), lambda x_2619#1001243, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001350) AS VOLUME#1001231]
Input [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, internalUUID#1001209, _extract_code#1001350]
(166) Scan parquet
Output [3]: [internalUUID#1001245, isoCode#1001249, systemId#1001244]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-common-unitofmeasurecodes-v2]
ReadSchema: struct<internalUUID:string,isoCode:struct<code:string>>
(167) Project
Output [2]: [internalUUID#1001245, isoCode#1001249.code AS _extract_code#1001347]
Input [3]: [internalUUID#1001245, isoCode#1001249, systemId#1001244]
(168) Exchange
Input [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390091]
(169) BroadcastExchange
Input [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390136]
(170) BroadcastHashJoin
Left keys [2]: [coalesce(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID, ), isnull(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001251.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001251, false))[0].productDimensions, lambdafunction((lambda x_2621#1001253.dimensionName.code = GROSS_WT), lambda x_2621#1001253, false))[0].measurementUnit.internalRefUUID)]
Right keys [2]: [coalesce(internalUUID#1001245, ), isnull(internalUUID#1001245)]
Join type: LeftOuter
Join condition: None
(171) Project
Output [40]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, filter(array(CURRENCY#1001219, VOLUME#1001231, struct(value, cast(filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001263.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001263, false))[0].productDimensions, lambdafunction((lambda x_2621#1001269.dimensionName.code = GROSS_WT), lambda x_2621#1001269, false))[0].dimensionValue as double), dimensionType, 3, dimensionCode, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001264.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001264, false))[0].productDimensions, lambdafunction((lambda x_2621#1001270.dimensionName.code = GROSS_WT), lambda x_2621#1001270, false))[0].measurementUnit.code, dimensionCodeUuid, filter(filter(_extract_unitOfMeasures#1001372, lambdafunction((lambda x_2620#1001265.measurementUnit.internalRefUUID = _extract_internalRefUUID#1001373), lambda x_2620#1001265, false))[0].productDimensions, lambdafunction((lambda x_2621#1001271.dimensionName.code = GROSS_WT), lambda x_2621#1001271, false))[0].measurementUnit.internalRefUUID, isoCode, _extract_code#1001347)), lambdafunction(isnotnull(lambda x_2622#1001273.value), lambda x_2622#1001273, false)) AS measurements#1001272]
Input [45]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, _extract_unitOfMeasures#1001372, _extract_internalRefUUID#1001373, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, CURRENCY#1001219, VOLUME#1001231, internalUUID#1001245, _extract_code#1001347]
(172) Exchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390095]
(173) BroadcastExchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[4, string, true], ), isnull(input[4, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=390140]
(174) BroadcastHashJoin
Left keys [10]: [coalesce(supplierGroup#1000970, ), isnull(supplierGroup#1000970), coalesce(supplier#1000971, ), isnull(supplier#1000971), coalesce(subrange#1000974, ), isnull(subrange#1000974), coalesce(plant#1000972, ), isnull(plant#1000972), coalesce(deliveryDateTime#1000973, 1970-01-01 00:00:00), isnull(deliveryDateTime#1000973)]
Right keys [10]: [coalesce(supplierGroup#1001280, ), isnull(supplierGroup#1001280), coalesce(supplier#1001275, ), isnull(supplier#1001275), coalesce(subrange#1001276, ), isnull(subrange#1001276), coalesce(plant#1001277, ), isnull(plant#1001277), coalesce(deliveryDateTime#1001278, 1970-01-01 00:00:00), isnull(deliveryDateTime#1001278)]
Join type: LeftOuter
Join condition: (isnull(supplyingPlant#1000975) AND isnull(productGroup#1000976))
(175) Project
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, [ServiceLevel,RangeOfCoverage,Quantity,ServiceLevelAtStartOfDelisting,Quantity] AS constraintLabels#1001145, [GE,LE,GE,LE,EQ] AS constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, null AS originalReplenishmentRunId#1001274L, coalesce(optimizationGroups#1001282, []) AS optimizationGroups#1001286]
Input [46]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
(176) AdaptiveSparkPlan
Output [44]: [orderProposalId#1000986L, orderProposalItemId#1000994, supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, externalProductId#1001037, externalPlantId#1001039, logisticUnits#1001118, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, minimumOrderQuantity#1001197, constraintLabels#1001145, constraintOperators#1001146, constraintValues#1001185, constraintRanks#1001148, constraintIsActive#1001179, netPriceAmount#1001198, netPriceCurrencyCode#1001200, netPriceQuantity#1001202, netPriceQuantityUom#1001204, netPriceQuantityUomUuid#1001206, measurements#1001272, originalReplenishmentRunId#1001274L, optimizationGroups#1001286]
Arguments: isFinalPlan=true
(177) TableCacheQueryStage
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: 0
(178) HashAggregate [codegen id : 4]
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1000986L, sequenceId#1000991]
(179) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, sequenceId#1000991, 25), ENSURE_REQUIREMENTS, [plan_id=392755]
(180) ShuffleQueryStage
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: 6
(181) AQEShuffleRead
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: coalesced
(182) HashAggregate [codegen id : 7]
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1000986L, sequenceId#1000991]
(183) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, 25), ENSURE_REQUIREMENTS, [plan_id=393208]
(184) ShuffleQueryStage
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: 11
(185) Project [codegen id : 9]
Output [8]: [orderProposalId#1000986L, sequenceId#1000991, cast(null as bigint) AS orderProposalId#1002198L, cast(null as string) AS optGroupId#1002494, cast(null as string) AS assignmentDetails#1002496, cast(null as string) AS minOrderProfile#1002497, cast(null as string) AS multiplerestrictionprofile#1002498, cast(null as struct<minOrderValue:double,dimensionType:int,unit:string,unitUuid:string,negligibleQuantitiesThreshold:double,acceptanceThreshold:double,isoCode:string>) AS minOrderGoal#1002178]
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
(186) Project [codegen id : 9]
Output [7]: [orderProposalId#1000986L, sequenceId#1000991, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, minOrderGoal#1002178]
Input [8]: [orderProposalId#1000986L, sequenceId#1000991, orderProposalId#1002198L, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, minOrderGoal#1002178]
(187) ObjectHashAggregate
Input [7]: [orderProposalId#1000986L, sequenceId#1000991, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, minOrderGoal#1002178]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions [1]: [partial_collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)]
Aggregate Attributes [1]: [buf#1005085]
Results [3]: [orderProposalId#1000986L, sequenceId#1000991, buf#1005086]
(188) ObjectHashAggregate
Input [3]: [orderProposalId#1000986L, sequenceId#1000991, buf#1005086]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions [1]: [collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)#1002518]
Results [3]: [orderProposalId#1000986L, sequenceId#1000991, filter(collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)#1002518, lambdafunction(isnotnull(lambda x_2623#1002520.optGroupId), lambda x_2623#1002520, false)) AS optimizationGroups#1002519]
(189) ResultQueryStage
Output [3]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519]
Arguments: 13
(190) HashAggregate
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1000986L, sequenceId#1000991]
(191) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, sequenceId#1000991, 25), ENSURE_REQUIREMENTS, [plan_id=390302]
(192) HashAggregate
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1000986L, sequenceId#1000991]
(193) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, 25), ENSURE_REQUIREMENTS, [plan_id=390330]
(194) Sort
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: [orderProposalId#1000986L ASC NULLS FIRST], false, 0
(195) InMemoryTableScan
Output [2]: [orderProposalId#1002198L, sequenceId#1002203]
Arguments: [orderProposalId#1002198L, sequenceId#1002203], [isnotnull(orderProposalId#1002198L)]
(196) InMemoryRelation
Arguments: [orderProposalId#1002198L, orderProposalItemId#1002206, supplierGroup#1002182, supplier#1002183, plant#1002184, deliveryDateTime#1002185, subrange#1002186, supplyingPlant#1002187, productGroup#1002188, product#1002189, orderDateTime#1002190, availabilityDateTime#1002191, nextAvailabilityDateTime#1002192, mrpController#1002193, sourceOfSupplyUuid#1002194, purchasingOrg#1002195, purchasingGroup#1002196, isFallbackOrderOnly#1002197, orderProposalHorizonGroupingId#1002199L, splitIndicator#1002200L, previousOrderProposal#1002201L, clusterId#1002202L, sequenceId#1002203, worklistShardItemId#1002204L, orderProposalItemGroupId#1002205, ... 19 more fields], StorageLevel(disk, memory, 2 replicas)
(197) Filter
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Condition : isnotnull(orderProposalId#1002198L)
(198) HashAggregate
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Keys [2]: [orderProposalId#1002198L, sequenceId#1002203]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1002198L, sequenceId#1002203]
(199) Exchange
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Arguments: hashpartitioning(orderProposalId#1002198L, sequenceId#1002203, 25), ENSURE_REQUIREMENTS, [plan_id=390304]
(200) HashAggregate
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Keys [2]: [orderProposalId#1002198L, sequenceId#1002203]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#1002198L]
(201) Exchange
Input [1]: [orderProposalId#1002198L]
Arguments: hashpartitioning(orderProposalId#1002198L, 25), ENSURE_REQUIREMENTS, [plan_id=390314]
(202) Sort
Input [1]: [orderProposalId#1002198L]
Arguments: [orderProposalId#1002198L ASC NULLS FIRST], false, 0
(203) InMemoryTableScan
Output [2]: [orderProposalId#1002354L, optimizationGroups#1002493]
Arguments: [orderProposalId#1002354L, optimizationGroups#1002493], [isnotnull(orderProposalId#1002354L)]
(204) InMemoryRelation
Arguments: [orderProposalId#1002354L, orderProposalItemId#1002362, supplierGroup#1002338, supplier#1002339, plant#1002340, deliveryDateTime#1002341, subrange#1002342, supplyingPlant#1002343, productGroup#1002344, product#1002345, orderDateTime#1002346, availabilityDateTime#1002347, nextAvailabilityDateTime#1002348, mrpController#1002349, sourceOfSupplyUuid#1002350, purchasingOrg#1002351, purchasingGroup#1002352, isFallbackOrderOnly#1002353, orderProposalHorizonGroupingId#1002355L, splitIndicator#1002356L, previousOrderProposal#1002357L, clusterId#1002358L, sequenceId#1002359, worklistShardItemId#1002360L, orderProposalItemGroupId#1002361, ... 19 more fields], StorageLevel(disk, memory, 2 replicas)
(205) Filter
Input [2]: [orderProposalId#1002354L, optimizationGroups#1002493]
Condition : isnotnull(orderProposalId#1002354L)
(206) Generate
Input [2]: [orderProposalId#1002354L, optimizationGroups#1002493]
Arguments: explode(optimizationGroups#1002493), [orderProposalId#1002354L], true, [optGroupId#1002494]
(207) Filter
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Condition : isnotnull(optGroupId#1002494)
(208) HashAggregate
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Keys [2]: [orderProposalId#1002354L, optGroupId#1002494]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1002354L, optGroupId#1002494]
(209) Exchange
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Arguments: hashpartitioning(orderProposalId#1002354L, optGroupId#1002494, 25), ENSURE_REQUIREMENTS, [plan_id=390306]
(210) HashAggregate
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Keys [2]: [orderProposalId#1002354L, optGroupId#1002494]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1002354L, optGroupId#1002494]
(211) Scan parquet
Output [4]: [optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000002111/SupplyNetworkProfiles/optimization_group]
PushedFilters: [IsNotNull(optGroupId), IsNotNull(minOrderProfile)]
ReadSchema: struct<optGroupId:string,assignmentDetails:string,minOrderProfile:string,multiplerestrictionprofile:string>
(212) Filter
Input [4]: [optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Condition : (isnotnull(optGroupId#1002495) AND isnotnull(minOrderProfile#1002497))
(213) Exchange
Input [4]: [optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390289]
(214) BroadcastExchange
Input [4]: [optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=390309]
(215) BroadcastHashJoin
Left keys [1]: [optGroupId#1002494]
Right keys [1]: [optGroupId#1002495]
Join type: Inner
Join condition: None
(216) Project
Output [5]: [optGroupId#1002494, orderProposalId#1002354L, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Input [6]: [orderProposalId#1002354L, optGroupId#1002494, optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
(217) Exchange
Input [5]: [optGroupId#1002494, orderProposalId#1002354L, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: hashpartitioning(orderProposalId#1002354L, 25), ENSURE_REQUIREMENTS, [plan_id=390315]
(218) Sort
Input [5]: [optGroupId#1002494, orderProposalId#1002354L, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: [orderProposalId#1002354L ASC NULLS FIRST], false, 0
(219) SortMergeJoin
Left keys [1]: [orderProposalId#1002198L]
Right keys [1]: [orderProposalId#1002354L]
Join type: LeftOuter
Join condition: None
(220) Project
Output [5]: [orderProposalId#1002198L, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Input [6]: [orderProposalId#1002198L, optGroupId#1002494, orderProposalId#1002354L, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
(221) Scan parquet
Output [5]: [supplierminimumprofilename#1002155, dimensionType#1002157, dimensionValue#1002158, dimensionUnit#1002159, acceptanceThreshold#1002160]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/supplier-minimum-profile]
ReadSchema: struct<supplierminimumprofilename:string,dimensionType:int,dimensionValue:double,dimensionUnit:struct<dimensionCode:string,dimensionCodeUuid:string>,acceptanceThreshold:double>
(222) Exchange
Input [5]: [supplierminimumprofilename#1002155, dimensionType#1002157, dimensionValue#1002158, dimensionUnit#1002159, acceptanceThreshold#1002160]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390276]
(223) BroadcastExchange
Input [5]: [supplierminimumprofilename#1002155, dimensionType#1002157, dimensionValue#1002158, dimensionUnit#1002159, acceptanceThreshold#1002160]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390321]
(224) BroadcastHashJoin
Left keys [2]: [coalesce(minOrderProfile#1002497, ), isnull(minOrderProfile#1002497)]
Right keys [2]: [coalesce(supplierminimumprofilename#1002155, ), isnull(supplierminimumprofilename#1002155)]
Join type: Inner
Join condition: None
(225) Project
Output [9]: [orderProposalId#1002198L, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, dimensionType#1002157, dimensionValue#1002158, dimensionUnit#1002159, acceptanceThreshold#1002160]
Input [10]: [orderProposalId#1002198L, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, supplierminimumprofilename#1002155, dimensionType#1002157, dimensionValue#1002158, dimensionUnit#1002159, acceptanceThreshold#1002160]
(226) Scan parquet
Output [3]: [internalUUID#1002164, isoCode#1002168, systemId#1002163]
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>>
(227) Project
Output [2]: [internalUUID#1002164, isoCode#1002168.code AS _extract_code#1004281]
Input [3]: [internalUUID#1002164, isoCode#1002168, systemId#1002163]
(228) Exchange
Input [2]: [internalUUID#1002164, _extract_code#1004281]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390281]
(229) BroadcastExchange
Input [2]: [internalUUID#1002164, _extract_code#1004281]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=390325]
(230) BroadcastHashJoin
Left keys [2]: [coalesce(dimensionUnit#1002159.dimensionCodeUuid, ), isnull(dimensionUnit#1002159.dimensionCodeUuid)]
Right keys [2]: [coalesce(internalUUID#1002164, ), isnull(internalUUID#1002164)]
Join type: LeftOuter
Join condition: None
(231) Project
Output [6]: [orderProposalId#1002198L, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, struct(minOrderValue, dimensionValue#1002158, dimensionType, dimensionType#1002157, unit, dimensionUnit#1002159.dimensionCode, unitUuid, dimensionUnit#1002159.dimensionCodeUuid, negligibleQuantitiesThreshold, 0.0, acceptanceThreshold, (acceptanceThreshold#1002160 / 100.0), isoCode, _extract_code#1004281) AS minOrderGoal#1002178]
Input [11]: [orderProposalId#1002198L, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, dimensionType#1002157, dimensionValue#1002158, dimensionUnit#1002159, acceptanceThreshold#1002160, internalUUID#1002164, _extract_code#1004281]
(232) SortMergeJoin
Left keys [1]: [orderProposalId#1000986L]
Right keys [1]: [orderProposalId#1002198L]
Join type: LeftOuter
Join condition: None
(233) Project
Output [7]: [orderProposalId#1000986L, sequenceId#1000991, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, minOrderGoal#1002178]
Input [8]: [orderProposalId#1000986L, sequenceId#1000991, orderProposalId#1002198L, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, minOrderGoal#1002178]
(234) ObjectHashAggregate
Input [7]: [orderProposalId#1000986L, sequenceId#1000991, optGroupId#1002494, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498, minOrderGoal#1002178]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions [1]: [partial_collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)]
Aggregate Attributes [1]: [buf#1005085]
Results [3]: [orderProposalId#1000986L, sequenceId#1000991, buf#1005086]
(235) ObjectHashAggregate
Input [3]: [orderProposalId#1000986L, sequenceId#1000991, buf#1005086]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions [1]: [collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)#1002518]
Results [3]: [orderProposalId#1000986L, sequenceId#1000991, filter(collect_list(struct(optGroupId, optGroupId#1002494, assignmentDetails, assignmentDetails#1002496, minOrderProfile, minOrderProfile#1002497, multiplerestrictionprofile, multiplerestrictionprofile#1002498, minOrderGoal, minOrderGoal#1002178), 0, 0)#1002518, lambdafunction(isnotnull(lambda x_2623#1002520.optGroupId), lambda x_2623#1002520, false)) AS optimizationGroups#1002519]
(236) AdaptiveSparkPlan
Output [3]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519]
Arguments: isFinalPlan=true
(237) Filter
Input [1]: [optimizationGroups#1002519]
Condition : (size(optimizationGroups#1002519.minOrderGoal, true) > 0)
(238) Project
Output [1]: [optimizationGroups#1002519.minOrderGoal AS _extract_minOrderGoal#1008279]
Input [1]: [optimizationGroups#1002519]
(239) Generate
Input [1]: [_extract_minOrderGoal#1008279]
Arguments: explode(_extract_minOrderGoal#1008279), false, [minOrderGoal#1005109]
(240) Filter
Input [1]: [minOrderGoal#1005109]
Condition : (minOrderGoal#1005109.dimensionType <=> 2)
(241) Project
Output [1]: [minOrderGoal#1005109.unit AS uomCategoryName#1005111]
Input [1]: [minOrderGoal#1005109]
(242) Scan parquet
Output [2]: [uomCategoryName#1005102, uoms#1005104]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/uom-category]
PushedFilters: [IsNotNull(uomCategoryName)]
ReadSchema: struct<uomCategoryName:string,uoms:array<struct<internalRefUUID:string,id:string>>>
(243) Filter
Input [2]: [uomCategoryName#1005102, uoms#1005104]
Condition : isnotnull(uomCategoryName#1005102)
(244) Exchange
Input [2]: [uomCategoryName#1005102, uoms#1005104]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=393535]
(245) BroadcastExchange
Input [2]: [uomCategoryName#1005102, uoms#1005104]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=393551]
(246) BroadcastHashJoin
Left keys [1]: [uomCategoryName#1005111]
Right keys [1]: [uomCategoryName#1005102]
Join type: LeftOuter
Join condition: None
(247) Project
Output [1]: [struct(uomCategoryName, uomCategoryName#1005111, uoms, transform(coalesce(uoms#1005104, []), lambdafunction(struct(uom, lambda x_2624#1005118.id, uomUuid, lambda x_2624#1005118.internalRefUUID), lambda x_2624#1005118, false))) AS uomCategory#1005119]
Input [3]: [uomCategoryName#1005111, uomCategoryName#1005102, uoms#1005104]
(248) ObjectHashAggregate
Input [1]: [uomCategory#1005119]
Keys [1]: [dummy AS dummy#1008427]
Functions [1]: [partial_collect_set(uomCategory#1005119, 0, 0)]
Aggregate Attributes [1]: [buf#1008428]
Results [2]: [dummy#1008427, buf#1008429]
(249) Exchange
Input [2]: [dummy#1008427, buf#1008429]
Arguments: hashpartitioning(dummy#1008427, 25), ENSURE_REQUIREMENTS, [plan_id=393556]
(250) ObjectHashAggregate
Input [2]: [dummy#1008427, buf#1008429]
Keys [1]: [dummy#1008427]
Functions [1]: [collect_set(uomCategory#1005119, 0, 0)]
Aggregate Attributes [1]: [collect_set(uomCategory#1005119, 0, 0)#1005129]
Results [1]: [collect_set(uomCategory#1005119, 0, 0)#1005129 AS uomCategories#1005121]
(251) BroadcastNestedLoopJoin
Join type: LeftOuter
Join condition: (dummy#1005130 = dummy)
(252) Project
Output [1]: [coalesce(uomCategories#1005121, []) AS uomCategories#1005131]
Input [2]: [dummy#1005130, uomCategories#1005121]
(253) Filter
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Condition : (isnotnull(configurationVersion#1005135) AND isnotnull(name#1005132))
(254) Exchange
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=393542]
(255) Sort
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Arguments: [name#1005132 ASC NULLS FIRST], false, 0
(256) SortAggregate
Input [4]: [name#1005132, status#1005134, configurationVersion#1005135, settings#1005138]
Keys [1]: [name#1005132]
Functions [1]: [partial_max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))]
Aggregate Attributes [1]: [max#1008432]
Results [2]: [name#1005132, max#1008433]
(257) Exchange
Input [2]: [name#1005132, max#1008433]
Arguments: hashpartitioning(name#1005132, 25), ENSURE_REQUIREMENTS, [plan_id=393565]
(258) Sort
Input [2]: [name#1005132, max#1008433]
Arguments: [name#1005132 ASC NULLS FIRST], false, 0
(259) SortAggregate
Input [2]: [name#1005132, max#1008433]
Keys [1]: [name#1005132]
Functions [1]: [max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))]
Aggregate Attributes [1]: [max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))#1005150]
Results [2]: [name#1005132, max(struct(configurationVersion, configurationVersion#1005135, status, status#1005134, settings, settings#1005138))#1005150 AS best#1005141]
(260) Filter
Input [2]: [name#1005132, best#1005141]
Condition : (isnotnull(best#1005141.status) AND (best#1005141.status = ACTIVE))
(261) Project
Output [3]: [name#1005132, best#1005141.settings AS settings#1005152, best#1005141.configurationVersion AS configurationVersion#1005153]
Input [2]: [name#1005132, best#1005141]
(262) ObjectHashAggregate
Input [3]: [name#1005132, settings#1005152, configurationVersion#1005153]
Keys: []
Functions [1]: [partial_collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)]
Aggregate Attributes [1]: [buf#1008430]
Results [1]: [buf#1008431]
(263) Exchange
Input [1]: [buf#1008431]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=393572]
(264) ObjectHashAggregate
Input [1]: [buf#1008431]
Keys: []
Functions [1]: [collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)#1005160]
Results [1]: [map_from_entries(collect_list(struct(name, name#1005132, configValue, struct(configurationVersion, configurationVersion#1005153, name, name#1005132, settings, settings#1005152, status, ACTIVE)), 0, 0)#1005160) AS insightConfigurations#1005156]
(265) BroadcastExchange
Input [1]: [insightConfigurations#1005156]
Arguments: IdentityBroadcastMode, [plan_id=393575]
(266) BroadcastNestedLoopJoin
Join type: Cross
Join condition: None
(267) Project
Output [3]: [uomCategories#1005131, insightConfigurations#1005156, 0_1_10000002111 AS shardId#1008226]
Input [2]: [uomCategories#1005131, insightConfigurations#1005156]
(268) AdaptiveSparkPlan
Output [3]: [uomCategories#1005131, insightConfigurations#1005156, shardId#1008226]
Arguments: isFinalPlan=false