== 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@2968a700, [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#555917, orderProposalId#555918L, items#555919, optimizationGroups#555920, isOptimal#555921, lastModified#555922, optimizationInsights#555923], false
(4) Filter
Arguments: shardId#555917 IN (0_1_10000002107)
(5) Filter
Arguments: shardId#555917 IN (0_1_10000002107)
(6) Project
Arguments: [shardId#555917, orderProposalId#555918L, items#555919, optimizationGroups#555920, isOptimal#555921, optimizationInsights#555923]
(7) LogicalRDD
Arguments: [shardId#569158, orderProposalId#569159L, items#569160, optimizationGroups#569161, isOptimal#569162, lastModified#569163, optimizationInsights#569164], false
(8) Filter
Arguments: shardId#569158 IN (0_1_10000002107)
(9) Filter
Arguments: shardId#569158 IN (0_1_10000002107)
(10) Project
Arguments: [shardId#569158, orderProposalId#569159L, items#569160, optimizationGroups#569161, isOptimal#569162, optimizationInsights#569164]
(11) Generate
Arguments: explode(items#569160), false, [item#556512]
(12) Project
Arguments: [shardId#569158, item#556512]
(13) Project
Arguments: [shardId#569158, item#556512.worklistShardItemId AS worklistShardItemId#556513L, item#556512.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#556514, item#556512.qty AS qty#556515]
(14) LocalRelation
Arguments: <empty>, [shardId#556669, worklistShardItemId#556670L, orderProposalId#556671L, orderProposalItemId#556672, orderProposalItemGroupId#556673, originalReplenishmentRunId#556674L, orderProposalHorizonGroupingId#556675L, splitIndicator#556676L, previousOrderProposal#556677L, clusterId#556678L, sequenceId#556679L, sourceOfSupplyUuid#556680, supplierGroup#556681, supplier#556682, subrange#556683, product#556684, plant#556685, purchasingOrg#556686, purchasingGroup#556687, mrpController#556688, orderDateTime#556689, deliveryDateTime#556690, availabilityDateTime#556691, nextAvailabilityDateTime#556692, isFallbackOrderOnly#556693, ... 20 more fields]
(15) LogicalRelation
Arguments: parquet, [orderProposalId#556817L, orderProposalItemId#556818, supplierGroup#556819, supplier#556820, plant#556821, deliveryDateTime#556822, subrange#556823, supplyingPlant#556824, productGroup#556825, product#556826, orderDateTime#556827, availabilityDateTime#556828, nextAvailabilityDateTime#556829, mrpController#556830, sourceOfSupplyUuid#556831, purchasingOrg#556832, purchasingGroup#556833, isFallbackOrderOnly#556834, orderProposalHorizonGroupingId#556835L, splitIndicator#556836L, previousOrderProposal#556837L, clusterId#556838L, sequenceId#556839, worklistShardItemId#556840L, orderProposalItemGroupId#556841, ... 20 more fields], false
(16) Filter
Arguments: (shardId#556861 = 0_1_10000002107)
(17) RepartitionByExpression
Arguments: [worklistShardItemId#556840L], 20
(18) Filter
Arguments: (sequenceId#556839 = 1)
(19) Project
Arguments: [orderProposalId#556817L, orderProposalItemId#556818, supplierGroup#556819, supplier#556820, plant#556821, deliveryDateTime#556822, subrange#556823, supplyingPlant#556824, productGroup#556825, product#556826, orderDateTime#556827, availabilityDateTime#556828, nextAvailabilityDateTime#556829, mrpController#556830, sourceOfSupplyUuid#556831, purchasingOrg#556832, purchasingGroup#556833, isFallbackOrderOnly#556834, orderProposalHorizonGroupingId#556835L, splitIndicator#556836L, previousOrderProposal#556837L, clusterId#556838L, sequenceId#556839, worklistShardItemId#556840L, orderProposalItemGroupId#556841, ... 20 more fields]
(20) Project
Arguments: [shardId#556863, worklistShardItemId#556840L, orderProposalId#556817L, orderProposalItemId#556818, orderProposalItemGroupId#556841, originalReplenishmentRunId#556859L, orderProposalHorizonGroupingId#556835L, splitIndicator#556836L, previousOrderProposal#556837L, clusterId#556838L, sequenceId#556839, sourceOfSupplyUuid#556831, supplierGroup#556819, supplier#556820, subrange#556823, product#556826, plant#556821, purchasingOrg#556832, purchasingGroup#556833, mrpController#556830, orderDateTime#556827, deliveryDateTime#556822, availabilityDateTime#556828, nextAvailabilityDateTime#556829, isFallbackOrderOnly#556834, ... 20 more fields]
(21) Project
Arguments: [shardId#556863, worklistShardItemId#556840L, orderProposalId#556817L, orderProposalItemId#556818, orderProposalItemGroupId#556841, originalReplenishmentRunId#556859L, orderProposalHorizonGroupingId#556835L, splitIndicator#556836L, previousOrderProposal#556837L, clusterId#556838L, cast(sequenceId#556839 as bigint) AS sequenceId#556864L, sourceOfSupplyUuid#556831, supplierGroup#556819, supplier#556820, subrange#556823, product#556826, plant#556821, purchasingOrg#556832, purchasingGroup#556833, mrpController#556830, orderDateTime#556827, deliveryDateTime#556822, availabilityDateTime#556828, nextAvailabilityDateTime#556829, isFallbackOrderOnly#556834, ... 20 more fields]
(22) Union
Arguments: false, false
(23) Join
Arguments: LeftOuter, ((shardId#569158 = shardId#556669) AND (worklistShardItemId#556513L = worklistShardItemId#556670L))
(24) Project
Arguments: [shardId#569158, worklistShardItemId#556513L, quantityAfterProdPlantOptimization#556514, qty#556515, orderProposalId#556671L, orderProposalItemId#556672, orderProposalItemGroupId#556673, originalReplenishmentRunId#556674L, orderProposalHorizonGroupingId#556675L, splitIndicator#556676L, previousOrderProposal#556677L, clusterId#556678L, sequenceId#556679L, sourceOfSupplyUuid#556680, supplierGroup#556681, supplier#556682, subrange#556683, product#556684, plant#556685, purchasingOrg#556686, purchasingGroup#556687, mrpController#556688, orderDateTime#556689, deliveryDateTime#556690, availabilityDateTime#556691, ... 22 more fields]
(25) Project
Arguments: [shardId#569158, worklistShardItemId#556513L, quantityAfterProdPlantOptimization#556514, qty#556515, orderProposalId#556671L, originalReplenishmentRunId#556674L, supplierGroup#556681, supplier#556682, supplyingPlant#556712, productGroup#556713, product#556684, plant#556685, subrange#556683, orderDateTime#556689, deliveryDateTime#556690, availabilityDateTime#556691, nextAvailabilityDateTime#556692, constraintValues#556706, constraintOperators#556704, constraintLabels#556703, logisticUnits#556708, orderQuantityBaseUom#556694, orderQuantityBaseUomUuid#556695, splitIndicator#556676L, netPriceAmount#556699, ... 14 more fields]
(26) Filter
Arguments: NOT (isFallbackOrderOnly#556693 <=> true)
(27) Project
Arguments: [orderProposalId#556671L]
(28) Deduplicate
Arguments: [orderProposalId#556671L]
(29) Join
Arguments: Inner, (orderProposalId#555918L = orderProposalId#556671L)
(30) Project
Arguments: [orderProposalId#555918L, shardId#555917, items#555919, optimizationGroups#555920, isOptimal#555921, optimizationInsights#555923]
(31) Generate
Arguments: explode(optimizationInsights#555923), false, [insight#569166]
(32) Project
Arguments: [shardId#555917, orderProposalId#555918L, insight#569166]
(33) Project
Arguments: [shardId#555917, orderProposalId#555918L, insight#569166.internalInsightType AS internalInsightType#569167, insight#569166.worklistShardItemId AS worklistShardItemId#569168L, insight#569166.thresholdValue AS thresholdValue#569169, insight#569166.reachedValue AS reachedValue#569170, insight#569166.unitOfMeasure AS unitOfMeasure#569171, insight#569166.assignmentDetails AS assignmentDetails#569172]
(34) LocalRelation
Arguments: <empty>, [shardId#569248, worklistShardItemId#569249L, orderProposalId#569250L, orderProposalItemId#569251, orderProposalItemGroupId#569252, originalReplenishmentRunId#569253L, orderProposalHorizonGroupingId#569254L, splitIndicator#569255L, previousOrderProposal#569256L, clusterId#569257L, sequenceId#569258L, sourceOfSupplyUuid#569259, supplierGroup#569260, supplier#569261, subrange#569262, product#569263, plant#569264, purchasingOrg#569265, purchasingGroup#569266, mrpController#569267, orderDateTime#569268, deliveryDateTime#569269, availabilityDateTime#569270, nextAvailabilityDateTime#569271, isFallbackOrderOnly#569272, ... 20 more fields]
(35) LogicalRelation
Arguments: parquet, [orderProposalId#569293L, orderProposalItemId#569294, supplierGroup#569295, supplier#569296, plant#569297, deliveryDateTime#569298, subrange#569299, supplyingPlant#569300, productGroup#569301, product#569302, orderDateTime#569303, availabilityDateTime#569304, nextAvailabilityDateTime#569305, mrpController#569306, sourceOfSupplyUuid#569307, purchasingOrg#569308, purchasingGroup#569309, isFallbackOrderOnly#569310, orderProposalHorizonGroupingId#569311L, splitIndicator#569312L, previousOrderProposal#569313L, clusterId#569314L, sequenceId#569315, worklistShardItemId#569316L, orderProposalItemGroupId#569317, ... 20 more fields], false
(36) Filter
Arguments: (shardId#569337 = 0_1_10000002107)
(37) RepartitionByExpression
Arguments: [worklistShardItemId#569316L], 20
(38) Filter
Arguments: (sequenceId#569315 = 1)
(39) Project
Arguments: [orderProposalId#569293L, orderProposalItemId#569294, supplierGroup#569295, supplier#569296, plant#569297, deliveryDateTime#569298, subrange#569299, supplyingPlant#569300, productGroup#569301, product#569302, orderDateTime#569303, availabilityDateTime#569304, nextAvailabilityDateTime#569305, mrpController#569306, sourceOfSupplyUuid#569307, purchasingOrg#569308, purchasingGroup#569309, isFallbackOrderOnly#569310, orderProposalHorizonGroupingId#569311L, splitIndicator#569312L, previousOrderProposal#569313L, clusterId#569314L, sequenceId#569315, worklistShardItemId#569316L, orderProposalItemGroupId#569317, ... 20 more fields]
(40) Project
Arguments: [shardId#569339, worklistShardItemId#569316L, orderProposalId#569293L, orderProposalItemId#569294, orderProposalItemGroupId#569317, originalReplenishmentRunId#569335L, orderProposalHorizonGroupingId#569311L, splitIndicator#569312L, previousOrderProposal#569313L, clusterId#569314L, sequenceId#569315, sourceOfSupplyUuid#569307, supplierGroup#569295, supplier#569296, subrange#569299, product#569302, plant#569297, purchasingOrg#569308, purchasingGroup#569309, mrpController#569306, orderDateTime#569303, deliveryDateTime#569298, availabilityDateTime#569304, nextAvailabilityDateTime#569305, isFallbackOrderOnly#569310, ... 20 more fields]
(41) Project
Arguments: [shardId#569339, worklistShardItemId#569316L, orderProposalId#569293L, orderProposalItemId#569294, orderProposalItemGroupId#569317, originalReplenishmentRunId#569335L, orderProposalHorizonGroupingId#569311L, splitIndicator#569312L, previousOrderProposal#569313L, clusterId#569314L, cast(sequenceId#569315 as bigint) AS sequenceId#569340L, sourceOfSupplyUuid#569307, supplierGroup#569295, supplier#569296, subrange#569299, product#569302, plant#569297, purchasingOrg#569308, purchasingGroup#569309, mrpController#569306, orderDateTime#569303, deliveryDateTime#569298, availabilityDateTime#569304, nextAvailabilityDateTime#569305, isFallbackOrderOnly#569310, ... 20 more fields]
(42) Union
Arguments: false, false
(43) Join
Arguments: LeftOuter, ((shardId#555917 = shardId#569248) AND (worklistShardItemId#569168L = worklistShardItemId#569249L))
(44) Project
Arguments: [shardId#555917, worklistShardItemId#569168L, orderProposalId#555918L, internalInsightType#569167, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, orderProposalId#569250L, orderProposalItemId#569251, orderProposalItemGroupId#569252, originalReplenishmentRunId#569253L, orderProposalHorizonGroupingId#569254L, splitIndicator#569255L, previousOrderProposal#569256L, clusterId#569257L, sequenceId#569258L, sourceOfSupplyUuid#569259, supplierGroup#569260, supplier#569261, subrange#569262, product#569263, plant#569264, purchasingOrg#569265, purchasingGroup#569266, ... 26 more fields]
(45) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, supplier#569261]
(46) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, supplier#569261, null AS businessContext#569645, null AS configurationVersion#569646]
(47) LogicalRDD
Arguments: [shardId#569532, orderProposalId#569533L, items#569534, optimizationGroups#569535, isOptimal#569536, lastModified#569537, optimizationInsights#569538], false
(48) Filter
Arguments: shardId#569532 IN (0_1_10000002107)
(49) Filter
Arguments: shardId#569532 IN (0_1_10000002107)
(50) Project
Arguments: [shardId#569532, orderProposalId#569533L, items#569534, optimizationGroups#569535, isOptimal#569536, optimizationInsights#569538]
(51) Generate
Arguments: explode(items#569534), false, [item#569539]
(52) Project
Arguments: [shardId#569532, item#569539]
(53) Project
Arguments: [shardId#569532, item#569539.worklistShardItemId AS worklistShardItemId#569540L, item#569539.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#569541, item#569539.qty AS qty#569542]
(54) LocalRelation
Arguments: <empty>, [shardId#569543, worklistShardItemId#569544L, orderProposalId#569545L, orderProposalItemId#569546, orderProposalItemGroupId#569547, originalReplenishmentRunId#569548L, orderProposalHorizonGroupingId#569549L, splitIndicator#569550L, previousOrderProposal#569551L, clusterId#569552L, sequenceId#569553L, sourceOfSupplyUuid#569554, supplierGroup#569555, supplier#569556, subrange#569557, product#569558, plant#569559, purchasingOrg#569560, purchasingGroup#569561, mrpController#569562, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, isFallbackOrderOnly#569567, ... 20 more fields]
(55) LogicalRelation
Arguments: parquet, [orderProposalId#569588L, orderProposalItemId#569589, supplierGroup#569590, supplier#569591, plant#569592, deliveryDateTime#569593, subrange#569594, supplyingPlant#569595, productGroup#569596, product#569597, orderDateTime#569598, availabilityDateTime#569599, nextAvailabilityDateTime#569600, mrpController#569601, sourceOfSupplyUuid#569602, purchasingOrg#569603, purchasingGroup#569604, isFallbackOrderOnly#569605, orderProposalHorizonGroupingId#569606L, splitIndicator#569607L, previousOrderProposal#569608L, clusterId#569609L, sequenceId#569610, worklistShardItemId#569611L, orderProposalItemGroupId#569612, ... 20 more fields], false
(56) Filter
Arguments: (shardId#569632 = 0_1_10000002107)
(57) RepartitionByExpression
Arguments: [worklistShardItemId#569611L], 20
(58) Filter
Arguments: (sequenceId#569610 = 1)
(59) Project
Arguments: [orderProposalId#569588L, orderProposalItemId#569589, supplierGroup#569590, supplier#569591, plant#569592, deliveryDateTime#569593, subrange#569594, supplyingPlant#569595, productGroup#569596, product#569597, orderDateTime#569598, availabilityDateTime#569599, nextAvailabilityDateTime#569600, mrpController#569601, sourceOfSupplyUuid#569602, purchasingOrg#569603, purchasingGroup#569604, isFallbackOrderOnly#569605, orderProposalHorizonGroupingId#569606L, splitIndicator#569607L, previousOrderProposal#569608L, clusterId#569609L, sequenceId#569610, worklistShardItemId#569611L, orderProposalItemGroupId#569612, ... 20 more fields]
(60) Project
Arguments: [shardId#569633, worklistShardItemId#569611L, orderProposalId#569588L, orderProposalItemId#569589, orderProposalItemGroupId#569612, originalReplenishmentRunId#569630L, orderProposalHorizonGroupingId#569606L, splitIndicator#569607L, previousOrderProposal#569608L, clusterId#569609L, sequenceId#569610, sourceOfSupplyUuid#569602, supplierGroup#569590, supplier#569591, subrange#569594, product#569597, plant#569592, purchasingOrg#569603, purchasingGroup#569604, mrpController#569601, orderDateTime#569598, deliveryDateTime#569593, availabilityDateTime#569599, nextAvailabilityDateTime#569600, isFallbackOrderOnly#569605, ... 20 more fields]
(61) Project
Arguments: [shardId#569633, worklistShardItemId#569611L, orderProposalId#569588L, orderProposalItemId#569589, orderProposalItemGroupId#569612, originalReplenishmentRunId#569630L, orderProposalHorizonGroupingId#569606L, splitIndicator#569607L, previousOrderProposal#569608L, clusterId#569609L, cast(sequenceId#569610 as bigint) AS sequenceId#569634L, sourceOfSupplyUuid#569602, supplierGroup#569590, supplier#569591, subrange#569594, product#569597, plant#569592, purchasingOrg#569603, purchasingGroup#569604, mrpController#569601, orderDateTime#569598, deliveryDateTime#569593, availabilityDateTime#569599, nextAvailabilityDateTime#569600, isFallbackOrderOnly#569605, ... 20 more fields]
(62) Union
Arguments: false, false
(63) Join
Arguments: LeftOuter, ((shardId#569532 = shardId#569543) AND (worklistShardItemId#569540L = worklistShardItemId#569544L))
(64) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, orderProposalItemId#569546, orderProposalItemGroupId#569547, originalReplenishmentRunId#569548L, orderProposalHorizonGroupingId#569549L, splitIndicator#569550L, previousOrderProposal#569551L, clusterId#569552L, sequenceId#569553L, sourceOfSupplyUuid#569554, supplierGroup#569555, supplier#569556, subrange#569557, product#569558, plant#569559, purchasingOrg#569560, purchasingGroup#569561, mrpController#569562, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, ... 22 more fields]
(65) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, originalReplenishmentRunId#569548L, supplierGroup#569555, supplier#569556, supplyingPlant#569586, productGroup#569587, product#569558, plant#569559, subrange#569557, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, constraintValues#569580, constraintOperators#569578, constraintLabels#569577, logisticUnits#569582, orderQuantityBaseUom#569568, orderQuantityBaseUomUuid#569569, splitIndicator#569550L, netPriceAmount#569573, ... 14 more fields]
(66) LogicalRDD
Arguments: [shardId#563116, worklistShardItemId#563117L, qty#563118, demandChannel#563119, demandStream#563120, kpis#563121], false
(67) Filter
Arguments: ((isnull(qty#563118) AND isnull(demandChannel#563119)) AND isnull(demandStream#563120))
(68) Project
Arguments: [shardId#563116, worklistShardItemId#563117L, coalesce(kpis#563121, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#563122]
(69) Join
Arguments: LeftOuter, ((shardId#569532 = shardId#563116) AND (worklistShardItemId#569540L = worklistShardItemId#563117L))
(70) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, originalReplenishmentRunId#569548L, supplierGroup#569555, supplier#569556, supplyingPlant#569586, productGroup#569587, product#569558, plant#569559, subrange#569557, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, constraintValues#569580, constraintOperators#569578, constraintLabels#569577, logisticUnits#569582, orderQuantityBaseUom#569568, orderQuantityBaseUomUuid#569569, splitIndicator#569550L, netPriceAmount#569573, ... 15 more fields]
(71) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, originalReplenishmentRunId#569548L, supplierGroup#569555, supplier#569556, supplyingPlant#569586, productGroup#569587, product#569558, plant#569559, subrange#569557, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, constraintValues#569580, constraintOperators#569578, constraintLabels#569577, logisticUnits#569582, orderQuantityBaseUom#569568, orderQuantityBaseUomUuid#569569, splitIndicator#569550L, netPriceAmount#569573, ... 15 more fields]
(72) LogicalRDD
Arguments: [shardId#563132, worklistShardItemId#563133L, qty#563134, demandChannel#563135, demandStream#563136, kpis#563137], false
(73) Filter
Arguments: (((isnull(qty#563134) AND isnotnull(demandChannel#563135)) AND isnotnull(demandStream#563136)) AND (size(kpis#563137, true) > 0))
(74) Aggregate
Arguments: [shardId#563132, worklistShardItemId#563133L], [shardId#563132, worklistShardItemId#563133L, collect_list(struct(demandChannel, demandChannel#563135, demandStream, demandStream#563136, kpis, kpis#563137), 0, 0) AS channelStreamSpecificKpis#563124]
(75) Join
Arguments: LeftOuter, ((shardId#569532 = shardId#563132) AND (worklistShardItemId#569540L = worklistShardItemId#563133L))
(76) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, originalReplenishmentRunId#569548L, supplierGroup#569555, supplier#569556, supplyingPlant#569586, productGroup#569587, product#569558, plant#569559, subrange#569557, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, constraintValues#569580, constraintOperators#569578, constraintLabels#569577, logisticUnits#569582, orderQuantityBaseUom#569568, orderQuantityBaseUomUuid#569569, splitIndicator#569550L, netPriceAmount#569573, ... 16 more fields]
(77) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, originalReplenishmentRunId#569548L, supplierGroup#569555, supplier#569556, supplyingPlant#569586, productGroup#569587, product#569558, plant#569559, subrange#569557, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, constraintValues#569580, constraintOperators#569578, constraintLabels#569577, logisticUnits#569582, orderQuantityBaseUom#569568, orderQuantityBaseUomUuid#569569, splitIndicator#569550L, netPriceAmount#569573, ... 16 more fields]
(78) LogicalRDD
Arguments: [shardId#563145, worklistShardItemId#563146L, qty#563147, demandChannel#563148, demandStream#563149, kpis#563150], false
(79) Filter
Arguments: (isnotnull(qty#563147) AND isnotnull(kpis#563150))
(80) Project
Arguments: [shardId#563145, worklistShardItemId#563146L, qty#563147, kpis#563150]
(81) Aggregate
Arguments: [shardId#563145, worklistShardItemId#563146L], [shardId#563145, worklistShardItemId#563146L, map_from_entries(collect_list(struct(qty, qty#563147, kpis, kpis#563150), 0, 0)) AS quantityKpis#563139]
(82) Join
Arguments: LeftOuter, ((shardId#569532 = shardId#563145) AND (worklistShardItemId#569540L = worklistShardItemId#563146L))
(83) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, originalReplenishmentRunId#569548L, supplierGroup#569555, supplier#569556, supplyingPlant#569586, productGroup#569587, product#569558, plant#569559, subrange#569557, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, constraintValues#569580, constraintOperators#569578, constraintLabels#569577, logisticUnits#569582, orderQuantityBaseUom#569568, orderQuantityBaseUomUuid#569569, splitIndicator#569550L, netPriceAmount#569573, ... 17 more fields]
(84) Project
Arguments: [shardId#569532, worklistShardItemId#569540L, quantityAfterProdPlantOptimization#569541, qty#569542, orderProposalId#569545L, originalReplenishmentRunId#569548L, supplierGroup#569555, supplier#569556, supplyingPlant#569586, productGroup#569587, product#569558, plant#569559, subrange#569557, orderDateTime#569563, deliveryDateTime#569564, availabilityDateTime#569565, nextAvailabilityDateTime#569566, constraintValues#569580, constraintOperators#569578, constraintLabels#569577, logisticUnits#569582, orderQuantityBaseUom#569568, orderQuantityBaseUomUuid#569569, splitIndicator#569550L, netPriceAmount#569573, ... 17 more fields]
(85) Filter
Arguments: NOT (isFallbackOrderOnly#569567 <=> true)
(86) LocalRelation
Arguments: <empty>, [shardId#569341, uomCategories#569342]
(87) Project
Arguments: [shardId#569341, uomCategories#569342, null AS insightConfigurations#569348]
(88) LogicalRelation
Arguments: parquet, [uomCategories#569343, insightConfigurations#569344, shardId#569345], false
(89) Filter
Arguments: (shardId#569345 = 0_1_10000002107)
(90) RepartitionByExpression
Arguments: 20
(91) Project
Arguments: [uomCategories#569343, insightConfigurations#569344, 0_1_10000002107 AS shardId#569347]
(92) Project
Arguments: [shardId#569347, uomCategories#569343, insightConfigurations#569344]
(93) Union
Arguments: false, false
(94) Project
Arguments: [insightConfigurations#569348]
(95) Join
Arguments: Cross
(96) Filter
Arguments: (((isnotnull(insightConfigurations#569348[POTENTIAL_OOS_STOCK_PERIOD]) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#563123, lambdafunction((lambda x_1442#569349.label = OutOfStockProbability), lambda x_1442#569349, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#569348[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1443#569350.name = OOS_PROBABILITY_THRESHOLD), lambda x_1443#569350, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#563123, lambdafunction((lambda x_1442#569351.label = OutOfStockProbability), lambda x_1442#569351, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#569348[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1443#569352.name = OOS_PROBABILITY_THRESHOLD), lambda x_1443#569352, false)), 1, None, false).value as double)) END) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#563123, lambdafunction((lambda x_1444#569353.label = InitialStockQty), lambda x_1444#569353, false)), 1, None, false).value) OR isnull(CASE WHEN cast(element_at(filter(insightConfigurations#569348[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1445#569354.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_1445#569354, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END)) THEN false ELSE (element_at(filter(prodLocSpecificKpis#563123, lambdafunction((lambda x_1444#569355.label = InitialStockQty), lambda x_1444#569355, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(insightConfigurations#569348[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1445#569356.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_1445#569356, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (isnull(CASE WHEN isnull(orderDateTime#569563) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#569563, 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#569348[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1446#569357.name = OFFSET_CURRENT_ORDER_DATE), lambda x_1446#569357, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#569563) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#569563, 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#569348[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1446#569358.name = OFFSET_CURRENT_ORDER_DATE), lambda x_1446#569358, false)), 1, None, false).value as double)) END)
(97) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#569545L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#569546 as string)), struct(name, PRODUCT, value, cast(externalProductId#569584 as string)), struct(name, PLANT, value, cast(externalPlantId#569585 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#569563 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(prodLocSpecificKpis#563123, lambdafunction((lambda x_1447#569374.label = UnfulfilledDemandQty), lambda x_1447#569374, false)), 1, None, false).value as string))) AS businessContext#569371, POTENTIAL_OOS_STOCK_PERIOD AS internalInsightType#569372, insightConfigurations#569348[POTENTIAL_OOS_STOCK_PERIOD].configurationVersion AS configurationVersion#569373]
(98) LogicalRDD
Arguments: [shardId#569395, orderProposalId#569396L, items#569397, optimizationGroups#569398, isOptimal#569399, lastModified#569400, optimizationInsights#569401], false
(99) Filter
Arguments: shardId#569395 IN (0_1_10000002107)
(100) Filter
Arguments: shardId#569395 IN (0_1_10000002107)
(101) Project
Arguments: [shardId#569395, orderProposalId#569396L, items#569397, optimizationGroups#569398, isOptimal#569399, optimizationInsights#569401]
(102) Generate
Arguments: explode(items#569397), false, [item#569402]
(103) Project
Arguments: [shardId#569395, item#569402]
(104) Project
Arguments: [shardId#569395, item#569402.worklistShardItemId AS worklistShardItemId#569403L, item#569402.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#569404, item#569402.qty AS qty#569405]
(105) LocalRelation
Arguments: <empty>, [shardId#569406, worklistShardItemId#569407L, orderProposalId#569408L, orderProposalItemId#569409, orderProposalItemGroupId#569410, originalReplenishmentRunId#569411L, orderProposalHorizonGroupingId#569412L, splitIndicator#569413L, previousOrderProposal#569414L, clusterId#569415L, sequenceId#569416L, sourceOfSupplyUuid#569417, supplierGroup#569418, supplier#569419, subrange#569420, product#569421, plant#569422, purchasingOrg#569423, purchasingGroup#569424, mrpController#569425, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, isFallbackOrderOnly#569430, ... 20 more fields]
(106) LogicalRelation
Arguments: parquet, [orderProposalId#569451L, orderProposalItemId#569452, supplierGroup#569453, supplier#569454, plant#569455, deliveryDateTime#569456, subrange#569457, supplyingPlant#569458, productGroup#569459, product#569460, orderDateTime#569461, availabilityDateTime#569462, nextAvailabilityDateTime#569463, mrpController#569464, sourceOfSupplyUuid#569465, purchasingOrg#569466, purchasingGroup#569467, isFallbackOrderOnly#569468, orderProposalHorizonGroupingId#569469L, splitIndicator#569470L, previousOrderProposal#569471L, clusterId#569472L, sequenceId#569473, worklistShardItemId#569474L, orderProposalItemGroupId#569475, ... 20 more fields], false
(107) Filter
Arguments: (shardId#569495 = 0_1_10000002107)
(108) RepartitionByExpression
Arguments: [worklistShardItemId#569474L], 20
(109) Filter
Arguments: (sequenceId#569473 = 1)
(110) Project
Arguments: [orderProposalId#569451L, orderProposalItemId#569452, supplierGroup#569453, supplier#569454, plant#569455, deliveryDateTime#569456, subrange#569457, supplyingPlant#569458, productGroup#569459, product#569460, orderDateTime#569461, availabilityDateTime#569462, nextAvailabilityDateTime#569463, mrpController#569464, sourceOfSupplyUuid#569465, purchasingOrg#569466, purchasingGroup#569467, isFallbackOrderOnly#569468, orderProposalHorizonGroupingId#569469L, splitIndicator#569470L, previousOrderProposal#569471L, clusterId#569472L, sequenceId#569473, worklistShardItemId#569474L, orderProposalItemGroupId#569475, ... 20 more fields]
(111) Project
Arguments: [shardId#569496, worklistShardItemId#569474L, orderProposalId#569451L, orderProposalItemId#569452, orderProposalItemGroupId#569475, originalReplenishmentRunId#569493L, orderProposalHorizonGroupingId#569469L, splitIndicator#569470L, previousOrderProposal#569471L, clusterId#569472L, sequenceId#569473, sourceOfSupplyUuid#569465, supplierGroup#569453, supplier#569454, subrange#569457, product#569460, plant#569455, purchasingOrg#569466, purchasingGroup#569467, mrpController#569464, orderDateTime#569461, deliveryDateTime#569456, availabilityDateTime#569462, nextAvailabilityDateTime#569463, isFallbackOrderOnly#569468, ... 20 more fields]
(112) Project
Arguments: [shardId#569496, worklistShardItemId#569474L, orderProposalId#569451L, orderProposalItemId#569452, orderProposalItemGroupId#569475, originalReplenishmentRunId#569493L, orderProposalHorizonGroupingId#569469L, splitIndicator#569470L, previousOrderProposal#569471L, clusterId#569472L, cast(sequenceId#569473 as bigint) AS sequenceId#569497L, sourceOfSupplyUuid#569465, supplierGroup#569453, supplier#569454, subrange#569457, product#569460, plant#569455, purchasingOrg#569466, purchasingGroup#569467, mrpController#569464, orderDateTime#569461, deliveryDateTime#569456, availabilityDateTime#569462, nextAvailabilityDateTime#569463, isFallbackOrderOnly#569468, ... 20 more fields]
(113) Union
Arguments: false, false
(114) Join
Arguments: LeftOuter, ((shardId#569395 = shardId#569406) AND (worklistShardItemId#569403L = worklistShardItemId#569407L))
(115) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, orderProposalItemId#569409, orderProposalItemGroupId#569410, originalReplenishmentRunId#569411L, orderProposalHorizonGroupingId#569412L, splitIndicator#569413L, previousOrderProposal#569414L, clusterId#569415L, sequenceId#569416L, sourceOfSupplyUuid#569417, supplierGroup#569418, supplier#569419, subrange#569420, product#569421, plant#569422, purchasingOrg#569423, purchasingGroup#569424, mrpController#569425, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, ... 22 more fields]
(116) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, originalReplenishmentRunId#569411L, supplierGroup#569418, supplier#569419, supplyingPlant#569449, productGroup#569450, product#569421, plant#569422, subrange#569420, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, constraintValues#569443, constraintOperators#569441, constraintLabels#569440, logisticUnits#569445, orderQuantityBaseUom#569431, orderQuantityBaseUomUuid#569432, splitIndicator#569413L, netPriceAmount#569436, ... 14 more fields]
(117) LogicalRDD
Arguments: [shardId#569498, worklistShardItemId#569499L, qty#569500, demandChannel#569501, demandStream#569502, kpis#569503], false
(118) Filter
Arguments: ((isnull(qty#569500) AND isnull(demandChannel#569501)) AND isnull(demandStream#569502))
(119) Project
Arguments: [shardId#569498, worklistShardItemId#569499L, coalesce(kpis#569503, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#569504]
(120) Join
Arguments: LeftOuter, ((shardId#569395 = shardId#569498) AND (worklistShardItemId#569403L = worklistShardItemId#569499L))
(121) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, originalReplenishmentRunId#569411L, supplierGroup#569418, supplier#569419, supplyingPlant#569449, productGroup#569450, product#569421, plant#569422, subrange#569420, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, constraintValues#569443, constraintOperators#569441, constraintLabels#569440, logisticUnits#569445, orderQuantityBaseUom#569431, orderQuantityBaseUomUuid#569432, splitIndicator#569413L, netPriceAmount#569436, ... 15 more fields]
(122) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, originalReplenishmentRunId#569411L, supplierGroup#569418, supplier#569419, supplyingPlant#569449, productGroup#569450, product#569421, plant#569422, subrange#569420, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, constraintValues#569443, constraintOperators#569441, constraintLabels#569440, logisticUnits#569445, orderQuantityBaseUom#569431, orderQuantityBaseUomUuid#569432, splitIndicator#569413L, netPriceAmount#569436, ... 15 more fields]
(123) LogicalRDD
Arguments: [shardId#569506, worklistShardItemId#569507L, qty#569508, demandChannel#569509, demandStream#569510, kpis#569511], false
(124) Filter
Arguments: (((isnull(qty#569508) AND isnotnull(demandChannel#569509)) AND isnotnull(demandStream#569510)) AND (size(kpis#569511, true) > 0))
(125) Aggregate
Arguments: [shardId#569506, worklistShardItemId#569507L], [shardId#569506, worklistShardItemId#569507L, collect_list(struct(demandChannel, demandChannel#569509, demandStream, demandStream#569510, kpis, kpis#569511), 0, 0) AS channelStreamSpecificKpis#569512]
(126) Join
Arguments: LeftOuter, ((shardId#569395 = shardId#569506) AND (worklistShardItemId#569403L = worklistShardItemId#569507L))
(127) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, originalReplenishmentRunId#569411L, supplierGroup#569418, supplier#569419, supplyingPlant#569449, productGroup#569450, product#569421, plant#569422, subrange#569420, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, constraintValues#569443, constraintOperators#569441, constraintLabels#569440, logisticUnits#569445, orderQuantityBaseUom#569431, orderQuantityBaseUomUuid#569432, splitIndicator#569413L, netPriceAmount#569436, ... 16 more fields]
(128) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, originalReplenishmentRunId#569411L, supplierGroup#569418, supplier#569419, supplyingPlant#569449, productGroup#569450, product#569421, plant#569422, subrange#569420, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, constraintValues#569443, constraintOperators#569441, constraintLabels#569440, logisticUnits#569445, orderQuantityBaseUom#569431, orderQuantityBaseUomUuid#569432, splitIndicator#569413L, netPriceAmount#569436, ... 16 more fields]
(129) LogicalRDD
Arguments: [shardId#569514, worklistShardItemId#569515L, qty#569516, demandChannel#569517, demandStream#569518, kpis#569519], false
(130) Filter
Arguments: (isnotnull(qty#569516) AND isnotnull(kpis#569519))
(131) Project
Arguments: [shardId#569514, worklistShardItemId#569515L, qty#569516, kpis#569519]
(132) Aggregate
Arguments: [shardId#569514, worklistShardItemId#569515L], [shardId#569514, worklistShardItemId#569515L, map_from_entries(collect_list(struct(qty, qty#569516, kpis, kpis#569519), 0, 0)) AS quantityKpis#569520]
(133) Join
Arguments: LeftOuter, ((shardId#569395 = shardId#569514) AND (worklistShardItemId#569403L = worklistShardItemId#569515L))
(134) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, originalReplenishmentRunId#569411L, supplierGroup#569418, supplier#569419, supplyingPlant#569449, productGroup#569450, product#569421, plant#569422, subrange#569420, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, constraintValues#569443, constraintOperators#569441, constraintLabels#569440, logisticUnits#569445, orderQuantityBaseUom#569431, orderQuantityBaseUomUuid#569432, splitIndicator#569413L, netPriceAmount#569436, ... 17 more fields]
(135) Project
Arguments: [shardId#569395, worklistShardItemId#569403L, quantityAfterProdPlantOptimization#569404, qty#569405, orderProposalId#569408L, originalReplenishmentRunId#569411L, supplierGroup#569418, supplier#569419, supplyingPlant#569449, productGroup#569450, product#569421, plant#569422, subrange#569420, orderDateTime#569426, deliveryDateTime#569427, availabilityDateTime#569428, nextAvailabilityDateTime#569429, constraintValues#569443, constraintOperators#569441, constraintLabels#569440, logisticUnits#569445, orderQuantityBaseUom#569431, orderQuantityBaseUomUuid#569432, splitIndicator#569413L, netPriceAmount#569436, ... 17 more fields]
(136) Filter
Arguments: NOT (isFallbackOrderOnly#569430 <=> true)
(137) LocalRelation
Arguments: <empty>, [shardId#569522, uomCategories#569523]
(138) Project
Arguments: [shardId#569522, uomCategories#569523, null AS insightConfigurations#569524]
(139) LogicalRelation
Arguments: parquet, [uomCategories#569525, insightConfigurations#569526, shardId#569527], false
(140) Filter
Arguments: (shardId#569527 = 0_1_10000002107)
(141) RepartitionByExpression
Arguments: 20
(142) Project
Arguments: [uomCategories#569525, insightConfigurations#569526, 0_1_10000002107 AS shardId#569528]
(143) Project
Arguments: [shardId#569528, uomCategories#569525, insightConfigurations#569526]
(144) Union
Arguments: false, false
(145) Project
Arguments: [insightConfigurations#569524]
(146) Join
Arguments: Cross
(147) Filter
Arguments: (isnotnull(insightConfigurations#569524[POTENTIAL_OOS_DEMAND_PERIOD]) AND CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#569521, qty#569405, None, false), lambdafunction((lambda x_1448#569375.label = OutOfStockProbability), lambda x_1448#569375, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#569524[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_1449#569376.name = OOS_PROBABILITY_THRESHOLD), lambda x_1449#569376, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#569521, qty#569405, None, false), lambdafunction((lambda x_1448#569377.label = OutOfStockProbability), lambda x_1448#569377, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#569524[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_1449#569378.name = OOS_PROBABILITY_THRESHOLD), lambda x_1449#569378, false)), 1, None, false).value as double)) END)
(148) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#569408L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#569409 as string)), struct(name, PRODUCT, value, cast(externalProductId#569447 as string)), struct(name, PLANT, value, cast(externalPlantId#569448 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#569426 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(element_at(quantityKpis#569521, qty#569405, None, false), lambdafunction((lambda x_1450#569394.label = UnfulfilledDemandQty), lambda x_1450#569394, false)), 1, None, false).value as string))) AS businessContext#569391, POTENTIAL_OOS_DEMAND_PERIOD AS internalInsightType#569392, insightConfigurations#569524[POTENTIAL_OOS_DEMAND_PERIOD].configurationVersion AS configurationVersion#569393]
(149) Union
Arguments: false, false
(150) Project
Arguments: [businessContext#569371, internalInsightType#569372, configurationVersion#569373, cast(null as string) AS supplier#569531]
(151) Project
Arguments: [null AS shardId#569635, null AS orderProposalId#569636L, internalInsightType#569372, null AS worklistShardItemId#569637L, null AS thresholdValue#569638, null AS reachedValue#569639, null AS unitOfMeasure#569640, null AS assignmentDetails#569641, null AS externalProductId#569642, null AS externalPlantId#569643, null AS orderProposalItemId#569644, supplier#569531, businessContext#569371, configurationVersion#569373]
(152) Union
Arguments: false, false
(153) Filter
Arguments: internalInsightType#569167 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#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, supplier#569261, businessContext#569645, configurationVersion#569646, struct(insightType, CASE WHEN (internalInsightType#569167 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#569167 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#569167 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#569167 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#569167 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#569167 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#569261 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#570272]
(156) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightTypeInfo#570272]
(157) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightTypeInfo#570272.insightType AS insightType#570273, insightTypeInfo#570272.supplierGroup AS supplierGroup#570274, insightTypeInfo#570272.supplier AS supplier#570275, insightTypeInfo#570272.supplierSubrange AS supplierSubrange#570276]
(158) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightType#570273, supplierGroup#570274, supplier#570275, supplierSubrange#570276, CASE WHEN (insightType#570273 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#570276 as string))) ELSE CASE WHEN (insightType#570273 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#570274 as string))) ELSE CASE WHEN (insightType#570273 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#570276 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#570274 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#570276 as string)), struct(objectType, Product, objectId, cast(externalProductId#569289 as string)), struct(objectType, Location, objectId, cast(externalPlantId#569290 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#570274 as string)), struct(objectType, Product, objectId, cast(externalProductId#569289 as string)), struct(objectType, Location, objectId, cast(externalPlantId#569290 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string)), struct(objectType, Product, objectId, cast(externalProductId#569289 as string)), struct(objectType, Location, objectId, cast(externalPlantId#569290 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#570276 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#570274 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#570276 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#570274 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002107 as string)), struct(objectType, Supplier, objectId, cast(supplier#570275 as string))) END END END END END END END END END END END END END END END AS triggerObject#570359]
(159) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightType#570273, supplierGroup#570274, supplier#570275, supplierSubrange#570276, triggerObject#570359, CASE WHEN (insightType#570273 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightType#570273 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightType#570273 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#569251 as string))) END END END END END END END END END END END END END END END AS anchorObject#570408]
(160) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightType#570273, supplierGroup#570274, supplier#570275, supplierSubrange#570276, triggerObject#570359, anchorObject#570408, CASE WHEN (insightType#570273 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#570276 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#569170 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#569171 as string))) ELSE CASE WHEN (insightType#570273 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#570274 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#569170 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#569171 as string))) ELSE CASE WHEN (insightType#570273 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#569170 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#569171 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#570276 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#570274 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#570276 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#569289 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#569290 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#570274 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#569289 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#569290 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#569289 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#569290 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#570276 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#569171 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#569170 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#570274 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#569171 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#569170 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#569171 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#569170 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#570276 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#569171 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#570274 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#569171 as string))) ELSE CASE WHEN (insightType#570273 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#570275 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#569171 as string))) END END END END END END END END END END END END END END END AS messageVariables#570503]
(161) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightType#570273, supplierGroup#570274, supplier#570275, supplierSubrange#570276, triggerObject#570359, anchorObject#570408, messageVariables#570503, ((insightType#570273 <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#570273 <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#570273 <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#570273 <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((insightType#570273 <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((insightType#570273 <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((insightType#570273 <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((insightType#570273 <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((insightType#570273 <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((insightType#570273 <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((insightType#570273 <=> OP_CALC_SG_MIN_NOT_MET) OR ((insightType#570273 <=> OP_CALC_SUP_MIN_NOT_MET) OR ((insightType#570273 <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((insightType#570273 <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (insightType#570273 <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))) AS insightTypeSupported#570504]
(162) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightType#570273, supplierGroup#570274, supplier#570275, supplierSubrange#570276, triggerObject#570359, anchorObject#570408, messageVariables#570503, insightTypeSupported#570504, NEW AS situationStatus#570505]
(163) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightType#570273, supplierGroup#570274, supplier#570275, supplierSubrange#570276, triggerObject#570359, anchorObject#570408, messageVariables#570503, insightTypeSupported#570504, situationStatus#570505, Daily_grocery AS marketUnit#570506]
(164) Filter
Arguments: (insightTypeSupported#570504 = true)
(165) Project
Arguments: [shardId#555917, orderProposalId#555918L, internalInsightType#569167, worklistShardItemId#569168L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, assignmentDetails#569172, externalProductId#569289, externalPlantId#569290, orderProposalItemId#569251, businessContext#569645, configurationVersion#569646, insightType#570273 AS situationType#570507, supplierGroup#570274, supplier#570275, supplierSubrange#570276, triggerObject#570359, anchorObject#570408, messageVariables#570503, insightTypeSupported#570504, situationStatus#570505, marketUnit#570506]
(166) Project
Arguments: [anchorObject#570408, messageVariables#570503, triggerObject#570359, marketUnit#570506, situationStatus#570505, situationType#570507]
(167) Project
Arguments: [to_json(struct(anchorObject, anchorObject#570408, messageVariables, messageVariables#570503, triggerObject, triggerObject#570359, marketUnit, marketUnit#570506, situationStatus, situationStatus#570505, situationType, situationType#570507), Some(UTC)) AS value#571492]
(168) Project
Arguments: [cast(value#571492 as string) AS value#571493]
(169) Project
Arguments: [value#571493, array(struct(key, X-Tenant-ID, value, cast(6944346648028224943 as binary)), struct(key, X-Message-ID, value, cast(uuid(Some(5921613278376256003)) 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#571502]