digraph G { 0 [id="node0" labelType="html" label="<b>CollectLimit</b><br><br>shuffle records written: 5<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1<br>local bytes read: 62.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>local merged bytes read: 0.0 B<br>remote reqs duration: 0 ms<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 65029.0: task 162464))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>310.0 B (62.0 B, 62.0 B, 62.0 B (stage 65029.0: task 162460))" tooltip="CollectLimit 1"]; 1 [id="node1" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 23" tooltip="InMemoryTableScan"]; subgraph cluster2 { isCluster="true"; id="cluster2"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n150 ms (0 ms, 8 ms, 24 ms (stage 65029.0: task 162460))"; tooltip="WholeStageCodegen (9)"; 3 [id="node3" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [CASE WHEN (insightTypeInfo#785719.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#777608L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#782362)) END END END END END END END END END END END END END END END AS anchorObject#785855, CASE WHEN (insightTypeInfo#785719.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#785719.supplierSubrange), struct(variableName, InitialValue, variableValue, cast(reachedValue#781938 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#781939)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#785719.supplierGroup), struct(variableName, InitialValue, variableValue, cast(reachedValue#781938 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#781939)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, InitialValue, variableValue, cast(reachedValue#781938 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#781939)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#785719.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#785719.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#785719.supplierSubrange), struct(variableName, ProductID, variableValue, externalProductId#782386), struct(variableName, LocationID, variableValue, externalPlantId#782387)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#785719.supplierGroup), struct(variableName, ProductID, variableValue, externalProductId#782386), struct(variableName, LocationID, variableValue, externalPlantId#782387)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, ProductID, variableValue, externalProductId#782386), struct(variableName, LocationID, variableValue, externalPlantId#782387)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#785719.supplierSubrange), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#781939), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#781938 as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#785719.supplierGroup), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#781939), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#781938 as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#781939), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#781938 as string))) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#785719.supplierSubrange), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#781939)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#785719.supplierGroup), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#781939)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#785719.supplier), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#781937 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#781939)) END END END END END END END END END END END END END END END AS messageVariables#785950, CASE WHEN (insightTypeInfo#785719.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#785719.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#785719.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#785719.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#785719.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#785719.supplierSubrange), struct(objectType, Product, objectId, externalProductId#782386), struct(objectType, Location, objectId, externalPlantId#782387)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#785719.supplierGroup), struct(objectType, Product, objectId, externalProductId#782386), struct(objectType, Location, objectId, externalPlantId#782387)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier), struct(objectType, Product, objectId, externalProductId#782386), struct(objectType, Location, objectId, externalPlantId#782387)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#785719.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#785719.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#785719.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#785719.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#785719.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#785719.supplier)) END END END END END END END END END END END END END END END AS triggerObject#785806, Daily_grocery AS marketUnit#785953, NEW AS situationStatus#785952, insightTypeInfo#785719.insightType AS situationType#785954]"]; } 4 [id="node4" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#777608L, thresholdValue#781937, reachedValue#781938, unitOfMeasure#781939, externalProductId#782386, externalPlantId#782387, orderProposalItemId#782362, struct(insightType, CASE WHEN (internalInsightType#781935 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#781935 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#781935 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#781935 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#781935 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#781935 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#782364 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#781940, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#785719]"]; subgraph cluster5 { isCluster="true"; id="cluster5"; label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n1.2 s (3 ms, 93 ms, 196 ms (stage 65029.0: task 162460))"; tooltip="WholeStageCodegen (8)"; 6 [id="node6" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 23" tooltip="BroadcastHashJoin [worklistShardItemId#781936L], [worklistShardItemId#782384L], LeftOuter, BuildRight, (shardId#777607 = 0_1_10000002108), false"]; 7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#777607, orderProposalId#777608L, insight#781934.internalInsightType AS internalInsightType#781935, insight#781934.worklistShardItemId AS worklistShardItemId#781936L, insight#781934.thresholdValue AS thresholdValue#781937, insight#781934.reachedValue AS reachedValue#781938, insight#781934.unitOfMeasure AS unitOfMeasure#781939, insight#781934.assignmentDetails AS assignmentDetails#781940]"]; } 8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 23" tooltip="Filter (insight#781934.internalInsightType 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) AND ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_SG_MIN_NOT_MET) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_SUP_MIN_NOT_MET) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (CASE WHEN (insight#781934.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, 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), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#781934.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#781934.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#781934.internalInsightType END <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))))"]; subgraph cluster9 { isCluster="true"; id="cluster9"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n2.1 s (11 ms, 151 ms, 312 ms (stage 65029.0: task 162460))"; tooltip="WholeStageCodegen (5)"; 10 [id="node10" labelType="html" label="<b>Generate</b><br><br>number of output rows: 113" tooltip="Generate explode(optimizationInsights#777613), [orderProposalId#777608L, shardId#777607], false, [insight#781934]"]; 11 [id="node11" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#777608L, shardId#777607, optimizationInsights#777613]"]; 12 [id="node12" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 11" tooltip="BroadcastHashJoin [orderProposalId#777608L], [orderProposalId#778320L], Inner, BuildLeft, false"]; 23 [id="node23" labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build total (min, med, max (stageId: taskId))<br>30 ms (0 ms, 1 ms, 3 ms (stage 65029.0: task 162468))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 65029.0: task 162461))<br>number of output rows: 59<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#778320L], functions=[])"]; } 13 [id="node13" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 34 ms<br>number of output rows: 11<br>data size: 1024.5 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=310082]"]; subgraph cluster14 { isCluster="true"; id="cluster14"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n0 ms (0 ms, 0 ms, 0 ms (stage 65023.0: task 162338))"; tooltip="WholeStageCodegen (1)"; 15 [id="node15" labelType="html" label="<b>Filter</b><br><br>number of output rows: 11" tooltip="Filter ((isnotnull(orderProposalId#777608L) AND (size(optimizationInsights#777613, true) > 0)) AND isnotnull(optimizationInsights#777613))"]; } 16 [id="node16" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 59" tooltip="InMemoryTableScan [shardId#777607, orderProposalId#777608L, optimizationInsights#777613], [isnotnull(orderProposalId#777608L), (size(optimizationInsights#777613, true) > 0), isnotnull(optimizationInsights#777613)]"]; subgraph cluster17 { isCluster="true"; id="cluster17"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 18 [id="node18" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#777607) AND (shardId#777607 = 0_1_10000002108))"]; } 19 [id="node19" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#777607, orderProposalId#777608L, items#777609, optimizationGroups#777610, isOptimal#777611, optimizationInsights#777613], [isnotnull(shardId#777607), (shardId#777607 = 0_1_10000002108)]"]; subgraph cluster20 { isCluster="true"; id="cluster20"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 21 [id="node21" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#777607) AND (shardId#777607 = 0_1_10000002108))"]; 22 [id="node22" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#777607,orderProposalId#777608L,items#777609,optimizationGroups#777610,isOptimal#777611,lastModified#777612,optimizationInsights#777613]"]; } 24 [id="node24" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 528<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 528<br>local bytes read total (min, med, max (stageId: taskId))<br>13.0 KiB (150.0 B, 741.0 B, 981.0 B (stage 65029.0: task 162474))<br>merged fetch fallback count: 0<br>local blocks read: 159<br>remote merged chunks fetched: 0<br>remote blocks read: 144<br>data size total (min, med, max (stageId: taskId))<br>8.3 KiB (336.0 B, 432.0 B, 496.0 B (stage 65028.0: task 162452))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>21 ms (0 ms, 1 ms, 1 ms (stage 65028.0: task 162447))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 65029.0: task 162461))<br>remote bytes read total (min, med, max (stageId: taskId))<br>11.7 KiB (300.0 B, 752.0 B, 961.0 B (stage 65029.0: task 162466))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>9 ms (0 ms, 1 ms, 1 ms (stage 65029.0: task 162468))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>24.7 KiB (1074.0 B, 1262.0 B, 1476.0 B (stage 65028.0: task 162457))" tooltip="Exchange hashpartitioning(orderProposalId#778320L, 20), ENSURE_REQUIREMENTS, [plan_id=310104]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n136 ms (3 ms, 7 ms, 10 ms (stage 65028.0: task 162442))"; tooltip="WholeStageCodegen (4)"; 26 [id="node26" labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build total (min, med, max (stageId: taskId))<br>41 ms (1 ms, 2 ms, 3 ms (stage 65028.0: task 162443))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 65028.0: task 162449))<br>number of output rows: 528<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#778320L], functions=[])"]; 27 [id="node27" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#778320L]"]; 28 [id="node28" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 980" tooltip="BroadcastHashJoin [worklistShardItemId#778119L], [worklistShardItemId#778343L], Inner, BuildLeft, false"]; 42 [id="node42" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#778343L, orderProposalId#778320L]"]; } 29 [id="node29" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 45 ms<br>number of output rows: 980<br>data size: 1047.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=310090]"]; subgraph cluster30 { isCluster="true"; id="cluster30"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n0 ms (0 ms, 0 ms, 0 ms (stage 65024.0: task 162343))"; tooltip="WholeStageCodegen (2)"; 31 [id="node31" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#778118L AS worklistShardItemId#778119L]"]; 32 [id="node32" labelType="html" label="<b>Generate</b><br><br>number of output rows: 980" tooltip="Generate explode(_extract_worklistShardItemId#786931), false, [item#778118L]"]; 33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#781928.worklistShardItemId AS _extract_worklistShardItemId#786931]"]; 34 [id="node34" labelType="html" label="<b>Filter</b><br><br>number of output rows: 59" tooltip="Filter (((size(items#781928.worklistShardItemId, true) > 0) AND isnotnull(items#781928.worklistShardItemId)) AND (shardId#781926 = 0_1_10000002108))"]; } 35 [id="node35" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 59" tooltip="InMemoryTableScan [items#781928, shardId#781926], [(size(items#781928.worklistShardItemId, true) > 0), isnotnull(items#781928.worklistShardItemId), (shardId#781926 = 0_1_10000002108)]"]; subgraph cluster36 { isCluster="true"; id="cluster36"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 37 [id="node37" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#777607) AND (shardId#777607 = 0_1_10000002108))"]; } 38 [id="node38" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#777607, orderProposalId#777608L, items#777609, optimizationGroups#777610, isOptimal#777611, optimizationInsights#777613], [isnotnull(shardId#777607), (shardId#777607 = 0_1_10000002108)]"]; subgraph cluster39 { isCluster="true"; id="cluster39"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 40 [id="node40" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#777607) AND (shardId#777607 = 0_1_10000002108))"]; 41 [id="node41" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#777607,orderProposalId#777608L,items#777609,optimizationGroups#777610,isOptimal#777611,lastModified#777612,optimizationInsights#777613]"]; } 43 [id="node43" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 980<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 980<br>local bytes read total (min, med, max (stageId: taskId))<br>21.4 KiB (722.0 B, 1162.0 B, 1335.0 B (stage 65028.0: task 162443))<br>merged fetch fallback count: 0<br>local blocks read: 209<br>remote merged chunks fetched: 0<br>remote blocks read: 216<br>data size total (min, med, max (stageId: taskId))<br>23.0 KiB (648.0 B, 960.0 B, 1152.0 B (stage 65027.0: task 162418))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>22 ms (0 ms, 0 ms, 1 ms (stage 65027.0: task 162418))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 65028.0: task 162449))<br>remote bytes read total (min, med, max (stageId: taskId))<br>22.5 KiB (702.0 B, 1160.0 B, 1468.0 B (stage 65028.0: task 162444))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>23 ms (0 ms, 1 ms, 2 ms (stage 65028.0: task 162448))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>43.8 KiB (1442.0 B, 1817.0 B, 2.1 KiB (stage 65027.0: task 162415))" tooltip="Exchange hashpartitioning(worklistShardItemId#778343L, 20), REPARTITION_BY_NUM, [plan_id=310097]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n2.9 s (97 ms, 111 ms, 196 ms (stage 65027.0: task 162436))"; tooltip="WholeStageCodegen (3)"; 45 [id="node45" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#778320L, worklistShardItemId#778343L]"]; 46 [id="node46" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter ((isnotnull(worklistShardItemId#778343L) AND NOT (isFallbackOrderOnly#778337 <=> true)) AND isnotnull(orderProposalId#778320L))"]; 47 [id="node47" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 980<br>number of input batches: 25" tooltip="ColumnarToRow"]; } 48 [id="node48" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 25<br>scan time total (min, med, max (stageId: taskId))<br>2.8 s (95 ms, 108 ms, 194 ms (stage 65027.0: task 162436))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 674.0 KiB<br>number of output rows: 980<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#778320L,isFallbackOrderOnly#778337,worklistShardItemId#778343L,shardId#778364,sequenceId#778342] Batched: true, DataFilters: [isnotnull(worklistShardItemId#778343L), NOT (isFallbackOrderOnly#778337 <=> true), isnotnull(ord..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#778364), isnotnull(sequenceId#778342), (shardId#778364 = 0_1_10000002108), (se..., PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderPro..., ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>"]; 49 [id="node49" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 469 ms<br>number of output rows: 980<br>data size: 1047.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=310123]"]; subgraph cluster50 { isCluster="true"; id="cluster50"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n47 ms (2 ms, 2 ms, 3 ms (stage 65026.0: task 162395))"; tooltip="WholeStageCodegen (7)"; 51 [id="node51" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#782384L, orderProposalItemId#782362, supplier#782364, externalProductId#782386, externalPlantId#782387]"]; } 52 [id="node52" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 980<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 980<br>local bytes read total (min, med, max (stageId: taskId))<br>49.4 KiB (1571.0 B, 2.4 KiB, 3.1 KiB (stage 65026.0: task 162414))<br>merged fetch fallback count: 0<br>local blocks read: 211<br>remote merged chunks fetched: 0<br>remote blocks read: 214<br>data size total (min, med, max (stageId: taskId))<br>114.8 KiB (3.2 KiB, 4.7 KiB, 5.6 KiB (stage 65025.0: task 162362))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>22 ms (0 ms, 0 ms, 1 ms (stage 65025.0: task 162356))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 65026.0: task 162403))<br>remote bytes read total (min, med, max (stageId: taskId))<br>51.6 KiB (1920.0 B, 2.6 KiB, 3.3 KiB (stage 65026.0: task 162407))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>23 ms (1 ms, 1 ms, 2 ms (stage 65026.0: task 162400))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>101.0 KiB (3.1 KiB, 4.1 KiB, 4.9 KiB (stage 65025.0: task 162356))" tooltip="Exchange hashpartitioning(worklistShardItemId#782384L, 20), REPARTITION_BY_NUM, [plan_id=310119]"]; subgraph cluster53 { isCluster="true"; id="cluster53"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n2.9 s (75 ms, 122 ms, 169 ms (stage 65025.0: task 162358))"; tooltip="WholeStageCodegen (6)"; 54 [id="node54" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalItemId#782362, supplier#782364, worklistShardItemId#782384L, externalProductId#782386, externalPlantId#782387]"]; 55 [id="node55" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter isnotnull(worklistShardItemId#782384L)"]; 56 [id="node56" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 980<br>number of input batches: 25" tooltip="ColumnarToRow"]; } 57 [id="node57" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 25<br>scan time total (min, med, max (stageId: taskId))<br>2.6 s (73 ms, 103 ms, 138 ms (stage 65025.0: task 162358))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 674.0 KiB<br>number of output rows: 980<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalItemId#782362,supplier#782364,worklistShardItemId#782384L,externalProductId#782386,externalPlantId#782387,shardId#782405,sequenceId#782383] Batched: true, DataFilters: [isnotnull(worklistShardItemId#782384L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#782405), isnotnull(sequenceId#782383), (shardId#782405 = 0_1_10000002108), (se..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalItemId:string,supplier:string,worklistShardItemId:bigint,externalProductId:st..."]; 1->0; 3->1; 4->3; 6->4; 7->6; 8->7; 10->8; 11->10; 12->11; 13->12; 15->13; 16->15; 18->16; 19->18; 21->19; 22->21; 23->12; 24->23; 26->24; 27->26; 28->27; 29->28; 31->29; 32->31; 33->32; 34->33; 35->34; 37->35; 38->37; 40->38; 41->40; 42->28; 43->42; 45->43; 46->45; 47->46; 48->47; 49->6; 51->49; 52->51; 54->52; 55->54; 56->55; 57->56; }