== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (7)
+- Project (6)
+- Project (5)
+- Project (4)
+- LogicalRelation (3)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.kafka010.KafkaSourceProvider@1c04de3e, [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=20.56.198.7:50094,20.56.198.7:50194,20.56.198.7:50294, kafka.ssl.keystore.key=-----BEGIN PRIVATE KEY-----
MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQCjWXGaAOjLbw9J
Fhb3mB5QdPc8s03zBbv46HGfcd6w9sJB0mSmo5VKlUprLQisCmMt3NYdqvfOkGo4
ZOUL18j2uEmByUa8xAVQaOs4r+bfjPpTY3I8J4uxj05mpUCqlL2x6Gj0SObUEfUG
MxlFY/ccKqYStauZdGHbfzgL8C7a8qGj4UuSzYoRHOQpoyYjONvupEoQgpWJuQfM
m/KFqjbxk6gXUbG054ynJaz0ZStF/fHHBm47hJPMtQdOQVi2jb7inD30kfZsEMlJ
PKh/XMtRLEdrU9iI+Y3fmtzF6Xhk8usPc71KPhXLuQdVhrSqis+BC794k81HflLh
3zvjU5/VAgMBAAECggEAHqbfThR7God30RFb1HCfSZ41MZb82sw56lplzdNehAr9
xz+tYuah0knC2essrCnT1AyTQiRtlT2crQHjyA3hGEjbBEdqZmwLCjxx3SSG2G6a
H5Ey465RBIvdXJ4ITSoVkX+IyEQwyl0nQxdOF+sK+OZY3Pxpm6VO4pMUB4t1o2Bk
yKkUxagJElB+2/Qg76eRvvzZQ75vG3WLbABlwqa+Z6VQcNgkoOf9en+EmyuVF3U5
AKvR8ljaj3n7e9giW985Fn48u0xC+YJ7R0HnQRzVq4lDcolBZV8TwiSbJYRKfyq9
NNYjj69hvV0uusOPRAeUV77rl3ig228IZBMgiD07yQKBgQDZU+uZT8o1mcSHRiSg
mSUd2f7a0/0WHdRiYunvc+JbFWlVgQkt+ZsTZrx1gNlrGbgvhJ5arKems8JdBW2f
nEfxqvwaoKdb3P6rLWjedwnNrSjkh6Wlvtfy1ac18vqgAq+IZfUpKXf7lZ8+BX0t
oIZFzFZjY26HPQnOx3Nfx3ZGzQKBgQDAapurkxrBKLv5EAre87zq6ebx6tEI3zW+
6EVDwwvUa5laPTd+ADMtq9NqqCQP1orUcJz4L4gFgOVSij3OeJDg2Sbtaq4EFDCl
Cc/QHFZzbhwF+PTLenCaTO1v4BsrTvoLkXL0XinvqsPWRbDA6ck+bkOZY/AYbLkk
bp1UKDFtKQKBgEejTR8dWRdwF4NL0NkLglujt0mk5WE79f10g46GEZBar30a6s63
37F2hRrqnUCbmsY3Hgffr+fYi3IkTu11E5YK+c1BNcmnQF9muZHThWzB7p/eQvEu
xnpqiRLUhF7oY7o/eZ/W5pEM0hAcuRWoO3qYj8V1SkLUEP6TammhE1DlAoGBAKfr
IWktGnchPlHPzzzchqyXbYUHQF82tCejefb1u1gogo7+x3O9ZuxffEQi8j2kJEna
8RGiIVl0MCzFGcUa8IxY1aDxrWU/3WfZ1TKv2D4qBGit56u/cY8mvTsZ33v/EzWP
PDvIBV7zrq5K6UKhg49pGLM/RON71mLV6ZTs8p1pAoGAD6im2RuJ+KXWryj4lZ8V
jw1hhE0v+WoPNKuQ5HAky+UPVggijkYnz1q/ZCnqB/cHCYX7VBx06UDOIW40ZQpp
dH1mR5b2VzoI9JBxouIRhJAnQYsMCT/F1j34zeqBhrTqTGFwS2C9DayO+2x8kh51
2YGP38p/7X9IZJ2mLT7yFfA=
-----END PRIVATE KEY-----, topic=SituationsTopic, kafka.ssl.truststore.type=PEM, kafka.ssl.keystore.certificate.chain=-----BEGIN CERTIFICATE-----
MIIG+TCCBOGgAwIBAgIQSUOKIqlhUbE3cWqhmeYHMjANBgkqhkiG9w0BAQsFADB5
MQswCQYDVQQGEwJERTENMAsGA1UEBwwERVUxMDEPMA0GA1UECgwGU0FQIFNFMSMw
IQYDVQQLDBpTQVAgQ2xvdWQgUGxhdGZvcm0gQ2xpZW50czElMCMGA1UEAwwcU0FQ
IENsb3VkIFBsYXRmb3JtIENsaWVudCBDQTAeFw0yNjAzMTIwOTI0MDdaFw0yNzAz
MTIxMDI0MDdaMIIB8TELMAkGA1UEBhMCREUxDzANBgNVBAoMBlNBUCBTRTEjMCEG
A1UECwwaU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudHMxGjAYBgNVBAsMEWNmLWV1
MjAtc2FwLWthZmthMYIBYzCCAV8GA1UEBwyCAVZEQjRkWjZ5NVRHSWI4bjU0V0Vl
b2hNWWp6eDVyWW9memdISWRieDViSTQtQ2NjSTBCSGt5anh0WE9Ea3F2aVVUZUp1
SFBHRi13QnYyMHlQTzFqdHJXMTB4YzZFUThkN05TS2k0VlZSc2ctaklYZFplTi0z
OTNjSGRESEUtdlRyb1dHcEpvRl90cFp5TmpYZGJ1MUd1aGU5bHQwd0NsUUpBUFpm
VktVSEloMDU1eW9MUEhrQVZQOVBGWkNXU1NCU0JWbkllOE1YMGVPYUlVMWpTQ1RM
cjUzaU44TkFmRy16YWctZXAxMkkxZjFieERkWldrYTJtRDM4VUxkWk9SbHNJeGRa
cEQwR2xucDdwUG1Ldk9NVlFuRnV2cUs4ZFhDemlEaTVfT1QyTVhnc090eGNmR3Bw
OHF6bmxXR3dmWTYwSFlvUUt0MnJ0amtLUkpRaGpNcVJiOGcxKTAnBgNVBAMMIHNi
c3NfdW11bXdiZXo4ZWg4bXR0YWZkX3lkY2xwYnppMIIBIjANBgkqhkiG9w0BAQEF
AAOCAQ8AMIIBCgKCAQEAo1lxmgDoy28PSRYW95geUHT3PLNN8wW7+Ohxn3HesPbC
QdJkpqOVSpVKay0IrApjLdzWHar3zpBqOGTlC9fI9rhJgclGvMQFUGjrOK/m34z6
U2NyPCeLsY9OZqVAqpS9seho9Ejm1BH1BjMZRWP3HCqmErWrmXRh2384C/Au2vKh
o+FLks2KERzkKaMmIzjb7qRKEIKVibkHzJvyhao28ZOoF1GxtOeMpyWs9GUrRf3x
xwZuO4STzLUHTkFYto2+4pw99JH2bBDJSTyof1zLUSxHa1PYiPmN35rcxel4ZPLr
D3O9Sj4Vy7kHVYa0qorPgQu/eJPNR35S4d8741Of1QIDAQABo4IBATCB/jAJBgNV
HRMEAjAAMB8GA1UdIwQYMBaAFO3HwDNeEqT3eTKbe+4K+KiFeIwvMB0GA1UdDgQW
BBRyd6TXZsAywPikC5nAMLpj+txvzjAOBgNVHQ8BAf8EBAMCBaAwEwYDVR0lBAww
CgYIKwYBBQUHAwIwgYsGA1UdHwSBgzCBgDB+oHygeoZ4aHR0cDovL3NhcC1jbG91
ZC1wbGF0Zm9ybS1jbGllbnQtY2EtZXUxMC1jcmxzLnMzLmV1LWNlbnRyYWwtMS5h
bWF6b25hd3MuY29tL2NybC8yYTFiNDlhYy1mYzAyLTRhNDgtOTkzYS05YTRkMGRm
ZWMzM2UuY3JsMA0GCSqGSIb3DQEBCwUAA4ICAQBZh8PAhyNhWRNMJBajQEUhTs3+
Vauov6nmr4Lw55TGYWaH0Opk/HjQ9H4fMtwIremRORyK3HBgFkga5rlcX5UbwJU0
wWPMtsvXoqiXkJbEqdlbXnDhUZEFV+3uEq/YLIXISTbmK5/GDqt8IFhesKMxceOD
zZkXJ3nj/XqlfRRLw+f8/lOic5T+K6hC2AV9CIGtjd5Mm+aAc9N8isU75LEFK+9x
FezOLVmGZSAot0ELlno11PSJllr8jcN5LIHt710NROT03NfGxKnJ5iaYzEn/5is4
AE0zrjvP99BzOpkSV6DD0IegEBQGqvD9Urn59jF1cRBWoaP1ukQ0zPAXIDV2f29A
e1ZJPK1qDyT18eW66hQNTAZ9I155yUVrHW7Nljbi+EGF1Dvbz27d8NizoTYFOj7i
dWmazm6qIG7g3725XZ35K7x9+ecPsZmvv/k8EA9Rdv3BACtqWPw1Ch3W9Y2XP/r4
al1g7W3PeAam31HKuzYEsZzIv32LbWApsbccOmb8LLb0TpQDOuF1aaaL7pwtYrIF
tUZZ/VQKrxvohZtCA90xiR740xjnf32eFged9MIZtzBekbTSuTk4L+Efl6RioTuh
m1sXVQKxq2bNVBjeECzzrky6WNAvzympR9d0HyeODeA1JZikPHkuvcQEIuKYU/N0
bv9DuzSOeZzTIzxuyw==
-----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#3319754, plant#3319755, horizonDateFrom#3319756, horizonDateTo#3319757], false
(4) Project
Arguments: [array(map(objectType, Product, objectId, product#3319754), map(objectType, Plant, objectId, plant#3319755)) AS anchorObject#3319762, array(map(variableName, HorizonStartDate, variableValue, cast(horizonDateFrom#3319756 as string)), map(variableName, HorizonEndDate, variableValue, cast(horizonDateTo#3319757 as string))) AS messageVariables#3319763, array(map(objectType, ReplenishmentRunId, objectId, 10000000000)) AS triggerObject#3319764, NEW AS situationStatus#3319765, REPLENISHMENT_BLOCKED AS situationType#3319766, 10000_OP_PERF AS marketUnit#3319767]
(5) Project
Arguments: [to_json(struct(anchorObject, anchorObject#3319762, messageVariables, messageVariables#3319763, triggerObject, triggerObject#3319764, situationStatus, situationStatus#3319765, situationType, situationType#3319766, marketUnit, marketUnit#3319767), Some(GMT)) AS value#3319775]
(6) Project
Arguments: [cast(value#3319775 as string) AS value#3319777]
(7) Project
Arguments: [value#3319777, array(struct(key, X-Tenant-ID, value, cast(8793759653749352888 as binary)), struct(key, X-BTP-Tenant-ID, value, cast(eaa49c20-85f6-4a2f-8a5e-c8b6ae1b9648 as binary)), struct(key, X-Message-ID, value, cast(ca524838-6c98-4054-a364-8cce466715d8 as binary)), struct(key, X-Event-Type, value, cast(SituationCreate as binary))) AS headers#3319787]