== 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@fd1281c, [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-----
MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQDZh6wkSCIlrWOg
Y/75q3QvxBmWBWMsUuQ/NTF5bbZBvmYZj2BhtYr6YPhWxcSGbj4wDugL7NBWlpjk
ESSuCKM67jlrDOzgu1dl2UCHaN4mXgo6CULIPemYX/6fEayZh7sCW3K0ETpuHtD1
1GVxsHh8xhqTcJGgb3sefec+KZ2CQJMyJOiq0q6kNhOEEUxWY5T7q/W6PFzWXuSd
oCKg+J0dIotz3ay61TPryYN8tzxbbgXXeutJD81UqCyGILoBzAzILHJsUE0P/h/K
YzMIY0j3E5jznnp/oT5ZKZXJC9cmEIX6XHxaRv92UJQ0x6GxSNsTZtJj7Lb/vn/8
wGfPJWCPAgMBAAECggEAMsxwoj5oHwVZPSTs79Aev2LbmMGkUb7/x1T8Oz+oLr0w
aaqmVtsG3AaWJ+liRgRrqFxqyxIf6wCbLrNkLfIdcE8egIXRsX9+Xu33mEegjTQr
zjbIbiurJ+bO9sWxWV8tiFTjufJGA15V7PqPQBf2Yyj+Hs1MbLtr9IhxXn5oZniQ
zym7ijt/BbUCLzeq7kX3oOGmBfd4z3GNbekS7/md4jkHfFFeBCDjN2mgVb0rYxvH
sWb+w6lOmvSQ0AaVq6BDWUoUWOFBfTr+RDUyZ67Brr+dZE6xIFag+BH4IQFjSZFT
1E/xDoqOa5aRvbyvTeVnsVm0GR5AgIpxOLDLDdB1FQKBgQDtddvXU4uWx8jUk83W
Btdok3zA32Tztv2SlIb8u8b17jVt7xNbOL6W9wfg5Gxdx+P8BBm8xuWL6i3ky2FF
5Et4SxUIH72+lh8mYM2ieZSGnJrcznwaGf5+GFU/qSLN2UpKhe17M9vUVkKXJKgg
XQqk0VKUUZ9GlmtM6EhWBvcMcwKBgQDqg3Z2MpYQ5Aug1qgj30bkNPpkaHhN1W6S
CLjJJIWZtDWS2oLFXlgYDd/wxXJ8SH+lU4GQBDm5QL2cVWqxrQN6eiPswSZ8IpBs
f/uBkobX32wLiqQuFNTI9NSzeqNJqqL3AVJNj03WjxS7fvdrAWG9JCfwgslTj4Wz
4F9IvtSQdQKBgG+ZBEieKuwh2HCPRh1f+bxcFDVQx9ECHwnUY9xDI65Q1StlQGOO
t4ObdUhsEcHBP5QhGTdvAlJPLGJqcry2HgHax3eZ80KuqtUOiZXiLbtVvjInmItr
y/7W0Lmqc4Dqrc94QbO1G4sfPwxpXdpX37i152ltMr2p06PBRr2naFOhAoGAVLtB
Dv3CCMJMjUVhpOxkUcnuel7gsMaf17W9Bjfi6aEaBkBbJXKsA6znr7e3YL5VGGfu
lRlhvdRtbdHS5fVsH1GIL1+uRwW6BunK9or5m3/HKvhhz6CJLT6Ap4R1AQXdMb/R
e+J+LjquM/xw6sGqDcvFfnnSwhVGKrKz2rXQWY0CgYBtcLIXQMjU22Wi1Qa6ie+/
abDmT9liC4uJXwPRvh5mHUgDyvMiaxscr/SmQfNQr7vyXJVjezEiSkRNaFsa6VtU
v2D99HWZ1H8gdJ6Bf+bFkxdnd7ZUf/RkObFG32sh3XUGhpirqTQOXi/I9X1sdl9a
HG1hbQINTMIJjtIDbm5j0g==
-----END PRIVATE KEY-----, topic=SituationsTopic, kafka.ssl.truststore.type=PEM, kafka.ssl.keystore.certificate.chain=-----BEGIN CERTIFICATE-----
MIIG+jCCBOKgAwIBAgIRAMueG7onFxFz1xcCi5wVLkIwDQYJKoZIhvcNAQELBQAw
eTELMAkGA1UEBhMCREUxDTALBgNVBAcMBEVVMTAxDzANBgNVBAoMBlNBUCBTRTEj
MCEGA1UECwwaU0FQIENsb3VkIFBsYXRmb3JtIENsaWVudHMxJTAjBgNVBAMMHFNB
UCBDbG91ZCBQbGF0Zm9ybSBDbGllbnQgQ0EwHhcNMjYwNTE5MDcwNzQ4WhcNMjcw
NTE5MDgwNzQ4WjCCAfExCzAJBgNVBAYTAkRFMQ8wDQYDVQQKDAZTQVAgU0UxIzAh
BgNVBAsMGlNBUCBDbG91ZCBQbGF0Zm9ybSBDbGllbnRzMRowGAYDVQQLDBFjZi1l
dTIwLXNhcC1rYWZrYTGCAWMwggFfBgNVBAcMggFWRnNPdzFqWm55V3dkVjVGRkxM
bDVEaXJCaTlGQTVLVTdmTHgxYklvSkVZVUZPaTE1OHRMRzk5RTNURU96Y1FzM2tu
aVlPdGdQNE1iaVVMWUhoak8yRVZQZ2hEQ09OOVRKSW5iRWRZeU53LUdBMGJnME1R
SFgxb2tSMnJwMlA1M05nYUp1Q09uaHkxc0wzYVFsS1ZBMmZvR21Dakxvc19vZnB4
cHRHOGxZZXdybzd4eTJIejBYT2E4WGZYdTJNMFBqOHoxRUUzUllldWJCSTFxYUdW
ZExxUGlYR0R6ZHE4RGktRkFyNy1wV0JGcDNhR0FPU2lxUzFjLXUzODFsZzg2NC1l
UlJrclNQVnRjTTh0MzVWSkI3YzNDb0VLb0Rzc3ozSHRraVBwNm5RNmdlcVV2VXZi
OHRoWGVIZWJJcXdkcjZITWFUVnVwMnlYbjV6ODZGUW1tOHNBMSkwJwYDVQQDDCBz
YnNzX2l2Z2V6N2ZodnRxYXk0b2tnMnRsYjJhdmgyeTCCASIwDQYJKoZIhvcNAQEB
BQADggEPADCCAQoCggEBANmHrCRIIiWtY6Bj/vmrdC/EGZYFYyxS5D81MXlttkG+
ZhmPYGG1ivpg+FbFxIZuPjAO6Avs0FaWmOQRJK4IozruOWsM7OC7V2XZQIdo3iZe
CjoJQsg96Zhf/p8RrJmHuwJbcrQROm4e0PXUZXGweHzGGpNwkaBvex595z4pnYJA
kzIk6KrSrqQ2E4QRTFZjlPur9bo8XNZe5J2gIqD4nR0ii3PdrLrVM+vJg3y3PFtu
Bdd660kPzVSoLIYgugHMDMgscmxQTQ/+H8pjMwhjSPcTmPOeen+hPlkplckL1yYQ
hfpcfFpG/3ZQlDTHobFI2xNm0mPstv++f/zAZ88lYI8CAwEAAaOCAQEwgf4wCQYD
VR0TBAIwADAfBgNVHSMEGDAWgBTtx8AzXhKk93kym3vuCviohXiMLzAdBgNVHQ4E
FgQUgdZcpxA5k3deyQbE+UCnuO2HgWUwDgYDVR0PAQH/BAQDAgWgMBMGA1UdJQQM
MAoGCCsGAQUFBwMCMIGLBgNVHR8EgYMwgYAwfqB8oHqGeGh0dHA6Ly9zYXAtY2xv
dWQtcGxhdGZvcm0tY2xpZW50LWNhLWV1MTAtY3Jscy5zMy5ldS1jZW50cmFsLTEu
YW1hem9uYXdzLmNvbS9jcmwvMmExYjQ5YWMtZmMwMi00YTQ4LTk5M2EtOWE0ZDBk
ZmVjMzNlLmNybDANBgkqhkiG9w0BAQsFAAOCAgEALo/FgW8ViN4bjBBj9oHJsJ2Q
plCI5YBBFbHoHUQVZUG7sExYr+ZYmEd2OBmEX6G383Tm6alMSfgvuDaEvFk46brt
WQRYIIKl9qfNKCdeltsbSgkTrVByGeUJg3o+PCVTtkoYr5la83kvgZzwTpdI5xRU
OfNnmmHkH6qrBkg9ndksHcDcUVSiYX1q3Hnad/4sWKukcncfnUF9eMTNwDMG1f48
56rC36/JfHaWg3C3Wp9YCOF1du/AzT5/4OvtzM8P41odqnMJphs78bSn/xK86yca
/4clhGChyCRHiHIBXhHx7lvpmRBCDlCU8bSvtdywMlCobobAzGz6hFGHqWt10Pm2
kWXfUPVqfiS4gBPDQxhgfp5nni35UXYUBZH0pwBz6L6ReVtKa2TtPksYlbY0hK+q
0JmZBr4hWmTx02cbZ5ktI8AWfDQCzGExqb2fA789B5+pszaeskxk/EQXth915ZYD
NBkgcSYfhBXws0qwUNcrNztQSidM+p9pBiP/QLkVZ9YlsH34VKi59imbD/4CT/wT
1kcnfvWOwKhrc6ashj1HzupHjFJlKbIJCKDeEiUK/tEd7rLmPyYKaOeP6yjVLkvF
1chyqu8Qf2rQsDkUUlnPhmDlpCX49c+qAHdXy+nMsfpoVoOVldhun7rdUDBSsPiv
4oHoOCJwX+Gen9FfsT0=
-----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#21517975, plant#21517976, orderDateTime#21517977, planningStartDateTime#21517978], false
(4) RepartitionByExpression
Arguments: [product#21517975, plant#21517976], 25
(5) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977]
(6) LogicalRelation
Arguments: parquet, [systemId#21517980, internalUUID#21517981, plant#21517982, product#21517983, blockedForReplenishmentStartingFrom#21517984, productionAspect#21517985, salesPlant#21517986, listing#21517987], false
(7) Repartition
Arguments: 25, true
(8) Project
Arguments: [systemId#21517980, internalUUID#21517981, plant#21517982, product#21517983, blockedForReplenishmentStartingFrom#21517984, productionAspect#21517985, salesPlant#21517986, listing#21517987, struct(systemId, systemId#21517980, internalUUID, internalUUID#21517981, plant, plant#21517982, product, product#21517983, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#21517984, productionAspect, productionAspect#21517985, salesPlant, salesPlant#21517986, listing, listing#21517987) AS productPlant#21517989]
(9) Project
Arguments: [productPlant#21517989]
(10) Join
Arguments: LeftOuter, ((product#21517975 <=> productPlant#21517989.product.internalRefUUID) AND (plant#21517976 <=> productPlant#21517989.plant.internalRefUUID))
(11) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989]
(12) LogicalRelation
Arguments: parquet, [systemId#21518034, internalUUID#21518035, id#21518036, displayId#21518037, name#21518038, baseUnitOfMeasure#21518039, unitOfMeasures#21518040, unitOfMeasureConversions#21518041, productionAspect#21518042, salesAspect#21518043, procurementAspect#21518044, productGroup#21518045], false
(13) Repartition
Arguments: 25, true
(14) Join
Arguments: LeftOuter, (product#21517975 = internalUUID#21518035)
(15) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, systemId#21518034, internalUUID#21518035, id#21518036, displayId#21518037, name#21518038, baseUnitOfMeasure#21518039, unitOfMeasures#21518040, unitOfMeasureConversions#21518041, productionAspect#21518042, salesAspect#21518043, procurementAspect#21518044, productGroup#21518045, filter(unitOfMeasureConversions#21518041, lambdafunction((((lambda u#21518048.measurementUnit1.code = productPlant#21517989.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#21518048.measurementUnit1.internalRefUUID = productPlant#21517989.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#21518048.measurementUnit2.code = baseUnitOfMeasure#21518039.code) AND (lambda u#21518048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#21518039.internalRefUUID))), lambda u#21518048, false)) AS filteredUnitOfMeasureConversions#21518047]
(16) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518047.quantityNumerator), true, [quantityNumerator#21518055]
(17) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, systemId#21518034, internalUUID#21518035, id#21518036, displayId#21518037, name#21518038, baseUnitOfMeasure#21518039, unitOfMeasures#21518040, unitOfMeasureConversions#21518041, productionAspect#21518042, salesAspect#21518043, procurementAspect#21518044, productGroup#21518045, filteredUnitOfMeasureConversions#21518047, quantityNumerator#21518055]
(18) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518047.quantityDenominator), true, [quantityDenominator#21518058]
(19) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, systemId#21518034, internalUUID#21518035, id#21518036, displayId#21518037, name#21518038, baseUnitOfMeasure#21518039, unitOfMeasures#21518040, unitOfMeasureConversions#21518041, productionAspect#21518042, salesAspect#21518043, procurementAspect#21518044, productGroup#21518045, filteredUnitOfMeasureConversions#21518047, quantityNumerator#21518055, quantityDenominator#21518058]
(20) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, systemId#21518034, internalUUID#21518035, id#21518036, displayId#21518037, name#21518038, baseUnitOfMeasure#21518039, unitOfMeasures#21518040, unitOfMeasureConversions#21518041, productionAspect#21518042, salesAspect#21518043, procurementAspect#21518044, productGroup#21518045, filteredUnitOfMeasureConversions#21518047, quantityNumerator#21518055, quantityDenominator#21518058, (cast(quantityNumerator#21518055 as double) / cast(quantityDenominator#21518058 as double)) AS outboundUnit#21518059]
(21) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, systemId#21518034, internalUUID#21518035, id#21518036, displayId#21518037, name#21518038, baseUnitOfMeasure#21518039, unitOfMeasures#21518040, unitOfMeasureConversions#21518041, productionAspect#21518042, salesAspect#21518043, procurementAspect#21518044, productGroup#21518045, filteredUnitOfMeasureConversions#21518047, quantityNumerator#21518055, quantityDenominator#21518058, CASE WHEN (isnull(outboundUnit#21518059) OR (outboundUnit#21518059 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#21518059 END AS outboundUnit#21518060]
(22) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, outboundUnit#21518060]
(23) LogicalRelation
Arguments: parquet, [systemId#21518148, internalUUID#21518149, product#21518150, plant#21518151, calculationDateTime#21518152, stockQuantities#21518153], false
(24) Repartition
Arguments: 25, true
(25) LogicalRelation
Arguments: parquet, [marketUnit#21518061, description#21518062, articleHierarchy#21518063, defaultCurrency#21518064, responsibilities#21518065, replenishmentTypes#21518066, distributionCenters#21518067, assignedArticleHierarchyNodes#21518068, minOrderQtySetting#21518069, listingCheck#21518070, odsSelection#21518071, demandProfiles#21518072, constraintProfiles#21518073, optimizationProfiles#21518074, orderGroupSplitProfiles#21518075, supplierMinimumProfiles#21518076, multipleRestrictionProfiles#21518077, preferredUomSource#21518078, handlingOfUnfulfilledDemands#21518079, negligibleQuantitiesThreshold#21518080, eventtype#21518081, minOrderQtySettingInternal#21518082], false
(26) Repartition
Arguments: 25, true
(27) Filter
Arguments: (marketUnit#21518061 <=> SS_Test_1)
(28) Project
Arguments: [marketUnit#21518061, description#21518062, articleHierarchy#21518063, defaultCurrency#21518064, responsibilities#21518065, replenishmentTypes#21518066, distributionCenters#21518067, assignedArticleHierarchyNodes#21518068, minOrderQtySetting#21518069, listingCheck#21518070, odsSelection#21518071, demandProfiles#21518072, constraintProfiles#21518073, optimizationProfiles#21518074, orderGroupSplitProfiles#21518075, supplierMinimumProfiles#21518076, multipleRestrictionProfiles#21518077, preferredUomSource#21518078, handlingOfUnfulfilledDemands#21518079, negligibleQuantitiesThreshold#21518080, eventtype#21518081, minOrderQtySettingInternal#21518082]
(29) Project
Arguments: [distributionCenters#21518067]
(30) Generate
Arguments: explode(distributionCenters#21518067), false, [distributionCenters#21518085]
(31) Project
Arguments: [distributionCenters#21518085]
(32) Generate
Arguments: explode(distributionCenters#21518085.storageLocations), false, [storageLocations#21518092]
(33) Project
Arguments: [distributionCenters#21518085.id AS plantId#21518086, distributionCenters#21518085.internalRefUUID AS plantUuid#21518087, storageLocations#21518092]
(34) Project
Arguments: [plantId#21518086, plantUuid#21518087, storageLocations#21518092.id AS storageLocId#21518093, storageLocations#21518092.internalRefUUID AS storageLocUuid#21518094]
(35) LogicalRelation
Arguments: parquet, [product#21518363, plant#21518364, orderDateTime#21518365, planningStartDateTime#21518366], false
(36) RepartitionByExpression
Arguments: [product#21518363, plant#21518364], 25
(37) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365]
(38) LogicalRelation
Arguments: parquet, [systemId#21518367, internalUUID#21518368, plant#21518369, product#21518370, blockedForReplenishmentStartingFrom#21518371, productionAspect#21518372, salesPlant#21518373, listing#21518374], false
(39) Repartition
Arguments: 25, true
(40) Project
Arguments: [systemId#21518367, internalUUID#21518368, plant#21518369, product#21518370, blockedForReplenishmentStartingFrom#21518371, productionAspect#21518372, salesPlant#21518373, listing#21518374, struct(systemId, systemId#21518367, internalUUID, internalUUID#21518368, plant, plant#21518369, product, product#21518370, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#21518371, productionAspect, productionAspect#21518372, salesPlant, salesPlant#21518373, listing, listing#21518374) AS productPlant#21518375]
(41) Project
Arguments: [productPlant#21518375]
(42) Join
Arguments: LeftOuter, ((product#21518363 <=> productPlant#21518375.product.internalRefUUID) AND (plant#21518364 <=> productPlant#21518375.plant.internalRefUUID))
(43) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365, productPlant#21518375]
(44) LogicalRelation
Arguments: parquet, [systemId#21518376, internalUUID#21518377, id#21518378, displayId#21518379, name#21518380, baseUnitOfMeasure#21518381, unitOfMeasures#21518382, unitOfMeasureConversions#21518383, productionAspect#21518384, salesAspect#21518385, procurementAspect#21518386, productGroup#21518387], false
(45) Repartition
Arguments: 25, true
(46) Join
Arguments: LeftOuter, (product#21518363 = internalUUID#21518377)
(47) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365, productPlant#21518375, systemId#21518376, internalUUID#21518377, id#21518378, displayId#21518379, name#21518380, baseUnitOfMeasure#21518381, unitOfMeasures#21518382, unitOfMeasureConversions#21518383, productionAspect#21518384, salesAspect#21518385, procurementAspect#21518386, productGroup#21518387, filter(unitOfMeasureConversions#21518383, lambdafunction((((lambda u#21518048.measurementUnit1.code = productPlant#21518375.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#21518048.measurementUnit1.internalRefUUID = productPlant#21518375.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#21518048.measurementUnit2.code = baseUnitOfMeasure#21518381.code) AND (lambda u#21518048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#21518381.internalRefUUID))), lambda u#21518048, false)) AS filteredUnitOfMeasureConversions#21518388]
(48) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518388.quantityNumerator), true, [quantityNumerator#21518389]
(49) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365, productPlant#21518375, systemId#21518376, internalUUID#21518377, id#21518378, displayId#21518379, name#21518380, baseUnitOfMeasure#21518381, unitOfMeasures#21518382, unitOfMeasureConversions#21518383, productionAspect#21518384, salesAspect#21518385, procurementAspect#21518386, productGroup#21518387, filteredUnitOfMeasureConversions#21518388, quantityNumerator#21518389]
(50) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518388.quantityDenominator), true, [quantityDenominator#21518390]
(51) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365, productPlant#21518375, systemId#21518376, internalUUID#21518377, id#21518378, displayId#21518379, name#21518380, baseUnitOfMeasure#21518381, unitOfMeasures#21518382, unitOfMeasureConversions#21518383, productionAspect#21518384, salesAspect#21518385, procurementAspect#21518386, productGroup#21518387, filteredUnitOfMeasureConversions#21518388, quantityNumerator#21518389, quantityDenominator#21518390]
(52) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365, productPlant#21518375, systemId#21518376, internalUUID#21518377, id#21518378, displayId#21518379, name#21518380, baseUnitOfMeasure#21518381, unitOfMeasures#21518382, unitOfMeasureConversions#21518383, productionAspect#21518384, salesAspect#21518385, procurementAspect#21518386, productGroup#21518387, filteredUnitOfMeasureConversions#21518388, quantityNumerator#21518389, quantityDenominator#21518390, (cast(quantityNumerator#21518389 as double) / cast(quantityDenominator#21518390 as double)) AS outboundUnit#21518391]
(53) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365, productPlant#21518375, systemId#21518376, internalUUID#21518377, id#21518378, displayId#21518379, name#21518380, baseUnitOfMeasure#21518381, unitOfMeasures#21518382, unitOfMeasureConversions#21518383, productionAspect#21518384, salesAspect#21518385, procurementAspect#21518386, productGroup#21518387, filteredUnitOfMeasureConversions#21518388, quantityNumerator#21518389, quantityDenominator#21518390, CASE WHEN (isnull(outboundUnit#21518391) OR (outboundUnit#21518391 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#21518391 END AS outboundUnit#21518392]
(54) Project
Arguments: [product#21518363, plant#21518364, orderDateTime#21518365, productPlant#21518375, outboundUnit#21518392]
(55) Project
Arguments: [plant#21518364]
(56) Deduplicate
Arguments: [plant#21518364]
(57) Join
Arguments: Inner, (plantUuid#21518087 = plant#21518364)
(58) Project
Arguments: [plantId#21518086, plantUuid#21518087, storageLocId#21518093, storageLocUuid#21518094]
(59) Join
Arguments: Inner, (plant#21518151.internalRefUUID <=> plantUuid#21518087)
(60) Generate
Arguments: explode(filter(stockQuantities#21518153, lambdafunction(((lambda x#21518157.storageLocation.internalRefUuid = storageLocUuid#21518094) AND (lambda x#21518157.storageLocation.Id = storageLocId#21518093)), lambda x#21518157, false))), false, [stockQuantity#21518158]
(61) Project
Arguments: [systemId#21518148, internalUUID#21518149, product#21518150, plant#21518151, calculationDateTime#21518152, stockQuantities#21518153, plantId#21518086, plantUuid#21518087, storageLocId#21518093, storageLocUuid#21518094, stockQuantity#21518158]
(62) Aggregate
Arguments: [plantUuid#21518087, internalUUID#21518149, plant#21518151, product#21518150, systemId#21518148], [plantUuid#21518087, internalUUID#21518149, plant#21518151, product#21518150, systemId#21518148, first(calculationDateTime#21518152, false) AS calculationDateTime#21518159, collect_list(stockQuantity#21518158, 0, 0) AS stockQuantities#21518160]
(63) Project
Arguments: [systemId#21518148, internalUUID#21518149, product#21518150, plant#21518151, calculationDateTime#21518159, stockQuantities#21518160]
(64) Generate
Arguments: explode(stockQuantities#21518160), false, [stockQuantity#21518175]
(65) Project
Arguments: [systemId#21518148, internalUUID#21518149, product#21518150, plant#21518151, calculationDateTime#21518159, stockQuantities#21518160, stockQuantity#21518175]
(66) Project
Arguments: [plant#21518151.id AS plant#21518176, plant#21518151.internalRefUUID AS plantUuid#21518177, product#21518150.id AS product#21518178, product#21518150.internalRefUUID AS productUuid#21518179, calculationDateTime#21518159, stockQuantity#21518175.storagelocation.id AS storageLocId#21518180, stockQuantity#21518175.storagelocation.internalRefUUID AS storageLocUuid#21518181, stockQuantity#21518175.quantity.measure AS quantity#21518182, stockQuantity#21518175.specialStockIndicator.code AS specialStockIndicator#21518183, stockQuantity#21518175.stockType.code AS stockType#21518184]
(67) Filter
Arguments: ((specialStockIndicator#21518183 = ) AND (stockType#21518184 = 01))
(68) LogicalRelation
Arguments: parquet, [product#21518194, plant#21518195, orderDateTime#21518196, planningStartDateTime#21518197], false
(69) RepartitionByExpression
Arguments: [product#21518194, plant#21518195], 25
(70) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196]
(71) LogicalRelation
Arguments: parquet, [systemId#21518198, internalUUID#21518199, plant#21518200, product#21518201, blockedForReplenishmentStartingFrom#21518202, productionAspect#21518203, salesPlant#21518204, listing#21518205], false
(72) Repartition
Arguments: 25, true
(73) Project
Arguments: [systemId#21518198, internalUUID#21518199, plant#21518200, product#21518201, blockedForReplenishmentStartingFrom#21518202, productionAspect#21518203, salesPlant#21518204, listing#21518205, struct(systemId, systemId#21518198, internalUUID, internalUUID#21518199, plant, plant#21518200, product, product#21518201, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#21518202, productionAspect, productionAspect#21518203, salesPlant, salesPlant#21518204, listing, listing#21518205) AS productPlant#21518206]
(74) Project
Arguments: [productPlant#21518206]
(75) Join
Arguments: LeftOuter, ((product#21518194 <=> productPlant#21518206.product.internalRefUUID) AND (plant#21518195 <=> productPlant#21518206.plant.internalRefUUID))
(76) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196, productPlant#21518206]
(77) LogicalRelation
Arguments: parquet, [systemId#21518207, internalUUID#21518208, id#21518209, displayId#21518210, name#21518211, baseUnitOfMeasure#21518212, unitOfMeasures#21518213, unitOfMeasureConversions#21518214, productionAspect#21518215, salesAspect#21518216, procurementAspect#21518217, productGroup#21518218], false
(78) Repartition
Arguments: 25, true
(79) Join
Arguments: LeftOuter, (product#21518194 = internalUUID#21518208)
(80) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196, productPlant#21518206, systemId#21518207, internalUUID#21518208, id#21518209, displayId#21518210, name#21518211, baseUnitOfMeasure#21518212, unitOfMeasures#21518213, unitOfMeasureConversions#21518214, productionAspect#21518215, salesAspect#21518216, procurementAspect#21518217, productGroup#21518218, filter(unitOfMeasureConversions#21518214, lambdafunction((((lambda u#21518048.measurementUnit1.code = productPlant#21518206.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#21518048.measurementUnit1.internalRefUUID = productPlant#21518206.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#21518048.measurementUnit2.code = baseUnitOfMeasure#21518212.code) AND (lambda u#21518048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#21518212.internalRefUUID))), lambda u#21518048, false)) AS filteredUnitOfMeasureConversions#21518219]
(81) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518219.quantityNumerator), true, [quantityNumerator#21518220]
(82) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196, productPlant#21518206, systemId#21518207, internalUUID#21518208, id#21518209, displayId#21518210, name#21518211, baseUnitOfMeasure#21518212, unitOfMeasures#21518213, unitOfMeasureConversions#21518214, productionAspect#21518215, salesAspect#21518216, procurementAspect#21518217, productGroup#21518218, filteredUnitOfMeasureConversions#21518219, quantityNumerator#21518220]
(83) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518219.quantityDenominator), true, [quantityDenominator#21518221]
(84) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196, productPlant#21518206, systemId#21518207, internalUUID#21518208, id#21518209, displayId#21518210, name#21518211, baseUnitOfMeasure#21518212, unitOfMeasures#21518213, unitOfMeasureConversions#21518214, productionAspect#21518215, salesAspect#21518216, procurementAspect#21518217, productGroup#21518218, filteredUnitOfMeasureConversions#21518219, quantityNumerator#21518220, quantityDenominator#21518221]
(85) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196, productPlant#21518206, systemId#21518207, internalUUID#21518208, id#21518209, displayId#21518210, name#21518211, baseUnitOfMeasure#21518212, unitOfMeasures#21518213, unitOfMeasureConversions#21518214, productionAspect#21518215, salesAspect#21518216, procurementAspect#21518217, productGroup#21518218, filteredUnitOfMeasureConversions#21518219, quantityNumerator#21518220, quantityDenominator#21518221, (cast(quantityNumerator#21518220 as double) / cast(quantityDenominator#21518221 as double)) AS outboundUnit#21518222]
(86) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196, productPlant#21518206, systemId#21518207, internalUUID#21518208, id#21518209, displayId#21518210, name#21518211, baseUnitOfMeasure#21518212, unitOfMeasures#21518213, unitOfMeasureConversions#21518214, productionAspect#21518215, salesAspect#21518216, procurementAspect#21518217, productGroup#21518218, filteredUnitOfMeasureConversions#21518219, quantityNumerator#21518220, quantityDenominator#21518221, CASE WHEN (isnull(outboundUnit#21518222) OR (outboundUnit#21518222 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#21518222 END AS outboundUnit#21518223]
(87) Project
Arguments: [product#21518194, plant#21518195, orderDateTime#21518196, productPlant#21518206, outboundUnit#21518223]
(88) Join
Arguments: Inner, ((plantUuid#21518177 = plant#21518195) AND (productUuid#21518179 = product#21518194))
(89) Filter
Arguments: (calculationDateTime#21518159 <= orderDateTime#21518196)
(90) Project
Arguments: [plantUuid#21518177 AS plant#21518227, productUuid#21518179 AS product#21518228, storageLocId#21518180, calculationDateTime#21518159, quantity#21518182]
(91) LogicalRelation
Arguments: parquet, [systemId#21518236, internalUUID#21518237, product#21518238, plant#21518239, calculationDateTime#21518240, stockQuantities#21518241], false
(92) Repartition
Arguments: 25, true
(93) LogicalRelation
Arguments: parquet, [marketUnit#21518242, description#21518243, articleHierarchy#21518244, defaultCurrency#21518245, responsibilities#21518246, replenishmentTypes#21518247, distributionCenters#21518248, assignedArticleHierarchyNodes#21518249, minOrderQtySetting#21518250, listingCheck#21518251, odsSelection#21518252, demandProfiles#21518253, constraintProfiles#21518254, optimizationProfiles#21518255, orderGroupSplitProfiles#21518256, supplierMinimumProfiles#21518257, multipleRestrictionProfiles#21518258, preferredUomSource#21518259, handlingOfUnfulfilledDemands#21518260, negligibleQuantitiesThreshold#21518261, eventtype#21518262, minOrderQtySettingInternal#21518263], false
(94) Repartition
Arguments: 25, true
(95) Filter
Arguments: (marketUnit#21518242 <=> SS_Test_1)
(96) Project
Arguments: [marketUnit#21518242, description#21518243, articleHierarchy#21518244, defaultCurrency#21518245, responsibilities#21518246, replenishmentTypes#21518247, distributionCenters#21518248, assignedArticleHierarchyNodes#21518249, minOrderQtySetting#21518250, listingCheck#21518251, odsSelection#21518252, demandProfiles#21518253, constraintProfiles#21518254, optimizationProfiles#21518255, orderGroupSplitProfiles#21518256, supplierMinimumProfiles#21518257, multipleRestrictionProfiles#21518258, preferredUomSource#21518259, handlingOfUnfulfilledDemands#21518260, negligibleQuantitiesThreshold#21518261, eventtype#21518262, minOrderQtySettingInternal#21518263]
(97) Project
Arguments: [distributionCenters#21518248]
(98) Generate
Arguments: explode(distributionCenters#21518248), false, [distributionCenters#21518264]
(99) Project
Arguments: [distributionCenters#21518264]
(100) Generate
Arguments: explode(distributionCenters#21518264.storageLocations), false, [storageLocations#21518265]
(101) Project
Arguments: [distributionCenters#21518264.id AS plantId#21518266, distributionCenters#21518264.internalRefUUID AS plantUuid#21518267, storageLocations#21518265]
(102) Project
Arguments: [plantId#21518266, plantUuid#21518267, storageLocations#21518265.id AS storageLocId#21518268, storageLocations#21518265.internalRefUUID AS storageLocUuid#21518269]
(103) LogicalRelation
Arguments: parquet, [product#21518270, plant#21518271, orderDateTime#21518272, planningStartDateTime#21518273], false
(104) RepartitionByExpression
Arguments: [product#21518270, plant#21518271], 25
(105) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272]
(106) LogicalRelation
Arguments: parquet, [systemId#21518274, internalUUID#21518275, plant#21518276, product#21518277, blockedForReplenishmentStartingFrom#21518278, productionAspect#21518279, salesPlant#21518280, listing#21518281], false
(107) Repartition
Arguments: 25, true
(108) Project
Arguments: [systemId#21518274, internalUUID#21518275, plant#21518276, product#21518277, blockedForReplenishmentStartingFrom#21518278, productionAspect#21518279, salesPlant#21518280, listing#21518281, struct(systemId, systemId#21518274, internalUUID, internalUUID#21518275, plant, plant#21518276, product, product#21518277, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#21518278, productionAspect, productionAspect#21518279, salesPlant, salesPlant#21518280, listing, listing#21518281) AS productPlant#21518282]
(109) Project
Arguments: [productPlant#21518282]
(110) Join
Arguments: LeftOuter, ((product#21518270 <=> productPlant#21518282.product.internalRefUUID) AND (plant#21518271 <=> productPlant#21518282.plant.internalRefUUID))
(111) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272, productPlant#21518282]
(112) LogicalRelation
Arguments: parquet, [systemId#21518283, internalUUID#21518284, id#21518285, displayId#21518286, name#21518287, baseUnitOfMeasure#21518288, unitOfMeasures#21518289, unitOfMeasureConversions#21518290, productionAspect#21518291, salesAspect#21518292, procurementAspect#21518293, productGroup#21518294], false
(113) Repartition
Arguments: 25, true
(114) Join
Arguments: LeftOuter, (product#21518270 = internalUUID#21518284)
(115) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272, productPlant#21518282, systemId#21518283, internalUUID#21518284, id#21518285, displayId#21518286, name#21518287, baseUnitOfMeasure#21518288, unitOfMeasures#21518289, unitOfMeasureConversions#21518290, productionAspect#21518291, salesAspect#21518292, procurementAspect#21518293, productGroup#21518294, filter(unitOfMeasureConversions#21518290, lambdafunction((((lambda u#21518048.measurementUnit1.code = productPlant#21518282.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#21518048.measurementUnit1.internalRefUUID = productPlant#21518282.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#21518048.measurementUnit2.code = baseUnitOfMeasure#21518288.code) AND (lambda u#21518048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#21518288.internalRefUUID))), lambda u#21518048, false)) AS filteredUnitOfMeasureConversions#21518295]
(116) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518295.quantityNumerator), true, [quantityNumerator#21518296]
(117) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272, productPlant#21518282, systemId#21518283, internalUUID#21518284, id#21518285, displayId#21518286, name#21518287, baseUnitOfMeasure#21518288, unitOfMeasures#21518289, unitOfMeasureConversions#21518290, productionAspect#21518291, salesAspect#21518292, procurementAspect#21518293, productGroup#21518294, filteredUnitOfMeasureConversions#21518295, quantityNumerator#21518296]
(118) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518295.quantityDenominator), true, [quantityDenominator#21518297]
(119) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272, productPlant#21518282, systemId#21518283, internalUUID#21518284, id#21518285, displayId#21518286, name#21518287, baseUnitOfMeasure#21518288, unitOfMeasures#21518289, unitOfMeasureConversions#21518290, productionAspect#21518291, salesAspect#21518292, procurementAspect#21518293, productGroup#21518294, filteredUnitOfMeasureConversions#21518295, quantityNumerator#21518296, quantityDenominator#21518297]
(120) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272, productPlant#21518282, systemId#21518283, internalUUID#21518284, id#21518285, displayId#21518286, name#21518287, baseUnitOfMeasure#21518288, unitOfMeasures#21518289, unitOfMeasureConversions#21518290, productionAspect#21518291, salesAspect#21518292, procurementAspect#21518293, productGroup#21518294, filteredUnitOfMeasureConversions#21518295, quantityNumerator#21518296, quantityDenominator#21518297, (cast(quantityNumerator#21518296 as double) / cast(quantityDenominator#21518297 as double)) AS outboundUnit#21518298]
(121) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272, productPlant#21518282, systemId#21518283, internalUUID#21518284, id#21518285, displayId#21518286, name#21518287, baseUnitOfMeasure#21518288, unitOfMeasures#21518289, unitOfMeasureConversions#21518290, productionAspect#21518291, salesAspect#21518292, procurementAspect#21518293, productGroup#21518294, filteredUnitOfMeasureConversions#21518295, quantityNumerator#21518296, quantityDenominator#21518297, CASE WHEN (isnull(outboundUnit#21518298) OR (outboundUnit#21518298 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#21518298 END AS outboundUnit#21518299]
(122) Project
Arguments: [product#21518270, plant#21518271, orderDateTime#21518272, productPlant#21518282, outboundUnit#21518299]
(123) Project
Arguments: [plant#21518271]
(124) Deduplicate
Arguments: [plant#21518271]
(125) Join
Arguments: Inner, (plantUuid#21518267 = plant#21518271)
(126) Project
Arguments: [plantId#21518266, plantUuid#21518267, storageLocId#21518268, storageLocUuid#21518269]
(127) Join
Arguments: Inner, (plant#21518239.internalRefUUID <=> plantUuid#21518267)
(128) Generate
Arguments: explode(filter(stockQuantities#21518241, lambdafunction(((lambda x#21518157.storageLocation.internalRefUuid = storageLocUuid#21518269) AND (lambda x#21518157.storageLocation.Id = storageLocId#21518268)), lambda x#21518157, false))), false, [stockQuantity#21518300]
(129) Project
Arguments: [systemId#21518236, internalUUID#21518237, product#21518238, plant#21518239, calculationDateTime#21518240, stockQuantities#21518241, plantId#21518266, plantUuid#21518267, storageLocId#21518268, storageLocUuid#21518269, stockQuantity#21518300]
(130) Aggregate
Arguments: [plantUuid#21518267, internalUUID#21518237, plant#21518239, product#21518238, systemId#21518236], [plantUuid#21518267, internalUUID#21518237, plant#21518239, product#21518238, systemId#21518236, first(calculationDateTime#21518240, false) AS calculationDateTime#21518301, collect_list(stockQuantity#21518300, 0, 0) AS stockQuantities#21518302]
(131) Project
Arguments: [systemId#21518236, internalUUID#21518237, product#21518238, plant#21518239, calculationDateTime#21518301, stockQuantities#21518302]
(132) Generate
Arguments: explode(stockQuantities#21518302), false, [stockQuantity#21518303]
(133) Project
Arguments: [systemId#21518236, internalUUID#21518237, product#21518238, plant#21518239, calculationDateTime#21518301, stockQuantities#21518302, stockQuantity#21518303]
(134) Project
Arguments: [plant#21518239.id AS plant#21518304, plant#21518239.internalRefUUID AS plantUuid#21518305, product#21518238.id AS product#21518306, product#21518238.internalRefUUID AS productUuid#21518307, calculationDateTime#21518301, stockQuantity#21518303.storagelocation.id AS storageLocId#21518308, stockQuantity#21518303.storagelocation.internalRefUUID AS storageLocUuid#21518309, stockQuantity#21518303.quantity.measure AS quantity#21518310, stockQuantity#21518303.specialStockIndicator.code AS specialStockIndicator#21518311, stockQuantity#21518303.stockType.code AS stockType#21518312]
(135) Filter
Arguments: ((specialStockIndicator#21518311 = ) AND (stockType#21518312 = 01))
(136) LogicalRelation
Arguments: parquet, [product#21518313, plant#21518314, orderDateTime#21518315, planningStartDateTime#21518316], false
(137) RepartitionByExpression
Arguments: [product#21518313, plant#21518314], 25
(138) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315]
(139) LogicalRelation
Arguments: parquet, [systemId#21518317, internalUUID#21518318, plant#21518319, product#21518320, blockedForReplenishmentStartingFrom#21518321, productionAspect#21518322, salesPlant#21518323, listing#21518324], false
(140) Repartition
Arguments: 25, true
(141) Project
Arguments: [systemId#21518317, internalUUID#21518318, plant#21518319, product#21518320, blockedForReplenishmentStartingFrom#21518321, productionAspect#21518322, salesPlant#21518323, listing#21518324, struct(systemId, systemId#21518317, internalUUID, internalUUID#21518318, plant, plant#21518319, product, product#21518320, blockedForReplenishmentStartingFrom, blockedForReplenishmentStartingFrom#21518321, productionAspect, productionAspect#21518322, salesPlant, salesPlant#21518323, listing, listing#21518324) AS productPlant#21518325]
(142) Project
Arguments: [productPlant#21518325]
(143) Join
Arguments: LeftOuter, ((product#21518313 <=> productPlant#21518325.product.internalRefUUID) AND (plant#21518314 <=> productPlant#21518325.plant.internalRefUUID))
(144) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315, productPlant#21518325]
(145) LogicalRelation
Arguments: parquet, [systemId#21518326, internalUUID#21518327, id#21518328, displayId#21518329, name#21518330, baseUnitOfMeasure#21518331, unitOfMeasures#21518332, unitOfMeasureConversions#21518333, productionAspect#21518334, salesAspect#21518335, procurementAspect#21518336, productGroup#21518337], false
(146) Repartition
Arguments: 25, true
(147) Join
Arguments: LeftOuter, (product#21518313 = internalUUID#21518327)
(148) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315, productPlant#21518325, systemId#21518326, internalUUID#21518327, id#21518328, displayId#21518329, name#21518330, baseUnitOfMeasure#21518331, unitOfMeasures#21518332, unitOfMeasureConversions#21518333, productionAspect#21518334, salesAspect#21518335, procurementAspect#21518336, productGroup#21518337, filter(unitOfMeasureConversions#21518333, lambdafunction((((lambda u#21518048.measurementUnit1.code = productPlant#21518325.productionAspect.productMovementPlants.unitOfIssue.code) AND (lambda u#21518048.measurementUnit1.internalRefUUID = productPlant#21518325.productionAspect.productMovementPlants.unitOfIssue.internalRefUUID)) AND ((lambda u#21518048.measurementUnit2.code = baseUnitOfMeasure#21518331.code) AND (lambda u#21518048.measurementUnit2.internalRefUUID = baseUnitOfMeasure#21518331.internalRefUUID))), lambda u#21518048, false)) AS filteredUnitOfMeasureConversions#21518338]
(149) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518338.quantityNumerator), true, [quantityNumerator#21518339]
(150) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315, productPlant#21518325, systemId#21518326, internalUUID#21518327, id#21518328, displayId#21518329, name#21518330, baseUnitOfMeasure#21518331, unitOfMeasures#21518332, unitOfMeasureConversions#21518333, productionAspect#21518334, salesAspect#21518335, procurementAspect#21518336, productGroup#21518337, filteredUnitOfMeasureConversions#21518338, quantityNumerator#21518339]
(151) Generate
Arguments: explode(filteredUnitOfMeasureConversions#21518338.quantityDenominator), true, [quantityDenominator#21518340]
(152) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315, productPlant#21518325, systemId#21518326, internalUUID#21518327, id#21518328, displayId#21518329, name#21518330, baseUnitOfMeasure#21518331, unitOfMeasures#21518332, unitOfMeasureConversions#21518333, productionAspect#21518334, salesAspect#21518335, procurementAspect#21518336, productGroup#21518337, filteredUnitOfMeasureConversions#21518338, quantityNumerator#21518339, quantityDenominator#21518340]
(153) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315, productPlant#21518325, systemId#21518326, internalUUID#21518327, id#21518328, displayId#21518329, name#21518330, baseUnitOfMeasure#21518331, unitOfMeasures#21518332, unitOfMeasureConversions#21518333, productionAspect#21518334, salesAspect#21518335, procurementAspect#21518336, productGroup#21518337, filteredUnitOfMeasureConversions#21518338, quantityNumerator#21518339, quantityDenominator#21518340, (cast(quantityNumerator#21518339 as double) / cast(quantityDenominator#21518340 as double)) AS outboundUnit#21518341]
(154) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315, productPlant#21518325, systemId#21518326, internalUUID#21518327, id#21518328, displayId#21518329, name#21518330, baseUnitOfMeasure#21518331, unitOfMeasures#21518332, unitOfMeasureConversions#21518333, productionAspect#21518334, salesAspect#21518335, procurementAspect#21518336, productGroup#21518337, filteredUnitOfMeasureConversions#21518338, quantityNumerator#21518339, quantityDenominator#21518340, CASE WHEN (isnull(outboundUnit#21518341) OR (outboundUnit#21518341 <= cast(0 as double))) THEN 1.0 ELSE outboundUnit#21518341 END AS outboundUnit#21518342]
(155) Project
Arguments: [product#21518313, plant#21518314, orderDateTime#21518315, productPlant#21518325, outboundUnit#21518342]
(156) Join
Arguments: Inner, ((plantUuid#21518305 = plant#21518314) AND (productUuid#21518307 = product#21518313))
(157) Filter
Arguments: (calculationDateTime#21518301 <= orderDateTime#21518315)
(158) Project
Arguments: [plantUuid#21518305 AS plant#21518343, productUuid#21518307 AS product#21518344, storageLocId#21518308, calculationDateTime#21518301, quantity#21518310]
(159) Aggregate
Arguments: [plant#21518343, product#21518344, storageLocId#21518308], [plant#21518343, product#21518344, storageLocId#21518308, max(calculationDateTime#21518301) AS max_calc_datetime#21518229]
(160) Join
Arguments: Inner, ((((plant#21518227 <=> plant#21518343) AND (product#21518228 <=> product#21518344)) AND (storageLocId#21518180 <=> storageLocId#21518308)) AND (calculationDateTime#21518159 <=> max_calc_datetime#21518229))
(161) Project
Arguments: [plant#21518227, product#21518228, storageLocId#21518180, calculationDateTime#21518159, quantity#21518182]
(162) Aggregate
Arguments: [product#21518228, plant#21518227], [product#21518228, plant#21518227, sum(quantity#21518182) AS quantitySum#21518353, min(calculationDateTime#21518159) AS minCalculationDateTime#21518354]
(163) Project
Arguments: [product#21518228, plant#21518227, quantitySum#21518353, minCalculationDateTime#21518354, round(quantitySum#21518353, 0) AS roundedQuantitySum#21518362]
(164) Join
Arguments: LeftOuter, ((plant#21517976 = plant#21518227) AND (product#21517975 = product#21518228))
(165) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, outboundUnit#21518060, roundedQuantitySum#21518362, minCalculationDateTime#21518354]
(166) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, outboundUnit#21518060, roundedQuantitySum#21518362, minCalculationDateTime#21518354, CASE WHEN isnotnull(minCalculationDateTime#21518354) THEN minCalculationDateTime#21518354 ELSE orderDateTime#21517977 END AS stockDatetime#21518396]
(167) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, outboundUnit#21518060, roundedQuantitySum#21518362, minCalculationDateTime#21518354, stockDatetime#21518396, CASE WHEN isnotnull(roundedQuantitySum#21518362) THEN array(roundedQuantitySum#21518362) ELSE array(0.0) END AS stockBatchQuantities#21518397]
(168) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, outboundUnit#21518060, roundedQuantitySum#21518362, minCalculationDateTime#21518354, stockDatetime#21518396, stockBatchQuantities#21518397, array(2199-01-01 00:00:00) AS stockBatchShelfLifeEndDatetimes#21518398]
(169) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, outboundUnit#21518060, roundedQuantitySum#21518362, stockDatetime#21518396, stockBatchQuantities#21518397, stockBatchShelfLifeEndDatetimes#21518398]
(170) Project
Arguments: [product#21517975, plant#21517976, orderDateTime#21517977, productPlant#21517989, outboundUnit#21518060, stockDatetime#21518396, stockBatchQuantities#21518397, stockBatchShelfLifeEndDatetimes#21518398]
(171) LogicalRelation
Arguments: parquet, [product#21518399, plant#21518400, demandChannel#21518401, demandStream#21518402, considerVariance#21518403, demandTimeBuckets#21518404, demandPointInTimeStart#21518405, demandPointInTimeEnd#21518406, demandPointInTime#21518407], false
(172) Join
Arguments: LeftOuter, ((plant#21518400 <=> plant#21517976) AND (product#21518399 <=> product#21517975))
(173) Filter
Arguments: (((size(demandTimeBuckets#21518404, true) = 0) OR isnull(demandTimeBuckets#21518404)) AND ((size(demandPointInTime#21518407, true) = 0) OR isnull(demandPointInTime#21518407)))
(174) Project
Arguments: [product#21517975, plant#21517976]
(175) Deduplicate
Arguments: [product#21517975, plant#21517976]
(176) LogicalRelation
Arguments: parquet, [systemId#21519106, internalUUID#21519107, plant#21519108, product#21519109, blockedForReplenishmentStartingFrom#21519110, productionAspect#21519111, salesPlant#21519112, listing#21519113], false
(177) Repartition
Arguments: 25, true
(178) Project
Arguments: [product#21519109.internalRefUUID AS product#21519114, plant#21519108.internalRefUUID AS plant#21519115, product#21519109.id AS productId#21519116, plant#21519108.id AS plantId#21519117]
(179) Join
Arguments: Inner, ((product#21517975 = product#21519114) AND (plant#21517976 = plant#21519115))
(180) Project
Arguments: [product#21517975, plant#21517976, productId#21519116, plantId#21519117]
(181) Project
Arguments: [productId#21519116 AS product#21519123, plantId#21519117 AS plant#21519124]
(182) Project
Arguments: [product#21519123, plant#21519124, array(map(objectType, Product, objectId, product#21519123), map(objectType, Plant, objectId, plant#21519124)) AS anchorObject#21519424]
(183) Project
Arguments: [product#21519123, plant#21519124, anchorObject#21519424, cast(array() as array<map<string,string>>) AS messageVariables#21519425]
(184) Project
Arguments: [product#21519123, plant#21519124, anchorObject#21519424, messageVariables#21519425, array(map(objectType, ReplenishmentRunId, objectId, 10000001651)) AS triggerObject#21519426]
(185) Project
Arguments: [product#21519123, plant#21519124, anchorObject#21519424, messageVariables#21519425, triggerObject#21519426, NEW AS situationStatus#21519427]
(186) Project
Arguments: [product#21519123, plant#21519124, anchorObject#21519424, messageVariables#21519425, triggerObject#21519426, situationStatus#21519427, UNKNOWN_DEMAND_FOR_PRODUCT_LOCATION AS situationType#21519428]
(187) Project
Arguments: [product#21519123, plant#21519124, anchorObject#21519424, messageVariables#21519425, triggerObject#21519426, situationStatus#21519427, situationType#21519428, SS_Test_1 AS marketUnit#21519429]
(188) Project
Arguments: [anchorObject#21519424, messageVariables#21519425, triggerObject#21519426, situationStatus#21519427, situationType#21519428, marketUnit#21519429]
(189) Project
Arguments: [to_json(struct(anchorObject, anchorObject#21519424, messageVariables, messageVariables#21519425, triggerObject, triggerObject#21519426, situationStatus, situationStatus#21519427, situationType, situationType#21519428, marketUnit, marketUnit#21519429), Some(UTC)) AS value#21530261]
(190) Project
Arguments: [cast(value#21530261 as string) AS value#21530262]
(191) Project
Arguments: [value#21530262, array(struct(key, X-Tenant-ID, value, cast(1699186316786241789 as binary)), struct(key, X-Message-ID, value, cast(bf8b0f14-4aa9-4a31-82f0-2ff9859a78cb 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#21530271]