== Physical Plan ==
AdaptiveSparkPlan (212)
+- == Current Plan ==
ResultQueryStage (210)
+- * Project (209)
+- TableCacheQueryStage (208), Statistics(sizeInBytes=600.0 B, rowCount=25)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (207)
+- == Final Plan ==
ResultQueryStage (160)
+- ObjectHashAggregate (159)
+- ObjectHashAggregate (158)
+- * Project (157)
+- * Project (156)
+- ShuffleQueryStage (155), Statistics(sizeInBytes=600.0 B, rowCount=25)
+- Exchange (154)
+- * HashAggregate (153)
+- AQEShuffleRead (152)
+- ShuffleQueryStage (151), Statistics(sizeInBytes=3.6 KiB, rowCount=155)
+- Exchange (150)
+- * HashAggregate (149)
+- TableCacheQueryStage (148), Statistics(sizeInBytes=235.3 KiB, rowCount=170)
+- InMemoryTableScan (3)
+- InMemoryRelation (4)
+- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
+- == Initial Plan ==
ObjectHashAggregate (206)
+- ObjectHashAggregate (205)
+- Project (204)
+- SortMergeJoin LeftOuter (203)
:- Sort (165)
: +- Exchange (164)
: +- HashAggregate (163)
: +- Exchange (162)
: +- HashAggregate (161)
: +- InMemoryTableScan (3)
: +- InMemoryRelation (4)
: +- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
+- Project (202)
+- BroadcastHashJoin LeftOuter BuildRight (201)
:- Project (196)
: +- BroadcastHashJoin Inner BuildRight (195)
: :- Project (191)
: : +- SortMergeJoin LeftOuter (190)
: : :- Sort (173)
: : : +- Exchange (172)
: : : +- HashAggregate (171)
: : : +- Exchange (170)
: : : +- HashAggregate (169)
: : : +- Filter (168)
: : : +- InMemoryTableScan (166)
: : : +- InMemoryRelation (167)
: : : +- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
: : +- Sort (189)
: : +- Exchange (188)
: : +- Project (187)
: : +- BroadcastHashJoin Inner BuildRight (186)
: : :- HashAggregate (181)
: : : +- Exchange (180)
: : : +- HashAggregate (179)
: : : +- Filter (178)
: : : +- Generate (177)
: : : +- Filter (176)
: : : +- InMemoryTableScan (174)
: : : +- InMemoryRelation (175)
: : : +- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
: : +- BroadcastExchange (185)
: : +- Exchange (184)
: : +- Filter (183)
: : +- Scan parquet (182)
: +- BroadcastExchange (194)
: +- Exchange (193)
: +- Scan parquet (192)
+- BroadcastExchange (200)
+- Exchange (199)
+- Project (198)
+- Scan parquet (197)
+- == Initial Plan ==
Project (211)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (207)
+- == Final Plan ==
ResultQueryStage (160)
+- ObjectHashAggregate (159)
+- ObjectHashAggregate (158)
+- * Project (157)
+- * Project (156)
+- ShuffleQueryStage (155), Statistics(sizeInBytes=600.0 B, rowCount=25)
+- Exchange (154)
+- * HashAggregate (153)
+- AQEShuffleRead (152)
+- ShuffleQueryStage (151), Statistics(sizeInBytes=3.6 KiB, rowCount=155)
+- Exchange (150)
+- * HashAggregate (149)
+- TableCacheQueryStage (148), Statistics(sizeInBytes=235.3 KiB, rowCount=170)
+- InMemoryTableScan (3)
+- InMemoryRelation (4)
+- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
+- == Initial Plan ==
ObjectHashAggregate (206)
+- ObjectHashAggregate (205)
+- Project (204)
+- SortMergeJoin LeftOuter (203)
:- Sort (165)
: +- Exchange (164)
: +- HashAggregate (163)
: +- Exchange (162)
: +- HashAggregate (161)
: +- InMemoryTableScan (3)
: +- InMemoryRelation (4)
: +- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
+- Project (202)
+- BroadcastHashJoin LeftOuter BuildRight (201)
:- Project (196)
: +- BroadcastHashJoin Inner BuildRight (195)
: :- Project (191)
: : +- SortMergeJoin LeftOuter (190)
: : :- Sort (173)
: : : +- Exchange (172)
: : : +- HashAggregate (171)
: : : +- Exchange (170)
: : : +- HashAggregate (169)
: : : +- Filter (168)
: : : +- InMemoryTableScan (166)
: : : +- InMemoryRelation (167)
: : : +- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
: : +- Sort (189)
: : +- Exchange (188)
: : +- Project (187)
: : +- BroadcastHashJoin Inner BuildRight (186)
: : :- HashAggregate (181)
: : : +- Exchange (180)
: : : +- HashAggregate (179)
: : : +- Filter (178)
: : : +- Generate (177)
: : : +- Filter (176)
: : : +- InMemoryTableScan (174)
: : : +- InMemoryRelation (175)
: : : +- AdaptiveSparkPlan (147)
+- == Final Plan ==
ResultQueryStage (85)
+- * Project (84)
+- * BroadcastHashJoin LeftOuter BuildRight (83)
:- Project (76)
: +- BroadcastHashJoin LeftOuter BuildRight (75)
: :- Project (72)
: : +- BroadcastHashJoin LeftOuter BuildRight (71)
: : :- Project (63)
: : : +- Project (62)
: : : +- Project (61)
: : : +- BroadcastHashJoin LeftOuter BuildRight (60)
: : : :- Project (52)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (51)
: : : : :- Project (44)
: : : : : +- Project (43)
: : : : : +- Project (42)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Project (39)
: : : : : +- Project (38)
: : : : : +- Project (37)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (36)
: : : : : :- * Project (27)
: : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (26)
: : : : : : :- * Project (17)
: : : : : : : +- * BroadcastHashJoin LeftOuter BuildRight (16)
: : : : : : : :- ShuffleQueryStage (8), Statistics(sizeInBytes=75.7 KiB, rowCount=170)
: : : : : : : : +- Exchange (7)
: : : : : : : : +- * ColumnarToRow (6)
: : : : : : : : +- Scan parquet (5)
: : : : : : : +- BroadcastQueryStage (15), Statistics(sizeInBytes=6.3 MiB, rowCount=4.34E+3)
: : : : : : : +- BroadcastExchange (14)
: : : : : : : +- ShuffleQueryStage (13), Statistics(sizeInBytes=4.1 MiB, rowCount=4.34E+3)
: : : : : : : +- Exchange (12)
: : : : : : : +- * Project (11)
: : : : : : : +- * ColumnarToRow (10)
: : : : : : : +- Scan parquet (9)
: : : : : : +- BroadcastQueryStage (25), Statistics(sizeInBytes=2.0 MiB, rowCount=573)
: : : : : : +- BroadcastExchange (24)
: : : : : : +- ShuffleQueryStage (23), Statistics(sizeInBytes=468.9 KiB, rowCount=573)
: : : : : : +- Exchange (22)
: : : : : : +- * Project (21)
: : : : : : +- * Filter (20)
: : : : : : +- * ColumnarToRow (19)
: : : : : : +- Scan parquet (18)
: : : : : +- BroadcastQueryStage (35), Statistics(sizeInBytes=2.0 MiB, rowCount=159)
: : : : : +- BroadcastExchange (34)
: : : : : +- ShuffleQueryStage (33), Statistics(sizeInBytes=269.2 KiB, rowCount=159)
: : : : : +- Exchange (32)
: : : : : +- * Project (31)
: : : : : +- * Filter (30)
: : : : : +- * ColumnarToRow (29)
: : : : : +- Scan parquet (28)
: : : : +- BroadcastQueryStage (50), Statistics(sizeInBytes=2.0 MiB, rowCount=170)
: : : : +- BroadcastExchange (49)
: : : : +- ShuffleQueryStage (48), Statistics(sizeInBytes=19.9 KiB, rowCount=170)
: : : : +- Exchange (47)
: : : : +- * ColumnarToRow (46)
: : : : +- Scan parquet (45)
: : : +- BroadcastQueryStage (59), Statistics(sizeInBytes=2.0 MiB, rowCount=5)
: : : +- BroadcastExchange (58)
: : : +- ShuffleQueryStage (57), Statistics(sizeInBytes=832.0 B, rowCount=5)
: : : +- Exchange (56)
: : : +- * Project (55)
: : : +- * ColumnarToRow (54)
: : : +- Scan parquet (53)
: : +- BroadcastQueryStage (70), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: : +- BroadcastExchange (69)
: : +- ShuffleQueryStage (68), Statistics(sizeInBytes=33.3 KiB, rowCount=572)
: : +- Exchange (67)
: : +- * Project (66)
: : +- * ColumnarToRow (65)
: : +- Scan parquet (64)
: +- BroadcastQueryStage (74), Statistics(sizeInBytes=2.0 MiB, rowCount=572)
: +- ReusedExchange (73)
+- BroadcastQueryStage (82), Statistics(sizeInBytes=2.0 MiB, rowCount=40)
+- BroadcastExchange (81)
+- ShuffleQueryStage (80), Statistics(sizeInBytes=8.8 KiB, rowCount=40)
+- Exchange (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
+- == Initial Plan ==
Project (146)
+- BroadcastHashJoin LeftOuter BuildRight (145)
:- Project (142)
: +- BroadcastHashJoin LeftOuter BuildRight (141)
: :- Project (136)
: : +- BroadcastHashJoin LeftOuter BuildRight (135)
: : :- Project (131)
: : : +- Project (130)
: : : +- Project (129)
: : : +- BroadcastHashJoin LeftOuter BuildRight (128)
: : : :- Project (124)
: : : : +- BroadcastHashJoin LeftOuter BuildRight (123)
: : : : :- Project (120)
: : : : : +- Project (119)
: : : : : +- BroadcastHashJoin LeftOuter BuildRight (118)
: : : : : :- Project (112)
: : : : : : +- BroadcastHashJoin LeftOuter BuildRight (111)
: : : : : : :- Project (105)
: : : : : : : +- Project (104)
: : : : : : : +- Project (103)
: : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (102)
: : : : : : : :- Project (97)
: : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (96)
: : : : : : : : :- Project (91)
: : : : : : : : : +- BroadcastHashJoin LeftOuter BuildRight (90)
: : : : : : : : : :- Exchange (86)
: : : : : : : : : : +- Scan parquet (5)
: : : : : : : : : +- BroadcastExchange (89)
: : : : : : : : : +- Exchange (88)
: : : : : : : : : +- Project (87)
: : : : : : : : : +- Scan parquet (9)
: : : : : : : : +- BroadcastExchange (95)
: : : : : : : : +- Exchange (94)
: : : : : : : : +- Project (93)
: : : : : : : : +- Filter (92)
: : : : : : : : +- Scan parquet (18)
: : : : : : : +- BroadcastExchange (101)
: : : : : : : +- Exchange (100)
: : : : : : : +- Project (99)
: : : : : : : +- Filter (98)
: : : : : : : +- Scan parquet (28)
: : : : : : +- BroadcastExchange (110)
: : : : : : +- Project (109)
: : : : : : +- InMemoryTableScan (106)
: : : : : : +- InMemoryRelation (107)
: : : : : : +- LocalTableScan (108)
: : : : : +- BroadcastExchange (117)
: : : : : +- Project (116)
: : : : : +- Filter (115)
: : : : : +- InMemoryTableScan (113)
: : : : : +- InMemoryRelation (114)
: : : : : +- LocalTableScan (108)
: : : : +- BroadcastExchange (122)
: : : : +- Exchange (121)
: : : : +- Scan parquet (45)
: : : +- BroadcastExchange (127)
: : : +- Exchange (126)
: : : +- Project (125)
: : : +- Scan parquet (53)
: : +- BroadcastExchange (134)
: : +- Exchange (133)
: : +- Project (132)
: : +- Scan parquet (64)
: +- BroadcastExchange (140)
: +- Exchange (139)
: +- Project (138)
: +- Scan parquet (137)
+- BroadcastExchange (144)
+- Exchange (143)
+- Scan parquet (77)
: : +- BroadcastExchange (185)
: : +- Exchange (184)
: : +- Filter (183)
: : +- Scan parquet (182)
: +- BroadcastExchange (194)
: +- Exchange (193)
: +- Scan parquet (192)
+- BroadcastExchange (200)
+- Exchange (199)
+- Project (198)
+- Scan parquet (197)
(1) InMemoryTableScan
Output [3]: [optimizationGroups#1002519, orderProposalId#1000986L, sequenceId#1000991]
Arguments: [optimizationGroups#1002519, orderProposalId#1000986L, sequenceId#1000991]
(2) InMemoryRelation
Arguments: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519], StorageLevel(disk, memory, 2 replicas)
(3) InMemoryTableScan
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: [orderProposalId#1000986L, sequenceId#1000991]
(4) 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)
(5) 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>
(6) 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]
(7) 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]
(8) 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
(9) 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>>
(10) 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]
(11) 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]
(12) 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]
(13) 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
(14) 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]
(15) 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
(16) 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
(17) 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]
(18) 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>>>
(19) ColumnarToRow [codegen id : 3]
Input [8]: [internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031, systemId#1001024]
(20) 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)
(21) 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]
(22) 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]
(23) ShuffleQueryStage
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: 2
(24) 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]
(25) BroadcastQueryStage
Output [8]: [systemId#1001024, internalUUID#1001025, plant#1001026, product#1001027, blockedForReplenishmentStartingFrom#1001028, productionAspect#1001029, salesPlant#1001030, listing#1001031]
Arguments: 21
(26) 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
(27) 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]
(28) 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>>
(29) 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]
(30) 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)
(31) 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]
(32) 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]
(33) 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
(34) 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]
(35) 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
(36) BroadcastHashJoin
Left keys [1]: [product#1000977]
Right keys [1]: [internalUUID#1001042]
Join type: LeftOuter
Join condition: None
(37) 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]
(38) 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]
(39) Project
Output [34]: [supplierGroup#1000970, supplier#1000971, plant#1000972, deliveryDateTime#1000973, subrange#1000974, supplyingPlant#1000975, productGroup#1000976, product#1000977, orderDateTime#1000978, availabilityDateTime#1000979, nextAvailabilityDateTime#1000980, mrpController#1000981, sourceOfSupplyUuid#1000982, purchasingOrg#1000983, purchasingGroup#1000984, isFallbackOrderOnly#1000985, orderProposalId#1000986L, orderProposalHorizonGroupingId#1000987L, splitIndicator#1000988L, previousOrderProposal#1000989L, clusterId#1000990L, sequenceId#1000991, worklistShardItemId#1000992L, orderProposalItemGroupId#1000993, orderProposalItemId#1000994, sos#1001020, productPlant#1001036, externalProductId#1001037, externalPlantId#1001039, productInformation#1001053, logisticUnits#1001071, orderQuantityBaseUom#1001067, orderQuantityBaseUomUuid#1001069, 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]
(40) 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]
(41) 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]
(42) 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]
(43) 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]
(44) 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]
(45) 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>
(46) ColumnarToRow [codegen id : 5]
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
(47) Exchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390476]
(48) ShuffleQueryStage
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: 6
(49) 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]
(50) BroadcastQueryStage
Output [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: 14
(51) 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
(52) 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]
(53) 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>>
(54) ColumnarToRow [codegen id : 6]
Input [5]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, maxRangeCoverage#1001137, minOrderQuantity#1001138]
(55) 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]
(56) 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]
(57) ShuffleQueryStage
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: 7
(58) 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]
(59) BroadcastQueryStage
Output [7]: [constraintProfile#1001132, minServiceLevel#1001134, maxServiceLevelEndListing#1001136, _extract_isActive#1001374, _extract_range#1001375, _extract_rank#1001376, minOrderQuantity#1001138]
Arguments: 17
(60) 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
(61) 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]
(62) 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]
(63) 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]
(64) 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>>
(65) ColumnarToRow [codegen id : 7]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(66) Project [codegen id : 7]
Output [2]: [internalUUID#1001209, isoCode#1001213.code AS _extract_code#1001350]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(67) Exchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390522]
(68) ShuffleQueryStage
Output [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: 8
(69) 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]
(70) BroadcastQueryStage
Output [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: 18
(71) 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
(72) 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]
(73) ReusedExchange [Reuses operator id: 69]
Output [2]: [internalUUID#1001245, _extract_code#1001347]
(74) BroadcastQueryStage
Output [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: 19
(75) 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
(76) 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]
(77) 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>>
(78) ColumnarToRow [codegen id : 9]
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
(79) Exchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390566]
(80) ShuffleQueryStage
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: 11
(81) 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]
(82) BroadcastQueryStage
Output [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: 15
(83) 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))
(84) 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]
(85) 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
(86) 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]
(87) 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]
(88) 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]
(89) 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]
(90) 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
(91) 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]
(92) 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)
(93) 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]
(94) 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]
(95) 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]
(96) 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
(97) 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]
(98) 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)
(99) 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]
(100) 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]
(101) 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]
(102) BroadcastHashJoin
Left keys [1]: [product#1000977]
Right keys [1]: [internalUUID#1001042]
Join type: LeftOuter
Join condition: None
(103) 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]
(104) 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]
(105) 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]
(106) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#1001084, plant#1001085]
Arguments: [logisticalRoundingProfile#1001084, plant#1001085]
(107) InMemoryRelation
Arguments: [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086], StorageLevel(disk, memory, 2 replicas)
(108) LocalTableScan
Output [3]: [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086]
Arguments: <empty>, [logisticalRoundingProfile#1001084, plant#1001085, logisticalRoundingRule#1001086]
(109) Project
Output [2]: [logisticalRoundingProfile#1001084, plant#1001085.internalRefUUID AS _extract_internalRefUUID#1001351]
Input [2]: [logisticalRoundingProfile#1001084, plant#1001085]
(110) 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]
(111) 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
(112) 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]
(113) InMemoryTableScan
Output [2]: [logisticalRoundingProfile#1001111, plant#1001112]
Arguments: [logisticalRoundingProfile#1001111, plant#1001112], [isnull(plant#1001112.internalRefUUID)]
(114) InMemoryRelation
Arguments: [logisticalRoundingProfile#1001111, plant#1001112, logisticalRoundingRule#1001113], StorageLevel(disk, memory, 2 replicas)
(115) Filter
Input [2]: [logisticalRoundingProfile#1001111, plant#1001112]
Condition : isnull(plant#1001112.internalRefUUID)
(116) Project
Output [1]: [logisticalRoundingProfile#1001111]
Input [2]: [logisticalRoundingProfile#1001111, plant#1001112]
(117) BroadcastExchange
Input [1]: [logisticalRoundingProfile#1001111]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[0, string, false], ), isnull(input[0, string, false])),false), [plan_id=390117]
(118) 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
(119) 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]
(120) 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]
(121) Exchange
Input [4]: [product#1001128, plant#1001129, orderDateTime#1001130, constraintprofile#1001131]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390074]
(122) 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]
(123) 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
(124) 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]
(125) 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]
(126) 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]
(127) 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]
(128) 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
(129) 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]
(130) 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]
(131) 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]
(132) Project
Output [2]: [internalUUID#1001209, isoCode#1001213.code AS _extract_code#1001350]
Input [3]: [internalUUID#1001209, isoCode#1001213, systemId#1001208]
(133) Exchange
Input [2]: [internalUUID#1001209, _extract_code#1001350]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390086]
(134) 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]
(135) 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
(136) 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]
(137) 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>>
(138) Project
Output [2]: [internalUUID#1001245, isoCode#1001249.code AS _extract_code#1001347]
Input [3]: [internalUUID#1001245, isoCode#1001249, systemId#1001244]
(139) Exchange
Input [2]: [internalUUID#1001245, _extract_code#1001347]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390091]
(140) 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]
(141) 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
(142) 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]
(143) Exchange
Input [6]: [supplier#1001275, subrange#1001276, plant#1001277, deliverydatetime#1001278, supplierGroup#1001280, optimizationGroups#1001282]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390095]
(144) 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]
(145) 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))
(146) 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]
(147) 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
(148) TableCacheQueryStage
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: 0
(149) 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]
(150) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, sequenceId#1000991, 25), ENSURE_REQUIREMENTS, [plan_id=392755]
(151) ShuffleQueryStage
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: 6
(152) AQEShuffleRead
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: coalesced
(153) 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]
(154) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, 25), ENSURE_REQUIREMENTS, [plan_id=393208]
(155) ShuffleQueryStage
Output [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: 11
(156) 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]
(157) 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]
(158) 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]
(159) 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]
(160) ResultQueryStage
Output [3]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519]
Arguments: 13
(161) HashAggregate
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1000986L, sequenceId#1000991]
(162) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, sequenceId#1000991, 25), ENSURE_REQUIREMENTS, [plan_id=390302]
(163) HashAggregate
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Keys [2]: [orderProposalId#1000986L, sequenceId#1000991]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1000986L, sequenceId#1000991]
(164) Exchange
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: hashpartitioning(orderProposalId#1000986L, 25), ENSURE_REQUIREMENTS, [plan_id=390330]
(165) Sort
Input [2]: [orderProposalId#1000986L, sequenceId#1000991]
Arguments: [orderProposalId#1000986L ASC NULLS FIRST], false, 0
(166) InMemoryTableScan
Output [2]: [orderProposalId#1002198L, sequenceId#1002203]
Arguments: [orderProposalId#1002198L, sequenceId#1002203], [isnotnull(orderProposalId#1002198L)]
(167) 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)
(168) Filter
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Condition : isnotnull(orderProposalId#1002198L)
(169) HashAggregate
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Keys [2]: [orderProposalId#1002198L, sequenceId#1002203]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1002198L, sequenceId#1002203]
(170) Exchange
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Arguments: hashpartitioning(orderProposalId#1002198L, sequenceId#1002203, 25), ENSURE_REQUIREMENTS, [plan_id=390304]
(171) HashAggregate
Input [2]: [orderProposalId#1002198L, sequenceId#1002203]
Keys [2]: [orderProposalId#1002198L, sequenceId#1002203]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#1002198L]
(172) Exchange
Input [1]: [orderProposalId#1002198L]
Arguments: hashpartitioning(orderProposalId#1002198L, 25), ENSURE_REQUIREMENTS, [plan_id=390314]
(173) Sort
Input [1]: [orderProposalId#1002198L]
Arguments: [orderProposalId#1002198L ASC NULLS FIRST], false, 0
(174) InMemoryTableScan
Output [2]: [orderProposalId#1002354L, optimizationGroups#1002493]
Arguments: [orderProposalId#1002354L, optimizationGroups#1002493], [isnotnull(orderProposalId#1002354L)]
(175) 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)
(176) Filter
Input [2]: [orderProposalId#1002354L, optimizationGroups#1002493]
Condition : isnotnull(orderProposalId#1002354L)
(177) Generate
Input [2]: [orderProposalId#1002354L, optimizationGroups#1002493]
Arguments: explode(optimizationGroups#1002493), [orderProposalId#1002354L], true, [optGroupId#1002494]
(178) Filter
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Condition : isnotnull(optGroupId#1002494)
(179) HashAggregate
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Keys [2]: [orderProposalId#1002354L, optGroupId#1002494]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1002354L, optGroupId#1002494]
(180) Exchange
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Arguments: hashpartitioning(orderProposalId#1002354L, optGroupId#1002494, 25), ENSURE_REQUIREMENTS, [plan_id=390306]
(181) HashAggregate
Input [2]: [orderProposalId#1002354L, optGroupId#1002494]
Keys [2]: [orderProposalId#1002354L, optGroupId#1002494]
Functions: []
Aggregate Attributes: []
Results [2]: [orderProposalId#1002354L, optGroupId#1002494]
(182) 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>
(183) Filter
Input [4]: [optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Condition : (isnotnull(optGroupId#1002495) AND isnotnull(minOrderProfile#1002497))
(184) Exchange
Input [4]: [optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390289]
(185) BroadcastExchange
Input [4]: [optGroupId#1002495, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=390309]
(186) BroadcastHashJoin
Left keys [1]: [optGroupId#1002494]
Right keys [1]: [optGroupId#1002495]
Join type: Inner
Join condition: None
(187) 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]
(188) Exchange
Input [5]: [optGroupId#1002494, orderProposalId#1002354L, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: hashpartitioning(orderProposalId#1002354L, 25), ENSURE_REQUIREMENTS, [plan_id=390315]
(189) Sort
Input [5]: [optGroupId#1002494, orderProposalId#1002354L, assignmentDetails#1002496, minOrderProfile#1002497, multiplerestrictionprofile#1002498]
Arguments: [orderProposalId#1002354L ASC NULLS FIRST], false, 0
(190) SortMergeJoin
Left keys [1]: [orderProposalId#1002198L]
Right keys [1]: [orderProposalId#1002354L]
Join type: LeftOuter
Join condition: None
(191) 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]
(192) 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>
(193) Exchange
Input [5]: [supplierminimumprofilename#1002155, dimensionType#1002157, dimensionValue#1002158, dimensionUnit#1002159, acceptanceThreshold#1002160]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390276]
(194) 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]
(195) 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
(196) 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]
(197) 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>>
(198) Project
Output [2]: [internalUUID#1002164, isoCode#1002168.code AS _extract_code#1004281]
Input [3]: [internalUUID#1002164, isoCode#1002168, systemId#1002163]
(199) Exchange
Input [2]: [internalUUID#1002164, _extract_code#1004281]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=390281]
(200) 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]
(201) 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
(202) 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]
(203) SortMergeJoin
Left keys [1]: [orderProposalId#1000986L]
Right keys [1]: [orderProposalId#1002198L]
Join type: LeftOuter
Join condition: None
(204) 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]
(205) 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]
(206) 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]
(207) AdaptiveSparkPlan
Output [3]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519]
Arguments: isFinalPlan=true
(208) TableCacheQueryStage
Output [3]: [optimizationGroups#1002519, orderProposalId#1000986L, sequenceId#1000991]
Arguments: 0
(209) Project [codegen id : 1]
Output [4]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519, 0_1_10000002111 AS shardId#1006617]
Input [3]: [optimizationGroups#1002519, orderProposalId#1000986L, sequenceId#1000991]
(210) ResultQueryStage
Output [4]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519, shardId#1006617]
Arguments: 2
(211) Project
Output [4]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519, 0_1_10000002111 AS shardId#1006617]
Input [3]: [optimizationGroups#1002519, orderProposalId#1000986L, sequenceId#1000991]
(212) AdaptiveSparkPlan
Output [4]: [orderProposalId#1000986L, sequenceId#1000991, optimizationGroups#1002519, shardId#1006617]
Arguments: isFinalPlan=false