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: 186.0 B<br>merged fetch fallback count: 0<br>local blocks read: 3<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 44286.0: task 125453))<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 44286.0: task 125452))" 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))\n142 ms (0 ms, 8 ms, 26 ms (stage 44286.0: task 125453))"; tooltip="WholeStageCodegen (9)"; 3 [id="node3" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [CASE WHEN (insightTypeInfo#598341.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#584005L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#591240)) END END END END END END END END END END END END END END END AS anchorObject#598477, CASE WHEN (insightTypeInfo#598341.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#598341.supplierSubrange), struct(variableName, InitialValue, variableValue, cast(reachedValue#590786 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#590787)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#598341.supplierGroup), struct(variableName, InitialValue, variableValue, cast(reachedValue#590786 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#590787)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, InitialValue, variableValue, cast(reachedValue#590786 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#590787)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#598341.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#598341.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#598341.supplierSubrange), struct(variableName, ProductID, variableValue, externalProductId#591264), struct(variableName, LocationID, variableValue, externalPlantId#591265)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#598341.supplierGroup), struct(variableName, ProductID, variableValue, externalProductId#591264), struct(variableName, LocationID, variableValue, externalPlantId#591265)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, ProductID, variableValue, externalProductId#591264), struct(variableName, LocationID, variableValue, externalPlantId#591265)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#598341.supplierSubrange), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#590787), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#590786 as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#598341.supplierGroup), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#590787), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#590786 as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#590787), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#590786 as string))) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#598341.supplierSubrange), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#590787)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#598341.supplierGroup), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#590787)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#598341.supplier), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#590785 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#590787)) END END END END END END END END END END END END END END END AS messageVariables#598572, CASE WHEN (insightTypeInfo#598341.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#598341.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#598341.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#598341.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#598341.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#598341.supplierSubrange), struct(objectType, Product, objectId, externalProductId#591264), struct(objectType, Location, objectId, externalPlantId#591265)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#598341.supplierGroup), struct(objectType, Product, objectId, externalProductId#591264), struct(objectType, Location, objectId, externalPlantId#591265)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier), struct(objectType, Product, objectId, externalProductId#591264), struct(objectType, Location, objectId, externalPlantId#591265)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#598341.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#598341.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#598341.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#598341.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#598341.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#598341.supplier)) END END END END END END END END END END END END END END END AS triggerObject#598428, Daily_grocery AS marketUnit#598575, NEW AS situationStatus#598574, insightTypeInfo#598341.insightType AS situationType#598576]"]; } 4 [id="node4" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#584005L, thresholdValue#590785, reachedValue#590786, unitOfMeasure#590787, externalProductId#591264, externalPlantId#591265, orderProposalItemId#591240, struct(insightType, CASE WHEN (internalInsightType#590783 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_SG_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_SUP_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_SUBR_MIN_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#590783 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#590783 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#590783 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#590783 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 1) THEN OP_CALC_ITEM_SG_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 2) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN OP_CALC_ITEM_SUBR_OPT_MISSING_MD WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#590783 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#591242 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#590788, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#598341]"]; subgraph cluster5 { isCluster="true"; id="cluster5"; label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n1.2 s (4 ms, 91 ms, 200 ms (stage 44286.0: task 125453))"; tooltip="WholeStageCodegen (8)"; 6 [id="node6" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 23" tooltip="BroadcastHashJoin [worklistShardItemId#590784L], [worklistShardItemId#591262L], LeftOuter, BuildRight, (shardId#584004 = 0_1_10000002106), false"]; 7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#584004, orderProposalId#584005L, insight#590782.internalInsightType AS internalInsightType#590783, insight#590782.worklistShardItemId AS worklistShardItemId#590784L, insight#590782.thresholdValue AS thresholdValue#590785, insight#590782.reachedValue AS reachedValue#590786, insight#590782.unitOfMeasure AS unitOfMeasure#590787, insight#590782.assignmentDetails AS assignmentDetails#590788]"]; } 8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 23" tooltip="Filter (insight#590782.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#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_SG_MIN_NOT_MET) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_SUP_MIN_NOT_MET) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.internalInsightType END <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (CASE WHEN (insight#590782.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#590782.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#590782.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#590782.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#590782.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#590782.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#590782.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.0 s (13 ms, 145 ms, 308 ms (stage 44286.0: task 125453))"; tooltip="WholeStageCodegen (5)"; 10 [id="node10" labelType="html" label="<b>Generate</b><br><br>number of output rows: 113" tooltip="Generate explode(optimizationInsights#584010), [orderProposalId#584005L, shardId#584004], false, [insight#590782]"]; 11 [id="node11" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#584005L, shardId#584004, optimizationInsights#584010]"]; 12 [id="node12" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 11" tooltip="BroadcastHashJoin [orderProposalId#584005L], [orderProposalId#584717L], 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>26 ms (0 ms, 1 ms, 2 ms (stage 44286.0: task 125450))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 44286.0: task 125450))<br>number of output rows: 59<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#584717L], 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: 154 ms<br>number of output rows: 11<br>data size: 1024.5 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=251856]"]; 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 44280.0: task 125314))"; tooltip="WholeStageCodegen (1)"; 15 [id="node15" labelType="html" label="<b>Filter</b><br><br>number of output rows: 11" tooltip="Filter ((isnotnull(orderProposalId#584005L) AND (size(optimizationInsights#584010, true) > 0)) AND isnotnull(optimizationInsights#584010))"]; } 16 [id="node16" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 59" tooltip="InMemoryTableScan [shardId#584004, orderProposalId#584005L, optimizationInsights#584010], [isnotnull(orderProposalId#584005L), (size(optimizationInsights#584010, true) > 0), isnotnull(optimizationInsights#584010)]"]; 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#584004) AND (shardId#584004 = 0_1_10000002106))"]; } 19 [id="node19" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#584004, orderProposalId#584005L, items#584006, optimizationGroups#584007, isOptimal#584008, optimizationInsights#584010], [isnotnull(shardId#584004), (shardId#584004 = 0_1_10000002106)]"]; 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#584004) AND (shardId#584004 = 0_1_10000002106))"]; 22 [id="node22" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#584004,orderProposalId#584005L,items#584006,optimizationGroups#584007,isOptimal#584008,lastModified#584009,optimizationInsights#584010]"]; } 24 [id="node24" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 532<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 532<br>local bytes read total (min, med, max (stageId: taskId))<br>12.4 KiB (150.0 B, 741.0 B, 970.0 B (stage 44286.0: task 125451))<br>merged fetch fallback count: 0<br>local blocks read: 154<br>remote merged chunks fetched: 0<br>remote blocks read: 152<br>data size total (min, med, max (stageId: taskId))<br>8.3 KiB (320.0 B, 432.0 B, 512.0 B (stage 44285.0: task 125439))<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 44285.0: task 125428))<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 44286.0: task 125450))<br>remote bytes read total (min, med, max (stageId: taskId))<br>12.4 KiB (150.0 B, 741.0 B, 981.0 B (stage 44286.0: task 125451))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>8 ms (0 ms, 0 ms, 1 ms (stage 44286.0: task 125452))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>24.8 KiB (988.0 B, 1279.0 B, 1568.0 B (stage 44285.0: task 125439))" tooltip="Exchange hashpartitioning(orderProposalId#584717L, 20), ENSURE_REQUIREMENTS, [plan_id=251878]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n119 ms (3 ms, 6 ms, 9 ms (stage 44285.0: task 125430))"; 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>36 ms (1 ms, 2 ms, 3 ms (stage 44285.0: task 125432))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 44285.0: task 125429))<br>number of output rows: 532<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#584717L], functions=[])"]; 27 [id="node27" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#584717L]"]; 28 [id="node28" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 980" tooltip="BroadcastHashJoin [worklistShardItemId#584516L], [worklistShardItemId#584740L], Inner, BuildLeft, false"]; 42 [id="node42" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#584740L, orderProposalId#584717L]"]; } 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: 156 ms<br>number of output rows: 980<br>data size: 1056.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=251864]"]; 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 44281.0: task 125315))"; tooltip="WholeStageCodegen (2)"; 31 [id="node31" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#584515L AS worklistShardItemId#584516L]"]; 32 [id="node32" labelType="html" label="<b>Generate</b><br><br>number of output rows: 980" tooltip="Generate explode(_extract_worklistShardItemId#599553), false, [item#584515L]"]; 33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#590776.worklistShardItemId AS _extract_worklistShardItemId#599553]"]; 34 [id="node34" labelType="html" label="<b>Filter</b><br><br>number of output rows: 59" tooltip="Filter (((size(items#590776.worklistShardItemId, true) > 0) AND isnotnull(items#590776.worklistShardItemId)) AND (shardId#590774 = 0_1_10000002106))"]; } 35 [id="node35" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 59" tooltip="InMemoryTableScan [items#590776, shardId#590774], [(size(items#590776.worklistShardItemId, true) > 0), isnotnull(items#590776.worklistShardItemId), (shardId#590774 = 0_1_10000002106)]"]; 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#584004) AND (shardId#584004 = 0_1_10000002106))"]; } 38 [id="node38" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#584004, orderProposalId#584005L, items#584006, optimizationGroups#584007, isOptimal#584008, optimizationInsights#584010], [isnotnull(shardId#584004), (shardId#584004 = 0_1_10000002106)]"]; 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#584004) AND (shardId#584004 = 0_1_10000002106))"]; 41 [id="node41" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#584004,orderProposalId#584005L,items#584006,optimizationGroups#584007,isOptimal#584008,lastModified#584009,optimizationInsights#584010]"]; } 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.0 KiB (502.0 B, 1145.0 B, 1463.0 B (stage 44285.0: task 125433))<br>merged fetch fallback count: 0<br>local blocks read: 215<br>remote merged chunks fetched: 0<br>remote blocks read: 206<br>data size total (min, med, max (stageId: taskId))<br>23.0 KiB (648.0 B, 960.0 B, 1152.0 B (stage 44284.0: task 125401))<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, 0 ms, 1 ms (stage 44284.0: task 125402))<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 44285.0: task 125429))<br>remote bytes read total (min, med, max (stageId: taskId))<br>21.7 KiB (403.0 B, 1108.0 B, 1609.0 B (stage 44285.0: task 125428))<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 44285.0: task 125424))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>43.7 KiB (1388.0 B, 1815.0 B, 2021.0 B (stage 44284.0: task 125400))" tooltip="Exchange hashpartitioning(worklistShardItemId#584740L, 20), REPARTITION_BY_NUM, [plan_id=251871]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n2.6 s (86 ms, 101 ms, 137 ms (stage 44284.0: task 125400))"; tooltip="WholeStageCodegen (3)"; 45 [id="node45" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#584717L, worklistShardItemId#584740L]"]; 46 [id="node46" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter ((isnotnull(worklistShardItemId#584740L) AND NOT (isFallbackOrderOnly#584734 <=> true)) AND isnotnull(orderProposalId#584717L))"]; 47 [id="node47" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 980<br>number of input batches: 25" tooltip="ColumnarToRow"]; } 48 [id="node48" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 25<br>scan time total (min, med, max (stageId: taskId))<br>2.5 s (83 ms, 99 ms, 135 ms (stage 44284.0: task 125400))<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#584717L,isFallbackOrderOnly#584734,worklistShardItemId#584740L,shardId#584761,sequenceId#584739] Batched: true, DataFilters: [isnotnull(worklistShardItemId#584740L), NOT (isFallbackOrderOnly#584734 <=> true), isnotnull(ord..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#584761), isnotnull(sequenceId#584739), (shardId#584761 = 0_1_10000002106), (se..., PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderPro..., ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>"]; 49 [id="node49" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 510 ms<br>number of output rows: 980<br>data size: 1056.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=251897]"]; subgraph cluster50 { isCluster="true"; id="cluster50"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n47 ms (2 ms, 2 ms, 3 ms (stage 44283.0: task 125381))"; tooltip="WholeStageCodegen (7)"; 51 [id="node51" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#591262L, orderProposalItemId#591240, supplier#591242, externalProductId#591264, externalPlantId#591265]"]; } 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>48.3 KiB (952.0 B, 2.5 KiB, 3.5 KiB (stage 44283.0: task 125381))<br>merged fetch fallback count: 0<br>local blocks read: 206<br>remote merged chunks fetched: 0<br>remote blocks read: 215<br>data size total (min, med, max (stageId: taskId))<br>114.8 KiB (3.2 KiB, 4.7 KiB, 5.6 KiB (stage 44282.0: task 125356))<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, 0 ms, 1 ms (stage 44282.0: task 125362))<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 44283.0: task 125379))<br>remote bytes read total (min, med, max (stageId: taskId))<br>51.0 KiB (1584.0 B, 2.6 KiB, 3.9 KiB (stage 44283.0: task 125388))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>21 ms (0 ms, 1 ms, 2 ms (stage 44283.0: task 125382))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>99.3 KiB (3.0 KiB, 4.1 KiB, 4.5 KiB (stage 44282.0: task 125328))" tooltip="Exchange hashpartitioning(worklistShardItemId#591262L, 20), REPARTITION_BY_NUM, [plan_id=251893]"]; subgraph cluster53 { isCluster="true"; id="cluster53"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n2.5 s (80 ms, 94 ms, 134 ms (stage 44282.0: task 125328))"; tooltip="WholeStageCodegen (6)"; 54 [id="node54" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalItemId#591240, supplier#591242, worklistShardItemId#591262L, externalProductId#591264, externalPlantId#591265]"]; 55 [id="node55" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter isnotnull(worklistShardItemId#591262L)"]; 56 [id="node56" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 980<br>number of input batches: 25" tooltip="ColumnarToRow"]; } 57 [id="node57" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 25<br>scan time total (min, med, max (stageId: taskId))<br>2.3 s (78 ms, 91 ms, 120 ms (stage 44282.0: task 125353))<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#591240,supplier#591242,worklistShardItemId#591262L,externalProductId#591264,externalPlantId#591265,shardId#591283,sequenceId#591261] Batched: true, DataFilters: [isnotnull(worklistShardItemId#591262L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#591283), isnotnull(sequenceId#591261), (shardId#591283 = 0_1_10000002106), (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; }