== 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@4bf7dc19, [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#777607, orderProposalId#777608L, items#777609, optimizationGroups#777610, isOptimal#777611, lastModified#777612, optimizationInsights#777613], false
(4) Filter
Arguments: shardId#777607 IN (0_1_10000002108)
(5) Filter
Arguments: shardId#777607 IN (0_1_10000002108)
(6) Project
Arguments: [shardId#777607, orderProposalId#777608L, items#777609, optimizationGroups#777610, isOptimal#777611, optimizationInsights#777613]
(7) LogicalRDD
Arguments: [shardId#781926, orderProposalId#781927L, items#781928, optimizationGroups#781929, isOptimal#781930, lastModified#781931, optimizationInsights#781932], false
(8) Filter
Arguments: shardId#781926 IN (0_1_10000002108)
(9) Filter
Arguments: shardId#781926 IN (0_1_10000002108)
(10) Project
Arguments: [shardId#781926, orderProposalId#781927L, items#781928, optimizationGroups#781929, isOptimal#781930, optimizationInsights#781932]
(11) Generate
Arguments: explode(items#781928), false, [item#778118]
(12) Project
Arguments: [shardId#781926, item#778118]
(13) Project
Arguments: [shardId#781926, item#778118.worklistShardItemId AS worklistShardItemId#778119L, item#778118.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#778120, item#778118.qty AS qty#778121]
(14) LocalRelation
Arguments: <empty>, [shardId#778275, worklistShardItemId#778276L, orderProposalId#778277L, orderProposalItemId#778278, orderProposalItemGroupId#778279, originalReplenishmentRunId#778280L, orderProposalHorizonGroupingId#778281L, splitIndicator#778282L, previousOrderProposal#778283L, clusterId#778284L, sequenceId#778285L, sourceOfSupplyUuid#778286, supplierGroup#778287, supplier#778288, subrange#778289, product#778290, plant#778291, purchasingOrg#778292, purchasingGroup#778293, mrpController#778294, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, nextAvailabilityDateTime#778298, isFallbackOrderOnly#778299, ... 20 more fields]
(15) LogicalRelation
Arguments: parquet, [orderProposalId#778320L, orderProposalItemId#778321, supplierGroup#778322, supplier#778323, plant#778324, deliveryDateTime#778325, subrange#778326, supplyingPlant#778327, productGroup#778328, product#778329, orderDateTime#778330, availabilityDateTime#778331, nextAvailabilityDateTime#778332, mrpController#778333, sourceOfSupplyUuid#778334, purchasingOrg#778335, purchasingGroup#778336, isFallbackOrderOnly#778337, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, sequenceId#778342, worklistShardItemId#778343L, orderProposalItemGroupId#778344, ... 20 more fields], false
(16) Filter
Arguments: (shardId#778364 = 0_1_10000002108)
(17) RepartitionByExpression
Arguments: [worklistShardItemId#778343L], 20
(18) Filter
Arguments: (sequenceId#778342 = 1)
(19) Project
Arguments: [orderProposalId#778320L, orderProposalItemId#778321, supplierGroup#778322, supplier#778323, plant#778324, deliveryDateTime#778325, subrange#778326, supplyingPlant#778327, productGroup#778328, product#778329, orderDateTime#778330, availabilityDateTime#778331, nextAvailabilityDateTime#778332, mrpController#778333, sourceOfSupplyUuid#778334, purchasingOrg#778335, purchasingGroup#778336, isFallbackOrderOnly#778337, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, sequenceId#778342, worklistShardItemId#778343L, orderProposalItemGroupId#778344, ... 20 more fields]
(20) Project
Arguments: [shardId#778366, worklistShardItemId#778343L, orderProposalId#778320L, orderProposalItemId#778321, orderProposalItemGroupId#778344, originalReplenishmentRunId#778362L, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, sequenceId#778342, sourceOfSupplyUuid#778334, supplierGroup#778322, supplier#778323, subrange#778326, product#778329, plant#778324, purchasingOrg#778335, purchasingGroup#778336, mrpController#778333, orderDateTime#778330, deliveryDateTime#778325, availabilityDateTime#778331, nextAvailabilityDateTime#778332, isFallbackOrderOnly#778337, ... 20 more fields]
(21) Project
Arguments: [shardId#778366, worklistShardItemId#778343L, orderProposalId#778320L, orderProposalItemId#778321, orderProposalItemGroupId#778344, originalReplenishmentRunId#778362L, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, cast(sequenceId#778342 as bigint) AS sequenceId#778367L, sourceOfSupplyUuid#778334, supplierGroup#778322, supplier#778323, subrange#778326, product#778329, plant#778324, purchasingOrg#778335, purchasingGroup#778336, mrpController#778333, orderDateTime#778330, deliveryDateTime#778325, availabilityDateTime#778331, nextAvailabilityDateTime#778332, isFallbackOrderOnly#778337, ... 20 more fields]
(22) Union
Arguments: false, false
(23) Join
Arguments: LeftOuter, ((shardId#781926 = shardId#778275) AND (worklistShardItemId#778119L = worklistShardItemId#778276L))
(24) Project
Arguments: [shardId#781926, worklistShardItemId#778119L, quantityAfterProdPlantOptimization#778120, qty#778121, orderProposalId#778277L, orderProposalItemId#778278, orderProposalItemGroupId#778279, originalReplenishmentRunId#778280L, orderProposalHorizonGroupingId#778281L, splitIndicator#778282L, previousOrderProposal#778283L, clusterId#778284L, sequenceId#778285L, sourceOfSupplyUuid#778286, supplierGroup#778287, supplier#778288, subrange#778289, product#778290, plant#778291, purchasingOrg#778292, purchasingGroup#778293, mrpController#778294, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, ... 22 more fields]
(25) Project
Arguments: [shardId#781926, worklistShardItemId#778119L, quantityAfterProdPlantOptimization#778120, qty#778121, orderProposalId#778277L, originalReplenishmentRunId#778280L, supplierGroup#778287, supplier#778288, supplyingPlant#778318, productGroup#778319, product#778290, plant#778291, subrange#778289, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, nextAvailabilityDateTime#778298, constraintValues#778312, constraintOperators#778310, constraintLabels#778309, logisticUnits#778314, orderQuantityBaseUom#778300, orderQuantityBaseUomUuid#778301, splitIndicator#778282L, netPriceAmount#778305, ... 14 more fields]
(26) Filter
Arguments: NOT (isFallbackOrderOnly#778299 <=> true)
(27) Project
Arguments: [orderProposalId#778277L]
(28) Deduplicate
Arguments: [orderProposalId#778277L]
(29) Join
Arguments: Inner, (orderProposalId#777608L = orderProposalId#778277L)
(30) Project
Arguments: [orderProposalId#777608L, shardId#777607, items#777609, optimizationGroups#777610, isOptimal#777611, optimizationInsights#777613]
(31) Generate
Arguments: explode(optimizationInsights#777613), false, [insight#781934]
(32) Project
Arguments: [shardId#777607, orderProposalId#777608L, insight#781934]
(33) Project
Arguments: [shardId#777607, orderProposalId#777608L, insight#781934.internalInsightType AS internalInsightType#781935, insight#781934.worklistShardItemId AS worklistShardItemId#781936L, insight#781934.thresholdValue AS thresholdValue#781937, insight#781934.reachedValue AS reachedValue#781938, insight#781934.unitOfMeasure AS unitOfMeasure#781939, insight#781934.assignmentDetails AS assignmentDetails#781940]
(34) LocalRelation
Arguments: <empty>, [shardId#782316, worklistShardItemId#782317L, orderProposalId#782318L, orderProposalItemId#782319, orderProposalItemGroupId#782320, originalReplenishmentRunId#782321L, orderProposalHorizonGroupingId#782322L, splitIndicator#782323L, previousOrderProposal#782324L, clusterId#782325L, sequenceId#782326L, sourceOfSupplyUuid#782327, supplierGroup#782328, supplier#782329, subrange#782330, product#782331, plant#782332, purchasingOrg#782333, purchasingGroup#782334, mrpController#782335, orderDateTime#782336, deliveryDateTime#782337, availabilityDateTime#782338, nextAvailabilityDateTime#782339, isFallbackOrderOnly#782340, ... 20 more fields]
(35) LogicalRelation
Arguments: parquet, [orderProposalId#782361L, orderProposalItemId#782362, supplierGroup#782363, supplier#782364, plant#782365, deliveryDateTime#782366, subrange#782367, supplyingPlant#782368, productGroup#782369, product#782370, orderDateTime#782371, availabilityDateTime#782372, nextAvailabilityDateTime#782373, mrpController#782374, sourceOfSupplyUuid#782375, purchasingOrg#782376, purchasingGroup#782377, isFallbackOrderOnly#782378, orderProposalHorizonGroupingId#782379L, splitIndicator#782380L, previousOrderProposal#782381L, clusterId#782382L, sequenceId#782383, worklistShardItemId#782384L, orderProposalItemGroupId#782385, ... 20 more fields], false
(36) Filter
Arguments: (shardId#782405 = 0_1_10000002108)
(37) RepartitionByExpression
Arguments: [worklistShardItemId#782384L], 20
(38) Filter
Arguments: (sequenceId#782383 = 1)
(39) Project
Arguments: [orderProposalId#782361L, orderProposalItemId#782362, supplierGroup#782363, supplier#782364, plant#782365, deliveryDateTime#782366, subrange#782367, supplyingPlant#782368, productGroup#782369, product#782370, orderDateTime#782371, availabilityDateTime#782372, nextAvailabilityDateTime#782373, mrpController#782374, sourceOfSupplyUuid#782375, purchasingOrg#782376, purchasingGroup#782377, isFallbackOrderOnly#782378, orderProposalHorizonGroupingId#782379L, splitIndicator#782380L, previousOrderProposal#782381L, clusterId#782382L, sequenceId#782383, worklistShardItemId#782384L, orderProposalItemGroupId#782385, ... 20 more fields]
(40) Project
Arguments: [shardId#782407, worklistShardItemId#782384L, orderProposalId#782361L, orderProposalItemId#782362, orderProposalItemGroupId#782385, originalReplenishmentRunId#782403L, orderProposalHorizonGroupingId#782379L, splitIndicator#782380L, previousOrderProposal#782381L, clusterId#782382L, sequenceId#782383, sourceOfSupplyUuid#782375, supplierGroup#782363, supplier#782364, subrange#782367, product#782370, plant#782365, purchasingOrg#782376, purchasingGroup#782377, mrpController#782374, orderDateTime#782371, deliveryDateTime#782366, availabilityDateTime#782372, nextAvailabilityDateTime#782373, isFallbackOrderOnly#782378, ... 20 more fields]
(41) Project
Arguments: [shardId#782407, worklistShardItemId#782384L, orderProposalId#782361L, orderProposalItemId#782362, orderProposalItemGroupId#782385, originalReplenishmentRunId#782403L, orderProposalHorizonGroupingId#782379L, splitIndicator#782380L, previousOrderProposal#782381L, clusterId#782382L, cast(sequenceId#782383 as bigint) AS sequenceId#782408L, sourceOfSupplyUuid#782375, supplierGroup#782363, supplier#782364, subrange#782367, product#782370, plant#782365, purchasingOrg#782376, purchasingGroup#782377, mrpController#782374, orderDateTime#782371, deliveryDateTime#782366, availabilityDateTime#782372, nextAvailabilityDateTime#782373, isFallbackOrderOnly#782378, ... 20 more fields]
(42) Union
Arguments: false, false
(43) Join
Arguments: LeftOuter, ((shardId#777607 = shardId#782316) AND (worklistShardItemId#781936L = worklistShardItemId#782317L))
(44) Project
Arguments: [shardId#777607, worklistShardItemId#781936L, orderProposalId#777608L, internalInsightType#781935, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, orderProposalId#782318L, orderProposalItemId#782319, orderProposalItemGroupId#782320, originalReplenishmentRunId#782321L, orderProposalHorizonGroupingId#782322L, splitIndicator#782323L, previousOrderProposal#782324L, clusterId#782325L, sequenceId#782326L, sourceOfSupplyUuid#782327, supplierGroup#782328, supplier#782329, subrange#782330, product#782331, plant#782332, purchasingOrg#782333, purchasingGroup#782334, ... 26 more fields]
(45) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, supplier#782329]
(46) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, supplier#782329, null AS businessContext#782713, null AS configurationVersion#782714]
(47) LogicalRDD
Arguments: [shardId#782600, orderProposalId#782601L, items#782602, optimizationGroups#782603, isOptimal#782604, lastModified#782605, optimizationInsights#782606], false
(48) Filter
Arguments: shardId#782600 IN (0_1_10000002108)
(49) Filter
Arguments: shardId#782600 IN (0_1_10000002108)
(50) Project
Arguments: [shardId#782600, orderProposalId#782601L, items#782602, optimizationGroups#782603, isOptimal#782604, optimizationInsights#782606]
(51) Generate
Arguments: explode(items#782602), false, [item#782607]
(52) Project
Arguments: [shardId#782600, item#782607]
(53) Project
Arguments: [shardId#782600, item#782607.worklistShardItemId AS worklistShardItemId#782608L, item#782607.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#782609, item#782607.qty AS qty#782610]
(54) LocalRelation
Arguments: <empty>, [shardId#782611, worklistShardItemId#782612L, orderProposalId#782613L, orderProposalItemId#782614, orderProposalItemGroupId#782615, originalReplenishmentRunId#782616L, orderProposalHorizonGroupingId#782617L, splitIndicator#782618L, previousOrderProposal#782619L, clusterId#782620L, sequenceId#782621L, sourceOfSupplyUuid#782622, supplierGroup#782623, supplier#782624, subrange#782625, product#782626, plant#782627, purchasingOrg#782628, purchasingGroup#782629, mrpController#782630, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, isFallbackOrderOnly#782635, ... 20 more fields]
(55) LogicalRelation
Arguments: parquet, [orderProposalId#782656L, orderProposalItemId#782657, supplierGroup#782658, supplier#782659, plant#782660, deliveryDateTime#782661, subrange#782662, supplyingPlant#782663, productGroup#782664, product#782665, orderDateTime#782666, availabilityDateTime#782667, nextAvailabilityDateTime#782668, mrpController#782669, sourceOfSupplyUuid#782670, purchasingOrg#782671, purchasingGroup#782672, isFallbackOrderOnly#782673, orderProposalHorizonGroupingId#782674L, splitIndicator#782675L, previousOrderProposal#782676L, clusterId#782677L, sequenceId#782678, worklistShardItemId#782679L, orderProposalItemGroupId#782680, ... 20 more fields], false
(56) Filter
Arguments: (shardId#782700 = 0_1_10000002108)
(57) RepartitionByExpression
Arguments: [worklistShardItemId#782679L], 20
(58) Filter
Arguments: (sequenceId#782678 = 1)
(59) Project
Arguments: [orderProposalId#782656L, orderProposalItemId#782657, supplierGroup#782658, supplier#782659, plant#782660, deliveryDateTime#782661, subrange#782662, supplyingPlant#782663, productGroup#782664, product#782665, orderDateTime#782666, availabilityDateTime#782667, nextAvailabilityDateTime#782668, mrpController#782669, sourceOfSupplyUuid#782670, purchasingOrg#782671, purchasingGroup#782672, isFallbackOrderOnly#782673, orderProposalHorizonGroupingId#782674L, splitIndicator#782675L, previousOrderProposal#782676L, clusterId#782677L, sequenceId#782678, worklistShardItemId#782679L, orderProposalItemGroupId#782680, ... 20 more fields]
(60) Project
Arguments: [shardId#782701, worklistShardItemId#782679L, orderProposalId#782656L, orderProposalItemId#782657, orderProposalItemGroupId#782680, originalReplenishmentRunId#782698L, orderProposalHorizonGroupingId#782674L, splitIndicator#782675L, previousOrderProposal#782676L, clusterId#782677L, sequenceId#782678, sourceOfSupplyUuid#782670, supplierGroup#782658, supplier#782659, subrange#782662, product#782665, plant#782660, purchasingOrg#782671, purchasingGroup#782672, mrpController#782669, orderDateTime#782666, deliveryDateTime#782661, availabilityDateTime#782667, nextAvailabilityDateTime#782668, isFallbackOrderOnly#782673, ... 20 more fields]
(61) Project
Arguments: [shardId#782701, worklistShardItemId#782679L, orderProposalId#782656L, orderProposalItemId#782657, orderProposalItemGroupId#782680, originalReplenishmentRunId#782698L, orderProposalHorizonGroupingId#782674L, splitIndicator#782675L, previousOrderProposal#782676L, clusterId#782677L, cast(sequenceId#782678 as bigint) AS sequenceId#782702L, sourceOfSupplyUuid#782670, supplierGroup#782658, supplier#782659, subrange#782662, product#782665, plant#782660, purchasingOrg#782671, purchasingGroup#782672, mrpController#782669, orderDateTime#782666, deliveryDateTime#782661, availabilityDateTime#782667, nextAvailabilityDateTime#782668, isFallbackOrderOnly#782673, ... 20 more fields]
(62) Union
Arguments: false, false
(63) Join
Arguments: LeftOuter, ((shardId#782600 = shardId#782611) AND (worklistShardItemId#782608L = worklistShardItemId#782612L))
(64) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, orderProposalItemId#782614, orderProposalItemGroupId#782615, originalReplenishmentRunId#782616L, orderProposalHorizonGroupingId#782617L, splitIndicator#782618L, previousOrderProposal#782619L, clusterId#782620L, sequenceId#782621L, sourceOfSupplyUuid#782622, supplierGroup#782623, supplier#782624, subrange#782625, product#782626, plant#782627, purchasingOrg#782628, purchasingGroup#782629, mrpController#782630, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, ... 22 more fields]
(65) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, originalReplenishmentRunId#782616L, supplierGroup#782623, supplier#782624, supplyingPlant#782654, productGroup#782655, product#782626, plant#782627, subrange#782625, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, constraintValues#782648, constraintOperators#782646, constraintLabels#782645, logisticUnits#782650, orderQuantityBaseUom#782636, orderQuantityBaseUomUuid#782637, splitIndicator#782618L, netPriceAmount#782641, ... 14 more fields]
(66) LogicalRDD
Arguments: [shardId#779016, worklistShardItemId#779017L, qty#779018, demandChannel#779019, demandStream#779020, kpis#779021], false
(67) Filter
Arguments: ((isnull(qty#779018) AND isnull(demandChannel#779019)) AND isnull(demandStream#779020))
(68) Project
Arguments: [shardId#779016, worklistShardItemId#779017L, coalesce(kpis#779021, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#779022]
(69) Join
Arguments: LeftOuter, ((shardId#782600 = shardId#779016) AND (worklistShardItemId#782608L = worklistShardItemId#779017L))
(70) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, originalReplenishmentRunId#782616L, supplierGroup#782623, supplier#782624, supplyingPlant#782654, productGroup#782655, product#782626, plant#782627, subrange#782625, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, constraintValues#782648, constraintOperators#782646, constraintLabels#782645, logisticUnits#782650, orderQuantityBaseUom#782636, orderQuantityBaseUomUuid#782637, splitIndicator#782618L, netPriceAmount#782641, ... 15 more fields]
(71) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, originalReplenishmentRunId#782616L, supplierGroup#782623, supplier#782624, supplyingPlant#782654, productGroup#782655, product#782626, plant#782627, subrange#782625, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, constraintValues#782648, constraintOperators#782646, constraintLabels#782645, logisticUnits#782650, orderQuantityBaseUom#782636, orderQuantityBaseUomUuid#782637, splitIndicator#782618L, netPriceAmount#782641, ... 15 more fields]
(72) LogicalRDD
Arguments: [shardId#779032, worklistShardItemId#779033L, qty#779034, demandChannel#779035, demandStream#779036, kpis#779037], false
(73) Filter
Arguments: (((isnull(qty#779034) AND isnotnull(demandChannel#779035)) AND isnotnull(demandStream#779036)) AND (size(kpis#779037, true) > 0))
(74) Aggregate
Arguments: [shardId#779032, worklistShardItemId#779033L], [shardId#779032, worklistShardItemId#779033L, collect_list(struct(demandChannel, demandChannel#779035, demandStream, demandStream#779036, kpis, kpis#779037), 0, 0) AS channelStreamSpecificKpis#779024]
(75) Join
Arguments: LeftOuter, ((shardId#782600 = shardId#779032) AND (worklistShardItemId#782608L = worklistShardItemId#779033L))
(76) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, originalReplenishmentRunId#782616L, supplierGroup#782623, supplier#782624, supplyingPlant#782654, productGroup#782655, product#782626, plant#782627, subrange#782625, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, constraintValues#782648, constraintOperators#782646, constraintLabels#782645, logisticUnits#782650, orderQuantityBaseUom#782636, orderQuantityBaseUomUuid#782637, splitIndicator#782618L, netPriceAmount#782641, ... 16 more fields]
(77) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, originalReplenishmentRunId#782616L, supplierGroup#782623, supplier#782624, supplyingPlant#782654, productGroup#782655, product#782626, plant#782627, subrange#782625, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, constraintValues#782648, constraintOperators#782646, constraintLabels#782645, logisticUnits#782650, orderQuantityBaseUom#782636, orderQuantityBaseUomUuid#782637, splitIndicator#782618L, netPriceAmount#782641, ... 16 more fields]
(78) LogicalRDD
Arguments: [shardId#779045, worklistShardItemId#779046L, qty#779047, demandChannel#779048, demandStream#779049, kpis#779050], false
(79) Filter
Arguments: (isnotnull(qty#779047) AND isnotnull(kpis#779050))
(80) Project
Arguments: [shardId#779045, worklistShardItemId#779046L, qty#779047, kpis#779050]
(81) Aggregate
Arguments: [shardId#779045, worklistShardItemId#779046L], [shardId#779045, worklistShardItemId#779046L, map_from_entries(collect_list(struct(qty, qty#779047, kpis, kpis#779050), 0, 0)) AS quantityKpis#779039]
(82) Join
Arguments: LeftOuter, ((shardId#782600 = shardId#779045) AND (worklistShardItemId#782608L = worklistShardItemId#779046L))
(83) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, originalReplenishmentRunId#782616L, supplierGroup#782623, supplier#782624, supplyingPlant#782654, productGroup#782655, product#782626, plant#782627, subrange#782625, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, constraintValues#782648, constraintOperators#782646, constraintLabels#782645, logisticUnits#782650, orderQuantityBaseUom#782636, orderQuantityBaseUomUuid#782637, splitIndicator#782618L, netPriceAmount#782641, ... 17 more fields]
(84) Project
Arguments: [shardId#782600, worklistShardItemId#782608L, quantityAfterProdPlantOptimization#782609, qty#782610, orderProposalId#782613L, originalReplenishmentRunId#782616L, supplierGroup#782623, supplier#782624, supplyingPlant#782654, productGroup#782655, product#782626, plant#782627, subrange#782625, orderDateTime#782631, deliveryDateTime#782632, availabilityDateTime#782633, nextAvailabilityDateTime#782634, constraintValues#782648, constraintOperators#782646, constraintLabels#782645, logisticUnits#782650, orderQuantityBaseUom#782636, orderQuantityBaseUomUuid#782637, splitIndicator#782618L, netPriceAmount#782641, ... 17 more fields]
(85) Filter
Arguments: NOT (isFallbackOrderOnly#782635 <=> true)
(86) LocalRelation
Arguments: <empty>, [shardId#782409, uomCategories#782410]
(87) Project
Arguments: [shardId#782409, uomCategories#782410, null AS insightConfigurations#782416]
(88) LogicalRelation
Arguments: parquet, [uomCategories#782411, insightConfigurations#782412, shardId#782413], false
(89) Filter
Arguments: (shardId#782413 = 0_1_10000002108)
(90) RepartitionByExpression
Arguments: 20
(91) Project
Arguments: [uomCategories#782411, insightConfigurations#782412, 0_1_10000002108 AS shardId#782415]
(92) Project
Arguments: [shardId#782415, uomCategories#782411, insightConfigurations#782412]
(93) Union
Arguments: false, false
(94) Project
Arguments: [insightConfigurations#782416]
(95) Join
Arguments: Cross
(96) Filter
Arguments: (((isnotnull(insightConfigurations#782416[POTENTIAL_OOS_STOCK_PERIOD]) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#779023, lambdafunction((lambda x_2066#782417.label = OutOfStockProbability), lambda x_2066#782417, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#782416[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2067#782418.name = OOS_PROBABILITY_THRESHOLD), lambda x_2067#782418, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#779023, lambdafunction((lambda x_2066#782419.label = OutOfStockProbability), lambda x_2066#782419, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#782416[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2067#782420.name = OOS_PROBABILITY_THRESHOLD), lambda x_2067#782420, false)), 1, None, false).value as double)) END) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#779023, lambdafunction((lambda x_2068#782421.label = InitialStockQty), lambda x_2068#782421, false)), 1, None, false).value) OR isnull(CASE WHEN cast(element_at(filter(insightConfigurations#782416[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2069#782422.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_2069#782422, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END)) THEN false ELSE (element_at(filter(prodLocSpecificKpis#779023, lambdafunction((lambda x_2068#782423.label = InitialStockQty), lambda x_2068#782423, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(insightConfigurations#782416[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2069#782424.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_2069#782424, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (isnull(CASE WHEN isnull(orderDateTime#782631) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#782631, 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#782416[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2070#782425.name = OFFSET_CURRENT_ORDER_DATE), lambda x_2070#782425, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#782631) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#782631, 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#782416[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2070#782426.name = OFFSET_CURRENT_ORDER_DATE), lambda x_2070#782426, false)), 1, None, false).value as double)) END)
(97) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#782613L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#782614 as string)), struct(name, PRODUCT, value, cast(externalProductId#782652 as string)), struct(name, PLANT, value, cast(externalPlantId#782653 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#782631 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(prodLocSpecificKpis#779023, lambdafunction((lambda x_2071#782442.label = UnfulfilledDemandQty), lambda x_2071#782442, false)), 1, None, false).value as string))) AS businessContext#782439, POTENTIAL_OOS_STOCK_PERIOD AS internalInsightType#782440, insightConfigurations#782416[POTENTIAL_OOS_STOCK_PERIOD].configurationVersion AS configurationVersion#782441]
(98) LogicalRDD
Arguments: [shardId#782463, orderProposalId#782464L, items#782465, optimizationGroups#782466, isOptimal#782467, lastModified#782468, optimizationInsights#782469], false
(99) Filter
Arguments: shardId#782463 IN (0_1_10000002108)
(100) Filter
Arguments: shardId#782463 IN (0_1_10000002108)
(101) Project
Arguments: [shardId#782463, orderProposalId#782464L, items#782465, optimizationGroups#782466, isOptimal#782467, optimizationInsights#782469]
(102) Generate
Arguments: explode(items#782465), false, [item#782470]
(103) Project
Arguments: [shardId#782463, item#782470]
(104) Project
Arguments: [shardId#782463, item#782470.worklistShardItemId AS worklistShardItemId#782471L, item#782470.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#782472, item#782470.qty AS qty#782473]
(105) LocalRelation
Arguments: <empty>, [shardId#782474, worklistShardItemId#782475L, orderProposalId#782476L, orderProposalItemId#782477, orderProposalItemGroupId#782478, originalReplenishmentRunId#782479L, orderProposalHorizonGroupingId#782480L, splitIndicator#782481L, previousOrderProposal#782482L, clusterId#782483L, sequenceId#782484L, sourceOfSupplyUuid#782485, supplierGroup#782486, supplier#782487, subrange#782488, product#782489, plant#782490, purchasingOrg#782491, purchasingGroup#782492, mrpController#782493, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, isFallbackOrderOnly#782498, ... 20 more fields]
(106) LogicalRelation
Arguments: parquet, [orderProposalId#782519L, orderProposalItemId#782520, supplierGroup#782521, supplier#782522, plant#782523, deliveryDateTime#782524, subrange#782525, supplyingPlant#782526, productGroup#782527, product#782528, orderDateTime#782529, availabilityDateTime#782530, nextAvailabilityDateTime#782531, mrpController#782532, sourceOfSupplyUuid#782533, purchasingOrg#782534, purchasingGroup#782535, isFallbackOrderOnly#782536, orderProposalHorizonGroupingId#782537L, splitIndicator#782538L, previousOrderProposal#782539L, clusterId#782540L, sequenceId#782541, worklistShardItemId#782542L, orderProposalItemGroupId#782543, ... 20 more fields], false
(107) Filter
Arguments: (shardId#782563 = 0_1_10000002108)
(108) RepartitionByExpression
Arguments: [worklistShardItemId#782542L], 20
(109) Filter
Arguments: (sequenceId#782541 = 1)
(110) Project
Arguments: [orderProposalId#782519L, orderProposalItemId#782520, supplierGroup#782521, supplier#782522, plant#782523, deliveryDateTime#782524, subrange#782525, supplyingPlant#782526, productGroup#782527, product#782528, orderDateTime#782529, availabilityDateTime#782530, nextAvailabilityDateTime#782531, mrpController#782532, sourceOfSupplyUuid#782533, purchasingOrg#782534, purchasingGroup#782535, isFallbackOrderOnly#782536, orderProposalHorizonGroupingId#782537L, splitIndicator#782538L, previousOrderProposal#782539L, clusterId#782540L, sequenceId#782541, worklistShardItemId#782542L, orderProposalItemGroupId#782543, ... 20 more fields]
(111) Project
Arguments: [shardId#782564, worklistShardItemId#782542L, orderProposalId#782519L, orderProposalItemId#782520, orderProposalItemGroupId#782543, originalReplenishmentRunId#782561L, orderProposalHorizonGroupingId#782537L, splitIndicator#782538L, previousOrderProposal#782539L, clusterId#782540L, sequenceId#782541, sourceOfSupplyUuid#782533, supplierGroup#782521, supplier#782522, subrange#782525, product#782528, plant#782523, purchasingOrg#782534, purchasingGroup#782535, mrpController#782532, orderDateTime#782529, deliveryDateTime#782524, availabilityDateTime#782530, nextAvailabilityDateTime#782531, isFallbackOrderOnly#782536, ... 20 more fields]
(112) Project
Arguments: [shardId#782564, worklistShardItemId#782542L, orderProposalId#782519L, orderProposalItemId#782520, orderProposalItemGroupId#782543, originalReplenishmentRunId#782561L, orderProposalHorizonGroupingId#782537L, splitIndicator#782538L, previousOrderProposal#782539L, clusterId#782540L, cast(sequenceId#782541 as bigint) AS sequenceId#782565L, sourceOfSupplyUuid#782533, supplierGroup#782521, supplier#782522, subrange#782525, product#782528, plant#782523, purchasingOrg#782534, purchasingGroup#782535, mrpController#782532, orderDateTime#782529, deliveryDateTime#782524, availabilityDateTime#782530, nextAvailabilityDateTime#782531, isFallbackOrderOnly#782536, ... 20 more fields]
(113) Union
Arguments: false, false
(114) Join
Arguments: LeftOuter, ((shardId#782463 = shardId#782474) AND (worklistShardItemId#782471L = worklistShardItemId#782475L))
(115) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, orderProposalItemId#782477, orderProposalItemGroupId#782478, originalReplenishmentRunId#782479L, orderProposalHorizonGroupingId#782480L, splitIndicator#782481L, previousOrderProposal#782482L, clusterId#782483L, sequenceId#782484L, sourceOfSupplyUuid#782485, supplierGroup#782486, supplier#782487, subrange#782488, product#782489, plant#782490, purchasingOrg#782491, purchasingGroup#782492, mrpController#782493, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, ... 22 more fields]
(116) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, originalReplenishmentRunId#782479L, supplierGroup#782486, supplier#782487, supplyingPlant#782517, productGroup#782518, product#782489, plant#782490, subrange#782488, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, constraintValues#782511, constraintOperators#782509, constraintLabels#782508, logisticUnits#782513, orderQuantityBaseUom#782499, orderQuantityBaseUomUuid#782500, splitIndicator#782481L, netPriceAmount#782504, ... 14 more fields]
(117) LogicalRDD
Arguments: [shardId#782566, worklistShardItemId#782567L, qty#782568, demandChannel#782569, demandStream#782570, kpis#782571], false
(118) Filter
Arguments: ((isnull(qty#782568) AND isnull(demandChannel#782569)) AND isnull(demandStream#782570))
(119) Project
Arguments: [shardId#782566, worklistShardItemId#782567L, coalesce(kpis#782571, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#782572]
(120) Join
Arguments: LeftOuter, ((shardId#782463 = shardId#782566) AND (worklistShardItemId#782471L = worklistShardItemId#782567L))
(121) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, originalReplenishmentRunId#782479L, supplierGroup#782486, supplier#782487, supplyingPlant#782517, productGroup#782518, product#782489, plant#782490, subrange#782488, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, constraintValues#782511, constraintOperators#782509, constraintLabels#782508, logisticUnits#782513, orderQuantityBaseUom#782499, orderQuantityBaseUomUuid#782500, splitIndicator#782481L, netPriceAmount#782504, ... 15 more fields]
(122) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, originalReplenishmentRunId#782479L, supplierGroup#782486, supplier#782487, supplyingPlant#782517, productGroup#782518, product#782489, plant#782490, subrange#782488, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, constraintValues#782511, constraintOperators#782509, constraintLabels#782508, logisticUnits#782513, orderQuantityBaseUom#782499, orderQuantityBaseUomUuid#782500, splitIndicator#782481L, netPriceAmount#782504, ... 15 more fields]
(123) LogicalRDD
Arguments: [shardId#782574, worklistShardItemId#782575L, qty#782576, demandChannel#782577, demandStream#782578, kpis#782579], false
(124) Filter
Arguments: (((isnull(qty#782576) AND isnotnull(demandChannel#782577)) AND isnotnull(demandStream#782578)) AND (size(kpis#782579, true) > 0))
(125) Aggregate
Arguments: [shardId#782574, worklistShardItemId#782575L], [shardId#782574, worklistShardItemId#782575L, collect_list(struct(demandChannel, demandChannel#782577, demandStream, demandStream#782578, kpis, kpis#782579), 0, 0) AS channelStreamSpecificKpis#782580]
(126) Join
Arguments: LeftOuter, ((shardId#782463 = shardId#782574) AND (worklistShardItemId#782471L = worklistShardItemId#782575L))
(127) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, originalReplenishmentRunId#782479L, supplierGroup#782486, supplier#782487, supplyingPlant#782517, productGroup#782518, product#782489, plant#782490, subrange#782488, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, constraintValues#782511, constraintOperators#782509, constraintLabels#782508, logisticUnits#782513, orderQuantityBaseUom#782499, orderQuantityBaseUomUuid#782500, splitIndicator#782481L, netPriceAmount#782504, ... 16 more fields]
(128) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, originalReplenishmentRunId#782479L, supplierGroup#782486, supplier#782487, supplyingPlant#782517, productGroup#782518, product#782489, plant#782490, subrange#782488, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, constraintValues#782511, constraintOperators#782509, constraintLabels#782508, logisticUnits#782513, orderQuantityBaseUom#782499, orderQuantityBaseUomUuid#782500, splitIndicator#782481L, netPriceAmount#782504, ... 16 more fields]
(129) LogicalRDD
Arguments: [shardId#782582, worklistShardItemId#782583L, qty#782584, demandChannel#782585, demandStream#782586, kpis#782587], false
(130) Filter
Arguments: (isnotnull(qty#782584) AND isnotnull(kpis#782587))
(131) Project
Arguments: [shardId#782582, worklistShardItemId#782583L, qty#782584, kpis#782587]
(132) Aggregate
Arguments: [shardId#782582, worklistShardItemId#782583L], [shardId#782582, worklistShardItemId#782583L, map_from_entries(collect_list(struct(qty, qty#782584, kpis, kpis#782587), 0, 0)) AS quantityKpis#782588]
(133) Join
Arguments: LeftOuter, ((shardId#782463 = shardId#782582) AND (worklistShardItemId#782471L = worklistShardItemId#782583L))
(134) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, originalReplenishmentRunId#782479L, supplierGroup#782486, supplier#782487, supplyingPlant#782517, productGroup#782518, product#782489, plant#782490, subrange#782488, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, constraintValues#782511, constraintOperators#782509, constraintLabels#782508, logisticUnits#782513, orderQuantityBaseUom#782499, orderQuantityBaseUomUuid#782500, splitIndicator#782481L, netPriceAmount#782504, ... 17 more fields]
(135) Project
Arguments: [shardId#782463, worklistShardItemId#782471L, quantityAfterProdPlantOptimization#782472, qty#782473, orderProposalId#782476L, originalReplenishmentRunId#782479L, supplierGroup#782486, supplier#782487, supplyingPlant#782517, productGroup#782518, product#782489, plant#782490, subrange#782488, orderDateTime#782494, deliveryDateTime#782495, availabilityDateTime#782496, nextAvailabilityDateTime#782497, constraintValues#782511, constraintOperators#782509, constraintLabels#782508, logisticUnits#782513, orderQuantityBaseUom#782499, orderQuantityBaseUomUuid#782500, splitIndicator#782481L, netPriceAmount#782504, ... 17 more fields]
(136) Filter
Arguments: NOT (isFallbackOrderOnly#782498 <=> true)
(137) LocalRelation
Arguments: <empty>, [shardId#782590, uomCategories#782591]
(138) Project
Arguments: [shardId#782590, uomCategories#782591, null AS insightConfigurations#782592]
(139) LogicalRelation
Arguments: parquet, [uomCategories#782593, insightConfigurations#782594, shardId#782595], false
(140) Filter
Arguments: (shardId#782595 = 0_1_10000002108)
(141) RepartitionByExpression
Arguments: 20
(142) Project
Arguments: [uomCategories#782593, insightConfigurations#782594, 0_1_10000002108 AS shardId#782596]
(143) Project
Arguments: [shardId#782596, uomCategories#782593, insightConfigurations#782594]
(144) Union
Arguments: false, false
(145) Project
Arguments: [insightConfigurations#782592]
(146) Join
Arguments: Cross
(147) Filter
Arguments: (isnotnull(insightConfigurations#782592[POTENTIAL_OOS_DEMAND_PERIOD]) AND CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#782589, qty#782473, None, false), lambdafunction((lambda x_2072#782443.label = OutOfStockProbability), lambda x_2072#782443, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#782592[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_2073#782444.name = OOS_PROBABILITY_THRESHOLD), lambda x_2073#782444, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#782589, qty#782473, None, false), lambdafunction((lambda x_2072#782445.label = OutOfStockProbability), lambda x_2072#782445, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#782592[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_2073#782446.name = OOS_PROBABILITY_THRESHOLD), lambda x_2073#782446, false)), 1, None, false).value as double)) END)
(148) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#782476L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#782477 as string)), struct(name, PRODUCT, value, cast(externalProductId#782515 as string)), struct(name, PLANT, value, cast(externalPlantId#782516 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#782494 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(element_at(quantityKpis#782589, qty#782473, None, false), lambdafunction((lambda x_2074#782462.label = UnfulfilledDemandQty), lambda x_2074#782462, false)), 1, None, false).value as string))) AS businessContext#782459, POTENTIAL_OOS_DEMAND_PERIOD AS internalInsightType#782460, insightConfigurations#782592[POTENTIAL_OOS_DEMAND_PERIOD].configurationVersion AS configurationVersion#782461]
(149) Union
Arguments: false, false
(150) Project
Arguments: [businessContext#782439, internalInsightType#782440, configurationVersion#782441, cast(null as string) AS supplier#782599]
(151) Project
Arguments: [null AS shardId#782703, null AS orderProposalId#782704L, internalInsightType#782440, null AS worklistShardItemId#782705L, null AS thresholdValue#782706, null AS reachedValue#782707, null AS unitOfMeasure#782708, null AS assignmentDetails#782709, null AS externalProductId#782710, null AS externalPlantId#782711, null AS orderProposalItemId#782712, supplier#782599, businessContext#782439, configurationVersion#782441]
(152) Union
Arguments: false, false
(153) Filter
Arguments: internalInsightType#781935 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#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, supplier#782329, businessContext#782713, configurationVersion#782714, struct(insightType, CASE WHEN (internalInsightType#781935 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, 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#781940, 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#781940, 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#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#781935 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, 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#781940, 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#781940, 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#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#781935 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, 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#781940, 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#781940, 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#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#781935 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, 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#781940, 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#781940, 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#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#781935 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, 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#781940, 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#781940, 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#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#781935 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#782329 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#785719]
(156) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightTypeInfo#785719]
(157) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightTypeInfo#785719.insightType AS insightType#785720, insightTypeInfo#785719.supplierGroup AS supplierGroup#785721, insightTypeInfo#785719.supplier AS supplier#785722, insightTypeInfo#785719.supplierSubrange AS supplierSubrange#785723]
(158) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightType#785720, supplierGroup#785721, supplier#785722, supplierSubrange#785723, CASE WHEN (insightType#785720 = 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#785722 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#785723 as string))) ELSE CASE WHEN (insightType#785720 = 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#785721 as string))) ELSE CASE WHEN (insightType#785720 = 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#785722 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#785723 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#785721 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#785723 as string)), struct(objectType, Product, objectId, cast(externalProductId#782357 as string)), struct(objectType, Location, objectId, cast(externalPlantId#782358 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#785721 as string)), struct(objectType, Product, objectId, cast(externalProductId#782357 as string)), struct(objectType, Location, objectId, cast(externalPlantId#782358 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string)), struct(objectType, Product, objectId, cast(externalProductId#782357 as string)), struct(objectType, Location, objectId, cast(externalPlantId#782358 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#785723 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#785721 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#785723 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#785721 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#785722 as string))) END END END END END END END END END END END END END END END AS triggerObject#785806]
(159) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightType#785720, supplierGroup#785721, supplier#785722, supplierSubrange#785723, triggerObject#785806, CASE WHEN (insightType#785720 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightType#785720 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightType#785720 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#782319 as string))) END END END END END END END END END END END END END END END AS anchorObject#785855]
(160) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightType#785720, supplierGroup#785721, supplier#785722, supplierSubrange#785723, triggerObject#785806, anchorObject#785855, CASE WHEN (insightType#785720 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#785723 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#781938 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#781939 as string))) ELSE CASE WHEN (insightType#785720 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#785721 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#781938 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#781939 as string))) ELSE CASE WHEN (insightType#785720 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#781938 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#781939 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#785723 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#785721 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#785723 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#782357 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#782358 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#785721 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#782357 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#782358 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#782357 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#782358 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#785723 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#781939 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#781938 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#785721 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#781939 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#781938 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#781939 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#781938 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#785723 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#781939 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#785721 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#781939 as string))) ELSE CASE WHEN (insightType#785720 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#785722 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#781939 as string))) END END END END END END END END END END END END END END END AS messageVariables#785950]
(161) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightType#785720, supplierGroup#785721, supplier#785722, supplierSubrange#785723, triggerObject#785806, anchorObject#785855, messageVariables#785950, ((insightType#785720 <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#785720 <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#785720 <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#785720 <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((insightType#785720 <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((insightType#785720 <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((insightType#785720 <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((insightType#785720 <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((insightType#785720 <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((insightType#785720 <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((insightType#785720 <=> OP_CALC_SG_MIN_NOT_MET) OR ((insightType#785720 <=> OP_CALC_SUP_MIN_NOT_MET) OR ((insightType#785720 <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((insightType#785720 <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (insightType#785720 <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))) AS insightTypeSupported#785951]
(162) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightType#785720, supplierGroup#785721, supplier#785722, supplierSubrange#785723, triggerObject#785806, anchorObject#785855, messageVariables#785950, insightTypeSupported#785951, NEW AS situationStatus#785952]
(163) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightType#785720, supplierGroup#785721, supplier#785722, supplierSubrange#785723, triggerObject#785806, anchorObject#785855, messageVariables#785950, insightTypeSupported#785951, situationStatus#785952, Daily_grocery AS marketUnit#785953]
(164) Filter
Arguments: (insightTypeSupported#785951 = true)
(165) Project
Arguments: [shardId#777607, orderProposalId#777608L, internalInsightType#781935, worklistShardItemId#781936L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, assignmentDetails#781940, externalProductId#782357, externalPlantId#782358, orderProposalItemId#782319, businessContext#782713, configurationVersion#782714, insightType#785720 AS situationType#785954, supplierGroup#785721, supplier#785722, supplierSubrange#785723, triggerObject#785806, anchorObject#785855, messageVariables#785950, insightTypeSupported#785951, situationStatus#785952, marketUnit#785953]
(166) Project
Arguments: [anchorObject#785855, messageVariables#785950, triggerObject#785806, marketUnit#785953, situationStatus#785952, situationType#785954]
(167) Project
Arguments: [to_json(struct(anchorObject, anchorObject#785855, messageVariables, messageVariables#785950, triggerObject, triggerObject#785806, marketUnit, marketUnit#785953, situationStatus, situationStatus#785952, situationType, situationType#785954), Some(UTC)) AS value#787612]
(168) Project
Arguments: [cast(value#787612 as string) AS value#787613]
(169) Project
Arguments: [value#787613, array(struct(key, X-Tenant-ID, value, cast(6944346648028224943 as binary)), struct(key, X-Message-ID, value, cast(uuid(Some(8779460467906892286)) 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#787622]