== 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@5eb62d86, [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#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, lastModified#643173, optimizationInsights#643174], false
(4) Filter
Arguments: shardId#643168 IN (0_1_10000002106)
(5) Filter
Arguments: shardId#643168 IN (0_1_10000002106)
(6) Project
Arguments: [shardId#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, optimizationInsights#643174]
(7) LogicalRDD
Arguments: [shardId#657612, orderProposalId#657613L, items#657614, optimizationGroups#657615, isOptimal#657616, lastModified#657617, optimizationInsights#657618], false
(8) Filter
Arguments: shardId#657612 IN (0_1_10000002106)
(9) Filter
Arguments: shardId#657612 IN (0_1_10000002106)
(10) Project
Arguments: [shardId#657612, orderProposalId#657613L, items#657614, optimizationGroups#657615, isOptimal#657616, optimizationInsights#657618]
(11) Generate
Arguments: explode(items#657614), false, [item#643815]
(12) Project
Arguments: [shardId#657612, item#643815]
(13) Project
Arguments: [shardId#657612, item#643815.worklistShardItemId AS worklistShardItemId#643816L, item#643815.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#643817, item#643815.qty AS qty#643818]
(14) LocalRelation
Arguments: <empty>, [shardId#644572, worklistShardItemId#644573L, orderProposalId#644574L, orderProposalItemId#644575, orderProposalItemGroupId#644576, originalReplenishmentRunId#644577L, orderProposalHorizonGroupingId#644578L, splitIndicator#644579L, previousOrderProposal#644580L, clusterId#644581L, sequenceId#644582L, sourceOfSupplyUuid#644583, supplierGroup#644584, supplier#644585, subrange#644586, product#644587, plant#644588, purchasingOrg#644589, purchasingGroup#644590, mrpController#644591, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, nextAvailabilityDateTime#644595, isFallbackOrderOnly#644596, ... 20 more fields]
(15) LogicalRelation
Arguments: parquet, [orderProposalId#645037L, orderProposalItemId#645038, supplierGroup#645039, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, orderDateTime#645047, availabilityDateTime#645048, nextAvailabilityDateTime#645049, mrpController#645050, sourceOfSupplyUuid#645051, purchasingOrg#645052, purchasingGroup#645053, isFallbackOrderOnly#645054, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, sequenceId#645059, worklistShardItemId#645060L, orderProposalItemGroupId#645061, ... 20 more fields], false
(16) Filter
Arguments: (shardId#645081 = 0_1_10000002106)
(17) RepartitionByExpression
Arguments: [worklistShardItemId#645060L], 20
(18) Filter
Arguments: (sequenceId#645059 = 2)
(19) Project
Arguments: [orderProposalId#645037L, orderProposalItemId#645038, supplierGroup#645039, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, orderDateTime#645047, availabilityDateTime#645048, nextAvailabilityDateTime#645049, mrpController#645050, sourceOfSupplyUuid#645051, purchasingOrg#645052, purchasingGroup#645053, isFallbackOrderOnly#645054, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, sequenceId#645059, worklistShardItemId#645060L, orderProposalItemGroupId#645061, ... 20 more fields]
(20) Project
Arguments: [shardId#645083, worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemId#645038, orderProposalItemGroupId#645061, originalReplenishmentRunId#645079L, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, sequenceId#645059, sourceOfSupplyUuid#645051, supplierGroup#645039, supplier#645040, subrange#645043, product#645046, plant#645041, purchasingOrg#645052, purchasingGroup#645053, mrpController#645050, orderDateTime#645047, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, ... 20 more fields]
(21) Project
Arguments: [shardId#645083, worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemId#645038, orderProposalItemGroupId#645061, originalReplenishmentRunId#645079L, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, cast(sequenceId#645059 as bigint) AS sequenceId#645084L, sourceOfSupplyUuid#645051, supplierGroup#645039, supplier#645040, subrange#645043, product#645046, plant#645041, purchasingOrg#645052, purchasingGroup#645053, mrpController#645050, orderDateTime#645047, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, ... 20 more fields]
(22) Union
Arguments: false, false
(23) Join
Arguments: LeftOuter, ((shardId#657612 = shardId#644572) AND (worklistShardItemId#643816L = worklistShardItemId#644573L))
(24) Project
Arguments: [shardId#657612, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#644574L, orderProposalItemId#644575, orderProposalItemGroupId#644576, originalReplenishmentRunId#644577L, orderProposalHorizonGroupingId#644578L, splitIndicator#644579L, previousOrderProposal#644580L, clusterId#644581L, sequenceId#644582L, sourceOfSupplyUuid#644583, supplierGroup#644584, supplier#644585, subrange#644586, product#644587, plant#644588, purchasingOrg#644589, purchasingGroup#644590, mrpController#644591, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, ... 22 more fields]
(25) Project
Arguments: [shardId#657612, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#644574L, originalReplenishmentRunId#644577L, supplierGroup#644584, supplier#644585, supplyingPlant#644615, productGroup#644616, product#644587, plant#644588, subrange#644586, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, nextAvailabilityDateTime#644595, constraintValues#644609, constraintOperators#644607, constraintLabels#644606, logisticUnits#644611, orderQuantityBaseUom#644597, orderQuantityBaseUomUuid#644598, splitIndicator#644579L, netPriceAmount#644602, ... 14 more fields]
(26) Filter
Arguments: NOT (isFallbackOrderOnly#644596 <=> true)
(27) Project
Arguments: [orderProposalId#644574L]
(28) Deduplicate
Arguments: [orderProposalId#644574L]
(29) Join
Arguments: Inner, (orderProposalId#643169L = orderProposalId#644574L)
(30) Project
Arguments: [orderProposalId#643169L, shardId#643168, items#643170, optimizationGroups#643171, isOptimal#643172, optimizationInsights#643174]
(31) Generate
Arguments: explode(optimizationInsights#643174), false, [insight#657620]
(32) Project
Arguments: [shardId#643168, orderProposalId#643169L, insight#657620]
(33) Project
Arguments: [shardId#643168, orderProposalId#643169L, insight#657620.internalInsightType AS internalInsightType#657621, insight#657620.worklistShardItemId AS worklistShardItemId#657622L, insight#657620.thresholdValue AS thresholdValue#657623, insight#657620.reachedValue AS reachedValue#657624, insight#657620.unitOfMeasure AS unitOfMeasure#657625, insight#657620.assignmentDetails AS assignmentDetails#657626]
(34) LocalRelation
Arguments: <empty>, [shardId#658099, worklistShardItemId#658100L, orderProposalId#658101L, orderProposalItemId#658102, orderProposalItemGroupId#658103, originalReplenishmentRunId#658104L, orderProposalHorizonGroupingId#658105L, splitIndicator#658106L, previousOrderProposal#658107L, clusterId#658108L, sequenceId#658109L, sourceOfSupplyUuid#658110, supplierGroup#658111, supplier#658112, subrange#658113, product#658114, plant#658115, purchasingOrg#658116, purchasingGroup#658117, mrpController#658118, orderDateTime#658119, deliveryDateTime#658120, availabilityDateTime#658121, nextAvailabilityDateTime#658122, isFallbackOrderOnly#658123, ... 20 more fields]
(35) LogicalRelation
Arguments: parquet, [orderProposalId#658144L, orderProposalItemId#658145, supplierGroup#658146, supplier#658147, plant#658148, deliveryDateTime#658149, subrange#658150, supplyingPlant#658151, productGroup#658152, product#658153, orderDateTime#658154, availabilityDateTime#658155, nextAvailabilityDateTime#658156, mrpController#658157, sourceOfSupplyUuid#658158, purchasingOrg#658159, purchasingGroup#658160, isFallbackOrderOnly#658161, orderProposalHorizonGroupingId#658162L, splitIndicator#658163L, previousOrderProposal#658164L, clusterId#658165L, sequenceId#658166, worklistShardItemId#658167L, orderProposalItemGroupId#658168, ... 20 more fields], false
(36) Filter
Arguments: (shardId#658188 = 0_1_10000002106)
(37) RepartitionByExpression
Arguments: [worklistShardItemId#658167L], 20
(38) Filter
Arguments: (sequenceId#658166 = 2)
(39) Project
Arguments: [orderProposalId#658144L, orderProposalItemId#658145, supplierGroup#658146, supplier#658147, plant#658148, deliveryDateTime#658149, subrange#658150, supplyingPlant#658151, productGroup#658152, product#658153, orderDateTime#658154, availabilityDateTime#658155, nextAvailabilityDateTime#658156, mrpController#658157, sourceOfSupplyUuid#658158, purchasingOrg#658159, purchasingGroup#658160, isFallbackOrderOnly#658161, orderProposalHorizonGroupingId#658162L, splitIndicator#658163L, previousOrderProposal#658164L, clusterId#658165L, sequenceId#658166, worklistShardItemId#658167L, orderProposalItemGroupId#658168, ... 20 more fields]
(40) Project
Arguments: [shardId#658190, worklistShardItemId#658167L, orderProposalId#658144L, orderProposalItemId#658145, orderProposalItemGroupId#658168, originalReplenishmentRunId#658186L, orderProposalHorizonGroupingId#658162L, splitIndicator#658163L, previousOrderProposal#658164L, clusterId#658165L, sequenceId#658166, sourceOfSupplyUuid#658158, supplierGroup#658146, supplier#658147, subrange#658150, product#658153, plant#658148, purchasingOrg#658159, purchasingGroup#658160, mrpController#658157, orderDateTime#658154, deliveryDateTime#658149, availabilityDateTime#658155, nextAvailabilityDateTime#658156, isFallbackOrderOnly#658161, ... 20 more fields]
(41) Project
Arguments: [shardId#658190, worklistShardItemId#658167L, orderProposalId#658144L, orderProposalItemId#658145, orderProposalItemGroupId#658168, originalReplenishmentRunId#658186L, orderProposalHorizonGroupingId#658162L, splitIndicator#658163L, previousOrderProposal#658164L, clusterId#658165L, cast(sequenceId#658166 as bigint) AS sequenceId#658191L, sourceOfSupplyUuid#658158, supplierGroup#658146, supplier#658147, subrange#658150, product#658153, plant#658148, purchasingOrg#658159, purchasingGroup#658160, mrpController#658157, orderDateTime#658154, deliveryDateTime#658149, availabilityDateTime#658155, nextAvailabilityDateTime#658156, isFallbackOrderOnly#658161, ... 20 more fields]
(42) Union
Arguments: false, false
(43) Join
Arguments: LeftOuter, ((shardId#643168 = shardId#658099) AND (worklistShardItemId#657622L = worklistShardItemId#658100L))
(44) Project
Arguments: [shardId#643168, worklistShardItemId#657622L, orderProposalId#643169L, internalInsightType#657621, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, orderProposalId#658101L, orderProposalItemId#658102, orderProposalItemGroupId#658103, originalReplenishmentRunId#658104L, orderProposalHorizonGroupingId#658105L, splitIndicator#658106L, previousOrderProposal#658107L, clusterId#658108L, sequenceId#658109L, sourceOfSupplyUuid#658110, supplierGroup#658111, supplier#658112, subrange#658113, product#658114, plant#658115, purchasingOrg#658116, purchasingGroup#658117, ... 26 more fields]
(45) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, supplier#658112]
(46) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, supplier#658112, null AS businessContext#658496, null AS configurationVersion#658497]
(47) LogicalRDD
Arguments: [shardId#658383, orderProposalId#658384L, items#658385, optimizationGroups#658386, isOptimal#658387, lastModified#658388, optimizationInsights#658389], false
(48) Filter
Arguments: shardId#658383 IN (0_1_10000002106)
(49) Filter
Arguments: shardId#658383 IN (0_1_10000002106)
(50) Project
Arguments: [shardId#658383, orderProposalId#658384L, items#658385, optimizationGroups#658386, isOptimal#658387, optimizationInsights#658389]
(51) Generate
Arguments: explode(items#658385), false, [item#658390]
(52) Project
Arguments: [shardId#658383, item#658390]
(53) Project
Arguments: [shardId#658383, item#658390.worklistShardItemId AS worklistShardItemId#658391L, item#658390.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#658392, item#658390.qty AS qty#658393]
(54) LocalRelation
Arguments: <empty>, [shardId#658394, worklistShardItemId#658395L, orderProposalId#658396L, orderProposalItemId#658397, orderProposalItemGroupId#658398, originalReplenishmentRunId#658399L, orderProposalHorizonGroupingId#658400L, splitIndicator#658401L, previousOrderProposal#658402L, clusterId#658403L, sequenceId#658404L, sourceOfSupplyUuid#658405, supplierGroup#658406, supplier#658407, subrange#658408, product#658409, plant#658410, purchasingOrg#658411, purchasingGroup#658412, mrpController#658413, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, isFallbackOrderOnly#658418, ... 20 more fields]
(55) LogicalRelation
Arguments: parquet, [orderProposalId#658439L, orderProposalItemId#658440, supplierGroup#658441, supplier#658442, plant#658443, deliveryDateTime#658444, subrange#658445, supplyingPlant#658446, productGroup#658447, product#658448, orderDateTime#658449, availabilityDateTime#658450, nextAvailabilityDateTime#658451, mrpController#658452, sourceOfSupplyUuid#658453, purchasingOrg#658454, purchasingGroup#658455, isFallbackOrderOnly#658456, orderProposalHorizonGroupingId#658457L, splitIndicator#658458L, previousOrderProposal#658459L, clusterId#658460L, sequenceId#658461, worklistShardItemId#658462L, orderProposalItemGroupId#658463, ... 20 more fields], false
(56) Filter
Arguments: (shardId#658483 = 0_1_10000002106)
(57) RepartitionByExpression
Arguments: [worklistShardItemId#658462L], 20
(58) Filter
Arguments: (sequenceId#658461 = 2)
(59) Project
Arguments: [orderProposalId#658439L, orderProposalItemId#658440, supplierGroup#658441, supplier#658442, plant#658443, deliveryDateTime#658444, subrange#658445, supplyingPlant#658446, productGroup#658447, product#658448, orderDateTime#658449, availabilityDateTime#658450, nextAvailabilityDateTime#658451, mrpController#658452, sourceOfSupplyUuid#658453, purchasingOrg#658454, purchasingGroup#658455, isFallbackOrderOnly#658456, orderProposalHorizonGroupingId#658457L, splitIndicator#658458L, previousOrderProposal#658459L, clusterId#658460L, sequenceId#658461, worklistShardItemId#658462L, orderProposalItemGroupId#658463, ... 20 more fields]
(60) Project
Arguments: [shardId#658484, worklistShardItemId#658462L, orderProposalId#658439L, orderProposalItemId#658440, orderProposalItemGroupId#658463, originalReplenishmentRunId#658481L, orderProposalHorizonGroupingId#658457L, splitIndicator#658458L, previousOrderProposal#658459L, clusterId#658460L, sequenceId#658461, sourceOfSupplyUuid#658453, supplierGroup#658441, supplier#658442, subrange#658445, product#658448, plant#658443, purchasingOrg#658454, purchasingGroup#658455, mrpController#658452, orderDateTime#658449, deliveryDateTime#658444, availabilityDateTime#658450, nextAvailabilityDateTime#658451, isFallbackOrderOnly#658456, ... 20 more fields]
(61) Project
Arguments: [shardId#658484, worklistShardItemId#658462L, orderProposalId#658439L, orderProposalItemId#658440, orderProposalItemGroupId#658463, originalReplenishmentRunId#658481L, orderProposalHorizonGroupingId#658457L, splitIndicator#658458L, previousOrderProposal#658459L, clusterId#658460L, cast(sequenceId#658461 as bigint) AS sequenceId#658485L, sourceOfSupplyUuid#658453, supplierGroup#658441, supplier#658442, subrange#658445, product#658448, plant#658443, purchasingOrg#658454, purchasingGroup#658455, mrpController#658452, orderDateTime#658449, deliveryDateTime#658444, availabilityDateTime#658450, nextAvailabilityDateTime#658451, isFallbackOrderOnly#658456, ... 20 more fields]
(62) Union
Arguments: false, false
(63) Join
Arguments: LeftOuter, ((shardId#658383 = shardId#658394) AND (worklistShardItemId#658391L = worklistShardItemId#658395L))
(64) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, orderProposalItemId#658397, orderProposalItemGroupId#658398, originalReplenishmentRunId#658399L, orderProposalHorizonGroupingId#658400L, splitIndicator#658401L, previousOrderProposal#658402L, clusterId#658403L, sequenceId#658404L, sourceOfSupplyUuid#658405, supplierGroup#658406, supplier#658407, subrange#658408, product#658409, plant#658410, purchasingOrg#658411, purchasingGroup#658412, mrpController#658413, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, ... 22 more fields]
(65) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, originalReplenishmentRunId#658399L, supplierGroup#658406, supplier#658407, supplyingPlant#658437, productGroup#658438, product#658409, plant#658410, subrange#658408, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, constraintValues#658431, constraintOperators#658429, constraintLabels#658428, logisticUnits#658433, orderQuantityBaseUom#658419, orderQuantityBaseUomUuid#658420, splitIndicator#658401L, netPriceAmount#658424, ... 14 more fields]
(66) LogicalRDD
Arguments: [shardId#647194, worklistShardItemId#647195L, qty#647196, demandChannel#647197, demandStream#647198, kpis#647199], false
(67) Filter
Arguments: ((isnull(qty#647196) AND isnull(demandChannel#647197)) AND isnull(demandStream#647198))
(68) Project
Arguments: [shardId#647194, worklistShardItemId#647195L, coalesce(kpis#647199, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#647200]
(69) Join
Arguments: LeftOuter, ((shardId#658383 = shardId#647194) AND (worklistShardItemId#658391L = worklistShardItemId#647195L))
(70) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, originalReplenishmentRunId#658399L, supplierGroup#658406, supplier#658407, supplyingPlant#658437, productGroup#658438, product#658409, plant#658410, subrange#658408, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, constraintValues#658431, constraintOperators#658429, constraintLabels#658428, logisticUnits#658433, orderQuantityBaseUom#658419, orderQuantityBaseUomUuid#658420, splitIndicator#658401L, netPriceAmount#658424, ... 15 more fields]
(71) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, originalReplenishmentRunId#658399L, supplierGroup#658406, supplier#658407, supplyingPlant#658437, productGroup#658438, product#658409, plant#658410, subrange#658408, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, constraintValues#658431, constraintOperators#658429, constraintLabels#658428, logisticUnits#658433, orderQuantityBaseUom#658419, orderQuantityBaseUomUuid#658420, splitIndicator#658401L, netPriceAmount#658424, ... 15 more fields]
(72) LogicalRDD
Arguments: [shardId#647210, worklistShardItemId#647211L, qty#647212, demandChannel#647213, demandStream#647214, kpis#647215], false
(73) Filter
Arguments: (((isnull(qty#647212) AND isnotnull(demandChannel#647213)) AND isnotnull(demandStream#647214)) AND (size(kpis#647215, true) > 0))
(74) Aggregate
Arguments: [shardId#647210, worklistShardItemId#647211L], [shardId#647210, worklistShardItemId#647211L, collect_list(struct(demandChannel, demandChannel#647213, demandStream, demandStream#647214, kpis, kpis#647215), 0, 0) AS channelStreamSpecificKpis#647202]
(75) Join
Arguments: LeftOuter, ((shardId#658383 = shardId#647210) AND (worklistShardItemId#658391L = worklistShardItemId#647211L))
(76) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, originalReplenishmentRunId#658399L, supplierGroup#658406, supplier#658407, supplyingPlant#658437, productGroup#658438, product#658409, plant#658410, subrange#658408, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, constraintValues#658431, constraintOperators#658429, constraintLabels#658428, logisticUnits#658433, orderQuantityBaseUom#658419, orderQuantityBaseUomUuid#658420, splitIndicator#658401L, netPriceAmount#658424, ... 16 more fields]
(77) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, originalReplenishmentRunId#658399L, supplierGroup#658406, supplier#658407, supplyingPlant#658437, productGroup#658438, product#658409, plant#658410, subrange#658408, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, constraintValues#658431, constraintOperators#658429, constraintLabels#658428, logisticUnits#658433, orderQuantityBaseUom#658419, orderQuantityBaseUomUuid#658420, splitIndicator#658401L, netPriceAmount#658424, ... 16 more fields]
(78) LogicalRDD
Arguments: [shardId#647223, worklistShardItemId#647224L, qty#647225, demandChannel#647226, demandStream#647227, kpis#647228], false
(79) Filter
Arguments: (isnotnull(qty#647225) AND isnotnull(kpis#647228))
(80) Project
Arguments: [shardId#647223, worklistShardItemId#647224L, qty#647225, kpis#647228]
(81) Aggregate
Arguments: [shardId#647223, worklistShardItemId#647224L], [shardId#647223, worklistShardItemId#647224L, map_from_entries(collect_list(struct(qty, qty#647225, kpis, kpis#647228), 0, 0)) AS quantityKpis#647217]
(82) Join
Arguments: LeftOuter, ((shardId#658383 = shardId#647223) AND (worklistShardItemId#658391L = worklistShardItemId#647224L))
(83) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, originalReplenishmentRunId#658399L, supplierGroup#658406, supplier#658407, supplyingPlant#658437, productGroup#658438, product#658409, plant#658410, subrange#658408, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, constraintValues#658431, constraintOperators#658429, constraintLabels#658428, logisticUnits#658433, orderQuantityBaseUom#658419, orderQuantityBaseUomUuid#658420, splitIndicator#658401L, netPriceAmount#658424, ... 17 more fields]
(84) Project
Arguments: [shardId#658383, worklistShardItemId#658391L, quantityAfterProdPlantOptimization#658392, qty#658393, orderProposalId#658396L, originalReplenishmentRunId#658399L, supplierGroup#658406, supplier#658407, supplyingPlant#658437, productGroup#658438, product#658409, plant#658410, subrange#658408, orderDateTime#658414, deliveryDateTime#658415, availabilityDateTime#658416, nextAvailabilityDateTime#658417, constraintValues#658431, constraintOperators#658429, constraintLabels#658428, logisticUnits#658433, orderQuantityBaseUom#658419, orderQuantityBaseUomUuid#658420, splitIndicator#658401L, netPriceAmount#658424, ... 17 more fields]
(85) Filter
Arguments: NOT (isFallbackOrderOnly#658418 <=> true)
(86) LocalRelation
Arguments: <empty>, [shardId#658192, uomCategories#658193]
(87) Project
Arguments: [shardId#658192, uomCategories#658193, null AS insightConfigurations#658199]
(88) LogicalRelation
Arguments: parquet, [uomCategories#658194, insightConfigurations#658195, shardId#658196], false
(89) Filter
Arguments: (shardId#658196 = 0_1_10000002106)
(90) RepartitionByExpression
Arguments: 20
(91) Project
Arguments: [uomCategories#658194, insightConfigurations#658195, 0_1_10000002106 AS shardId#658198]
(92) Project
Arguments: [shardId#658198, uomCategories#658194, insightConfigurations#658195]
(93) Union
Arguments: false, false
(94) Project
Arguments: [insightConfigurations#658199]
(95) Join
Arguments: Cross
(96) Filter
Arguments: (((isnotnull(insightConfigurations#658199[POTENTIAL_OOS_STOCK_PERIOD]) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1708#658200.label = OutOfStockProbability), lambda x_1708#658200, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#658199[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1709#658201.name = OOS_PROBABILITY_THRESHOLD), lambda x_1709#658201, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1708#658202.label = OutOfStockProbability), lambda x_1708#658202, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#658199[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1709#658203.name = OOS_PROBABILITY_THRESHOLD), lambda x_1709#658203, false)), 1, None, false).value as double)) END) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1710#658204.label = InitialStockQty), lambda x_1710#658204, false)), 1, None, false).value) OR isnull(CASE WHEN cast(element_at(filter(insightConfigurations#658199[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1711#658205.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_1711#658205, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END)) THEN false ELSE (element_at(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1710#658206.label = InitialStockQty), lambda x_1710#658206, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(insightConfigurations#658199[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1711#658207.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_1711#658207, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (isnull(CASE WHEN isnull(orderDateTime#658414) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#658414, 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#658199[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1712#658208.name = OFFSET_CURRENT_ORDER_DATE), lambda x_1712#658208, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#658414) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#658414, 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#658199[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1712#658209.name = OFFSET_CURRENT_ORDER_DATE), lambda x_1712#658209, false)), 1, None, false).value as double)) END)
(97) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#658396L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#658397 as string)), struct(name, PRODUCT, value, cast(externalProductId#658435 as string)), struct(name, PLANT, value, cast(externalPlantId#658436 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#658414 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1713#658225.label = UnfulfilledDemandQty), lambda x_1713#658225, false)), 1, None, false).value as string))) AS businessContext#658222, POTENTIAL_OOS_STOCK_PERIOD AS internalInsightType#658223, insightConfigurations#658199[POTENTIAL_OOS_STOCK_PERIOD].configurationVersion AS configurationVersion#658224]
(98) LogicalRDD
Arguments: [shardId#658246, orderProposalId#658247L, items#658248, optimizationGroups#658249, isOptimal#658250, lastModified#658251, optimizationInsights#658252], false
(99) Filter
Arguments: shardId#658246 IN (0_1_10000002106)
(100) Filter
Arguments: shardId#658246 IN (0_1_10000002106)
(101) Project
Arguments: [shardId#658246, orderProposalId#658247L, items#658248, optimizationGroups#658249, isOptimal#658250, optimizationInsights#658252]
(102) Generate
Arguments: explode(items#658248), false, [item#658253]
(103) Project
Arguments: [shardId#658246, item#658253]
(104) Project
Arguments: [shardId#658246, item#658253.worklistShardItemId AS worklistShardItemId#658254L, item#658253.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#658255, item#658253.qty AS qty#658256]
(105) LocalRelation
Arguments: <empty>, [shardId#658257, worklistShardItemId#658258L, orderProposalId#658259L, orderProposalItemId#658260, orderProposalItemGroupId#658261, originalReplenishmentRunId#658262L, orderProposalHorizonGroupingId#658263L, splitIndicator#658264L, previousOrderProposal#658265L, clusterId#658266L, sequenceId#658267L, sourceOfSupplyUuid#658268, supplierGroup#658269, supplier#658270, subrange#658271, product#658272, plant#658273, purchasingOrg#658274, purchasingGroup#658275, mrpController#658276, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, isFallbackOrderOnly#658281, ... 20 more fields]
(106) LogicalRelation
Arguments: parquet, [orderProposalId#658302L, orderProposalItemId#658303, supplierGroup#658304, supplier#658305, plant#658306, deliveryDateTime#658307, subrange#658308, supplyingPlant#658309, productGroup#658310, product#658311, orderDateTime#658312, availabilityDateTime#658313, nextAvailabilityDateTime#658314, mrpController#658315, sourceOfSupplyUuid#658316, purchasingOrg#658317, purchasingGroup#658318, isFallbackOrderOnly#658319, orderProposalHorizonGroupingId#658320L, splitIndicator#658321L, previousOrderProposal#658322L, clusterId#658323L, sequenceId#658324, worklistShardItemId#658325L, orderProposalItemGroupId#658326, ... 20 more fields], false
(107) Filter
Arguments: (shardId#658346 = 0_1_10000002106)
(108) RepartitionByExpression
Arguments: [worklistShardItemId#658325L], 20
(109) Filter
Arguments: (sequenceId#658324 = 2)
(110) Project
Arguments: [orderProposalId#658302L, orderProposalItemId#658303, supplierGroup#658304, supplier#658305, plant#658306, deliveryDateTime#658307, subrange#658308, supplyingPlant#658309, productGroup#658310, product#658311, orderDateTime#658312, availabilityDateTime#658313, nextAvailabilityDateTime#658314, mrpController#658315, sourceOfSupplyUuid#658316, purchasingOrg#658317, purchasingGroup#658318, isFallbackOrderOnly#658319, orderProposalHorizonGroupingId#658320L, splitIndicator#658321L, previousOrderProposal#658322L, clusterId#658323L, sequenceId#658324, worklistShardItemId#658325L, orderProposalItemGroupId#658326, ... 20 more fields]
(111) Project
Arguments: [shardId#658347, worklistShardItemId#658325L, orderProposalId#658302L, orderProposalItemId#658303, orderProposalItemGroupId#658326, originalReplenishmentRunId#658344L, orderProposalHorizonGroupingId#658320L, splitIndicator#658321L, previousOrderProposal#658322L, clusterId#658323L, sequenceId#658324, sourceOfSupplyUuid#658316, supplierGroup#658304, supplier#658305, subrange#658308, product#658311, plant#658306, purchasingOrg#658317, purchasingGroup#658318, mrpController#658315, orderDateTime#658312, deliveryDateTime#658307, availabilityDateTime#658313, nextAvailabilityDateTime#658314, isFallbackOrderOnly#658319, ... 20 more fields]
(112) Project
Arguments: [shardId#658347, worklistShardItemId#658325L, orderProposalId#658302L, orderProposalItemId#658303, orderProposalItemGroupId#658326, originalReplenishmentRunId#658344L, orderProposalHorizonGroupingId#658320L, splitIndicator#658321L, previousOrderProposal#658322L, clusterId#658323L, cast(sequenceId#658324 as bigint) AS sequenceId#658348L, sourceOfSupplyUuid#658316, supplierGroup#658304, supplier#658305, subrange#658308, product#658311, plant#658306, purchasingOrg#658317, purchasingGroup#658318, mrpController#658315, orderDateTime#658312, deliveryDateTime#658307, availabilityDateTime#658313, nextAvailabilityDateTime#658314, isFallbackOrderOnly#658319, ... 20 more fields]
(113) Union
Arguments: false, false
(114) Join
Arguments: LeftOuter, ((shardId#658246 = shardId#658257) AND (worklistShardItemId#658254L = worklistShardItemId#658258L))
(115) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, orderProposalItemId#658260, orderProposalItemGroupId#658261, originalReplenishmentRunId#658262L, orderProposalHorizonGroupingId#658263L, splitIndicator#658264L, previousOrderProposal#658265L, clusterId#658266L, sequenceId#658267L, sourceOfSupplyUuid#658268, supplierGroup#658269, supplier#658270, subrange#658271, product#658272, plant#658273, purchasingOrg#658274, purchasingGroup#658275, mrpController#658276, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, ... 22 more fields]
(116) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, originalReplenishmentRunId#658262L, supplierGroup#658269, supplier#658270, supplyingPlant#658300, productGroup#658301, product#658272, plant#658273, subrange#658271, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, constraintValues#658294, constraintOperators#658292, constraintLabels#658291, logisticUnits#658296, orderQuantityBaseUom#658282, orderQuantityBaseUomUuid#658283, splitIndicator#658264L, netPriceAmount#658287, ... 14 more fields]
(117) LogicalRDD
Arguments: [shardId#658349, worklistShardItemId#658350L, qty#658351, demandChannel#658352, demandStream#658353, kpis#658354], false
(118) Filter
Arguments: ((isnull(qty#658351) AND isnull(demandChannel#658352)) AND isnull(demandStream#658353))
(119) Project
Arguments: [shardId#658349, worklistShardItemId#658350L, coalesce(kpis#658354, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#658355]
(120) Join
Arguments: LeftOuter, ((shardId#658246 = shardId#658349) AND (worklistShardItemId#658254L = worklistShardItemId#658350L))
(121) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, originalReplenishmentRunId#658262L, supplierGroup#658269, supplier#658270, supplyingPlant#658300, productGroup#658301, product#658272, plant#658273, subrange#658271, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, constraintValues#658294, constraintOperators#658292, constraintLabels#658291, logisticUnits#658296, orderQuantityBaseUom#658282, orderQuantityBaseUomUuid#658283, splitIndicator#658264L, netPriceAmount#658287, ... 15 more fields]
(122) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, originalReplenishmentRunId#658262L, supplierGroup#658269, supplier#658270, supplyingPlant#658300, productGroup#658301, product#658272, plant#658273, subrange#658271, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, constraintValues#658294, constraintOperators#658292, constraintLabels#658291, logisticUnits#658296, orderQuantityBaseUom#658282, orderQuantityBaseUomUuid#658283, splitIndicator#658264L, netPriceAmount#658287, ... 15 more fields]
(123) LogicalRDD
Arguments: [shardId#658357, worklistShardItemId#658358L, qty#658359, demandChannel#658360, demandStream#658361, kpis#658362], false
(124) Filter
Arguments: (((isnull(qty#658359) AND isnotnull(demandChannel#658360)) AND isnotnull(demandStream#658361)) AND (size(kpis#658362, true) > 0))
(125) Aggregate
Arguments: [shardId#658357, worklistShardItemId#658358L], [shardId#658357, worklistShardItemId#658358L, collect_list(struct(demandChannel, demandChannel#658360, demandStream, demandStream#658361, kpis, kpis#658362), 0, 0) AS channelStreamSpecificKpis#658363]
(126) Join
Arguments: LeftOuter, ((shardId#658246 = shardId#658357) AND (worklistShardItemId#658254L = worklistShardItemId#658358L))
(127) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, originalReplenishmentRunId#658262L, supplierGroup#658269, supplier#658270, supplyingPlant#658300, productGroup#658301, product#658272, plant#658273, subrange#658271, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, constraintValues#658294, constraintOperators#658292, constraintLabels#658291, logisticUnits#658296, orderQuantityBaseUom#658282, orderQuantityBaseUomUuid#658283, splitIndicator#658264L, netPriceAmount#658287, ... 16 more fields]
(128) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, originalReplenishmentRunId#658262L, supplierGroup#658269, supplier#658270, supplyingPlant#658300, productGroup#658301, product#658272, plant#658273, subrange#658271, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, constraintValues#658294, constraintOperators#658292, constraintLabels#658291, logisticUnits#658296, orderQuantityBaseUom#658282, orderQuantityBaseUomUuid#658283, splitIndicator#658264L, netPriceAmount#658287, ... 16 more fields]
(129) LogicalRDD
Arguments: [shardId#658365, worklistShardItemId#658366L, qty#658367, demandChannel#658368, demandStream#658369, kpis#658370], false
(130) Filter
Arguments: (isnotnull(qty#658367) AND isnotnull(kpis#658370))
(131) Project
Arguments: [shardId#658365, worklistShardItemId#658366L, qty#658367, kpis#658370]
(132) Aggregate
Arguments: [shardId#658365, worklistShardItemId#658366L], [shardId#658365, worklistShardItemId#658366L, map_from_entries(collect_list(struct(qty, qty#658367, kpis, kpis#658370), 0, 0)) AS quantityKpis#658371]
(133) Join
Arguments: LeftOuter, ((shardId#658246 = shardId#658365) AND (worklistShardItemId#658254L = worklistShardItemId#658366L))
(134) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, originalReplenishmentRunId#658262L, supplierGroup#658269, supplier#658270, supplyingPlant#658300, productGroup#658301, product#658272, plant#658273, subrange#658271, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, constraintValues#658294, constraintOperators#658292, constraintLabels#658291, logisticUnits#658296, orderQuantityBaseUom#658282, orderQuantityBaseUomUuid#658283, splitIndicator#658264L, netPriceAmount#658287, ... 17 more fields]
(135) Project
Arguments: [shardId#658246, worklistShardItemId#658254L, quantityAfterProdPlantOptimization#658255, qty#658256, orderProposalId#658259L, originalReplenishmentRunId#658262L, supplierGroup#658269, supplier#658270, supplyingPlant#658300, productGroup#658301, product#658272, plant#658273, subrange#658271, orderDateTime#658277, deliveryDateTime#658278, availabilityDateTime#658279, nextAvailabilityDateTime#658280, constraintValues#658294, constraintOperators#658292, constraintLabels#658291, logisticUnits#658296, orderQuantityBaseUom#658282, orderQuantityBaseUomUuid#658283, splitIndicator#658264L, netPriceAmount#658287, ... 17 more fields]
(136) Filter
Arguments: NOT (isFallbackOrderOnly#658281 <=> true)
(137) LocalRelation
Arguments: <empty>, [shardId#658373, uomCategories#658374]
(138) Project
Arguments: [shardId#658373, uomCategories#658374, null AS insightConfigurations#658375]
(139) LogicalRelation
Arguments: parquet, [uomCategories#658376, insightConfigurations#658377, shardId#658378], false
(140) Filter
Arguments: (shardId#658378 = 0_1_10000002106)
(141) RepartitionByExpression
Arguments: 20
(142) Project
Arguments: [uomCategories#658376, insightConfigurations#658377, 0_1_10000002106 AS shardId#658379]
(143) Project
Arguments: [shardId#658379, uomCategories#658376, insightConfigurations#658377]
(144) Union
Arguments: false, false
(145) Project
Arguments: [insightConfigurations#658375]
(146) Join
Arguments: Cross
(147) Filter
Arguments: (isnotnull(insightConfigurations#658375[POTENTIAL_OOS_DEMAND_PERIOD]) AND CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#658372, qty#658256, None, false), lambdafunction((lambda x_1714#658226.label = OutOfStockProbability), lambda x_1714#658226, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#658375[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_1715#658227.name = OOS_PROBABILITY_THRESHOLD), lambda x_1715#658227, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#658372, qty#658256, None, false), lambdafunction((lambda x_1714#658228.label = OutOfStockProbability), lambda x_1714#658228, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#658375[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_1715#658229.name = OOS_PROBABILITY_THRESHOLD), lambda x_1715#658229, false)), 1, None, false).value as double)) END)
(148) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#658259L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#658260 as string)), struct(name, PRODUCT, value, cast(externalProductId#658298 as string)), struct(name, PLANT, value, cast(externalPlantId#658299 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#658277 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(element_at(quantityKpis#658372, qty#658256, None, false), lambdafunction((lambda x_1716#658245.label = UnfulfilledDemandQty), lambda x_1716#658245, false)), 1, None, false).value as string))) AS businessContext#658242, POTENTIAL_OOS_DEMAND_PERIOD AS internalInsightType#658243, insightConfigurations#658375[POTENTIAL_OOS_DEMAND_PERIOD].configurationVersion AS configurationVersion#658244]
(149) Union
Arguments: false, false
(150) Project
Arguments: [businessContext#658222, internalInsightType#658223, configurationVersion#658224, cast(null as string) AS supplier#658382]
(151) Project
Arguments: [null AS shardId#658486, null AS orderProposalId#658487L, internalInsightType#658223, null AS worklistShardItemId#658488L, null AS thresholdValue#658489, null AS reachedValue#658490, null AS unitOfMeasure#658491, null AS assignmentDetails#658492, null AS externalProductId#658493, null AS externalPlantId#658494, null AS orderProposalItemId#658495, supplier#658382, businessContext#658222, configurationVersion#658224]
(152) Union
Arguments: false, false
(153) Filter
Arguments: internalInsightType#657621 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#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, supplier#658112, businessContext#658496, configurationVersion#658497, struct(insightType, CASE WHEN (internalInsightType#657621 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#657621 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#657621 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#657621 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#657621 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#657621 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#658112 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#658828]
(156) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightTypeInfo#658828]
(157) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightTypeInfo#658828.insightType AS insightType#658829, insightTypeInfo#658828.supplierGroup AS supplierGroup#658830, insightTypeInfo#658828.supplier AS supplier#658831, insightTypeInfo#658828.supplierSubrange AS supplierSubrange#658832]
(158) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightType#658829, supplierGroup#658830, supplier#658831, supplierSubrange#658832, CASE WHEN (insightType#658829 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#658832 as string))) ELSE CASE WHEN (insightType#658829 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#658830 as string))) ELSE CASE WHEN (insightType#658829 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#658832 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#658830 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#658832 as string)), struct(objectType, Product, objectId, cast(externalProductId#658140 as string)), struct(objectType, Location, objectId, cast(externalPlantId#658141 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#658830 as string)), struct(objectType, Product, objectId, cast(externalProductId#658140 as string)), struct(objectType, Location, objectId, cast(externalPlantId#658141 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string)), struct(objectType, Product, objectId, cast(externalProductId#658140 as string)), struct(objectType, Location, objectId, cast(externalPlantId#658141 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#658832 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#658830 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#658832 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#658830 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#658831 as string))) END END END END END END END END END END END END END END END AS triggerObject#658915]
(159) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightType#658829, supplierGroup#658830, supplier#658831, supplierSubrange#658832, triggerObject#658915, CASE WHEN (insightType#658829 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightType#658829 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightType#658829 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#658102 as string))) END END END END END END END END END END END END END END END AS anchorObject#658964]
(160) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightType#658829, supplierGroup#658830, supplier#658831, supplierSubrange#658832, triggerObject#658915, anchorObject#658964, CASE WHEN (insightType#658829 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#658832 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#657624 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#657625 as string))) ELSE CASE WHEN (insightType#658829 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#658830 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#657624 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#657625 as string))) ELSE CASE WHEN (insightType#658829 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#657624 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#657625 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#658832 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#658830 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#658832 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#658140 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#658141 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#658830 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#658140 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#658141 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#658140 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#658141 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#658832 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#657625 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#657624 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#658830 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#657625 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#657624 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#657625 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#657624 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#658832 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#657625 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#658830 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#657625 as string))) ELSE CASE WHEN (insightType#658829 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#658831 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#657625 as string))) END END END END END END END END END END END END END END END AS messageVariables#659059]
(161) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightType#658829, supplierGroup#658830, supplier#658831, supplierSubrange#658832, triggerObject#658915, anchorObject#658964, messageVariables#659059, ((insightType#658829 <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#658829 <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#658829 <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#658829 <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((insightType#658829 <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((insightType#658829 <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((insightType#658829 <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((insightType#658829 <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((insightType#658829 <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((insightType#658829 <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((insightType#658829 <=> OP_CALC_SG_MIN_NOT_MET) OR ((insightType#658829 <=> OP_CALC_SUP_MIN_NOT_MET) OR ((insightType#658829 <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((insightType#658829 <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (insightType#658829 <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))) AS insightTypeSupported#659060]
(162) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightType#658829, supplierGroup#658830, supplier#658831, supplierSubrange#658832, triggerObject#658915, anchorObject#658964, messageVariables#659059, insightTypeSupported#659060, NEW AS situationStatus#659061]
(163) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightType#658829, supplierGroup#658830, supplier#658831, supplierSubrange#658832, triggerObject#658915, anchorObject#658964, messageVariables#659059, insightTypeSupported#659060, situationStatus#659061, Daily_grocery AS marketUnit#659062]
(164) Filter
Arguments: (insightTypeSupported#659060 = true)
(165) Project
Arguments: [shardId#643168, orderProposalId#643169L, internalInsightType#657621, worklistShardItemId#657622L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, assignmentDetails#657626, externalProductId#658140, externalPlantId#658141, orderProposalItemId#658102, businessContext#658496, configurationVersion#658497, insightType#658829 AS situationType#659063, supplierGroup#658830, supplier#658831, supplierSubrange#658832, triggerObject#658915, anchorObject#658964, messageVariables#659059, insightTypeSupported#659060, situationStatus#659061, marketUnit#659062]
(166) Project
Arguments: [anchorObject#658964, messageVariables#659059, triggerObject#658915, marketUnit#659062, situationStatus#659061, situationType#659063]
(167) Project
Arguments: [to_json(struct(anchorObject, anchorObject#658964, messageVariables, messageVariables#659059, triggerObject, triggerObject#658915, marketUnit, marketUnit#659062, situationStatus, situationStatus#659061, situationType, situationType#659063), Some(UTC)) AS value#659878]
(168) Project
Arguments: [cast(value#659878 as string) AS value#659879]
(169) Project
Arguments: [value#659879, array(struct(key, X-Tenant-ID, value, cast(6944346648028224943 as binary)), struct(key, X-Message-ID, value, cast(uuid(Some(1092037931404111572)) 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#659888]