== 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@647a9c60, [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=108.142.115.57:50094,108.142.115.57:50194,108.142.115.57:50294, kafka.ssl.keystore.key=-----BEGIN PRIVATE KEY-----
MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCONfDCFe0ADc/P
XqMo8JwdGlSVeC1DO/yr6PbcNE+TxlN8GiSAzfM6StGsbDO/CFd0ALa5tx99JqYP
F+BolPv+/2ChPQQnbTwqoHOE3Xo3NQNTxB+Lp+z6kqaeN25y0f7nmDezHxHICUo9
1ZZEO5YAJwVVc1mBtej7KcckoPht/o02F/E/nJmLR2XPzIL1LPMYnCpB8R0UOrTZ
ny0751Oq0gSmUAxe8TAEXfXASx8Ru290zxZJz0yjnQ3zPuP9PCznwzAbWbR1ypEp
AP/NxFnCxOPVxy/ku33fm89qXGMNwZrVyVzRSps79npvTD9+jcEakQNfMYMw3yuB
pgrMVPm3AgMBAAECggEARoT8ExqRUHYI52GcEhiiqZHdgNM7yrvr84mOJKsyDOsL
ih5inJbENtNUPybW0DPAPi9+bQCgdkycix6BcwryHUShM8OQlEaIT/EJ58h2Kvs4
X6kBJZ1LmAPx6MI/HGQC/fBPKp1NEX9918TbA5Hys7el3vZY28gLtMTGUmUaXFxh
g90fM8YHfMD5aAKMMtYip0vZnCp2mYDMuzrvPLCMpv0vKt2NlkYB6X2bHgjTrF/h
SkATNW/BgdHLxvcIqjM8GekPXMgB6t7+1R0KPwTV9Eb2ty5ZL/YSVSZWGa9voYuu
nz7iRjZKyetw24FhtvRGudErNubcCc0q9GS2VfrujQKBgQDBnsgDelafqRiLwBlX
fWSf2FcSVPctSSXhv5REWG/Gs/RY3WCj2DORX4tnA0MEQyOHB8ZfZRu2aBjGIeBF
y5qwlbAp91aWhXkcLkDsMfUAIGlzZHlkoOQWpm1DWZPoYsTCEl06m1jHYL7k4oGq
wLlFoNLkwrYyuGPLV0x7s+co3QKBgQC8Bw3sqymJe/a1iNNJrJzj0cp58lMM42g+
RJ44HAQKEzSqo2v76WcpPKElfSa32NVcfCHFu+zN0GQf69i+EENusRbAcZW0LOEk
GDtnjW7qpnU8xjp42LFJYej2DeVTxiJgcj4zdhK3GT65BpeM248YBSfcLnmM4Fej
aM66VRP5owKBgEdLdFLzhVodJdCv16UDoz3Ip6c0ah/ew3gw1yOjfOUp9luSiLdM
MRDioa444UB8iGR8VGtkC6RLCHRMnQyWQEutksShMt0SINpjnbxbWN/HD41R/fEz
3UkJ10npfjEfzVu472NZOIOR+DjHvv9lH9OnuIBLwlNC2lxRtPQH9qJxAoGBAIVI
mt5BFliWvvM/4kY/TZdQhy6aT7S7HpHFIkKz2UkrBBJRdaJEeRQKHlDsvh1kXxoI
BAieheX+6nqWPDW+YY59iZsw6OWnSpDDfJiS8ST0ifZireAr+sAB35lLkFwp/wRO
9ziTYgDYrFWMDrGSkYR9Yxv49cCe5oC3MpNy643xAoGBAJOGE+W8yyuCIKBuz7q0
+eNstW6Bli/ij2oVjSm0QAPtjy5oSVMOovIvLrnDOCQG1+R1RZcZARIGK5yZZAIm
d67xdtJbSZG490Qu447LCF5dE5jFmOVw/IbIx0wybh+mz96vlwlceXy/kzkiAgIY
cNR0cj93ouH10gi2G2fX4Rdy
-----END PRIVATE KEY-----, topic=SituationsTopic, kafka.ssl.truststore.type=PEM, kafka.ssl.keystore.certificate.chain=-----BEGIN CERTIFICATE-----
MIIG+jCCBOKgAwIBAgIRAPnvu/+WaCPa83EK0s1wj1IwDQYJKoZIhvcNAQELBQAw
eTELMAkGA1UEBhMCREUxDTALBgNVBAcMBEVVMTAxDzANBgNVBAoMBlNBUCBTRTEj
MCEGA1UECwwaU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudHMxJTAjBgNVBAMMHFNB
UCBDbG91ZCBQbGF0Zm9ybSBDbGllbnQgQ0EwHhcNMjUxMjAzMjAzMTM5WhcNMjYx
MjAzMjEzMTM5WjCCAfExCzAJBgNVBAYTAkRFMQ8wDQYDVQQKDAZTQVAgU0UxIzAh
BgNVBAsMGlNBUCBDbG91ZCBQbGF0Zm9ybSBDbGllbnRzMRowGAYDVQQLDBFjZi1l
dTIwLXNhcC1rYWZrYTGCAWMwggFfBgNVBAcMggFWZXlDUU84V2pqNWZRZm1RN3Vt
a2ZfMGNnelpJWXNsX3ZyT0NTRzZ5LWM1dWNjWllBbDdYMjBrVDhxMjlwRDNLRkZC
aWVWZGNRZkpCNzhVS1lzVTkyN0JXQmhlcnRGUHdlTGY4R3dqTDl5QzhGazJxWUZX
cDlvZWRObmNsb2tsemVSc2VhVmRsQ1kzQ1R0YVgxZ2twOHZWX2drWWdKOGJVV0lV
ZmhXSzk2ak93TjNLT1pRaUhfcE12OGNMVWxUTkJOd2VEWkZiMDFZUUkzTVFqR19B
bHBUS20tUGpKOUhYdHNBMVZibUVXSldBU1dQdkJ6aXdSRU9tYjFZUVpyWEJGU0Vh
amhPMUI2RWJKWkx4Vmh3dHktTnc3R3pBXzJGNUR3XzdlVVhaaFFyWkdzXzUtYUNp
V1UxVUpfZmYxYngzTkRaQjZuUmJXbUJPZkppaXFSMXFUbmR3MSkwJwYDVQQDDCBz
YnNzX2JlbDhuM3Ixd3dmdndvdTFnemZxMmthd2NkYzCCASIwDQYJKoZIhvcNAQEB
BQADggEPADCCAQoCggEBAI418MIV7QANz89eoyjwnB0aVJV4LUM7/Kvo9tw0T5PG
U3waJIDN8zpK0axsM78IV3QAtrm3H30mpg8X4GiU+/7/YKE9BCdtPCqgc4Tdejc1
A1PEH4un7PqSpp43bnLR/ueYN7MfEcgJSj3VlkQ7lgAnBVVzWYG16PspxySg+G3+
jTYX8T+cmYtHZc/MgvUs8xicKkHxHRQ6tNmfLTvnU6rSBKZQDF7xMARd9cBLHxG7
b3TPFknPTKOdDfM+4/08LOfDMBtZtHXKkSkA/83EWcLE49XHL+S7fd+bz2pcYw3B
mtXJXNFKmzv2em9MP36NwRqRA18xgzDfK4GmCsxU+bcCAwEAAaOCAQEwgf4wCQYD
VR0TBAIwADAfBgNVHSMEGDAWgBTtx8AzXhKk93kym3vuCviohXiMLzAdBgNVHQ4E
FgQU3zf0JRz/WLhwwR/Q5UGXxMoDZz4wDgYDVR0PAQH/BAQDAgWgMBMGA1UdJQQM
MAoGCCsGAQUFBwMCMIGLBgNVHR8EgYMwgYAwfqB8oHqGeGh0dHA6Ly9zYXAtY2xv
dWQtcGxhdGZvcm0tY2xpZW50LWNhLWV1MTAtY3Jscy5zMy5ldS1jZW50cmFsLTEu
YW1hem9uYXdzLmNvbS9jcmwvMmExYjQ5YWMtZmMwMi00YTQ4LTk5M2EtOWE0ZDBk
ZmVjMzNlLmNybDANBgkqhkiG9w0BAQsFAAOCAgEANLqT++8g/9D18ukde6JDLLqy
OfquBnMSo21rsNaEQkZQj5mvZjw5QAUCuRfY7J616fl1hdoaG2La4lsDDEhk3ny3
eI44yvA8ZSxkeI8wkC+8JipwpPw5aUHW/NWqlNCwxvM/uUq1At8/SHQbQ+QGPsWS
cbjR6XLZJ5ZiwA4FAEBtS10ivWcNLbqusaxCyThke1nO151ZEN9QBx4utZ1OxjBX
Vio23lzzsDdlFt1qMeWDrZYnd1ylmsH4cQzXP5e1zDi7nDC97lpzUl+7pDenLjJD
0N4IAMq2+sMF710eQPFXiHDoC8P8uCBMcAGTdEpiOhiM8r+V7P83l5r1tQdt4fYC
LEO09Qromavo6FEKDPmyFqqhhAXNzbNR42GPWdWNYj/e8hkeN1f49qkP7WjKNfzA
j/rnz8OqSyDnJCpxaZgKYg0hSBgrtCPeNA+ioTjec0+i0koP0Izu24XxY4RYCcTb
mNyVv2yKIdGubUIyKOky76pcB+U03U6vCkbYVtKsvCMJB72sVr25Gbk+vfb0w6qW
MZBossXuG1ZDfTHxvGiYEIkULTSo2Drc6VZdZd1n1TwQYI4bIzqtmCD6NZ73pjgs
Txr3jEChdMcDMLpEhJGIzpf96y/He2GGf4jHuoOCmnxnlx+k4uZgw2Ey6rfqq1fv
TYyTGwAbAA/roXsKddU=
-----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#31, messageVariables#32, triggerObject#33, situationStatus#34, situationType#35, marketUnit#36]
(4) Project
Arguments: [to_json(struct(anchorObject, anchorObject#31, messageVariables, messageVariables#32, triggerObject, triggerObject#33, situationStatus, situationStatus#34, situationType, situationType#35, marketUnit, marketUnit#36), Some(GMT)) AS value#43]
(5) Project
Arguments: [cast(value#43 as string) AS value#45]
(6) Project
Arguments: [value#45, array(struct(key, X-Tenant-ID, value, cast(8322290869003019352 as binary)), struct(key, X-Message-ID, value, cast(78856e8b-c31c-4591-9f64-afe85c7d9ad3 as binary)), struct(key, X-Event-Type, value, cast(SituationCreate as binary)), struct(key, X-BTP-Tenant-ID, value, cast(3f5e7e7d-8c81-488c-881f-e3134b991ba8 as binary))) AS headers#55]