crp-order-quantity-kpi-service - Details for Query 5545

Submitted Time: 2026/07/21 12:26:56
Duration: 0.2 s
Succeeded Jobs: 8786
Plan Visualization
Show the Stage ID and Task ID that corresponds to the max metric
Details
== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
   +- SaveIntoDataSourceCommand (2)
         +- Project (222)
            +- Project (221)
               +- Project (220)
                  +- Project (219)
                     +- Project (218)
                        +- Project (217)
                           +- Project (216)
                              +- Deduplicate (215)
                                 +- Project (214)
                                    +- Project (213)
                                       +- Project (212)
                                          +- Project (211)
                                             +- Project (210)
                                                +- Filter (209)
                                                   +- Project (208)
                                                      +- Join (207)
                                                         :- Project (205)
                                                         :  +- Project (204)
                                                         :     +- Project (203)
                                                         :        +- Project (202)
                                                         :           +- Project (201)
                                                         :              +- Project (200)
                                                         :                 +- Join (199)
                                                         :                    :- Project (29)
                                                         :                    :  +- Project (28)
                                                         :                    :     +- Project (27)
                                                         :                    :        +- Project (26)
                                                         :                    :           +- Generate (25)
                                                         :                    :              +- Project (24)
                                                         :                    :                 +- Generate (23)
                                                         :                    :                    +- Project (22)
                                                         :                    :                       +- Join (21)
                                                         :                    :                          :- Project (18)
                                                         :                    :                          :  +- Project (17)
                                                         :                    :                          :     +- Join (16)
                                                         :                    :                          :        :- SubqueryAlias (12)
                                                         :                    :                          :        :  +- Project (11)
                                                         :                    :                          :        :     +- Join (10)
                                                         :                    :                          :        :        :- Project (5)
                                                         :                    :                          :        :        :  +- RepartitionByExpression (4)
                                                         :                    :                          :        :        :     +- LogicalRelation (3)
                                                         :                    :                          :        :        +- Project (9)
                                                         :                    :                          :        :           +- Project (8)
                                                         :                    :                          :        :              +- Repartition (7)
                                                         :                    :                          :        :                 +- LogicalRelation (6)
                                                         :                    :                          :        +- Project (15)
                                                         :                    :                          :           +- Repartition (14)
                                                         :                    :                          :              +- LogicalRelation (13)
                                                         :                    :                          +- Repartition (20)
                                                         :                    :                             +- LogicalRelation (19)
                                                         :                    +- Project (198)
                                                         :                       +- Aggregate (197)
                                                         :                          +- Project (196)
                                                         :                             +- Join (195)
                                                         :                                :- Project (111)
                                                         :                                :  +- Filter (110)
                                                         :                                :     +- Join (109)
                                                         :                                :        :- Filter (81)
                                                         :                                :        :  +- Project (80)
                                                         :                                :        :     +- Project (79)
                                                         :                                :        :        +- Generate (78)
                                                         :                                :        :           +- Project (77)
                                                         :                                :        :              +- Aggregate (76)
                                                         :                                :        :                 +- Project (75)
                                                         :                                :        :                    +- Generate (74)
                                                         :                                :        :                       +- Join (73)
                                                         :                                :        :                          :- Repartition (31)
                                                         :                                :        :                          :  +- LogicalRelation (30)
                                                         :                                :        :                          +- Project (72)
                                                         :                                :        :                             +- Join (71)
                                                         :                                :        :                                :- Project (41)
                                                         :                                :        :                                :  +- Project (40)
                                                         :                                :        :                                :     +- Generate (39)
                                                         :                                :        :                                :        +- Project (38)
                                                         :                                :        :                                :           +- Generate (37)
                                                         :                                :        :                                :              +- Project (36)
                                                         :                                :        :                                :                 +- Project (35)
                                                         :                                :        :                                :                    +- Filter (34)
                                                         :                                :        :                                :                       +- Repartition (33)
                                                         :                                :        :                                :                          +- LogicalRelation (32)
                                                         :                                :        :                                +- Deduplicate (70)
                                                         :                                :        :                                   +- Project (69)
                                                         :                                :        :                                      +- Project (68)
                                                         :                                :        :                                         +- Project (67)
                                                         :                                :        :                                            +- Project (66)
                                                         :                                :        :                                               +- Project (65)
                                                         :                                :        :                                                  +- Generate (64)
                                                         :                                :        :                                                     +- Project (63)
                                                         :                                :        :                                                        +- Generate (62)
                                                         :                                :        :                                                           +- Project (61)
                                                         :                                :        :                                                              +- Join (60)
                                                         :                                :        :                                                                 :- Project (57)
                                                         :                                :        :                                                                 :  +- Project (56)
                                                         :                                :        :                                                                 :     +- Join (55)
                                                         :                                :        :                                                                 :        :- SubqueryAlias (51)
                                                         :                                :        :                                                                 :        :  +- Project (50)
                                                         :                                :        :                                                                 :        :     +- Join (49)
                                                         :                                :        :                                                                 :        :        :- Project (44)
                                                         :                                :        :                                                                 :        :        :  +- RepartitionByExpression (43)
                                                         :                                :        :                                                                 :        :        :     +- LogicalRelation (42)
                                                         :                                :        :                                                                 :        :        +- Project (48)
                                                         :                                :        :                                                                 :        :           +- Project (47)
                                                         :                                :        :                                                                 :        :              +- Repartition (46)
                                                         :                                :        :                                                                 :        :                 +- LogicalRelation (45)
                                                         :                                :        :                                                                 :        +- Project (54)
                                                         :                                :        :                                                                 :           +- Repartition (53)
                                                         :                                :        :                                                                 :              +- LogicalRelation (52)
                                                         :                                :        :                                                                 +- Repartition (59)
                                                         :                                :        :                                                                    +- LogicalRelation (58)
                                                         :                                :        +- Project (108)
                                                         :                                :           +- Project (107)
                                                         :                                :              +- Project (106)
                                                         :                                :                 +- Project (105)
                                                         :                                :                    +- Generate (104)
                                                         :                                :                       +- Project (103)
                                                         :                                :                          +- Generate (102)
                                                         :                                :                             +- Project (101)
                                                         :                                :                                +- Join (100)
                                                         :                                :                                   :- Project (97)
                                                         :                                :                                   :  +- Project (96)
                                                         :                                :                                   :     +- Join (95)
                                                         :                                :                                   :        :- SubqueryAlias (91)
                                                         :                                :                                   :        :  +- Project (90)
                                                         :                                :                                   :        :     +- Join (89)
                                                         :                                :                                   :        :        :- Project (84)
                                                         :                                :                                   :        :        :  +- RepartitionByExpression (83)
                                                         :                                :                                   :        :        :     +- LogicalRelation (82)
                                                         :                                :                                   :        :        +- Project (88)
                                                         :                                :                                   :        :           +- Project (87)
                                                         :                                :                                   :        :              +- Repartition (86)
                                                         :                                :                                   :        :                 +- LogicalRelation (85)
                                                         :                                :                                   :        +- Project (94)
                                                         :                                :                                   :           +- Repartition (93)
                                                         :                                :                                   :              +- LogicalRelation (92)
                                                         :                                :                                   +- Repartition (99)
                                                         :                                :                                      +- LogicalRelation (98)
                                                         :                                +- Aggregate (194)
                                                         :                                   +- Project (193)
                                                         :                                      +- Filter (192)
                                                         :                                         +- Join (191)
                                                         :                                            :- Filter (163)
                                                         :                                            :  +- Project (162)
                                                         :                                            :     +- Project (161)
                                                         :                                            :        +- Generate (160)
                                                         :                                            :           +- Project (159)
                                                         :                                            :              +- Aggregate (158)
                                                         :                                            :                 +- Project (157)
                                                         :                                            :                    +- Generate (156)
                                                         :                                            :                       +- Join (155)
                                                         :                                            :                          :- Repartition (113)
                                                         :                                            :                          :  +- LogicalRelation (112)
                                                         :                                            :                          +- Project (154)
                                                         :                                            :                             +- Join (153)
                                                         :                                            :                                :- Project (123)
                                                         :                                            :                                :  +- Project (122)
                                                         :                                            :                                :     +- Generate (121)
                                                         :                                            :                                :        +- Project (120)
                                                         :                                            :                                :           +- Generate (119)
                                                         :                                            :                                :              +- Project (118)
                                                         :                                            :                                :                 +- Project (117)
                                                         :                                            :                                :                    +- Filter (116)
                                                         :                                            :                                :                       +- Repartition (115)
                                                         :                                            :                                :                          +- LogicalRelation (114)
                                                         :                                            :                                +- Deduplicate (152)
                                                         :                                            :                                   +- Project (151)
                                                         :                                            :                                      +- Project (150)
                                                         :                                            :                                         +- Project (149)
                                                         :                                            :                                            +- Project (148)
                                                         :                                            :                                               +- Project (147)
                                                         :                                            :                                                  +- Generate (146)
                                                         :                                            :                                                     +- Project (145)
                                                         :                                            :                                                        +- Generate (144)
                                                         :                                            :                                                           +- Project (143)
                                                         :                                            :                                                              +- Join (142)
                                                         :                                            :                                                                 :- Project (139)
                                                         :                                            :                                                                 :  +- Project (138)
                                                         :                                            :                                                                 :     +- Join (137)
                                                         :                                            :                                                                 :        :- SubqueryAlias (133)
                                                         :                                            :                                                                 :        :  +- Project (132)
                                                         :                                            :                                                                 :        :     +- Join (131)
                                                         :                                            :                                                                 :        :        :- Project (126)
                                                         :                                            :                                                                 :        :        :  +- RepartitionByExpression (125)
                                                         :                                            :                                                                 :        :        :     +- LogicalRelation (124)
                                                         :                                            :                                                                 :        :        +- Project (130)
                                                         :                                            :                                                                 :        :           +- Project (129)
                                                         :                                            :                                                                 :        :              +- Repartition (128)
                                                         :                                            :                                                                 :        :                 +- LogicalRelation (127)
                                                         :                                            :                                                                 :        +- Project (136)
                                                         :                                            :                                                                 :           +- Repartition (135)
                                                         :                                            :                                                                 :              +- LogicalRelation (134)
                                                         :                                            :                                                                 +- Repartition (141)
                                                         :                                            :                                                                    +- LogicalRelation (140)
                                                         :                                            +- Project (190)
                                                         :                                               +- Project (189)
                                                         :                                                  +- Project (188)
                                                         :                                                     +- Project (187)
                                                         :                                                        +- Generate (186)
                                                         :                                                           +- Project (185)
                                                         :                                                              +- Generate (184)
                                                         :                                                                 +- Project (183)
                                                         :                                                                    +- Join (182)
                                                         :                                                                       :- Project (179)
                                                         :                                                                       :  +- Project (178)
                                                         :                                                                       :     +- Join (177)
                                                         :                                                                       :        :- SubqueryAlias (173)
                                                         :                                                                       :        :  +- Project (172)
                                                         :                                                                       :        :     +- Join (171)
                                                         :                                                                       :        :        :- Project (166)
                                                         :                                                                       :        :        :  +- RepartitionByExpression (165)
                                                         :                                                                       :        :        :     +- LogicalRelation (164)
                                                         :                                                                       :        :        +- Project (170)
                                                         :                                                                       :        :           +- Project (169)
                                                         :                                                                       :        :              +- Repartition (168)
                                                         :                                                                       :        :                 +- LogicalRelation (167)
                                                         :                                                                       :        +- Project (176)
                                                         :                                                                       :           +- Repartition (175)
                                                         :                                                                       :              +- LogicalRelation (174)
                                                         :                                                                       +- Repartition (181)
                                                         :                                                                          +- LogicalRelation (180)
                                                         +- LogicalRelation (206)


(1) Execute SaveIntoDataSourceCommand
Output: []

(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.kafka010.KafkaSourceProvider@39407019, [kafka.ssl.keystore.type=PEM, kafka.ssl.truststore.certificates=-----BEGIN CERTIFICATE-----
MIIGDzCCA/egAwIBAgIUJRTgKUjNpiA/y4yfE+RwMDi71fEwDQYJKoZIhvcNAQEL
BQAwgY4xCzAJBgNVBAYTAkRFMRswGQYDVQQIDBJCYWRlbi1XdWVydHRlbWJlcmcx
ETAPBgNVBAcMCFdhbGxkb3JmMQ8wDQYDVQQKDAZTQVAgU0UxHzAdBgNVBAsMFlNB
UCBDUCBEYXRhIE1hbmFnZW1lbnQxHTAbBgNVBAMMFFNBUCBTRSBLYWZrYSBSb290
IENBMB4XDTI0MDIwODEzMTY1NloXDTI3MDUyMzEzMTY1NlowgY4xCzAJBgNVBAYT
AkRFMRswGQYDVQQIDBJCYWRlbi1XdWVydHRlbWJlcmcxETAPBgNVBAcMCFdhbGxk
b3JmMQ8wDQYDVQQKDAZTQVAgU0UxHzAdBgNVBAsMFlNBUCBDUCBEYXRhIE1hbmFn
ZW1lbnQxHTAbBgNVBAMMFFNBUCBTRSBLYWZrYSBSb290IENBMIICIjANBgkqhkiG
9w0BAQEFAAOCAg8AMIICCgKCAgEAoLH563sTndme/L5sUH/LggOO5sgRk6D6eYJi
YgPZFX/o8a0dctgMTBK574kPAZeniwvOIUUeGhKM/Ho4ou/B3XDD/8WtoOIZt4lj
QGyeSlZVFtCI3Ip/ENj5gIuFhO6N209mpw9wIgjhCdCTU+g6uaAe440aqCMhVO5I
54bHp4hSHwkLdNZnsRjSopufEKxWbJm52w7lKHwBwNc0cAckiagne6FbBTliF4K/
bgmfRRwP9fzjcmgno+GGgKastNkJVh6Ku/2NCpOKSzQiGNAQAvqbZbpQIkCt4/PK
Nj4c5pjbRSajwt8JWNHRJ9muJz2Db7ZceQF7H/vcAwlu/IK/ARHygfA72IY164du
QN1qJyi1DkPs1qm5cuA8WbfL8KSqIFeiKoInHL524zeK2Yt5b89sS00ydtLSYbri
1kd31McUCHcj66DDX5xBbNg7bgRx09DNpfwKlUnwC7tphz1DLJprJ9OvhjEZi0w7
TNrL21yETIKGG0qSgebIhLPWTG650i2hEM2dF1t9RfVB4qdhaxS194rkwQPZ2lQ8
74hWnuqiZ3L4XhMp1AO86UoFEWyeCbIFsZ4YHnCNfBOO4t8LSPpUiV9bTIwqG549
upI9tWMZMVV59GiuA4M9oit7vYa1eNxpUhKWpqAVCA66tETln04umAKsywt06pUn
0udI1OsCAwEAAaNjMGEwHQYDVR0OBBYEFGRMbSqCPP1qeNX3hEYn4YAClp/cMB8G
A1UdIwQYMBaAFGRMbSqCPP1qeNX3hEYn4YAClp/cMA8GA1UdEwEB/wQFMAMBAf8w
DgYDVR0PAQH/BAQDAgGGMA0GCSqGSIb3DQEBCwUAA4ICAQBfn+8f1fmSSpUCe1ks
OB6A4KubhEDsQ3XUZ7myBU+nMhLAoPflra3+jcUcq3fqR/ybK2rfEK+Vngf8NBou
YP+1p/QaWJPgzzEEGEEAQx5U57HbnPw7DoDJaUkIoqT3gmLkWTw9R1t+AK+neHnL
tfUygvBkLevcXG4klLjFW1B5/8T9hIg7wK5httXgr+P6sic458tB2oImQWkUIaCh
3NkVAWtLjz81LiaM0fgiI0/kiufq0FZWqhazTTz8qY/qocdHbhEUmA4wSjL1XB/K
UrUC0yB7uN5vpCpunWC3EhkzCLgemIm+DPyREg7euGvg6URuP1VIsoaLstxX6caB
DROwWXY3P7kVZtzHXK6g6lrJAYxtP9tf6dyZhFHf0/XL7kwHVabU+s9MgvDvIaxA
V588fCGJbB9A+QrWxF2QKDzUrygHHd8y+EE6Oj6rbnNEgkxxuP+qDiza/46MVPVh
KzF6gepXlv9fgm2+v3Mu/HRKVAoHPOKefC3KeNv8wZkPn76dC4CEZHU+zB+YgvQ3
n1sgzPdcFfV+0wLOhLJkzbTWJ9znspJMZWYn6CR1VWbiWgDMfM9R18onHGxcAxn4
qfoGuXQDP5cnSOsIUVG75z6dfixzzn41hAaW0bQXP8nbMve5LcZhvmDQtxqNiFZu
/jpDfYNIFFeK2b96ea3PMzQYLg==
-----END CERTIFICATE-----, kafka.bootstrap.servers=4.175.151.0:50094,4.175.151.0:50194,4.175.151.0:50294, kafka.ssl.keystore.key=-----BEGIN PRIVATE KEY-----
MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDZiThCxCqy+tw3
4byO8mNc+uqFs2mtyLeQgh5ftIggMun7/aEqDYZ9kL14TfTSzbnxJzI/qLb4p+39
OqkxuQILIpmU6PX+l4iJitB/84vD41wuN6aZl9sOJjSTcFv1JGTKgTiDNO7ZRcwu
oMcMQfNMlVkpHY38/fgyo17jr+syrf1G1b+Z/bL7Gxo3iYZH6cmiOcpAmRRFBjsY
rxbAu1s35Et8U9nYSO1ZKqcrTBcHQBXmBArMgfkTH+RFEDCq0MjbMWY4KTkJ4Q0f
/bAoaoGaiwn9KI6Y8LxvD9k6Lwwbs9uModwVpZ2Ds8MX7cE8aUThDIdybPeihUzf
PyOlV/0xAgMBAAECggEACWnNIOMAGcP+G+8xT5J8sx8ivz+/88Kk8lx2E+RCFHod
is9rLiCdFHGLKGG/tZBMUruUaqGqbsTGCTRk0ktwI6MW+CUTUYW1RWXnzzSe1H6B
/HhBJeH2y0RDF8r3uLo/IA3y0AcuK4HgI7eme2Dedk67Z6qBLJyhFRBhnJrOA8Ck
G7MUXppnQxNmNrZjismnLxBllBb1kePct/MVYInkumD8AqVlYhF97KkjpS5elnJv
MfJkQlBU7q2JZBkvC0J9Kj8S9ix899rDs2Gb6KGjR/DHJL2Fz18LtkpGCh7oYTyI
s1V4q/8hY7yCIbuCystWEB/GOmCPv+tbHJYBN1tNIQKBgQD3vIjpTrHW9He0Y5kR
PiLT4ekvogz+/a2INsJThXXOeE6Fvcwex6MWoWdd2S6XFWOC7zQ5IbJCwZ8gdW4e
ozbL7nq/hEFWD3sqvf7kRfxSev+b9/QqCo9h75Z+zfRNQKK3H8bBY5jmFU51uR8g
FbuWbVpq7CUS9fHEJBTW7LJ+YQKBgQDgysxKw/Co0+uSGGCSc0SrSvIBTuuHemlc
VhSnsCtgKg5k9/1mkHQCp3xlmNztRcs08/jEHSQxphsNeG/T9oDwcMYXVOgmeBhH
70SfTaODaU/9nZrYPEUro9wZ84sUgkhuxNHZ4QCUcOpiI49r3rGH4z6f1MLokwr+
CVtSpvDQ0QKBgEroDt28lblRIgDBPL8h8pXucPueHB/dxGKza/6lFAHiDpwRz25f
Hsjw9LhDuvqj1Pr6KOg9cBEPSnYeC7Xn0+HFsgfGjZrgA3XhDPko0CqAVllql8E+
gCw0rWSaEYxqRsjoKsi+vLSVLKwb1XV2HMpXNkeuL2eURg3wevyhhTcBAoGAY7CM
OPv8VmLlLb0x1sDXyz9JY9skCMj4wMJMFrHCCrub9psj/cBCMoskV8oa7/7rx2gL
Aq4JxxrrFGY88bt4IylgMCiva6AG5J/vxtYflb+2gbrLWOohouDgU4H2Q/ojNTyD
9CQcpbgNucgbarMv+BuHQkqQxaOwVEjB/z2ZvoECgYEAlBLENuK4E/Hz5zW/n/HZ
smZV4S3l5s9aa28LyS7oRYAIdRbuo36HxkMJB7LdsW1mxAtgzXydZvXe6wn0ayBK
4Rlh3Ge3nj6NXUkpGEgb3/yA92hcc+TT2fL11M5XzdGnr4MNtyxuBv40vIiyj+ZH
SnSwe4JBNbi8JMUOU/PmXwg=
-----END PRIVATE KEY-----, topic=InsightsTopic, kafka.ssl.truststore.type=PEM, kafka.ssl.keystore.certificate.chain=-----BEGIN CERTIFICATE-----
MIIG+jCCBOKgAwIBAgIRAJgFqBGrmJXq2vq43m2zj64wDQYJKoZIhvcNAQELBQAw
eTELMAkGA1UEBhMCREUxDTALBgNVBAcMBEVVMTAxDzANBgNVBAoMBlNBUCBTRTEj
MCEGA1UECwwaU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudHMxJTAjBgNVBAMMHFNB
UCBDbG91ZCBQbGF0Zm9ybSBDbGllbnQgQ0EwHhcNMjUwOTE1MTEyMDA2WhcNMjYw
OTE1MTIyMDA2WjCCAfExCzAJBgNVBAYTAkRFMQ8wDQYDVQQKDAZTQVAgU0UxIzAh
BgNVBAsMGlNBUCBDbG91ZCBQbGF0Zm9ybSBDbGllbnRzMRowGAYDVQQLDBFjZi1l
dTIwLXNhcC1rYWZrYTGCAWMwggFfBgNVBAcMggFWRElrV09RQlJmd1Rqa1FuYjhU
MEtJMXRyY0pVQUtBUlZmLVl0NHZVRHllRnlOMHRYQnlhd3hZNnFUTEgxMk5kbUhf
NEJ4djRQM1I3MzRpSk9GTjlqeUw5bE9hYW90RW1nNHkxdVJqd08yazlFWHJ1Q0xf
YWJkVEJpQWwzMUN3QWxLRFBaNm5icDRjMThTYm15dnJIWm9GVzZSUWVQMnlSSVRJ
Wk1aNmZWR0djUFM2T2VJWmtRYS1KNkdQMEtlLXhkWVhDT24xbFdXdFNGXy1JX19P
QXNTUmhyNHp1bEdmS2pWUVdTYW0yS2FPeWhsY3hsZ3pGT2ZhdUlQWmFXSHhxSThZ
b0JpRE04NUtpT2V5d1duWjhzQlI2ZXNCMlgtTUw0ZDE1SC1fSlFiMDFXNVZ1NWRD
UGNiSGF3Z3I3Y0ljQnFmOUc4WFljcWVUUklJUDRJa1hjY0RBMSkwJwYDVQQDDCBz
YnNzX3VsY3R3bW9hamplX2dpY2ZuajN4aThnbDN5YTCCASIwDQYJKoZIhvcNAQEB
BQADggEPADCCAQoCggEBANmJOELEKrL63DfhvI7yY1z66oWzaa3It5CCHl+0iCAy
6fv9oSoNhn2QvXhN9NLNufEnMj+otvin7f06qTG5AgsimZTo9f6XiImK0H/zi8Pj
XC43ppmX2w4mNJNwW/UkZMqBOIM07tlFzC6gxwxB80yVWSkdjfz9+DKjXuOv6zKt
/UbVv5n9svsbGjeJhkfpyaI5ykCZFEUGOxivFsC7WzfkS3xT2dhI7VkqpytMFwdA
FeYECsyB+RMf5EUQMKrQyNsxZjgpOQnhDR/9sChqgZqLCf0ojpjwvG8P2TovDBuz
24yh3BWlnYOzwxftwTxpROEMh3Js96KFTN8/I6VX/TECAwEAAaOCAQEwgf4wCQYD
VR0TBAIwADAfBgNVHSMEGDAWgBTtx8AzXhKk93kym3vuCviohXiMLzAdBgNVHQ4E
FgQUbN53SjfH93hobdzUsGTksF60DBowDgYDVR0PAQH/BAQDAgWgMBMGA1UdJQQM
MAoGCCsGAQUFBwMCMIGLBgNVHR8EgYMwgYAwfqB8oHqGeGh0dHA6Ly9zYXAtY2xv
dWQtcGxhdGZvcm0tY2xpZW50LWNhLWV1MTAtY3Jscy5zMy5ldS1jZW50cmFsLTEu
YW1hem9uYXdzLmNvbS9jcmwvMmExYjQ5YWMtZmMwMi00YTQ4LTk5M2EtOWE0ZDBk
ZmVjMzNlLmNybDANBgkqhkiG9w0BAQsFAAOCAgEAG/gbwaN6HTtPJZz67NPykGdb
DS0cnHUvlNnY+sE9viSSJAlD7bLEt0XdNM2L4EIwbhib2MdUyW5npgciXbaglRKh
117lT1543BqV/abnt/KVL+4CwG4WcwMfxgrPaT6v7mkTyYZAOte24kI4rMk/0lVn
hew/KBKYIQXvynKtRrl+kKZU52n7MXuyzdFBf0HbPQAYrbMwbB57eUvKbjVEJJWh
gp3+vhX6RUD8m8tx1VJk5Ijo08YbcKUhhUMD8hh89/jPc7TTpu1alVy6oRyBhFa0
JYYHiEQQrPjo0TakG9XuUl2pMViA1fsFEs99ZOjmwr5afzpzbIZedfCzkUprs4+n
o6D3l2LXwC4SkdGeGctWHQoB6fBLvxEWTnOPxergBFdWquASMvt2EntDYtwmoKsY
cnj83AwXpOHweQvXq5bu0UgE1NA1NIUz6poObwQ0IB8RvlM5UgbirJVdYNLVfzd4
TcHVJ6tTDsmgASPWGfSj43uVu9JjNOHbBZb/ktlsOkiF+44TMlko4sNVbbDRdP/S
+ud2LyKXRCCPr17Y6h4cO+0GyKnlAdx9IcHio9OHRz/UU3TyMt3x8Rp6bS2QbDDN
CmYo14JdK1Ju4IHOYk0Pw73+kQJFiqrnqBrJLW4l5Tw5hkpelPzx8iSXQGkiI4Ra
wOM/Grh4HUHtQ7TYRmQ=
-----END CERTIFICATE-----
-----BEGIN CERTIFICATE-----
MIIGYDCCBEigAwIBAgITcAAAAA0Y1cDKQ147YwAAAAAADTANBgkqhkiG9w0BAQsF
ADBNMQswCQYDVQQGEwJERTERMA8GA1UEBwwIV2FsbGRvcmYxDzANBgNVBAoMBlNB
UCBTRTEaMBgGA1UEAwwRU0FQIENsb3VkIFJvb3QgQ0EwHhcNMjMxMTIxMTAzNjE1
WhcNMzMxMTIxMTA0NjE1WjB5MQswCQYDVQQGEwJERTENMAsGA1UEBwwERVUxMDEP
MA0GA1UECgwGU0FQIFNFMSMwIQYDVQQLDBpTQVAgQ2xvdWQgUGxhdGZvcm0gQ2xp
ZW50czElMCMGA1UEAwwcU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudCBDQTCCAiIw
DQYJKoZIhvcNAQEBBQADggIPADCCAgoCggIBAI8hpWjKK+OzKOPvXmlzD0EaWT9I
sINsnw7ek+BuxCtWnWWX1ILIqHjX+47dhD9IY/tUPiLFEI7WAFGoyzSmjY1qclx4
ZFkqvYhOoZe3r6LWL78TX/o1mRYLgg2SCDkDDsmnrT0l/X2fnW+2hb70s/d7q84M
mbrIC1gI0jtAJvFMZm0+82d+a0b3XYrUmmE6FTN0avFPcW4H83lFQJLJKwQ0HI72
Bno6ptle2k7QLZISkw0Mr76qJuHSi6DZxmGb0Ecp5g6X4Q++YdgmMu5gtQikkfIs
/qFnjPdRMKXblA0szRH2HlgNgmflpB3361oWz8jAwkujQz2VLeL+OGoVscAmLcUn
NYieXdUDnaAuUqgKYnc4QyGygVqMMx3g+1VTnXN+xwZ4oinaDucIWkolRZfuOIXo
g8gh50jAO2qy3Z+l783PCFA2RdncMThEuEctvSQXqQex2w/JpXKk+jkhnNOPYdWS
tbwOjofN/CRmlrOKNw8GRCT0YJCrQ/ZP6/C+yDlgAl617wbzjPNhfTi8T+7k1794
QPTKTRcPyJ6tBv6JOb0A7C6UfAA/pEVDhOX9NnB93mFYZxwEw6n2JLhRG/rNvEdf
7NKAs6M1EYhVNFD8iDWukpR2/jGJTgsxJvRk5nEPavgkIS2Mffv2zFnIpaPqv9ox
M01BXHJs6vK6rePfAgMBAAGjggELMIIBBzASBgNVHRMBAf8ECDAGAQH/AgEAMB0G
A1UdDgQWBBTtx8AzXhKk93kym3vuCviohXiMLzAfBgNVHSMEGDAWgBQcvGYrDsqN
S5+Nk3GpD8pnRmkTIjBKBgNVHR8EQzBBMD+gPaA7hjlodHRwOi8vY2RwLnBraS5j
by5zYXAuY29tL2NkcC9TQVAlMjBDbG91ZCUyMFJvb3QlMjBDQS5jcmwwVQYIKwYB
BQUHAQEESTBHMEUGCCsGAQUFBzAChjlodHRwOi8vYWlhLnBraS5jby5zYXAuY29t
L2FpYS9TQVAlMjBDbG91ZCUyMFJvb3QlMjBDQS5jcnQwDgYDVR0PAQH/BAQDAgEG
MA0GCSqGSIb3DQEBCwUAA4ICAQBWP3oZa36jJ+4JakH1kEkCcoKffY9UYFwuBCAL
3jdBruhHH8aLGseI2Zhl5r7os1rkD0Sl55xrM4i1gyeRAyTM/Pe28cBIxFs2vbBC
+4mpIfKPSuTw61P3FOeaqHUgvVJsIiHgfKbMIDzrvwAUMTr453a77DrKZ/oAXW3K
xelNxhfjiCDsWIs++6NbSIwZsQjxPZp39HyN0XBh6BoxN5dmwT9AnlzkqyBiIPwi
TrNxcdCB4MDrwLRZlW21nRb/nTDCfavITqJNAjz1vzNXpSfda74MINstrOwsAcsX
gkYJpxPK7q9VV3vx2ZfZwRIBIxXlisUD/wIkz7zteStT2yfkV8uoh2pweedBgdX1
yah+dWl5LXvSRtmxgGL2CsxZcbQHbnh10OBS9qXBbeN3UswwoXKigYy9v0JkKmKg
knhhNG5+SYVUUzWBCy9DyM2TDMH2VtiZcu2dFqRuzRTi68GXaN9HCIr6gxjqbaPf
yjtQppmfobrrHpBpuI7jM8RPPg2N3Kmj/Wzmf4uPNJT00WUiCG3FdWO4cCX/UxJs
dxAXH+QhykGB1t28JbYpzO1NQohd2shlShkpgqn4ldS6kPC5VWSGUod3139KCrFO
HYFN+t5tRFJ5amXg7nzYf2tGFzsWfa8qMLtuKZWBo+2hvDaxreSSlfTQ6M8QHvS7
TG767A==
-----END CERTIFICATE-----, kafka.security.protocol=SSL], ErrorIfExists

(3) LogicalRelation
Arguments: parquet, [product#1135691, plant#1135692, orderDateTime#1135693, planningStartDateTime#1135694], false

(4) RepartitionByExpression
Arguments: [product#1135691, plant#1135692], 37

(5) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693]

(6) LogicalRelation
Arguments: parquet, [systemId#1135696, internalUUID#1135697, plant#1135698, product#1135699, blockedForReplenishmentStartingFrom#1135700, productionAspect#1135701, salesPlant#1135702, listing#1135703], false

(7) Repartition
Arguments: 37, true

(8) Project
Arguments: [systemId#1135696, internalUUID#1135697, plant#1135698, product#1135699, blockedForReplenishmentStartingFrom#1135700, productionAspect#1135701, salesPlant#1135702, listing#1135703, struct(systemId, systemId#1135696, internalUUID, internalUUID#1135697, plant, plant#1135698, product, product#1135699, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1135700, productionAspect, productionAspect#1135701, salesPlant, salesPlant#1135702, listing, listing#1135703) AS productPlant#1135705]

(9) Project
Arguments: [productPlant#1135705]

(10) Join
Arguments: LeftOuter, ((product#1135691 <=> productPlant#1135705.product.internalRefUUID) AND (plant#1135692 <=> productPlant#1135705.plant.internalRefUUID))

(11) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705]

(12) SubqueryAlias
Arguments: wl

(13) LogicalRelation
Arguments: parquet, [systemId#1135708, internalUUID#1135709, id#1135710, displayId#1135711, name#1135712, category#1135713, companyCode#1135714, address#1135715, mainDistributionChain#1135716, mainPurchasingOrganization#1135717, validPurchasingOrganizations#1135718, productGroup#1135719], false

(14) Repartition
Arguments: 37, true

(15) Project
Arguments: [internalUUID#1135709, address#1135715.timeZone.code AS timezonecode#1135720]

(16) Join
Arguments: LeftOuter, (plant#1135692 <=> internalUUID#1135709)

(17) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, internalUUID#1135709, CASE WHEN isnotnull(timezonecode#1135720) THEN timezonecode#1135720 ELSE UTC END AS timezonecode#1135723]

(18) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723]

(19) LogicalRelation
Arguments: parquet, [systemId#1135724, internalUUID#1135725, id#1135726, displayId#1135727, name#1135728, baseUnitOfMeasure#1135729, unitOfMeasures#1135730, unitOfMeasureConversions#1135731, productionAspect#1135732, salesAspect#1135733, procurementAspect#1135734, productGroup#1135735], false

(20) Repartition
Arguments: 37, true

(21) Join
Arguments: LeftOuter, (product#1135691 = internalUUID#1135725)

(22) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, systemId#1135724, internalUUID#1135725, id#1135726, displayId#1135727, name#1135728, baseUnitOfMeasure#1135729, unitOfMeasures#1135730, unitOfMeasureConversions#1135731, productionAspect#1135732, salesAspect#1135733, procurementAspect#1135734, productGroup#1135735, filter(unitOfMeasureConversions#1135731, lambdafunction((((lambda u#1135738.measurementUnit1.code = productPlant#1135705.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1135738.measurementUnit1.internalRefUUID = productPlant#1135705.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1135738.measurementUnit2.code = baseUnitOfMeasure#1135729.code) AND (lambda u#1135738.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1135729.internalRefUUID))), lambda u#1135738, false)) AS filteredUnitOfMeasureConversions#1135737]

(23) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1135737.quantityNumerator), true, [quantityNumerator#1135745]

(24) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, systemId#1135724, internalUUID#1135725, id#1135726, displayId#1135727, name#1135728, baseUnitOfMeasure#1135729, unitOfMeasures#1135730, unitOfMeasureConversions#1135731, productionAspect#1135732, salesAspect#1135733, procurementAspect#1135734, productGroup#1135735, filteredUnitOfMeasureConversions#1135737, quantityNumerator#1135745]

(25) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1135737.quantityDenominator), true, [quantityDenominator#1135748]

(26) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, systemId#1135724, internalUUID#1135725, id#1135726, displayId#1135727, name#1135728, baseUnitOfMeasure#1135729, unitOfMeasures#1135730, unitOfMeasureConversions#1135731, productionAspect#1135732, salesAspect#1135733, procurementAspect#1135734, productGroup#1135735, filteredUnitOfMeasureConversions#1135737, quantityNumerator#1135745, quantityDenominator#1135748]

(27) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, systemId#1135724, internalUUID#1135725, id#1135726, displayId#1135727, name#1135728, baseUnitOfMeasure#1135729, unitOfMeasures#1135730, unitOfMeasureConversions#1135731, productionAspect#1135732, salesAspect#1135733, procurementAspect#1135734, productGroup#1135735, filteredUnitOfMeasureConversions#1135737, quantityNumerator#1135745, quantityDenominator#1135748, (cast(quantityNumerator#1135745 as double) / cast(quantityDenominator#1135748 as double)) AS outboundUnit#1135749]

(28) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, systemId#1135724, internalUUID#1135725, id#1135726, displayId#1135727, name#1135728, baseUnitOfMeasure#1135729, unitOfMeasures#1135730, unitOfMeasureConversions#1135731, productionAspect#1135732, salesAspect#1135733, procurementAspect#1135734, productGroup#1135735, filteredUnitOfMeasureConversions#1135737, quantityNumerator#1135745, quantityDenominator#1135748, CASE WHEN (isnull(outboundUnit#1135749) OR (outboundUnit#1135749 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1135749 END AS outboundUnit#1135750]

(29) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750]

(30) LogicalRelation
Arguments: parquet, [systemId#1135787, internalUUID#1135788, product#1135789, plant#1135790, calculationDateTime#1135791, stockQuantities#1135792], false

(31) Repartition
Arguments: 37, true

(32) LogicalRelation
Arguments: parquet, [marketUnit#1135751, description#1135752, articleHierarchy#1135753, defaultCurrency#1135754, responsibilities#1135755, replenishmentTypes#1135756, distributionCenters#1135757, assignedArticleHierarchyNodes#1135758, minOrderQtySetting#1135759, listingCheck#1135760, odsSelection#1135761, demandProfiles#1135762, constraintProfiles#1135763, optimizationProfiles#1135764, orderGroupSplitProfiles#1135765, supplierMinimumProfiles#1135766, multipleRestrictionProfiles#1135767, preferredUomSource#1135768, handlingOfUnfulfilledDemands#1135769, negligibleQuantitiesThreshold#1135770, eventtype#1135771, minOrderQtySettingInternal#1135772], false

(33) Repartition
Arguments: 37, true

(34) Filter
Arguments: (marketUnit#1135751 <=> Alert_Test1)

(35) Project
Arguments: [marketUnit#1135751, description#1135752, articleHierarchy#1135753, defaultCurrency#1135754, responsibilities#1135755, replenishmentTypes#1135756, distributionCenters#1135757, assignedArticleHierarchyNodes#1135758, minOrderQtySetting#1135759, listingCheck#1135760, odsSelection#1135761, demandProfiles#1135762, constraintProfiles#1135763, optimizationProfiles#1135764, orderGroupSplitProfiles#1135765, supplierMinimumProfiles#1135766, multipleRestrictionProfiles#1135767, preferredUomSource#1135768, handlingOfUnfulfilledDemands#1135769, negligibleQuantitiesThreshold#1135770, eventtype#1135771, minOrderQtySettingInternal#1135772]

(36) Project
Arguments: [distributionCenters#1135757]

(37) Generate
Arguments: explode(distributionCenters#1135757), false, [distributionCenters#1135775]

(38) Project
Arguments: [distributionCenters#1135775]

(39) Generate
Arguments: explode(distributionCenters#1135775.storageLocations), false, [storageLocations#1135782]

(40) Project
Arguments: [distributionCenters#1135775.id AS plantId#1135776, distributionCenters#1135775.internalRefUUID AS plantUuid#1135777, storageLocations#1135782]

(41) Project
Arguments: [plantId#1135776, plantUuid#1135777, storageLocations#1135782.id AS storageLocId#1135783, storageLocations#1135782.internalRefUUID AS storageLocUuid#1135784]

(42) LogicalRelation
Arguments: parquet, [product#1136047, plant#1136048, orderDateTime#1136049, planningStartDateTime#1136050], false

(43) RepartitionByExpression
Arguments: [product#1136047, plant#1136048], 37

(44) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049]

(45) LogicalRelation
Arguments: parquet, [systemId#1136051, internalUUID#1136052, plant#1136053, product#1136054, blockedForReplenishmentStartingFrom#1136055, productionAspect#1136056, salesPlant#1136057, listing#1136058], false

(46) Repartition
Arguments: 37, true

(47) Project
Arguments: [systemId#1136051, internalUUID#1136052, plant#1136053, product#1136054, blockedForReplenishmentStartingFrom#1136055, productionAspect#1136056, salesPlant#1136057, listing#1136058, struct(systemId, systemId#1136051, internalUUID, internalUUID#1136052, plant, plant#1136053, product, product#1136054, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1136055, productionAspect, productionAspect#1136056, salesPlant, salesPlant#1136057, listing, listing#1136058) AS productPlant#1136059]

(48) Project
Arguments: [productPlant#1136059]

(49) Join
Arguments: LeftOuter, ((product#1136047 <=> productPlant#1136059.product.internalRefUUID) AND (plant#1136048 <=> productPlant#1136059.plant.internalRefUUID))

(50) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059]

(51) SubqueryAlias
Arguments: wl

(52) LogicalRelation
Arguments: parquet, [systemId#1136060, internalUUID#1136061, id#1136062, displayId#1136063, name#1136064, category#1136065, companyCode#1136066, address#1136067, mainDistributionChain#1136068, mainPurchasingOrganization#1136069, validPurchasingOrganizations#1136070, productGroup#1136071], false

(53) Repartition
Arguments: 37, true

(54) Project
Arguments: [internalUUID#1136061, address#1136067.timeZone.code AS timezonecode#1136072]

(55) Join
Arguments: LeftOuter, (plant#1136048 <=> internalUUID#1136061)

(56) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, internalUUID#1136061, CASE WHEN isnotnull(timezonecode#1136072) THEN timezonecode#1136072 ELSE UTC END AS timezonecode#1136073]

(57) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, timezonecode#1136073]

(58) LogicalRelation
Arguments: parquet, [systemId#1136074, internalUUID#1136075, id#1136076, displayId#1136077, name#1136078, baseUnitOfMeasure#1136079, unitOfMeasures#1136080, unitOfMeasureConversions#1136081, productionAspect#1136082, salesAspect#1136083, procurementAspect#1136084, productGroup#1136085], false

(59) Repartition
Arguments: 37, true

(60) Join
Arguments: LeftOuter, (product#1136047 = internalUUID#1136075)

(61) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, timezonecode#1136073, systemId#1136074, internalUUID#1136075, id#1136076, displayId#1136077, name#1136078, baseUnitOfMeasure#1136079, unitOfMeasures#1136080, unitOfMeasureConversions#1136081, productionAspect#1136082, salesAspect#1136083, procurementAspect#1136084, productGroup#1136085, filter(unitOfMeasureConversions#1136081, lambdafunction((((lambda u#1135738.measurementUnit1.code = productPlant#1136059.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1135738.measurementUnit1.internalRefUUID = productPlant#1136059.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1135738.measurementUnit2.code = baseUnitOfMeasure#1136079.code) AND (lambda u#1135738.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1136079.internalRefUUID))), lambda u#1135738, false)) AS filteredUnitOfMeasureConversions#1136086]

(62) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1136086.quantityNumerator), true, [quantityNumerator#1136087]

(63) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, timezonecode#1136073, systemId#1136074, internalUUID#1136075, id#1136076, displayId#1136077, name#1136078, baseUnitOfMeasure#1136079, unitOfMeasures#1136080, unitOfMeasureConversions#1136081, productionAspect#1136082, salesAspect#1136083, procurementAspect#1136084, productGroup#1136085, filteredUnitOfMeasureConversions#1136086, quantityNumerator#1136087]

(64) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1136086.quantityDenominator), true, [quantityDenominator#1136088]

(65) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, timezonecode#1136073, systemId#1136074, internalUUID#1136075, id#1136076, displayId#1136077, name#1136078, baseUnitOfMeasure#1136079, unitOfMeasures#1136080, unitOfMeasureConversions#1136081, productionAspect#1136082, salesAspect#1136083, procurementAspect#1136084, productGroup#1136085, filteredUnitOfMeasureConversions#1136086, quantityNumerator#1136087, quantityDenominator#1136088]

(66) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, timezonecode#1136073, systemId#1136074, internalUUID#1136075, id#1136076, displayId#1136077, name#1136078, baseUnitOfMeasure#1136079, unitOfMeasures#1136080, unitOfMeasureConversions#1136081, productionAspect#1136082, salesAspect#1136083, procurementAspect#1136084, productGroup#1136085, filteredUnitOfMeasureConversions#1136086, quantityNumerator#1136087, quantityDenominator#1136088, (cast(quantityNumerator#1136087 as double) / cast(quantityDenominator#1136088 as double)) AS outboundUnit#1136089]

(67) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, timezonecode#1136073, systemId#1136074, internalUUID#1136075, id#1136076, displayId#1136077, name#1136078, baseUnitOfMeasure#1136079, unitOfMeasures#1136080, unitOfMeasureConversions#1136081, productionAspect#1136082, salesAspect#1136083, procurementAspect#1136084, productGroup#1136085, filteredUnitOfMeasureConversions#1136086, quantityNumerator#1136087, quantityDenominator#1136088, CASE WHEN (isnull(outboundUnit#1136089) OR (outboundUnit#1136089 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1136089 END AS outboundUnit#1136090]

(68) Project
Arguments: [product#1136047, plant#1136048, orderDateTime#1136049, productPlant#1136059, timezonecode#1136073, outboundUnit#1136090]

(69) Project
Arguments: [plant#1136048]

(70) Deduplicate
Arguments: [plant#1136048]

(71) Join
Arguments: Inner, (plantUuid#1135777 = plant#1136048)

(72) Project
Arguments: [plantId#1135776, plantUuid#1135777, storageLocId#1135783, storageLocUuid#1135784]

(73) Join
Arguments: Inner, (plant#1135790.internalRefUUID <=> plantUuid#1135777)

(74) Generate
Arguments: explode(filter(stockQuantities#1135792, lambdafunction(((lambda x#1135796.storageLocation.internalRefUuid = storageLocUuid#1135784) AND (lambda x#1135796.storageLocation.Id = storageLocId#1135783)), lambda x#1135796, false))), false, [stockQuantity#1135797]

(75) Project
Arguments: [systemId#1135787, internalUUID#1135788, product#1135789, plant#1135790, calculationDateTime#1135791, stockQuantities#1135792, plantId#1135776, plantUuid#1135777, storageLocId#1135783, storageLocUuid#1135784, stockQuantity#1135797]

(76) Aggregate
Arguments: [plantUuid#1135777, internalUUID#1135788, plant#1135790, product#1135789, systemId#1135787], [plantUuid#1135777, internalUUID#1135788, plant#1135790, product#1135789, systemId#1135787, first(calculationDateTime#1135791, false) AS calculationDateTime#1135798, collect_list(stockQuantity#1135797, 0, 0) AS stockQuantities#1135799]

(77) Project
Arguments: [systemId#1135787, internalUUID#1135788, product#1135789, plant#1135790, calculationDateTime#1135798, stockQuantities#1135799]

(78) Generate
Arguments: explode(stockQuantities#1135799), false, [stockQuantity#1135814]

(79) Project
Arguments: [systemId#1135787, internalUUID#1135788, product#1135789, plant#1135790, calculationDateTime#1135798, stockQuantities#1135799, stockQuantity#1135814]

(80) Project
Arguments: [plant#1135790.id AS plant#1135815, plant#1135790.internalRefUUID AS plantUuid#1135816, product#1135789.id AS product#1135817, product#1135789.internalRefUUID AS productUuid#1135818, calculationDateTime#1135798, stockQuantity#1135814.storagelocation.id AS storageLocId#1135819, stockQuantity#1135814.storagelocation.internalRefUUID AS storageLocUuid#1135820, stockQuantity#1135814.quantity.measure AS quantity#1135821, stockQuantity#1135814.specialStockIndicator.code AS specialStockIndicator#1135822, stockQuantity#1135814.stockType.code AS stockType#1135823]

(81) Filter
Arguments: ((specialStockIndicator#1135822 = ) AND (stockType#1135823 = 01))

(82) LogicalRelation
Arguments: parquet, [product#1135833, plant#1135834, orderDateTime#1135835, planningStartDateTime#1135836], false

(83) RepartitionByExpression
Arguments: [product#1135833, plant#1135834], 37

(84) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835]

(85) LogicalRelation
Arguments: parquet, [systemId#1135837, internalUUID#1135838, plant#1135839, product#1135840, blockedForReplenishmentStartingFrom#1135841, productionAspect#1135842, salesPlant#1135843, listing#1135844], false

(86) Repartition
Arguments: 37, true

(87) Project
Arguments: [systemId#1135837, internalUUID#1135838, plant#1135839, product#1135840, blockedForReplenishmentStartingFrom#1135841, productionAspect#1135842, salesPlant#1135843, listing#1135844, struct(systemId, systemId#1135837, internalUUID, internalUUID#1135838, plant, plant#1135839, product, product#1135840, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1135841, productionAspect, productionAspect#1135842, salesPlant, salesPlant#1135843, listing, listing#1135844) AS productPlant#1135845]

(88) Project
Arguments: [productPlant#1135845]

(89) Join
Arguments: LeftOuter, ((product#1135833 <=> productPlant#1135845.product.internalRefUUID) AND (plant#1135834 <=> productPlant#1135845.plant.internalRefUUID))

(90) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845]

(91) SubqueryAlias
Arguments: wl

(92) LogicalRelation
Arguments: parquet, [systemId#1135846, internalUUID#1135847, id#1135848, displayId#1135849, name#1135850, category#1135851, companyCode#1135852, address#1135853, mainDistributionChain#1135854, mainPurchasingOrganization#1135855, validPurchasingOrganizations#1135856, productGroup#1135857], false

(93) Repartition
Arguments: 37, true

(94) Project
Arguments: [internalUUID#1135847, address#1135853.timeZone.code AS timezonecode#1135858]

(95) Join
Arguments: LeftOuter, (plant#1135834 <=> internalUUID#1135847)

(96) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, internalUUID#1135847, CASE WHEN isnotnull(timezonecode#1135858) THEN timezonecode#1135858 ELSE UTC END AS timezonecode#1135859]

(97) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, timezonecode#1135859]

(98) LogicalRelation
Arguments: parquet, [systemId#1135860, internalUUID#1135861, id#1135862, displayId#1135863, name#1135864, baseUnitOfMeasure#1135865, unitOfMeasures#1135866, unitOfMeasureConversions#1135867, productionAspect#1135868, salesAspect#1135869, procurementAspect#1135870, productGroup#1135871], false

(99) Repartition
Arguments: 37, true

(100) Join
Arguments: LeftOuter, (product#1135833 = internalUUID#1135861)

(101) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, timezonecode#1135859, systemId#1135860, internalUUID#1135861, id#1135862, displayId#1135863, name#1135864, baseUnitOfMeasure#1135865, unitOfMeasures#1135866, unitOfMeasureConversions#1135867, productionAspect#1135868, salesAspect#1135869, procurementAspect#1135870, productGroup#1135871, filter(unitOfMeasureConversions#1135867, lambdafunction((((lambda u#1135738.measurementUnit1.code = productPlant#1135845.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1135738.measurementUnit1.internalRefUUID = productPlant#1135845.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1135738.measurementUnit2.code = baseUnitOfMeasure#1135865.code) AND (lambda u#1135738.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1135865.internalRefUUID))), lambda u#1135738, false)) AS filteredUnitOfMeasureConversions#1135872]

(102) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1135872.quantityNumerator), true, [quantityNumerator#1135873]

(103) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, timezonecode#1135859, systemId#1135860, internalUUID#1135861, id#1135862, displayId#1135863, name#1135864, baseUnitOfMeasure#1135865, unitOfMeasures#1135866, unitOfMeasureConversions#1135867, productionAspect#1135868, salesAspect#1135869, procurementAspect#1135870, productGroup#1135871, filteredUnitOfMeasureConversions#1135872, quantityNumerator#1135873]

(104) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1135872.quantityDenominator), true, [quantityDenominator#1135874]

(105) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, timezonecode#1135859, systemId#1135860, internalUUID#1135861, id#1135862, displayId#1135863, name#1135864, baseUnitOfMeasure#1135865, unitOfMeasures#1135866, unitOfMeasureConversions#1135867, productionAspect#1135868, salesAspect#1135869, procurementAspect#1135870, productGroup#1135871, filteredUnitOfMeasureConversions#1135872, quantityNumerator#1135873, quantityDenominator#1135874]

(106) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, timezonecode#1135859, systemId#1135860, internalUUID#1135861, id#1135862, displayId#1135863, name#1135864, baseUnitOfMeasure#1135865, unitOfMeasures#1135866, unitOfMeasureConversions#1135867, productionAspect#1135868, salesAspect#1135869, procurementAspect#1135870, productGroup#1135871, filteredUnitOfMeasureConversions#1135872, quantityNumerator#1135873, quantityDenominator#1135874, (cast(quantityNumerator#1135873 as double) / cast(quantityDenominator#1135874 as double)) AS outboundUnit#1135875]

(107) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, timezonecode#1135859, systemId#1135860, internalUUID#1135861, id#1135862, displayId#1135863, name#1135864, baseUnitOfMeasure#1135865, unitOfMeasures#1135866, unitOfMeasureConversions#1135867, productionAspect#1135868, salesAspect#1135869, procurementAspect#1135870, productGroup#1135871, filteredUnitOfMeasureConversions#1135872, quantityNumerator#1135873, quantityDenominator#1135874, CASE WHEN (isnull(outboundUnit#1135875) OR (outboundUnit#1135875 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1135875 END AS outboundUnit#1135876]

(108) Project
Arguments: [product#1135833, plant#1135834, orderDateTime#1135835, productPlant#1135845, timezonecode#1135859, outboundUnit#1135876]

(109) Join
Arguments: Inner, ((plantUuid#1135816 = plant#1135834) AND (productUuid#1135818 = product#1135833))

(110) Filter
Arguments: (calculationDateTime#1135798 <= orderDateTime#1135835)

(111) Project
Arguments: [plantUuid#1135816 AS plant#1135881, productUuid#1135818 AS product#1135882, storageLocId#1135819, calculationDateTime#1135798, quantity#1135821]

(112) LogicalRelation
Arguments: parquet, [systemId#1135890, internalUUID#1135891, product#1135892, plant#1135893, calculationDateTime#1135894, stockQuantities#1135895], false

(113) Repartition
Arguments: 37, true

(114) LogicalRelation
Arguments: parquet, [marketUnit#1135896, description#1135897, articleHierarchy#1135898, defaultCurrency#1135899, responsibilities#1135900, replenishmentTypes#1135901, distributionCenters#1135902, assignedArticleHierarchyNodes#1135903, minOrderQtySetting#1135904, listingCheck#1135905, odsSelection#1135906, demandProfiles#1135907, constraintProfiles#1135908, optimizationProfiles#1135909, orderGroupSplitProfiles#1135910, supplierMinimumProfiles#1135911, multipleRestrictionProfiles#1135912, preferredUomSource#1135913, handlingOfUnfulfilledDemands#1135914, negligibleQuantitiesThreshold#1135915, eventtype#1135916, minOrderQtySettingInternal#1135917], false

(115) Repartition
Arguments: 37, true

(116) Filter
Arguments: (marketUnit#1135896 <=> Alert_Test1)

(117) Project
Arguments: [marketUnit#1135896, description#1135897, articleHierarchy#1135898, defaultCurrency#1135899, responsibilities#1135900, replenishmentTypes#1135901, distributionCenters#1135902, assignedArticleHierarchyNodes#1135903, minOrderQtySetting#1135904, listingCheck#1135905, odsSelection#1135906, demandProfiles#1135907, constraintProfiles#1135908, optimizationProfiles#1135909, orderGroupSplitProfiles#1135910, supplierMinimumProfiles#1135911, multipleRestrictionProfiles#1135912, preferredUomSource#1135913, handlingOfUnfulfilledDemands#1135914, negligibleQuantitiesThreshold#1135915, eventtype#1135916, minOrderQtySettingInternal#1135917]

(118) Project
Arguments: [distributionCenters#1135902]

(119) Generate
Arguments: explode(distributionCenters#1135902), false, [distributionCenters#1135918]

(120) Project
Arguments: [distributionCenters#1135918]

(121) Generate
Arguments: explode(distributionCenters#1135918.storageLocations), false, [storageLocations#1135919]

(122) Project
Arguments: [distributionCenters#1135918.id AS plantId#1135920, distributionCenters#1135918.internalRefUUID AS plantUuid#1135921, storageLocations#1135919]

(123) Project
Arguments: [plantId#1135920, plantUuid#1135921, storageLocations#1135919.id AS storageLocId#1135922, storageLocations#1135919.internalRefUUID AS storageLocUuid#1135923]

(124) LogicalRelation
Arguments: parquet, [product#1135924, plant#1135925, orderDateTime#1135926, planningStartDateTime#1135927], false

(125) RepartitionByExpression
Arguments: [product#1135924, plant#1135925], 37

(126) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926]

(127) LogicalRelation
Arguments: parquet, [systemId#1135928, internalUUID#1135929, plant#1135930, product#1135931, blockedForReplenishmentStartingFrom#1135932, productionAspect#1135933, salesPlant#1135934, listing#1135935], false

(128) Repartition
Arguments: 37, true

(129) Project
Arguments: [systemId#1135928, internalUUID#1135929, plant#1135930, product#1135931, blockedForReplenishmentStartingFrom#1135932, productionAspect#1135933, salesPlant#1135934, listing#1135935, struct(systemId, systemId#1135928, internalUUID, internalUUID#1135929, plant, plant#1135930, product, product#1135931, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1135932, productionAspect, productionAspect#1135933, salesPlant, salesPlant#1135934, listing, listing#1135935) AS productPlant#1135936]

(130) Project
Arguments: [productPlant#1135936]

(131) Join
Arguments: LeftOuter, ((product#1135924 <=> productPlant#1135936.product.internalRefUUID) AND (plant#1135925 <=> productPlant#1135936.plant.internalRefUUID))

(132) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936]

(133) SubqueryAlias
Arguments: wl

(134) LogicalRelation
Arguments: parquet, [systemId#1135937, internalUUID#1135938, id#1135939, displayId#1135940, name#1135941, category#1135942, companyCode#1135943, address#1135944, mainDistributionChain#1135945, mainPurchasingOrganization#1135946, validPurchasingOrganizations#1135947, productGroup#1135948], false

(135) Repartition
Arguments: 37, true

(136) Project
Arguments: [internalUUID#1135938, address#1135944.timeZone.code AS timezonecode#1135949]

(137) Join
Arguments: LeftOuter, (plant#1135925 <=> internalUUID#1135938)

(138) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, internalUUID#1135938, CASE WHEN isnotnull(timezonecode#1135949) THEN timezonecode#1135949 ELSE UTC END AS timezonecode#1135950]

(139) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, timezonecode#1135950]

(140) LogicalRelation
Arguments: parquet, [systemId#1135951, internalUUID#1135952, id#1135953, displayId#1135954, name#1135955, baseUnitOfMeasure#1135956, unitOfMeasures#1135957, unitOfMeasureConversions#1135958, productionAspect#1135959, salesAspect#1135960, procurementAspect#1135961, productGroup#1135962], false

(141) Repartition
Arguments: 37, true

(142) Join
Arguments: LeftOuter, (product#1135924 = internalUUID#1135952)

(143) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, timezonecode#1135950, systemId#1135951, internalUUID#1135952, id#1135953, displayId#1135954, name#1135955, baseUnitOfMeasure#1135956, unitOfMeasures#1135957, unitOfMeasureConversions#1135958, productionAspect#1135959, salesAspect#1135960, procurementAspect#1135961, productGroup#1135962, filter(unitOfMeasureConversions#1135958, lambdafunction((((lambda u#1135738.measurementUnit1.code = productPlant#1135936.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1135738.measurementUnit1.internalRefUUID = productPlant#1135936.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1135738.measurementUnit2.code = baseUnitOfMeasure#1135956.code) AND (lambda u#1135738.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1135956.internalRefUUID))), lambda u#1135738, false)) AS filteredUnitOfMeasureConversions#1135963]

(144) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1135963.quantityNumerator), true, [quantityNumerator#1135964]

(145) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, timezonecode#1135950, systemId#1135951, internalUUID#1135952, id#1135953, displayId#1135954, name#1135955, baseUnitOfMeasure#1135956, unitOfMeasures#1135957, unitOfMeasureConversions#1135958, productionAspect#1135959, salesAspect#1135960, procurementAspect#1135961, productGroup#1135962, filteredUnitOfMeasureConversions#1135963, quantityNumerator#1135964]

(146) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1135963.quantityDenominator), true, [quantityDenominator#1135965]

(147) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, timezonecode#1135950, systemId#1135951, internalUUID#1135952, id#1135953, displayId#1135954, name#1135955, baseUnitOfMeasure#1135956, unitOfMeasures#1135957, unitOfMeasureConversions#1135958, productionAspect#1135959, salesAspect#1135960, procurementAspect#1135961, productGroup#1135962, filteredUnitOfMeasureConversions#1135963, quantityNumerator#1135964, quantityDenominator#1135965]

(148) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, timezonecode#1135950, systemId#1135951, internalUUID#1135952, id#1135953, displayId#1135954, name#1135955, baseUnitOfMeasure#1135956, unitOfMeasures#1135957, unitOfMeasureConversions#1135958, productionAspect#1135959, salesAspect#1135960, procurementAspect#1135961, productGroup#1135962, filteredUnitOfMeasureConversions#1135963, quantityNumerator#1135964, quantityDenominator#1135965, (cast(quantityNumerator#1135964 as double) / cast(quantityDenominator#1135965 as double)) AS outboundUnit#1135966]

(149) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, timezonecode#1135950, systemId#1135951, internalUUID#1135952, id#1135953, displayId#1135954, name#1135955, baseUnitOfMeasure#1135956, unitOfMeasures#1135957, unitOfMeasureConversions#1135958, productionAspect#1135959, salesAspect#1135960, procurementAspect#1135961, productGroup#1135962, filteredUnitOfMeasureConversions#1135963, quantityNumerator#1135964, quantityDenominator#1135965, CASE WHEN (isnull(outboundUnit#1135966) OR (outboundUnit#1135966 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1135966 END AS outboundUnit#1135967]

(150) Project
Arguments: [product#1135924, plant#1135925, orderDateTime#1135926, productPlant#1135936, timezonecode#1135950, outboundUnit#1135967]

(151) Project
Arguments: [plant#1135925]

(152) Deduplicate
Arguments: [plant#1135925]

(153) Join
Arguments: Inner, (plantUuid#1135921 = plant#1135925)

(154) Project
Arguments: [plantId#1135920, plantUuid#1135921, storageLocId#1135922, storageLocUuid#1135923]

(155) Join
Arguments: Inner, (plant#1135893.internalRefUUID <=> plantUuid#1135921)

(156) Generate
Arguments: explode(filter(stockQuantities#1135895, lambdafunction(((lambda x#1135796.storageLocation.internalRefUuid = storageLocUuid#1135923) AND (lambda x#1135796.storageLocation.Id = storageLocId#1135922)), lambda x#1135796, false))), false, [stockQuantity#1135968]

(157) Project
Arguments: [systemId#1135890, internalUUID#1135891, product#1135892, plant#1135893, calculationDateTime#1135894, stockQuantities#1135895, plantId#1135920, plantUuid#1135921, storageLocId#1135922, storageLocUuid#1135923, stockQuantity#1135968]

(158) Aggregate
Arguments: [plantUuid#1135921, internalUUID#1135891, plant#1135893, product#1135892, systemId#1135890], [plantUuid#1135921, internalUUID#1135891, plant#1135893, product#1135892, systemId#1135890, first(calculationDateTime#1135894, false) AS calculationDateTime#1135969, collect_list(stockQuantity#1135968, 0, 0) AS stockQuantities#1135970]

(159) Project
Arguments: [systemId#1135890, internalUUID#1135891, product#1135892, plant#1135893, calculationDateTime#1135969, stockQuantities#1135970]

(160) Generate
Arguments: explode(stockQuantities#1135970), false, [stockQuantity#1135971]

(161) Project
Arguments: [systemId#1135890, internalUUID#1135891, product#1135892, plant#1135893, calculationDateTime#1135969, stockQuantities#1135970, stockQuantity#1135971]

(162) Project
Arguments: [plant#1135893.id AS plant#1135972, plant#1135893.internalRefUUID AS plantUuid#1135973, product#1135892.id AS product#1135974, product#1135892.internalRefUUID AS productUuid#1135975, calculationDateTime#1135969, stockQuantity#1135971.storagelocation.id AS storageLocId#1135976, stockQuantity#1135971.storagelocation.internalRefUUID AS storageLocUuid#1135977, stockQuantity#1135971.quantity.measure AS quantity#1135978, stockQuantity#1135971.specialStockIndicator.code AS specialStockIndicator#1135979, stockQuantity#1135971.stockType.code AS stockType#1135980]

(163) Filter
Arguments: ((specialStockIndicator#1135979 = ) AND (stockType#1135980 = 01))

(164) LogicalRelation
Arguments: parquet, [product#1135981, plant#1135982, orderDateTime#1135983, planningStartDateTime#1135984], false

(165) RepartitionByExpression
Arguments: [product#1135981, plant#1135982], 37

(166) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983]

(167) LogicalRelation
Arguments: parquet, [systemId#1135985, internalUUID#1135986, plant#1135987, product#1135988, blockedForReplenishmentStartingFrom#1135989, productionAspect#1135990, salesPlant#1135991, listing#1135992], false

(168) Repartition
Arguments: 37, true

(169) Project
Arguments: [systemId#1135985, internalUUID#1135986, plant#1135987, product#1135988, blockedForReplenishmentStartingFrom#1135989, productionAspect#1135990, salesPlant#1135991, listing#1135992, struct(systemId, systemId#1135985, internalUUID, internalUUID#1135986, plant, plant#1135987, product, product#1135988, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1135989, productionAspect, productionAspect#1135990, salesPlant, salesPlant#1135991, listing, listing#1135992) AS productPlant#1135993]

(170) Project
Arguments: [productPlant#1135993]

(171) Join
Arguments: LeftOuter, ((product#1135981 <=> productPlant#1135993.product.internalRefUUID) AND (plant#1135982 <=> productPlant#1135993.plant.internalRefUUID))

(172) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993]

(173) SubqueryAlias
Arguments: wl

(174) LogicalRelation
Arguments: parquet, [systemId#1135994, internalUUID#1135995, id#1135996, displayId#1135997, name#1135998, category#1135999, companyCode#1136000, address#1136001, mainDistributionChain#1136002, mainPurchasingOrganization#1136003, validPurchasingOrganizations#1136004, productGroup#1136005], false

(175) Repartition
Arguments: 37, true

(176) Project
Arguments: [internalUUID#1135995, address#1136001.timeZone.code AS timezonecode#1136006]

(177) Join
Arguments: LeftOuter, (plant#1135982 <=> internalUUID#1135995)

(178) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, internalUUID#1135995, CASE WHEN isnotnull(timezonecode#1136006) THEN timezonecode#1136006 ELSE UTC END AS timezonecode#1136007]

(179) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, timezonecode#1136007]

(180) LogicalRelation
Arguments: parquet, [systemId#1136008, internalUUID#1136009, id#1136010, displayId#1136011, name#1136012, baseUnitOfMeasure#1136013, unitOfMeasures#1136014, unitOfMeasureConversions#1136015, productionAspect#1136016, salesAspect#1136017, procurementAspect#1136018, productGroup#1136019], false

(181) Repartition
Arguments: 37, true

(182) Join
Arguments: LeftOuter, (product#1135981 = internalUUID#1136009)

(183) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, timezonecode#1136007, systemId#1136008, internalUUID#1136009, id#1136010, displayId#1136011, name#1136012, baseUnitOfMeasure#1136013, unitOfMeasures#1136014, unitOfMeasureConversions#1136015, productionAspect#1136016, salesAspect#1136017, procurementAspect#1136018, productGroup#1136019, filter(unitOfMeasureConversions#1136015, lambdafunction((((lambda u#1135738.measurementUnit1.code = productPlant#1135993.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1135738.measurementUnit1.internalRefUUID = productPlant#1135993.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1135738.measurementUnit2.code = baseUnitOfMeasure#1136013.code) AND (lambda u#1135738.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1136013.internalRefUUID))), lambda u#1135738, false)) AS filteredUnitOfMeasureConversions#1136020]

(184) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1136020.quantityNumerator), true, [quantityNumerator#1136021]

(185) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, timezonecode#1136007, systemId#1136008, internalUUID#1136009, id#1136010, displayId#1136011, name#1136012, baseUnitOfMeasure#1136013, unitOfMeasures#1136014, unitOfMeasureConversions#1136015, productionAspect#1136016, salesAspect#1136017, procurementAspect#1136018, productGroup#1136019, filteredUnitOfMeasureConversions#1136020, quantityNumerator#1136021]

(186) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1136020.quantityDenominator), true, [quantityDenominator#1136022]

(187) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, timezonecode#1136007, systemId#1136008, internalUUID#1136009, id#1136010, displayId#1136011, name#1136012, baseUnitOfMeasure#1136013, unitOfMeasures#1136014, unitOfMeasureConversions#1136015, productionAspect#1136016, salesAspect#1136017, procurementAspect#1136018, productGroup#1136019, filteredUnitOfMeasureConversions#1136020, quantityNumerator#1136021, quantityDenominator#1136022]

(188) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, timezonecode#1136007, systemId#1136008, internalUUID#1136009, id#1136010, displayId#1136011, name#1136012, baseUnitOfMeasure#1136013, unitOfMeasures#1136014, unitOfMeasureConversions#1136015, productionAspect#1136016, salesAspect#1136017, procurementAspect#1136018, productGroup#1136019, filteredUnitOfMeasureConversions#1136020, quantityNumerator#1136021, quantityDenominator#1136022, (cast(quantityNumerator#1136021 as double) / cast(quantityDenominator#1136022 as double)) AS outboundUnit#1136023]

(189) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, timezonecode#1136007, systemId#1136008, internalUUID#1136009, id#1136010, displayId#1136011, name#1136012, baseUnitOfMeasure#1136013, unitOfMeasures#1136014, unitOfMeasureConversions#1136015, productionAspect#1136016, salesAspect#1136017, procurementAspect#1136018, productGroup#1136019, filteredUnitOfMeasureConversions#1136020, quantityNumerator#1136021, quantityDenominator#1136022, CASE WHEN (isnull(outboundUnit#1136023) OR (outboundUnit#1136023 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1136023 END AS outboundUnit#1136024]

(190) Project
Arguments: [product#1135981, plant#1135982, orderDateTime#1135983, productPlant#1135993, timezonecode#1136007, outboundUnit#1136024]

(191) Join
Arguments: Inner, ((plantUuid#1135973 = plant#1135982) AND (productUuid#1135975 = product#1135981))

(192) Filter
Arguments: (calculationDateTime#1135969 <= orderDateTime#1135983)

(193) Project
Arguments: [plantUuid#1135973 AS plant#1136025, productUuid#1135975 AS product#1136026, storageLocId#1135976, calculationDateTime#1135969, quantity#1135978]

(194) Aggregate
Arguments: [plant#1136025, product#1136026, storageLocId#1135976], [plant#1136025, product#1136026, storageLocId#1135976, max(calculationDateTime#1135969) AS max_calc_datetime#1135883]

(195) Join
Arguments: Inner, ((((plant#1135881 <=> plant#1136025) AND (product#1135882 <=> product#1136026)) AND (storageLocId#1135819 <=> storageLocId#1135976)) AND (calculationDateTime#1135798 <=> max_calc_datetime#1135883))

(196) Project
Arguments: [plant#1135881, product#1135882, storageLocId#1135819, calculationDateTime#1135798, quantity#1135821]

(197) Aggregate
Arguments: [product#1135882, plant#1135881], [product#1135882, plant#1135881, sum(quantity#1135821) AS quantitySum#1136037, min(calculationDateTime#1135798) AS minCalculationDateTime#1136038]

(198) Project
Arguments: [product#1135882, plant#1135881, quantitySum#1136037, minCalculationDateTime#1136038, round(quantitySum#1136037, 0) AS roundedQuantitySum#1136046]

(199) Join
Arguments: LeftOuter, ((plant#1135692 = plant#1135881) AND (product#1135691 = product#1135882))

(200) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750, roundedQuantitySum#1136046, minCalculationDateTime#1136038]

(201) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750, roundedQuantitySum#1136046, minCalculationDateTime#1136038, CASE WHEN isnotnull(minCalculationDateTime#1136038) THEN minCalculationDateTime#1136038 ELSE orderDateTime#1135693 END AS stockDatetime#1136095]

(202) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750, roundedQuantitySum#1136046, minCalculationDateTime#1136038, stockDatetime#1136095, CASE WHEN isnotnull(roundedQuantitySum#1136046) THEN array(roundedQuantitySum#1136046) ELSE array(0.0) END AS stockBatchQuantities#1136096]

(203) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750, roundedQuantitySum#1136046, minCalculationDateTime#1136038, stockDatetime#1136095, stockBatchQuantities#1136096, array(2199-01-01 00:00:00) AS stockBatchShelfLifeEndDatetimes#1136097]

(204) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750, roundedQuantitySum#1136046, stockDatetime#1136095, stockBatchQuantities#1136096, stockBatchShelfLifeEndDatetimes#1136097]

(205) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750, stockDatetime#1136095, stockBatchQuantities#1136096, stockBatchShelfLifeEndDatetimes#1136097]

(206) LogicalRelation
Arguments: parquet, [product#1136098, plant#1136099, demandChannel#1136100, demandStream#1136101, considerVariance#1136102, demandTimeBuckets#1136103, demandPointInTimeStart#1136104, demandPointInTimeEnd#1136105, demandPointInTime#1136106], false

(207) Join
Arguments: LeftOuter, ((product#1135691 = product#1136098) AND (plant#1135692 = plant#1136099))

(208) Project
Arguments: [product#1135691, plant#1135692, orderDateTime#1135693, productPlant#1135705, timezonecode#1135723, outboundUnit#1135750, stockDatetime#1136095, stockBatchQuantities#1136096, stockBatchShelfLifeEndDatetimes#1136097, demandChannel#1136100, demandStream#1136101, considerVariance#1136102, demandTimeBuckets#1136103, demandPointInTimeStart#1136104, demandPointInTimeEnd#1136105, demandPointInTime#1136106]

(209) Filter
Arguments: (((size(demandTimeBuckets#1136103, true) = 0) OR isnull(demandTimeBuckets#1136103)) AND ((size(demandPointInTime#1136106, true) = 0) OR isnull(demandPointInTime#1136106)))

(210) Project
Arguments: [product#1135691, plant#1135692]

(211) Project
Arguments: [product#1135691, plant#1135692, 1 AS configurationVersion#1136108]

(212) Project
Arguments: [product#1135691, plant#1135692, configurationVersion#1136108, UNKNOWN_DEMAND_FOR_PRODUCT_LOCATION AS name#1136109]

(213) Project
Arguments: [product#1135691, plant#1135692, configurationVersion#1136108, name#1136109, array(struct(name, PRODUCT, value, cast(product#1135691 as string)), struct(name, PLANT, value, cast(plant#1135692 as string))) AS businessContext#1136114]

(214) Project
Arguments: [product#1135691, plant#1135692, configurationVersion#1136108, name#1136109, businessContext#1136114, cast(array() as array<struct<variableName:string,variableValue:string>>) AS messageVariables#1136115]

(215) Deduplicate
Arguments: [businessContext#1136114, messageVariables#1136115, configurationVersion#1136108, product#1135691, plant#1135692, name#1136109]

(216) Project
Arguments: [product#1135691, plant#1135692, configurationVersion#1136108, name#1136109, businessContext#1136114, messageVariables#1136115, 10000001353 AS executionId#1136116]

(217) Project
Arguments: [product#1135691, plant#1135692, configurationVersion#1136108, name#1136109, businessContext#1136114, messageVariables#1136115, executionId#1136116, Alert_Test1 AS marketUnit#1136117]

(218) Project
Arguments: [product#1135691, plant#1135692, configurationVersion#1136108, name#1136109, businessContext#1136114, messageVariables#1136115, executionId#1136116, marketUnit#1136117, 2026-07-21T12:26:30.309Z AS createdAt#1136118]

(219) Project
Arguments: [name#1136109, configurationVersion#1136108, executionId#1136116, createdAt#1136118, marketUnit#1136117, businessContext#1136114, messageVariables#1136115]

(220) Project
Arguments: [to_json(struct(name, name#1136109, configurationVersion, configurationVersion#1136108, executionId, executionId#1136116, createdAt, createdAt#1136118, marketUnit, marketUnit#1136117, businessContext, businessContext#1136114, messageVariables, messageVariables#1136115), Some(UTC)) AS value#1152241]

(221) Project
Arguments: [cast(value#1152241 as string) AS value#1152242]

(222) Project
Arguments: [value#1152242, array(struct(key, X-Tenant-ID, value, cast(7233423560970044043 as binary)), struct(key, X-Message-ID, value, cast(02ed2442-dfd8-47b5-8fa0-e211a6ff8f18 as binary)), struct(key, X-Event-Type, value, cast(com.sap.dip.insight.created as binary)), struct(key, X-BTP-Tenant-ID, value, cast(65802631-6462-4867-aef3-60d3858f828b as binary))) AS headers#1152251]
SQL / DataFrame Properties
Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	0
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
temporal.activity.id	c0d716ca-c986-3952-99ee-328b497c66de
temporal.activity.type	BufferDataSnapShot