== 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@183dd33c, [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#1199942, plant#1199943, orderDateTime#1199944, planningStartDateTime#1199945], false
(4) RepartitionByExpression
Arguments: [product#1199942, plant#1199943], 37
(5) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944]
(6) LogicalRelation
Arguments: parquet, [systemId#1199947, internalUUID#1199948, plant#1199949, product#1199950, blockedForReplenishmentStartingFrom#1199951, productionAspect#1199952, salesPlant#1199953, listing#1199954], false
(7) Repartition
Arguments: 37, true
(8) Project
Arguments: [systemId#1199947, internalUUID#1199948, plant#1199949, product#1199950, blockedForReplenishmentStartingFrom#1199951, productionAspect#1199952, salesPlant#1199953, listing#1199954, struct(systemId, systemId#1199947, internalUUID, internalUUID#1199948, plant, plant#1199949, product, product#1199950, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1199951, productionAspect, productionAspect#1199952, salesPlant, salesPlant#1199953, listing, listing#1199954) AS productPlant#1199956]
(9) Project
Arguments: [productPlant#1199956]
(10) Join
Arguments: LeftOuter, ((product#1199942 <=> productPlant#1199956.product.internalRefUUID) AND (plant#1199943 <=> productPlant#1199956.plant.internalRefUUID))
(11) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956]
(12) SubqueryAlias
Arguments: wl
(13) LogicalRelation
Arguments: parquet, [systemId#1199959, internalUUID#1199960, id#1199961, displayId#1199962, name#1199963, category#1199964, companyCode#1199965, address#1199966, mainDistributionChain#1199967, mainPurchasingOrganization#1199968, validPurchasingOrganizations#1199969, productGroup#1199970], false
(14) Repartition
Arguments: 37, true
(15) Project
Arguments: [internalUUID#1199960, address#1199966.timeZone.code AS timezonecode#1199971]
(16) Join
Arguments: LeftOuter, (plant#1199943 <=> internalUUID#1199960)
(17) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, internalUUID#1199960, CASE WHEN isnotnull(timezonecode#1199971) THEN timezonecode#1199971 ELSE UTC END AS timezonecode#1199974]
(18) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974]
(19) LogicalRelation
Arguments: parquet, [systemId#1199975, internalUUID#1199976, id#1199977, displayId#1199978, name#1199979, baseUnitOfMeasure#1199980, unitOfMeasures#1199981, unitOfMeasureConversions#1199982, productionAspect#1199983, salesAspect#1199984, procurementAspect#1199985, productGroup#1199986], false
(20) Repartition
Arguments: 37, true
(21) Join
Arguments: LeftOuter, (product#1199942 = internalUUID#1199976)
(22) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, systemId#1199975, internalUUID#1199976, id#1199977, displayId#1199978, name#1199979, baseUnitOfMeasure#1199980, unitOfMeasures#1199981, unitOfMeasureConversions#1199982, productionAspect#1199983, salesAspect#1199984, procurementAspect#1199985, productGroup#1199986, filter(unitOfMeasureConversions#1199982, lambdafunction((((lambda u#1199989.measurementUnit1.code = productPlant#1199956.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1199989.measurementUnit1.internalRefUUID = productPlant#1199956.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1199989.measurementUnit2.code = baseUnitOfMeasure#1199980.code) AND (lambda u#1199989.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1199980.internalRefUUID))), lambda u#1199989, false)) AS filteredUnitOfMeasureConversions#1199988]
(23) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1199988.quantityNumerator), true, [quantityNumerator#1199996]
(24) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, systemId#1199975, internalUUID#1199976, id#1199977, displayId#1199978, name#1199979, baseUnitOfMeasure#1199980, unitOfMeasures#1199981, unitOfMeasureConversions#1199982, productionAspect#1199983, salesAspect#1199984, procurementAspect#1199985, productGroup#1199986, filteredUnitOfMeasureConversions#1199988, quantityNumerator#1199996]
(25) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1199988.quantityDenominator), true, [quantityDenominator#1199999]
(26) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, systemId#1199975, internalUUID#1199976, id#1199977, displayId#1199978, name#1199979, baseUnitOfMeasure#1199980, unitOfMeasures#1199981, unitOfMeasureConversions#1199982, productionAspect#1199983, salesAspect#1199984, procurementAspect#1199985, productGroup#1199986, filteredUnitOfMeasureConversions#1199988, quantityNumerator#1199996, quantityDenominator#1199999]
(27) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, systemId#1199975, internalUUID#1199976, id#1199977, displayId#1199978, name#1199979, baseUnitOfMeasure#1199980, unitOfMeasures#1199981, unitOfMeasureConversions#1199982, productionAspect#1199983, salesAspect#1199984, procurementAspect#1199985, productGroup#1199986, filteredUnitOfMeasureConversions#1199988, quantityNumerator#1199996, quantityDenominator#1199999, (cast(quantityNumerator#1199996 as double) / cast(quantityDenominator#1199999 as double)) AS outboundUnit#1200000]
(28) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, systemId#1199975, internalUUID#1199976, id#1199977, displayId#1199978, name#1199979, baseUnitOfMeasure#1199980, unitOfMeasures#1199981, unitOfMeasureConversions#1199982, productionAspect#1199983, salesAspect#1199984, procurementAspect#1199985, productGroup#1199986, filteredUnitOfMeasureConversions#1199988, quantityNumerator#1199996, quantityDenominator#1199999, CASE WHEN (isnull(outboundUnit#1200000) OR (outboundUnit#1200000 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1200000 END AS outboundUnit#1200001]
(29) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001]
(30) LogicalRelation
Arguments: parquet, [systemId#1200038, internalUUID#1200039, product#1200040, plant#1200041, calculationDateTime#1200042, stockQuantities#1200043], false
(31) Repartition
Arguments: 37, true
(32) LogicalRelation
Arguments: parquet, [marketUnit#1200002, description#1200003, articleHierarchy#1200004, defaultCurrency#1200005, responsibilities#1200006, replenishmentTypes#1200007, distributionCenters#1200008, assignedArticleHierarchyNodes#1200009, minOrderQtySetting#1200010, listingCheck#1200011, odsSelection#1200012, demandProfiles#1200013, constraintProfiles#1200014, optimizationProfiles#1200015, orderGroupSplitProfiles#1200016, supplierMinimumProfiles#1200017, multipleRestrictionProfiles#1200018, preferredUomSource#1200019, handlingOfUnfulfilledDemands#1200020, negligibleQuantitiesThreshold#1200021, eventtype#1200022, minOrderQtySettingInternal#1200023], false
(33) Repartition
Arguments: 37, true
(34) Filter
Arguments: (marketUnit#1200002 <=> Grocery_SS)
(35) Project
Arguments: [marketUnit#1200002, description#1200003, articleHierarchy#1200004, defaultCurrency#1200005, responsibilities#1200006, replenishmentTypes#1200007, distributionCenters#1200008, assignedArticleHierarchyNodes#1200009, minOrderQtySetting#1200010, listingCheck#1200011, odsSelection#1200012, demandProfiles#1200013, constraintProfiles#1200014, optimizationProfiles#1200015, orderGroupSplitProfiles#1200016, supplierMinimumProfiles#1200017, multipleRestrictionProfiles#1200018, preferredUomSource#1200019, handlingOfUnfulfilledDemands#1200020, negligibleQuantitiesThreshold#1200021, eventtype#1200022, minOrderQtySettingInternal#1200023]
(36) Project
Arguments: [distributionCenters#1200008]
(37) Generate
Arguments: explode(distributionCenters#1200008), false, [distributionCenters#1200026]
(38) Project
Arguments: [distributionCenters#1200026]
(39) Generate
Arguments: explode(distributionCenters#1200026.storageLocations), false, [storageLocations#1200033]
(40) Project
Arguments: [distributionCenters#1200026.id AS plantId#1200027, distributionCenters#1200026.internalRefUUID AS plantUuid#1200028, storageLocations#1200033]
(41) Project
Arguments: [plantId#1200027, plantUuid#1200028, storageLocations#1200033.id AS storageLocId#1200034, storageLocations#1200033.internalRefUUID AS storageLocUuid#1200035]
(42) LogicalRelation
Arguments: parquet, [product#1200298, plant#1200299, orderDateTime#1200300, planningStartDateTime#1200301], false
(43) RepartitionByExpression
Arguments: [product#1200298, plant#1200299], 37
(44) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300]
(45) LogicalRelation
Arguments: parquet, [systemId#1200302, internalUUID#1200303, plant#1200304, product#1200305, blockedForReplenishmentStartingFrom#1200306, productionAspect#1200307, salesPlant#1200308, listing#1200309], false
(46) Repartition
Arguments: 37, true
(47) Project
Arguments: [systemId#1200302, internalUUID#1200303, plant#1200304, product#1200305, blockedForReplenishmentStartingFrom#1200306, productionAspect#1200307, salesPlant#1200308, listing#1200309, struct(systemId, systemId#1200302, internalUUID, internalUUID#1200303, plant, plant#1200304, product, product#1200305, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1200306, productionAspect, productionAspect#1200307, salesPlant, salesPlant#1200308, listing, listing#1200309) AS productPlant#1200310]
(48) Project
Arguments: [productPlant#1200310]
(49) Join
Arguments: LeftOuter, ((product#1200298 <=> productPlant#1200310.product.internalRefUUID) AND (plant#1200299 <=> productPlant#1200310.plant.internalRefUUID))
(50) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310]
(51) SubqueryAlias
Arguments: wl
(52) LogicalRelation
Arguments: parquet, [systemId#1200311, internalUUID#1200312, id#1200313, displayId#1200314, name#1200315, category#1200316, companyCode#1200317, address#1200318, mainDistributionChain#1200319, mainPurchasingOrganization#1200320, validPurchasingOrganizations#1200321, productGroup#1200322], false
(53) Repartition
Arguments: 37, true
(54) Project
Arguments: [internalUUID#1200312, address#1200318.timeZone.code AS timezonecode#1200323]
(55) Join
Arguments: LeftOuter, (plant#1200299 <=> internalUUID#1200312)
(56) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, internalUUID#1200312, CASE WHEN isnotnull(timezonecode#1200323) THEN timezonecode#1200323 ELSE UTC END AS timezonecode#1200324]
(57) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, timezonecode#1200324]
(58) LogicalRelation
Arguments: parquet, [systemId#1200325, internalUUID#1200326, id#1200327, displayId#1200328, name#1200329, baseUnitOfMeasure#1200330, unitOfMeasures#1200331, unitOfMeasureConversions#1200332, productionAspect#1200333, salesAspect#1200334, procurementAspect#1200335, productGroup#1200336], false
(59) Repartition
Arguments: 37, true
(60) Join
Arguments: LeftOuter, (product#1200298 = internalUUID#1200326)
(61) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, timezonecode#1200324, systemId#1200325, internalUUID#1200326, id#1200327, displayId#1200328, name#1200329, baseUnitOfMeasure#1200330, unitOfMeasures#1200331, unitOfMeasureConversions#1200332, productionAspect#1200333, salesAspect#1200334, procurementAspect#1200335, productGroup#1200336, filter(unitOfMeasureConversions#1200332, lambdafunction((((lambda u#1199989.measurementUnit1.code = productPlant#1200310.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1199989.measurementUnit1.internalRefUUID = productPlant#1200310.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1199989.measurementUnit2.code = baseUnitOfMeasure#1200330.code) AND (lambda u#1199989.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1200330.internalRefUUID))), lambda u#1199989, false)) AS filteredUnitOfMeasureConversions#1200337]
(62) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200337.quantityNumerator), true, [quantityNumerator#1200338]
(63) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, timezonecode#1200324, systemId#1200325, internalUUID#1200326, id#1200327, displayId#1200328, name#1200329, baseUnitOfMeasure#1200330, unitOfMeasures#1200331, unitOfMeasureConversions#1200332, productionAspect#1200333, salesAspect#1200334, procurementAspect#1200335, productGroup#1200336, filteredUnitOfMeasureConversions#1200337, quantityNumerator#1200338]
(64) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200337.quantityDenominator), true, [quantityDenominator#1200339]
(65) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, timezonecode#1200324, systemId#1200325, internalUUID#1200326, id#1200327, displayId#1200328, name#1200329, baseUnitOfMeasure#1200330, unitOfMeasures#1200331, unitOfMeasureConversions#1200332, productionAspect#1200333, salesAspect#1200334, procurementAspect#1200335, productGroup#1200336, filteredUnitOfMeasureConversions#1200337, quantityNumerator#1200338, quantityDenominator#1200339]
(66) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, timezonecode#1200324, systemId#1200325, internalUUID#1200326, id#1200327, displayId#1200328, name#1200329, baseUnitOfMeasure#1200330, unitOfMeasures#1200331, unitOfMeasureConversions#1200332, productionAspect#1200333, salesAspect#1200334, procurementAspect#1200335, productGroup#1200336, filteredUnitOfMeasureConversions#1200337, quantityNumerator#1200338, quantityDenominator#1200339, (cast(quantityNumerator#1200338 as double) / cast(quantityDenominator#1200339 as double)) AS outboundUnit#1200340]
(67) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, timezonecode#1200324, systemId#1200325, internalUUID#1200326, id#1200327, displayId#1200328, name#1200329, baseUnitOfMeasure#1200330, unitOfMeasures#1200331, unitOfMeasureConversions#1200332, productionAspect#1200333, salesAspect#1200334, procurementAspect#1200335, productGroup#1200336, filteredUnitOfMeasureConversions#1200337, quantityNumerator#1200338, quantityDenominator#1200339, CASE WHEN (isnull(outboundUnit#1200340) OR (outboundUnit#1200340 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1200340 END AS outboundUnit#1200341]
(68) Project
Arguments: [product#1200298, plant#1200299, orderDateTime#1200300, productPlant#1200310, timezonecode#1200324, outboundUnit#1200341]
(69) Project
Arguments: [plant#1200299]
(70) Deduplicate
Arguments: [plant#1200299]
(71) Join
Arguments: Inner, (plantUuid#1200028 = plant#1200299)
(72) Project
Arguments: [plantId#1200027, plantUuid#1200028, storageLocId#1200034, storageLocUuid#1200035]
(73) Join
Arguments: Inner, (plant#1200041.internalRefUUID <=> plantUuid#1200028)
(74) Generate
Arguments: explode(filter(stockQuantities#1200043, lambdafunction(((lambda x#1200047.storageLocation.internalRefUuid = storageLocUuid#1200035) AND (lambda x#1200047.storageLocation.Id = storageLocId#1200034)), lambda x#1200047, false))), false, [stockQuantity#1200048]
(75) Project
Arguments: [systemId#1200038, internalUUID#1200039, product#1200040, plant#1200041, calculationDateTime#1200042, stockQuantities#1200043, plantId#1200027, plantUuid#1200028, storageLocId#1200034, storageLocUuid#1200035, stockQuantity#1200048]
(76) Aggregate
Arguments: [plantUuid#1200028, internalUUID#1200039, plant#1200041, product#1200040, systemId#1200038], [plantUuid#1200028, internalUUID#1200039, plant#1200041, product#1200040, systemId#1200038, first(calculationDateTime#1200042, false) AS calculationDateTime#1200049, collect_list(stockQuantity#1200048, 0, 0) AS stockQuantities#1200050]
(77) Project
Arguments: [systemId#1200038, internalUUID#1200039, product#1200040, plant#1200041, calculationDateTime#1200049, stockQuantities#1200050]
(78) Generate
Arguments: explode(stockQuantities#1200050), false, [stockQuantity#1200065]
(79) Project
Arguments: [systemId#1200038, internalUUID#1200039, product#1200040, plant#1200041, calculationDateTime#1200049, stockQuantities#1200050, stockQuantity#1200065]
(80) Project
Arguments: [plant#1200041.id AS plant#1200066, plant#1200041.internalRefUUID AS plantUuid#1200067, product#1200040.id AS product#1200068, product#1200040.internalRefUUID AS productUuid#1200069, calculationDateTime#1200049, stockQuantity#1200065.storagelocation.id AS storageLocId#1200070, stockQuantity#1200065.storagelocation.internalRefUUID AS storageLocUuid#1200071, stockQuantity#1200065.quantity.measure AS quantity#1200072, stockQuantity#1200065.specialStockIndicator.code AS specialStockIndicator#1200073, stockQuantity#1200065.stockType.code AS stockType#1200074]
(81) Filter
Arguments: ((specialStockIndicator#1200073 = ) AND (stockType#1200074 = 01))
(82) LogicalRelation
Arguments: parquet, [product#1200084, plant#1200085, orderDateTime#1200086, planningStartDateTime#1200087], false
(83) RepartitionByExpression
Arguments: [product#1200084, plant#1200085], 37
(84) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086]
(85) LogicalRelation
Arguments: parquet, [systemId#1200088, internalUUID#1200089, plant#1200090, product#1200091, blockedForReplenishmentStartingFrom#1200092, productionAspect#1200093, salesPlant#1200094, listing#1200095], false
(86) Repartition
Arguments: 37, true
(87) Project
Arguments: [systemId#1200088, internalUUID#1200089, plant#1200090, product#1200091, blockedForReplenishmentStartingFrom#1200092, productionAspect#1200093, salesPlant#1200094, listing#1200095, struct(systemId, systemId#1200088, internalUUID, internalUUID#1200089, plant, plant#1200090, product, product#1200091, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1200092, productionAspect, productionAspect#1200093, salesPlant, salesPlant#1200094, listing, listing#1200095) AS productPlant#1200096]
(88) Project
Arguments: [productPlant#1200096]
(89) Join
Arguments: LeftOuter, ((product#1200084 <=> productPlant#1200096.product.internalRefUUID) AND (plant#1200085 <=> productPlant#1200096.plant.internalRefUUID))
(90) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096]
(91) SubqueryAlias
Arguments: wl
(92) LogicalRelation
Arguments: parquet, [systemId#1200097, internalUUID#1200098, id#1200099, displayId#1200100, name#1200101, category#1200102, companyCode#1200103, address#1200104, mainDistributionChain#1200105, mainPurchasingOrganization#1200106, validPurchasingOrganizations#1200107, productGroup#1200108], false
(93) Repartition
Arguments: 37, true
(94) Project
Arguments: [internalUUID#1200098, address#1200104.timeZone.code AS timezonecode#1200109]
(95) Join
Arguments: LeftOuter, (plant#1200085 <=> internalUUID#1200098)
(96) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, internalUUID#1200098, CASE WHEN isnotnull(timezonecode#1200109) THEN timezonecode#1200109 ELSE UTC END AS timezonecode#1200110]
(97) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, timezonecode#1200110]
(98) LogicalRelation
Arguments: parquet, [systemId#1200111, internalUUID#1200112, id#1200113, displayId#1200114, name#1200115, baseUnitOfMeasure#1200116, unitOfMeasures#1200117, unitOfMeasureConversions#1200118, productionAspect#1200119, salesAspect#1200120, procurementAspect#1200121, productGroup#1200122], false
(99) Repartition
Arguments: 37, true
(100) Join
Arguments: LeftOuter, (product#1200084 = internalUUID#1200112)
(101) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, timezonecode#1200110, systemId#1200111, internalUUID#1200112, id#1200113, displayId#1200114, name#1200115, baseUnitOfMeasure#1200116, unitOfMeasures#1200117, unitOfMeasureConversions#1200118, productionAspect#1200119, salesAspect#1200120, procurementAspect#1200121, productGroup#1200122, filter(unitOfMeasureConversions#1200118, lambdafunction((((lambda u#1199989.measurementUnit1.code = productPlant#1200096.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1199989.measurementUnit1.internalRefUUID = productPlant#1200096.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1199989.measurementUnit2.code = baseUnitOfMeasure#1200116.code) AND (lambda u#1199989.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1200116.internalRefUUID))), lambda u#1199989, false)) AS filteredUnitOfMeasureConversions#1200123]
(102) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200123.quantityNumerator), true, [quantityNumerator#1200124]
(103) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, timezonecode#1200110, systemId#1200111, internalUUID#1200112, id#1200113, displayId#1200114, name#1200115, baseUnitOfMeasure#1200116, unitOfMeasures#1200117, unitOfMeasureConversions#1200118, productionAspect#1200119, salesAspect#1200120, procurementAspect#1200121, productGroup#1200122, filteredUnitOfMeasureConversions#1200123, quantityNumerator#1200124]
(104) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200123.quantityDenominator), true, [quantityDenominator#1200125]
(105) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, timezonecode#1200110, systemId#1200111, internalUUID#1200112, id#1200113, displayId#1200114, name#1200115, baseUnitOfMeasure#1200116, unitOfMeasures#1200117, unitOfMeasureConversions#1200118, productionAspect#1200119, salesAspect#1200120, procurementAspect#1200121, productGroup#1200122, filteredUnitOfMeasureConversions#1200123, quantityNumerator#1200124, quantityDenominator#1200125]
(106) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, timezonecode#1200110, systemId#1200111, internalUUID#1200112, id#1200113, displayId#1200114, name#1200115, baseUnitOfMeasure#1200116, unitOfMeasures#1200117, unitOfMeasureConversions#1200118, productionAspect#1200119, salesAspect#1200120, procurementAspect#1200121, productGroup#1200122, filteredUnitOfMeasureConversions#1200123, quantityNumerator#1200124, quantityDenominator#1200125, (cast(quantityNumerator#1200124 as double) / cast(quantityDenominator#1200125 as double)) AS outboundUnit#1200126]
(107) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, timezonecode#1200110, systemId#1200111, internalUUID#1200112, id#1200113, displayId#1200114, name#1200115, baseUnitOfMeasure#1200116, unitOfMeasures#1200117, unitOfMeasureConversions#1200118, productionAspect#1200119, salesAspect#1200120, procurementAspect#1200121, productGroup#1200122, filteredUnitOfMeasureConversions#1200123, quantityNumerator#1200124, quantityDenominator#1200125, CASE WHEN (isnull(outboundUnit#1200126) OR (outboundUnit#1200126 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1200126 END AS outboundUnit#1200127]
(108) Project
Arguments: [product#1200084, plant#1200085, orderDateTime#1200086, productPlant#1200096, timezonecode#1200110, outboundUnit#1200127]
(109) Join
Arguments: Inner, ((plantUuid#1200067 = plant#1200085) AND (productUuid#1200069 = product#1200084))
(110) Filter
Arguments: (calculationDateTime#1200049 <= orderDateTime#1200086)
(111) Project
Arguments: [plantUuid#1200067 AS plant#1200132, productUuid#1200069 AS product#1200133, storageLocId#1200070, calculationDateTime#1200049, quantity#1200072]
(112) LogicalRelation
Arguments: parquet, [systemId#1200141, internalUUID#1200142, product#1200143, plant#1200144, calculationDateTime#1200145, stockQuantities#1200146], false
(113) Repartition
Arguments: 37, true
(114) LogicalRelation
Arguments: parquet, [marketUnit#1200147, description#1200148, articleHierarchy#1200149, defaultCurrency#1200150, responsibilities#1200151, replenishmentTypes#1200152, distributionCenters#1200153, assignedArticleHierarchyNodes#1200154, minOrderQtySetting#1200155, listingCheck#1200156, odsSelection#1200157, demandProfiles#1200158, constraintProfiles#1200159, optimizationProfiles#1200160, orderGroupSplitProfiles#1200161, supplierMinimumProfiles#1200162, multipleRestrictionProfiles#1200163, preferredUomSource#1200164, handlingOfUnfulfilledDemands#1200165, negligibleQuantitiesThreshold#1200166, eventtype#1200167, minOrderQtySettingInternal#1200168], false
(115) Repartition
Arguments: 37, true
(116) Filter
Arguments: (marketUnit#1200147 <=> Grocery_SS)
(117) Project
Arguments: [marketUnit#1200147, description#1200148, articleHierarchy#1200149, defaultCurrency#1200150, responsibilities#1200151, replenishmentTypes#1200152, distributionCenters#1200153, assignedArticleHierarchyNodes#1200154, minOrderQtySetting#1200155, listingCheck#1200156, odsSelection#1200157, demandProfiles#1200158, constraintProfiles#1200159, optimizationProfiles#1200160, orderGroupSplitProfiles#1200161, supplierMinimumProfiles#1200162, multipleRestrictionProfiles#1200163, preferredUomSource#1200164, handlingOfUnfulfilledDemands#1200165, negligibleQuantitiesThreshold#1200166, eventtype#1200167, minOrderQtySettingInternal#1200168]
(118) Project
Arguments: [distributionCenters#1200153]
(119) Generate
Arguments: explode(distributionCenters#1200153), false, [distributionCenters#1200169]
(120) Project
Arguments: [distributionCenters#1200169]
(121) Generate
Arguments: explode(distributionCenters#1200169.storageLocations), false, [storageLocations#1200170]
(122) Project
Arguments: [distributionCenters#1200169.id AS plantId#1200171, distributionCenters#1200169.internalRefUUID AS plantUuid#1200172, storageLocations#1200170]
(123) Project
Arguments: [plantId#1200171, plantUuid#1200172, storageLocations#1200170.id AS storageLocId#1200173, storageLocations#1200170.internalRefUUID AS storageLocUuid#1200174]
(124) LogicalRelation
Arguments: parquet, [product#1200175, plant#1200176, orderDateTime#1200177, planningStartDateTime#1200178], false
(125) RepartitionByExpression
Arguments: [product#1200175, plant#1200176], 37
(126) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177]
(127) LogicalRelation
Arguments: parquet, [systemId#1200179, internalUUID#1200180, plant#1200181, product#1200182, blockedForReplenishmentStartingFrom#1200183, productionAspect#1200184, salesPlant#1200185, listing#1200186], false
(128) Repartition
Arguments: 37, true
(129) Project
Arguments: [systemId#1200179, internalUUID#1200180, plant#1200181, product#1200182, blockedForReplenishmentStartingFrom#1200183, productionAspect#1200184, salesPlant#1200185, listing#1200186, struct(systemId, systemId#1200179, internalUUID, internalUUID#1200180, plant, plant#1200181, product, product#1200182, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1200183, productionAspect, productionAspect#1200184, salesPlant, salesPlant#1200185, listing, listing#1200186) AS productPlant#1200187]
(130) Project
Arguments: [productPlant#1200187]
(131) Join
Arguments: LeftOuter, ((product#1200175 <=> productPlant#1200187.product.internalRefUUID) AND (plant#1200176 <=> productPlant#1200187.plant.internalRefUUID))
(132) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187]
(133) SubqueryAlias
Arguments: wl
(134) LogicalRelation
Arguments: parquet, [systemId#1200188, internalUUID#1200189, id#1200190, displayId#1200191, name#1200192, category#1200193, companyCode#1200194, address#1200195, mainDistributionChain#1200196, mainPurchasingOrganization#1200197, validPurchasingOrganizations#1200198, productGroup#1200199], false
(135) Repartition
Arguments: 37, true
(136) Project
Arguments: [internalUUID#1200189, address#1200195.timeZone.code AS timezonecode#1200200]
(137) Join
Arguments: LeftOuter, (plant#1200176 <=> internalUUID#1200189)
(138) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, internalUUID#1200189, CASE WHEN isnotnull(timezonecode#1200200) THEN timezonecode#1200200 ELSE UTC END AS timezonecode#1200201]
(139) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, timezonecode#1200201]
(140) LogicalRelation
Arguments: parquet, [systemId#1200202, internalUUID#1200203, id#1200204, displayId#1200205, name#1200206, baseUnitOfMeasure#1200207, unitOfMeasures#1200208, unitOfMeasureConversions#1200209, productionAspect#1200210, salesAspect#1200211, procurementAspect#1200212, productGroup#1200213], false
(141) Repartition
Arguments: 37, true
(142) Join
Arguments: LeftOuter, (product#1200175 = internalUUID#1200203)
(143) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, timezonecode#1200201, systemId#1200202, internalUUID#1200203, id#1200204, displayId#1200205, name#1200206, baseUnitOfMeasure#1200207, unitOfMeasures#1200208, unitOfMeasureConversions#1200209, productionAspect#1200210, salesAspect#1200211, procurementAspect#1200212, productGroup#1200213, filter(unitOfMeasureConversions#1200209, lambdafunction((((lambda u#1199989.measurementUnit1.code = productPlant#1200187.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1199989.measurementUnit1.internalRefUUID = productPlant#1200187.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1199989.measurementUnit2.code = baseUnitOfMeasure#1200207.code) AND (lambda u#1199989.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1200207.internalRefUUID))), lambda u#1199989, false)) AS filteredUnitOfMeasureConversions#1200214]
(144) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200214.quantityNumerator), true, [quantityNumerator#1200215]
(145) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, timezonecode#1200201, systemId#1200202, internalUUID#1200203, id#1200204, displayId#1200205, name#1200206, baseUnitOfMeasure#1200207, unitOfMeasures#1200208, unitOfMeasureConversions#1200209, productionAspect#1200210, salesAspect#1200211, procurementAspect#1200212, productGroup#1200213, filteredUnitOfMeasureConversions#1200214, quantityNumerator#1200215]
(146) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200214.quantityDenominator), true, [quantityDenominator#1200216]
(147) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, timezonecode#1200201, systemId#1200202, internalUUID#1200203, id#1200204, displayId#1200205, name#1200206, baseUnitOfMeasure#1200207, unitOfMeasures#1200208, unitOfMeasureConversions#1200209, productionAspect#1200210, salesAspect#1200211, procurementAspect#1200212, productGroup#1200213, filteredUnitOfMeasureConversions#1200214, quantityNumerator#1200215, quantityDenominator#1200216]
(148) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, timezonecode#1200201, systemId#1200202, internalUUID#1200203, id#1200204, displayId#1200205, name#1200206, baseUnitOfMeasure#1200207, unitOfMeasures#1200208, unitOfMeasureConversions#1200209, productionAspect#1200210, salesAspect#1200211, procurementAspect#1200212, productGroup#1200213, filteredUnitOfMeasureConversions#1200214, quantityNumerator#1200215, quantityDenominator#1200216, (cast(quantityNumerator#1200215 as double) / cast(quantityDenominator#1200216 as double)) AS outboundUnit#1200217]
(149) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, timezonecode#1200201, systemId#1200202, internalUUID#1200203, id#1200204, displayId#1200205, name#1200206, baseUnitOfMeasure#1200207, unitOfMeasures#1200208, unitOfMeasureConversions#1200209, productionAspect#1200210, salesAspect#1200211, procurementAspect#1200212, productGroup#1200213, filteredUnitOfMeasureConversions#1200214, quantityNumerator#1200215, quantityDenominator#1200216, CASE WHEN (isnull(outboundUnit#1200217) OR (outboundUnit#1200217 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1200217 END AS outboundUnit#1200218]
(150) Project
Arguments: [product#1200175, plant#1200176, orderDateTime#1200177, productPlant#1200187, timezonecode#1200201, outboundUnit#1200218]
(151) Project
Arguments: [plant#1200176]
(152) Deduplicate
Arguments: [plant#1200176]
(153) Join
Arguments: Inner, (plantUuid#1200172 = plant#1200176)
(154) Project
Arguments: [plantId#1200171, plantUuid#1200172, storageLocId#1200173, storageLocUuid#1200174]
(155) Join
Arguments: Inner, (plant#1200144.internalRefUUID <=> plantUuid#1200172)
(156) Generate
Arguments: explode(filter(stockQuantities#1200146, lambdafunction(((lambda x#1200047.storageLocation.internalRefUuid = storageLocUuid#1200174) AND (lambda x#1200047.storageLocation.Id = storageLocId#1200173)), lambda x#1200047, false))), false, [stockQuantity#1200219]
(157) Project
Arguments: [systemId#1200141, internalUUID#1200142, product#1200143, plant#1200144, calculationDateTime#1200145, stockQuantities#1200146, plantId#1200171, plantUuid#1200172, storageLocId#1200173, storageLocUuid#1200174, stockQuantity#1200219]
(158) Aggregate
Arguments: [plantUuid#1200172, internalUUID#1200142, plant#1200144, product#1200143, systemId#1200141], [plantUuid#1200172, internalUUID#1200142, plant#1200144, product#1200143, systemId#1200141, first(calculationDateTime#1200145, false) AS calculationDateTime#1200220, collect_list(stockQuantity#1200219, 0, 0) AS stockQuantities#1200221]
(159) Project
Arguments: [systemId#1200141, internalUUID#1200142, product#1200143, plant#1200144, calculationDateTime#1200220, stockQuantities#1200221]
(160) Generate
Arguments: explode(stockQuantities#1200221), false, [stockQuantity#1200222]
(161) Project
Arguments: [systemId#1200141, internalUUID#1200142, product#1200143, plant#1200144, calculationDateTime#1200220, stockQuantities#1200221, stockQuantity#1200222]
(162) Project
Arguments: [plant#1200144.id AS plant#1200223, plant#1200144.internalRefUUID AS plantUuid#1200224, product#1200143.id AS product#1200225, product#1200143.internalRefUUID AS productUuid#1200226, calculationDateTime#1200220, stockQuantity#1200222.storagelocation.id AS storageLocId#1200227, stockQuantity#1200222.storagelocation.internalRefUUID AS storageLocUuid#1200228, stockQuantity#1200222.quantity.measure AS quantity#1200229, stockQuantity#1200222.specialStockIndicator.code AS specialStockIndicator#1200230, stockQuantity#1200222.stockType.code AS stockType#1200231]
(163) Filter
Arguments: ((specialStockIndicator#1200230 = ) AND (stockType#1200231 = 01))
(164) LogicalRelation
Arguments: parquet, [product#1200232, plant#1200233, orderDateTime#1200234, planningStartDateTime#1200235], false
(165) RepartitionByExpression
Arguments: [product#1200232, plant#1200233], 37
(166) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234]
(167) LogicalRelation
Arguments: parquet, [systemId#1200236, internalUUID#1200237, plant#1200238, product#1200239, blockedForReplenishmentStartingFrom#1200240, productionAspect#1200241, salesPlant#1200242, listing#1200243], false
(168) Repartition
Arguments: 37, true
(169) Project
Arguments: [systemId#1200236, internalUUID#1200237, plant#1200238, product#1200239, blockedForReplenishmentStartingFrom#1200240, productionAspect#1200241, salesPlant#1200242, listing#1200243, struct(systemId, systemId#1200236, internalUUID, internalUUID#1200237, plant, plant#1200238, product, product#1200239, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1200240, productionAspect, productionAspect#1200241, salesPlant, salesPlant#1200242, listing, listing#1200243) AS productPlant#1200244]
(170) Project
Arguments: [productPlant#1200244]
(171) Join
Arguments: LeftOuter, ((product#1200232 <=> productPlant#1200244.product.internalRefUUID) AND (plant#1200233 <=> productPlant#1200244.plant.internalRefUUID))
(172) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244]
(173) SubqueryAlias
Arguments: wl
(174) LogicalRelation
Arguments: parquet, [systemId#1200245, internalUUID#1200246, id#1200247, displayId#1200248, name#1200249, category#1200250, companyCode#1200251, address#1200252, mainDistributionChain#1200253, mainPurchasingOrganization#1200254, validPurchasingOrganizations#1200255, productGroup#1200256], false
(175) Repartition
Arguments: 37, true
(176) Project
Arguments: [internalUUID#1200246, address#1200252.timeZone.code AS timezonecode#1200257]
(177) Join
Arguments: LeftOuter, (plant#1200233 <=> internalUUID#1200246)
(178) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, internalUUID#1200246, CASE WHEN isnotnull(timezonecode#1200257) THEN timezonecode#1200257 ELSE UTC END AS timezonecode#1200258]
(179) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, timezonecode#1200258]
(180) LogicalRelation
Arguments: parquet, [systemId#1200259, internalUUID#1200260, id#1200261, displayId#1200262, name#1200263, baseUnitOfMeasure#1200264, unitOfMeasures#1200265, unitOfMeasureConversions#1200266, productionAspect#1200267, salesAspect#1200268, procurementAspect#1200269, productGroup#1200270], false
(181) Repartition
Arguments: 37, true
(182) Join
Arguments: LeftOuter, (product#1200232 = internalUUID#1200260)
(183) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, timezonecode#1200258, systemId#1200259, internalUUID#1200260, id#1200261, displayId#1200262, name#1200263, baseUnitOfMeasure#1200264, unitOfMeasures#1200265, unitOfMeasureConversions#1200266, productionAspect#1200267, salesAspect#1200268, procurementAspect#1200269, productGroup#1200270, filter(unitOfMeasureConversions#1200266, lambdafunction((((lambda u#1199989.measurementUnit1.code = productPlant#1200244.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1199989.measurementUnit1.internalRefUUID = productPlant#1200244.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1199989.measurementUnit2.code = baseUnitOfMeasure#1200264.code) AND (lambda u#1199989.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1200264.internalRefUUID))), lambda u#1199989, false)) AS filteredUnitOfMeasureConversions#1200271]
(184) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200271.quantityNumerator), true, [quantityNumerator#1200272]
(185) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, timezonecode#1200258, systemId#1200259, internalUUID#1200260, id#1200261, displayId#1200262, name#1200263, baseUnitOfMeasure#1200264, unitOfMeasures#1200265, unitOfMeasureConversions#1200266, productionAspect#1200267, salesAspect#1200268, procurementAspect#1200269, productGroup#1200270, filteredUnitOfMeasureConversions#1200271, quantityNumerator#1200272]
(186) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1200271.quantityDenominator), true, [quantityDenominator#1200273]
(187) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, timezonecode#1200258, systemId#1200259, internalUUID#1200260, id#1200261, displayId#1200262, name#1200263, baseUnitOfMeasure#1200264, unitOfMeasures#1200265, unitOfMeasureConversions#1200266, productionAspect#1200267, salesAspect#1200268, procurementAspect#1200269, productGroup#1200270, filteredUnitOfMeasureConversions#1200271, quantityNumerator#1200272, quantityDenominator#1200273]
(188) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, timezonecode#1200258, systemId#1200259, internalUUID#1200260, id#1200261, displayId#1200262, name#1200263, baseUnitOfMeasure#1200264, unitOfMeasures#1200265, unitOfMeasureConversions#1200266, productionAspect#1200267, salesAspect#1200268, procurementAspect#1200269, productGroup#1200270, filteredUnitOfMeasureConversions#1200271, quantityNumerator#1200272, quantityDenominator#1200273, (cast(quantityNumerator#1200272 as double) / cast(quantityDenominator#1200273 as double)) AS outboundUnit#1200274]
(189) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, timezonecode#1200258, systemId#1200259, internalUUID#1200260, id#1200261, displayId#1200262, name#1200263, baseUnitOfMeasure#1200264, unitOfMeasures#1200265, unitOfMeasureConversions#1200266, productionAspect#1200267, salesAspect#1200268, procurementAspect#1200269, productGroup#1200270, filteredUnitOfMeasureConversions#1200271, quantityNumerator#1200272, quantityDenominator#1200273, CASE WHEN (isnull(outboundUnit#1200274) OR (outboundUnit#1200274 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1200274 END AS outboundUnit#1200275]
(190) Project
Arguments: [product#1200232, plant#1200233, orderDateTime#1200234, productPlant#1200244, timezonecode#1200258, outboundUnit#1200275]
(191) Join
Arguments: Inner, ((plantUuid#1200224 = plant#1200233) AND (productUuid#1200226 = product#1200232))
(192) Filter
Arguments: (calculationDateTime#1200220 <= orderDateTime#1200234)
(193) Project
Arguments: [plantUuid#1200224 AS plant#1200276, productUuid#1200226 AS product#1200277, storageLocId#1200227, calculationDateTime#1200220, quantity#1200229]
(194) Aggregate
Arguments: [plant#1200276, product#1200277, storageLocId#1200227], [plant#1200276, product#1200277, storageLocId#1200227, max(calculationDateTime#1200220) AS max_calc_datetime#1200134]
(195) Join
Arguments: Inner, ((((plant#1200132 <=> plant#1200276) AND (product#1200133 <=> product#1200277)) AND (storageLocId#1200070 <=> storageLocId#1200227)) AND (calculationDateTime#1200049 <=> max_calc_datetime#1200134))
(196) Project
Arguments: [plant#1200132, product#1200133, storageLocId#1200070, calculationDateTime#1200049, quantity#1200072]
(197) Aggregate
Arguments: [product#1200133, plant#1200132], [product#1200133, plant#1200132, sum(quantity#1200072) AS quantitySum#1200288, min(calculationDateTime#1200049) AS minCalculationDateTime#1200289]
(198) Project
Arguments: [product#1200133, plant#1200132, quantitySum#1200288, minCalculationDateTime#1200289, round(quantitySum#1200288, 0) AS roundedQuantitySum#1200297]
(199) Join
Arguments: LeftOuter, ((plant#1199943 = plant#1200132) AND (product#1199942 = product#1200133))
(200) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001, roundedQuantitySum#1200297, minCalculationDateTime#1200289]
(201) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001, roundedQuantitySum#1200297, minCalculationDateTime#1200289, CASE WHEN isnotnull(minCalculationDateTime#1200289) THEN minCalculationDateTime#1200289 ELSE orderDateTime#1199944 END AS stockDatetime#1200346]
(202) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001, roundedQuantitySum#1200297, minCalculationDateTime#1200289, stockDatetime#1200346, CASE WHEN isnotnull(roundedQuantitySum#1200297) THEN array(roundedQuantitySum#1200297) ELSE array(0.0) END AS stockBatchQuantities#1200347]
(203) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001, roundedQuantitySum#1200297, minCalculationDateTime#1200289, stockDatetime#1200346, stockBatchQuantities#1200347, array(2199-01-01 00:00:00) AS stockBatchShelfLifeEndDatetimes#1200348]
(204) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001, roundedQuantitySum#1200297, stockDatetime#1200346, stockBatchQuantities#1200347, stockBatchShelfLifeEndDatetimes#1200348]
(205) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001, stockDatetime#1200346, stockBatchQuantities#1200347, stockBatchShelfLifeEndDatetimes#1200348]
(206) LogicalRelation
Arguments: parquet, [product#1200349, plant#1200350, demandChannel#1200351, demandStream#1200352, considerVariance#1200353, demandTimeBuckets#1200354, demandPointInTimeStart#1200355, demandPointInTimeEnd#1200356, demandPointInTime#1200357], false
(207) Join
Arguments: LeftOuter, ((product#1199942 = product#1200349) AND (plant#1199943 = plant#1200350))
(208) Project
Arguments: [product#1199942, plant#1199943, orderDateTime#1199944, productPlant#1199956, timezonecode#1199974, outboundUnit#1200001, stockDatetime#1200346, stockBatchQuantities#1200347, stockBatchShelfLifeEndDatetimes#1200348, demandChannel#1200351, demandStream#1200352, considerVariance#1200353, demandTimeBuckets#1200354, demandPointInTimeStart#1200355, demandPointInTimeEnd#1200356, demandPointInTime#1200357]
(209) Filter
Arguments: (((size(demandTimeBuckets#1200354, true) = 0) OR isnull(demandTimeBuckets#1200354)) AND ((size(demandPointInTime#1200357, true) = 0) OR isnull(demandPointInTime#1200357)))
(210) Project
Arguments: [product#1199942, plant#1199943]
(211) Project
Arguments: [product#1199942, plant#1199943, 1 AS configurationVersion#1200359]
(212) Project
Arguments: [product#1199942, plant#1199943, configurationVersion#1200359, UNKNOWN_DEMAND_FOR_PRODUCT_LOCATION AS name#1200360]
(213) Project
Arguments: [product#1199942, plant#1199943, configurationVersion#1200359, name#1200360, array(struct(name, PRODUCT, value, cast(product#1199942 as string)), struct(name, PLANT, value, cast(plant#1199943 as string))) AS businessContext#1200365]
(214) Project
Arguments: [product#1199942, plant#1199943, configurationVersion#1200359, name#1200360, businessContext#1200365, cast(array() as array<struct<variableName:string,variableValue:string>>) AS messageVariables#1200366]
(215) Deduplicate
Arguments: [businessContext#1200365, messageVariables#1200366, configurationVersion#1200359, product#1199942, plant#1199943, name#1200360]
(216) Project
Arguments: [product#1199942, plant#1199943, configurationVersion#1200359, name#1200360, businessContext#1200365, messageVariables#1200366, 10000001355 AS executionId#1200367]
(217) Project
Arguments: [product#1199942, plant#1199943, configurationVersion#1200359, name#1200360, businessContext#1200365, messageVariables#1200366, executionId#1200367, Grocery_SS AS marketUnit#1200368]
(218) Project
Arguments: [product#1199942, plant#1199943, configurationVersion#1200359, name#1200360, businessContext#1200365, messageVariables#1200366, executionId#1200367, marketUnit#1200368, 2026-07-21T13:23:35.337Z AS createdAt#1200369]
(219) Project
Arguments: [name#1200360, configurationVersion#1200359, executionId#1200367, createdAt#1200369, marketUnit#1200368, businessContext#1200365, messageVariables#1200366]
(220) Project
Arguments: [to_json(struct(name, name#1200360, configurationVersion, configurationVersion#1200359, executionId, executionId#1200367, createdAt, createdAt#1200369, marketUnit, marketUnit#1200368, businessContext, businessContext#1200365, messageVariables, messageVariables#1200366), Some(UTC)) AS value#1208925]
(221) Project
Arguments: [cast(value#1208925 as string) AS value#1208926]
(222) Project
Arguments: [value#1208926, array(struct(key, X-Tenant-ID, value, cast(7233423560970044043 as binary)), struct(key, X-Message-ID, value, cast(d35bacbc-ed78-4817-ac7a-e9ce44ada30a 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#1208935]