== 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@30e81a54, [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#905388, plant#905389, orderDateTime#905390, planningStartDateTime#905391], false
(4) RepartitionByExpression
Arguments: [product#905388, plant#905389], 37
(5) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390]
(6) LogicalRelation
Arguments: parquet, [systemId#905415, internalUUID#905416, plant#905417, product#905418, blockedForReplenishmentStartingFrom#905419, productionAspect#905420, salesPlant#905421, listing#905422, sourceOfSupplyCategory#905423], false
(7) Repartition
Arguments: 37, true
(8) Project
Arguments: [systemId#905415, internalUUID#905416, plant#905417, product#905418, blockedForReplenishmentStartingFrom#905419, productionAspect#905420, salesPlant#905421, listing#905422, sourceOfSupplyCategory#905423, struct(systemId, systemId#905415, internalUUID, internalUUID#905416, plant, plant#905417, product, product#905418, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#905419, productionAspect, productionAspect#905420, salesPlant, salesPlant#905421, listing, listing#905422, sourceOfSupplyCategory, sourceOfSupplyCategory#905423) AS productPlant#905425]
(9) Project
Arguments: [productPlant#905425]
(10) Join
Arguments: LeftOuter, ((product#905388 <=> productPlant#905425.product.internalRefUUID) AND (plant#905389 <=> productPlant#905425.plant.internalRefUUID))
(11) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425]
(12) LogicalRelation
Arguments: parquet, [systemId#905450, internalUUID#905451, id#905452, displayId#905453, name#905454, baseUnitOfMeasure#905455, unitOfMeasures#905456, unitOfMeasureConversions#905457, productionAspect#905458, salesAspect#905459, procurementAspect#905460, productGroup#905461], false
(13) Repartition
Arguments: 37, true
(14) Join
Arguments: LeftOuter, (product#905388 = internalUUID#905451)
(15) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, systemId#905450, internalUUID#905451, id#905452, displayId#905453, name#905454, baseUnitOfMeasure#905455, unitOfMeasures#905456, unitOfMeasureConversions#905457, productionAspect#905458, salesAspect#905459, procurementAspect#905460, productGroup#905461, filter(unitOfMeasureConversions#905457, lambdafunction((((lambda u#905464.measurementUnit1.code = productPlant#905425.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#905464.measurementUnit1.internalRefUUID = productPlant#905425.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#905464.measurementUnit2.code = baseUnitOfMeasure#905455.code) AND (lambda u#905464.measurementUnit2.internalRefUUID = baseUnitOfMeasure#905455.internalRefUUID))), lambda u#905464, false)) AS filteredUnitOfMeasureConversions#905463]
(16) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905463.quantityNumerator), true, [quantityNumerator#905471]
(17) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, systemId#905450, internalUUID#905451, id#905452, displayId#905453, name#905454, baseUnitOfMeasure#905455, unitOfMeasures#905456, unitOfMeasureConversions#905457, productionAspect#905458, salesAspect#905459, procurementAspect#905460, productGroup#905461, filteredUnitOfMeasureConversions#905463, quantityNumerator#905471]
(18) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905463.quantityDenominator), true, [quantityDenominator#905474]
(19) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, systemId#905450, internalUUID#905451, id#905452, displayId#905453, name#905454, baseUnitOfMeasure#905455, unitOfMeasures#905456, unitOfMeasureConversions#905457, productionAspect#905458, salesAspect#905459, procurementAspect#905460, productGroup#905461, filteredUnitOfMeasureConversions#905463, quantityNumerator#905471, quantityDenominator#905474]
(20) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, systemId#905450, internalUUID#905451, id#905452, displayId#905453, name#905454, baseUnitOfMeasure#905455, unitOfMeasures#905456, unitOfMeasureConversions#905457, productionAspect#905458, salesAspect#905459, procurementAspect#905460, productGroup#905461, filteredUnitOfMeasureConversions#905463, quantityNumerator#905471, quantityDenominator#905474, (cast(quantityNumerator#905471 as double) / cast(quantityDenominator#905474 as double)) AS outboundUnit#905475]
(21) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, systemId#905450, internalUUID#905451, id#905452, displayId#905453, name#905454, baseUnitOfMeasure#905455, unitOfMeasures#905456, unitOfMeasureConversions#905457, productionAspect#905458, salesAspect#905459, procurementAspect#905460, productGroup#905461, filteredUnitOfMeasureConversions#905463, quantityNumerator#905471, quantityDenominator#905474, CASE WHEN (isnull(outboundUnit#905475) OR (outboundUnit#905475 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#905475 END AS outboundUnit#905476]
(22) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, outboundUnit#905476]
(23) LogicalRelation
Arguments: parquet, [systemId#905585, internalUUID#905586, product#905587, plant#905588, calculationDateTime#905589, stockQuantities#905590], false
(24) Repartition
Arguments: 37, true
(25) LogicalRelation
Arguments: parquet, [marketUnit#905528, description#905529, articleHierarchy#905530, defaultCurrency#905531, responsibilities#905532, replenishmentTypes#905533, distributionCenters#905534, assignedArticleHierarchyNodes#905535, minOrderQtySetting#905536, listingCheck#905537, odsSelection#905538, demandProfiles#905539, constraintProfiles#905540, optimizationProfiles#905541, orderGroupSplitProfiles#905542, supplierMinimumProfiles#905543, multipleRestrictionProfiles#905544, preferredUomSource#905545, handlingOfUnfulfilledDemands#905546, negligibleQuantitiesThreshold#905547, eventtype#905548], false
(26) Repartition
Arguments: 37, true
(27) Filter
Arguments: (marketUnit#905528 <=> AUTO_ALL_ProdLoc)
(28) Project
Arguments: [marketUnit#905528, description#905529, articleHierarchy#905530, defaultCurrency#905531, responsibilities#905532, replenishmentTypes#905533, distributionCenters#905534, assignedArticleHierarchyNodes#905535, minOrderQtySetting#905536, listingCheck#905537, odsSelection#905538, demandProfiles#905539, constraintProfiles#905540, optimizationProfiles#905541, orderGroupSplitProfiles#905542, supplierMinimumProfiles#905543, multipleRestrictionProfiles#905544, preferredUomSource#905545, handlingOfUnfulfilledDemands#905546, negligibleQuantitiesThreshold#905547, eventtype#905548]
(29) Project
Arguments: [distributionCenters#905534]
(30) Generate
Arguments: explode(distributionCenters#905534), false, [distributionCenters#905551]
(31) Project
Arguments: [distributionCenters#905551]
(32) Generate
Arguments: explode(distributionCenters#905551.storageLocations), false, [storageLocations#905558]
(33) Project
Arguments: [distributionCenters#905551.id AS plantId#905552, distributionCenters#905551.internalRefUUID AS plantUuid#905553, storageLocations#905558]
(34) Project
Arguments: [plantId#905552, plantUuid#905553, storageLocations#905558.id AS storageLocId#905559, storageLocations#905558.internalRefUUID AS storageLocUuid#905560]
(35) LogicalRelation
Arguments: parquet, [product#905802, plant#905803, orderDateTime#905804, planningStartDateTime#905805], false
(36) RepartitionByExpression
Arguments: [product#905802, plant#905803], 37
(37) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804]
(38) LogicalRelation
Arguments: parquet, [systemId#905806, internalUUID#905807, plant#905808, product#905809, blockedForReplenishmentStartingFrom#905810, productionAspect#905811, salesPlant#905812, listing#905813, sourceOfSupplyCategory#905814], false
(39) Repartition
Arguments: 37, true
(40) Project
Arguments: [systemId#905806, internalUUID#905807, plant#905808, product#905809, blockedForReplenishmentStartingFrom#905810, productionAspect#905811, salesPlant#905812, listing#905813, sourceOfSupplyCategory#905814, struct(systemId, systemId#905806, internalUUID, internalUUID#905807, plant, plant#905808, product, product#905809, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#905810, productionAspect, productionAspect#905811, salesPlant, salesPlant#905812, listing, listing#905813, sourceOfSupplyCategory, sourceOfSupplyCategory#905814) AS productPlant#905815]
(41) Project
Arguments: [productPlant#905815]
(42) Join
Arguments: LeftOuter, ((product#905802 <=> productPlant#905815.product.internalRefUUID) AND (plant#905803 <=> productPlant#905815.plant.internalRefUUID))
(43) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804, productPlant#905815]
(44) LogicalRelation
Arguments: parquet, [systemId#905816, internalUUID#905817, id#905818, displayId#905819, name#905820, baseUnitOfMeasure#905821, unitOfMeasures#905822, unitOfMeasureConversions#905823, productionAspect#905824, salesAspect#905825, procurementAspect#905826, productGroup#905827], false
(45) Repartition
Arguments: 37, true
(46) Join
Arguments: LeftOuter, (product#905802 = internalUUID#905817)
(47) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804, productPlant#905815, systemId#905816, internalUUID#905817, id#905818, displayId#905819, name#905820, baseUnitOfMeasure#905821, unitOfMeasures#905822, unitOfMeasureConversions#905823, productionAspect#905824, salesAspect#905825, procurementAspect#905826, productGroup#905827, filter(unitOfMeasureConversions#905823, lambdafunction((((lambda u#905464.measurementUnit1.code = productPlant#905815.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#905464.measurementUnit1.internalRefUUID = productPlant#905815.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#905464.measurementUnit2.code = baseUnitOfMeasure#905821.code) AND (lambda u#905464.measurementUnit2.internalRefUUID = baseUnitOfMeasure#905821.internalRefUUID))), lambda u#905464, false)) AS filteredUnitOfMeasureConversions#905828]
(48) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905828.quantityNumerator), true, [quantityNumerator#905829]
(49) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804, productPlant#905815, systemId#905816, internalUUID#905817, id#905818, displayId#905819, name#905820, baseUnitOfMeasure#905821, unitOfMeasures#905822, unitOfMeasureConversions#905823, productionAspect#905824, salesAspect#905825, procurementAspect#905826, productGroup#905827, filteredUnitOfMeasureConversions#905828, quantityNumerator#905829]
(50) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905828.quantityDenominator), true, [quantityDenominator#905830]
(51) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804, productPlant#905815, systemId#905816, internalUUID#905817, id#905818, displayId#905819, name#905820, baseUnitOfMeasure#905821, unitOfMeasures#905822, unitOfMeasureConversions#905823, productionAspect#905824, salesAspect#905825, procurementAspect#905826, productGroup#905827, filteredUnitOfMeasureConversions#905828, quantityNumerator#905829, quantityDenominator#905830]
(52) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804, productPlant#905815, systemId#905816, internalUUID#905817, id#905818, displayId#905819, name#905820, baseUnitOfMeasure#905821, unitOfMeasures#905822, unitOfMeasureConversions#905823, productionAspect#905824, salesAspect#905825, procurementAspect#905826, productGroup#905827, filteredUnitOfMeasureConversions#905828, quantityNumerator#905829, quantityDenominator#905830, (cast(quantityNumerator#905829 as double) / cast(quantityDenominator#905830 as double)) AS outboundUnit#905831]
(53) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804, productPlant#905815, systemId#905816, internalUUID#905817, id#905818, displayId#905819, name#905820, baseUnitOfMeasure#905821, unitOfMeasures#905822, unitOfMeasureConversions#905823, productionAspect#905824, salesAspect#905825, procurementAspect#905826, productGroup#905827, filteredUnitOfMeasureConversions#905828, quantityNumerator#905829, quantityDenominator#905830, CASE WHEN (isnull(outboundUnit#905831) OR (outboundUnit#905831 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#905831 END AS outboundUnit#905832]
(54) Project
Arguments: [product#905802, plant#905803, orderDateTime#905804, productPlant#905815, outboundUnit#905832]
(55) Project
Arguments: [plant#905803]
(56) Deduplicate
Arguments: [plant#905803]
(57) Join
Arguments: Inner, (plantUuid#905553 = plant#905803)
(58) Project
Arguments: [plantId#905552, plantUuid#905553, storageLocId#905559, storageLocUuid#905560]
(59) Join
Arguments: Inner, (plant#905588.internalRefUUID <=> plantUuid#905553)
(60) Generate
Arguments: explode(filter(stockQuantities#905590, lambdafunction(((lambda x#905594.storageLocation.internalRefUuid = storageLocUuid#905560) AND (lambda x#905594.storageLocation.Id = storageLocId#905559)), lambda x#905594, false))), false, [stockQuantity#905595]
(61) Project
Arguments: [systemId#905585, internalUUID#905586, product#905587, plant#905588, calculationDateTime#905589, stockQuantities#905590, plantId#905552, plantUuid#905553, storageLocId#905559, storageLocUuid#905560, stockQuantity#905595]
(62) Aggregate
Arguments: [plantUuid#905553, internalUUID#905586, plant#905588, product#905587, systemId#905585], [plantUuid#905553, internalUUID#905586, plant#905588, product#905587, systemId#905585, first(calculationDateTime#905589, false) AS calculationDateTime#905596, collect_list(stockQuantity#905595, 0, 0) AS stockQuantities#905597]
(63) Project
Arguments: [systemId#905585, internalUUID#905586, product#905587, plant#905588, calculationDateTime#905596, stockQuantities#905597]
(64) Generate
Arguments: explode(stockQuantities#905597), false, [stockQuantity#905612]
(65) Project
Arguments: [systemId#905585, internalUUID#905586, product#905587, plant#905588, calculationDateTime#905596, stockQuantities#905597, stockQuantity#905612]
(66) Project
Arguments: [plant#905588.id AS plant#905613, plant#905588.internalRefUUID AS plantUuid#905614, product#905587.id AS product#905615, product#905587.internalRefUUID AS productUuid#905616, calculationDateTime#905596, stockQuantity#905612.storagelocation.id AS storageLocId#905617, stockQuantity#905612.storagelocation.internalRefUUID AS storageLocUuid#905618, stockQuantity#905612.quantity.measure AS quantity#905619, stockQuantity#905612.specialStockIndicator.code AS specialStockIndicator#905620, stockQuantity#905612.stockType.code AS stockType#905621]
(67) Filter
Arguments: ((specialStockIndicator#905620 = ) AND (stockType#905621 = 01))
(68) LogicalRelation
Arguments: parquet, [product#905631, plant#905632, orderDateTime#905633, planningStartDateTime#905634], false
(69) RepartitionByExpression
Arguments: [product#905631, plant#905632], 37
(70) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633]
(71) LogicalRelation
Arguments: parquet, [systemId#905635, internalUUID#905636, plant#905637, product#905638, blockedForReplenishmentStartingFrom#905639, productionAspect#905640, salesPlant#905641, listing#905642, sourceOfSupplyCategory#905643], false
(72) Repartition
Arguments: 37, true
(73) Project
Arguments: [systemId#905635, internalUUID#905636, plant#905637, product#905638, blockedForReplenishmentStartingFrom#905639, productionAspect#905640, salesPlant#905641, listing#905642, sourceOfSupplyCategory#905643, struct(systemId, systemId#905635, internalUUID, internalUUID#905636, plant, plant#905637, product, product#905638, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#905639, productionAspect, productionAspect#905640, salesPlant, salesPlant#905641, listing, listing#905642, sourceOfSupplyCategory, sourceOfSupplyCategory#905643) AS productPlant#905644]
(74) Project
Arguments: [productPlant#905644]
(75) Join
Arguments: LeftOuter, ((product#905631 <=> productPlant#905644.product.internalRefUUID) AND (plant#905632 <=> productPlant#905644.plant.internalRefUUID))
(76) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633, productPlant#905644]
(77) LogicalRelation
Arguments: parquet, [systemId#905645, internalUUID#905646, id#905647, displayId#905648, name#905649, baseUnitOfMeasure#905650, unitOfMeasures#905651, unitOfMeasureConversions#905652, productionAspect#905653, salesAspect#905654, procurementAspect#905655, productGroup#905656], false
(78) Repartition
Arguments: 37, true
(79) Join
Arguments: LeftOuter, (product#905631 = internalUUID#905646)
(80) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633, productPlant#905644, systemId#905645, internalUUID#905646, id#905647, displayId#905648, name#905649, baseUnitOfMeasure#905650, unitOfMeasures#905651, unitOfMeasureConversions#905652, productionAspect#905653, salesAspect#905654, procurementAspect#905655, productGroup#905656, filter(unitOfMeasureConversions#905652, lambdafunction((((lambda u#905464.measurementUnit1.code = productPlant#905644.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#905464.measurementUnit1.internalRefUUID = productPlant#905644.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#905464.measurementUnit2.code = baseUnitOfMeasure#905650.code) AND (lambda u#905464.measurementUnit2.internalRefUUID = baseUnitOfMeasure#905650.internalRefUUID))), lambda u#905464, false)) AS filteredUnitOfMeasureConversions#905657]
(81) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905657.quantityNumerator), true, [quantityNumerator#905658]
(82) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633, productPlant#905644, systemId#905645, internalUUID#905646, id#905647, displayId#905648, name#905649, baseUnitOfMeasure#905650, unitOfMeasures#905651, unitOfMeasureConversions#905652, productionAspect#905653, salesAspect#905654, procurementAspect#905655, productGroup#905656, filteredUnitOfMeasureConversions#905657, quantityNumerator#905658]
(83) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905657.quantityDenominator), true, [quantityDenominator#905659]
(84) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633, productPlant#905644, systemId#905645, internalUUID#905646, id#905647, displayId#905648, name#905649, baseUnitOfMeasure#905650, unitOfMeasures#905651, unitOfMeasureConversions#905652, productionAspect#905653, salesAspect#905654, procurementAspect#905655, productGroup#905656, filteredUnitOfMeasureConversions#905657, quantityNumerator#905658, quantityDenominator#905659]
(85) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633, productPlant#905644, systemId#905645, internalUUID#905646, id#905647, displayId#905648, name#905649, baseUnitOfMeasure#905650, unitOfMeasures#905651, unitOfMeasureConversions#905652, productionAspect#905653, salesAspect#905654, procurementAspect#905655, productGroup#905656, filteredUnitOfMeasureConversions#905657, quantityNumerator#905658, quantityDenominator#905659, (cast(quantityNumerator#905658 as double) / cast(quantityDenominator#905659 as double)) AS outboundUnit#905660]
(86) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633, productPlant#905644, systemId#905645, internalUUID#905646, id#905647, displayId#905648, name#905649, baseUnitOfMeasure#905650, unitOfMeasures#905651, unitOfMeasureConversions#905652, productionAspect#905653, salesAspect#905654, procurementAspect#905655, productGroup#905656, filteredUnitOfMeasureConversions#905657, quantityNumerator#905658, quantityDenominator#905659, CASE WHEN (isnull(outboundUnit#905660) OR (outboundUnit#905660 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#905660 END AS outboundUnit#905661]
(87) Project
Arguments: [product#905631, plant#905632, orderDateTime#905633, productPlant#905644, outboundUnit#905661]
(88) Join
Arguments: Inner, ((plantUuid#905614 = plant#905632) AND (productUuid#905616 = product#905631))
(89) Filter
Arguments: (calculationDateTime#905596 <= orderDateTime#905633)
(90) Project
Arguments: [plantUuid#905614 AS plant#905665, productUuid#905616 AS product#905666, storageLocId#905617, calculationDateTime#905596, quantity#905619]
(91) LogicalRelation
Arguments: parquet, [systemId#905674, internalUUID#905675, product#905676, plant#905677, calculationDateTime#905678, stockQuantities#905679], false
(92) Repartition
Arguments: 37, true
(93) LogicalRelation
Arguments: parquet, [marketUnit#905680, description#905681, articleHierarchy#905682, defaultCurrency#905683, responsibilities#905684, replenishmentTypes#905685, distributionCenters#905686, assignedArticleHierarchyNodes#905687, minOrderQtySetting#905688, listingCheck#905689, odsSelection#905690, demandProfiles#905691, constraintProfiles#905692, optimizationProfiles#905693, orderGroupSplitProfiles#905694, supplierMinimumProfiles#905695, multipleRestrictionProfiles#905696, preferredUomSource#905697, handlingOfUnfulfilledDemands#905698, negligibleQuantitiesThreshold#905699, eventtype#905700], false
(94) Repartition
Arguments: 37, true
(95) Filter
Arguments: (marketUnit#905680 <=> AUTO_ALL_ProdLoc)
(96) Project
Arguments: [marketUnit#905680, description#905681, articleHierarchy#905682, defaultCurrency#905683, responsibilities#905684, replenishmentTypes#905685, distributionCenters#905686, assignedArticleHierarchyNodes#905687, minOrderQtySetting#905688, listingCheck#905689, odsSelection#905690, demandProfiles#905691, constraintProfiles#905692, optimizationProfiles#905693, orderGroupSplitProfiles#905694, supplierMinimumProfiles#905695, multipleRestrictionProfiles#905696, preferredUomSource#905697, handlingOfUnfulfilledDemands#905698, negligibleQuantitiesThreshold#905699, eventtype#905700]
(97) Project
Arguments: [distributionCenters#905686]
(98) Generate
Arguments: explode(distributionCenters#905686), false, [distributionCenters#905701]
(99) Project
Arguments: [distributionCenters#905701]
(100) Generate
Arguments: explode(distributionCenters#905701.storageLocations), false, [storageLocations#905702]
(101) Project
Arguments: [distributionCenters#905701.id AS plantId#905703, distributionCenters#905701.internalRefUUID AS plantUuid#905704, storageLocations#905702]
(102) Project
Arguments: [plantId#905703, plantUuid#905704, storageLocations#905702.id AS storageLocId#905705, storageLocations#905702.internalRefUUID AS storageLocUuid#905706]
(103) LogicalRelation
Arguments: parquet, [product#905707, plant#905708, orderDateTime#905709, planningStartDateTime#905710], false
(104) RepartitionByExpression
Arguments: [product#905707, plant#905708], 37
(105) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709]
(106) LogicalRelation
Arguments: parquet, [systemId#905711, internalUUID#905712, plant#905713, product#905714, blockedForReplenishmentStartingFrom#905715, productionAspect#905716, salesPlant#905717, listing#905718, sourceOfSupplyCategory#905719], false
(107) Repartition
Arguments: 37, true
(108) Project
Arguments: [systemId#905711, internalUUID#905712, plant#905713, product#905714, blockedForReplenishmentStartingFrom#905715, productionAspect#905716, salesPlant#905717, listing#905718, sourceOfSupplyCategory#905719, struct(systemId, systemId#905711, internalUUID, internalUUID#905712, plant, plant#905713, product, product#905714, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#905715, productionAspect, productionAspect#905716, salesPlant, salesPlant#905717, listing, listing#905718, sourceOfSupplyCategory, sourceOfSupplyCategory#905719) AS productPlant#905720]
(109) Project
Arguments: [productPlant#905720]
(110) Join
Arguments: LeftOuter, ((product#905707 <=> productPlant#905720.product.internalRefUUID) AND (plant#905708 <=> productPlant#905720.plant.internalRefUUID))
(111) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709, productPlant#905720]
(112) LogicalRelation
Arguments: parquet, [systemId#905721, internalUUID#905722, id#905723, displayId#905724, name#905725, baseUnitOfMeasure#905726, unitOfMeasures#905727, unitOfMeasureConversions#905728, productionAspect#905729, salesAspect#905730, procurementAspect#905731, productGroup#905732], false
(113) Repartition
Arguments: 37, true
(114) Join
Arguments: LeftOuter, (product#905707 = internalUUID#905722)
(115) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709, productPlant#905720, systemId#905721, internalUUID#905722, id#905723, displayId#905724, name#905725, baseUnitOfMeasure#905726, unitOfMeasures#905727, unitOfMeasureConversions#905728, productionAspect#905729, salesAspect#905730, procurementAspect#905731, productGroup#905732, filter(unitOfMeasureConversions#905728, lambdafunction((((lambda u#905464.measurementUnit1.code = productPlant#905720.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#905464.measurementUnit1.internalRefUUID = productPlant#905720.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#905464.measurementUnit2.code = baseUnitOfMeasure#905726.code) AND (lambda u#905464.measurementUnit2.internalRefUUID = baseUnitOfMeasure#905726.internalRefUUID))), lambda u#905464, false)) AS filteredUnitOfMeasureConversions#905733]
(116) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905733.quantityNumerator), true, [quantityNumerator#905734]
(117) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709, productPlant#905720, systemId#905721, internalUUID#905722, id#905723, displayId#905724, name#905725, baseUnitOfMeasure#905726, unitOfMeasures#905727, unitOfMeasureConversions#905728, productionAspect#905729, salesAspect#905730, procurementAspect#905731, productGroup#905732, filteredUnitOfMeasureConversions#905733, quantityNumerator#905734]
(118) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905733.quantityDenominator), true, [quantityDenominator#905735]
(119) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709, productPlant#905720, systemId#905721, internalUUID#905722, id#905723, displayId#905724, name#905725, baseUnitOfMeasure#905726, unitOfMeasures#905727, unitOfMeasureConversions#905728, productionAspect#905729, salesAspect#905730, procurementAspect#905731, productGroup#905732, filteredUnitOfMeasureConversions#905733, quantityNumerator#905734, quantityDenominator#905735]
(120) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709, productPlant#905720, systemId#905721, internalUUID#905722, id#905723, displayId#905724, name#905725, baseUnitOfMeasure#905726, unitOfMeasures#905727, unitOfMeasureConversions#905728, productionAspect#905729, salesAspect#905730, procurementAspect#905731, productGroup#905732, filteredUnitOfMeasureConversions#905733, quantityNumerator#905734, quantityDenominator#905735, (cast(quantityNumerator#905734 as double) / cast(quantityDenominator#905735 as double)) AS outboundUnit#905736]
(121) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709, productPlant#905720, systemId#905721, internalUUID#905722, id#905723, displayId#905724, name#905725, baseUnitOfMeasure#905726, unitOfMeasures#905727, unitOfMeasureConversions#905728, productionAspect#905729, salesAspect#905730, procurementAspect#905731, productGroup#905732, filteredUnitOfMeasureConversions#905733, quantityNumerator#905734, quantityDenominator#905735, CASE WHEN (isnull(outboundUnit#905736) OR (outboundUnit#905736 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#905736 END AS outboundUnit#905737]
(122) Project
Arguments: [product#905707, plant#905708, orderDateTime#905709, productPlant#905720, outboundUnit#905737]
(123) Project
Arguments: [plant#905708]
(124) Deduplicate
Arguments: [plant#905708]
(125) Join
Arguments: Inner, (plantUuid#905704 = plant#905708)
(126) Project
Arguments: [plantId#905703, plantUuid#905704, storageLocId#905705, storageLocUuid#905706]
(127) Join
Arguments: Inner, (plant#905677.internalRefUUID <=> plantUuid#905704)
(128) Generate
Arguments: explode(filter(stockQuantities#905679, lambdafunction(((lambda x#905594.storageLocation.internalRefUuid = storageLocUuid#905706) AND (lambda x#905594.storageLocation.Id = storageLocId#905705)), lambda x#905594, false))), false, [stockQuantity#905738]
(129) Project
Arguments: [systemId#905674, internalUUID#905675, product#905676, plant#905677, calculationDateTime#905678, stockQuantities#905679, plantId#905703, plantUuid#905704, storageLocId#905705, storageLocUuid#905706, stockQuantity#905738]
(130) Aggregate
Arguments: [plantUuid#905704, internalUUID#905675, plant#905677, product#905676, systemId#905674], [plantUuid#905704, internalUUID#905675, plant#905677, product#905676, systemId#905674, first(calculationDateTime#905678, false) AS calculationDateTime#905739, collect_list(stockQuantity#905738, 0, 0) AS stockQuantities#905740]
(131) Project
Arguments: [systemId#905674, internalUUID#905675, product#905676, plant#905677, calculationDateTime#905739, stockQuantities#905740]
(132) Generate
Arguments: explode(stockQuantities#905740), false, [stockQuantity#905741]
(133) Project
Arguments: [systemId#905674, internalUUID#905675, product#905676, plant#905677, calculationDateTime#905739, stockQuantities#905740, stockQuantity#905741]
(134) Project
Arguments: [plant#905677.id AS plant#905742, plant#905677.internalRefUUID AS plantUuid#905743, product#905676.id AS product#905744, product#905676.internalRefUUID AS productUuid#905745, calculationDateTime#905739, stockQuantity#905741.storagelocation.id AS storageLocId#905746, stockQuantity#905741.storagelocation.internalRefUUID AS storageLocUuid#905747, stockQuantity#905741.quantity.measure AS quantity#905748, stockQuantity#905741.specialStockIndicator.code AS specialStockIndicator#905749, stockQuantity#905741.stockType.code AS stockType#905750]
(135) Filter
Arguments: ((specialStockIndicator#905749 = ) AND (stockType#905750 = 01))
(136) LogicalRelation
Arguments: parquet, [product#905751, plant#905752, orderDateTime#905753, planningStartDateTime#905754], false
(137) RepartitionByExpression
Arguments: [product#905751, plant#905752], 37
(138) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753]
(139) LogicalRelation
Arguments: parquet, [systemId#905755, internalUUID#905756, plant#905757, product#905758, blockedForReplenishmentStartingFrom#905759, productionAspect#905760, salesPlant#905761, listing#905762, sourceOfSupplyCategory#905763], false
(140) Repartition
Arguments: 37, true
(141) Project
Arguments: [systemId#905755, internalUUID#905756, plant#905757, product#905758, blockedForReplenishmentStartingFrom#905759, productionAspect#905760, salesPlant#905761, listing#905762, sourceOfSupplyCategory#905763, struct(systemId, systemId#905755, internalUUID, internalUUID#905756, plant, plant#905757, product, product#905758, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#905759, productionAspect, productionAspect#905760, salesPlant, salesPlant#905761, listing, listing#905762, sourceOfSupplyCategory, sourceOfSupplyCategory#905763) AS productPlant#905764]
(142) Project
Arguments: [productPlant#905764]
(143) Join
Arguments: LeftOuter, ((product#905751 <=> productPlant#905764.product.internalRefUUID) AND (plant#905752 <=> productPlant#905764.plant.internalRefUUID))
(144) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753, productPlant#905764]
(145) LogicalRelation
Arguments: parquet, [systemId#905765, internalUUID#905766, id#905767, displayId#905768, name#905769, baseUnitOfMeasure#905770, unitOfMeasures#905771, unitOfMeasureConversions#905772, productionAspect#905773, salesAspect#905774, procurementAspect#905775, productGroup#905776], false
(146) Repartition
Arguments: 37, true
(147) Join
Arguments: LeftOuter, (product#905751 = internalUUID#905766)
(148) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753, productPlant#905764, systemId#905765, internalUUID#905766, id#905767, displayId#905768, name#905769, baseUnitOfMeasure#905770, unitOfMeasures#905771, unitOfMeasureConversions#905772, productionAspect#905773, salesAspect#905774, procurementAspect#905775, productGroup#905776, filter(unitOfMeasureConversions#905772, lambdafunction((((lambda u#905464.measurementUnit1.code = productPlant#905764.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#905464.measurementUnit1.internalRefUUID = productPlant#905764.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#905464.measurementUnit2.code = baseUnitOfMeasure#905770.code) AND (lambda u#905464.measurementUnit2.internalRefUUID = baseUnitOfMeasure#905770.internalRefUUID))), lambda u#905464, false)) AS filteredUnitOfMeasureConversions#905777]
(149) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905777.quantityNumerator), true, [quantityNumerator#905778]
(150) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753, productPlant#905764, systemId#905765, internalUUID#905766, id#905767, displayId#905768, name#905769, baseUnitOfMeasure#905770, unitOfMeasures#905771, unitOfMeasureConversions#905772, productionAspect#905773, salesAspect#905774, procurementAspect#905775, productGroup#905776, filteredUnitOfMeasureConversions#905777, quantityNumerator#905778]
(151) Generate
Arguments: explode(filteredUnitOfMeasureConversions#905777.quantityDenominator), true, [quantityDenominator#905779]
(152) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753, productPlant#905764, systemId#905765, internalUUID#905766, id#905767, displayId#905768, name#905769, baseUnitOfMeasure#905770, unitOfMeasures#905771, unitOfMeasureConversions#905772, productionAspect#905773, salesAspect#905774, procurementAspect#905775, productGroup#905776, filteredUnitOfMeasureConversions#905777, quantityNumerator#905778, quantityDenominator#905779]
(153) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753, productPlant#905764, systemId#905765, internalUUID#905766, id#905767, displayId#905768, name#905769, baseUnitOfMeasure#905770, unitOfMeasures#905771, unitOfMeasureConversions#905772, productionAspect#905773, salesAspect#905774, procurementAspect#905775, productGroup#905776, filteredUnitOfMeasureConversions#905777, quantityNumerator#905778, quantityDenominator#905779, (cast(quantityNumerator#905778 as double) / cast(quantityDenominator#905779 as double)) AS outboundUnit#905780]
(154) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753, productPlant#905764, systemId#905765, internalUUID#905766, id#905767, displayId#905768, name#905769, baseUnitOfMeasure#905770, unitOfMeasures#905771, unitOfMeasureConversions#905772, productionAspect#905773, salesAspect#905774, procurementAspect#905775, productGroup#905776, filteredUnitOfMeasureConversions#905777, quantityNumerator#905778, quantityDenominator#905779, CASE WHEN (isnull(outboundUnit#905780) OR (outboundUnit#905780 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#905780 END AS outboundUnit#905781]
(155) Project
Arguments: [product#905751, plant#905752, orderDateTime#905753, productPlant#905764, outboundUnit#905781]
(156) Join
Arguments: Inner, ((plantUuid#905743 = plant#905752) AND (productUuid#905745 = product#905751))
(157) Filter
Arguments: (calculationDateTime#905739 <= orderDateTime#905753)
(158) Project
Arguments: [plantUuid#905743 AS plant#905782, productUuid#905745 AS product#905783, storageLocId#905746, calculationDateTime#905739, quantity#905748]
(159) Aggregate
Arguments: [plant#905782, product#905783, storageLocId#905746], [plant#905782, product#905783, storageLocId#905746, max(calculationDateTime#905739) AS max_calc_datetime#905667]
(160) Join
Arguments: Inner, ((((plant#905665 <=> plant#905782) AND (product#905666 <=> product#905783)) AND (storageLocId#905617 <=> storageLocId#905746)) AND (calculationDateTime#905596 <=> max_calc_datetime#905667))
(161) Project
Arguments: [plant#905665, product#905666, storageLocId#905617, calculationDateTime#905596, quantity#905619]
(162) Aggregate
Arguments: [product#905666, plant#905665], [product#905666, plant#905665, sum(quantity#905619) AS quantitySum#905792, min(calculationDateTime#905596) AS minCalculationDateTime#905793]
(163) Project
Arguments: [product#905666, plant#905665, quantitySum#905792, minCalculationDateTime#905793, round(quantitySum#905792, 0) AS roundedQuantitySum#905801]
(164) Join
Arguments: LeftOuter, ((plant#905389 = plant#905665) AND (product#905388 = product#905666))
(165) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, outboundUnit#905476, roundedQuantitySum#905801, minCalculationDateTime#905793]
(166) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, outboundUnit#905476, roundedQuantitySum#905801, minCalculationDateTime#905793, CASE WHEN isnotnull(minCalculationDateTime#905793) THEN minCalculationDateTime#905793 ELSE orderDateTime#905390 END AS stockDatetime#905836]
(167) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, outboundUnit#905476, roundedQuantitySum#905801, minCalculationDateTime#905793, stockDatetime#905836, CASE WHEN isnotnull(roundedQuantitySum#905801) THEN array(roundedQuantitySum#905801) ELSE array(0.0) END AS stockBatchQuantities#905837]
(168) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, outboundUnit#905476, roundedQuantitySum#905801, minCalculationDateTime#905793, stockDatetime#905836, stockBatchQuantities#905837, array(2199-01-01 00:00:00) AS stockBatchShelfLifeEndDatetimes#905838]
(169) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, outboundUnit#905476, roundedQuantitySum#905801, stockDatetime#905836, stockBatchQuantities#905837, stockBatchShelfLifeEndDatetimes#905838]
(170) Project
Arguments: [product#905388, plant#905389, orderDateTime#905390, productPlant#905425, outboundUnit#905476, stockDatetime#905836, stockBatchQuantities#905837, stockBatchShelfLifeEndDatetimes#905838]
(171) LogicalRelation
Arguments: parquet, [product#905839, plant#905840, demandChannel#905841, demandStream#905842, considerVariance#905843, demandTimeBuckets#905844, demandPointInTimeStart#905845, demandPointInTimeEnd#905846, demandPointInTime#905847], false
(172) Join
Arguments: LeftOuter, ((plant#905840 <=> plant#905389) AND (product#905839 <=> product#905388))
(173) Filter
Arguments: (((size(demandTimeBuckets#905844, true) = 0) OR isnull(demandTimeBuckets#905844)) AND ((size(demandPointInTime#905847, true) = 0) OR isnull(demandPointInTime#905847)))
(174) Project
Arguments: [product#905388, plant#905389]
(175) Deduplicate
Arguments: [product#905388, plant#905389]
(176) LogicalRelation
Arguments: parquet, [systemId#906558, internalUUID#906559, plant#906560, product#906561, blockedForReplenishmentStartingFrom#906562, productionAspect#906563, salesPlant#906564, listing#906565, sourceOfSupplyCategory#906566], false
(177) Repartition
Arguments: 37, true
(178) Project
Arguments: [product#906561.internalRefUUID AS product#906567, plant#906560.internalRefUUID AS plant#906568, product#906561.id AS productId#906569, plant#906560.id AS plantId#906570]
(179) Join
Arguments: Inner, ((product#905388 = product#906567) AND (plant#905389 = plant#906568))
(180) Project
Arguments: [product#905388, plant#905389, productId#906569, plantId#906570]
(181) Project
Arguments: [productId#906569 AS product#906576, plantId#906570 AS plant#906577]
(182) Project
Arguments: [product#906576, plant#906577, array(map(objectType, Product, objectId, product#906576), map(objectType, Plant, objectId, plant#906577)) AS anchorObject#906878]
(183) Project
Arguments: [product#906576, plant#906577, anchorObject#906878, cast(array() as array<map<string,string>>) AS messageVariables#906879]
(184) Project
Arguments: [product#906576, plant#906577, anchorObject#906878, messageVariables#906879, array(map(objectType, ReplenishmentRunId, objectId, 10000000348)) AS triggerObject#906880]
(185) Project
Arguments: [product#906576, plant#906577, anchorObject#906878, messageVariables#906879, triggerObject#906880, NEW AS situationStatus#906881]
(186) Project
Arguments: [product#906576, plant#906577, anchorObject#906878, messageVariables#906879, triggerObject#906880, situationStatus#906881, UNKNOWN_DEMAND_FOR_PRODUCT_LOCATION AS situationType#906882]
(187) Project
Arguments: [product#906576, plant#906577, anchorObject#906878, messageVariables#906879, triggerObject#906880, situationStatus#906881, situationType#906882, AUTO_ALL_ProdLoc AS marketUnit#906883]
(188) Project
Arguments: [anchorObject#906878, messageVariables#906879, triggerObject#906880, situationStatus#906881, situationType#906882, marketUnit#906883]
(189) Project
Arguments: [to_json(struct(anchorObject, anchorObject#906878, messageVariables, messageVariables#906879, triggerObject, triggerObject#906880, situationStatus, situationStatus#906881, situationType, situationType#906882, marketUnit, marketUnit#906883), Some(UTC)) AS value#914951]
(190) Project
Arguments: [cast(value#914951 as string) AS value#914952]
(191) Project
Arguments: [value#914952, array(struct(key, X-Tenant-ID, value, cast(7233423560970044043 as binary)), struct(key, X-Message-ID, value, cast(961147fb-2991-4113-8c47-739fa2df5fe1 as binary)), struct(key, X-Event-Type, value, cast(SituationCreate as binary)), struct(key, X-BTP-Tenant-ID, value, cast(65802631-6462-4867-aef3-60d3858f828b as binary))) AS headers#914961]