== 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@7585ac3b, [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#13791972, plant#13791973, orderDateTime#13791974, planningStartDateTime#13791975], false
(4) RepartitionByExpression
Arguments: [product#13791972, plant#13791973], 37
(5) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974]
(6) LogicalRelation
Arguments: parquet, [systemId#13791999, internalUUID#13792000, plant#13792001, product#13792002, blockedForReplenishmentStartingFrom#13792003, productionAspect#13792004, salesPlant#13792005, listing#13792006, sourceOfSupplyCategory#13792007], false
(7) Repartition
Arguments: 37, true
(8) Project
Arguments: [systemId#13791999, internalUUID#13792000, plant#13792001, product#13792002, blockedForReplenishmentStartingFrom#13792003, productionAspect#13792004, salesPlant#13792005, listing#13792006, sourceOfSupplyCategory#13792007, struct(systemId, systemId#13791999, internalUUID, internalUUID#13792000, plant, plant#13792001, product, product#13792002, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#13792003, productionAspect, productionAspect#13792004, salesPlant, salesPlant#13792005, listing, listing#13792006, sourceOfSupplyCategory, sourceOfSupplyCategory#13792007) AS productPlant#13792009]
(9) Project
Arguments: [productPlant#13792009]
(10) Join
Arguments: LeftOuter, ((product#13791972 <=> productPlant#13792009.product.internalRefUUID) AND (plant#13791973 <=> productPlant#13792009.plant.internalRefUUID))
(11) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009]
(12) LogicalRelation
Arguments: parquet, [systemId#13792034, internalUUID#13792035, id#13792036, displayId#13792037, name#13792038, baseUnitOfMeasure#13792039, unitOfMeasures#13792040, unitOfMeasureConversions#13792041, productionAspect#13792042, salesAspect#13792043, procurementAspect#13792044, productGroup#13792045], false
(13) Repartition
Arguments: 37, true
(14) Join
Arguments: LeftOuter, (product#13791972 = internalUUID#13792035)
(15) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, systemId#13792034, internalUUID#13792035, id#13792036, displayId#13792037, name#13792038, baseUnitOfMeasure#13792039, unitOfMeasures#13792040, unitOfMeasureConversions#13792041, productionAspect#13792042, salesAspect#13792043, procurementAspect#13792044, productGroup#13792045, filter(unitOfMeasureConversions#13792041, lambdafunction((((lambda u#13792048.measurementUnit1.code = productPlant#13792009.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#13792048.measurementUnit1.internalRefUUID = productPlant#13792009.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#13792048.measurementUnit2.code = baseUnitOfMeasure#13792039.code) AND (lambda u#13792048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#13792039.internalRefUUID))), lambda u#13792048, false)) AS filteredUnitOfMeasureConversions#13792047]
(16) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792047.quantityNumerator), true, [quantityNumerator#13792055]
(17) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, systemId#13792034, internalUUID#13792035, id#13792036, displayId#13792037, name#13792038, baseUnitOfMeasure#13792039, unitOfMeasures#13792040, unitOfMeasureConversions#13792041, productionAspect#13792042, salesAspect#13792043, procurementAspect#13792044, productGroup#13792045, filteredUnitOfMeasureConversions#13792047, quantityNumerator#13792055]
(18) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792047.quantityDenominator), true, [quantityDenominator#13792058]
(19) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, systemId#13792034, internalUUID#13792035, id#13792036, displayId#13792037, name#13792038, baseUnitOfMeasure#13792039, unitOfMeasures#13792040, unitOfMeasureConversions#13792041, productionAspect#13792042, salesAspect#13792043, procurementAspect#13792044, productGroup#13792045, filteredUnitOfMeasureConversions#13792047, quantityNumerator#13792055, quantityDenominator#13792058]
(20) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, systemId#13792034, internalUUID#13792035, id#13792036, displayId#13792037, name#13792038, baseUnitOfMeasure#13792039, unitOfMeasures#13792040, unitOfMeasureConversions#13792041, productionAspect#13792042, salesAspect#13792043, procurementAspect#13792044, productGroup#13792045, filteredUnitOfMeasureConversions#13792047, quantityNumerator#13792055, quantityDenominator#13792058, (cast(quantityNumerator#13792055 as double) / cast(quantityDenominator#13792058 as double)) AS outboundUnit#13792059]
(21) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, systemId#13792034, internalUUID#13792035, id#13792036, displayId#13792037, name#13792038, baseUnitOfMeasure#13792039, unitOfMeasures#13792040, unitOfMeasureConversions#13792041, productionAspect#13792042, salesAspect#13792043, procurementAspect#13792044, productGroup#13792045, filteredUnitOfMeasureConversions#13792047, quantityNumerator#13792055, quantityDenominator#13792058, CASE WHEN (isnull(outboundUnit#13792059) OR (outboundUnit#13792059 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#13792059 END AS outboundUnit#13792060]
(22) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, outboundUnit#13792060]
(23) LogicalRelation
Arguments: parquet, [systemId#13792119, internalUUID#13792120, product#13792121, plant#13792122, calculationDateTime#13792123, stockQuantities#13792124], false
(24) Repartition
Arguments: 37, true
(25) LogicalRelation
Arguments: parquet, [marketUnit#13792061, description#13792062, articleHierarchy#13792063, defaultCurrency#13792064, responsibilities#13792065, replenishmentTypes#13792066, distributionCenters#13792067, assignedArticleHierarchyNodes#13792068, minOrderQtySetting#13792069, listingCheck#13792070, odsSelection#13792071, demandProfiles#13792072, constraintProfiles#13792073, optimizationProfiles#13792074, orderGroupSplitProfiles#13792075, supplierMinimumProfiles#13792076, multipleRestrictionProfiles#13792077, preferredUomSource#13792078, handlingOfUnfulfilledDemands#13792079, negligibleQuantitiesThreshold#13792080, eventtype#13792081, minOrderQtySettingInternal#13792082], false
(26) Repartition
Arguments: 37, true
(27) Filter
Arguments: (marketUnit#13792061 <=> AUTO_ALL_ProdLoc)
(28) Project
Arguments: [marketUnit#13792061, description#13792062, articleHierarchy#13792063, defaultCurrency#13792064, responsibilities#13792065, replenishmentTypes#13792066, distributionCenters#13792067, assignedArticleHierarchyNodes#13792068, minOrderQtySetting#13792069, listingCheck#13792070, odsSelection#13792071, demandProfiles#13792072, constraintProfiles#13792073, optimizationProfiles#13792074, orderGroupSplitProfiles#13792075, supplierMinimumProfiles#13792076, multipleRestrictionProfiles#13792077, preferredUomSource#13792078, handlingOfUnfulfilledDemands#13792079, negligibleQuantitiesThreshold#13792080, eventtype#13792081, minOrderQtySettingInternal#13792082]
(29) Project
Arguments: [distributionCenters#13792067]
(30) Generate
Arguments: explode(distributionCenters#13792067), false, [distributionCenters#13792085]
(31) Project
Arguments: [distributionCenters#13792085]
(32) Generate
Arguments: explode(distributionCenters#13792085.storageLocations), false, [storageLocations#13792092]
(33) Project
Arguments: [distributionCenters#13792085.id AS plantId#13792086, distributionCenters#13792085.internalRefUUID AS plantUuid#13792087, storageLocations#13792092]
(34) Project
Arguments: [plantId#13792086, plantUuid#13792087, storageLocations#13792092.id AS storageLocId#13792093, storageLocations#13792092.internalRefUUID AS storageLocUuid#13792094]
(35) LogicalRelation
Arguments: parquet, [product#13792337, plant#13792338, orderDateTime#13792339, planningStartDateTime#13792340], false
(36) RepartitionByExpression
Arguments: [product#13792337, plant#13792338], 37
(37) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339]
(38) LogicalRelation
Arguments: parquet, [systemId#13792341, internalUUID#13792342, plant#13792343, product#13792344, blockedForReplenishmentStartingFrom#13792345, productionAspect#13792346, salesPlant#13792347, listing#13792348, sourceOfSupplyCategory#13792349], false
(39) Repartition
Arguments: 37, true
(40) Project
Arguments: [systemId#13792341, internalUUID#13792342, plant#13792343, product#13792344, blockedForReplenishmentStartingFrom#13792345, productionAspect#13792346, salesPlant#13792347, listing#13792348, sourceOfSupplyCategory#13792349, struct(systemId, systemId#13792341, internalUUID, internalUUID#13792342, plant, plant#13792343, product, product#13792344, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#13792345, productionAspect, productionAspect#13792346, salesPlant, salesPlant#13792347, listing, listing#13792348, sourceOfSupplyCategory, sourceOfSupplyCategory#13792349) AS productPlant#13792350]
(41) Project
Arguments: [productPlant#13792350]
(42) Join
Arguments: LeftOuter, ((product#13792337 <=> productPlant#13792350.product.internalRefUUID) AND (plant#13792338 <=> productPlant#13792350.plant.internalRefUUID))
(43) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339, productPlant#13792350]
(44) LogicalRelation
Arguments: parquet, [systemId#13792351, internalUUID#13792352, id#13792353, displayId#13792354, name#13792355, baseUnitOfMeasure#13792356, unitOfMeasures#13792357, unitOfMeasureConversions#13792358, productionAspect#13792359, salesAspect#13792360, procurementAspect#13792361, productGroup#13792362], false
(45) Repartition
Arguments: 37, true
(46) Join
Arguments: LeftOuter, (product#13792337 = internalUUID#13792352)
(47) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339, productPlant#13792350, systemId#13792351, internalUUID#13792352, id#13792353, displayId#13792354, name#13792355, baseUnitOfMeasure#13792356, unitOfMeasures#13792357, unitOfMeasureConversions#13792358, productionAspect#13792359, salesAspect#13792360, procurementAspect#13792361, productGroup#13792362, filter(unitOfMeasureConversions#13792358, lambdafunction((((lambda u#13792048.measurementUnit1.code = productPlant#13792350.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#13792048.measurementUnit1.internalRefUUID = productPlant#13792350.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#13792048.measurementUnit2.code = baseUnitOfMeasure#13792356.code) AND (lambda u#13792048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#13792356.internalRefUUID))), lambda u#13792048, false)) AS filteredUnitOfMeasureConversions#13792363]
(48) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792363.quantityNumerator), true, [quantityNumerator#13792364]
(49) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339, productPlant#13792350, systemId#13792351, internalUUID#13792352, id#13792353, displayId#13792354, name#13792355, baseUnitOfMeasure#13792356, unitOfMeasures#13792357, unitOfMeasureConversions#13792358, productionAspect#13792359, salesAspect#13792360, procurementAspect#13792361, productGroup#13792362, filteredUnitOfMeasureConversions#13792363, quantityNumerator#13792364]
(50) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792363.quantityDenominator), true, [quantityDenominator#13792365]
(51) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339, productPlant#13792350, systemId#13792351, internalUUID#13792352, id#13792353, displayId#13792354, name#13792355, baseUnitOfMeasure#13792356, unitOfMeasures#13792357, unitOfMeasureConversions#13792358, productionAspect#13792359, salesAspect#13792360, procurementAspect#13792361, productGroup#13792362, filteredUnitOfMeasureConversions#13792363, quantityNumerator#13792364, quantityDenominator#13792365]
(52) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339, productPlant#13792350, systemId#13792351, internalUUID#13792352, id#13792353, displayId#13792354, name#13792355, baseUnitOfMeasure#13792356, unitOfMeasures#13792357, unitOfMeasureConversions#13792358, productionAspect#13792359, salesAspect#13792360, procurementAspect#13792361, productGroup#13792362, filteredUnitOfMeasureConversions#13792363, quantityNumerator#13792364, quantityDenominator#13792365, (cast(quantityNumerator#13792364 as double) / cast(quantityDenominator#13792365 as double)) AS outboundUnit#13792366]
(53) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339, productPlant#13792350, systemId#13792351, internalUUID#13792352, id#13792353, displayId#13792354, name#13792355, baseUnitOfMeasure#13792356, unitOfMeasures#13792357, unitOfMeasureConversions#13792358, productionAspect#13792359, salesAspect#13792360, procurementAspect#13792361, productGroup#13792362, filteredUnitOfMeasureConversions#13792363, quantityNumerator#13792364, quantityDenominator#13792365, CASE WHEN (isnull(outboundUnit#13792366) OR (outboundUnit#13792366 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#13792366 END AS outboundUnit#13792367]
(54) Project
Arguments: [product#13792337, plant#13792338, orderDateTime#13792339, productPlant#13792350, outboundUnit#13792367]
(55) Project
Arguments: [plant#13792338]
(56) Deduplicate
Arguments: [plant#13792338]
(57) Join
Arguments: Inner, (plantUuid#13792087 = plant#13792338)
(58) Project
Arguments: [plantId#13792086, plantUuid#13792087, storageLocId#13792093, storageLocUuid#13792094]
(59) Join
Arguments: Inner, (plant#13792122.internalRefUUID <=> plantUuid#13792087)
(60) Generate
Arguments: explode(filter(stockQuantities#13792124, lambdafunction(((lambda x#13792128.storageLocation.internalRefUuid = storageLocUuid#13792094) AND (lambda x#13792128.storageLocation.Id = storageLocId#13792093)), lambda x#13792128, false))), false, [stockQuantity#13792129]
(61) Project
Arguments: [systemId#13792119, internalUUID#13792120, product#13792121, plant#13792122, calculationDateTime#13792123, stockQuantities#13792124, plantId#13792086, plantUuid#13792087, storageLocId#13792093, storageLocUuid#13792094, stockQuantity#13792129]
(62) Aggregate
Arguments: [plantUuid#13792087, internalUUID#13792120, plant#13792122, product#13792121, systemId#13792119], [plantUuid#13792087, internalUUID#13792120, plant#13792122, product#13792121, systemId#13792119, first(calculationDateTime#13792123, false) AS calculationDateTime#13792130, collect_list(stockQuantity#13792129, 0, 0) AS stockQuantities#13792131]
(63) Project
Arguments: [systemId#13792119, internalUUID#13792120, product#13792121, plant#13792122, calculationDateTime#13792130, stockQuantities#13792131]
(64) Generate
Arguments: explode(stockQuantities#13792131), false, [stockQuantity#13792146]
(65) Project
Arguments: [systemId#13792119, internalUUID#13792120, product#13792121, plant#13792122, calculationDateTime#13792130, stockQuantities#13792131, stockQuantity#13792146]
(66) Project
Arguments: [plant#13792122.id AS plant#13792147, plant#13792122.internalRefUUID AS plantUuid#13792148, product#13792121.id AS product#13792149, product#13792121.internalRefUUID AS productUuid#13792150, calculationDateTime#13792130, stockQuantity#13792146.storagelocation.id AS storageLocId#13792151, stockQuantity#13792146.storagelocation.internalRefUUID AS storageLocUuid#13792152, stockQuantity#13792146.quantity.measure AS quantity#13792153, stockQuantity#13792146.specialStockIndicator.code AS specialStockIndicator#13792154, stockQuantity#13792146.stockType.code AS stockType#13792155]
(67) Filter
Arguments: ((specialStockIndicator#13792154 = ) AND (stockType#13792155 = 01))
(68) LogicalRelation
Arguments: parquet, [product#13792165, plant#13792166, orderDateTime#13792167, planningStartDateTime#13792168], false
(69) RepartitionByExpression
Arguments: [product#13792165, plant#13792166], 37
(70) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167]
(71) LogicalRelation
Arguments: parquet, [systemId#13792169, internalUUID#13792170, plant#13792171, product#13792172, blockedForReplenishmentStartingFrom#13792173, productionAspect#13792174, salesPlant#13792175, listing#13792176, sourceOfSupplyCategory#13792177], false
(72) Repartition
Arguments: 37, true
(73) Project
Arguments: [systemId#13792169, internalUUID#13792170, plant#13792171, product#13792172, blockedForReplenishmentStartingFrom#13792173, productionAspect#13792174, salesPlant#13792175, listing#13792176, sourceOfSupplyCategory#13792177, struct(systemId, systemId#13792169, internalUUID, internalUUID#13792170, plant, plant#13792171, product, product#13792172, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#13792173, productionAspect, productionAspect#13792174, salesPlant, salesPlant#13792175, listing, listing#13792176, sourceOfSupplyCategory, sourceOfSupplyCategory#13792177) AS productPlant#13792178]
(74) Project
Arguments: [productPlant#13792178]
(75) Join
Arguments: LeftOuter, ((product#13792165 <=> productPlant#13792178.product.internalRefUUID) AND (plant#13792166 <=> productPlant#13792178.plant.internalRefUUID))
(76) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167, productPlant#13792178]
(77) LogicalRelation
Arguments: parquet, [systemId#13792179, internalUUID#13792180, id#13792181, displayId#13792182, name#13792183, baseUnitOfMeasure#13792184, unitOfMeasures#13792185, unitOfMeasureConversions#13792186, productionAspect#13792187, salesAspect#13792188, procurementAspect#13792189, productGroup#13792190], false
(78) Repartition
Arguments: 37, true
(79) Join
Arguments: LeftOuter, (product#13792165 = internalUUID#13792180)
(80) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167, productPlant#13792178, systemId#13792179, internalUUID#13792180, id#13792181, displayId#13792182, name#13792183, baseUnitOfMeasure#13792184, unitOfMeasures#13792185, unitOfMeasureConversions#13792186, productionAspect#13792187, salesAspect#13792188, procurementAspect#13792189, productGroup#13792190, filter(unitOfMeasureConversions#13792186, lambdafunction((((lambda u#13792048.measurementUnit1.code = productPlant#13792178.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#13792048.measurementUnit1.internalRefUUID = productPlant#13792178.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#13792048.measurementUnit2.code = baseUnitOfMeasure#13792184.code) AND (lambda u#13792048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#13792184.internalRefUUID))), lambda u#13792048, false)) AS filteredUnitOfMeasureConversions#13792191]
(81) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792191.quantityNumerator), true, [quantityNumerator#13792192]
(82) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167, productPlant#13792178, systemId#13792179, internalUUID#13792180, id#13792181, displayId#13792182, name#13792183, baseUnitOfMeasure#13792184, unitOfMeasures#13792185, unitOfMeasureConversions#13792186, productionAspect#13792187, salesAspect#13792188, procurementAspect#13792189, productGroup#13792190, filteredUnitOfMeasureConversions#13792191, quantityNumerator#13792192]
(83) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792191.quantityDenominator), true, [quantityDenominator#13792193]
(84) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167, productPlant#13792178, systemId#13792179, internalUUID#13792180, id#13792181, displayId#13792182, name#13792183, baseUnitOfMeasure#13792184, unitOfMeasures#13792185, unitOfMeasureConversions#13792186, productionAspect#13792187, salesAspect#13792188, procurementAspect#13792189, productGroup#13792190, filteredUnitOfMeasureConversions#13792191, quantityNumerator#13792192, quantityDenominator#13792193]
(85) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167, productPlant#13792178, systemId#13792179, internalUUID#13792180, id#13792181, displayId#13792182, name#13792183, baseUnitOfMeasure#13792184, unitOfMeasures#13792185, unitOfMeasureConversions#13792186, productionAspect#13792187, salesAspect#13792188, procurementAspect#13792189, productGroup#13792190, filteredUnitOfMeasureConversions#13792191, quantityNumerator#13792192, quantityDenominator#13792193, (cast(quantityNumerator#13792192 as double) / cast(quantityDenominator#13792193 as double)) AS outboundUnit#13792194]
(86) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167, productPlant#13792178, systemId#13792179, internalUUID#13792180, id#13792181, displayId#13792182, name#13792183, baseUnitOfMeasure#13792184, unitOfMeasures#13792185, unitOfMeasureConversions#13792186, productionAspect#13792187, salesAspect#13792188, procurementAspect#13792189, productGroup#13792190, filteredUnitOfMeasureConversions#13792191, quantityNumerator#13792192, quantityDenominator#13792193, CASE WHEN (isnull(outboundUnit#13792194) OR (outboundUnit#13792194 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#13792194 END AS outboundUnit#13792195]
(87) Project
Arguments: [product#13792165, plant#13792166, orderDateTime#13792167, productPlant#13792178, outboundUnit#13792195]
(88) Join
Arguments: Inner, ((plantUuid#13792148 = plant#13792166) AND (productUuid#13792150 = product#13792165))
(89) Filter
Arguments: (calculationDateTime#13792130 <= orderDateTime#13792167)
(90) Project
Arguments: [plantUuid#13792148 AS plant#13792199, productUuid#13792150 AS product#13792200, storageLocId#13792151, calculationDateTime#13792130, quantity#13792153]
(91) LogicalRelation
Arguments: parquet, [systemId#13792208, internalUUID#13792209, product#13792210, plant#13792211, calculationDateTime#13792212, stockQuantities#13792213], false
(92) Repartition
Arguments: 37, true
(93) LogicalRelation
Arguments: parquet, [marketUnit#13792214, description#13792215, articleHierarchy#13792216, defaultCurrency#13792217, responsibilities#13792218, replenishmentTypes#13792219, distributionCenters#13792220, assignedArticleHierarchyNodes#13792221, minOrderQtySetting#13792222, listingCheck#13792223, odsSelection#13792224, demandProfiles#13792225, constraintProfiles#13792226, optimizationProfiles#13792227, orderGroupSplitProfiles#13792228, supplierMinimumProfiles#13792229, multipleRestrictionProfiles#13792230, preferredUomSource#13792231, handlingOfUnfulfilledDemands#13792232, negligibleQuantitiesThreshold#13792233, eventtype#13792234, minOrderQtySettingInternal#13792235], false
(94) Repartition
Arguments: 37, true
(95) Filter
Arguments: (marketUnit#13792214 <=> AUTO_ALL_ProdLoc)
(96) Project
Arguments: [marketUnit#13792214, description#13792215, articleHierarchy#13792216, defaultCurrency#13792217, responsibilities#13792218, replenishmentTypes#13792219, distributionCenters#13792220, assignedArticleHierarchyNodes#13792221, minOrderQtySetting#13792222, listingCheck#13792223, odsSelection#13792224, demandProfiles#13792225, constraintProfiles#13792226, optimizationProfiles#13792227, orderGroupSplitProfiles#13792228, supplierMinimumProfiles#13792229, multipleRestrictionProfiles#13792230, preferredUomSource#13792231, handlingOfUnfulfilledDemands#13792232, negligibleQuantitiesThreshold#13792233, eventtype#13792234, minOrderQtySettingInternal#13792235]
(97) Project
Arguments: [distributionCenters#13792220]
(98) Generate
Arguments: explode(distributionCenters#13792220), false, [distributionCenters#13792236]
(99) Project
Arguments: [distributionCenters#13792236]
(100) Generate
Arguments: explode(distributionCenters#13792236.storageLocations), false, [storageLocations#13792237]
(101) Project
Arguments: [distributionCenters#13792236.id AS plantId#13792238, distributionCenters#13792236.internalRefUUID AS plantUuid#13792239, storageLocations#13792237]
(102) Project
Arguments: [plantId#13792238, plantUuid#13792239, storageLocations#13792237.id AS storageLocId#13792240, storageLocations#13792237.internalRefUUID AS storageLocUuid#13792241]
(103) LogicalRelation
Arguments: parquet, [product#13792242, plant#13792243, orderDateTime#13792244, planningStartDateTime#13792245], false
(104) RepartitionByExpression
Arguments: [product#13792242, plant#13792243], 37
(105) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244]
(106) LogicalRelation
Arguments: parquet, [systemId#13792246, internalUUID#13792247, plant#13792248, product#13792249, blockedForReplenishmentStartingFrom#13792250, productionAspect#13792251, salesPlant#13792252, listing#13792253, sourceOfSupplyCategory#13792254], false
(107) Repartition
Arguments: 37, true
(108) Project
Arguments: [systemId#13792246, internalUUID#13792247, plant#13792248, product#13792249, blockedForReplenishmentStartingFrom#13792250, productionAspect#13792251, salesPlant#13792252, listing#13792253, sourceOfSupplyCategory#13792254, struct(systemId, systemId#13792246, internalUUID, internalUUID#13792247, plant, plant#13792248, product, product#13792249, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#13792250, productionAspect, productionAspect#13792251, salesPlant, salesPlant#13792252, listing, listing#13792253, sourceOfSupplyCategory, sourceOfSupplyCategory#13792254) AS productPlant#13792255]
(109) Project
Arguments: [productPlant#13792255]
(110) Join
Arguments: LeftOuter, ((product#13792242 <=> productPlant#13792255.product.internalRefUUID) AND (plant#13792243 <=> productPlant#13792255.plant.internalRefUUID))
(111) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244, productPlant#13792255]
(112) LogicalRelation
Arguments: parquet, [systemId#13792256, internalUUID#13792257, id#13792258, displayId#13792259, name#13792260, baseUnitOfMeasure#13792261, unitOfMeasures#13792262, unitOfMeasureConversions#13792263, productionAspect#13792264, salesAspect#13792265, procurementAspect#13792266, productGroup#13792267], false
(113) Repartition
Arguments: 37, true
(114) Join
Arguments: LeftOuter, (product#13792242 = internalUUID#13792257)
(115) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244, productPlant#13792255, systemId#13792256, internalUUID#13792257, id#13792258, displayId#13792259, name#13792260, baseUnitOfMeasure#13792261, unitOfMeasures#13792262, unitOfMeasureConversions#13792263, productionAspect#13792264, salesAspect#13792265, procurementAspect#13792266, productGroup#13792267, filter(unitOfMeasureConversions#13792263, lambdafunction((((lambda u#13792048.measurementUnit1.code = productPlant#13792255.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#13792048.measurementUnit1.internalRefUUID = productPlant#13792255.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#13792048.measurementUnit2.code = baseUnitOfMeasure#13792261.code) AND (lambda u#13792048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#13792261.internalRefUUID))), lambda u#13792048, false)) AS filteredUnitOfMeasureConversions#13792268]
(116) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792268.quantityNumerator), true, [quantityNumerator#13792269]
(117) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244, productPlant#13792255, systemId#13792256, internalUUID#13792257, id#13792258, displayId#13792259, name#13792260, baseUnitOfMeasure#13792261, unitOfMeasures#13792262, unitOfMeasureConversions#13792263, productionAspect#13792264, salesAspect#13792265, procurementAspect#13792266, productGroup#13792267, filteredUnitOfMeasureConversions#13792268, quantityNumerator#13792269]
(118) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792268.quantityDenominator), true, [quantityDenominator#13792270]
(119) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244, productPlant#13792255, systemId#13792256, internalUUID#13792257, id#13792258, displayId#13792259, name#13792260, baseUnitOfMeasure#13792261, unitOfMeasures#13792262, unitOfMeasureConversions#13792263, productionAspect#13792264, salesAspect#13792265, procurementAspect#13792266, productGroup#13792267, filteredUnitOfMeasureConversions#13792268, quantityNumerator#13792269, quantityDenominator#13792270]
(120) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244, productPlant#13792255, systemId#13792256, internalUUID#13792257, id#13792258, displayId#13792259, name#13792260, baseUnitOfMeasure#13792261, unitOfMeasures#13792262, unitOfMeasureConversions#13792263, productionAspect#13792264, salesAspect#13792265, procurementAspect#13792266, productGroup#13792267, filteredUnitOfMeasureConversions#13792268, quantityNumerator#13792269, quantityDenominator#13792270, (cast(quantityNumerator#13792269 as double) / cast(quantityDenominator#13792270 as double)) AS outboundUnit#13792271]
(121) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244, productPlant#13792255, systemId#13792256, internalUUID#13792257, id#13792258, displayId#13792259, name#13792260, baseUnitOfMeasure#13792261, unitOfMeasures#13792262, unitOfMeasureConversions#13792263, productionAspect#13792264, salesAspect#13792265, procurementAspect#13792266, productGroup#13792267, filteredUnitOfMeasureConversions#13792268, quantityNumerator#13792269, quantityDenominator#13792270, CASE WHEN (isnull(outboundUnit#13792271) OR (outboundUnit#13792271 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#13792271 END AS outboundUnit#13792272]
(122) Project
Arguments: [product#13792242, plant#13792243, orderDateTime#13792244, productPlant#13792255, outboundUnit#13792272]
(123) Project
Arguments: [plant#13792243]
(124) Deduplicate
Arguments: [plant#13792243]
(125) Join
Arguments: Inner, (plantUuid#13792239 = plant#13792243)
(126) Project
Arguments: [plantId#13792238, plantUuid#13792239, storageLocId#13792240, storageLocUuid#13792241]
(127) Join
Arguments: Inner, (plant#13792211.internalRefUUID <=> plantUuid#13792239)
(128) Generate
Arguments: explode(filter(stockQuantities#13792213, lambdafunction(((lambda x#13792128.storageLocation.internalRefUuid = storageLocUuid#13792241) AND (lambda x#13792128.storageLocation.Id = storageLocId#13792240)), lambda x#13792128, false))), false, [stockQuantity#13792273]
(129) Project
Arguments: [systemId#13792208, internalUUID#13792209, product#13792210, plant#13792211, calculationDateTime#13792212, stockQuantities#13792213, plantId#13792238, plantUuid#13792239, storageLocId#13792240, storageLocUuid#13792241, stockQuantity#13792273]
(130) Aggregate
Arguments: [plantUuid#13792239, internalUUID#13792209, plant#13792211, product#13792210, systemId#13792208], [plantUuid#13792239, internalUUID#13792209, plant#13792211, product#13792210, systemId#13792208, first(calculationDateTime#13792212, false) AS calculationDateTime#13792274, collect_list(stockQuantity#13792273, 0, 0) AS stockQuantities#13792275]
(131) Project
Arguments: [systemId#13792208, internalUUID#13792209, product#13792210, plant#13792211, calculationDateTime#13792274, stockQuantities#13792275]
(132) Generate
Arguments: explode(stockQuantities#13792275), false, [stockQuantity#13792276]
(133) Project
Arguments: [systemId#13792208, internalUUID#13792209, product#13792210, plant#13792211, calculationDateTime#13792274, stockQuantities#13792275, stockQuantity#13792276]
(134) Project
Arguments: [plant#13792211.id AS plant#13792277, plant#13792211.internalRefUUID AS plantUuid#13792278, product#13792210.id AS product#13792279, product#13792210.internalRefUUID AS productUuid#13792280, calculationDateTime#13792274, stockQuantity#13792276.storagelocation.id AS storageLocId#13792281, stockQuantity#13792276.storagelocation.internalRefUUID AS storageLocUuid#13792282, stockQuantity#13792276.quantity.measure AS quantity#13792283, stockQuantity#13792276.specialStockIndicator.code AS specialStockIndicator#13792284, stockQuantity#13792276.stockType.code AS stockType#13792285]
(135) Filter
Arguments: ((specialStockIndicator#13792284 = ) AND (stockType#13792285 = 01))
(136) LogicalRelation
Arguments: parquet, [product#13792286, plant#13792287, orderDateTime#13792288, planningStartDateTime#13792289], false
(137) RepartitionByExpression
Arguments: [product#13792286, plant#13792287], 37
(138) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288]
(139) LogicalRelation
Arguments: parquet, [systemId#13792290, internalUUID#13792291, plant#13792292, product#13792293, blockedForReplenishmentStartingFrom#13792294, productionAspect#13792295, salesPlant#13792296, listing#13792297, sourceOfSupplyCategory#13792298], false
(140) Repartition
Arguments: 37, true
(141) Project
Arguments: [systemId#13792290, internalUUID#13792291, plant#13792292, product#13792293, blockedForReplenishmentStartingFrom#13792294, productionAspect#13792295, salesPlant#13792296, listing#13792297, sourceOfSupplyCategory#13792298, struct(systemId, systemId#13792290, internalUUID, internalUUID#13792291, plant, plant#13792292, product, product#13792293, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#13792294, productionAspect, productionAspect#13792295, salesPlant, salesPlant#13792296, listing, listing#13792297, sourceOfSupplyCategory, sourceOfSupplyCategory#13792298) AS productPlant#13792299]
(142) Project
Arguments: [productPlant#13792299]
(143) Join
Arguments: LeftOuter, ((product#13792286 <=> productPlant#13792299.product.internalRefUUID) AND (plant#13792287 <=> productPlant#13792299.plant.internalRefUUID))
(144) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288, productPlant#13792299]
(145) LogicalRelation
Arguments: parquet, [systemId#13792300, internalUUID#13792301, id#13792302, displayId#13792303, name#13792304, baseUnitOfMeasure#13792305, unitOfMeasures#13792306, unitOfMeasureConversions#13792307, productionAspect#13792308, salesAspect#13792309, procurementAspect#13792310, productGroup#13792311], false
(146) Repartition
Arguments: 37, true
(147) Join
Arguments: LeftOuter, (product#13792286 = internalUUID#13792301)
(148) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288, productPlant#13792299, systemId#13792300, internalUUID#13792301, id#13792302, displayId#13792303, name#13792304, baseUnitOfMeasure#13792305, unitOfMeasures#13792306, unitOfMeasureConversions#13792307, productionAspect#13792308, salesAspect#13792309, procurementAspect#13792310, productGroup#13792311, filter(unitOfMeasureConversions#13792307, lambdafunction((((lambda u#13792048.measurementUnit1.code = productPlant#13792299.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#13792048.measurementUnit1.internalRefUUID = productPlant#13792299.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#13792048.measurementUnit2.code = baseUnitOfMeasure#13792305.code) AND (lambda u#13792048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#13792305.internalRefUUID))), lambda u#13792048, false)) AS filteredUnitOfMeasureConversions#13792312]
(149) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792312.quantityNumerator), true, [quantityNumerator#13792313]
(150) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288, productPlant#13792299, systemId#13792300, internalUUID#13792301, id#13792302, displayId#13792303, name#13792304, baseUnitOfMeasure#13792305, unitOfMeasures#13792306, unitOfMeasureConversions#13792307, productionAspect#13792308, salesAspect#13792309, procurementAspect#13792310, productGroup#13792311, filteredUnitOfMeasureConversions#13792312, quantityNumerator#13792313]
(151) Generate
Arguments: explode(filteredUnitOfMeasureConversions#13792312.quantityDenominator), true, [quantityDenominator#13792314]
(152) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288, productPlant#13792299, systemId#13792300, internalUUID#13792301, id#13792302, displayId#13792303, name#13792304, baseUnitOfMeasure#13792305, unitOfMeasures#13792306, unitOfMeasureConversions#13792307, productionAspect#13792308, salesAspect#13792309, procurementAspect#13792310, productGroup#13792311, filteredUnitOfMeasureConversions#13792312, quantityNumerator#13792313, quantityDenominator#13792314]
(153) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288, productPlant#13792299, systemId#13792300, internalUUID#13792301, id#13792302, displayId#13792303, name#13792304, baseUnitOfMeasure#13792305, unitOfMeasures#13792306, unitOfMeasureConversions#13792307, productionAspect#13792308, salesAspect#13792309, procurementAspect#13792310, productGroup#13792311, filteredUnitOfMeasureConversions#13792312, quantityNumerator#13792313, quantityDenominator#13792314, (cast(quantityNumerator#13792313 as double) / cast(quantityDenominator#13792314 as double)) AS outboundUnit#13792315]
(154) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288, productPlant#13792299, systemId#13792300, internalUUID#13792301, id#13792302, displayId#13792303, name#13792304, baseUnitOfMeasure#13792305, unitOfMeasures#13792306, unitOfMeasureConversions#13792307, productionAspect#13792308, salesAspect#13792309, procurementAspect#13792310, productGroup#13792311, filteredUnitOfMeasureConversions#13792312, quantityNumerator#13792313, quantityDenominator#13792314, CASE WHEN (isnull(outboundUnit#13792315) OR (outboundUnit#13792315 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#13792315 END AS outboundUnit#13792316]
(155) Project
Arguments: [product#13792286, plant#13792287, orderDateTime#13792288, productPlant#13792299, outboundUnit#13792316]
(156) Join
Arguments: Inner, ((plantUuid#13792278 = plant#13792287) AND (productUuid#13792280 = product#13792286))
(157) Filter
Arguments: (calculationDateTime#13792274 <= orderDateTime#13792288)
(158) Project
Arguments: [plantUuid#13792278 AS plant#13792317, productUuid#13792280 AS product#13792318, storageLocId#13792281, calculationDateTime#13792274, quantity#13792283]
(159) Aggregate
Arguments: [plant#13792317, product#13792318, storageLocId#13792281], [plant#13792317, product#13792318, storageLocId#13792281, max(calculationDateTime#13792274) AS max_calc_datetime#13792201]
(160) Join
Arguments: Inner, ((((plant#13792199 <=> plant#13792317) AND (product#13792200 <=> product#13792318)) AND (storageLocId#13792151 <=> storageLocId#13792281)) AND (calculationDateTime#13792130 <=> max_calc_datetime#13792201))
(161) Project
Arguments: [plant#13792199, product#13792200, storageLocId#13792151, calculationDateTime#13792130, quantity#13792153]
(162) Aggregate
Arguments: [product#13792200, plant#13792199], [product#13792200, plant#13792199, sum(quantity#13792153) AS quantitySum#13792327, min(calculationDateTime#13792130) AS minCalculationDateTime#13792328]
(163) Project
Arguments: [product#13792200, plant#13792199, quantitySum#13792327, minCalculationDateTime#13792328, round(quantitySum#13792327, 0) AS roundedQuantitySum#13792336]
(164) Join
Arguments: LeftOuter, ((plant#13791973 = plant#13792199) AND (product#13791972 = product#13792200))
(165) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, outboundUnit#13792060, roundedQuantitySum#13792336, minCalculationDateTime#13792328]
(166) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, outboundUnit#13792060, roundedQuantitySum#13792336, minCalculationDateTime#13792328, CASE WHEN isnotnull(minCalculationDateTime#13792328) THEN minCalculationDateTime#13792328 ELSE orderDateTime#13791974 END AS stockDatetime#13792371]
(167) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, outboundUnit#13792060, roundedQuantitySum#13792336, minCalculationDateTime#13792328, stockDatetime#13792371, CASE WHEN isnotnull(roundedQuantitySum#13792336) THEN array(roundedQuantitySum#13792336) ELSE array(0.0) END AS stockBatchQuantities#13792372]
(168) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, outboundUnit#13792060, roundedQuantitySum#13792336, minCalculationDateTime#13792328, stockDatetime#13792371, stockBatchQuantities#13792372, array(2199-01-01 00:00:00) AS stockBatchShelfLifeEndDatetimes#13792373]
(169) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, outboundUnit#13792060, roundedQuantitySum#13792336, stockDatetime#13792371, stockBatchQuantities#13792372, stockBatchShelfLifeEndDatetimes#13792373]
(170) Project
Arguments: [product#13791972, plant#13791973, orderDateTime#13791974, productPlant#13792009, outboundUnit#13792060, stockDatetime#13792371, stockBatchQuantities#13792372, stockBatchShelfLifeEndDatetimes#13792373]
(171) LogicalRelation
Arguments: parquet, [product#13792374, plant#13792375, demandChannel#13792376, demandStream#13792377, considerVariance#13792378, demandTimeBuckets#13792379, demandPointInTimeStart#13792380, demandPointInTimeEnd#13792381, demandPointInTime#13792382], false
(172) Join
Arguments: LeftOuter, ((plant#13792375 <=> plant#13791973) AND (product#13792374 <=> product#13791972))
(173) Filter
Arguments: (((size(demandTimeBuckets#13792379, true) = 0) OR isnull(demandTimeBuckets#13792379)) AND ((size(demandPointInTime#13792382, true) = 0) OR isnull(demandPointInTime#13792382)))
(174) Project
Arguments: [product#13791972, plant#13791973]
(175) Deduplicate
Arguments: [product#13791972, plant#13791973]
(176) LogicalRelation
Arguments: parquet, [systemId#13793093, internalUUID#13793094, plant#13793095, product#13793096, blockedForReplenishmentStartingFrom#13793097, productionAspect#13793098, salesPlant#13793099, listing#13793100, sourceOfSupplyCategory#13793101], false
(177) Repartition
Arguments: 37, true
(178) Project
Arguments: [product#13793096.internalRefUUID AS product#13793102, plant#13793095.internalRefUUID AS plant#13793103, product#13793096.id AS productId#13793104, plant#13793095.id AS plantId#13793105]
(179) Join
Arguments: Inner, ((product#13791972 = product#13793102) AND (plant#13791973 = plant#13793103))
(180) Project
Arguments: [product#13791972, plant#13791973, productId#13793104, plantId#13793105]
(181) Project
Arguments: [productId#13793104 AS product#13793111, plantId#13793105 AS plant#13793112]
(182) Project
Arguments: [product#13793111, plant#13793112, array(map(objectType, Product, objectId, product#13793111), map(objectType, Plant, objectId, plant#13793112)) AS anchorObject#13793413]
(183) Project
Arguments: [product#13793111, plant#13793112, anchorObject#13793413, cast(array() as array<map<string,string>>) AS messageVariables#13793414]
(184) Project
Arguments: [product#13793111, plant#13793112, anchorObject#13793413, messageVariables#13793414, array(map(objectType, ReplenishmentRunId, objectId, 10000000539)) AS triggerObject#13793415]
(185) Project
Arguments: [product#13793111, plant#13793112, anchorObject#13793413, messageVariables#13793414, triggerObject#13793415, NEW AS situationStatus#13793416]
(186) Project
Arguments: [product#13793111, plant#13793112, anchorObject#13793413, messageVariables#13793414, triggerObject#13793415, situationStatus#13793416, UNKNOWN_DEMAND_FOR_PRODUCT_LOCATION AS situationType#13793417]
(187) Project
Arguments: [product#13793111, plant#13793112, anchorObject#13793413, messageVariables#13793414, triggerObject#13793415, situationStatus#13793416, situationType#13793417, AUTO_ALL_ProdLoc AS marketUnit#13793418]
(188) Project
Arguments: [anchorObject#13793413, messageVariables#13793414, triggerObject#13793415, situationStatus#13793416, situationType#13793417, marketUnit#13793418]
(189) Project
Arguments: [to_json(struct(anchorObject, anchorObject#13793413, messageVariables, messageVariables#13793414, triggerObject, triggerObject#13793415, situationStatus, situationStatus#13793416, situationType, situationType#13793417, marketUnit, marketUnit#13793418), Some(UTC)) AS value#13801837]
(190) Project
Arguments: [cast(value#13801837 as string) AS value#13801838]
(191) Project
Arguments: [value#13801838, array(struct(key, X-Tenant-ID, value, cast(7233423560970044043 as binary)), struct(key, X-Message-ID, value, cast(f91320dc-8d51-410f-83bc-b10c1eaf6fa5 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#13801847]