== 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@6beb05a3, [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#1101131, plant#1101132, orderDateTime#1101133, planningStartDateTime#1101134], false
(4) RepartitionByExpression
Arguments: [product#1101131, plant#1101132], 37
(5) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133]
(6) LogicalRelation
Arguments: parquet, [systemId#1101158, internalUUID#1101159, plant#1101160, product#1101161, blockedForReplenishmentStartingFrom#1101162, productionAspect#1101163, salesPlant#1101164, listing#1101165, sourceOfSupplyCategory#1101166], false
(7) Repartition
Arguments: 37, true
(8) Project
Arguments: [systemId#1101158, internalUUID#1101159, plant#1101160, product#1101161, blockedForReplenishmentStartingFrom#1101162, productionAspect#1101163, salesPlant#1101164, listing#1101165, sourceOfSupplyCategory#1101166, struct(systemId, systemId#1101158, internalUUID, internalUUID#1101159, plant, plant#1101160, product, product#1101161, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1101162, productionAspect, productionAspect#1101163, salesPlant, salesPlant#1101164, listing, listing#1101165, sourceOfSupplyCategory, sourceOfSupplyCategory#1101166) AS productPlant#1101168]
(9) Project
Arguments: [productPlant#1101168]
(10) Join
Arguments: LeftOuter, ((product#1101131 <=> productPlant#1101168.product.internalRefUUID) AND (plant#1101132 <=> productPlant#1101168.plant.internalRefUUID))
(11) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168]
(12) LogicalRelation
Arguments: parquet, [systemId#1101193, internalUUID#1101194, id#1101195, displayId#1101196, name#1101197, baseUnitOfMeasure#1101198, unitOfMeasures#1101199, unitOfMeasureConversions#1101200, productionAspect#1101201, salesAspect#1101202, procurementAspect#1101203, productGroup#1101204], false
(13) Repartition
Arguments: 37, true
(14) Join
Arguments: LeftOuter, (product#1101131 = internalUUID#1101194)
(15) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, systemId#1101193, internalUUID#1101194, id#1101195, displayId#1101196, name#1101197, baseUnitOfMeasure#1101198, unitOfMeasures#1101199, unitOfMeasureConversions#1101200, productionAspect#1101201, salesAspect#1101202, procurementAspect#1101203, productGroup#1101204, filter(unitOfMeasureConversions#1101200, lambdafunction((((lambda u#1101207.measurementUnit1.code = productPlant#1101168.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1101207.measurementUnit1.internalRefUUID = productPlant#1101168.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1101207.measurementUnit2.code = baseUnitOfMeasure#1101198.code) AND (lambda u#1101207.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1101198.internalRefUUID))), lambda u#1101207, false)) AS filteredUnitOfMeasureConversions#1101206]
(16) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101206.quantityNumerator), true, [quantityNumerator#1101214]
(17) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, systemId#1101193, internalUUID#1101194, id#1101195, displayId#1101196, name#1101197, baseUnitOfMeasure#1101198, unitOfMeasures#1101199, unitOfMeasureConversions#1101200, productionAspect#1101201, salesAspect#1101202, procurementAspect#1101203, productGroup#1101204, filteredUnitOfMeasureConversions#1101206, quantityNumerator#1101214]
(18) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101206.quantityDenominator), true, [quantityDenominator#1101217]
(19) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, systemId#1101193, internalUUID#1101194, id#1101195, displayId#1101196, name#1101197, baseUnitOfMeasure#1101198, unitOfMeasures#1101199, unitOfMeasureConversions#1101200, productionAspect#1101201, salesAspect#1101202, procurementAspect#1101203, productGroup#1101204, filteredUnitOfMeasureConversions#1101206, quantityNumerator#1101214, quantityDenominator#1101217]
(20) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, systemId#1101193, internalUUID#1101194, id#1101195, displayId#1101196, name#1101197, baseUnitOfMeasure#1101198, unitOfMeasures#1101199, unitOfMeasureConversions#1101200, productionAspect#1101201, salesAspect#1101202, procurementAspect#1101203, productGroup#1101204, filteredUnitOfMeasureConversions#1101206, quantityNumerator#1101214, quantityDenominator#1101217, (cast(quantityNumerator#1101214 as double) / cast(quantityDenominator#1101217 as double)) AS outboundUnit#1101218]
(21) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, systemId#1101193, internalUUID#1101194, id#1101195, displayId#1101196, name#1101197, baseUnitOfMeasure#1101198, unitOfMeasures#1101199, unitOfMeasureConversions#1101200, productionAspect#1101201, salesAspect#1101202, procurementAspect#1101203, productGroup#1101204, filteredUnitOfMeasureConversions#1101206, quantityNumerator#1101214, quantityDenominator#1101217, CASE WHEN (isnull(outboundUnit#1101218) OR (outboundUnit#1101218 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1101218 END AS outboundUnit#1101219]
(22) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, outboundUnit#1101219]
(23) LogicalRelation
Arguments: parquet, [systemId#1101328, internalUUID#1101329, product#1101330, plant#1101331, calculationDateTime#1101332, stockQuantities#1101333], false
(24) Repartition
Arguments: 37, true
(25) LogicalRelation
Arguments: parquet, [marketUnit#1101271, description#1101272, articleHierarchy#1101273, defaultCurrency#1101274, responsibilities#1101275, replenishmentTypes#1101276, distributionCenters#1101277, assignedArticleHierarchyNodes#1101278, minOrderQtySetting#1101279, listingCheck#1101280, odsSelection#1101281, demandProfiles#1101282, constraintProfiles#1101283, optimizationProfiles#1101284, orderGroupSplitProfiles#1101285, supplierMinimumProfiles#1101286, multipleRestrictionProfiles#1101287, preferredUomSource#1101288, handlingOfUnfulfilledDemands#1101289, negligibleQuantitiesThreshold#1101290, eventtype#1101291], false
(26) Repartition
Arguments: 37, true
(27) Filter
Arguments: (marketUnit#1101271 <=> AUTO_ALL_ProdLoc)
(28) Project
Arguments: [marketUnit#1101271, description#1101272, articleHierarchy#1101273, defaultCurrency#1101274, responsibilities#1101275, replenishmentTypes#1101276, distributionCenters#1101277, assignedArticleHierarchyNodes#1101278, minOrderQtySetting#1101279, listingCheck#1101280, odsSelection#1101281, demandProfiles#1101282, constraintProfiles#1101283, optimizationProfiles#1101284, orderGroupSplitProfiles#1101285, supplierMinimumProfiles#1101286, multipleRestrictionProfiles#1101287, preferredUomSource#1101288, handlingOfUnfulfilledDemands#1101289, negligibleQuantitiesThreshold#1101290, eventtype#1101291]
(29) Project
Arguments: [distributionCenters#1101277]
(30) Generate
Arguments: explode(distributionCenters#1101277), false, [distributionCenters#1101294]
(31) Project
Arguments: [distributionCenters#1101294]
(32) Generate
Arguments: explode(distributionCenters#1101294.storageLocations), false, [storageLocations#1101301]
(33) Project
Arguments: [distributionCenters#1101294.id AS plantId#1101295, distributionCenters#1101294.internalRefUUID AS plantUuid#1101296, storageLocations#1101301]
(34) Project
Arguments: [plantId#1101295, plantUuid#1101296, storageLocations#1101301.id AS storageLocId#1101302, storageLocations#1101301.internalRefUUID AS storageLocUuid#1101303]
(35) LogicalRelation
Arguments: parquet, [product#1101545, plant#1101546, orderDateTime#1101547, planningStartDateTime#1101548], false
(36) RepartitionByExpression
Arguments: [product#1101545, plant#1101546], 37
(37) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547]
(38) LogicalRelation
Arguments: parquet, [systemId#1101549, internalUUID#1101550, plant#1101551, product#1101552, blockedForReplenishmentStartingFrom#1101553, productionAspect#1101554, salesPlant#1101555, listing#1101556, sourceOfSupplyCategory#1101557], false
(39) Repartition
Arguments: 37, true
(40) Project
Arguments: [systemId#1101549, internalUUID#1101550, plant#1101551, product#1101552, blockedForReplenishmentStartingFrom#1101553, productionAspect#1101554, salesPlant#1101555, listing#1101556, sourceOfSupplyCategory#1101557, struct(systemId, systemId#1101549, internalUUID, internalUUID#1101550, plant, plant#1101551, product, product#1101552, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1101553, productionAspect, productionAspect#1101554, salesPlant, salesPlant#1101555, listing, listing#1101556, sourceOfSupplyCategory, sourceOfSupplyCategory#1101557) AS productPlant#1101558]
(41) Project
Arguments: [productPlant#1101558]
(42) Join
Arguments: LeftOuter, ((product#1101545 <=> productPlant#1101558.product.internalRefUUID) AND (plant#1101546 <=> productPlant#1101558.plant.internalRefUUID))
(43) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547, productPlant#1101558]
(44) LogicalRelation
Arguments: parquet, [systemId#1101559, internalUUID#1101560, id#1101561, displayId#1101562, name#1101563, baseUnitOfMeasure#1101564, unitOfMeasures#1101565, unitOfMeasureConversions#1101566, productionAspect#1101567, salesAspect#1101568, procurementAspect#1101569, productGroup#1101570], false
(45) Repartition
Arguments: 37, true
(46) Join
Arguments: LeftOuter, (product#1101545 = internalUUID#1101560)
(47) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547, productPlant#1101558, systemId#1101559, internalUUID#1101560, id#1101561, displayId#1101562, name#1101563, baseUnitOfMeasure#1101564, unitOfMeasures#1101565, unitOfMeasureConversions#1101566, productionAspect#1101567, salesAspect#1101568, procurementAspect#1101569, productGroup#1101570, filter(unitOfMeasureConversions#1101566, lambdafunction((((lambda u#1101207.measurementUnit1.code = productPlant#1101558.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1101207.measurementUnit1.internalRefUUID = productPlant#1101558.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1101207.measurementUnit2.code = baseUnitOfMeasure#1101564.code) AND (lambda u#1101207.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1101564.internalRefUUID))), lambda u#1101207, false)) AS filteredUnitOfMeasureConversions#1101571]
(48) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101571.quantityNumerator), true, [quantityNumerator#1101572]
(49) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547, productPlant#1101558, systemId#1101559, internalUUID#1101560, id#1101561, displayId#1101562, name#1101563, baseUnitOfMeasure#1101564, unitOfMeasures#1101565, unitOfMeasureConversions#1101566, productionAspect#1101567, salesAspect#1101568, procurementAspect#1101569, productGroup#1101570, filteredUnitOfMeasureConversions#1101571, quantityNumerator#1101572]
(50) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101571.quantityDenominator), true, [quantityDenominator#1101573]
(51) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547, productPlant#1101558, systemId#1101559, internalUUID#1101560, id#1101561, displayId#1101562, name#1101563, baseUnitOfMeasure#1101564, unitOfMeasures#1101565, unitOfMeasureConversions#1101566, productionAspect#1101567, salesAspect#1101568, procurementAspect#1101569, productGroup#1101570, filteredUnitOfMeasureConversions#1101571, quantityNumerator#1101572, quantityDenominator#1101573]
(52) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547, productPlant#1101558, systemId#1101559, internalUUID#1101560, id#1101561, displayId#1101562, name#1101563, baseUnitOfMeasure#1101564, unitOfMeasures#1101565, unitOfMeasureConversions#1101566, productionAspect#1101567, salesAspect#1101568, procurementAspect#1101569, productGroup#1101570, filteredUnitOfMeasureConversions#1101571, quantityNumerator#1101572, quantityDenominator#1101573, (cast(quantityNumerator#1101572 as double) / cast(quantityDenominator#1101573 as double)) AS outboundUnit#1101574]
(53) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547, productPlant#1101558, systemId#1101559, internalUUID#1101560, id#1101561, displayId#1101562, name#1101563, baseUnitOfMeasure#1101564, unitOfMeasures#1101565, unitOfMeasureConversions#1101566, productionAspect#1101567, salesAspect#1101568, procurementAspect#1101569, productGroup#1101570, filteredUnitOfMeasureConversions#1101571, quantityNumerator#1101572, quantityDenominator#1101573, CASE WHEN (isnull(outboundUnit#1101574) OR (outboundUnit#1101574 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1101574 END AS outboundUnit#1101575]
(54) Project
Arguments: [product#1101545, plant#1101546, orderDateTime#1101547, productPlant#1101558, outboundUnit#1101575]
(55) Project
Arguments: [plant#1101546]
(56) Deduplicate
Arguments: [plant#1101546]
(57) Join
Arguments: Inner, (plantUuid#1101296 = plant#1101546)
(58) Project
Arguments: [plantId#1101295, plantUuid#1101296, storageLocId#1101302, storageLocUuid#1101303]
(59) Join
Arguments: Inner, (plant#1101331.internalRefUUID <=> plantUuid#1101296)
(60) Generate
Arguments: explode(filter(stockQuantities#1101333, lambdafunction(((lambda x#1101337.storageLocation.internalRefUuid = storageLocUuid#1101303) AND (lambda x#1101337.storageLocation.Id = storageLocId#1101302)), lambda x#1101337, false))), false, [stockQuantity#1101338]
(61) Project
Arguments: [systemId#1101328, internalUUID#1101329, product#1101330, plant#1101331, calculationDateTime#1101332, stockQuantities#1101333, plantId#1101295, plantUuid#1101296, storageLocId#1101302, storageLocUuid#1101303, stockQuantity#1101338]
(62) Aggregate
Arguments: [plantUuid#1101296, internalUUID#1101329, plant#1101331, product#1101330, systemId#1101328], [plantUuid#1101296, internalUUID#1101329, plant#1101331, product#1101330, systemId#1101328, first(calculationDateTime#1101332, false) AS calculationDateTime#1101339, collect_list(stockQuantity#1101338, 0, 0) AS stockQuantities#1101340]
(63) Project
Arguments: [systemId#1101328, internalUUID#1101329, product#1101330, plant#1101331, calculationDateTime#1101339, stockQuantities#1101340]
(64) Generate
Arguments: explode(stockQuantities#1101340), false, [stockQuantity#1101355]
(65) Project
Arguments: [systemId#1101328, internalUUID#1101329, product#1101330, plant#1101331, calculationDateTime#1101339, stockQuantities#1101340, stockQuantity#1101355]
(66) Project
Arguments: [plant#1101331.id AS plant#1101356, plant#1101331.internalRefUUID AS plantUuid#1101357, product#1101330.id AS product#1101358, product#1101330.internalRefUUID AS productUuid#1101359, calculationDateTime#1101339, stockQuantity#1101355.storagelocation.id AS storageLocId#1101360, stockQuantity#1101355.storagelocation.internalRefUUID AS storageLocUuid#1101361, stockQuantity#1101355.quantity.measure AS quantity#1101362, stockQuantity#1101355.specialStockIndicator.code AS specialStockIndicator#1101363, stockQuantity#1101355.stockType.code AS stockType#1101364]
(67) Filter
Arguments: ((specialStockIndicator#1101363 = ) AND (stockType#1101364 = 01))
(68) LogicalRelation
Arguments: parquet, [product#1101374, plant#1101375, orderDateTime#1101376, planningStartDateTime#1101377], false
(69) RepartitionByExpression
Arguments: [product#1101374, plant#1101375], 37
(70) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376]
(71) LogicalRelation
Arguments: parquet, [systemId#1101378, internalUUID#1101379, plant#1101380, product#1101381, blockedForReplenishmentStartingFrom#1101382, productionAspect#1101383, salesPlant#1101384, listing#1101385, sourceOfSupplyCategory#1101386], false
(72) Repartition
Arguments: 37, true
(73) Project
Arguments: [systemId#1101378, internalUUID#1101379, plant#1101380, product#1101381, blockedForReplenishmentStartingFrom#1101382, productionAspect#1101383, salesPlant#1101384, listing#1101385, sourceOfSupplyCategory#1101386, struct(systemId, systemId#1101378, internalUUID, internalUUID#1101379, plant, plant#1101380, product, product#1101381, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1101382, productionAspect, productionAspect#1101383, salesPlant, salesPlant#1101384, listing, listing#1101385, sourceOfSupplyCategory, sourceOfSupplyCategory#1101386) AS productPlant#1101387]
(74) Project
Arguments: [productPlant#1101387]
(75) Join
Arguments: LeftOuter, ((product#1101374 <=> productPlant#1101387.product.internalRefUUID) AND (plant#1101375 <=> productPlant#1101387.plant.internalRefUUID))
(76) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376, productPlant#1101387]
(77) LogicalRelation
Arguments: parquet, [systemId#1101388, internalUUID#1101389, id#1101390, displayId#1101391, name#1101392, baseUnitOfMeasure#1101393, unitOfMeasures#1101394, unitOfMeasureConversions#1101395, productionAspect#1101396, salesAspect#1101397, procurementAspect#1101398, productGroup#1101399], false
(78) Repartition
Arguments: 37, true
(79) Join
Arguments: LeftOuter, (product#1101374 = internalUUID#1101389)
(80) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376, productPlant#1101387, systemId#1101388, internalUUID#1101389, id#1101390, displayId#1101391, name#1101392, baseUnitOfMeasure#1101393, unitOfMeasures#1101394, unitOfMeasureConversions#1101395, productionAspect#1101396, salesAspect#1101397, procurementAspect#1101398, productGroup#1101399, filter(unitOfMeasureConversions#1101395, lambdafunction((((lambda u#1101207.measurementUnit1.code = productPlant#1101387.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1101207.measurementUnit1.internalRefUUID = productPlant#1101387.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1101207.measurementUnit2.code = baseUnitOfMeasure#1101393.code) AND (lambda u#1101207.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1101393.internalRefUUID))), lambda u#1101207, false)) AS filteredUnitOfMeasureConversions#1101400]
(81) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101400.quantityNumerator), true, [quantityNumerator#1101401]
(82) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376, productPlant#1101387, systemId#1101388, internalUUID#1101389, id#1101390, displayId#1101391, name#1101392, baseUnitOfMeasure#1101393, unitOfMeasures#1101394, unitOfMeasureConversions#1101395, productionAspect#1101396, salesAspect#1101397, procurementAspect#1101398, productGroup#1101399, filteredUnitOfMeasureConversions#1101400, quantityNumerator#1101401]
(83) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101400.quantityDenominator), true, [quantityDenominator#1101402]
(84) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376, productPlant#1101387, systemId#1101388, internalUUID#1101389, id#1101390, displayId#1101391, name#1101392, baseUnitOfMeasure#1101393, unitOfMeasures#1101394, unitOfMeasureConversions#1101395, productionAspect#1101396, salesAspect#1101397, procurementAspect#1101398, productGroup#1101399, filteredUnitOfMeasureConversions#1101400, quantityNumerator#1101401, quantityDenominator#1101402]
(85) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376, productPlant#1101387, systemId#1101388, internalUUID#1101389, id#1101390, displayId#1101391, name#1101392, baseUnitOfMeasure#1101393, unitOfMeasures#1101394, unitOfMeasureConversions#1101395, productionAspect#1101396, salesAspect#1101397, procurementAspect#1101398, productGroup#1101399, filteredUnitOfMeasureConversions#1101400, quantityNumerator#1101401, quantityDenominator#1101402, (cast(quantityNumerator#1101401 as double) / cast(quantityDenominator#1101402 as double)) AS outboundUnit#1101403]
(86) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376, productPlant#1101387, systemId#1101388, internalUUID#1101389, id#1101390, displayId#1101391, name#1101392, baseUnitOfMeasure#1101393, unitOfMeasures#1101394, unitOfMeasureConversions#1101395, productionAspect#1101396, salesAspect#1101397, procurementAspect#1101398, productGroup#1101399, filteredUnitOfMeasureConversions#1101400, quantityNumerator#1101401, quantityDenominator#1101402, CASE WHEN (isnull(outboundUnit#1101403) OR (outboundUnit#1101403 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1101403 END AS outboundUnit#1101404]
(87) Project
Arguments: [product#1101374, plant#1101375, orderDateTime#1101376, productPlant#1101387, outboundUnit#1101404]
(88) Join
Arguments: Inner, ((plantUuid#1101357 = plant#1101375) AND (productUuid#1101359 = product#1101374))
(89) Filter
Arguments: (calculationDateTime#1101339 <= orderDateTime#1101376)
(90) Project
Arguments: [plantUuid#1101357 AS plant#1101408, productUuid#1101359 AS product#1101409, storageLocId#1101360, calculationDateTime#1101339, quantity#1101362]
(91) LogicalRelation
Arguments: parquet, [systemId#1101417, internalUUID#1101418, product#1101419, plant#1101420, calculationDateTime#1101421, stockQuantities#1101422], false
(92) Repartition
Arguments: 37, true
(93) LogicalRelation
Arguments: parquet, [marketUnit#1101423, description#1101424, articleHierarchy#1101425, defaultCurrency#1101426, responsibilities#1101427, replenishmentTypes#1101428, distributionCenters#1101429, assignedArticleHierarchyNodes#1101430, minOrderQtySetting#1101431, listingCheck#1101432, odsSelection#1101433, demandProfiles#1101434, constraintProfiles#1101435, optimizationProfiles#1101436, orderGroupSplitProfiles#1101437, supplierMinimumProfiles#1101438, multipleRestrictionProfiles#1101439, preferredUomSource#1101440, handlingOfUnfulfilledDemands#1101441, negligibleQuantitiesThreshold#1101442, eventtype#1101443], false
(94) Repartition
Arguments: 37, true
(95) Filter
Arguments: (marketUnit#1101423 <=> AUTO_ALL_ProdLoc)
(96) Project
Arguments: [marketUnit#1101423, description#1101424, articleHierarchy#1101425, defaultCurrency#1101426, responsibilities#1101427, replenishmentTypes#1101428, distributionCenters#1101429, assignedArticleHierarchyNodes#1101430, minOrderQtySetting#1101431, listingCheck#1101432, odsSelection#1101433, demandProfiles#1101434, constraintProfiles#1101435, optimizationProfiles#1101436, orderGroupSplitProfiles#1101437, supplierMinimumProfiles#1101438, multipleRestrictionProfiles#1101439, preferredUomSource#1101440, handlingOfUnfulfilledDemands#1101441, negligibleQuantitiesThreshold#1101442, eventtype#1101443]
(97) Project
Arguments: [distributionCenters#1101429]
(98) Generate
Arguments: explode(distributionCenters#1101429), false, [distributionCenters#1101444]
(99) Project
Arguments: [distributionCenters#1101444]
(100) Generate
Arguments: explode(distributionCenters#1101444.storageLocations), false, [storageLocations#1101445]
(101) Project
Arguments: [distributionCenters#1101444.id AS plantId#1101446, distributionCenters#1101444.internalRefUUID AS plantUuid#1101447, storageLocations#1101445]
(102) Project
Arguments: [plantId#1101446, plantUuid#1101447, storageLocations#1101445.id AS storageLocId#1101448, storageLocations#1101445.internalRefUUID AS storageLocUuid#1101449]
(103) LogicalRelation
Arguments: parquet, [product#1101450, plant#1101451, orderDateTime#1101452, planningStartDateTime#1101453], false
(104) RepartitionByExpression
Arguments: [product#1101450, plant#1101451], 37
(105) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452]
(106) LogicalRelation
Arguments: parquet, [systemId#1101454, internalUUID#1101455, plant#1101456, product#1101457, blockedForReplenishmentStartingFrom#1101458, productionAspect#1101459, salesPlant#1101460, listing#1101461, sourceOfSupplyCategory#1101462], false
(107) Repartition
Arguments: 37, true
(108) Project
Arguments: [systemId#1101454, internalUUID#1101455, plant#1101456, product#1101457, blockedForReplenishmentStartingFrom#1101458, productionAspect#1101459, salesPlant#1101460, listing#1101461, sourceOfSupplyCategory#1101462, struct(systemId, systemId#1101454, internalUUID, internalUUID#1101455, plant, plant#1101456, product, product#1101457, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1101458, productionAspect, productionAspect#1101459, salesPlant, salesPlant#1101460, listing, listing#1101461, sourceOfSupplyCategory, sourceOfSupplyCategory#1101462) AS productPlant#1101463]
(109) Project
Arguments: [productPlant#1101463]
(110) Join
Arguments: LeftOuter, ((product#1101450 <=> productPlant#1101463.product.internalRefUUID) AND (plant#1101451 <=> productPlant#1101463.plant.internalRefUUID))
(111) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452, productPlant#1101463]
(112) LogicalRelation
Arguments: parquet, [systemId#1101464, internalUUID#1101465, id#1101466, displayId#1101467, name#1101468, baseUnitOfMeasure#1101469, unitOfMeasures#1101470, unitOfMeasureConversions#1101471, productionAspect#1101472, salesAspect#1101473, procurementAspect#1101474, productGroup#1101475], false
(113) Repartition
Arguments: 37, true
(114) Join
Arguments: LeftOuter, (product#1101450 = internalUUID#1101465)
(115) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452, productPlant#1101463, systemId#1101464, internalUUID#1101465, id#1101466, displayId#1101467, name#1101468, baseUnitOfMeasure#1101469, unitOfMeasures#1101470, unitOfMeasureConversions#1101471, productionAspect#1101472, salesAspect#1101473, procurementAspect#1101474, productGroup#1101475, filter(unitOfMeasureConversions#1101471, lambdafunction((((lambda u#1101207.measurementUnit1.code = productPlant#1101463.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1101207.measurementUnit1.internalRefUUID = productPlant#1101463.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1101207.measurementUnit2.code = baseUnitOfMeasure#1101469.code) AND (lambda u#1101207.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1101469.internalRefUUID))), lambda u#1101207, false)) AS filteredUnitOfMeasureConversions#1101476]
(116) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101476.quantityNumerator), true, [quantityNumerator#1101477]
(117) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452, productPlant#1101463, systemId#1101464, internalUUID#1101465, id#1101466, displayId#1101467, name#1101468, baseUnitOfMeasure#1101469, unitOfMeasures#1101470, unitOfMeasureConversions#1101471, productionAspect#1101472, salesAspect#1101473, procurementAspect#1101474, productGroup#1101475, filteredUnitOfMeasureConversions#1101476, quantityNumerator#1101477]
(118) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101476.quantityDenominator), true, [quantityDenominator#1101478]
(119) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452, productPlant#1101463, systemId#1101464, internalUUID#1101465, id#1101466, displayId#1101467, name#1101468, baseUnitOfMeasure#1101469, unitOfMeasures#1101470, unitOfMeasureConversions#1101471, productionAspect#1101472, salesAspect#1101473, procurementAspect#1101474, productGroup#1101475, filteredUnitOfMeasureConversions#1101476, quantityNumerator#1101477, quantityDenominator#1101478]
(120) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452, productPlant#1101463, systemId#1101464, internalUUID#1101465, id#1101466, displayId#1101467, name#1101468, baseUnitOfMeasure#1101469, unitOfMeasures#1101470, unitOfMeasureConversions#1101471, productionAspect#1101472, salesAspect#1101473, procurementAspect#1101474, productGroup#1101475, filteredUnitOfMeasureConversions#1101476, quantityNumerator#1101477, quantityDenominator#1101478, (cast(quantityNumerator#1101477 as double) / cast(quantityDenominator#1101478 as double)) AS outboundUnit#1101479]
(121) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452, productPlant#1101463, systemId#1101464, internalUUID#1101465, id#1101466, displayId#1101467, name#1101468, baseUnitOfMeasure#1101469, unitOfMeasures#1101470, unitOfMeasureConversions#1101471, productionAspect#1101472, salesAspect#1101473, procurementAspect#1101474, productGroup#1101475, filteredUnitOfMeasureConversions#1101476, quantityNumerator#1101477, quantityDenominator#1101478, CASE WHEN (isnull(outboundUnit#1101479) OR (outboundUnit#1101479 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1101479 END AS outboundUnit#1101480]
(122) Project
Arguments: [product#1101450, plant#1101451, orderDateTime#1101452, productPlant#1101463, outboundUnit#1101480]
(123) Project
Arguments: [plant#1101451]
(124) Deduplicate
Arguments: [plant#1101451]
(125) Join
Arguments: Inner, (plantUuid#1101447 = plant#1101451)
(126) Project
Arguments: [plantId#1101446, plantUuid#1101447, storageLocId#1101448, storageLocUuid#1101449]
(127) Join
Arguments: Inner, (plant#1101420.internalRefUUID <=> plantUuid#1101447)
(128) Generate
Arguments: explode(filter(stockQuantities#1101422, lambdafunction(((lambda x#1101337.storageLocation.internalRefUuid = storageLocUuid#1101449) AND (lambda x#1101337.storageLocation.Id = storageLocId#1101448)), lambda x#1101337, false))), false, [stockQuantity#1101481]
(129) Project
Arguments: [systemId#1101417, internalUUID#1101418, product#1101419, plant#1101420, calculationDateTime#1101421, stockQuantities#1101422, plantId#1101446, plantUuid#1101447, storageLocId#1101448, storageLocUuid#1101449, stockQuantity#1101481]
(130) Aggregate
Arguments: [plantUuid#1101447, internalUUID#1101418, plant#1101420, product#1101419, systemId#1101417], [plantUuid#1101447, internalUUID#1101418, plant#1101420, product#1101419, systemId#1101417, first(calculationDateTime#1101421, false) AS calculationDateTime#1101482, collect_list(stockQuantity#1101481, 0, 0) AS stockQuantities#1101483]
(131) Project
Arguments: [systemId#1101417, internalUUID#1101418, product#1101419, plant#1101420, calculationDateTime#1101482, stockQuantities#1101483]
(132) Generate
Arguments: explode(stockQuantities#1101483), false, [stockQuantity#1101484]
(133) Project
Arguments: [systemId#1101417, internalUUID#1101418, product#1101419, plant#1101420, calculationDateTime#1101482, stockQuantities#1101483, stockQuantity#1101484]
(134) Project
Arguments: [plant#1101420.id AS plant#1101485, plant#1101420.internalRefUUID AS plantUuid#1101486, product#1101419.id AS product#1101487, product#1101419.internalRefUUID AS productUuid#1101488, calculationDateTime#1101482, stockQuantity#1101484.storagelocation.id AS storageLocId#1101489, stockQuantity#1101484.storagelocation.internalRefUUID AS storageLocUuid#1101490, stockQuantity#1101484.quantity.measure AS quantity#1101491, stockQuantity#1101484.specialStockIndicator.code AS specialStockIndicator#1101492, stockQuantity#1101484.stockType.code AS stockType#1101493]
(135) Filter
Arguments: ((specialStockIndicator#1101492 = ) AND (stockType#1101493 = 01))
(136) LogicalRelation
Arguments: parquet, [product#1101494, plant#1101495, orderDateTime#1101496, planningStartDateTime#1101497], false
(137) RepartitionByExpression
Arguments: [product#1101494, plant#1101495], 37
(138) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496]
(139) LogicalRelation
Arguments: parquet, [systemId#1101498, internalUUID#1101499, plant#1101500, product#1101501, blockedForReplenishmentStartingFrom#1101502, productionAspect#1101503, salesPlant#1101504, listing#1101505, sourceOfSupplyCategory#1101506], false
(140) Repartition
Arguments: 37, true
(141) Project
Arguments: [systemId#1101498, internalUUID#1101499, plant#1101500, product#1101501, blockedForReplenishmentStartingFrom#1101502, productionAspect#1101503, salesPlant#1101504, listing#1101505, sourceOfSupplyCategory#1101506, struct(systemId, systemId#1101498, internalUUID, internalUUID#1101499, plant, plant#1101500, product, product#1101501, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#1101502, productionAspect, productionAspect#1101503, salesPlant, salesPlant#1101504, listing, listing#1101505, sourceOfSupplyCategory, sourceOfSupplyCategory#1101506) AS productPlant#1101507]
(142) Project
Arguments: [productPlant#1101507]
(143) Join
Arguments: LeftOuter, ((product#1101494 <=> productPlant#1101507.product.internalRefUUID) AND (plant#1101495 <=> productPlant#1101507.plant.internalRefUUID))
(144) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496, productPlant#1101507]
(145) LogicalRelation
Arguments: parquet, [systemId#1101508, internalUUID#1101509, id#1101510, displayId#1101511, name#1101512, baseUnitOfMeasure#1101513, unitOfMeasures#1101514, unitOfMeasureConversions#1101515, productionAspect#1101516, salesAspect#1101517, procurementAspect#1101518, productGroup#1101519], false
(146) Repartition
Arguments: 37, true
(147) Join
Arguments: LeftOuter, (product#1101494 = internalUUID#1101509)
(148) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496, productPlant#1101507, systemId#1101508, internalUUID#1101509, id#1101510, displayId#1101511, name#1101512, baseUnitOfMeasure#1101513, unitOfMeasures#1101514, unitOfMeasureConversions#1101515, productionAspect#1101516, salesAspect#1101517, procurementAspect#1101518, productGroup#1101519, filter(unitOfMeasureConversions#1101515, lambdafunction((((lambda u#1101207.measurementUnit1.code = productPlant#1101507.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#1101207.measurementUnit1.internalRefUUID = productPlant#1101507.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#1101207.measurementUnit2.code = baseUnitOfMeasure#1101513.code) AND (lambda u#1101207.measurementUnit2.internalRefUUID = baseUnitOfMeasure#1101513.internalRefUUID))), lambda u#1101207, false)) AS filteredUnitOfMeasureConversions#1101520]
(149) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101520.quantityNumerator), true, [quantityNumerator#1101521]
(150) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496, productPlant#1101507, systemId#1101508, internalUUID#1101509, id#1101510, displayId#1101511, name#1101512, baseUnitOfMeasure#1101513, unitOfMeasures#1101514, unitOfMeasureConversions#1101515, productionAspect#1101516, salesAspect#1101517, procurementAspect#1101518, productGroup#1101519, filteredUnitOfMeasureConversions#1101520, quantityNumerator#1101521]
(151) Generate
Arguments: explode(filteredUnitOfMeasureConversions#1101520.quantityDenominator), true, [quantityDenominator#1101522]
(152) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496, productPlant#1101507, systemId#1101508, internalUUID#1101509, id#1101510, displayId#1101511, name#1101512, baseUnitOfMeasure#1101513, unitOfMeasures#1101514, unitOfMeasureConversions#1101515, productionAspect#1101516, salesAspect#1101517, procurementAspect#1101518, productGroup#1101519, filteredUnitOfMeasureConversions#1101520, quantityNumerator#1101521, quantityDenominator#1101522]
(153) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496, productPlant#1101507, systemId#1101508, internalUUID#1101509, id#1101510, displayId#1101511, name#1101512, baseUnitOfMeasure#1101513, unitOfMeasures#1101514, unitOfMeasureConversions#1101515, productionAspect#1101516, salesAspect#1101517, procurementAspect#1101518, productGroup#1101519, filteredUnitOfMeasureConversions#1101520, quantityNumerator#1101521, quantityDenominator#1101522, (cast(quantityNumerator#1101521 as double) / cast(quantityDenominator#1101522 as double)) AS outboundUnit#1101523]
(154) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496, productPlant#1101507, systemId#1101508, internalUUID#1101509, id#1101510, displayId#1101511, name#1101512, baseUnitOfMeasure#1101513, unitOfMeasures#1101514, unitOfMeasureConversions#1101515, productionAspect#1101516, salesAspect#1101517, procurementAspect#1101518, productGroup#1101519, filteredUnitOfMeasureConversions#1101520, quantityNumerator#1101521, quantityDenominator#1101522, CASE WHEN (isnull(outboundUnit#1101523) OR (outboundUnit#1101523 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#1101523 END AS outboundUnit#1101524]
(155) Project
Arguments: [product#1101494, plant#1101495, orderDateTime#1101496, productPlant#1101507, outboundUnit#1101524]
(156) Join
Arguments: Inner, ((plantUuid#1101486 = plant#1101495) AND (productUuid#1101488 = product#1101494))
(157) Filter
Arguments: (calculationDateTime#1101482 <= orderDateTime#1101496)
(158) Project
Arguments: [plantUuid#1101486 AS plant#1101525, productUuid#1101488 AS product#1101526, storageLocId#1101489, calculationDateTime#1101482, quantity#1101491]
(159) Aggregate
Arguments: [plant#1101525, product#1101526, storageLocId#1101489], [plant#1101525, product#1101526, storageLocId#1101489, max(calculationDateTime#1101482) AS max_calc_datetime#1101410]
(160) Join
Arguments: Inner, ((((plant#1101408 <=> plant#1101525) AND (product#1101409 <=> product#1101526)) AND (storageLocId#1101360 <=> storageLocId#1101489)) AND (calculationDateTime#1101339 <=> max_calc_datetime#1101410))
(161) Project
Arguments: [plant#1101408, product#1101409, storageLocId#1101360, calculationDateTime#1101339, quantity#1101362]
(162) Aggregate
Arguments: [product#1101409, plant#1101408], [product#1101409, plant#1101408, sum(quantity#1101362) AS quantitySum#1101535, min(calculationDateTime#1101339) AS minCalculationDateTime#1101536]
(163) Project
Arguments: [product#1101409, plant#1101408, quantitySum#1101535, minCalculationDateTime#1101536, round(quantitySum#1101535, 0) AS roundedQuantitySum#1101544]
(164) Join
Arguments: LeftOuter, ((plant#1101132 = plant#1101408) AND (product#1101131 = product#1101409))
(165) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, outboundUnit#1101219, roundedQuantitySum#1101544, minCalculationDateTime#1101536]
(166) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, outboundUnit#1101219, roundedQuantitySum#1101544, minCalculationDateTime#1101536, CASE WHEN isnotnull(minCalculationDateTime#1101536) THEN minCalculationDateTime#1101536 ELSE orderDateTime#1101133 END AS stockDatetime#1101579]
(167) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, outboundUnit#1101219, roundedQuantitySum#1101544, minCalculationDateTime#1101536, stockDatetime#1101579, CASE WHEN isnotnull(roundedQuantitySum#1101544) THEN array(roundedQuantitySum#1101544) ELSE array(0.0) END AS stockBatchQuantities#1101580]
(168) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, outboundUnit#1101219, roundedQuantitySum#1101544, minCalculationDateTime#1101536, stockDatetime#1101579, stockBatchQuantities#1101580, array(2199-01-01 00:00:00) AS stockBatchShelfLifeEndDatetimes#1101581]
(169) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, outboundUnit#1101219, roundedQuantitySum#1101544, stockDatetime#1101579, stockBatchQuantities#1101580, stockBatchShelfLifeEndDatetimes#1101581]
(170) Project
Arguments: [product#1101131, plant#1101132, orderDateTime#1101133, productPlant#1101168, outboundUnit#1101219, stockDatetime#1101579, stockBatchQuantities#1101580, stockBatchShelfLifeEndDatetimes#1101581]
(171) LogicalRelation
Arguments: parquet, [product#1101582, plant#1101583, demandChannel#1101584, demandStream#1101585, considerVariance#1101586, demandTimeBuckets#1101587, demandPointInTimeStart#1101588, demandPointInTimeEnd#1101589, demandPointInTime#1101590], false
(172) Join
Arguments: LeftOuter, ((plant#1101583 <=> plant#1101132) AND (product#1101582 <=> product#1101131))
(173) Filter
Arguments: (((size(demandTimeBuckets#1101587, true) = 0) OR isnull(demandTimeBuckets#1101587)) AND ((size(demandPointInTime#1101590, true) = 0) OR isnull(demandPointInTime#1101590)))
(174) Project
Arguments: [product#1101131, plant#1101132]
(175) Deduplicate
Arguments: [product#1101131, plant#1101132]
(176) LogicalRelation
Arguments: parquet, [systemId#1102301, internalUUID#1102302, plant#1102303, product#1102304, blockedForReplenishmentStartingFrom#1102305, productionAspect#1102306, salesPlant#1102307, listing#1102308, sourceOfSupplyCategory#1102309], false
(177) Repartition
Arguments: 37, true
(178) Project
Arguments: [product#1102304.internalRefUUID AS product#1102310, plant#1102303.internalRefUUID AS plant#1102311, product#1102304.id AS productId#1102312, plant#1102303.id AS plantId#1102313]
(179) Join
Arguments: Inner, ((product#1101131 = product#1102310) AND (plant#1101132 = plant#1102311))
(180) Project
Arguments: [product#1101131, plant#1101132, productId#1102312, plantId#1102313]
(181) Project
Arguments: [productId#1102312 AS product#1102319, plantId#1102313 AS plant#1102320]
(182) Project
Arguments: [product#1102319, plant#1102320, array(map(objectType, Product, objectId, product#1102319), map(objectType, Plant, objectId, plant#1102320)) AS anchorObject#1102621]
(183) Project
Arguments: [product#1102319, plant#1102320, anchorObject#1102621, cast(array() as array<map<string,string>>) AS messageVariables#1102622]
(184) Project
Arguments: [product#1102319, plant#1102320, anchorObject#1102621, messageVariables#1102622, array(map(objectType, ReplenishmentRunId, objectId, 10000000350)) AS triggerObject#1102623]
(185) Project
Arguments: [product#1102319, plant#1102320, anchorObject#1102621, messageVariables#1102622, triggerObject#1102623, NEW AS situationStatus#1102624]
(186) Project
Arguments: [product#1102319, plant#1102320, anchorObject#1102621, messageVariables#1102622, triggerObject#1102623, situationStatus#1102624, UNKNOWN_DEMAND_FOR_PRODUCT_LOCATION AS situationType#1102625]
(187) Project
Arguments: [product#1102319, plant#1102320, anchorObject#1102621, messageVariables#1102622, triggerObject#1102623, situationStatus#1102624, situationType#1102625, AUTO_ALL_ProdLoc AS marketUnit#1102626]
(188) Project
Arguments: [anchorObject#1102621, messageVariables#1102622, triggerObject#1102623, situationStatus#1102624, situationType#1102625, marketUnit#1102626]
(189) Project
Arguments: [to_json(struct(anchorObject, anchorObject#1102621, messageVariables, messageVariables#1102622, triggerObject, triggerObject#1102623, situationStatus, situationStatus#1102624, situationType, situationType#1102625, marketUnit, marketUnit#1102626), Some(UTC)) AS value#1110576]
(190) Project
Arguments: [cast(value#1110576 as string) AS value#1110577]
(191) Project
Arguments: [value#1110577, array(struct(key, X-Tenant-ID, value, cast(7233423560970044043 as binary)), struct(key, X-Message-ID, value, cast(75b610bc-c09a-4ada-a928-461af7ff552f 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#1110586]