== 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@7657e3ee, [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#584004, orderProposalId#584005L, items#584006, optimizationGroups#584007, isOptimal#584008, lastModified#584009, optimizationInsights#584010], false
(4) Filter
Arguments: shardId#584004 IN (0_1_10000002106)
(5) Filter
Arguments: shardId#584004 IN (0_1_10000002106)
(6) Project
Arguments: [shardId#584004, orderProposalId#584005L, items#584006, optimizationGroups#584007, isOptimal#584008, optimizationInsights#584010]
(7) LogicalRDD
Arguments: [shardId#590774, orderProposalId#590775L, items#590776, optimizationGroups#590777, isOptimal#590778, lastModified#590779, optimizationInsights#590780], false
(8) Filter
Arguments: shardId#590774 IN (0_1_10000002106)
(9) Filter
Arguments: shardId#590774 IN (0_1_10000002106)
(10) Project
Arguments: [shardId#590774, orderProposalId#590775L, items#590776, optimizationGroups#590777, isOptimal#590778, optimizationInsights#590780]
(11) Generate
Arguments: explode(items#590776), false, [item#584515]
(12) Project
Arguments: [shardId#590774, item#584515]
(13) Project
Arguments: [shardId#590774, item#584515.worklistShardItemId AS worklistShardItemId#584516L, item#584515.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#584517, item#584515.qty AS qty#584518]
(14) LocalRelation
Arguments: <empty>, [shardId#584672, worklistShardItemId#584673L, orderProposalId#584674L, orderProposalItemId#584675, orderProposalItemGroupId#584676, originalReplenishmentRunId#584677L, orderProposalHorizonGroupingId#584678L, splitIndicator#584679L, previousOrderProposal#584680L, clusterId#584681L, sequenceId#584682L, sourceOfSupplyUuid#584683, supplierGroup#584684, supplier#584685, subrange#584686, product#584687, plant#584688, purchasingOrg#584689, purchasingGroup#584690, mrpController#584691, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, nextAvailabilityDateTime#584695, isFallbackOrderOnly#584696, ... 20 more fields]
(15) LogicalRelation
Arguments: parquet, [orderProposalId#584717L, orderProposalItemId#584718, supplierGroup#584719, supplier#584720, plant#584721, deliveryDateTime#584722, subrange#584723, supplyingPlant#584724, productGroup#584725, product#584726, orderDateTime#584727, availabilityDateTime#584728, nextAvailabilityDateTime#584729, mrpController#584730, sourceOfSupplyUuid#584731, purchasingOrg#584732, purchasingGroup#584733, isFallbackOrderOnly#584734, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, sequenceId#584739, worklistShardItemId#584740L, orderProposalItemGroupId#584741, ... 20 more fields], false
(16) Filter
Arguments: (shardId#584761 = 0_1_10000002106)
(17) RepartitionByExpression
Arguments: [worklistShardItemId#584740L], 20
(18) Filter
Arguments: (sequenceId#584739 = 1)
(19) Project
Arguments: [orderProposalId#584717L, orderProposalItemId#584718, supplierGroup#584719, supplier#584720, plant#584721, deliveryDateTime#584722, subrange#584723, supplyingPlant#584724, productGroup#584725, product#584726, orderDateTime#584727, availabilityDateTime#584728, nextAvailabilityDateTime#584729, mrpController#584730, sourceOfSupplyUuid#584731, purchasingOrg#584732, purchasingGroup#584733, isFallbackOrderOnly#584734, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, sequenceId#584739, worklistShardItemId#584740L, orderProposalItemGroupId#584741, ... 20 more fields]
(20) Project
Arguments: [shardId#584763, worklistShardItemId#584740L, orderProposalId#584717L, orderProposalItemId#584718, orderProposalItemGroupId#584741, originalReplenishmentRunId#584759L, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, sequenceId#584739, sourceOfSupplyUuid#584731, supplierGroup#584719, supplier#584720, subrange#584723, product#584726, plant#584721, purchasingOrg#584732, purchasingGroup#584733, mrpController#584730, orderDateTime#584727, deliveryDateTime#584722, availabilityDateTime#584728, nextAvailabilityDateTime#584729, isFallbackOrderOnly#584734, ... 20 more fields]
(21) Project
Arguments: [shardId#584763, worklistShardItemId#584740L, orderProposalId#584717L, orderProposalItemId#584718, orderProposalItemGroupId#584741, originalReplenishmentRunId#584759L, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, cast(sequenceId#584739 as bigint) AS sequenceId#584764L, sourceOfSupplyUuid#584731, supplierGroup#584719, supplier#584720, subrange#584723, product#584726, plant#584721, purchasingOrg#584732, purchasingGroup#584733, mrpController#584730, orderDateTime#584727, deliveryDateTime#584722, availabilityDateTime#584728, nextAvailabilityDateTime#584729, isFallbackOrderOnly#584734, ... 20 more fields]
(22) Union
Arguments: false, false
(23) Join
Arguments: LeftOuter, ((shardId#590774 = shardId#584672) AND (worklistShardItemId#584516L = worklistShardItemId#584673L))
(24) Project
Arguments: [shardId#590774, worklistShardItemId#584516L, quantityAfterProdPlantOptimization#584517, qty#584518, orderProposalId#584674L, orderProposalItemId#584675, orderProposalItemGroupId#584676, originalReplenishmentRunId#584677L, orderProposalHorizonGroupingId#584678L, splitIndicator#584679L, previousOrderProposal#584680L, clusterId#584681L, sequenceId#584682L, sourceOfSupplyUuid#584683, supplierGroup#584684, supplier#584685, subrange#584686, product#584687, plant#584688, purchasingOrg#584689, purchasingGroup#584690, mrpController#584691, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, ... 22 more fields]
(25) Project
Arguments: [shardId#590774, worklistShardItemId#584516L, quantityAfterProdPlantOptimization#584517, qty#584518, orderProposalId#584674L, originalReplenishmentRunId#584677L, supplierGroup#584684, supplier#584685, supplyingPlant#584715, productGroup#584716, product#584687, plant#584688, subrange#584686, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, nextAvailabilityDateTime#584695, constraintValues#584709, constraintOperators#584707, constraintLabels#584706, logisticUnits#584711, orderQuantityBaseUom#584697, orderQuantityBaseUomUuid#584698, splitIndicator#584679L, netPriceAmount#584702, ... 14 more fields]
(26) Filter
Arguments: NOT (isFallbackOrderOnly#584696 <=> true)
(27) Project
Arguments: [orderProposalId#584674L]
(28) Deduplicate
Arguments: [orderProposalId#584674L]
(29) Join
Arguments: Inner, (orderProposalId#584005L = orderProposalId#584674L)
(30) Project
Arguments: [orderProposalId#584005L, shardId#584004, items#584006, optimizationGroups#584007, isOptimal#584008, optimizationInsights#584010]
(31) Generate
Arguments: explode(optimizationInsights#584010), false, [insight#590782]
(32) Project
Arguments: [shardId#584004, orderProposalId#584005L, insight#590782]
(33) Project
Arguments: [shardId#584004, orderProposalId#584005L, insight#590782.internalInsightType AS internalInsightType#590783, insight#590782.worklistShardItemId AS worklistShardItemId#590784L, insight#590782.thresholdValue AS thresholdValue#590785, insight#590782.reachedValue AS reachedValue#590786, insight#590782.unitOfMeasure AS unitOfMeasure#590787, insight#590782.assignmentDetails AS assignmentDetails#590788]
(34) LocalRelation
Arguments: <empty>, [shardId#591194, worklistShardItemId#591195L, orderProposalId#591196L, orderProposalItemId#591197, orderProposalItemGroupId#591198, originalReplenishmentRunId#591199L, orderProposalHorizonGroupingId#591200L, splitIndicator#591201L, previousOrderProposal#591202L, clusterId#591203L, sequenceId#591204L, sourceOfSupplyUuid#591205, supplierGroup#591206, supplier#591207, subrange#591208, product#591209, plant#591210, purchasingOrg#591211, purchasingGroup#591212, mrpController#591213, orderDateTime#591214, deliveryDateTime#591215, availabilityDateTime#591216, nextAvailabilityDateTime#591217, isFallbackOrderOnly#591218, ... 20 more fields]
(35) LogicalRelation
Arguments: parquet, [orderProposalId#591239L, orderProposalItemId#591240, supplierGroup#591241, supplier#591242, plant#591243, deliveryDateTime#591244, subrange#591245, supplyingPlant#591246, productGroup#591247, product#591248, orderDateTime#591249, availabilityDateTime#591250, nextAvailabilityDateTime#591251, mrpController#591252, sourceOfSupplyUuid#591253, purchasingOrg#591254, purchasingGroup#591255, isFallbackOrderOnly#591256, orderProposalHorizonGroupingId#591257L, splitIndicator#591258L, previousOrderProposal#591259L, clusterId#591260L, sequenceId#591261, worklistShardItemId#591262L, orderProposalItemGroupId#591263, ... 20 more fields], false
(36) Filter
Arguments: (shardId#591283 = 0_1_10000002106)
(37) RepartitionByExpression
Arguments: [worklistShardItemId#591262L], 20
(38) Filter
Arguments: (sequenceId#591261 = 1)
(39) Project
Arguments: [orderProposalId#591239L, orderProposalItemId#591240, supplierGroup#591241, supplier#591242, plant#591243, deliveryDateTime#591244, subrange#591245, supplyingPlant#591246, productGroup#591247, product#591248, orderDateTime#591249, availabilityDateTime#591250, nextAvailabilityDateTime#591251, mrpController#591252, sourceOfSupplyUuid#591253, purchasingOrg#591254, purchasingGroup#591255, isFallbackOrderOnly#591256, orderProposalHorizonGroupingId#591257L, splitIndicator#591258L, previousOrderProposal#591259L, clusterId#591260L, sequenceId#591261, worklistShardItemId#591262L, orderProposalItemGroupId#591263, ... 20 more fields]
(40) Project
Arguments: [shardId#591285, worklistShardItemId#591262L, orderProposalId#591239L, orderProposalItemId#591240, orderProposalItemGroupId#591263, originalReplenishmentRunId#591281L, orderProposalHorizonGroupingId#591257L, splitIndicator#591258L, previousOrderProposal#591259L, clusterId#591260L, sequenceId#591261, sourceOfSupplyUuid#591253, supplierGroup#591241, supplier#591242, subrange#591245, product#591248, plant#591243, purchasingOrg#591254, purchasingGroup#591255, mrpController#591252, orderDateTime#591249, deliveryDateTime#591244, availabilityDateTime#591250, nextAvailabilityDateTime#591251, isFallbackOrderOnly#591256, ... 20 more fields]
(41) Project
Arguments: [shardId#591285, worklistShardItemId#591262L, orderProposalId#591239L, orderProposalItemId#591240, orderProposalItemGroupId#591263, originalReplenishmentRunId#591281L, orderProposalHorizonGroupingId#591257L, splitIndicator#591258L, previousOrderProposal#591259L, clusterId#591260L, cast(sequenceId#591261 as bigint) AS sequenceId#591286L, sourceOfSupplyUuid#591253, supplierGroup#591241, supplier#591242, subrange#591245, product#591248, plant#591243, purchasingOrg#591254, purchasingGroup#591255, mrpController#591252, orderDateTime#591249, deliveryDateTime#591244, availabilityDateTime#591250, nextAvailabilityDateTime#591251, isFallbackOrderOnly#591256, ... 20 more fields]
(42) Union
Arguments: false, false
(43) Join
Arguments: LeftOuter, ((shardId#584004 = shardId#591194) AND (worklistShardItemId#590784L = worklistShardItemId#591195L))
(44) Project
Arguments: [shardId#584004, worklistShardItemId#590784L, orderProposalId#584005L, internalInsightType#590783, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, orderProposalId#591196L, orderProposalItemId#591197, orderProposalItemGroupId#591198, originalReplenishmentRunId#591199L, orderProposalHorizonGroupingId#591200L, splitIndicator#591201L, previousOrderProposal#591202L, clusterId#591203L, sequenceId#591204L, sourceOfSupplyUuid#591205, supplierGroup#591206, supplier#591207, subrange#591208, product#591209, plant#591210, purchasingOrg#591211, purchasingGroup#591212, ... 26 more fields]
(45) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, supplier#591207]
(46) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, supplier#591207, null AS businessContext#591591, null AS configurationVersion#591592]
(47) LogicalRDD
Arguments: [shardId#591478, orderProposalId#591479L, items#591480, optimizationGroups#591481, isOptimal#591482, lastModified#591483, optimizationInsights#591484], false
(48) Filter
Arguments: shardId#591478 IN (0_1_10000002106)
(49) Filter
Arguments: shardId#591478 IN (0_1_10000002106)
(50) Project
Arguments: [shardId#591478, orderProposalId#591479L, items#591480, optimizationGroups#591481, isOptimal#591482, optimizationInsights#591484]
(51) Generate
Arguments: explode(items#591480), false, [item#591485]
(52) Project
Arguments: [shardId#591478, item#591485]
(53) Project
Arguments: [shardId#591478, item#591485.worklistShardItemId AS worklistShardItemId#591486L, item#591485.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#591487, item#591485.qty AS qty#591488]
(54) LocalRelation
Arguments: <empty>, [shardId#591489, worklistShardItemId#591490L, orderProposalId#591491L, orderProposalItemId#591492, orderProposalItemGroupId#591493, originalReplenishmentRunId#591494L, orderProposalHorizonGroupingId#591495L, splitIndicator#591496L, previousOrderProposal#591497L, clusterId#591498L, sequenceId#591499L, sourceOfSupplyUuid#591500, supplierGroup#591501, supplier#591502, subrange#591503, product#591504, plant#591505, purchasingOrg#591506, purchasingGroup#591507, mrpController#591508, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, isFallbackOrderOnly#591513, ... 20 more fields]
(55) LogicalRelation
Arguments: parquet, [orderProposalId#591534L, orderProposalItemId#591535, supplierGroup#591536, supplier#591537, plant#591538, deliveryDateTime#591539, subrange#591540, supplyingPlant#591541, productGroup#591542, product#591543, orderDateTime#591544, availabilityDateTime#591545, nextAvailabilityDateTime#591546, mrpController#591547, sourceOfSupplyUuid#591548, purchasingOrg#591549, purchasingGroup#591550, isFallbackOrderOnly#591551, orderProposalHorizonGroupingId#591552L, splitIndicator#591553L, previousOrderProposal#591554L, clusterId#591555L, sequenceId#591556, worklistShardItemId#591557L, orderProposalItemGroupId#591558, ... 20 more fields], false
(56) Filter
Arguments: (shardId#591578 = 0_1_10000002106)
(57) RepartitionByExpression
Arguments: [worklistShardItemId#591557L], 20
(58) Filter
Arguments: (sequenceId#591556 = 1)
(59) Project
Arguments: [orderProposalId#591534L, orderProposalItemId#591535, supplierGroup#591536, supplier#591537, plant#591538, deliveryDateTime#591539, subrange#591540, supplyingPlant#591541, productGroup#591542, product#591543, orderDateTime#591544, availabilityDateTime#591545, nextAvailabilityDateTime#591546, mrpController#591547, sourceOfSupplyUuid#591548, purchasingOrg#591549, purchasingGroup#591550, isFallbackOrderOnly#591551, orderProposalHorizonGroupingId#591552L, splitIndicator#591553L, previousOrderProposal#591554L, clusterId#591555L, sequenceId#591556, worklistShardItemId#591557L, orderProposalItemGroupId#591558, ... 20 more fields]
(60) Project
Arguments: [shardId#591579, worklistShardItemId#591557L, orderProposalId#591534L, orderProposalItemId#591535, orderProposalItemGroupId#591558, originalReplenishmentRunId#591576L, orderProposalHorizonGroupingId#591552L, splitIndicator#591553L, previousOrderProposal#591554L, clusterId#591555L, sequenceId#591556, sourceOfSupplyUuid#591548, supplierGroup#591536, supplier#591537, subrange#591540, product#591543, plant#591538, purchasingOrg#591549, purchasingGroup#591550, mrpController#591547, orderDateTime#591544, deliveryDateTime#591539, availabilityDateTime#591545, nextAvailabilityDateTime#591546, isFallbackOrderOnly#591551, ... 20 more fields]
(61) Project
Arguments: [shardId#591579, worklistShardItemId#591557L, orderProposalId#591534L, orderProposalItemId#591535, orderProposalItemGroupId#591558, originalReplenishmentRunId#591576L, orderProposalHorizonGroupingId#591552L, splitIndicator#591553L, previousOrderProposal#591554L, clusterId#591555L, cast(sequenceId#591556 as bigint) AS sequenceId#591580L, sourceOfSupplyUuid#591548, supplierGroup#591536, supplier#591537, subrange#591540, product#591543, plant#591538, purchasingOrg#591549, purchasingGroup#591550, mrpController#591547, orderDateTime#591544, deliveryDateTime#591539, availabilityDateTime#591545, nextAvailabilityDateTime#591546, isFallbackOrderOnly#591551, ... 20 more fields]
(62) Union
Arguments: false, false
(63) Join
Arguments: LeftOuter, ((shardId#591478 = shardId#591489) AND (worklistShardItemId#591486L = worklistShardItemId#591490L))
(64) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, orderProposalItemId#591492, orderProposalItemGroupId#591493, originalReplenishmentRunId#591494L, orderProposalHorizonGroupingId#591495L, splitIndicator#591496L, previousOrderProposal#591497L, clusterId#591498L, sequenceId#591499L, sourceOfSupplyUuid#591500, supplierGroup#591501, supplier#591502, subrange#591503, product#591504, plant#591505, purchasingOrg#591506, purchasingGroup#591507, mrpController#591508, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, ... 22 more fields]
(65) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, originalReplenishmentRunId#591494L, supplierGroup#591501, supplier#591502, supplyingPlant#591532, productGroup#591533, product#591504, plant#591505, subrange#591503, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, constraintValues#591526, constraintOperators#591524, constraintLabels#591523, logisticUnits#591528, orderQuantityBaseUom#591514, orderQuantityBaseUomUuid#591515, splitIndicator#591496L, netPriceAmount#591519, ... 14 more fields]
(66) LogicalRDD
Arguments: [shardId#586384, worklistShardItemId#586385L, qty#586386, demandChannel#586387, demandStream#586388, kpis#586389], false
(67) Filter
Arguments: ((isnull(qty#586386) AND isnull(demandChannel#586387)) AND isnull(demandStream#586388))
(68) Project
Arguments: [shardId#586384, worklistShardItemId#586385L, coalesce(kpis#586389, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#586390]
(69) Join
Arguments: LeftOuter, ((shardId#591478 = shardId#586384) AND (worklistShardItemId#591486L = worklistShardItemId#586385L))
(70) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, originalReplenishmentRunId#591494L, supplierGroup#591501, supplier#591502, supplyingPlant#591532, productGroup#591533, product#591504, plant#591505, subrange#591503, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, constraintValues#591526, constraintOperators#591524, constraintLabels#591523, logisticUnits#591528, orderQuantityBaseUom#591514, orderQuantityBaseUomUuid#591515, splitIndicator#591496L, netPriceAmount#591519, ... 15 more fields]
(71) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, originalReplenishmentRunId#591494L, supplierGroup#591501, supplier#591502, supplyingPlant#591532, productGroup#591533, product#591504, plant#591505, subrange#591503, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, constraintValues#591526, constraintOperators#591524, constraintLabels#591523, logisticUnits#591528, orderQuantityBaseUom#591514, orderQuantityBaseUomUuid#591515, splitIndicator#591496L, netPriceAmount#591519, ... 15 more fields]
(72) LogicalRDD
Arguments: [shardId#586400, worklistShardItemId#586401L, qty#586402, demandChannel#586403, demandStream#586404, kpis#586405], false
(73) Filter
Arguments: (((isnull(qty#586402) AND isnotnull(demandChannel#586403)) AND isnotnull(demandStream#586404)) AND (size(kpis#586405, true) > 0))
(74) Aggregate
Arguments: [shardId#586400, worklistShardItemId#586401L], [shardId#586400, worklistShardItemId#586401L, collect_list(struct(demandChannel, demandChannel#586403, demandStream, demandStream#586404, kpis, kpis#586405), 0, 0) AS channelStreamSpecificKpis#586392]
(75) Join
Arguments: LeftOuter, ((shardId#591478 = shardId#586400) AND (worklistShardItemId#591486L = worklistShardItemId#586401L))
(76) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, originalReplenishmentRunId#591494L, supplierGroup#591501, supplier#591502, supplyingPlant#591532, productGroup#591533, product#591504, plant#591505, subrange#591503, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, constraintValues#591526, constraintOperators#591524, constraintLabels#591523, logisticUnits#591528, orderQuantityBaseUom#591514, orderQuantityBaseUomUuid#591515, splitIndicator#591496L, netPriceAmount#591519, ... 16 more fields]
(77) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, originalReplenishmentRunId#591494L, supplierGroup#591501, supplier#591502, supplyingPlant#591532, productGroup#591533, product#591504, plant#591505, subrange#591503, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, constraintValues#591526, constraintOperators#591524, constraintLabels#591523, logisticUnits#591528, orderQuantityBaseUom#591514, orderQuantityBaseUomUuid#591515, splitIndicator#591496L, netPriceAmount#591519, ... 16 more fields]
(78) LogicalRDD
Arguments: [shardId#586413, worklistShardItemId#586414L, qty#586415, demandChannel#586416, demandStream#586417, kpis#586418], false
(79) Filter
Arguments: (isnotnull(qty#586415) AND isnotnull(kpis#586418))
(80) Project
Arguments: [shardId#586413, worklistShardItemId#586414L, qty#586415, kpis#586418]
(81) Aggregate
Arguments: [shardId#586413, worklistShardItemId#586414L], [shardId#586413, worklistShardItemId#586414L, map_from_entries(collect_list(struct(qty, qty#586415, kpis, kpis#586418), 0, 0)) AS quantityKpis#586407]
(82) Join
Arguments: LeftOuter, ((shardId#591478 = shardId#586413) AND (worklistShardItemId#591486L = worklistShardItemId#586414L))
(83) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, originalReplenishmentRunId#591494L, supplierGroup#591501, supplier#591502, supplyingPlant#591532, productGroup#591533, product#591504, plant#591505, subrange#591503, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, constraintValues#591526, constraintOperators#591524, constraintLabels#591523, logisticUnits#591528, orderQuantityBaseUom#591514, orderQuantityBaseUomUuid#591515, splitIndicator#591496L, netPriceAmount#591519, ... 17 more fields]
(84) Project
Arguments: [shardId#591478, worklistShardItemId#591486L, quantityAfterProdPlantOptimization#591487, qty#591488, orderProposalId#591491L, originalReplenishmentRunId#591494L, supplierGroup#591501, supplier#591502, supplyingPlant#591532, productGroup#591533, product#591504, plant#591505, subrange#591503, orderDateTime#591509, deliveryDateTime#591510, availabilityDateTime#591511, nextAvailabilityDateTime#591512, constraintValues#591526, constraintOperators#591524, constraintLabels#591523, logisticUnits#591528, orderQuantityBaseUom#591514, orderQuantityBaseUomUuid#591515, splitIndicator#591496L, netPriceAmount#591519, ... 17 more fields]
(85) Filter
Arguments: NOT (isFallbackOrderOnly#591513 <=> true)
(86) LocalRelation
Arguments: <empty>, [shardId#591287, uomCategories#591288]
(87) Project
Arguments: [shardId#591287, uomCategories#591288, null AS insightConfigurations#591294]
(88) LogicalRelation
Arguments: parquet, [uomCategories#591289, insightConfigurations#591290, shardId#591291], false
(89) Filter
Arguments: (shardId#591291 = 0_1_10000002106)
(90) RepartitionByExpression
Arguments: 20
(91) Project
Arguments: [uomCategories#591289, insightConfigurations#591290, 0_1_10000002106 AS shardId#591293]
(92) Project
Arguments: [shardId#591293, uomCategories#591289, insightConfigurations#591290]
(93) Union
Arguments: false, false
(94) Project
Arguments: [insightConfigurations#591294]
(95) Join
Arguments: Cross
(96) Filter
Arguments: (((isnotnull(insightConfigurations#591294[POTENTIAL_OOS_STOCK_PERIOD]) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#586391, lambdafunction((lambda x_1511#591295.label = OutOfStockProbability), lambda x_1511#591295, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#591294[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1512#591296.name = OOS_PROBABILITY_THRESHOLD), lambda x_1512#591296, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#586391, lambdafunction((lambda x_1511#591297.label = OutOfStockProbability), lambda x_1511#591297, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#591294[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1512#591298.name = OOS_PROBABILITY_THRESHOLD), lambda x_1512#591298, false)), 1, None, false).value as double)) END) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#586391, lambdafunction((lambda x_1513#591299.label = InitialStockQty), lambda x_1513#591299, false)), 1, None, false).value) OR isnull(CASE WHEN cast(element_at(filter(insightConfigurations#591294[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1514#591300.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_1514#591300, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END)) THEN false ELSE (element_at(filter(prodLocSpecificKpis#586391, lambdafunction((lambda x_1513#591301.label = InitialStockQty), lambda x_1513#591301, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(insightConfigurations#591294[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1514#591302.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_1514#591302, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (isnull(CASE WHEN isnull(orderDateTime#591509) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#591509, 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#591294[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1515#591303.name = OFFSET_CURRENT_ORDER_DATE), lambda x_1515#591303, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#591509) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#591509, 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#591294[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_1515#591304.name = OFFSET_CURRENT_ORDER_DATE), lambda x_1515#591304, false)), 1, None, false).value as double)) END)
(97) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#591491L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#591492 as string)), struct(name, PRODUCT, value, cast(externalProductId#591530 as string)), struct(name, PLANT, value, cast(externalPlantId#591531 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#591509 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(prodLocSpecificKpis#586391, lambdafunction((lambda x_1516#591320.label = UnfulfilledDemandQty), lambda x_1516#591320, false)), 1, None, false).value as string))) AS businessContext#591317, POTENTIAL_OOS_STOCK_PERIOD AS internalInsightType#591318, insightConfigurations#591294[POTENTIAL_OOS_STOCK_PERIOD].configurationVersion AS configurationVersion#591319]
(98) LogicalRDD
Arguments: [shardId#591341, orderProposalId#591342L, items#591343, optimizationGroups#591344, isOptimal#591345, lastModified#591346, optimizationInsights#591347], false
(99) Filter
Arguments: shardId#591341 IN (0_1_10000002106)
(100) Filter
Arguments: shardId#591341 IN (0_1_10000002106)
(101) Project
Arguments: [shardId#591341, orderProposalId#591342L, items#591343, optimizationGroups#591344, isOptimal#591345, optimizationInsights#591347]
(102) Generate
Arguments: explode(items#591343), false, [item#591348]
(103) Project
Arguments: [shardId#591341, item#591348]
(104) Project
Arguments: [shardId#591341, item#591348.worklistShardItemId AS worklistShardItemId#591349L, item#591348.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#591350, item#591348.qty AS qty#591351]
(105) LocalRelation
Arguments: <empty>, [shardId#591352, worklistShardItemId#591353L, orderProposalId#591354L, orderProposalItemId#591355, orderProposalItemGroupId#591356, originalReplenishmentRunId#591357L, orderProposalHorizonGroupingId#591358L, splitIndicator#591359L, previousOrderProposal#591360L, clusterId#591361L, sequenceId#591362L, sourceOfSupplyUuid#591363, supplierGroup#591364, supplier#591365, subrange#591366, product#591367, plant#591368, purchasingOrg#591369, purchasingGroup#591370, mrpController#591371, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, isFallbackOrderOnly#591376, ... 20 more fields]
(106) LogicalRelation
Arguments: parquet, [orderProposalId#591397L, orderProposalItemId#591398, supplierGroup#591399, supplier#591400, plant#591401, deliveryDateTime#591402, subrange#591403, supplyingPlant#591404, productGroup#591405, product#591406, orderDateTime#591407, availabilityDateTime#591408, nextAvailabilityDateTime#591409, mrpController#591410, sourceOfSupplyUuid#591411, purchasingOrg#591412, purchasingGroup#591413, isFallbackOrderOnly#591414, orderProposalHorizonGroupingId#591415L, splitIndicator#591416L, previousOrderProposal#591417L, clusterId#591418L, sequenceId#591419, worklistShardItemId#591420L, orderProposalItemGroupId#591421, ... 20 more fields], false
(107) Filter
Arguments: (shardId#591441 = 0_1_10000002106)
(108) RepartitionByExpression
Arguments: [worklistShardItemId#591420L], 20
(109) Filter
Arguments: (sequenceId#591419 = 1)
(110) Project
Arguments: [orderProposalId#591397L, orderProposalItemId#591398, supplierGroup#591399, supplier#591400, plant#591401, deliveryDateTime#591402, subrange#591403, supplyingPlant#591404, productGroup#591405, product#591406, orderDateTime#591407, availabilityDateTime#591408, nextAvailabilityDateTime#591409, mrpController#591410, sourceOfSupplyUuid#591411, purchasingOrg#591412, purchasingGroup#591413, isFallbackOrderOnly#591414, orderProposalHorizonGroupingId#591415L, splitIndicator#591416L, previousOrderProposal#591417L, clusterId#591418L, sequenceId#591419, worklistShardItemId#591420L, orderProposalItemGroupId#591421, ... 20 more fields]
(111) Project
Arguments: [shardId#591442, worklistShardItemId#591420L, orderProposalId#591397L, orderProposalItemId#591398, orderProposalItemGroupId#591421, originalReplenishmentRunId#591439L, orderProposalHorizonGroupingId#591415L, splitIndicator#591416L, previousOrderProposal#591417L, clusterId#591418L, sequenceId#591419, sourceOfSupplyUuid#591411, supplierGroup#591399, supplier#591400, subrange#591403, product#591406, plant#591401, purchasingOrg#591412, purchasingGroup#591413, mrpController#591410, orderDateTime#591407, deliveryDateTime#591402, availabilityDateTime#591408, nextAvailabilityDateTime#591409, isFallbackOrderOnly#591414, ... 20 more fields]
(112) Project
Arguments: [shardId#591442, worklistShardItemId#591420L, orderProposalId#591397L, orderProposalItemId#591398, orderProposalItemGroupId#591421, originalReplenishmentRunId#591439L, orderProposalHorizonGroupingId#591415L, splitIndicator#591416L, previousOrderProposal#591417L, clusterId#591418L, cast(sequenceId#591419 as bigint) AS sequenceId#591443L, sourceOfSupplyUuid#591411, supplierGroup#591399, supplier#591400, subrange#591403, product#591406, plant#591401, purchasingOrg#591412, purchasingGroup#591413, mrpController#591410, orderDateTime#591407, deliveryDateTime#591402, availabilityDateTime#591408, nextAvailabilityDateTime#591409, isFallbackOrderOnly#591414, ... 20 more fields]
(113) Union
Arguments: false, false
(114) Join
Arguments: LeftOuter, ((shardId#591341 = shardId#591352) AND (worklistShardItemId#591349L = worklistShardItemId#591353L))
(115) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, orderProposalItemId#591355, orderProposalItemGroupId#591356, originalReplenishmentRunId#591357L, orderProposalHorizonGroupingId#591358L, splitIndicator#591359L, previousOrderProposal#591360L, clusterId#591361L, sequenceId#591362L, sourceOfSupplyUuid#591363, supplierGroup#591364, supplier#591365, subrange#591366, product#591367, plant#591368, purchasingOrg#591369, purchasingGroup#591370, mrpController#591371, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, ... 22 more fields]
(116) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, originalReplenishmentRunId#591357L, supplierGroup#591364, supplier#591365, supplyingPlant#591395, productGroup#591396, product#591367, plant#591368, subrange#591366, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, constraintValues#591389, constraintOperators#591387, constraintLabels#591386, logisticUnits#591391, orderQuantityBaseUom#591377, orderQuantityBaseUomUuid#591378, splitIndicator#591359L, netPriceAmount#591382, ... 14 more fields]
(117) LogicalRDD
Arguments: [shardId#591444, worklistShardItemId#591445L, qty#591446, demandChannel#591447, demandStream#591448, kpis#591449], false
(118) Filter
Arguments: ((isnull(qty#591446) AND isnull(demandChannel#591447)) AND isnull(demandStream#591448))
(119) Project
Arguments: [shardId#591444, worklistShardItemId#591445L, coalesce(kpis#591449, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#591450]
(120) Join
Arguments: LeftOuter, ((shardId#591341 = shardId#591444) AND (worklistShardItemId#591349L = worklistShardItemId#591445L))
(121) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, originalReplenishmentRunId#591357L, supplierGroup#591364, supplier#591365, supplyingPlant#591395, productGroup#591396, product#591367, plant#591368, subrange#591366, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, constraintValues#591389, constraintOperators#591387, constraintLabels#591386, logisticUnits#591391, orderQuantityBaseUom#591377, orderQuantityBaseUomUuid#591378, splitIndicator#591359L, netPriceAmount#591382, ... 15 more fields]
(122) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, originalReplenishmentRunId#591357L, supplierGroup#591364, supplier#591365, supplyingPlant#591395, productGroup#591396, product#591367, plant#591368, subrange#591366, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, constraintValues#591389, constraintOperators#591387, constraintLabels#591386, logisticUnits#591391, orderQuantityBaseUom#591377, orderQuantityBaseUomUuid#591378, splitIndicator#591359L, netPriceAmount#591382, ... 15 more fields]
(123) LogicalRDD
Arguments: [shardId#591452, worklistShardItemId#591453L, qty#591454, demandChannel#591455, demandStream#591456, kpis#591457], false
(124) Filter
Arguments: (((isnull(qty#591454) AND isnotnull(demandChannel#591455)) AND isnotnull(demandStream#591456)) AND (size(kpis#591457, true) > 0))
(125) Aggregate
Arguments: [shardId#591452, worklistShardItemId#591453L], [shardId#591452, worklistShardItemId#591453L, collect_list(struct(demandChannel, demandChannel#591455, demandStream, demandStream#591456, kpis, kpis#591457), 0, 0) AS channelStreamSpecificKpis#591458]
(126) Join
Arguments: LeftOuter, ((shardId#591341 = shardId#591452) AND (worklistShardItemId#591349L = worklistShardItemId#591453L))
(127) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, originalReplenishmentRunId#591357L, supplierGroup#591364, supplier#591365, supplyingPlant#591395, productGroup#591396, product#591367, plant#591368, subrange#591366, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, constraintValues#591389, constraintOperators#591387, constraintLabels#591386, logisticUnits#591391, orderQuantityBaseUom#591377, orderQuantityBaseUomUuid#591378, splitIndicator#591359L, netPriceAmount#591382, ... 16 more fields]
(128) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, originalReplenishmentRunId#591357L, supplierGroup#591364, supplier#591365, supplyingPlant#591395, productGroup#591396, product#591367, plant#591368, subrange#591366, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, constraintValues#591389, constraintOperators#591387, constraintLabels#591386, logisticUnits#591391, orderQuantityBaseUom#591377, orderQuantityBaseUomUuid#591378, splitIndicator#591359L, netPriceAmount#591382, ... 16 more fields]
(129) LogicalRDD
Arguments: [shardId#591460, worklistShardItemId#591461L, qty#591462, demandChannel#591463, demandStream#591464, kpis#591465], false
(130) Filter
Arguments: (isnotnull(qty#591462) AND isnotnull(kpis#591465))
(131) Project
Arguments: [shardId#591460, worklistShardItemId#591461L, qty#591462, kpis#591465]
(132) Aggregate
Arguments: [shardId#591460, worklistShardItemId#591461L], [shardId#591460, worklistShardItemId#591461L, map_from_entries(collect_list(struct(qty, qty#591462, kpis, kpis#591465), 0, 0)) AS quantityKpis#591466]
(133) Join
Arguments: LeftOuter, ((shardId#591341 = shardId#591460) AND (worklistShardItemId#591349L = worklistShardItemId#591461L))
(134) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, originalReplenishmentRunId#591357L, supplierGroup#591364, supplier#591365, supplyingPlant#591395, productGroup#591396, product#591367, plant#591368, subrange#591366, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, constraintValues#591389, constraintOperators#591387, constraintLabels#591386, logisticUnits#591391, orderQuantityBaseUom#591377, orderQuantityBaseUomUuid#591378, splitIndicator#591359L, netPriceAmount#591382, ... 17 more fields]
(135) Project
Arguments: [shardId#591341, worklistShardItemId#591349L, quantityAfterProdPlantOptimization#591350, qty#591351, orderProposalId#591354L, originalReplenishmentRunId#591357L, supplierGroup#591364, supplier#591365, supplyingPlant#591395, productGroup#591396, product#591367, plant#591368, subrange#591366, orderDateTime#591372, deliveryDateTime#591373, availabilityDateTime#591374, nextAvailabilityDateTime#591375, constraintValues#591389, constraintOperators#591387, constraintLabels#591386, logisticUnits#591391, orderQuantityBaseUom#591377, orderQuantityBaseUomUuid#591378, splitIndicator#591359L, netPriceAmount#591382, ... 17 more fields]
(136) Filter
Arguments: NOT (isFallbackOrderOnly#591376 <=> true)
(137) LocalRelation
Arguments: <empty>, [shardId#591468, uomCategories#591469]
(138) Project
Arguments: [shardId#591468, uomCategories#591469, null AS insightConfigurations#591470]
(139) LogicalRelation
Arguments: parquet, [uomCategories#591471, insightConfigurations#591472, shardId#591473], false
(140) Filter
Arguments: (shardId#591473 = 0_1_10000002106)
(141) RepartitionByExpression
Arguments: 20
(142) Project
Arguments: [uomCategories#591471, insightConfigurations#591472, 0_1_10000002106 AS shardId#591474]
(143) Project
Arguments: [shardId#591474, uomCategories#591471, insightConfigurations#591472]
(144) Union
Arguments: false, false
(145) Project
Arguments: [insightConfigurations#591470]
(146) Join
Arguments: Cross
(147) Filter
Arguments: (isnotnull(insightConfigurations#591470[POTENTIAL_OOS_DEMAND_PERIOD]) AND CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#591467, qty#591351, None, false), lambdafunction((lambda x_1517#591321.label = OutOfStockProbability), lambda x_1517#591321, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#591470[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_1518#591322.name = OOS_PROBABILITY_THRESHOLD), lambda x_1518#591322, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#591467, qty#591351, None, false), lambdafunction((lambda x_1517#591323.label = OutOfStockProbability), lambda x_1517#591323, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#591470[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_1518#591324.name = OOS_PROBABILITY_THRESHOLD), lambda x_1518#591324, false)), 1, None, false).value as double)) END)
(148) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#591354L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#591355 as string)), struct(name, PRODUCT, value, cast(externalProductId#591393 as string)), struct(name, PLANT, value, cast(externalPlantId#591394 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#591372 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(element_at(quantityKpis#591467, qty#591351, None, false), lambdafunction((lambda x_1519#591340.label = UnfulfilledDemandQty), lambda x_1519#591340, false)), 1, None, false).value as string))) AS businessContext#591337, POTENTIAL_OOS_DEMAND_PERIOD AS internalInsightType#591338, insightConfigurations#591470[POTENTIAL_OOS_DEMAND_PERIOD].configurationVersion AS configurationVersion#591339]
(149) Union
Arguments: false, false
(150) Project
Arguments: [businessContext#591317, internalInsightType#591318, configurationVersion#591319, cast(null as string) AS supplier#591477]
(151) Project
Arguments: [null AS shardId#591581, null AS orderProposalId#591582L, internalInsightType#591318, null AS worklistShardItemId#591583L, null AS thresholdValue#591584, null AS reachedValue#591585, null AS unitOfMeasure#591586, null AS assignmentDetails#591587, null AS externalProductId#591588, null AS externalPlantId#591589, null AS orderProposalItemId#591590, supplier#591477, businessContext#591317, configurationVersion#591319]
(152) Union
Arguments: false, false
(153) Filter
Arguments: internalInsightType#590783 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#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, supplier#591207, businessContext#591591, configurationVersion#591592, struct(insightType, CASE WHEN (internalInsightType#590783 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, 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#590788, 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#590788, 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#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#590783 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, 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#590788, 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#590788, 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#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#590783 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, 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#590788, 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#590788, 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#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#590783 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, 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#590788, 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#590788, 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#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#590783 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, 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#590788, 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#590788, 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#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#590783 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#591207 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#598341]
(156) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightTypeInfo#598341]
(157) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightTypeInfo#598341.insightType AS insightType#598342, insightTypeInfo#598341.supplierGroup AS supplierGroup#598343, insightTypeInfo#598341.supplier AS supplier#598344, insightTypeInfo#598341.supplierSubrange AS supplierSubrange#598345]
(158) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightType#598342, supplierGroup#598343, supplier#598344, supplierSubrange#598345, CASE WHEN (insightType#598342 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#598345 as string))) ELSE CASE WHEN (insightType#598342 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#598343 as string))) ELSE CASE WHEN (insightType#598342 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#598345 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#598343 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#598345 as string)), struct(objectType, Product, objectId, cast(externalProductId#591235 as string)), struct(objectType, Location, objectId, cast(externalPlantId#591236 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#598343 as string)), struct(objectType, Product, objectId, cast(externalProductId#591235 as string)), struct(objectType, Location, objectId, cast(externalPlantId#591236 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string)), struct(objectType, Product, objectId, cast(externalProductId#591235 as string)), struct(objectType, Location, objectId, cast(externalPlantId#591236 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#598345 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#598343 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#598345 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#598343 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002106 as string)), struct(objectType, Supplier, objectId, cast(supplier#598344 as string))) END END END END END END END END END END END END END END END AS triggerObject#598428]
(159) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightType#598342, supplierGroup#598343, supplier#598344, supplierSubrange#598345, triggerObject#598428, CASE WHEN (insightType#598342 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightType#598342 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightType#598342 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#591197 as string))) END END END END END END END END END END END END END END END AS anchorObject#598477]
(160) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightType#598342, supplierGroup#598343, supplier#598344, supplierSubrange#598345, triggerObject#598428, anchorObject#598477, CASE WHEN (insightType#598342 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#598345 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#590786 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#590787 as string))) ELSE CASE WHEN (insightType#598342 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#598343 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#590786 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#590787 as string))) ELSE CASE WHEN (insightType#598342 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#590786 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#590787 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#598345 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#598343 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#598345 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#591235 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#591236 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#598343 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#591235 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#591236 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#591235 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#591236 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#598345 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#590787 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#590786 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#598343 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#590787 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#590786 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#590787 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#590786 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#598345 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#590787 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#598343 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#590787 as string))) ELSE CASE WHEN (insightType#598342 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#598344 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#590787 as string))) END END END END END END END END END END END END END END END AS messageVariables#598572]
(161) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightType#598342, supplierGroup#598343, supplier#598344, supplierSubrange#598345, triggerObject#598428, anchorObject#598477, messageVariables#598572, ((insightType#598342 <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#598342 <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#598342 <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#598342 <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((insightType#598342 <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((insightType#598342 <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((insightType#598342 <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((insightType#598342 <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((insightType#598342 <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((insightType#598342 <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((insightType#598342 <=> OP_CALC_SG_MIN_NOT_MET) OR ((insightType#598342 <=> OP_CALC_SUP_MIN_NOT_MET) OR ((insightType#598342 <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((insightType#598342 <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (insightType#598342 <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))) AS insightTypeSupported#598573]
(162) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightType#598342, supplierGroup#598343, supplier#598344, supplierSubrange#598345, triggerObject#598428, anchorObject#598477, messageVariables#598572, insightTypeSupported#598573, NEW AS situationStatus#598574]
(163) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightType#598342, supplierGroup#598343, supplier#598344, supplierSubrange#598345, triggerObject#598428, anchorObject#598477, messageVariables#598572, insightTypeSupported#598573, situationStatus#598574, Daily_grocery AS marketUnit#598575]
(164) Filter
Arguments: (insightTypeSupported#598573 = true)
(165) Project
Arguments: [shardId#584004, orderProposalId#584005L, internalInsightType#590783, worklistShardItemId#590784L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, assignmentDetails#590788, externalProductId#591235, externalPlantId#591236, orderProposalItemId#591197, businessContext#591591, configurationVersion#591592, insightType#598342 AS situationType#598576, supplierGroup#598343, supplier#598344, supplierSubrange#598345, triggerObject#598428, anchorObject#598477, messageVariables#598572, insightTypeSupported#598573, situationStatus#598574, marketUnit#598575]
(166) Project
Arguments: [anchorObject#598477, messageVariables#598572, triggerObject#598428, marketUnit#598575, situationStatus#598574, situationType#598576]
(167) Project
Arguments: [to_json(struct(anchorObject, anchorObject#598477, messageVariables, messageVariables#598572, triggerObject, triggerObject#598428, marketUnit, marketUnit#598575, situationStatus, situationStatus#598574, situationType, situationType#598576), Some(UTC)) AS value#602326]
(168) Project
Arguments: [cast(value#602326 as string) AS value#602327]
(169) Project
Arguments: [value#602327, array(struct(key, X-Tenant-ID, value, cast(6944346648028224943 as binary)), struct(key, X-Message-ID, value, cast(uuid(Some(6439284987706633055)) 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#602336]