== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (6)
+- Project (5)
+- Project (4)
+- LocalRelation (3)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.kafka010.KafkaSourceProvider@40b70e5a, [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=132.220.198.208:50094,132.220.198.208:50194,132.220.198.208:50294, kafka.ssl.keystore.key=-----BEGIN PRIVATE KEY-----
MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDM/2boMNrqIMfn
8HltUG1oPKa6kMp99tLrlBPECewbOJ3xKV1D/dLG+KUHaPbZj+CHlFrIq9b+keRF
PO0uxJu/I6lKHICSiAhKjMR1x2Zlru6iCjFl3ZJABcE8wQLJhwdcfNfRrMNYGgh0
hvswpOZlSvQI4dNw9U1CrbFSBKibzWpD+C+bQsZlTvYHXFPKmZ7tr3gvhMrIFmri
Y0kTrsenJvdeNZgXRWpM/lA7ROPMKYq7JfdOU9Wb9avxYD5q77+IHbwmtiJgCLmA
/RJewTdhJaknavwozp4WDgwdjkL7rzMLOsygvAApfUNab+tzorZwrW52whySXnMS
ZOOrucurAgMBAAECggEATBLhnPv4WVdF6DBI14S3vS140BZIVtuAZVUDysXF3Uoy
7ppjloY8sIL4NxpANPecIqQu1nZSqBD67ajQ+gCTLajtu2d9XSNnNEct5ulS+hwj
SXXP5BYIHoMkNUgJIUFfPXbE3nYm3ex3Q8sNr30aVO+uRReM0Efv3nU3rxC0g3Ba
qE/W3T9N+zJrnx7+lnOuQLdcBO5rtWwKE5R2qWXgX2+Nck6+vuRfNA27dn4hUYJ2
xeX66mXbwU5/T3ILsUKapTqkgRVNsoe/ZSPbnB93t8ilo8dGC8KVMPYiTx6i1h1k
ZopXgvia3XrXxeKZWb6JxWTjTDvcgNmr3VXJ8TVgrQKBgQDw1OVu3+T+1JGmCGK0
SFSLBnG37bbrKoYZOhW+wP4AxjOmYWYsZ9YldZfboTnlIGw9VFybR9Ux4SNC2UjM
HYPDVfftOrT9SomgmhS+iTIjNnemi/gbPb4i9Y+WKalSalOEWLUbkQywRx6O9LQ7
xGFGY4ccfysUCQDooQW7phM4/wKBgQDZ6LqK06tYDqCeyI3Oq+9AREEAR2ul0X3c
iZu9zsAwgpWyztyerBoV3+6rFRucvAvzTK828B0CJatxEXeIVJDf9h1Djyk5rL3G
lXQzb2GY4Iu7lUlgQzrJLsj2LdHrZZftqknMLwkbTjUnzvQRHE1KOKWptMd2IHiR
zkiyLAEhVQKBgEZ2k/Z/zbl9qmvA0lhbPVk79nPROo7N71RcOVaJkwfY9e29W66s
Zuyo3lilcJIIjYLYNww71TX14GJDvtfx3sZ9Vb/0SFY/w8rYqi8hZykEW7fABkS6
KPKDlJJj+CWj9HGpnrvFEchV1qwPDtjZ2XhF0JdW4dzH0Zs+2bWQntkzAoGAQwFF
GxsrPNCCo1CYCkzkLKbQNf3AJCTexsmpkhvZDRGaZnklbcUN4FwTT5gV/YP1SMLz
vbjnsplStlngn5MhWTyckwGac5miYUXjjU1afV/Ol8e34FnL4cD5GnnMas26geIy
/w4XhsXtomgItJo3SfNRPXXRP4mMiYkc4WyWjGECgYEA2F4kJE6iHWktcx9HWFvn
VHiY2wmoNiMRks0iVOQc7Q9VdOhJmBPNBKR+2cyheVOOUiYJsRLWxWOcazU0dZZt
AgxSXkDuS3N5cUu9t3t3KHcHOgyzl9AqKmtqAbZpV2W++3dbv5qaG+0sEK1n4IJz
+GzqTCdp571orwLareQmLO0=
-----END PRIVATE KEY-----, topic=SituationsTopic, kafka.ssl.truststore.type=PEM, kafka.ssl.keystore.certificate.chain=-----BEGIN CERTIFICATE-----
MIIG+jCCBOKgAwIBAgIRAILFsTmzrVjcrJUa5s/fxJwwDQYJKoZIhvcNAQELBQAw
eTELMAkGA1UEBhMCREUxDTALBgNVBAcMBEVVMTAxDzANBgNVBAoMBlNBUCBTRTEj
MCEGA1UECwwaU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudHMxJTAjBgNVBAMMHFNB
UCBDbG91ZCBQbGF0Zm9ybSBDbGllbnQgQ0EwHhcNMjUwNjE4MDgxODQzWhcNMjYw
NjE4MDkxODQzWjCCAfExCzAJBgNVBAYTAkRFMQ8wDQYDVQQKDAZTQVAgU0UxIzAh
BgNVBAsMGlNBUCBDbG91ZCBQbGF0Zm9ybSBDbGllbnRzMRowGAYDVQQLDBFjZi1l
dTIwLXNhcC1rYWZrYTGCAWMwggFfBgNVBAcMggFWZFRxTVJZamFtZlBUNExWSDN1
NC05d3NOU1ZWbk9yYTRkZEs3VFVNWDRNdnl1dXE0aHl5cE5qSW4zX1BVOEdTREdy
ME9zTVBLMDZFMkE0eUFiN1Y1dVV2QU4xd29SLW85WXJKbVNfcUpGQ19jT0tGODhx
RUxNYi1ERlZzSnd2Qm1VVlNJZm1sQ0dPcmZyMGVaa2UtVGZJMmRDZjJjWC1Uc285
NGNNMkVHbnlDVmFnRGR4alliNHFXQmZvMVZaYW5lTkJUVVVZclpuY2JUUkJvWXBP
U0c3SU1yQ1pDR2J1R2JSNUlkUzFDWTdkeUlLRjVzQnZMaHNtNmJ1VF9tX1U4T0Na
enI0NlBiMFByeFVybXBDaDhwTmsxdFVnOFZHQmRWWUNaXzZDNks2MUp1Tk9DcWUz
Y3FVZURaR1FpNW9JMVVrS1ZIbVN2OFNHR1V5RUJrbnlQM3B3MSkwJwYDVQQDDCBz
YnNzX2thb2lqZXN0ZGFyZTFyZndvdjhvNHN4YndicTCCASIwDQYJKoZIhvcNAQEB
BQADggEPADCCAQoCggEBAMz/Zugw2uogx+fweW1QbWg8prqQyn320uuUE8QJ7Bs4
nfEpXUP90sb4pQdo9tmP4IeUWsir1v6R5EU87S7Em78jqUocgJKICEqMxHXHZmWu
7qIKMWXdkkAFwTzBAsmHB1x819Gsw1gaCHSG+zCk5mVK9Ajh03D1TUKtsVIEqJvN
akP4L5tCxmVO9gdcU8qZnu2veC+EysgWauJjSROux6cm9141mBdFakz+UDtE48wp
irsl905T1Zv1q/FgPmrvv4gdvCa2ImAIuYD9El7BN2ElqSdq/CjOnhYODB2OQvuv
Mws6zKC8ACl9Q1pv63OitnCtbnbCHJJecxJk46u5y6sCAwEAAaOCAQEwgf4wCQYD
VR0TBAIwADAfBgNVHSMEGDAWgBTtx8AzXhKk93kym3vuCviohXiMLzAdBgNVHQ4E
FgQU2NpMTPICeJ9+KCov78LkMo6+GRMwDgYDVR0PAQH/BAQDAgWgMBMGA1UdJQQM
MAoGCCsGAQUFBwMCMIGLBgNVHR8EgYMwgYAwfqB8oHqGeGh0dHA6Ly9zYXAtY2xv
dWQtcGxhdGZvcm0tY2xpZW50LWNhLWV1MTAtY3Jscy5zMy5ldS1jZW50cmFsLTEu
YW1hem9uYXdzLmNvbS9jcmwvMmExYjQ5YWMtZmMwMi00YTQ4LTk5M2EtOWE0ZDBk
ZmVjMzNlLmNybDANBgkqhkiG9w0BAQsFAAOCAgEAUb1ITWqSGaBUC0v5/FugHBcw
/zPhcHhXkHFNjayWCjFx23ejABVCnrivpzy+U9Rvg9dGEYPu0T488JtoLkQPM5YJ
SHqyBBtl2GTmMPZch4ZQnTlZ8WiiaIR+hpeYtpeGcZilv8GuBYULc+zMh0Q/OvIW
n3xP5zWOw9VRPbQArRbPl3sGe9CQsHlMUJx1EUR3q8nyW4BvVHAgevzrN3g9bgJX
VxfgSFafipPMI/RkvqKlr3F6i7417H9KwSsFz9i/XwMbpGUfjFThPFsveXLug5J+
BxXszMVw/ZPeCoFT2BFY4VJcip75Ywb3fOPgqe7siXuii1o+0xzKJBk4ddr6Yn4M
6lPCn/3V/oRkp1AVXbFrwjKpTUZ/msPdTqAQc7RSIiA8wPZmFrCU3tB7aGtK+vML
DlSp7FJUyM3ofJScsxRcFPBPb48gSljd/KykpZ9w9nuHL9LyOysKxrq0fVjD2WkY
ZlTnrL49T6Rk+7dfkXhyuLd459rb+4SQNao4zfSA8qnCFwLTZW0wbFZGYOME9ozC
ae/ecTA2ymt5tmBixtpHio4PHb/X9BEbcp9dLv8ilnbT0Votqo6E+yjSvYUvfuaj
+EnjNl/rfNaSNESeA236e0v8W2QGASQHjYexKbIHKpfENkTRuKFDTF39Gl2Q40yk
9wFPNcfpsaN8pIDbcXg=
-----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) LocalRelation
Arguments: <empty>, [anchorObject#257, messageVariables#258, triggerObject#259, situationStatus#260, situationType#261, marketUnit#262]
(4) Project
Arguments: [to_json(struct(anchorObject, anchorObject#257, messageVariables, messageVariables#258, triggerObject, triggerObject#259, situationStatus, situationStatus#260, situationType, situationType#261, marketUnit, marketUnit#262), Some(GMT)) AS value#263]
(5) Project
Arguments: [cast(value#263 as string) AS value#264]
(6) Project
Arguments: [value#264, array(struct(key, X-Tenant-ID, value, cast(1699186316786241789 as binary)), struct(key, X-Message-ID, value, cast(67e4093a-9ff8-44ea-803c-fd08a3177b6f as binary)), struct(key, X-Event-Type, value, cast(SituationCreate as binary)), struct(key, X-BTP-Tenant-ID, value, cast(cf8a2c2a-e86b-470c-8435-90332cc06f03 as binary))) AS headers#273]