== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (191)
+- Project (190)
+- Project (189)
+- Project (188)
+- Project (187)
+- Project (186)
+- Project (185)
+- Project (184)
+- Project (183)
+- Project (182)
+- Project (181)
+- Project (180)
+- Join (179)
:- Deduplicate (175)
: +- Project (174)
: +- Filter (173)
: +- Join (172)
: :- Project (170)
: : +- Project (169)
: : +- Project (168)
: : +- Project (167)
: : +- Project (166)
: : +- Project (165)
: : +- Join (164)
: : :- Project (22)
: : : +- Project (21)
: : : +- Project (20)
: : : +- Project (19)
: : : +- Generate (18)
: : : +- Project (17)
: : : +- Generate (16)
: : : +- Project (15)
: : : +- Join (14)
: : : :- Project (11)
: : : : +- Join (10)
: : : : :- Project (5)
: : : : : +- RepartitionByExpression (4)
: : : : : +- LogicalRelation (3)
: : : : +- Project (9)
: : : : +- Project (8)
: : : : +- Repartition (7)
: : : : +- LogicalRelation (6)
: : : +- Repartition (13)
: : : +- LogicalRelation (12)
: : +- Project (163)
: : +- Aggregate (162)
: : +- Project (161)
: : +- Join (160)
: : :- Project (90)
: : : +- Filter (89)
: : : +- Join (88)
: : : :- Filter (67)
: : : : +- Project (66)
: : : : +- Project (65)
: : : : +- Generate (64)
: : : : +- Project (63)
: : : : +- Aggregate (62)
: : : : +- Project (61)
: : : : +- Generate (60)
: : : : +- Join (59)
: : : : :- Repartition (24)
: : : : : +- LogicalRelation (23)
: : : : +- Project (58)
: : : : +- Join (57)
: : : : :- Project (34)
: : : : : +- Project (33)
: : : : : +- Generate (32)
: : : : : +- Project (31)
: : : : : +- Generate (30)
: : : : : +- Project (29)
: : : : : +- Project (28)
: : : : : +- Filter (27)
: : : : : +- Repartition (26)
: : : : : +- LogicalRelation (25)
: : : : +- Deduplicate (56)
: : : : +- Project (55)
: : : : +- Project (54)
: : : : +- Project (53)
: : : : +- Project (52)
: : : : +- Project (51)
: : : : +- Generate (50)
: : : : +- Project (49)
: : : : +- Generate (48)
: : : : +- Project (47)
: : : : +- Join (46)
: : : : :- Project (43)
: : : : : +- Join (42)
: : : : : :- Project (37)
: : : : : : +- RepartitionByExpression (36)
: : : : : : +- LogicalRelation (35)
: : : : : +- Project (41)
: : : : : +- Project (40)
: : : : : +- Repartition (39)
: : : : : +- LogicalRelation (38)
: : : : +- Repartition (45)
: : : : +- LogicalRelation (44)
: : : +- Project (87)
: : : +- Project (86)
: : : +- Project (85)
: : : +- Project (84)
: : : +- Generate (83)
: : : +- Project (82)
: : : +- Generate (81)
: : : +- Project (80)
: : : +- Join (79)
: : : :- Project (76)
: : : : +- Join (75)
: : : : :- Project (70)
: : : : : +- RepartitionByExpression (69)
: : : : : +- LogicalRelation (68)
: : : : +- Project (74)
: : : : +- Project (73)
: : : : +- Repartition (72)
: : : : +- LogicalRelation (71)
: : : +- Repartition (78)
: : : +- LogicalRelation (77)
: : +- Aggregate (159)
: : +- Project (158)
: : +- Filter (157)
: : +- Join (156)
: : :- Filter (135)
: : : +- Project (134)
: : : +- Project (133)
: : : +- Generate (132)
: : : +- Project (131)
: : : +- Aggregate (130)
: : : +- Project (129)
: : : +- Generate (128)
: : : +- Join (127)
: : : :- Repartition (92)
: : : : +- LogicalRelation (91)
: : : +- Project (126)
: : : +- Join (125)
: : : :- Project (102)
: : : : +- Project (101)
: : : : +- Generate (100)
: : : : +- Project (99)
: : : : +- Generate (98)
: : : : +- Project (97)
: : : : +- Project (96)
: : : : +- Filter (95)
: : : : +- Repartition (94)
: : : : +- LogicalRelation (93)
: : : +- Deduplicate (124)
: : : +- Project (123)
: : : +- Project (122)
: : : +- Project (121)
: : : +- Project (120)
: : : +- Project (119)
: : : +- Generate (118)
: : : +- Project (117)
: : : +- Generate (116)
: : : +- Project (115)
: : : +- Join (114)
: : : :- Project (111)
: : : : +- Join (110)
: : : : :- Project (105)
: : : : : +- RepartitionByExpression (104)
: : : : : +- LogicalRelation (103)
: : : : +- Project (109)
: : : : +- Project (108)
: : : : +- Repartition (107)
: : : : +- LogicalRelation (106)
: : : +- Repartition (113)
: : : +- LogicalRelation (112)
: : +- Project (155)
: : +- Project (154)
: : +- Project (153)
: : +- Project (152)
: : +- Generate (151)
: : +- Project (150)
: : +- Generate (149)
: : +- Project (148)
: : +- Join (147)
: : :- Project (144)
: : : +- Join (143)
: : : :- Project (138)
: : : : +- RepartitionByExpression (137)
: : : : +- LogicalRelation (136)
: : : +- Project (142)
: : : +- Project (141)
: : : +- Repartition (140)
: : : +- LogicalRelation (139)
: : +- Repartition (146)
: : +- LogicalRelation (145)
: +- LogicalRelation (171)
+- Project (178)
+- Repartition (177)
+- LogicalRelation (176)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.kafka010.KafkaSourceProvider@2291d28a, [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=SituationsTopic, 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#944305, plant#944306, orderDateTime#944307, planningStartDateTime#944308], false
(4) RepartitionByExpression
Arguments: [product#944305, plant#944306], 37
(5) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307]
(6) LogicalRelation
Arguments: parquet, [systemId#944361, internalUUID#944362, plant#944363, product#944364, blockedForReplenishmentStartingFrom#944365, productionAspect#944366, salesPlant#944367, listing#944368, sourceOfSupplyCategory#944369], false
(7) Repartition
Arguments: 37, true
(8) Project
Arguments: [systemId#944361, internalUUID#944362, plant#944363, product#944364, blockedForReplenishmentStartingFrom#944365, productionAspect#944366, salesPlant#944367, listing#944368, sourceOfSupplyCategory#944369, struct(systemId, systemId#944361, internalUUID, internalUUID#944362, plant, plant#944363, product, product#944364, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#944365, productionAspect, productionAspect#944366, salesPlant, salesPlant#944367, listing, listing#944368, sourceOfSupplyCategory, sourceOfSupplyCategory#944369) AS productPlant#944371]
(9) Project
Arguments: [productPlant#944371]
(10) Join
Arguments: LeftOuter, ((product#944305 <=> productPlant#944371.product.internalRefUUID) AND (plant#944306 <=> productPlant#944371.plant.internalRefUUID))
(11) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371]
(12) LogicalRelation
Arguments: parquet, [systemId#944396, internalUUID#944397, id#944398, displayId#944399, name#944400, baseUnitOfMeasure#944401, unitOfMeasures#944402, unitOfMeasureConversions#944403, productionAspect#944404, salesAspect#944405, procurementAspect#944406, productGroup#944407], false
(13) Repartition
Arguments: 37, true
(14) Join
Arguments: LeftOuter, (product#944305 = internalUUID#944397)
(15) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, systemId#944396, internalUUID#944397, id#944398, displayId#944399, name#944400, baseUnitOfMeasure#944401, unitOfMeasures#944402, unitOfMeasureConversions#944403, productionAspect#944404, salesAspect#944405, procurementAspect#944406, productGroup#944407, filter(unitOfMeasureConversions#944403, lambdafunction((((lambda u#944410.measurementUnit1.code = productPlant#944371.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#944410.measurementUnit1.internalRefUUID = productPlant#944371.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#944410.measurementUnit2.code = baseUnitOfMeasure#944401.code) AND (lambda u#944410.measurementUnit2.internalRefUUID = baseUnitOfMeasure#944401.internalRefUUID))), lambda u#944410, false)) AS filteredUnitOfMeasureConversions#944409]
(16) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944409.quantityNumerator), true, [quantityNumerator#944417]
(17) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, systemId#944396, internalUUID#944397, id#944398, displayId#944399, name#944400, baseUnitOfMeasure#944401, unitOfMeasures#944402, unitOfMeasureConversions#944403, productionAspect#944404, salesAspect#944405, procurementAspect#944406, productGroup#944407, filteredUnitOfMeasureConversions#944409, quantityNumerator#944417]
(18) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944409.quantityDenominator), true, [quantityDenominator#944420]
(19) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, systemId#944396, internalUUID#944397, id#944398, displayId#944399, name#944400, baseUnitOfMeasure#944401, unitOfMeasures#944402, unitOfMeasureConversions#944403, productionAspect#944404, salesAspect#944405, procurementAspect#944406, productGroup#944407, filteredUnitOfMeasureConversions#944409, quantityNumerator#944417, quantityDenominator#944420]
(20) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, systemId#944396, internalUUID#944397, id#944398, displayId#944399, name#944400, baseUnitOfMeasure#944401, unitOfMeasures#944402, unitOfMeasureConversions#944403, productionAspect#944404, salesAspect#944405, procurementAspect#944406, productGroup#944407, filteredUnitOfMeasureConversions#944409, quantityNumerator#944417, quantityDenominator#944420, (cast(quantityNumerator#944417 as double) / cast(quantityDenominator#944420 as double)) AS outboundUnit#944421]
(21) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, systemId#944396, internalUUID#944397, id#944398, displayId#944399, name#944400, baseUnitOfMeasure#944401, unitOfMeasures#944402, unitOfMeasureConversions#944403, productionAspect#944404, salesAspect#944405, procurementAspect#944406, productGroup#944407, filteredUnitOfMeasureConversions#944409, quantityNumerator#944417, quantityDenominator#944420, CASE WHEN (isnull(outboundUnit#944421) OR (outboundUnit#944421 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#944421 END AS outboundUnit#944422]
(22) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, outboundUnit#944422]
(23) LogicalRelation
Arguments: parquet, [systemId#944560, internalUUID#944561, product#944562, plant#944563, calculationDateTime#944564, stockQuantities#944565], false
(24) Repartition
Arguments: 37, true
(25) LogicalRelation
Arguments: parquet, [marketUnit#944474, description#944475, articleHierarchy#944476, defaultCurrency#944477, responsibilities#944478, replenishmentTypes#944479, distributionCenters#944480, assignedArticleHierarchyNodes#944481, minOrderQtySetting#944482, listingCheck#944483, odsSelection#944484, demandProfiles#944485, constraintProfiles#944486, optimizationProfiles#944487, orderGroupSplitProfiles#944488, supplierMinimumProfiles#944489, multipleRestrictionProfiles#944490, preferredUomSource#944491, handlingOfUnfulfilledDemands#944492, negligibleQuantitiesThreshold#944493, eventtype#944494], false
(26) Repartition
Arguments: 37, true
(27) Filter
Arguments: (marketUnit#944474 <=> IW_MU_CRP-125444_1)
(28) Project
Arguments: [marketUnit#944474, description#944475, articleHierarchy#944476, defaultCurrency#944477, responsibilities#944478, replenishmentTypes#944479, distributionCenters#944480, assignedArticleHierarchyNodes#944481, minOrderQtySetting#944482, listingCheck#944483, odsSelection#944484, demandProfiles#944485, constraintProfiles#944486, optimizationProfiles#944487, orderGroupSplitProfiles#944488, supplierMinimumProfiles#944489, multipleRestrictionProfiles#944490, preferredUomSource#944491, handlingOfUnfulfilledDemands#944492, negligibleQuantitiesThreshold#944493, eventtype#944494]
(29) Project
Arguments: [distributionCenters#944480]
(30) Generate
Arguments: explode(distributionCenters#944480), false, [distributionCenters#944497]
(31) Project
Arguments: [distributionCenters#944497]
(32) Generate
Arguments: explode(distributionCenters#944497.storageLocations), false, [storageLocations#944504]
(33) Project
Arguments: [distributionCenters#944497.id AS plantId#944498, distributionCenters#944497.internalRefUUID AS plantUuid#944499, storageLocations#944504]
(34) Project
Arguments: [plantId#944498, plantUuid#944499, storageLocations#944504.id AS storageLocId#944505, storageLocations#944504.internalRefUUID AS storageLocUuid#944506]
(35) LogicalRelation
Arguments: parquet, [product#944777, plant#944778, orderDateTime#944779, planningStartDateTime#944780], false
(36) RepartitionByExpression
Arguments: [product#944777, plant#944778], 37
(37) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779]
(38) LogicalRelation
Arguments: parquet, [systemId#944781, internalUUID#944782, plant#944783, product#944784, blockedForReplenishmentStartingFrom#944785, productionAspect#944786, salesPlant#944787, listing#944788, sourceOfSupplyCategory#944789], false
(39) Repartition
Arguments: 37, true
(40) Project
Arguments: [systemId#944781, internalUUID#944782, plant#944783, product#944784, blockedForReplenishmentStartingFrom#944785, productionAspect#944786, salesPlant#944787, listing#944788, sourceOfSupplyCategory#944789, struct(systemId, systemId#944781, internalUUID, internalUUID#944782, plant, plant#944783, product, product#944784, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#944785, productionAspect, productionAspect#944786, salesPlant, salesPlant#944787, listing, listing#944788, sourceOfSupplyCategory, sourceOfSupplyCategory#944789) AS productPlant#944790]
(41) Project
Arguments: [productPlant#944790]
(42) Join
Arguments: LeftOuter, ((product#944777 <=> productPlant#944790.product.internalRefUUID) AND (plant#944778 <=> productPlant#944790.plant.internalRefUUID))
(43) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779, productPlant#944790]
(44) LogicalRelation
Arguments: parquet, [systemId#944791, internalUUID#944792, id#944793, displayId#944794, name#944795, baseUnitOfMeasure#944796, unitOfMeasures#944797, unitOfMeasureConversions#944798, productionAspect#944799, salesAspect#944800, procurementAspect#944801, productGroup#944802], false
(45) Repartition
Arguments: 37, true
(46) Join
Arguments: LeftOuter, (product#944777 = internalUUID#944792)
(47) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779, productPlant#944790, systemId#944791, internalUUID#944792, id#944793, displayId#944794, name#944795, baseUnitOfMeasure#944796, unitOfMeasures#944797, unitOfMeasureConversions#944798, productionAspect#944799, salesAspect#944800, procurementAspect#944801, productGroup#944802, filter(unitOfMeasureConversions#944798, lambdafunction((((lambda u#944410.measurementUnit1.code = productPlant#944790.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#944410.measurementUnit1.internalRefUUID = productPlant#944790.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#944410.measurementUnit2.code = baseUnitOfMeasure#944796.code) AND (lambda u#944410.measurementUnit2.internalRefUUID = baseUnitOfMeasure#944796.internalRefUUID))), lambda u#944410, false)) AS filteredUnitOfMeasureConversions#944803]
(48) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944803.quantityNumerator), true, [quantityNumerator#944804]
(49) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779, productPlant#944790, systemId#944791, internalUUID#944792, id#944793, displayId#944794, name#944795, baseUnitOfMeasure#944796, unitOfMeasures#944797, unitOfMeasureConversions#944798, productionAspect#944799, salesAspect#944800, procurementAspect#944801, productGroup#944802, filteredUnitOfMeasureConversions#944803, quantityNumerator#944804]
(50) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944803.quantityDenominator), true, [quantityDenominator#944805]
(51) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779, productPlant#944790, systemId#944791, internalUUID#944792, id#944793, displayId#944794, name#944795, baseUnitOfMeasure#944796, unitOfMeasures#944797, unitOfMeasureConversions#944798, productionAspect#944799, salesAspect#944800, procurementAspect#944801, productGroup#944802, filteredUnitOfMeasureConversions#944803, quantityNumerator#944804, quantityDenominator#944805]
(52) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779, productPlant#944790, systemId#944791, internalUUID#944792, id#944793, displayId#944794, name#944795, baseUnitOfMeasure#944796, unitOfMeasures#944797, unitOfMeasureConversions#944798, productionAspect#944799, salesAspect#944800, procurementAspect#944801, productGroup#944802, filteredUnitOfMeasureConversions#944803, quantityNumerator#944804, quantityDenominator#944805, (cast(quantityNumerator#944804 as double) / cast(quantityDenominator#944805 as double)) AS outboundUnit#944806]
(53) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779, productPlant#944790, systemId#944791, internalUUID#944792, id#944793, displayId#944794, name#944795, baseUnitOfMeasure#944796, unitOfMeasures#944797, unitOfMeasureConversions#944798, productionAspect#944799, salesAspect#944800, procurementAspect#944801, productGroup#944802, filteredUnitOfMeasureConversions#944803, quantityNumerator#944804, quantityDenominator#944805, CASE WHEN (isnull(outboundUnit#944806) OR (outboundUnit#944806 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#944806 END AS outboundUnit#944807]
(54) Project
Arguments: [product#944777, plant#944778, orderDateTime#944779, productPlant#944790, outboundUnit#944807]
(55) Project
Arguments: [plant#944778]
(56) Deduplicate
Arguments: [plant#944778]
(57) Join
Arguments: Inner, (plantUuid#944499 = plant#944778)
(58) Project
Arguments: [plantId#944498, plantUuid#944499, storageLocId#944505, storageLocUuid#944506]
(59) Join
Arguments: Inner, (plant#944563.internalRefUUID <=> plantUuid#944499)
(60) Generate
Arguments: explode(filter(stockQuantities#944565, lambdafunction(((lambda x#944569.storageLocation.internalRefUuid = storageLocUuid#944506) AND (lambda x#944569.storageLocation.Id = storageLocId#944505)), lambda x#944569, false))), false, [stockQuantity#944570]
(61) Project
Arguments: [systemId#944560, internalUUID#944561, product#944562, plant#944563, calculationDateTime#944564, stockQuantities#944565, plantId#944498, plantUuid#944499, storageLocId#944505, storageLocUuid#944506, stockQuantity#944570]
(62) Aggregate
Arguments: [plantUuid#944499, internalUUID#944561, plant#944563, product#944562, systemId#944560], [plantUuid#944499, internalUUID#944561, plant#944563, product#944562, systemId#944560, first(calculationDateTime#944564, false) AS calculationDateTime#944571, collect_list(stockQuantity#944570, 0, 0) AS stockQuantities#944572]
(63) Project
Arguments: [systemId#944560, internalUUID#944561, product#944562, plant#944563, calculationDateTime#944571, stockQuantities#944572]
(64) Generate
Arguments: explode(stockQuantities#944572), false, [stockQuantity#944587]
(65) Project
Arguments: [systemId#944560, internalUUID#944561, product#944562, plant#944563, calculationDateTime#944571, stockQuantities#944572, stockQuantity#944587]
(66) Project
Arguments: [plant#944563.id AS plant#944588, plant#944563.internalRefUUID AS plantUuid#944589, product#944562.id AS product#944590, product#944562.internalRefUUID AS productUuid#944591, calculationDateTime#944571, stockQuantity#944587.storagelocation.id AS storageLocId#944592, stockQuantity#944587.storagelocation.internalRefUUID AS storageLocUuid#944593, stockQuantity#944587.quantity.measure AS quantity#944594, stockQuantity#944587.specialStockIndicator.code AS specialStockIndicator#944595, stockQuantity#944587.stockType.code AS stockType#944596]
(67) Filter
Arguments: ((specialStockIndicator#944595 = ) AND (stockType#944596 = 01))
(68) LogicalRelation
Arguments: parquet, [product#944606, plant#944607, orderDateTime#944608, planningStartDateTime#944609], false
(69) RepartitionByExpression
Arguments: [product#944606, plant#944607], 37
(70) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608]
(71) LogicalRelation
Arguments: parquet, [systemId#944610, internalUUID#944611, plant#944612, product#944613, blockedForReplenishmentStartingFrom#944614, productionAspect#944615, salesPlant#944616, listing#944617, sourceOfSupplyCategory#944618], false
(72) Repartition
Arguments: 37, true
(73) Project
Arguments: [systemId#944610, internalUUID#944611, plant#944612, product#944613, blockedForReplenishmentStartingFrom#944614, productionAspect#944615, salesPlant#944616, listing#944617, sourceOfSupplyCategory#944618, struct(systemId, systemId#944610, internalUUID, internalUUID#944611, plant, plant#944612, product, product#944613, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#944614, productionAspect, productionAspect#944615, salesPlant, salesPlant#944616, listing, listing#944617, sourceOfSupplyCategory, sourceOfSupplyCategory#944618) AS productPlant#944619]
(74) Project
Arguments: [productPlant#944619]
(75) Join
Arguments: LeftOuter, ((product#944606 <=> productPlant#944619.product.internalRefUUID) AND (plant#944607 <=> productPlant#944619.plant.internalRefUUID))
(76) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608, productPlant#944619]
(77) LogicalRelation
Arguments: parquet, [systemId#944620, internalUUID#944621, id#944622, displayId#944623, name#944624, baseUnitOfMeasure#944625, unitOfMeasures#944626, unitOfMeasureConversions#944627, productionAspect#944628, salesAspect#944629, procurementAspect#944630, productGroup#944631], false
(78) Repartition
Arguments: 37, true
(79) Join
Arguments: LeftOuter, (product#944606 = internalUUID#944621)
(80) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608, productPlant#944619, systemId#944620, internalUUID#944621, id#944622, displayId#944623, name#944624, baseUnitOfMeasure#944625, unitOfMeasures#944626, unitOfMeasureConversions#944627, productionAspect#944628, salesAspect#944629, procurementAspect#944630, productGroup#944631, filter(unitOfMeasureConversions#944627, lambdafunction((((lambda u#944410.measurementUnit1.code = productPlant#944619.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#944410.measurementUnit1.internalRefUUID = productPlant#944619.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#944410.measurementUnit2.code = baseUnitOfMeasure#944625.code) AND (lambda u#944410.measurementUnit2.internalRefUUID = baseUnitOfMeasure#944625.internalRefUUID))), lambda u#944410, false)) AS filteredUnitOfMeasureConversions#944632]
(81) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944632.quantityNumerator), true, [quantityNumerator#944633]
(82) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608, productPlant#944619, systemId#944620, internalUUID#944621, id#944622, displayId#944623, name#944624, baseUnitOfMeasure#944625, unitOfMeasures#944626, unitOfMeasureConversions#944627, productionAspect#944628, salesAspect#944629, procurementAspect#944630, productGroup#944631, filteredUnitOfMeasureConversions#944632, quantityNumerator#944633]
(83) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944632.quantityDenominator), true, [quantityDenominator#944634]
(84) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608, productPlant#944619, systemId#944620, internalUUID#944621, id#944622, displayId#944623, name#944624, baseUnitOfMeasure#944625, unitOfMeasures#944626, unitOfMeasureConversions#944627, productionAspect#944628, salesAspect#944629, procurementAspect#944630, productGroup#944631, filteredUnitOfMeasureConversions#944632, quantityNumerator#944633, quantityDenominator#944634]
(85) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608, productPlant#944619, systemId#944620, internalUUID#944621, id#944622, displayId#944623, name#944624, baseUnitOfMeasure#944625, unitOfMeasures#944626, unitOfMeasureConversions#944627, productionAspect#944628, salesAspect#944629, procurementAspect#944630, productGroup#944631, filteredUnitOfMeasureConversions#944632, quantityNumerator#944633, quantityDenominator#944634, (cast(quantityNumerator#944633 as double) / cast(quantityDenominator#944634 as double)) AS outboundUnit#944635]
(86) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608, productPlant#944619, systemId#944620, internalUUID#944621, id#944622, displayId#944623, name#944624, baseUnitOfMeasure#944625, unitOfMeasures#944626, unitOfMeasureConversions#944627, productionAspect#944628, salesAspect#944629, procurementAspect#944630, productGroup#944631, filteredUnitOfMeasureConversions#944632, quantityNumerator#944633, quantityDenominator#944634, CASE WHEN (isnull(outboundUnit#944635) OR (outboundUnit#944635 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#944635 END AS outboundUnit#944636]
(87) Project
Arguments: [product#944606, plant#944607, orderDateTime#944608, productPlant#944619, outboundUnit#944636]
(88) Join
Arguments: Inner, ((plantUuid#944589 = plant#944607) AND (productUuid#944591 = product#944606))
(89) Filter
Arguments: (calculationDateTime#944571 <= orderDateTime#944608)
(90) Project
Arguments: [plantUuid#944589 AS plant#944640, productUuid#944591 AS product#944641, storageLocId#944592, calculationDateTime#944571, quantity#944594]
(91) LogicalRelation
Arguments: parquet, [systemId#944649, internalUUID#944650, product#944651, plant#944652, calculationDateTime#944653, stockQuantities#944654], false
(92) Repartition
Arguments: 37, true
(93) LogicalRelation
Arguments: parquet, [marketUnit#944655, description#944656, articleHierarchy#944657, defaultCurrency#944658, responsibilities#944659, replenishmentTypes#944660, distributionCenters#944661, assignedArticleHierarchyNodes#944662, minOrderQtySetting#944663, listingCheck#944664, odsSelection#944665, demandProfiles#944666, constraintProfiles#944667, optimizationProfiles#944668, orderGroupSplitProfiles#944669, supplierMinimumProfiles#944670, multipleRestrictionProfiles#944671, preferredUomSource#944672, handlingOfUnfulfilledDemands#944673, negligibleQuantitiesThreshold#944674, eventtype#944675], false
(94) Repartition
Arguments: 37, true
(95) Filter
Arguments: (marketUnit#944655 <=> IW_MU_CRP-125444_1)
(96) Project
Arguments: [marketUnit#944655, description#944656, articleHierarchy#944657, defaultCurrency#944658, responsibilities#944659, replenishmentTypes#944660, distributionCenters#944661, assignedArticleHierarchyNodes#944662, minOrderQtySetting#944663, listingCheck#944664, odsSelection#944665, demandProfiles#944666, constraintProfiles#944667, optimizationProfiles#944668, orderGroupSplitProfiles#944669, supplierMinimumProfiles#944670, multipleRestrictionProfiles#944671, preferredUomSource#944672, handlingOfUnfulfilledDemands#944673, negligibleQuantitiesThreshold#944674, eventtype#944675]
(97) Project
Arguments: [distributionCenters#944661]
(98) Generate
Arguments: explode(distributionCenters#944661), false, [distributionCenters#944676]
(99) Project
Arguments: [distributionCenters#944676]
(100) Generate
Arguments: explode(distributionCenters#944676.storageLocations), false, [storageLocations#944677]
(101) Project
Arguments: [distributionCenters#944676.id AS plantId#944678, distributionCenters#944676.internalRefUUID AS plantUuid#944679, storageLocations#944677]
(102) Project
Arguments: [plantId#944678, plantUuid#944679, storageLocations#944677.id AS storageLocId#944680, storageLocations#944677.internalRefUUID AS storageLocUuid#944681]
(103) LogicalRelation
Arguments: parquet, [product#944682, plant#944683, orderDateTime#944684, planningStartDateTime#944685], false
(104) RepartitionByExpression
Arguments: [product#944682, plant#944683], 37
(105) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684]
(106) LogicalRelation
Arguments: parquet, [systemId#944686, internalUUID#944687, plant#944688, product#944689, blockedForReplenishmentStartingFrom#944690, productionAspect#944691, salesPlant#944692, listing#944693, sourceOfSupplyCategory#944694], false
(107) Repartition
Arguments: 37, true
(108) Project
Arguments: [systemId#944686, internalUUID#944687, plant#944688, product#944689, blockedForReplenishmentStartingFrom#944690, productionAspect#944691, salesPlant#944692, listing#944693, sourceOfSupplyCategory#944694, struct(systemId, systemId#944686, internalUUID, internalUUID#944687, plant, plant#944688, product, product#944689, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#944690, productionAspect, productionAspect#944691, salesPlant, salesPlant#944692, listing, listing#944693, sourceOfSupplyCategory, sourceOfSupplyCategory#944694) AS productPlant#944695]
(109) Project
Arguments: [productPlant#944695]
(110) Join
Arguments: LeftOuter, ((product#944682 <=> productPlant#944695.product.internalRefUUID) AND (plant#944683 <=> productPlant#944695.plant.internalRefUUID))
(111) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684, productPlant#944695]
(112) LogicalRelation
Arguments: parquet, [systemId#944696, internalUUID#944697, id#944698, displayId#944699, name#944700, baseUnitOfMeasure#944701, unitOfMeasures#944702, unitOfMeasureConversions#944703, productionAspect#944704, salesAspect#944705, procurementAspect#944706, productGroup#944707], false
(113) Repartition
Arguments: 37, true
(114) Join
Arguments: LeftOuter, (product#944682 = internalUUID#944697)
(115) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684, productPlant#944695, systemId#944696, internalUUID#944697, id#944698, displayId#944699, name#944700, baseUnitOfMeasure#944701, unitOfMeasures#944702, unitOfMeasureConversions#944703, productionAspect#944704, salesAspect#944705, procurementAspect#944706, productGroup#944707, filter(unitOfMeasureConversions#944703, lambdafunction((((lambda u#944410.measurementUnit1.code = productPlant#944695.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#944410.measurementUnit1.internalRefUUID = productPlant#944695.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#944410.measurementUnit2.code = baseUnitOfMeasure#944701.code) AND (lambda u#944410.measurementUnit2.internalRefUUID = baseUnitOfMeasure#944701.internalRefUUID))), lambda u#944410, false)) AS filteredUnitOfMeasureConversions#944708]
(116) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944708.quantityNumerator), true, [quantityNumerator#944709]
(117) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684, productPlant#944695, systemId#944696, internalUUID#944697, id#944698, displayId#944699, name#944700, baseUnitOfMeasure#944701, unitOfMeasures#944702, unitOfMeasureConversions#944703, productionAspect#944704, salesAspect#944705, procurementAspect#944706, productGroup#944707, filteredUnitOfMeasureConversions#944708, quantityNumerator#944709]
(118) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944708.quantityDenominator), true, [quantityDenominator#944710]
(119) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684, productPlant#944695, systemId#944696, internalUUID#944697, id#944698, displayId#944699, name#944700, baseUnitOfMeasure#944701, unitOfMeasures#944702, unitOfMeasureConversions#944703, productionAspect#944704, salesAspect#944705, procurementAspect#944706, productGroup#944707, filteredUnitOfMeasureConversions#944708, quantityNumerator#944709, quantityDenominator#944710]
(120) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684, productPlant#944695, systemId#944696, internalUUID#944697, id#944698, displayId#944699, name#944700, baseUnitOfMeasure#944701, unitOfMeasures#944702, unitOfMeasureConversions#944703, productionAspect#944704, salesAspect#944705, procurementAspect#944706, productGroup#944707, filteredUnitOfMeasureConversions#944708, quantityNumerator#944709, quantityDenominator#944710, (cast(quantityNumerator#944709 as double) / cast(quantityDenominator#944710 as double)) AS outboundUnit#944711]
(121) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684, productPlant#944695, systemId#944696, internalUUID#944697, id#944698, displayId#944699, name#944700, baseUnitOfMeasure#944701, unitOfMeasures#944702, unitOfMeasureConversions#944703, productionAspect#944704, salesAspect#944705, procurementAspect#944706, productGroup#944707, filteredUnitOfMeasureConversions#944708, quantityNumerator#944709, quantityDenominator#944710, CASE WHEN (isnull(outboundUnit#944711) OR (outboundUnit#944711 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#944711 END AS outboundUnit#944712]
(122) Project
Arguments: [product#944682, plant#944683, orderDateTime#944684, productPlant#944695, outboundUnit#944712]
(123) Project
Arguments: [plant#944683]
(124) Deduplicate
Arguments: [plant#944683]
(125) Join
Arguments: Inner, (plantUuid#944679 = plant#944683)
(126) Project
Arguments: [plantId#944678, plantUuid#944679, storageLocId#944680, storageLocUuid#944681]
(127) Join
Arguments: Inner, (plant#944652.internalRefUUID <=> plantUuid#944679)
(128) Generate
Arguments: explode(filter(stockQuantities#944654, lambdafunction(((lambda x#944569.storageLocation.internalRefUuid = storageLocUuid#944681) AND (lambda x#944569.storageLocation.Id = storageLocId#944680)), lambda x#944569, false))), false, [stockQuantity#944713]
(129) Project
Arguments: [systemId#944649, internalUUID#944650, product#944651, plant#944652, calculationDateTime#944653, stockQuantities#944654, plantId#944678, plantUuid#944679, storageLocId#944680, storageLocUuid#944681, stockQuantity#944713]
(130) Aggregate
Arguments: [plantUuid#944679, internalUUID#944650, plant#944652, product#944651, systemId#944649], [plantUuid#944679, internalUUID#944650, plant#944652, product#944651, systemId#944649, first(calculationDateTime#944653, false) AS calculationDateTime#944714, collect_list(stockQuantity#944713, 0, 0) AS stockQuantities#944715]
(131) Project
Arguments: [systemId#944649, internalUUID#944650, product#944651, plant#944652, calculationDateTime#944714, stockQuantities#944715]
(132) Generate
Arguments: explode(stockQuantities#944715), false, [stockQuantity#944716]
(133) Project
Arguments: [systemId#944649, internalUUID#944650, product#944651, plant#944652, calculationDateTime#944714, stockQuantities#944715, stockQuantity#944716]
(134) Project
Arguments: [plant#944652.id AS plant#944717, plant#944652.internalRefUUID AS plantUuid#944718, product#944651.id AS product#944719, product#944651.internalRefUUID AS productUuid#944720, calculationDateTime#944714, stockQuantity#944716.storagelocation.id AS storageLocId#944721, stockQuantity#944716.storagelocation.internalRefUUID AS storageLocUuid#944722, stockQuantity#944716.quantity.measure AS quantity#944723, stockQuantity#944716.specialStockIndicator.code AS specialStockIndicator#944724, stockQuantity#944716.stockType.code AS stockType#944725]
(135) Filter
Arguments: ((specialStockIndicator#944724 = ) AND (stockType#944725 = 01))
(136) LogicalRelation
Arguments: parquet, [product#944726, plant#944727, orderDateTime#944728, planningStartDateTime#944729], false
(137) RepartitionByExpression
Arguments: [product#944726, plant#944727], 37
(138) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728]
(139) LogicalRelation
Arguments: parquet, [systemId#944730, internalUUID#944731, plant#944732, product#944733, blockedForReplenishmentStartingFrom#944734, productionAspect#944735, salesPlant#944736, listing#944737, sourceOfSupplyCategory#944738], false
(140) Repartition
Arguments: 37, true
(141) Project
Arguments: [systemId#944730, internalUUID#944731, plant#944732, product#944733, blockedForReplenishmentStartingFrom#944734, productionAspect#944735, salesPlant#944736, listing#944737, sourceOfSupplyCategory#944738, struct(systemId, systemId#944730, internalUUID, internalUUID#944731, plant, plant#944732, product, product#944733, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#944734, productionAspect, productionAspect#944735, salesPlant, salesPlant#944736, listing, listing#944737, sourceOfSupplyCategory, sourceOfSupplyCategory#944738) AS productPlant#944739]
(142) Project
Arguments: [productPlant#944739]
(143) Join
Arguments: LeftOuter, ((product#944726 <=> productPlant#944739.product.internalRefUUID) AND (plant#944727 <=> productPlant#944739.plant.internalRefUUID))
(144) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728, productPlant#944739]
(145) LogicalRelation
Arguments: parquet, [systemId#944740, internalUUID#944741, id#944742, displayId#944743, name#944744, baseUnitOfMeasure#944745, unitOfMeasures#944746, unitOfMeasureConversions#944747, productionAspect#944748, salesAspect#944749, procurementAspect#944750, productGroup#944751], false
(146) Repartition
Arguments: 37, true
(147) Join
Arguments: LeftOuter, (product#944726 = internalUUID#944741)
(148) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728, productPlant#944739, systemId#944740, internalUUID#944741, id#944742, displayId#944743, name#944744, baseUnitOfMeasure#944745, unitOfMeasures#944746, unitOfMeasureConversions#944747, productionAspect#944748, salesAspect#944749, procurementAspect#944750, productGroup#944751, filter(unitOfMeasureConversions#944747, lambdafunction((((lambda u#944410.measurementUnit1.code = productPlant#944739.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#944410.measurementUnit1.internalRefUUID = productPlant#944739.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#944410.measurementUnit2.code = baseUnitOfMeasure#944745.code) AND (lambda u#944410.measurementUnit2.internalRefUUID = baseUnitOfMeasure#944745.internalRefUUID))), lambda u#944410, false)) AS filteredUnitOfMeasureConversions#944752]
(149) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944752.quantityNumerator), true, [quantityNumerator#944753]
(150) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728, productPlant#944739, systemId#944740, internalUUID#944741, id#944742, displayId#944743, name#944744, baseUnitOfMeasure#944745, unitOfMeasures#944746, unitOfMeasureConversions#944747, productionAspect#944748, salesAspect#944749, procurementAspect#944750, productGroup#944751, filteredUnitOfMeasureConversions#944752, quantityNumerator#944753]
(151) Generate
Arguments: explode(filteredUnitOfMeasureConversions#944752.quantityDenominator), true, [quantityDenominator#944754]
(152) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728, productPlant#944739, systemId#944740, internalUUID#944741, id#944742, displayId#944743, name#944744, baseUnitOfMeasure#944745, unitOfMeasures#944746, unitOfMeasureConversions#944747, productionAspect#944748, salesAspect#944749, procurementAspect#944750, productGroup#944751, filteredUnitOfMeasureConversions#944752, quantityNumerator#944753, quantityDenominator#944754]
(153) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728, productPlant#944739, systemId#944740, internalUUID#944741, id#944742, displayId#944743, name#944744, baseUnitOfMeasure#944745, unitOfMeasures#944746, unitOfMeasureConversions#944747, productionAspect#944748, salesAspect#944749, procurementAspect#944750, productGroup#944751, filteredUnitOfMeasureConversions#944752, quantityNumerator#944753, quantityDenominator#944754, (cast(quantityNumerator#944753 as double) / cast(quantityDenominator#944754 as double)) AS outboundUnit#944755]
(154) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728, productPlant#944739, systemId#944740, internalUUID#944741, id#944742, displayId#944743, name#944744, baseUnitOfMeasure#944745, unitOfMeasures#944746, unitOfMeasureConversions#944747, productionAspect#944748, salesAspect#944749, procurementAspect#944750, productGroup#944751, filteredUnitOfMeasureConversions#944752, quantityNumerator#944753, quantityDenominator#944754, CASE WHEN (isnull(outboundUnit#944755) OR (outboundUnit#944755 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#944755 END AS outboundUnit#944756]
(155) Project
Arguments: [product#944726, plant#944727, orderDateTime#944728, productPlant#944739, outboundUnit#944756]
(156) Join
Arguments: Inner, ((plantUuid#944718 = plant#944727) AND (productUuid#944720 = product#944726))
(157) Filter
Arguments: (calculationDateTime#944714 <= orderDateTime#944728)
(158) Project
Arguments: [plantUuid#944718 AS plant#944757, productUuid#944720 AS product#944758, storageLocId#944721, calculationDateTime#944714, quantity#944723]
(159) Aggregate
Arguments: [plant#944757, product#944758, storageLocId#944721], [plant#944757, product#944758, storageLocId#944721, max(calculationDateTime#944714) AS max_calc_datetime#944642]
(160) Join
Arguments: Inner, ((((plant#944640 <=> plant#944757) AND (product#944641 <=> product#944758)) AND (storageLocId#944592 <=> storageLocId#944721)) AND (calculationDateTime#944571 <=> max_calc_datetime#944642))
(161) Project
Arguments: [plant#944640, product#944641, storageLocId#944592, calculationDateTime#944571, quantity#944594]
(162) Aggregate
Arguments: [product#944641, plant#944640], [product#944641, plant#944640, sum(quantity#944594) AS quantitySum#944767, min(calculationDateTime#944571) AS minCalculationDateTime#944768]
(163) Project
Arguments: [product#944641, plant#944640, quantitySum#944767, minCalculationDateTime#944768, round(quantitySum#944767, 0) AS roundedQuantitySum#944776]
(164) Join
Arguments: LeftOuter, ((plant#944306 = plant#944640) AND (product#944305 = product#944641))
(165) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, outboundUnit#944422, roundedQuantitySum#944776, minCalculationDateTime#944768]
(166) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, outboundUnit#944422, roundedQuantitySum#944776, minCalculationDateTime#944768, CASE WHEN isnotnull(minCalculationDateTime#944768) THEN minCalculationDateTime#944768 ELSE orderDateTime#944307 END AS stockDatetime#944811]
(167) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, outboundUnit#944422, roundedQuantitySum#944776, minCalculationDateTime#944768, stockDatetime#944811, CASE WHEN isnotnull(roundedQuantitySum#944776) THEN array(roundedQuantitySum#944776) ELSE array(0.0) END AS stockBatchQuantities#944812]
(168) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, outboundUnit#944422, roundedQuantitySum#944776, minCalculationDateTime#944768, stockDatetime#944811, stockBatchQuantities#944812, array(2199-01-01 00:00:00) AS stockBatchShelfLifeEndDatetimes#944813]
(169) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, outboundUnit#944422, roundedQuantitySum#944776, stockDatetime#944811, stockBatchQuantities#944812, stockBatchShelfLifeEndDatetimes#944813]
(170) Project
Arguments: [product#944305, plant#944306, orderDateTime#944307, productPlant#944371, outboundUnit#944422, stockDatetime#944811, stockBatchQuantities#944812, stockBatchShelfLifeEndDatetimes#944813]
(171) LogicalRelation
Arguments: parquet, [product#944814, plant#944815, demandChannel#944816, demandStream#944817, considerVariance#944818, demandTimeBuckets#944819, demandPointInTimeStart#944820, demandPointInTimeEnd#944821, demandPointInTime#944822], false
(172) Join
Arguments: LeftOuter, ((plant#944815 <=> plant#944306) AND (product#944814 <=> product#944305))
(173) Filter
Arguments: (((size(demandTimeBuckets#944819, true) = 0) OR isnull(demandTimeBuckets#944819)) AND ((size(demandPointInTime#944822, true) = 0) OR isnull(demandPointInTime#944822)))
(174) Project
Arguments: [product#944305, plant#944306]
(175) Deduplicate
Arguments: [product#944305, plant#944306]
(176) LogicalRelation
Arguments: parquet, [systemId#945556, internalUUID#945557, plant#945558, product#945559, blockedForReplenishmentStartingFrom#945560, productionAspect#945561, salesPlant#945562, listing#945563, sourceOfSupplyCategory#945564], false
(177) Repartition
Arguments: 37, true
(178) Project
Arguments: [product#945559.internalRefUUID AS product#945565, plant#945558.internalRefUUID AS plant#945566, product#945559.id AS productId#945567, plant#945558.id AS plantId#945568]
(179) Join
Arguments: Inner, ((product#944305 = product#945565) AND (plant#944306 = plant#945566))
(180) Project
Arguments: [product#944305, plant#944306, productId#945567, plantId#945568]
(181) Project
Arguments: [productId#945567 AS product#945574, plantId#945568 AS plant#945575]
(182) Project
Arguments: [product#945574, plant#945575, array(map(objectType, Product, objectId, product#945574), map(objectType, Plant, objectId, plant#945575)) AS anchorObject#945876]
(183) Project
Arguments: [product#945574, plant#945575, anchorObject#945876, cast(array() as array<map<string,string>>) AS messageVariables#945877]
(184) Project
Arguments: [product#945574, plant#945575, anchorObject#945876, messageVariables#945877, array(map(objectType, ReplenishmentRunId, objectId, 10000000678)) AS triggerObject#945878]
(185) Project
Arguments: [product#945574, plant#945575, anchorObject#945876, messageVariables#945877, triggerObject#945878, NEW AS situationStatus#945879]
(186) Project
Arguments: [product#945574, plant#945575, anchorObject#945876, messageVariables#945877, triggerObject#945878, situationStatus#945879, UNKNOWN_DEMAND_FOR_PRODUCT_LOCATION AS situationType#945880]
(187) Project
Arguments: [product#945574, plant#945575, anchorObject#945876, messageVariables#945877, triggerObject#945878, situationStatus#945879, situationType#945880, IW_MU_CRP-125444_1 AS marketUnit#945881]
(188) Project
Arguments: [anchorObject#945876, messageVariables#945877, triggerObject#945878, situationStatus#945879, situationType#945880, marketUnit#945881]
(189) Project
Arguments: [to_json(struct(anchorObject, anchorObject#945876, messageVariables, messageVariables#945877, triggerObject, triggerObject#945878, situationStatus, situationStatus#945879, situationType, situationType#945880, marketUnit, marketUnit#945881), Some(UTC)) AS value#957864]
(190) Project
Arguments: [cast(value#957864 as string) AS value#957865]
(191) Project
Arguments: [value#957865, array(struct(key, X-Tenant-ID, value, cast(6951945722030153353 as binary)), struct(key, X-Message-ID, value, cast(4cca7584-4c98-4ff5-950b-0e89ead2a21b as binary)), struct(key, X-Event-Type, value, cast(SituationCreate as binary)), struct(key, X-BTP-Tenant-ID, value, cast(f8a41c27-607a-45cd-a336-dc401b675e89 as binary))) AS headers#957874]