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: 124.0 B<br>merged fetch fallback count: 0<br>local blocks read: 2<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 67300.0: task 167838))<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 67300.0: task 167838))" 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))\n154 ms (0 ms, 8 ms, 24 ms (stage 67300.0: task 167837))"; tooltip="WholeStageCodegen (9)"; 3 [id="node3" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [CASE WHEN (insightTypeInfo#810943.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#803009L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#807586)) END END END END END END END END END END END END END END END AS anchorObject#811079, CASE WHEN (insightTypeInfo#810943.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#810943.supplierSubrange), struct(variableName, InitialValue, variableValue, cast(reachedValue#807162 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#807163)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#810943.supplierGroup), struct(variableName, InitialValue, variableValue, cast(reachedValue#807162 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#807163)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, InitialValue, variableValue, cast(reachedValue#807162 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#807163)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#810943.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#810943.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#810943.supplierSubrange), struct(variableName, ProductID, variableValue, externalProductId#807610), struct(variableName, LocationID, variableValue, externalPlantId#807611)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#810943.supplierGroup), struct(variableName, ProductID, variableValue, externalProductId#807610), struct(variableName, LocationID, variableValue, externalPlantId#807611)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, ProductID, variableValue, externalProductId#807610), struct(variableName, LocationID, variableValue, externalPlantId#807611)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#810943.supplierSubrange), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#807163), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#807162 as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#810943.supplierGroup), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#807163), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#807162 as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#807163), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#807162 as string))) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#810943.supplierSubrange), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#807163)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#810943.supplierGroup), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#807163)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#810943.supplier), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#807161 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#807163)) END END END END END END END END END END END END END END END AS messageVariables#811174, CASE WHEN (insightTypeInfo#810943.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#810943.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#810943.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#810943.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#810943.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#810943.supplierSubrange), struct(objectType, Product, objectId, externalProductId#807610), struct(objectType, Location, objectId, externalPlantId#807611)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#810943.supplierGroup), struct(objectType, Product, objectId, externalProductId#807610), struct(objectType, Location, objectId, externalPlantId#807611)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier), struct(objectType, Product, objectId, externalProductId#807610), struct(objectType, Location, objectId, externalPlantId#807611)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#810943.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#810943.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#810943.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, SupplierGroup, objectId, insightTypeInfo#810943.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#810943.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002108], struct(objectType, Supplier, objectId, insightTypeInfo#810943.supplier)) END END END END END END END END END END END END END END END AS triggerObject#811030, Daily_grocery AS marketUnit#811177, NEW AS situationStatus#811176, insightTypeInfo#810943.insightType AS situationType#811178]"]; } 4 [id="node4" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#803009L, thresholdValue#807161, reachedValue#807162, unitOfMeasure#807163, externalProductId#807610, externalPlantId#807611, orderProposalItemId#807586, struct(insightType, CASE WHEN (internalInsightType#807159 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#807159 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#807159 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#807159 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#807159 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#807159 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#807588 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#807164, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#810943]"]; subgraph cluster5 { isCluster="true"; id="cluster5"; label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n1.4 s (5 ms, 96 ms, 202 ms (stage 67300.0: task 167838))"; tooltip="WholeStageCodegen (8)"; 6 [id="node6" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 23" tooltip="BroadcastHashJoin [worklistShardItemId#807160L], [worklistShardItemId#807608L], LeftOuter, BuildRight, (shardId#803008 = 0_1_10000002108), false"]; 7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#803008, orderProposalId#803009L, insight#807158.internalInsightType AS internalInsightType#807159, insight#807158.worklistShardItemId AS worklistShardItemId#807160L, insight#807158.thresholdValue AS thresholdValue#807161, insight#807158.reachedValue AS reachedValue#807162, insight#807158.unitOfMeasure AS unitOfMeasure#807163, insight#807158.assignmentDetails AS assignmentDetails#807164]"]; } 8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 23" tooltip="Filter (insight#807158.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#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_SG_MIN_NOT_MET) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_SUP_MIN_NOT_MET) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.internalInsightType END <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (CASE WHEN (insight#807158.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#807158.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#807158.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#807158.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#807158.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#807158.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#807158.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.2 s (14 ms, 151 ms, 313 ms (stage 67300.0: task 167838))"; tooltip="WholeStageCodegen (5)"; 10 [id="node10" labelType="html" label="<b>Generate</b><br><br>number of output rows: 113" tooltip="Generate explode(optimizationInsights#803014), [orderProposalId#803009L, shardId#803008], false, [insight#807158]"]; 11 [id="node11" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#803009L, shardId#803008, optimizationInsights#803014]"]; 12 [id="node12" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 11" tooltip="BroadcastHashJoin [orderProposalId#803009L], [orderProposalId#803721L], 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>34 ms (0 ms, 2 ms, 3 ms (stage 67300.0: task 167843))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 67300.0: task 167841))<br>number of output rows: 59<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#803721L], 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: 48 ms<br>number of output rows: 11<br>data size: 1024.5 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=317281]"]; 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 67295.0: task 167718))"; tooltip="WholeStageCodegen (1)"; 15 [id="node15" labelType="html" label="<b>Filter</b><br><br>number of output rows: 11" tooltip="Filter ((isnotnull(orderProposalId#803009L) AND (size(optimizationInsights#803014, true) > 0)) AND isnotnull(optimizationInsights#803014))"]; } 16 [id="node16" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 59" tooltip="InMemoryTableScan [shardId#803008, orderProposalId#803009L, optimizationInsights#803014], [isnotnull(orderProposalId#803009L), (size(optimizationInsights#803014, true) > 0), isnotnull(optimizationInsights#803014)]"]; 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#803008) AND (shardId#803008 = 0_1_10000002108))"]; } 19 [id="node19" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#803008, orderProposalId#803009L, items#803010, optimizationGroups#803011, isOptimal#803012, optimizationInsights#803014], [isnotnull(shardId#803008), (shardId#803008 = 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#803008) AND (shardId#803008 = 0_1_10000002108))"]; 22 [id="node22" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#803008,orderProposalId#803009L,items#803010,optimizationGroups#803011,isOptimal#803012,lastModified#803013,optimizationInsights#803014]"]; } 24 [id="node24" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 523<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 523<br>local bytes read total (min, med, max (stageId: taskId))<br>12.4 KiB (225.0 B, 644.0 B, 926.0 B (stage 67300.0: task 167842))<br>merged fetch fallback count: 0<br>local blocks read: 152<br>remote merged chunks fetched: 0<br>remote blocks read: 154<br>data size total (min, med, max (stageId: taskId))<br>8.2 KiB (304.0 B, 416.0 B, 528.0 B (stage 67299.0: task 167825))<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 67299.0: task 167817))<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 67300.0: task 167841))<br>remote bytes read total (min, med, max (stageId: taskId))<br>12.4 KiB (225.0 B, 686.0 B, 937.0 B (stage 67300.0: task 167847))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>10 ms (0 ms, 1 ms, 1 ms (stage 67300.0: task 167840))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>24.7 KiB (1041.0 B, 1257.0 B, 1515.0 B (stage 67299.0: task 167825))" tooltip="Exchange hashpartitioning(orderProposalId#803721L, 20), ENSURE_REQUIREMENTS, [plan_id=317303]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n130 ms (4 ms, 7 ms, 9 ms (stage 67299.0: task 167821))"; 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>39 ms (1 ms, 2 ms, 3 ms (stage 67299.0: task 167820))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 67299.0: task 167818))<br>number of output rows: 523<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#803721L], functions=[])"]; 27 [id="node27" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#803721L]"]; 28 [id="node28" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 980" tooltip="BroadcastHashJoin [worklistShardItemId#803520L], [worklistShardItemId#803744L], Inner, BuildLeft, false"]; 42 [id="node42" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#803744L, orderProposalId#803721L]"]; } 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: 37 ms<br>number of output rows: 980<br>data size: 1047.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=317289]"]; 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 67294.0: task 167704))"; tooltip="WholeStageCodegen (2)"; 31 [id="node31" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#803519L AS worklistShardItemId#803520L]"]; 32 [id="node32" labelType="html" label="<b>Generate</b><br><br>number of output rows: 980" tooltip="Generate explode(_extract_worklistShardItemId#812155), false, [item#803519L]"]; 33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#807152.worklistShardItemId AS _extract_worklistShardItemId#812155]"]; 34 [id="node34" labelType="html" label="<b>Filter</b><br><br>number of output rows: 59" tooltip="Filter (((size(items#807152.worklistShardItemId, true) > 0) AND isnotnull(items#807152.worklistShardItemId)) AND (shardId#807150 = 0_1_10000002108))"]; } 35 [id="node35" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 59" tooltip="InMemoryTableScan [items#807152, shardId#807150], [(size(items#807152.worklistShardItemId, true) > 0), isnotnull(items#807152.worklistShardItemId), (shardId#807150 = 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#803008) AND (shardId#803008 = 0_1_10000002108))"]; } 38 [id="node38" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#803008, orderProposalId#803009L, items#803010, optimizationGroups#803011, isOptimal#803012, optimizationInsights#803014], [isnotnull(shardId#803008), (shardId#803008 = 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#803008) AND (shardId#803008 = 0_1_10000002108))"]; 41 [id="node41" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#803008,orderProposalId#803009L,items#803010,optimizationGroups#803011,isOptimal#803012,lastModified#803013,optimizationInsights#803014]"]; } 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>22.6 KiB (766.0 B, 1265.0 B, 1447.0 B (stage 67299.0: task 167825))<br>merged fetch fallback count: 0<br>local blocks read: 224<br>remote merged chunks fetched: 0<br>remote blocks read: 214<br>data size total (min, med, max (stageId: taskId))<br>23.0 KiB (648.0 B, 960.0 B, 1152.0 B (stage 67298.0: task 167792))<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 67298.0: task 167803))<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 67299.0: task 167818))<br>remote bytes read total (min, med, max (stageId: taskId))<br>22.0 KiB (800.0 B, 1105.0 B, 1541.0 B (stage 67299.0: task 167822))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>22 ms (0 ms, 1 ms, 2 ms (stage 67299.0: task 167828))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>44.6 KiB (1367.0 B, 1819.0 B, 2.1 KiB (stage 67298.0: task 167791))" tooltip="Exchange hashpartitioning(worklistShardItemId#803744L, 20), REPARTITION_BY_NUM, [plan_id=317296]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n4.6 s (132 ms, 185 ms, 222 ms (stage 67298.0: task 167804))"; tooltip="WholeStageCodegen (3)"; 45 [id="node45" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#803721L, worklistShardItemId#803744L]"]; 46 [id="node46" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter ((isnotnull(worklistShardItemId#803744L) AND NOT (isFallbackOrderOnly#803738 <=> true)) AND isnotnull(orderProposalId#803721L))"]; 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>4.5 s (130 ms, 183 ms, 220 ms (stage 67298.0: task 167804))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 674.1 KiB<br>number of output rows: 980<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#803721L,isFallbackOrderOnly#803738,worklistShardItemId#803744L,shardId#803765,sequenceId#803743] Batched: true, DataFilters: [isnotnull(worklistShardItemId#803744L), NOT (isFallbackOrderOnly#803738 <=> true), isnotnull(ord..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#803765), isnotnull(sequenceId#803743), (shardId#803765 = 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: 1 ms<br>time to collect: 612 ms<br>number of output rows: 980<br>data size: 1047.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=317322]"]; subgraph cluster50 { isCluster="true"; id="cluster50"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n46 ms (1 ms, 2 ms, 3 ms (stage 67297.0: task 167773))"; tooltip="WholeStageCodegen (7)"; 51 [id="node51" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#807608L, orderProposalItemId#807586, supplier#807588, externalProductId#807610, externalPlantId#807611]"]; } 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>51.9 KiB (1969.0 B, 2.7 KiB, 3.2 KiB (stage 67297.0: task 167780))<br>merged fetch fallback count: 0<br>local blocks read: 219<br>remote merged chunks fetched: 0<br>remote blocks read: 219<br>data size total (min, med, max (stageId: taskId))<br>114.8 KiB (3.2 KiB, 4.7 KiB, 5.6 KiB (stage 67296.0: task 167738))<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 67296.0: task 167763))<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>1 ms (0 ms, 0 ms, 1 ms (stage 67297.0: task 167782))<br>remote bytes read total (min, med, max (stageId: taskId))<br>50.1 KiB (2.0 KiB, 2.6 KiB, 3.0 KiB (stage 67297.0: task 167784))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>29 ms (1 ms, 1 ms, 3 ms (stage 67297.0: task 167782))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>102.0 KiB (3.0 KiB, 4.0 KiB, 4.8 KiB (stage 67296.0: task 167727))" tooltip="Exchange hashpartitioning(worklistShardItemId#807608L, 20), REPARTITION_BY_NUM, [plan_id=317318]"]; subgraph cluster53 { isCluster="true"; id="cluster53"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n4.2 s (117 ms, 157 ms, 241 ms (stage 67296.0: task 167727))"; tooltip="WholeStageCodegen (6)"; 54 [id="node54" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalItemId#807586, supplier#807588, worklistShardItemId#807608L, externalProductId#807610, externalPlantId#807611]"]; 55 [id="node55" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter isnotnull(worklistShardItemId#807608L)"]; 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>3.8 s (115 ms, 152 ms, 204 ms (stage 67296.0: task 167727))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 674.1 KiB<br>number of output rows: 980<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalItemId#807586,supplier#807588,worklistShardItemId#807608L,externalProductId#807610,externalPlantId#807611,shardId#807629,sequenceId#807607] Batched: true, DataFilters: [isnotnull(worklistShardItemId#807608L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#807629), isnotnull(sequenceId#807607), (shardId#807629 = 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; }