== 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@43cfdc67, [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#803008, orderProposalId#803009L, items#803010, optimizationGroups#803011, isOptimal#803012, lastModified#803013, optimizationInsights#803014], false
(4) Filter
Arguments: shardId#803008 IN (0_1_10000002108)
(5) Filter
Arguments: shardId#803008 IN (0_1_10000002108)
(6) Project
Arguments: [shardId#803008, orderProposalId#803009L, items#803010, optimizationGroups#803011, isOptimal#803012, optimizationInsights#803014]
(7) LogicalRDD
Arguments: [shardId#807150, orderProposalId#807151L, items#807152, optimizationGroups#807153, isOptimal#807154, lastModified#807155, optimizationInsights#807156], false
(8) Filter
Arguments: shardId#807150 IN (0_1_10000002108)
(9) Filter
Arguments: shardId#807150 IN (0_1_10000002108)
(10) Project
Arguments: [shardId#807150, orderProposalId#807151L, items#807152, optimizationGroups#807153, isOptimal#807154, optimizationInsights#807156]
(11) Generate
Arguments: explode(items#807152), false, [item#803519]
(12) Project
Arguments: [shardId#807150, item#803519]
(13) Project
Arguments: [shardId#807150, item#803519.worklistShardItemId AS worklistShardItemId#803520L, item#803519.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#803521, item#803519.qty AS qty#803522]
(14) LocalRelation
Arguments: <empty>, [shardId#803676, worklistShardItemId#803677L, orderProposalId#803678L, orderProposalItemId#803679, orderProposalItemGroupId#803680, originalReplenishmentRunId#803681L, orderProposalHorizonGroupingId#803682L, splitIndicator#803683L, previousOrderProposal#803684L, clusterId#803685L, sequenceId#803686L, sourceOfSupplyUuid#803687, supplierGroup#803688, supplier#803689, subrange#803690, product#803691, plant#803692, purchasingOrg#803693, purchasingGroup#803694, mrpController#803695, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, nextAvailabilityDateTime#803699, isFallbackOrderOnly#803700, ... 20 more fields]
(15) LogicalRelation
Arguments: parquet, [orderProposalId#803721L, orderProposalItemId#803722, supplierGroup#803723, supplier#803724, plant#803725, deliveryDateTime#803726, subrange#803727, supplyingPlant#803728, productGroup#803729, product#803730, orderDateTime#803731, availabilityDateTime#803732, nextAvailabilityDateTime#803733, mrpController#803734, sourceOfSupplyUuid#803735, purchasingOrg#803736, purchasingGroup#803737, isFallbackOrderOnly#803738, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, sequenceId#803743, worklistShardItemId#803744L, orderProposalItemGroupId#803745, ... 20 more fields], false
(16) Filter
Arguments: (shardId#803765 = 0_1_10000002108)
(17) RepartitionByExpression
Arguments: [worklistShardItemId#803744L], 20
(18) Filter
Arguments: (sequenceId#803743 = 2)
(19) Project
Arguments: [orderProposalId#803721L, orderProposalItemId#803722, supplierGroup#803723, supplier#803724, plant#803725, deliveryDateTime#803726, subrange#803727, supplyingPlant#803728, productGroup#803729, product#803730, orderDateTime#803731, availabilityDateTime#803732, nextAvailabilityDateTime#803733, mrpController#803734, sourceOfSupplyUuid#803735, purchasingOrg#803736, purchasingGroup#803737, isFallbackOrderOnly#803738, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, sequenceId#803743, worklistShardItemId#803744L, orderProposalItemGroupId#803745, ... 20 more fields]
(20) Project
Arguments: [shardId#803767, worklistShardItemId#803744L, orderProposalId#803721L, orderProposalItemId#803722, orderProposalItemGroupId#803745, originalReplenishmentRunId#803763L, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, sequenceId#803743, sourceOfSupplyUuid#803735, supplierGroup#803723, supplier#803724, subrange#803727, product#803730, plant#803725, purchasingOrg#803736, purchasingGroup#803737, mrpController#803734, orderDateTime#803731, deliveryDateTime#803726, availabilityDateTime#803732, nextAvailabilityDateTime#803733, isFallbackOrderOnly#803738, ... 20 more fields]
(21) Project
Arguments: [shardId#803767, worklistShardItemId#803744L, orderProposalId#803721L, orderProposalItemId#803722, orderProposalItemGroupId#803745, originalReplenishmentRunId#803763L, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, cast(sequenceId#803743 as bigint) AS sequenceId#803768L, sourceOfSupplyUuid#803735, supplierGroup#803723, supplier#803724, subrange#803727, product#803730, plant#803725, purchasingOrg#803736, purchasingGroup#803737, mrpController#803734, orderDateTime#803731, deliveryDateTime#803726, availabilityDateTime#803732, nextAvailabilityDateTime#803733, isFallbackOrderOnly#803738, ... 20 more fields]
(22) Union
Arguments: false, false
(23) Join
Arguments: LeftOuter, ((shardId#807150 = shardId#803676) AND (worklistShardItemId#803520L = worklistShardItemId#803677L))
(24) Project
Arguments: [shardId#807150, worklistShardItemId#803520L, quantityAfterProdPlantOptimization#803521, qty#803522, orderProposalId#803678L, orderProposalItemId#803679, orderProposalItemGroupId#803680, originalReplenishmentRunId#803681L, orderProposalHorizonGroupingId#803682L, splitIndicator#803683L, previousOrderProposal#803684L, clusterId#803685L, sequenceId#803686L, sourceOfSupplyUuid#803687, supplierGroup#803688, supplier#803689, subrange#803690, product#803691, plant#803692, purchasingOrg#803693, purchasingGroup#803694, mrpController#803695, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, ... 22 more fields]
(25) Project
Arguments: [shardId#807150, worklistShardItemId#803520L, quantityAfterProdPlantOptimization#803521, qty#803522, orderProposalId#803678L, originalReplenishmentRunId#803681L, supplierGroup#803688, supplier#803689, supplyingPlant#803719, productGroup#803720, product#803691, plant#803692, subrange#803690, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, nextAvailabilityDateTime#803699, constraintValues#803713, constraintOperators#803711, constraintLabels#803710, logisticUnits#803715, orderQuantityBaseUom#803701, orderQuantityBaseUomUuid#803702, splitIndicator#803683L, netPriceAmount#803706, ... 14 more fields]
(26) Filter
Arguments: NOT (isFallbackOrderOnly#803700 <=> true)
(27) Project
Arguments: [orderProposalId#803678L]
(28) Deduplicate
Arguments: [orderProposalId#803678L]
(29) Join
Arguments: Inner, (orderProposalId#803009L = orderProposalId#803678L)
(30) Project
Arguments: [orderProposalId#803009L, shardId#803008, items#803010, optimizationGroups#803011, isOptimal#803012, optimizationInsights#803014]
(31) Generate
Arguments: explode(optimizationInsights#803014), false, [insight#807158]
(32) Project
Arguments: [shardId#803008, orderProposalId#803009L, insight#807158]
(33) Project
Arguments: [shardId#803008, orderProposalId#803009L, insight#807158.internalInsightType AS internalInsightType#807159, insight#807158.worklistShardItemId AS worklistShardItemId#807160L, insight#807158.thresholdValue AS thresholdValue#807161, insight#807158.reachedValue AS reachedValue#807162, insight#807158.unitOfMeasure AS unitOfMeasure#807163, insight#807158.assignmentDetails AS assignmentDetails#807164]
(34) LocalRelation
Arguments: <empty>, [shardId#807540, worklistShardItemId#807541L, orderProposalId#807542L, orderProposalItemId#807543, orderProposalItemGroupId#807544, originalReplenishmentRunId#807545L, orderProposalHorizonGroupingId#807546L, splitIndicator#807547L, previousOrderProposal#807548L, clusterId#807549L, sequenceId#807550L, sourceOfSupplyUuid#807551, supplierGroup#807552, supplier#807553, subrange#807554, product#807555, plant#807556, purchasingOrg#807557, purchasingGroup#807558, mrpController#807559, orderDateTime#807560, deliveryDateTime#807561, availabilityDateTime#807562, nextAvailabilityDateTime#807563, isFallbackOrderOnly#807564, ... 20 more fields]
(35) LogicalRelation
Arguments: parquet, [orderProposalId#807585L, orderProposalItemId#807586, supplierGroup#807587, supplier#807588, plant#807589, deliveryDateTime#807590, subrange#807591, supplyingPlant#807592, productGroup#807593, product#807594, orderDateTime#807595, availabilityDateTime#807596, nextAvailabilityDateTime#807597, mrpController#807598, sourceOfSupplyUuid#807599, purchasingOrg#807600, purchasingGroup#807601, isFallbackOrderOnly#807602, orderProposalHorizonGroupingId#807603L, splitIndicator#807604L, previousOrderProposal#807605L, clusterId#807606L, sequenceId#807607, worklistShardItemId#807608L, orderProposalItemGroupId#807609, ... 20 more fields], false
(36) Filter
Arguments: (shardId#807629 = 0_1_10000002108)
(37) RepartitionByExpression
Arguments: [worklistShardItemId#807608L], 20
(38) Filter
Arguments: (sequenceId#807607 = 2)
(39) Project
Arguments: [orderProposalId#807585L, orderProposalItemId#807586, supplierGroup#807587, supplier#807588, plant#807589, deliveryDateTime#807590, subrange#807591, supplyingPlant#807592, productGroup#807593, product#807594, orderDateTime#807595, availabilityDateTime#807596, nextAvailabilityDateTime#807597, mrpController#807598, sourceOfSupplyUuid#807599, purchasingOrg#807600, purchasingGroup#807601, isFallbackOrderOnly#807602, orderProposalHorizonGroupingId#807603L, splitIndicator#807604L, previousOrderProposal#807605L, clusterId#807606L, sequenceId#807607, worklistShardItemId#807608L, orderProposalItemGroupId#807609, ... 20 more fields]
(40) Project
Arguments: [shardId#807631, worklistShardItemId#807608L, orderProposalId#807585L, orderProposalItemId#807586, orderProposalItemGroupId#807609, originalReplenishmentRunId#807627L, orderProposalHorizonGroupingId#807603L, splitIndicator#807604L, previousOrderProposal#807605L, clusterId#807606L, sequenceId#807607, sourceOfSupplyUuid#807599, supplierGroup#807587, supplier#807588, subrange#807591, product#807594, plant#807589, purchasingOrg#807600, purchasingGroup#807601, mrpController#807598, orderDateTime#807595, deliveryDateTime#807590, availabilityDateTime#807596, nextAvailabilityDateTime#807597, isFallbackOrderOnly#807602, ... 20 more fields]
(41) Project
Arguments: [shardId#807631, worklistShardItemId#807608L, orderProposalId#807585L, orderProposalItemId#807586, orderProposalItemGroupId#807609, originalReplenishmentRunId#807627L, orderProposalHorizonGroupingId#807603L, splitIndicator#807604L, previousOrderProposal#807605L, clusterId#807606L, cast(sequenceId#807607 as bigint) AS sequenceId#807632L, sourceOfSupplyUuid#807599, supplierGroup#807587, supplier#807588, subrange#807591, product#807594, plant#807589, purchasingOrg#807600, purchasingGroup#807601, mrpController#807598, orderDateTime#807595, deliveryDateTime#807590, availabilityDateTime#807596, nextAvailabilityDateTime#807597, isFallbackOrderOnly#807602, ... 20 more fields]
(42) Union
Arguments: false, false
(43) Join
Arguments: LeftOuter, ((shardId#803008 = shardId#807540) AND (worklistShardItemId#807160L = worklistShardItemId#807541L))
(44) Project
Arguments: [shardId#803008, worklistShardItemId#807160L, orderProposalId#803009L, internalInsightType#807159, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, orderProposalId#807542L, orderProposalItemId#807543, orderProposalItemGroupId#807544, originalReplenishmentRunId#807545L, orderProposalHorizonGroupingId#807546L, splitIndicator#807547L, previousOrderProposal#807548L, clusterId#807549L, sequenceId#807550L, sourceOfSupplyUuid#807551, supplierGroup#807552, supplier#807553, subrange#807554, product#807555, plant#807556, purchasingOrg#807557, purchasingGroup#807558, ... 26 more fields]
(45) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, supplier#807553]
(46) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, supplier#807553, null AS businessContext#807937, null AS configurationVersion#807938]
(47) LogicalRDD
Arguments: [shardId#807824, orderProposalId#807825L, items#807826, optimizationGroups#807827, isOptimal#807828, lastModified#807829, optimizationInsights#807830], false
(48) Filter
Arguments: shardId#807824 IN (0_1_10000002108)
(49) Filter
Arguments: shardId#807824 IN (0_1_10000002108)
(50) Project
Arguments: [shardId#807824, orderProposalId#807825L, items#807826, optimizationGroups#807827, isOptimal#807828, optimizationInsights#807830]
(51) Generate
Arguments: explode(items#807826), false, [item#807831]
(52) Project
Arguments: [shardId#807824, item#807831]
(53) Project
Arguments: [shardId#807824, item#807831.worklistShardItemId AS worklistShardItemId#807832L, item#807831.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#807833, item#807831.qty AS qty#807834]
(54) LocalRelation
Arguments: <empty>, [shardId#807835, worklistShardItemId#807836L, orderProposalId#807837L, orderProposalItemId#807838, orderProposalItemGroupId#807839, originalReplenishmentRunId#807840L, orderProposalHorizonGroupingId#807841L, splitIndicator#807842L, previousOrderProposal#807843L, clusterId#807844L, sequenceId#807845L, sourceOfSupplyUuid#807846, supplierGroup#807847, supplier#807848, subrange#807849, product#807850, plant#807851, purchasingOrg#807852, purchasingGroup#807853, mrpController#807854, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, isFallbackOrderOnly#807859, ... 20 more fields]
(55) LogicalRelation
Arguments: parquet, [orderProposalId#807880L, orderProposalItemId#807881, supplierGroup#807882, supplier#807883, plant#807884, deliveryDateTime#807885, subrange#807886, supplyingPlant#807887, productGroup#807888, product#807889, orderDateTime#807890, availabilityDateTime#807891, nextAvailabilityDateTime#807892, mrpController#807893, sourceOfSupplyUuid#807894, purchasingOrg#807895, purchasingGroup#807896, isFallbackOrderOnly#807897, orderProposalHorizonGroupingId#807898L, splitIndicator#807899L, previousOrderProposal#807900L, clusterId#807901L, sequenceId#807902, worklistShardItemId#807903L, orderProposalItemGroupId#807904, ... 20 more fields], false
(56) Filter
Arguments: (shardId#807924 = 0_1_10000002108)
(57) RepartitionByExpression
Arguments: [worklistShardItemId#807903L], 20
(58) Filter
Arguments: (sequenceId#807902 = 2)
(59) Project
Arguments: [orderProposalId#807880L, orderProposalItemId#807881, supplierGroup#807882, supplier#807883, plant#807884, deliveryDateTime#807885, subrange#807886, supplyingPlant#807887, productGroup#807888, product#807889, orderDateTime#807890, availabilityDateTime#807891, nextAvailabilityDateTime#807892, mrpController#807893, sourceOfSupplyUuid#807894, purchasingOrg#807895, purchasingGroup#807896, isFallbackOrderOnly#807897, orderProposalHorizonGroupingId#807898L, splitIndicator#807899L, previousOrderProposal#807900L, clusterId#807901L, sequenceId#807902, worklistShardItemId#807903L, orderProposalItemGroupId#807904, ... 20 more fields]
(60) Project
Arguments: [shardId#807925, worklistShardItemId#807903L, orderProposalId#807880L, orderProposalItemId#807881, orderProposalItemGroupId#807904, originalReplenishmentRunId#807922L, orderProposalHorizonGroupingId#807898L, splitIndicator#807899L, previousOrderProposal#807900L, clusterId#807901L, sequenceId#807902, sourceOfSupplyUuid#807894, supplierGroup#807882, supplier#807883, subrange#807886, product#807889, plant#807884, purchasingOrg#807895, purchasingGroup#807896, mrpController#807893, orderDateTime#807890, deliveryDateTime#807885, availabilityDateTime#807891, nextAvailabilityDateTime#807892, isFallbackOrderOnly#807897, ... 20 more fields]
(61) Project
Arguments: [shardId#807925, worklistShardItemId#807903L, orderProposalId#807880L, orderProposalItemId#807881, orderProposalItemGroupId#807904, originalReplenishmentRunId#807922L, orderProposalHorizonGroupingId#807898L, splitIndicator#807899L, previousOrderProposal#807900L, clusterId#807901L, cast(sequenceId#807902 as bigint) AS sequenceId#807926L, sourceOfSupplyUuid#807894, supplierGroup#807882, supplier#807883, subrange#807886, product#807889, plant#807884, purchasingOrg#807895, purchasingGroup#807896, mrpController#807893, orderDateTime#807890, deliveryDateTime#807885, availabilityDateTime#807891, nextAvailabilityDateTime#807892, isFallbackOrderOnly#807897, ... 20 more fields]
(62) Union
Arguments: false, false
(63) Join
Arguments: LeftOuter, ((shardId#807824 = shardId#807835) AND (worklistShardItemId#807832L = worklistShardItemId#807836L))
(64) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, orderProposalItemId#807838, orderProposalItemGroupId#807839, originalReplenishmentRunId#807840L, orderProposalHorizonGroupingId#807841L, splitIndicator#807842L, previousOrderProposal#807843L, clusterId#807844L, sequenceId#807845L, sourceOfSupplyUuid#807846, supplierGroup#807847, supplier#807848, subrange#807849, product#807850, plant#807851, purchasingOrg#807852, purchasingGroup#807853, mrpController#807854, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, ... 22 more fields]
(65) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, originalReplenishmentRunId#807840L, supplierGroup#807847, supplier#807848, supplyingPlant#807878, productGroup#807879, product#807850, plant#807851, subrange#807849, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, constraintValues#807872, constraintOperators#807870, constraintLabels#807869, logisticUnits#807874, orderQuantityBaseUom#807860, orderQuantityBaseUomUuid#807861, splitIndicator#807842L, netPriceAmount#807865, ... 14 more fields]
(66) LogicalRDD
Arguments: [shardId#804240, worklistShardItemId#804241L, qty#804242, demandChannel#804243, demandStream#804244, kpis#804245], false
(67) Filter
Arguments: ((isnull(qty#804242) AND isnull(demandChannel#804243)) AND isnull(demandStream#804244))
(68) Project
Arguments: [shardId#804240, worklistShardItemId#804241L, coalesce(kpis#804245, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#804246]
(69) Join
Arguments: LeftOuter, ((shardId#807824 = shardId#804240) AND (worklistShardItemId#807832L = worklistShardItemId#804241L))
(70) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, originalReplenishmentRunId#807840L, supplierGroup#807847, supplier#807848, supplyingPlant#807878, productGroup#807879, product#807850, plant#807851, subrange#807849, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, constraintValues#807872, constraintOperators#807870, constraintLabels#807869, logisticUnits#807874, orderQuantityBaseUom#807860, orderQuantityBaseUomUuid#807861, splitIndicator#807842L, netPriceAmount#807865, ... 15 more fields]
(71) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, originalReplenishmentRunId#807840L, supplierGroup#807847, supplier#807848, supplyingPlant#807878, productGroup#807879, product#807850, plant#807851, subrange#807849, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, constraintValues#807872, constraintOperators#807870, constraintLabels#807869, logisticUnits#807874, orderQuantityBaseUom#807860, orderQuantityBaseUomUuid#807861, splitIndicator#807842L, netPriceAmount#807865, ... 15 more fields]
(72) LogicalRDD
Arguments: [shardId#804256, worklistShardItemId#804257L, qty#804258, demandChannel#804259, demandStream#804260, kpis#804261], false
(73) Filter
Arguments: (((isnull(qty#804258) AND isnotnull(demandChannel#804259)) AND isnotnull(demandStream#804260)) AND (size(kpis#804261, true) > 0))
(74) Aggregate
Arguments: [shardId#804256, worklistShardItemId#804257L], [shardId#804256, worklistShardItemId#804257L, collect_list(struct(demandChannel, demandChannel#804259, demandStream, demandStream#804260, kpis, kpis#804261), 0, 0) AS channelStreamSpecificKpis#804248]
(75) Join
Arguments: LeftOuter, ((shardId#807824 = shardId#804256) AND (worklistShardItemId#807832L = worklistShardItemId#804257L))
(76) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, originalReplenishmentRunId#807840L, supplierGroup#807847, supplier#807848, supplyingPlant#807878, productGroup#807879, product#807850, plant#807851, subrange#807849, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, constraintValues#807872, constraintOperators#807870, constraintLabels#807869, logisticUnits#807874, orderQuantityBaseUom#807860, orderQuantityBaseUomUuid#807861, splitIndicator#807842L, netPriceAmount#807865, ... 16 more fields]
(77) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, originalReplenishmentRunId#807840L, supplierGroup#807847, supplier#807848, supplyingPlant#807878, productGroup#807879, product#807850, plant#807851, subrange#807849, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, constraintValues#807872, constraintOperators#807870, constraintLabels#807869, logisticUnits#807874, orderQuantityBaseUom#807860, orderQuantityBaseUomUuid#807861, splitIndicator#807842L, netPriceAmount#807865, ... 16 more fields]
(78) LogicalRDD
Arguments: [shardId#804269, worklistShardItemId#804270L, qty#804271, demandChannel#804272, demandStream#804273, kpis#804274], false
(79) Filter
Arguments: (isnotnull(qty#804271) AND isnotnull(kpis#804274))
(80) Project
Arguments: [shardId#804269, worklistShardItemId#804270L, qty#804271, kpis#804274]
(81) Aggregate
Arguments: [shardId#804269, worklistShardItemId#804270L], [shardId#804269, worklistShardItemId#804270L, map_from_entries(collect_list(struct(qty, qty#804271, kpis, kpis#804274), 0, 0)) AS quantityKpis#804263]
(82) Join
Arguments: LeftOuter, ((shardId#807824 = shardId#804269) AND (worklistShardItemId#807832L = worklistShardItemId#804270L))
(83) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, originalReplenishmentRunId#807840L, supplierGroup#807847, supplier#807848, supplyingPlant#807878, productGroup#807879, product#807850, plant#807851, subrange#807849, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, constraintValues#807872, constraintOperators#807870, constraintLabels#807869, logisticUnits#807874, orderQuantityBaseUom#807860, orderQuantityBaseUomUuid#807861, splitIndicator#807842L, netPriceAmount#807865, ... 17 more fields]
(84) Project
Arguments: [shardId#807824, worklistShardItemId#807832L, quantityAfterProdPlantOptimization#807833, qty#807834, orderProposalId#807837L, originalReplenishmentRunId#807840L, supplierGroup#807847, supplier#807848, supplyingPlant#807878, productGroup#807879, product#807850, plant#807851, subrange#807849, orderDateTime#807855, deliveryDateTime#807856, availabilityDateTime#807857, nextAvailabilityDateTime#807858, constraintValues#807872, constraintOperators#807870, constraintLabels#807869, logisticUnits#807874, orderQuantityBaseUom#807860, orderQuantityBaseUomUuid#807861, splitIndicator#807842L, netPriceAmount#807865, ... 17 more fields]
(85) Filter
Arguments: NOT (isFallbackOrderOnly#807859 <=> true)
(86) LocalRelation
Arguments: <empty>, [shardId#807633, uomCategories#807634]
(87) Project
Arguments: [shardId#807633, uomCategories#807634, null AS insightConfigurations#807640]
(88) LogicalRelation
Arguments: parquet, [uomCategories#807635, insightConfigurations#807636, shardId#807637], false
(89) Filter
Arguments: (shardId#807637 = 0_1_10000002108)
(90) RepartitionByExpression
Arguments: 20
(91) Project
Arguments: [uomCategories#807635, insightConfigurations#807636, 0_1_10000002108 AS shardId#807639]
(92) Project
Arguments: [shardId#807639, uomCategories#807635, insightConfigurations#807636]
(93) Union
Arguments: false, false
(94) Project
Arguments: [insightConfigurations#807640]
(95) Join
Arguments: Cross
(96) Filter
Arguments: (((isnotnull(insightConfigurations#807640[POTENTIAL_OOS_STOCK_PERIOD]) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#804247, lambdafunction((lambda x_2133#807641.label = OutOfStockProbability), lambda x_2133#807641, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#807640[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2134#807642.name = OOS_PROBABILITY_THRESHOLD), lambda x_2134#807642, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#804247, lambdafunction((lambda x_2133#807643.label = OutOfStockProbability), lambda x_2133#807643, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#807640[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2134#807644.name = OOS_PROBABILITY_THRESHOLD), lambda x_2134#807644, false)), 1, None, false).value as double)) END) AND CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#804247, lambdafunction((lambda x_2135#807645.label = InitialStockQty), lambda x_2135#807645, false)), 1, None, false).value) OR isnull(CASE WHEN cast(element_at(filter(insightConfigurations#807640[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2136#807646.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_2136#807646, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END)) THEN false ELSE (element_at(filter(prodLocSpecificKpis#804247, lambdafunction((lambda x_2135#807647.label = InitialStockQty), lambda x_2135#807647, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(insightConfigurations#807640[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2136#807648.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_2136#807648, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (isnull(CASE WHEN isnull(orderDateTime#807855) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#807855, 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#807640[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2137#807649.name = OFFSET_CURRENT_ORDER_DATE), lambda x_2137#807649, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#807855) THEN cast(null as double) ELSE (cast((unix_timestamp(orderDateTime#807855, 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#807640[POTENTIAL_OOS_STOCK_PERIOD].settings, lambdafunction((lambda x_2137#807650.name = OFFSET_CURRENT_ORDER_DATE), lambda x_2137#807650, false)), 1, None, false).value as double)) END)
(97) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#807837L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#807838 as string)), struct(name, PRODUCT, value, cast(externalProductId#807876 as string)), struct(name, PLANT, value, cast(externalPlantId#807877 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#807855 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(prodLocSpecificKpis#804247, lambdafunction((lambda x_2138#807666.label = UnfulfilledDemandQty), lambda x_2138#807666, false)), 1, None, false).value as string))) AS businessContext#807663, POTENTIAL_OOS_STOCK_PERIOD AS internalInsightType#807664, insightConfigurations#807640[POTENTIAL_OOS_STOCK_PERIOD].configurationVersion AS configurationVersion#807665]
(98) LogicalRDD
Arguments: [shardId#807687, orderProposalId#807688L, items#807689, optimizationGroups#807690, isOptimal#807691, lastModified#807692, optimizationInsights#807693], false
(99) Filter
Arguments: shardId#807687 IN (0_1_10000002108)
(100) Filter
Arguments: shardId#807687 IN (0_1_10000002108)
(101) Project
Arguments: [shardId#807687, orderProposalId#807688L, items#807689, optimizationGroups#807690, isOptimal#807691, optimizationInsights#807693]
(102) Generate
Arguments: explode(items#807689), false, [item#807694]
(103) Project
Arguments: [shardId#807687, item#807694]
(104) Project
Arguments: [shardId#807687, item#807694.worklistShardItemId AS worklistShardItemId#807695L, item#807694.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#807696, item#807694.qty AS qty#807697]
(105) LocalRelation
Arguments: <empty>, [shardId#807698, worklistShardItemId#807699L, orderProposalId#807700L, orderProposalItemId#807701, orderProposalItemGroupId#807702, originalReplenishmentRunId#807703L, orderProposalHorizonGroupingId#807704L, splitIndicator#807705L, previousOrderProposal#807706L, clusterId#807707L, sequenceId#807708L, sourceOfSupplyUuid#807709, supplierGroup#807710, supplier#807711, subrange#807712, product#807713, plant#807714, purchasingOrg#807715, purchasingGroup#807716, mrpController#807717, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, isFallbackOrderOnly#807722, ... 20 more fields]
(106) LogicalRelation
Arguments: parquet, [orderProposalId#807743L, orderProposalItemId#807744, supplierGroup#807745, supplier#807746, plant#807747, deliveryDateTime#807748, subrange#807749, supplyingPlant#807750, productGroup#807751, product#807752, orderDateTime#807753, availabilityDateTime#807754, nextAvailabilityDateTime#807755, mrpController#807756, sourceOfSupplyUuid#807757, purchasingOrg#807758, purchasingGroup#807759, isFallbackOrderOnly#807760, orderProposalHorizonGroupingId#807761L, splitIndicator#807762L, previousOrderProposal#807763L, clusterId#807764L, sequenceId#807765, worklistShardItemId#807766L, orderProposalItemGroupId#807767, ... 20 more fields], false
(107) Filter
Arguments: (shardId#807787 = 0_1_10000002108)
(108) RepartitionByExpression
Arguments: [worklistShardItemId#807766L], 20
(109) Filter
Arguments: (sequenceId#807765 = 2)
(110) Project
Arguments: [orderProposalId#807743L, orderProposalItemId#807744, supplierGroup#807745, supplier#807746, plant#807747, deliveryDateTime#807748, subrange#807749, supplyingPlant#807750, productGroup#807751, product#807752, orderDateTime#807753, availabilityDateTime#807754, nextAvailabilityDateTime#807755, mrpController#807756, sourceOfSupplyUuid#807757, purchasingOrg#807758, purchasingGroup#807759, isFallbackOrderOnly#807760, orderProposalHorizonGroupingId#807761L, splitIndicator#807762L, previousOrderProposal#807763L, clusterId#807764L, sequenceId#807765, worklistShardItemId#807766L, orderProposalItemGroupId#807767, ... 20 more fields]
(111) Project
Arguments: [shardId#807788, worklistShardItemId#807766L, orderProposalId#807743L, orderProposalItemId#807744, orderProposalItemGroupId#807767, originalReplenishmentRunId#807785L, orderProposalHorizonGroupingId#807761L, splitIndicator#807762L, previousOrderProposal#807763L, clusterId#807764L, sequenceId#807765, sourceOfSupplyUuid#807757, supplierGroup#807745, supplier#807746, subrange#807749, product#807752, plant#807747, purchasingOrg#807758, purchasingGroup#807759, mrpController#807756, orderDateTime#807753, deliveryDateTime#807748, availabilityDateTime#807754, nextAvailabilityDateTime#807755, isFallbackOrderOnly#807760, ... 20 more fields]
(112) Project
Arguments: [shardId#807788, worklistShardItemId#807766L, orderProposalId#807743L, orderProposalItemId#807744, orderProposalItemGroupId#807767, originalReplenishmentRunId#807785L, orderProposalHorizonGroupingId#807761L, splitIndicator#807762L, previousOrderProposal#807763L, clusterId#807764L, cast(sequenceId#807765 as bigint) AS sequenceId#807789L, sourceOfSupplyUuid#807757, supplierGroup#807745, supplier#807746, subrange#807749, product#807752, plant#807747, purchasingOrg#807758, purchasingGroup#807759, mrpController#807756, orderDateTime#807753, deliveryDateTime#807748, availabilityDateTime#807754, nextAvailabilityDateTime#807755, isFallbackOrderOnly#807760, ... 20 more fields]
(113) Union
Arguments: false, false
(114) Join
Arguments: LeftOuter, ((shardId#807687 = shardId#807698) AND (worklistShardItemId#807695L = worklistShardItemId#807699L))
(115) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, orderProposalItemId#807701, orderProposalItemGroupId#807702, originalReplenishmentRunId#807703L, orderProposalHorizonGroupingId#807704L, splitIndicator#807705L, previousOrderProposal#807706L, clusterId#807707L, sequenceId#807708L, sourceOfSupplyUuid#807709, supplierGroup#807710, supplier#807711, subrange#807712, product#807713, plant#807714, purchasingOrg#807715, purchasingGroup#807716, mrpController#807717, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, ... 22 more fields]
(116) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, originalReplenishmentRunId#807703L, supplierGroup#807710, supplier#807711, supplyingPlant#807741, productGroup#807742, product#807713, plant#807714, subrange#807712, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, constraintValues#807735, constraintOperators#807733, constraintLabels#807732, logisticUnits#807737, orderQuantityBaseUom#807723, orderQuantityBaseUomUuid#807724, splitIndicator#807705L, netPriceAmount#807728, ... 14 more fields]
(117) LogicalRDD
Arguments: [shardId#807790, worklistShardItemId#807791L, qty#807792, demandChannel#807793, demandStream#807794, kpis#807795], false
(118) Filter
Arguments: ((isnull(qty#807792) AND isnull(demandChannel#807793)) AND isnull(demandStream#807794))
(119) Project
Arguments: [shardId#807790, worklistShardItemId#807791L, coalesce(kpis#807795, cast(array() as array<struct<label:string,dateTime:timestamp,value:double>>)) AS prodLocSpecificKpis#807796]
(120) Join
Arguments: LeftOuter, ((shardId#807687 = shardId#807790) AND (worklistShardItemId#807695L = worklistShardItemId#807791L))
(121) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, originalReplenishmentRunId#807703L, supplierGroup#807710, supplier#807711, supplyingPlant#807741, productGroup#807742, product#807713, plant#807714, subrange#807712, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, constraintValues#807735, constraintOperators#807733, constraintLabels#807732, logisticUnits#807737, orderQuantityBaseUom#807723, orderQuantityBaseUomUuid#807724, splitIndicator#807705L, netPriceAmount#807728, ... 15 more fields]
(122) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, originalReplenishmentRunId#807703L, supplierGroup#807710, supplier#807711, supplyingPlant#807741, productGroup#807742, product#807713, plant#807714, subrange#807712, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, constraintValues#807735, constraintOperators#807733, constraintLabels#807732, logisticUnits#807737, orderQuantityBaseUom#807723, orderQuantityBaseUomUuid#807724, splitIndicator#807705L, netPriceAmount#807728, ... 15 more fields]
(123) LogicalRDD
Arguments: [shardId#807798, worklistShardItemId#807799L, qty#807800, demandChannel#807801, demandStream#807802, kpis#807803], false
(124) Filter
Arguments: (((isnull(qty#807800) AND isnotnull(demandChannel#807801)) AND isnotnull(demandStream#807802)) AND (size(kpis#807803, true) > 0))
(125) Aggregate
Arguments: [shardId#807798, worklistShardItemId#807799L], [shardId#807798, worklistShardItemId#807799L, collect_list(struct(demandChannel, demandChannel#807801, demandStream, demandStream#807802, kpis, kpis#807803), 0, 0) AS channelStreamSpecificKpis#807804]
(126) Join
Arguments: LeftOuter, ((shardId#807687 = shardId#807798) AND (worklistShardItemId#807695L = worklistShardItemId#807799L))
(127) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, originalReplenishmentRunId#807703L, supplierGroup#807710, supplier#807711, supplyingPlant#807741, productGroup#807742, product#807713, plant#807714, subrange#807712, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, constraintValues#807735, constraintOperators#807733, constraintLabels#807732, logisticUnits#807737, orderQuantityBaseUom#807723, orderQuantityBaseUomUuid#807724, splitIndicator#807705L, netPriceAmount#807728, ... 16 more fields]
(128) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, originalReplenishmentRunId#807703L, supplierGroup#807710, supplier#807711, supplyingPlant#807741, productGroup#807742, product#807713, plant#807714, subrange#807712, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, constraintValues#807735, constraintOperators#807733, constraintLabels#807732, logisticUnits#807737, orderQuantityBaseUom#807723, orderQuantityBaseUomUuid#807724, splitIndicator#807705L, netPriceAmount#807728, ... 16 more fields]
(129) LogicalRDD
Arguments: [shardId#807806, worklistShardItemId#807807L, qty#807808, demandChannel#807809, demandStream#807810, kpis#807811], false
(130) Filter
Arguments: (isnotnull(qty#807808) AND isnotnull(kpis#807811))
(131) Project
Arguments: [shardId#807806, worklistShardItemId#807807L, qty#807808, kpis#807811]
(132) Aggregate
Arguments: [shardId#807806, worklistShardItemId#807807L], [shardId#807806, worklistShardItemId#807807L, map_from_entries(collect_list(struct(qty, qty#807808, kpis, kpis#807811), 0, 0)) AS quantityKpis#807812]
(133) Join
Arguments: LeftOuter, ((shardId#807687 = shardId#807806) AND (worklistShardItemId#807695L = worklistShardItemId#807807L))
(134) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, originalReplenishmentRunId#807703L, supplierGroup#807710, supplier#807711, supplyingPlant#807741, productGroup#807742, product#807713, plant#807714, subrange#807712, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, constraintValues#807735, constraintOperators#807733, constraintLabels#807732, logisticUnits#807737, orderQuantityBaseUom#807723, orderQuantityBaseUomUuid#807724, splitIndicator#807705L, netPriceAmount#807728, ... 17 more fields]
(135) Project
Arguments: [shardId#807687, worklistShardItemId#807695L, quantityAfterProdPlantOptimization#807696, qty#807697, orderProposalId#807700L, originalReplenishmentRunId#807703L, supplierGroup#807710, supplier#807711, supplyingPlant#807741, productGroup#807742, product#807713, plant#807714, subrange#807712, orderDateTime#807718, deliveryDateTime#807719, availabilityDateTime#807720, nextAvailabilityDateTime#807721, constraintValues#807735, constraintOperators#807733, constraintLabels#807732, logisticUnits#807737, orderQuantityBaseUom#807723, orderQuantityBaseUomUuid#807724, splitIndicator#807705L, netPriceAmount#807728, ... 17 more fields]
(136) Filter
Arguments: NOT (isFallbackOrderOnly#807722 <=> true)
(137) LocalRelation
Arguments: <empty>, [shardId#807814, uomCategories#807815]
(138) Project
Arguments: [shardId#807814, uomCategories#807815, null AS insightConfigurations#807816]
(139) LogicalRelation
Arguments: parquet, [uomCategories#807817, insightConfigurations#807818, shardId#807819], false
(140) Filter
Arguments: (shardId#807819 = 0_1_10000002108)
(141) RepartitionByExpression
Arguments: 20
(142) Project
Arguments: [uomCategories#807817, insightConfigurations#807818, 0_1_10000002108 AS shardId#807820]
(143) Project
Arguments: [shardId#807820, uomCategories#807817, insightConfigurations#807818]
(144) Union
Arguments: false, false
(145) Project
Arguments: [insightConfigurations#807816]
(146) Join
Arguments: Cross
(147) Filter
Arguments: (isnotnull(insightConfigurations#807816[POTENTIAL_OOS_DEMAND_PERIOD]) AND CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#807813, qty#807697, None, false), lambdafunction((lambda x_2139#807667.label = OutOfStockProbability), lambda x_2139#807667, false)), 1, None, false).value) OR isnull(cast(element_at(filter(insightConfigurations#807816[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_2140#807668.name = OOS_PROBABILITY_THRESHOLD), lambda x_2140#807668, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#807813, qty#807697, None, false), lambdafunction((lambda x_2139#807669.label = OutOfStockProbability), lambda x_2139#807669, false)), 1, None, false).value >= cast(element_at(filter(insightConfigurations#807816[POTENTIAL_OOS_DEMAND_PERIOD].settings, lambdafunction((lambda x_2140#807670.name = OOS_PROBABILITY_THRESHOLD), lambda x_2140#807670, false)), 1, None, false).value as double)) END)
(148) Project
Arguments: [array(struct(name, ORDER_PROPOSAL, value, cast(orderProposalId#807700L as string)), struct(name, ORDER_PROPOSAL_ITEM, value, cast(orderProposalItemId#807701 as string)), struct(name, PRODUCT, value, cast(externalProductId#807739 as string)), struct(name, PLANT, value, cast(externalPlantId#807740 as string)), struct(name, ORDER_DATE_TIME, value, date_format(cast(orderDateTime#807718 as timestamp), yyyy-MM-dd'T'HH:mm:ss'Z', Some(UTC))), struct(name, UNFULFILLED_DEMAND, value, cast(element_at(filter(element_at(quantityKpis#807813, qty#807697, None, false), lambdafunction((lambda x_2141#807686.label = UnfulfilledDemandQty), lambda x_2141#807686, false)), 1, None, false).value as string))) AS businessContext#807683, POTENTIAL_OOS_DEMAND_PERIOD AS internalInsightType#807684, insightConfigurations#807816[POTENTIAL_OOS_DEMAND_PERIOD].configurationVersion AS configurationVersion#807685]
(149) Union
Arguments: false, false
(150) Project
Arguments: [businessContext#807663, internalInsightType#807664, configurationVersion#807665, cast(null as string) AS supplier#807823]
(151) Project
Arguments: [null AS shardId#807927, null AS orderProposalId#807928L, internalInsightType#807664, null AS worklistShardItemId#807929L, null AS thresholdValue#807930, null AS reachedValue#807931, null AS unitOfMeasure#807932, null AS assignmentDetails#807933, null AS externalProductId#807934, null AS externalPlantId#807935, null AS orderProposalItemId#807936, supplier#807823, businessContext#807663, configurationVersion#807665]
(152) Union
Arguments: false, false
(153) Filter
Arguments: internalInsightType#807159 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#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, supplier#807553, businessContext#807937, configurationVersion#807938, struct(insightType, CASE WHEN (internalInsightType#807159 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, 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#807164, 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#807164, 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#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#807159 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, 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#807164, 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#807164, 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#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#807159 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, 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#807164, 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#807164, 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#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#807159 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, 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#807164, 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#807164, 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#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#807159 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, 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#807164, 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#807164, 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#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#807159 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#807553 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevel,StringType,true), StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#810943]
(156) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightTypeInfo#810943]
(157) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightTypeInfo#810943.insightType AS insightType#810944, insightTypeInfo#810943.supplierGroup AS supplierGroup#810945, insightTypeInfo#810943.supplier AS supplier#810946, insightTypeInfo#810943.supplierSubrange AS supplierSubrange#810947]
(158) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightType#810944, supplierGroup#810945, supplier#810946, supplierSubrange#810947, CASE WHEN (insightType#810944 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#810947 as string))) ELSE CASE WHEN (insightType#810944 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#810945 as string))) ELSE CASE WHEN (insightType#810944 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#810947 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#810945 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#810947 as string)), struct(objectType, Product, objectId, cast(externalProductId#807581 as string)), struct(objectType, Location, objectId, cast(externalPlantId#807582 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#810945 as string)), struct(objectType, Product, objectId, cast(externalProductId#807581 as string)), struct(objectType, Location, objectId, cast(externalPlantId#807582 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string)), struct(objectType, Product, objectId, cast(externalProductId#807581 as string)), struct(objectType, Location, objectId, cast(externalPlantId#807582 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#810947 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#810945 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string)), struct(objectType, SupplierSubrange, objectId, cast(supplierSubrange#810947 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, SupplierGroup, objectId, cast(supplierGroup#810945 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, ReplenishmentRunId, objectId, cast(10000002108 as string)), struct(objectType, Supplier, objectId, cast(supplier#810946 as string))) END END END END END END END END END END END END END END END AS triggerObject#811030]
(159) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightType#810944, supplierGroup#810945, supplier#810946, supplierSubrange#810947, triggerObject#811030, CASE WHEN (insightType#810944 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightType#810944 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightType#810944 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, cast(orderProposalItemId#807543 as string))) END END END END END END END END END END END END END END END AS anchorObject#811079]
(160) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightType#810944, supplierGroup#810945, supplier#810946, supplierSubrange#810947, triggerObject#811030, anchorObject#811079, CASE WHEN (insightType#810944 = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#810947 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#807162 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#807163 as string))) ELSE CASE WHEN (insightType#810944 = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#810945 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#807162 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#807163 as string))) ELSE CASE WHEN (insightType#810944 = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, InitialValue, variableValue, cast(reachedValue#807162 as string)), struct(variableName, InitialUoM, variableValue, cast(unitOfMeasure#807163 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#810947 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#810945 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#810947 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#807581 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#807582 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#810945 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#807581 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#807582 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, ProductID, variableValue, cast(externalProductId#807581 as string)), struct(variableName, LocationID, variableValue, cast(externalPlantId#807582 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#810947 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#807163 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#807162 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#810945 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#807163 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#807162 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, cast(unitOfMeasure#807163 as string)), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#807162 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, SupplierSubrangeID, variableValue, cast(supplierSubrange#810947 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#807163 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, cast(supplierGroup#810945 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#807163 as string))) ELSE CASE WHEN (insightType#810944 = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, cast(supplier#810946 as string)), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, cast(unitOfMeasure#807163 as string))) END END END END END END END END END END END END END END END AS messageVariables#811174]
(161) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightType#810944, supplierGroup#810945, supplier#810946, supplierSubrange#810947, triggerObject#811030, anchorObject#811079, messageVariables#811174, ((insightType#810944 <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#810944 <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#810944 <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((insightType#810944 <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((insightType#810944 <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((insightType#810944 <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((insightType#810944 <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((insightType#810944 <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((insightType#810944 <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((insightType#810944 <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((insightType#810944 <=> OP_CALC_SG_MIN_NOT_MET) OR ((insightType#810944 <=> OP_CALC_SUP_MIN_NOT_MET) OR ((insightType#810944 <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((insightType#810944 <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (insightType#810944 <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))) AS insightTypeSupported#811175]
(162) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightType#810944, supplierGroup#810945, supplier#810946, supplierSubrange#810947, triggerObject#811030, anchorObject#811079, messageVariables#811174, insightTypeSupported#811175, NEW AS situationStatus#811176]
(163) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightType#810944, supplierGroup#810945, supplier#810946, supplierSubrange#810947, triggerObject#811030, anchorObject#811079, messageVariables#811174, insightTypeSupported#811175, situationStatus#811176, Daily_grocery AS marketUnit#811177]
(164) Filter
Arguments: (insightTypeSupported#811175 = true)
(165) Project
Arguments: [shardId#803008, orderProposalId#803009L, internalInsightType#807159, worklistShardItemId#807160L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, assignmentDetails#807164, externalProductId#807581, externalPlantId#807582, orderProposalItemId#807543, businessContext#807937, configurationVersion#807938, insightType#810944 AS situationType#811178, supplierGroup#810945, supplier#810946, supplierSubrange#810947, triggerObject#811030, anchorObject#811079, messageVariables#811174, insightTypeSupported#811175, situationStatus#811176, marketUnit#811177]
(166) Project
Arguments: [anchorObject#811079, messageVariables#811174, triggerObject#811030, marketUnit#811177, situationStatus#811176, situationType#811178]
(167) Project
Arguments: [to_json(struct(anchorObject, anchorObject#811079, messageVariables, messageVariables#811174, triggerObject, triggerObject#811030, marketUnit, marketUnit#811177, situationStatus, situationStatus#811176, situationType, situationType#811178), Some(UTC)) AS value#812836]
(168) Project
Arguments: [cast(value#812836 as string) AS value#812837]
(169) Project
Arguments: [value#812837, array(struct(key, X-Tenant-ID, value, cast(6944346648028224943 as binary)), struct(key, X-Message-ID, value, cast(uuid(Some(1544487932232976361)) 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#812846]