== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (169)
+- Project (168)
+- Project (167)
+- Project (166)
+- Project (165)
+- Filter (164)
+- Project (163)
+- Project (162)
+- Project (161)
+- Project (160)
+- Project (159)
+- Project (158)
+- Project (157)
+- Project (156)
+- Project (155)
+- SubqueryAlias (154)
+- Filter (153)
+- Union (152)
:- Project (46)
: +- Project (45)
: +- Project (44)
: +- Join (43)
: :- Project (33)
: : +- Project (32)
: : +- Generate (31)
: : +- Project (30)
: : +- Join (29)
: : :- Project (6)
: : : +- Filter (5)
: : : +- Filter (4)
: : : +- LogicalRDD (3)
: : +- Deduplicate (28)
: : +- Project (27)
: : +- Filter (26)
: : +- Project (25)
: : +- Project (24)
: : +- Join (23)
: : :- Project (13)
: : : +- Project (12)
: : : +- Generate (11)
: : : +- Project (10)
: : : +- Filter (9)
: : : +- Filter (8)
: : : +- LogicalRDD (7)
: : +- Union (22)
: : :- LocalRelation (14)
: : +- Project (21)
: : +- Project (20)
: : +- Project (19)
: : +- Filter (18)
: : +- RepartitionByExpression (17)
: : +- Filter (16)
: : +- LogicalRelation (15)
: +- Union (42)
: :- LocalRelation (34)
: +- Project (41)
: +- Project (40)
: +- Project (39)
: +- Filter (38)
: +- RepartitionByExpression (37)
: +- Filter (36)
: +- LogicalRelation (35)
+- Project (151)
+- Project (150)
+- Union (149)
:- Project (97)
: +- Filter (96)
: +- Join (95)
: :- Filter (85)
: : +- Project (84)
: : +- Project (83)
: : +- Join (82)
: : :- Project (77)
: : : +- Project (76)
: : : +- Join (75)
: : : :- Project (71)
: : : : +- Project (70)
: : : : +- Join (69)
: : : : :- Project (65)
: : : : : +- Project (64)
: : : : : +- Join (63)
: : : : : :- Project (53)
: : : : : : +- Project (52)
: : : : : : +- Generate (51)
: : : : : : +- Project (50)
: : : : : : +- Filter (49)
: : : : : : +- Filter (48)
: : : : : : +- LogicalRDD (47)
: : : : : +- Union (62)
: : : : : :- LocalRelation (54)
: : : : : +- Project (61)
: : : : : +- Project (60)
: : : : : +- Project (59)
: : : : : +- Filter (58)
: : : : : +- RepartitionByExpression (57)
: : : : : +- Filter (56)
: : : : : +- LogicalRelation (55)
: : : : +- Project (68)
: : : : +- Filter (67)
: : : : +- LogicalRDD (66)
: : : +- Aggregate (74)
: : : +- Filter (73)
: : : +- LogicalRDD (72)
: : +- Aggregate (81)
: : +- Project (80)
: : +- Filter (79)
: : +- LogicalRDD (78)
: +- Project (94)
: +- Union (93)
: :- Project (87)
: : +- LocalRelation (86)
: +- Project (92)
: +- Project (91)
: +- RepartitionByExpression (90)
: +- Filter (89)
: +- LogicalRelation (88)
+- Project (148)
+- Filter (147)
+- Join (146)
:- Filter (136)
: +- Project (135)
: +- Project (134)
: +- Join (133)
: :- Project (128)
: : +- Project (127)
: : +- Join (126)
: : :- Project (122)
: : : +- Project (121)
: : : +- Join (120)
: : : :- Project (116)
: : : : +- Project (115)
: : : : +- Join (114)
: : : : :- Project (104)
: : : : : +- Project (103)
: : : : : +- Generate (102)
: : : : : +- Project (101)
: : : : : +- Filter (100)
: : : : : +- Filter (99)
: : : : : +- LogicalRDD (98)
: : : : +- Union (113)
: : : : :- LocalRelation (105)
: : : : +- Project (112)
: : : : +- Project (111)
: : : : +- Project (110)
: : : : +- Filter (109)
: : : : +- RepartitionByExpression (108)
: : : : +- Filter (107)
: : : : +- LogicalRelation (106)
: : : +- Project (119)
: : : +- Filter (118)
: : : +- LogicalRDD (117)
: : +- Aggregate (125)
: : +- Filter (124)
: : +- LogicalRDD (123)
: +- Aggregate (132)
: +- Project (131)
: +- Filter (130)
: +- LogicalRDD (129)
+- Project (145)
+- Union (144)
:- Project (138)
: +- LocalRelation (137)
+- Project (143)
+- Project (142)
+- RepartitionByExpression (141)
+- Filter (140)
+- LogicalRelation (139)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.kafka010.KafkaSourceProvider@7ebef3cc, [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) LogicalRDD
Arguments: [shardId#752363, orderProposalId#752364L, items#752365, optimizationGroups#752366, isOptimal#752367, lastModified#752368, optimizationInsights#752369], false
(4) Filter
Arguments: shardId#752363 IN (0_1_10000002108)
(5) Filter
Arguments: shardId#752363 IN (0_1_10000002108)
(6) Project
Arguments: [shardId#752363, orderProposalId#752364L, items#752365, optimizationGroups#752366, isOptimal#752367, optimizationInsights#752369]
(7) LogicalRDD
Arguments: [shardId#756682, orderProposalId#756683L, items#756684, optimizationGroups#756685, isOptimal#756686, lastModified#756687, optimizationInsights#756688], false
(8) Filter
Arguments: shardId#756682 IN (0_1_10000002108)
(9) Filter
Arguments: shardId#756682 IN (0_1_10000002108)
(10) Project
Arguments: [shardId#756682, orderProposalId#756683L, items#756684, optimizationGroups#756685, isOptimal#756686, optimizationInsights#756688]
(11) Generate
Arguments: explode(items#756684), false, [item#752874]
(12) Project
Arguments: [shardId#756682, item#752874]
(13) Project
Arguments: [shardId#756682, item#752874.worklistShardItemId AS worklistShardItemId#752875L, item#752874.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#752876, item#752874.qty AS qty#752877]
(14) LocalRelation
Arguments: <empty>, [shardId#753031, worklistShardItemId#753032L, orderProposalId#753033L, orderProposalItemId#753034, orderProposalItemGroupId#753035, originalReplenishmentRunId#753036L, orderProposalHorizonGroupingId#753037L, splitIndicator#753038L, previousOrderProposal#753039L, clusterId#753040L, sequenceId#753041L, sourceOfSupplyUuid#753042, supplierGroup#753043, supplier#753044, subrange#753045, product#753046, plant#753047, purchasingOrg#753048, purchasingGroup#753049, mrpController#753050, orderDateTime#753051, deliveryDateTime#753052, availabilityDateTime#753053, nextAvailabilityDateTime#753054, isFallbackOrderOnly#753055, ... 20 more fields]
(15) LogicalRelation
Arguments: parquet, [orderProposalId#753076L, orderProposalItemId#753077, supplierGroup#753078, supplier#753079, plant#753080, deliveryDateTime#753081, subrange#753082, supplyingPlant#753083, productGroup#753084, product#753085, orderDateTime#753086, availabilityDateTime#753087, nextAvailabilityDateTime#753088, mrpController#753089, sourceOfSupplyUuid#753090, purchasingOrg#753091, purchasingGroup#753092, isFallbackOrderOnly#753093, orderProposalHorizonGroupingId#753094L, splitIndicator#753095L, previousOrderProposal#753096L, clusterId#753097L, sequenceId#753098, worklistShardItemId#753099L, orderProposalItemGroupId#753100, ... 20 more fields], false
(16) Filter
Arguments: (shardId#753120 = 0_1_10000002108)
(17) RepartitionByExpression
Arguments: [worklistShardItemId#753099L], 20
(18) Filter
Arguments: (sequenceId#753098 = 0)
(19) Project
Arguments: [orderProposalId#753076L, orderProposalItemId#753077, supplierGroup#753078, supplier#753079, plant#753080, deliveryDateTime#753081, subrange#753082, supplyingPlant#753083, productGroup#753084, product#753085, orderDateTime#753086, availabilityDateTime#753087, nextAvailabilityDateTime#753088, mrpController#753089, sourceOfSupplyUuid#753090, purchasingOrg#753091, purchasingGroup#753092, isFallbackOrderOnly#753093, orderProposalHorizonGroupingId#753094L, splitIndicator#753095L, previousOrderProposal#753096L, clusterId#753097L, sequenceId#753098, worklistShardItemId#753099L, orderProposalItemGroupId#753100, ... 20 more fields]
(20) Project
Arguments: [shardId#753122, worklistShardItemId#753099L, orderProposalId#753076L, orderProposalItemId#753077, orderProposalItemGroupId#753100, originalReplenishmentRunId#753118L, orderProposalHorizonGroupingId#753094L, splitIndicator#753095L, previousOrderProposal#753096L, clusterId#753097L, sequenceId#753098, sourceOfSupplyUuid#753090, supplierGroup#753078, supplier#753079, subrange#753082, product#753085, plant#753080, purchasingOrg#753091, purchasingGroup#753092, mrpController#753089, orderDateTime#753086, deliveryDateTime#753081, availabilityDateTime#753087, nextAvailabilityDateTime#753088, isFallbackOrderOnly#753093, ... 20 more fields]
(21) Project
Arguments: [shardId#753122, worklistShardItemId#753099L, orderProposalId#753076L, orderProposalItemId#753077, orderProposalItemGroupId#753100, originalReplenishmentRunId#753118L, orderProposalHorizonGroupingId#753094L, splitIndicator#753095L, previousOrderProposal#753096L, clusterId#753097L, cast(sequenceId#753098 as bigint) AS sequenceId#753123L, sourceOfSupplyUuid#753090, supplierGroup#753078, supplier#753079, subrange#753082, product#753085, plant#753080, purchasingOrg#753091, purchasingGroup#753092, mrpController#753089, orderDateTime#753086, deliveryDateTime#753081, availabilityDateTime#753087, nextAvailabilityDateTime#753088, isFallbackOrderOnly#753093, ... 20 more fields]
(22) Union
Arguments: false, false
(23) Join
Arguments: LeftOuter, ((shardId#756682 = shardId#753031) AND (worklistShardItemId#752875L = worklistShardItemId#753032L))
(24) Project
Arguments: [shardId#756682, worklistShardItemId#752875L, quantityAfterProdPlantOptimization#752876, qty#752877, orderProposalId#753033L, orderProposalItemId#753034, orderProposalItemGroupId#753035, originalReplenishmentRunId#753036L, orderProposalHorizonGroupingId#753037L, splitIndicator#753038L, previousOrderProposal#753039L, clusterId#753040L, sequenceId#753041L, sourceOfSupplyUuid#753042, supplierGroup#753043, supplier#753044, subrange#753045, product#753046, plant#753047, purchasingOrg#753048, purchasingGroup#753049, mrpController#753050, orderDateTime#753051, deliveryDateTime#753052, availabilityDateTime#753053, ... 22 more fields]
(25) Project
Arguments: [shardId#756682, worklistShardItemId#752875L, quantityAfterProdPlantOptimization#752876, qty#752877, orderProposalId#753033L, originalReplenishmentRunId#753036L, supplierGroup#753043, supplier#753044, supplyingPlant#753074, productGroup#753075, product#753046, plant#753047, subrange#753045, orderDateTime#753051, deliveryDateTime#753052, availabilityDateTime#753053, nextAvailabilityDateTime#753054, constraintValues#753068, constraintOperators#753066, constraintLabels#753065, logisticUnits#753070, orderQuantityBaseUom#753056, orderQuantityBaseUomUuid#753057, splitIndicator#753038L, netPriceAmount#753061, ... 14 more fields]
(26) Filter
Arguments: NOT (isFallbackOrderOnly#753055 <=> true)
(27) Project
Arguments: [orderProposalId#753033L]
(28) Deduplicate
Arguments: [orderProposalId#753033L]
(29) Join
Arguments: Inner, (orderProposalId#752364L = orderProposalId#753033L)
(30) Project
Arguments: [orderProposalId#752364L, shardId#752363, items#752365, optimizationGroups#752366, isOptimal#752367, optimizationInsights#752369]
(31) Generate
Arguments: explode(optimizationInsights#752369), false, [insight#756690]
(32) Project
Arguments: [shardId#752363, orderProposalId#752364L, insight#756690]
(33) Project
Arguments: [shardId#752363, orderProposalId#752364L, insight#756690.internalInsightType AS internalInsightType#756691, insight#756690.worklistShardItemId AS worklistShardItemId#756692L, insight#756690.thresholdValue AS thresholdValue#756693, insight#756690.reachedValue AS reachedValue#756694, insight#756690.unitOfMeasure AS unitOfMeasure#756695, insight#756690.assignmentDetails AS assignmentDetails#756696]
(34) LocalRelation
Arguments: <empty>, [shardId#757072, worklistShardItemId#757073L, orderProposalId#757074L, orderProposalItemId#757075, orderProposalItemGroupId#757076, originalReplenishmentRunId#757077L, orderProposalHorizonGroupingId#757078L, splitIndicator#757079L, previousOrderProposal#757080L, clusterId#757081L, sequenceId#757082L, sourceOfSupplyUuid#757083, supplierGroup#757084, supplier#757085, subrange#757086, product#757087, plant#757088, purchasingOrg#757089, purchasingGroup#757090, mrpController#757091, orderDateTime#757092, deliveryDateTime#757093, availabilityDateTime#757094, nextAvailabilityDateTime#757095, isFallbackOrderOnly#757096, ... 20 more fields]
(35) LogicalRelation
Arguments: parquet, [orderProposalId#757117L, orderProposalItemId#757118, supplierGroup#757119, supplier#757120, plant#757121, deliveryDateTime#757122, subrange#757123, supplyingPlant#757124, productGroup#757125, product#757126, orderDateTime#757127, availabilityDateTime#757128, nextAvailabilityDateTime#757129, mrpController#757130, sourceOfSupplyUuid#757131, purchasingOrg#757132, purchasingGroup#757133, isFallbackOrderOnly#757134, orderProposalHorizonGroupingId#757135L, splitIndicator#757136L, previousOrderProposal#757137L, clusterId#757138L, sequenceId#757139, worklistShardItemId#757140L, orderProposalItemGroupId#757141, ... 20 more fields], false
(36) Filter
Arguments: (shardId#757161 = 0_1_10000002108)
(37) RepartitionByExpression
Arguments: [worklistShardItemId#757140L], 20
(38) Filter
Arguments: (sequenceId#757139 = 0)
(39) Project
Arguments: [orderProposalId#757117L, orderProposalItemId#757118, supplierGroup#757119, supplier#757120, plant#757121, deliveryDateTime#757122, subrange#757123, supplyingPlant#757124, productGroup#757125, product#757126, orderDateTime#757127, availabilityDateTime#757128, nextAvailabilityDateTime#757129, mrpController#757130, sourceOfSupplyUuid#757131, purchasingOrg#757132, purchasingGroup#757133, isFallbackOrderOnly#757134, orderProposalHorizonGroupingId#757135L, splitIndicator#757136L, previousOrderProposal#757137L, clusterId#757138L, sequenceId#757139, worklistShardItemId#757140L, orderProposalItemGroupId#757141, ... 20 more fields]
(40) Project
Arguments: [shardId#757163, worklistShardItemId#757140L, orderProposalId#757117L, orderProposalItemId#757118, orderProposalItemGroupId#757141, originalReplenishmentRunId#757159L, orderProposalHorizonGroupingId#757135L, splitIndicator#757136L, previousOrderProposal#757137L, clusterId#757138L, sequenceId#757139, sourceOfSupplyUuid#757131, supplierGroup#757119, supplier#757120, subrange#757123, product#757126, plant#757121, purchasingOrg#757132, purchasingGroup#757133, mrpController#757130, orderDateTime#757127, deliveryDateTime#757122, availabilityDateTime#757128, nextAvailabilityDateTime#757129, isFallbackOrderOnly#757134, ... 20 more fields]
(41) Project
Arguments: [shardId#757163, worklistShardItemId#757140L, orderProposalId#757117L, orderProposalItemId#757118, orderProposalItemGroupId#757141, originalReplenishmentRunId#757159L, orderProposalHorizonGroupingId#757135L, splitIndicator#757136L, previousOrderProposal#757137L, clusterId#757138L, cast(sequenceId#757139 as bigint) AS sequenceId#757164L, sourceOfSupplyUuid#757131, supplierGroup#757119, supplier#757120, subrange#757123, product#757126, plant#757121, purchasingOrg#757132, purchasingGroup#757133, mrpController#757130, orderDateTime#757127, deliveryDateTime#757122, availabilityDateTime#757128, nextAvailabilityDateTime#757129, isFallbackOrderOnly#757134, ... 20 more fields]
(42) Union
Arguments: false, false
(43) Join
Arguments: LeftOuter, ((shardId#752363 = shardId#757072) AND (worklistShardItemId#756692L = worklistShardItemId#757073L))
(44) Project
Arguments: [shardId#752363, worklistShardItemId#756692L, orderProposalId#752364L, internalInsightType#756691, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, orderProposalId#757074L, orderProposalItemId#757075, orderProposalItemGroupId#757076, originalReplenishmentRunId#757077L, orderProposalHorizonGroupingId#757078L, splitIndicator#757079L, previousOrderProposal#757080L, clusterId#757081L, sequenceId#757082L, sourceOfSupplyUuid#757083, supplierGroup#757084, supplier#757085, subrange#757086, product#757087, plant#757088, purchasingOrg#757089, purchasingGroup#757090, ... 26 more fields]
(45) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, supplier#757085]
(46) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, supplier#757085, null AS businessContext#757469, null AS configurationVersion#757470]
(47) LogicalRDD
Arguments: [shardId#757356, orderProposalId#757357L, items#757358, optimizationGroups#757359, isOptimal#757360, lastModified#757361, optimizationInsights#757362], false
(48) Filter
Arguments: shardId#757356 IN (0_1_10000002108)
(49) Filter
Arguments: shardId#757356 IN (0_1_10000002108)
(50) Project
Arguments: [shardId#757356, orderProposalId#757357L, items#757358, optimizationGroups#757359, isOptimal#757360, optimizationInsights#757362]
(51) Generate
Arguments: explode(items#757358), false, [item#757363]
(52) Project
Arguments: [shardId#757356, item#757363]
(53) Project
Arguments: [shardId#757356, item#757363.worklistShardItemId AS worklistShardItemId#757364L, item#757363.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#757365, item#757363.qty AS qty#757366]
(54) LocalRelation
Arguments: <empty>, [shardId#757367, worklistShardItemId#757368L, orderProposalId#757369L, orderProposalItemId#757370, orderProposalItemGroupId#757371, originalReplenishmentRunId#757372L, orderProposalHorizonGroupingId#757373L, splitIndicator#757374L, previousOrderProposal#757375L, clusterId#757376L, sequenceId#757377L, sourceOfSupplyUuid#757378, supplierGroup#757379, supplier#757380, subrange#757381, product#757382, plant#757383, purchasingOrg#757384, purchasingGroup#757385, mrpController#757386, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, isFallbackOrderOnly#757391, ... 20 more fields]
(55) LogicalRelation
Arguments: parquet, [orderProposalId#757412L, orderProposalItemId#757413, supplierGroup#757414, supplier#757415, plant#757416, deliveryDateTime#757417, subrange#757418, supplyingPlant#757419, productGroup#757420, product#757421, orderDateTime#757422, availabilityDateTime#757423, nextAvailabilityDateTime#757424, mrpController#757425, sourceOfSupplyUuid#757426, purchasingOrg#757427, purchasingGroup#757428, isFallbackOrderOnly#757429, orderProposalHorizonGroupingId#757430L, splitIndicator#757431L, previousOrderProposal#757432L, clusterId#757433L, sequenceId#757434, worklistShardItemId#757435L, orderProposalItemGroupId#757436, ... 20 more fields], false
(56) Filter
Arguments: (shardId#757456 = 0_1_10000002108)
(57) RepartitionByExpression
Arguments: [worklistShardItemId#757435L], 20
(58) Filter
Arguments: (sequenceId#757434 = 0)
(59) Project
Arguments: [orderProposalId#757412L, orderProposalItemId#757413, supplierGroup#757414, supplier#757415, plant#757416, deliveryDateTime#757417, subrange#757418, supplyingPlant#757419, productGroup#757420, product#757421, orderDateTime#757422, availabilityDateTime#757423, nextAvailabilityDateTime#757424, mrpController#757425, sourceOfSupplyUuid#757426, purchasingOrg#757427, purchasingGroup#757428, isFallbackOrderOnly#757429, orderProposalHorizonGroupingId#757430L, splitIndicator#757431L, previousOrderProposal#757432L, clusterId#757433L, sequenceId#757434, worklistShardItemId#757435L, orderProposalItemGroupId#757436, ... 20 more fields]
(60) Project
Arguments: [shardId#757457, worklistShardItemId#757435L, orderProposalId#757412L, orderProposalItemId#757413, orderProposalItemGroupId#757436, originalReplenishmentRunId#757454L, orderProposalHorizonGroupingId#757430L, splitIndicator#757431L, previousOrderProposal#757432L, clusterId#757433L, sequenceId#757434, sourceOfSupplyUuid#757426, supplierGroup#757414, supplier#757415, subrange#757418, product#757421, plant#757416, purchasingOrg#757427, purchasingGroup#757428, mrpController#757425, orderDateTime#757422, deliveryDateTime#757417, availabilityDateTime#757423, nextAvailabilityDateTime#757424, isFallbackOrderOnly#757429, ... 20 more fields]
(61) Project
Arguments: [shardId#757457, worklistShardItemId#757435L, orderProposalId#757412L, orderProposalItemId#757413, orderProposalItemGroupId#757436, originalReplenishmentRunId#757454L, orderProposalHorizonGroupingId#757430L, splitIndicator#757431L, previousOrderProposal#757432L, clusterId#757433L, cast(sequenceId#757434 as bigint) AS sequenceId#757458L, sourceOfSupplyUuid#757426, supplierGroup#757414, supplier#757415, subrange#757418, product#757421, plant#757416, purchasingOrg#757427, purchasingGroup#757428, mrpController#757425, orderDateTime#757422, deliveryDateTime#757417, availabilityDateTime#757423, nextAvailabilityDateTime#757424, isFallbackOrderOnly#757429, ... 20 more fields]
(62) Union
Arguments: false, false
(63) Join
Arguments: LeftOuter, ((shardId#757356 = shardId#757367) AND (worklistShardItemId#757364L = worklistShardItemId#757368L))
(64) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, orderProposalItemId#757370, orderProposalItemGroupId#757371, originalReplenishmentRunId#757372L, orderProposalHorizonGroupingId#757373L, splitIndicator#757374L, previousOrderProposal#757375L, clusterId#757376L, sequenceId#757377L, sourceOfSupplyUuid#757378, supplierGroup#757379, supplier#757380, subrange#757381, product#757382, plant#757383, purchasingOrg#757384, purchasingGroup#757385, mrpController#757386, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, ... 22 more fields]
(65) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, originalReplenishmentRunId#757372L, supplierGroup#757379, supplier#757380, supplyingPlant#757410, productGroup#757411, product#757382, plant#757383, subrange#757381, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, constraintValues#757404, constraintOperators#757402, constraintLabels#757401, logisticUnits#757406, orderQuantityBaseUom#757392, orderQuantityBaseUomUuid#757393, splitIndicator#757374L, netPriceAmount#757397, ... 14 more fields]
(66) LogicalRDD
Arguments: [shardId#753772, worklistShardItemId#753773L, qty#753774, demandChannel#753775, demandStream#753776, kpis#753777], false
(67) Filter
Arguments: ((isnull(qty#753774) AND isnull(demandChannel#753775)) AND isnull(demandStream#753776))
(68) Project
Arguments: [shardId#753772, worklistShardItemId#753773L, coalesce(kpis#753777, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#753778]
(69) Join
Arguments: LeftOuter, ((shardId#757356 = shardId#753772) AND (worklistShardItemId#757364L = worklistShardItemId#753773L))
(70) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, originalReplenishmentRunId#757372L, supplierGroup#757379, supplier#757380, supplyingPlant#757410, productGroup#757411, product#757382, plant#757383, subrange#757381, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, constraintValues#757404, constraintOperators#757402, constraintLabels#757401, logisticUnits#757406, orderQuantityBaseUom#757392, orderQuantityBaseUomUuid#757393, splitIndicator#757374L, netPriceAmount#757397, ... 15 more fields]
(71) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, originalReplenishmentRunId#757372L, supplierGroup#757379, supplier#757380, supplyingPlant#757410, productGroup#757411, product#757382, plant#757383, subrange#757381, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, constraintValues#757404, constraintOperators#757402, constraintLabels#757401, logisticUnits#757406, orderQuantityBaseUom#757392, orderQuantityBaseUomUuid#757393, splitIndicator#757374L, netPriceAmount#757397, ... 15 more fields]
(72) LogicalRDD
Arguments: [shardId#753788, worklistShardItemId#753789L, qty#753790, demandChannel#753791, demandStream#753792, kpis#753793], false
(73) Filter
Arguments: (((isnull(qty#753790) AND isnotnull(demandChannel#753791)) AND isnotnull(demandStream#753792)) AND (size(kpis#753793, true) > 0))
(74) Aggregate
Arguments: [shardId#753788, worklistShardItemId#753789L], [shardId#753788, worklistShardItemId#753789L, collect_list(struct(demandChannel, demandChannel#753791, demandStream, demandStream#753792, kpis, kpis#753793), 0, 0) AS channelStreamSpecificKpis#753780]
(75) Join
Arguments: LeftOuter, ((shardId#757356 = shardId#753788) AND (worklistShardItemId#757364L = worklistShardItemId#753789L))
(76) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, originalReplenishmentRunId#757372L, supplierGroup#757379, supplier#757380, supplyingPlant#757410, productGroup#757411, product#757382, plant#757383, subrange#757381, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, constraintValues#757404, constraintOperators#757402, constraintLabels#757401, logisticUnits#757406, orderQuantityBaseUom#757392, orderQuantityBaseUomUuid#757393, splitIndicator#757374L, netPriceAmount#757397, ... 16 more fields]
(77) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, originalReplenishmentRunId#757372L, supplierGroup#757379, supplier#757380, supplyingPlant#757410, productGroup#757411, product#757382, plant#757383, subrange#757381, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, constraintValues#757404, constraintOperators#757402, constraintLabels#757401, logisticUnits#757406, orderQuantityBaseUom#757392, orderQuantityBaseUomUuid#757393, splitIndicator#757374L, netPriceAmount#757397, ... 16 more fields]
(78) LogicalRDD
Arguments: [shardId#753801, worklistShardItemId#753802L, qty#753803, demandChannel#753804, demandStream#753805, kpis#753806], false
(79) Filter
Arguments: (isnotnull(qty#753803) AND isnotnull(kpis#753806))
(80) Project
Arguments: [shardId#753801, worklistShardItemId#753802L, qty#753803, kpis#753806]
(81) Aggregate
Arguments: [shardId#753801, worklistShardItemId#753802L], [shardId#753801, worklistShardItemId#753802L, map_from_entries(collect_list(struct(qty, qty#753803, kpis, kpis#753806), 0, 0)) AS quantityKpis#753795]
(82) Join
Arguments: LeftOuter, ((shardId#757356 = shardId#753801) AND (worklistShardItemId#757364L = worklistShardItemId#753802L))
(83) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, originalReplenishmentRunId#757372L, supplierGroup#757379, supplier#757380, supplyingPlant#757410, productGroup#757411, product#757382, plant#757383, subrange#757381, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, constraintValues#757404, constraintOperators#757402, constraintLabels#757401, logisticUnits#757406, orderQuantityBaseUom#757392, orderQuantityBaseUomUuid#757393, splitIndicator#757374L, netPriceAmount#757397, ... 17 more fields]
(84) Project
Arguments: [shardId#757356, worklistShardItemId#757364L, quantityAfterProdPlantOptimization#757365, qty#757366, orderProposalId#757369L, originalReplenishmentRunId#757372L, supplierGroup#757379, supplier#757380, supplyingPlant#757410, productGroup#757411, product#757382, plant#757383, subrange#757381, orderDateTime#757387, deliveryDateTime#757388, availabilityDateTime#757389, nextAvailabilityDateTime#757390, constraintValues#757404, constraintOperators#757402, constraintLabels#757401, logisticUnits#757406, orderQuantityBaseUom#757392, orderQuantityBaseUomUuid#757393, splitIndicator#757374L, netPriceAmount#757397, ... 17 more fields]
(85) Filter
Arguments: NOT (isFallbackOrderOnly#757391 <=> true)
(86) LocalRelation
Arguments: <empty>, [shardId#757165, uomCategories#757166]
(87) Project
Arguments: [shardId#757165, uomCategories#757166, null AS insightConfigurations#757172]
(88) LogicalRelation
Arguments: parquet, [uomCategories#757167, insightConfigurations#757168, shardId#757169], false
(89) Filter
Arguments: (shardId#757169 = 0_1_10000002108)
(90) RepartitionByExpression
Arguments: 20
(91) Project
Arguments: [uomCategories#757167, insightConfigurations#757168, 0_1_10000002108 AS shardId#757171]
(92) Project
Arguments: [shardId#757171, uomCategories#757167, insightConfigurations#757168]
(93) Union
Arguments: false, false
(94) Project
Arguments: [insightConfigurations#757172]
(95) Join
Arguments: Cross
(96) Filter
Arguments: (((isnotnull(insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD]) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#753779, lambdafunction((lambda x_1999#757173.label = OutOfStockProbability), lambda x_1999#757173, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2000#757174.name = OOS_PROBABILITY_THRESHOLD), lambda x_2000#757174, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#753779, lambdafunction((lambda x_1999#757175.label = OutOfStockProbability), lambda x_1999#757175, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2000#757176.name = OOS_PROBABILITY_THRESHOLD), lambda x_2000#757176, false)), 1, None, false).value as double)) END) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#753779, lambdafunction((lambda x_2001#757177.label = InitialStockQty), lambda x_2001#757177, false)), 1, None, false).value) OR isnull(CASE WHEN cast(element_at(filter(insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2002#757178.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_2002#757178, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END)) THEN false ELSE (element_at(filter(prodLocSpecificKpis#753779, lambdafunction((lambda x_2001#757179.label = InitialStockQty), lambda x_2001#757179, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2002#757180.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_2002#757180, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (isnull(CASE WHEN isnull(orderDateTime#757387) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#757387, yyyy-MM-dd HH:mm:ss, Some(UTC), false) - unix_timestamp(current_timestamp(), yyyy-MM-dd HH:mm:ss, Some(UTC), false)) as double) / cast(3600.0 as double)) END) OR isnull(cast(element_at(filter(insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2003#757181.name = OFFSET_CURRENT_ORDER_DATE), lambda x_2003#757181, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#757387) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#757387, yyyy-MM-dd HH:mm:ss, Some(UTC), false) - unix_timestamp(current_timestamp(), yyyy-MM-dd HH:mm:ss, Some(UTC), false)) as double) / cast(3600.0 as double)) END >= cast(element_at(filter(insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2003#757182.name = OFFSET_CURRENT_ORDER_DATE), lambda x_2003#757182, false)), 1, None, false).value as double)) END)
(97) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#757369L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#757370 as string)), struct(name, PRODUCT, value, cast(externalProductId#757408 as string)), struct(name, PLANT, value, cast(externalPlantId#757409 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#757387 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(prodLocSpecificKpis#753779, lambdafunction((lambda x_2004#757198.label = UnfulfilledDemandQty), lambda x_2004#757198, false)), 1, None, false).value as string))) AS businessContext#757195, POTENTIAL_OOS_STOCK_PERIOD AS internalInsightType#757196, insightConfigurations#757172[POTENTIAL_OOS_STOCK_PERIOD].configurationVersion AS configurationVersion#757197]
(98) LogicalRDD
Arguments: [shardId#757219, orderProposalId#757220L, items#757221, optimizationGroups#757222, isOptimal#757223, lastModified#757224, optimizationInsights#757225], false
(99) Filter
Arguments: shardId#757219 IN (0_1_10000002108)
(100) Filter
Arguments: shardId#757219 IN (0_1_10000002108)
(101) Project
Arguments: [shardId#757219, orderProposalId#757220L, items#757221, optimizationGroups#757222, isOptimal#757223, optimizationInsights#757225]
(102) Generate
Arguments: explode(items#757221), false, [item#757226]
(103) Project
Arguments: [shardId#757219, item#757226]
(104) Project
Arguments: [shardId#757219, item#757226.worklistShardItemId AS worklistShardItemId#757227L, item#757226.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#757228, item#757226.qty AS qty#757229]
(105) LocalRelation
Arguments: <empty>, [shardId#757230, worklistShardItemId#757231L, orderProposalId#757232L, orderProposalItemId#757233, orderProposalItemGroupId#757234, originalReplenishmentRunId#757235L, orderProposalHorizonGroupingId#757236L, splitIndicator#757237L, previousOrderProposal#757238L, clusterId#757239L, sequenceId#757240L, sourceOfSupplyUuid#757241, supplierGroup#757242, supplier#757243, subrange#757244, product#757245, plant#757246, purchasingOrg#757247, purchasingGroup#757248, mrpController#757249, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, isFallbackOrderOnly#757254, ... 20 more fields]
(106) LogicalRelation
Arguments: parquet, [orderProposalId#757275L, orderProposalItemId#757276, supplierGroup#757277, supplier#757278, plant#757279, deliveryDateTime#757280, subrange#757281, supplyingPlant#757282, productGroup#757283, product#757284, orderDateTime#757285, availabilityDateTime#757286, nextAvailabilityDateTime#757287, mrpController#757288, sourceOfSupplyUuid#757289, purchasingOrg#757290, purchasingGroup#757291, isFallbackOrderOnly#757292, orderProposalHorizonGroupingId#757293L, splitIndicator#757294L, previousOrderProposal#757295L, clusterId#757296L, sequenceId#757297, worklistShardItemId#757298L, orderProposalItemGroupId#757299, ... 20 more fields], false
(107) Filter
Arguments: (shardId#757319 = 0_1_10000002108)
(108) RepartitionByExpression
Arguments: [worklistShardItemId#757298L], 20
(109) Filter
Arguments: (sequenceId#757297 = 0)
(110) Project
Arguments: [orderProposalId#757275L, orderProposalItemId#757276, supplierGroup#757277, supplier#757278, plant#757279, deliveryDateTime#757280, subrange#757281, supplyingPlant#757282, productGroup#757283, product#757284, orderDateTime#757285, availabilityDateTime#757286, nextAvailabilityDateTime#757287, mrpController#757288, sourceOfSupplyUuid#757289, purchasingOrg#757290, purchasingGroup#757291, isFallbackOrderOnly#757292, orderProposalHorizonGroupingId#757293L, splitIndicator#757294L, previousOrderProposal#757295L, clusterId#757296L, sequenceId#757297, worklistShardItemId#757298L, orderProposalItemGroupId#757299, ... 20 more fields]
(111) Project
Arguments: [shardId#757320, worklistShardItemId#757298L, orderProposalId#757275L, orderProposalItemId#757276, orderProposalItemGroupId#757299, originalReplenishmentRunId#757317L, orderProposalHorizonGroupingId#757293L, splitIndicator#757294L, previousOrderProposal#757295L, clusterId#757296L, sequenceId#757297, sourceOfSupplyUuid#757289, supplierGroup#757277, supplier#757278, subrange#757281, product#757284, plant#757279, purchasingOrg#757290, purchasingGroup#757291, mrpController#757288, orderDateTime#757285, deliveryDateTime#757280, availabilityDateTime#757286, nextAvailabilityDateTime#757287, isFallbackOrderOnly#757292, ... 20 more fields]
(112) Project
Arguments: [shardId#757320, worklistShardItemId#757298L, orderProposalId#757275L, orderProposalItemId#757276, orderProposalItemGroupId#757299, originalReplenishmentRunId#757317L, orderProposalHorizonGroupingId#757293L, splitIndicator#757294L, previousOrderProposal#757295L, clusterId#757296L, cast(sequenceId#757297 as bigint) AS sequenceId#757321L, sourceOfSupplyUuid#757289, supplierGroup#757277, supplier#757278, subrange#757281, product#757284, plant#757279, purchasingOrg#757290, purchasingGroup#757291, mrpController#757288, orderDateTime#757285, deliveryDateTime#757280, availabilityDateTime#757286, nextAvailabilityDateTime#757287, isFallbackOrderOnly#757292, ... 20 more fields]
(113) Union
Arguments: false, false
(114) Join
Arguments: LeftOuter, ((shardId#757219 = shardId#757230) AND (worklistShardItemId#757227L = worklistShardItemId#757231L))
(115) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, orderProposalItemId#757233, orderProposalItemGroupId#757234, originalReplenishmentRunId#757235L, orderProposalHorizonGroupingId#757236L, splitIndicator#757237L, previousOrderProposal#757238L, clusterId#757239L, sequenceId#757240L, sourceOfSupplyUuid#757241, supplierGroup#757242, supplier#757243, subrange#757244, product#757245, plant#757246, purchasingOrg#757247, purchasingGroup#757248, mrpController#757249, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, ... 22 more fields]
(116) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, originalReplenishmentRunId#757235L, supplierGroup#757242, supplier#757243, supplyingPlant#757273, productGroup#757274, product#757245, plant#757246, subrange#757244, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, constraintValues#757267, constraintOperators#757265, constraintLabels#757264, logisticUnits#757269, orderQuantityBaseUom#757255, orderQuantityBaseUomUuid#757256, splitIndicator#757237L, netPriceAmount#757260, ... 14 more fields]
(117) LogicalRDD
Arguments: [shardId#757322, worklistShardItemId#757323L, qty#757324, demandChannel#757325, demandStream#757326, kpis#757327], false
(118) Filter
Arguments: ((isnull(qty#757324) AND isnull(demandChannel#757325)) AND isnull(demandStream#757326))
(119) Project
Arguments: [shardId#757322, worklistShardItemId#757323L, coalesce(kpis#757327, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#757328]
(120) Join
Arguments: LeftOuter, ((shardId#757219 = shardId#757322) AND (worklistShardItemId#757227L = worklistShardItemId#757323L))
(121) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, originalReplenishmentRunId#757235L, supplierGroup#757242, supplier#757243, supplyingPlant#757273, productGroup#757274, product#757245, plant#757246, subrange#757244, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, constraintValues#757267, constraintOperators#757265, constraintLabels#757264, logisticUnits#757269, orderQuantityBaseUom#757255, orderQuantityBaseUomUuid#757256, splitIndicator#757237L, netPriceAmount#757260, ... 15 more fields]
(122) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, originalReplenishmentRunId#757235L, supplierGroup#757242, supplier#757243, supplyingPlant#757273, productGroup#757274, product#757245, plant#757246, subrange#757244, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, constraintValues#757267, constraintOperators#757265, constraintLabels#757264, logisticUnits#757269, orderQuantityBaseUom#757255, orderQuantityBaseUomUuid#757256, splitIndicator#757237L, netPriceAmount#757260, ... 15 more fields]
(123) LogicalRDD
Arguments: [shardId#757330, worklistShardItemId#757331L, qty#757332, demandChannel#757333, demandStream#757334, kpis#757335], false
(124) Filter
Arguments: (((isnull(qty#757332) AND isnotnull(demandChannel#757333)) AND isnotnull(demandStream#757334)) AND (size(kpis#757335, true) > 0))
(125) Aggregate
Arguments: [shardId#757330, worklistShardItemId#757331L], [shardId#757330, worklistShardItemId#757331L, collect_list(struct(demandChannel, demandChannel#757333, demandStream, demandStream#757334, kpis, kpis#757335), 0, 0) AS channelStreamSpecificKpis#757336]
(126) Join
Arguments: LeftOuter, ((shardId#757219 = shardId#757330) AND (worklistShardItemId#757227L = worklistShardItemId#757331L))
(127) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, originalReplenishmentRunId#757235L, supplierGroup#757242, supplier#757243, supplyingPlant#757273, productGroup#757274, product#757245, plant#757246, subrange#757244, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, constraintValues#757267, constraintOperators#757265, constraintLabels#757264, logisticUnits#757269, orderQuantityBaseUom#757255, orderQuantityBaseUomUuid#757256, splitIndicator#757237L, netPriceAmount#757260, ... 16 more fields]
(128) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, originalReplenishmentRunId#757235L, supplierGroup#757242, supplier#757243, supplyingPlant#757273, productGroup#757274, product#757245, plant#757246, subrange#757244, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, constraintValues#757267, constraintOperators#757265, constraintLabels#757264, logisticUnits#757269, orderQuantityBaseUom#757255, orderQuantityBaseUomUuid#757256, splitIndicator#757237L, netPriceAmount#757260, ... 16 more fields]
(129) LogicalRDD
Arguments: [shardId#757338, worklistShardItemId#757339L, qty#757340, demandChannel#757341, demandStream#757342, kpis#757343], false
(130) Filter
Arguments: (isnotnull(qty#757340) AND isnotnull(kpis#757343))
(131) Project
Arguments: [shardId#757338, worklistShardItemId#757339L, qty#757340, kpis#757343]
(132) Aggregate
Arguments: [shardId#757338, worklistShardItemId#757339L], [shardId#757338, worklistShardItemId#757339L, map_from_entries(collect_list(struct(qty, qty#757340, kpis, kpis#757343), 0, 0)) AS quantityKpis#757344]
(133) Join
Arguments: LeftOuter, ((shardId#757219 = shardId#757338) AND (worklistShardItemId#757227L = worklistShardItemId#757339L))
(134) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, originalReplenishmentRunId#757235L, supplierGroup#757242, supplier#757243, supplyingPlant#757273, productGroup#757274, product#757245, plant#757246, subrange#757244, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, constraintValues#757267, constraintOperators#757265, constraintLabels#757264, logisticUnits#757269, orderQuantityBaseUom#757255, orderQuantityBaseUomUuid#757256, splitIndicator#757237L, netPriceAmount#757260, ... 17 more fields]
(135) Project
Arguments: [shardId#757219, worklistShardItemId#757227L, quantityAfterProdPlantOptimization#757228, qty#757229, orderProposalId#757232L, originalReplenishmentRunId#757235L, supplierGroup#757242, supplier#757243, supplyingPlant#757273, productGroup#757274, product#757245, plant#757246, subrange#757244, orderDateTime#757250, deliveryDateTime#757251, availabilityDateTime#757252, nextAvailabilityDateTime#757253, constraintValues#757267, constraintOperators#757265, constraintLabels#757264, logisticUnits#757269, orderQuantityBaseUom#757255, orderQuantityBaseUomUuid#757256, splitIndicator#757237L, netPriceAmount#757260, ... 17 more fields]
(136) Filter
Arguments: NOT (isFallbackOrderOnly#757254 <=> true)
(137) LocalRelation
Arguments: <empty>, [shardId#757346, uomCategories#757347]
(138) Project
Arguments: [shardId#757346, uomCategories#757347, null AS insightConfigurations#757348]
(139) LogicalRelation
Arguments: parquet, [uomCategories#757349, insightConfigurations#757350, shardId#757351], false
(140) Filter
Arguments: (shardId#757351 = 0_1_10000002108)
(141) RepartitionByExpression
Arguments: 20
(142) Project
Arguments: [uomCategories#757349, insightConfigurations#757350, 0_1_10000002108 AS shardId#757352]
(143) Project
Arguments: [shardId#757352, uomCategories#757349, insightConfigurations#757350]
(144) Union
Arguments: false, false
(145) Project
Arguments: [insightConfigurations#757348]
(146) Join
Arguments: Cross
(147) Filter
Arguments: (isnotnull(insightConfigurations#757348[POTENTIAL_OOS_DEMAND_PERIOD]) AND CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#757345, qty#757229, None, false), lambdafunction((lambda x_2005#757199.label = OutOfStockProbability), lambda x_2005#757199, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#757348[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_2006#757200.name = OOS_PROBABILITY_THRESHOLD), lambda x_2006#757200, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#757345, qty#757229, None, false), lambdafunction((lambda x_2005#757201.label = OutOfStockProbability), lambda x_2005#757201, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#757348[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_2006#757202.name = OOS_PROBABILITY_THRESHOLD), lambda x_2006#757202, false)), 1, None, false).value as double)) END)
(148) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#757232L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#757233 as string)), struct(name, PRODUCT, value, cast(externalProductId#757271 as string)), struct(name, PLANT, value, cast(externalPlantId#757272 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#757250 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(element_at(quantityKpis#757345, qty#757229, None, false), lambdafunction((lambda x_2007#757218.label = UnfulfilledDemandQty), lambda x_2007#757218, false)), 1, None, false).value as string))) AS businessContext#757215, POTENTIAL_OOS_DEMAND_PERIOD AS internalInsightType#757216, insightConfigurations#757348[POTENTIAL_OOS_DEMAND_PERIOD].configurationVersion AS configurationVersion#757217]
(149) Union
Arguments: false, false
(150) Project
Arguments: [businessContext#757195, internalInsightType#757196, configurationVersion#757197, cast(null as string) AS supplier#757355]
(151) Project
Arguments: [null AS shardId#757459, null AS orderProposalId#757460L, internalInsightType#757196, null AS worklistShardItemId#757461L, null AS thresholdValue#757462, null AS reachedValue#757463, null AS unitOfMeasure#757464, null AS assignmentDetails#757465, null AS externalProductId#757466, null AS externalPlantId#757467, null AS orderProposalItemId#757468, supplier#757355, businessContext#757195, configurationVersion#757197]
(152) Union
Arguments: false, false
(153) Filter
Arguments: internalInsightType#756691 IN (OP_CALC_ITEM_ACCEPT_THR_NOT_MET,OP_CALC_ITEM_NEGL_THR_NOT_MET,OP_CALC_ITEM_OPT_MISSING_MD,OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT,OP_CALC_MIN_NOT_MET)
(154) SubqueryAlias
Arguments: rawInsights
(155) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, supplier#757085, businessContext#757469, configurationVersion#757470, struct(insightType, CASE WHEN (internalInsightType#756691 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#756691 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#756691 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#756691 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#756691 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#756691 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#757085 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#756696, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#760475]
(156) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightTypeInfo#760475]
(157) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightTypeInfo#760475.insightType AS insightType#760476, insightTypeInfo#760475.supplierGroup AS supplierGroup#760477, insightTypeInfo#760475.supplier AS supplier#760478, insightTypeInfo#760475.supplierSubrange AS supplierSubrange#760479]
(158) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightType#760476, supplierGroup#760477, supplier#760478, supplierSubrange#760479, CASE WHEN (insightType#760476 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#760479 as string))) ELSE CASE WHEN (insightType#760476 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#760477 as string))) ELSE CASE WHEN (insightType#760476 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#760479 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#760477 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#760479 as string)), struct(objectType, Product, objectId, cast(externalProductId#757113 as string)), struct(objectType, Location, objectId, cast(externalPlantId#757114 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#760477 as string)), struct(objectType, Product, objectId, cast(externalProductId#757113 as string)), struct(objectType, Location, objectId, cast(externalPlantId#757114 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string)), struct(objectType, Product, objectId, cast(externalProductId#757113 as string)), struct(objectType, Location, objectId, cast(externalPlantId#757114 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#760479 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#760477 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#760479 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#760477 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#760478 as string))) END END END END END END END END END END END END END END END AS triggerObject#760562]
(159) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightType#760476, supplierGroup#760477, supplier#760478, supplierSubrange#760479, triggerObject#760562, CASE WHEN (insightType#760476 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string))) ELSE CASE WHEN (insightType#760476 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string))) ELSE CASE WHEN (insightType#760476 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#752364L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#757075 as string))) END END END END END END END END END END END END END END END AS anchorObject#760611]
(160) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightType#760476, supplierGroup#760477, supplier#760478, supplierSubrange#760479, triggerObject#760562, anchorObject#760611, CASE WHEN (insightType#760476 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#760479 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#756694 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#756695 as string))) ELSE CASE WHEN (insightType#760476 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#760477 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#756694 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#756695 as string))) ELSE CASE WHEN (insightType#760476 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#756694 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#756695 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#760479 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#760477 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#760479 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#757113 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#757114 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#760477 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#757113 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#757114 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#757113 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#757114 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#760479 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#756693 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#756695 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#756694 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#760477 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#756693 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#756695 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#756694 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#756693 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#756695 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#756694 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#760479 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#756693 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#756695 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#760477 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#756693 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#756695 as string))) ELSE CASE WHEN (insightType#760476 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#760478 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#756693 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#756695 as string))) END END END END END END END END END END END END END END END AS messageVariables#760706]
(161) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightType#760476, supplierGroup#760477, supplier#760478, supplierSubrange#760479, triggerObject#760562, anchorObject#760611, messageVariables#760706, ((insightType#760476 <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#760476 <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#760476 <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#760476 <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((insightType#760476 <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((insightType#760476 <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((insightType#760476 <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((insightType#760476 <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((insightType#760476 <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((insightType#760476 <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((insightType#760476 <=> OP_CALC_SG_MIN_NOT_MET) OR ((insightType#760476 <=> OP_CALC_SUP_MIN_NOT_MET) OR ((insightType#760476 <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((insightType#760476 <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (insightType#760476 <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))) AS insightTypeSupported#760707]
(162) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightType#760476, supplierGroup#760477, supplier#760478, supplierSubrange#760479, triggerObject#760562, anchorObject#760611, messageVariables#760706, insightTypeSupported#760707, NEW AS situationStatus#760708]
(163) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightType#760476, supplierGroup#760477, supplier#760478, supplierSubrange#760479, triggerObject#760562, anchorObject#760611, messageVariables#760706, insightTypeSupported#760707, situationStatus#760708, Daily_grocery AS marketUnit#760709]
(164) Filter
Arguments: (insightTypeSupported#760707 = true)
(165) Project
Arguments: [shardId#752363, orderProposalId#752364L, internalInsightType#756691, worklistShardItemId#756692L, thresholdValue#756693, reachedValue#756694, unitOfMeasure#756695, assignmentDetails#756696, externalProductId#757113, externalPlantId#757114, orderProposalItemId#757075, businessContext#757469, configurationVersion#757470, insightType#760476 AS situationType#760710, supplierGroup#760477, supplier#760478, supplierSubrange#760479, triggerObject#760562, anchorObject#760611, messageVariables#760706, insightTypeSupported#760707, situationStatus#760708, marketUnit#760709]
(166) Project
Arguments: [anchorObject#760611, messageVariables#760706, triggerObject#760562, marketUnit#760709, situationStatus#760708, situationType#760710]
(167) Project
Arguments: [to_json(struct(anchorObject, anchorObject#760611, messageVariables, messageVariables#760706, triggerObject, triggerObject#760562, marketUnit, marketUnit#760709, situationStatus, situationStatus#760708, situationType, situationType#760710), Some(UTC)) AS value#762413]
(168) Project
Arguments: [cast(value#762413 as string) AS value#762414]
(169) Project
Arguments: [value#762414, array(struct(key, X-Tenant-ID, value, cast(6944346648028224943 as binary)), struct(key, X-Message-ID, value, cast(uuid(Some(3333948204116395558)) as binary)), struct(key, X-BTP-Tenant-ID, value, cast(0059d9b2-605f-467b-887c-9c65d0e59daf as binary)), struct(key, X-Event-Type, value, cast(SituationCreate as binary))) AS headers#762423]