digraph G { 0 [id="node0" labelType="html" label="<b>CollectLimit</b><br><br>shuffle records written: 2<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1<br>local bytes read: 62.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>local merged bytes read: 0.0 B<br>remote reqs duration: 0 ms<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 40844.0: task 117895))<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>124.0 B (62.0 B, 62.0 B, 62.0 B (stage 40844.0: task 117893))" tooltip="CollectLimit 1"]; 1 [id="node1" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 21" tooltip="InMemoryTableScan"]; subgraph cluster2 { isCluster="true"; id="cluster2"; label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n55 ms (0 ms, 3 ms, 16 ms (stage 40844.0: task 117893))"; tooltip="WholeStageCodegen (11)"; 3 [id="node3" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [CASE WHEN (insightTypeInfo#570272.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#555918L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#569294)) END END END END END END END END END END END END END END END AS anchorObject#570408, CASE WHEN (insightTypeInfo#570272.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#570272.supplierSubrange), struct(variableName, InitialValue, variableValue, cast(reachedValue#569170 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#569171)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#570272.supplierGroup), struct(variableName, InitialValue, variableValue, cast(reachedValue#569170 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#569171)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, InitialValue, variableValue, cast(reachedValue#569170 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#569171)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#570272.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#570272.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#570272.supplierSubrange), struct(variableName, ProductID, variableValue, externalProductId#569318), struct(variableName, LocationID, variableValue, externalPlantId#569319)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#570272.supplierGroup), struct(variableName, ProductID, variableValue, externalProductId#569318), struct(variableName, LocationID, variableValue, externalPlantId#569319)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, ProductID, variableValue, externalProductId#569318), struct(variableName, LocationID, variableValue, externalPlantId#569319)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#570272.supplierSubrange), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#569171), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#569170 as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#570272.supplierGroup), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#569171), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#569170 as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#569171), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#569170 as string))) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#570272.supplierSubrange), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#569171)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#570272.supplierGroup), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#569171)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#570272.supplier), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#569169 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#569171)) END END END END END END END END END END END END END END END AS messageVariables#570503, CASE WHEN (insightTypeInfo#570272.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#570272.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002107], struct(objectType, SupplierGroup, objectId, insightTypeInfo#570272.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#570272.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, SupplierGroup, objectId, insightTypeInfo#570272.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#570272.supplierSubrange), struct(objectType, Product, objectId, externalProductId#569318), struct(objectType, Location, objectId, externalPlantId#569319)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002107], struct(objectType, SupplierGroup, objectId, insightTypeInfo#570272.supplierGroup), struct(objectType, Product, objectId, externalProductId#569318), struct(objectType, Location, objectId, externalPlantId#569319)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier), struct(objectType, Product, objectId, externalProductId#569318), struct(objectType, Location, objectId, externalPlantId#569319)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#570272.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, SupplierGroup, objectId, insightTypeInfo#570272.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#570272.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, SupplierGroup, objectId, insightTypeInfo#570272.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#570272.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002107], struct(objectType, Supplier, objectId, insightTypeInfo#570272.supplier)) END END END END END END END END END END END END END END END AS triggerObject#570359, Daily_grocery AS marketUnit#570506, NEW AS situationStatus#570505, insightTypeInfo#570272.insightType AS situationType#570507]"]; } 4 [id="node4" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#555918L, thresholdValue#569169, reachedValue#569170, unitOfMeasure#569171, externalProductId#569318, externalPlantId#569319, orderProposalItemId#569294, struct(insightType, CASE WHEN (internalInsightType#569167 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#569167 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#569167 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#569167 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#569167 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, 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#569172, 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#569172, 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#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#569167 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#569296 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#569172, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#570272]"]; subgraph cluster5 { isCluster="true"; id="cluster5"; label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n1.1 s (3 ms, 84 ms, 184 ms (stage 40844.0: task 117895))"; tooltip="WholeStageCodegen (10)"; 6 [id="node6" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 21" tooltip="BroadcastHashJoin [worklistShardItemId#569168L], [worklistShardItemId#569316L], LeftOuter, BuildRight, (shardId#555917 = 0_1_10000002107), false"]; 7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#555917, orderProposalId#555918L, insight#569166.internalInsightType AS internalInsightType#569167, insight#569166.worklistShardItemId AS worklistShardItemId#569168L, insight#569166.thresholdValue AS thresholdValue#569169, insight#569166.reachedValue AS reachedValue#569170, insight#569166.unitOfMeasure AS unitOfMeasure#569171, insight#569166.assignmentDetails AS assignmentDetails#569172]"]; } 8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 21" tooltip="Filter (insight#569166.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#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_SG_MIN_NOT_MET) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_SUP_MIN_NOT_MET) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (CASE WHEN (insight#569166.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#569166.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#569166.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#569166.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#569166.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#569166.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#569166.internalInsightType END <=> OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET))))))))))))))))"]; subgraph cluster9 { isCluster="true"; id="cluster9"; label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n1.8 s (10 ms, 134 ms, 288 ms (stage 40844.0: task 117895))"; tooltip="WholeStageCodegen (7)"; 10 [id="node10" labelType="html" label="<b>Generate</b><br><br>number of output rows: 38" tooltip="Generate explode(optimizationInsights#555923), [orderProposalId#555918L, shardId#555917], false, [insight#569166]"]; 11 [id="node11" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#555918L, shardId#555917, optimizationInsights#555923]"]; 12 [id="node12" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 6<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 40844.0: task 117889))" tooltip="SortMergeJoin [orderProposalId#555918L], [orderProposalId#556817L], Inner"]; } subgraph cluster13 { isCluster="true"; id="cluster13"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n1.9 s (10 ms, 165 ms, 180 ms (stage 40844.0: task 117895))"; tooltip="WholeStageCodegen (2)"; 14 [id="node14" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 40844.0: task 117889))<br>peak memory total (min, med, max (stageId: taskId))<br>7.3 MiB (64.0 KiB, 64.0 KiB, 2.1 MiB (stage 40844.0: task 117893))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 40844.0: task 117889))" tooltip="Sort [orderProposalId#555918L ASC NULLS FIRST], false, 0"]; } 15 [id="node15" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 6<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 6<br>local bytes read total (min, med, max (stageId: taskId))<br>1380.0 B (298.0 B, 303.0 B, 779.0 B (stage 40844.0: task 117893))<br>merged fetch fallback count: 0<br>local blocks read: 4<br>remote merged chunks fetched: 0<br>remote blocks read: 2<br>data size total (min, med, max (stageId: taskId))<br>7.2 KiB (768.0 B, 1024.0 B, 2.1 KiB (stage 40843.0: task 117886))<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>1 ms (0 ms, 0 ms, 0 ms (stage 40843.0: task 117863))<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 40844.0: task 117893))<br>remote bytes read: 604.0 B<br>number of partitions: 20<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>1984.0 B (289.0 B, 315.0 B, 435.0 B (stage 40843.0: task 117886))" tooltip="Exchange hashpartitioning(orderProposalId#555918L, 20), ENSURE_REQUIREMENTS, [plan_id=241797]"]; subgraph cluster16 { isCluster="true"; id="cluster16"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n91 ms (0 ms, 7 ms, 11 ms (stage 40843.0: task 117863))"; tooltip="WholeStageCodegen (1)"; 17 [id="node17" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#555917, orderProposalId#555918L, optimizationInsights#555923]"]; 18 [id="node18" labelType="html" label="<b>Filter</b><br><br>number of output rows: 6" tooltip="Filter ((isnotnull(shardId#555917) AND (shardId#555917 = 0_1_10000002107)) AND ((isnotnull(orderProposalId#555918L) AND (size(optimizationInsights#555923, true) > 0)) AND isnotnull(optimizationInsights#555923)))"]; 19 [id="node19" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 14" tooltip="Scan ExistingRDD[shardId#555917,orderProposalId#555918L,items#555919,optimizationGroups#555920,isOptimal#555921,lastModified#555922,optimizationInsights#555923]"]; } subgraph cluster20 { isCluster="true"; id="cluster20"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n522 ms (172 ms, 175 ms, 175 ms (stage 40844.0: task 117892))"; tooltip="WholeStageCodegen (6)"; 21 [id="node21" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 40844.0: task 117893))<br>peak memory total (min, med, max (stageId: taskId))<br>6.2 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 40844.0: task 117893))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 40844.0: task 117893))" tooltip="Sort [orderProposalId#556817L ASC NULLS FIRST], false, 0"]; 22 [id="node22" 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>0 ms (0 ms, 0 ms, 0 ms (stage 40844.0: task 117893))<br>peak memory total (min, med, max (stageId: taskId))<br>768.0 KiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 40844.0: task 117893))<br>number of output rows: 8<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#556817L], functions=[])"]; } 23 [id="node23" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 14<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 8<br>local bytes read total (min, med, max (stageId: taskId))<br>750.0 B (75.0 B, 75.0 B, 150.0 B (stage 40844.0: task 117893))<br>merged fetch fallback count: 0<br>local blocks read: 10<br>remote merged chunks fetched: 0<br>remote blocks read: 4<br>data size total (min, med, max (stageId: taskId))<br>224.0 B (16.0 B, 16.0 B, 32.0 B (stage 40842.0: task 117866))<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>4 ms (0 ms, 0 ms, 0 ms (stage 40842.0: task 117876))<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 40844.0: task 117893))<br>remote bytes read total (min, med, max (stageId: taskId))<br>300.0 B (75.0 B, 75.0 B, 150.0 B (stage 40844.0: task 117893))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 40844.0: task 117893))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>1050.0 B (75.0 B, 75.0 B, 150.0 B (stage 40842.0: task 117866))" tooltip="Exchange hashpartitioning(orderProposalId#556817L, 20), ENSURE_REQUIREMENTS, [plan_id=241817]"]; subgraph cluster24 { isCluster="true"; id="cluster24"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n136 ms (0 ms, 8 ms, 12 ms (stage 40842.0: task 117853))"; tooltip="WholeStageCodegen (5)"; 25 [id="node25" 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>94 ms (0 ms, 7 ms, 10 ms (stage 40842.0: task 117867))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 40842.0: task 117852))<br>number of output rows: 14<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#556817L], functions=[])"]; 26 [id="node26" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#556817L]"]; 27 [id="node27" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 205" tooltip="BroadcastHashJoin [worklistShardItemId#556513L], [worklistShardItemId#556840L], Inner, BuildRight, false"]; 28 [id="node28" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#556512L AS worklistShardItemId#556513L]"]; 29 [id="node29" labelType="html" label="<b>Generate</b><br><br>number of output rows: 205" tooltip="Generate explode(_extract_worklistShardItemId#570524), false, [item#556512L]"]; 30 [id="node30" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#569160.worklistShardItemId AS _extract_worklistShardItemId#570524]"]; 31 [id="node31" labelType="html" label="<b>Filter</b><br><br>number of output rows: 14" tooltip="Filter ((isnotnull(shardId#569158) AND (shardId#569158 = 0_1_10000002107)) AND ((size(items#569160.worklistShardItemId, true) > 0) AND isnotnull(items#569160.worklistShardItemId)))"]; 32 [id="node32" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 14" tooltip="Scan ExistingRDD[shardId#569158,orderProposalId#569159L,items#569160,optimizationGroups#569161,isOptimal#569162,lastModified#569163,optimizationInsights#569164]"]; } 33 [id="node33" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 753 ms<br>number of output rows: 205<br>data size: 1032.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=241811]"]; subgraph cluster34 { isCluster="true"; id="cluster34"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n16 ms (0 ms, 1 ms, 1 ms (stage 40762.0: task 117794))"; tooltip="WholeStageCodegen (4)"; 35 [id="node35" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#556840L, orderProposalId#556817L]"]; } 36 [id="node36" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 205<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 205<br>local bytes read total (min, med, max (stageId: taskId))<br>7.1 KiB (168.0 B, 352.0 B, 538.0 B (stage 40762.0: task 117793))<br>merged fetch fallback count: 0<br>local blocks read: 84<br>remote merged chunks fetched: 0<br>remote blocks read: 92<br>data size total (min, med, max (stageId: taskId))<br>4.8 KiB (96.0 B, 216.0 B, 264.0 B (stage 40761.0: task 117669))<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>13 ms (0 ms, 0 ms, 0 ms (stage 40761.0: task 117669))<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 40762.0: task 117794))<br>remote bytes read total (min, med, max (stageId: taskId))<br>7.7 KiB (84.0 B, 420.0 B, 706.0 B (stage 40762.0: task 117807))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>7 ms (0 ms, 0 ms, 1 ms (stage 40762.0: task 117790))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>14.9 KiB (336.0 B, 619.0 B, 840.0 B (stage 40761.0: task 117671))" tooltip="Exchange hashpartitioning(worklistShardItemId#556840L, 20), REPARTITION_BY_NUM, [plan_id=241807]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n2.7 s (83 ms, 108 ms, 190 ms (stage 40761.0: task 117729))"; tooltip="WholeStageCodegen (3)"; 38 [id="node38" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#556817L, worklistShardItemId#556840L]"]; 39 [id="node39" labelType="html" label="<b>Filter</b><br><br>number of output rows: 205" tooltip="Filter ((isnotnull(worklistShardItemId#556840L) AND NOT (isFallbackOrderOnly#556834 <=> true)) AND isnotnull(orderProposalId#556817L))"]; 40 [id="node40" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 205<br>number of input batches: 25" tooltip="ColumnarToRow"]; } 41 [id="node41" 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.7 s (81 ms, 107 ms, 188 ms (stage 40761.0: task 117729))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 520.6 KiB<br>number of output rows: 205<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#556817L,isFallbackOrderOnly#556834,worklistShardItemId#556840L,shardId#556861,sequenceId#556839] Batched: true, DataFilters: [isnotnull(worklistShardItemId#556840L), NOT (isFallbackOrderOnly#556834 <=> true), isnotnull(ord..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#556861), isnotnull(sequenceId#556839), (shardId#556861 = 0_1_10000002107), (se..., PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderPro..., ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>"]; 42 [id="node42" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 859 ms<br>number of output rows: 205<br>data size: 1032.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=241839]"]; subgraph cluster43 { isCluster="true"; id="cluster43"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n13 ms (0 ms, 1 ms, 1 ms (stage 40764.0: task 117822))"; tooltip="WholeStageCodegen (9)"; 44 [id="node44" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#569316L, orderProposalItemId#569294, supplier#569296, externalProductId#569318, externalPlantId#569319]"]; } 45 [id="node45" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 205<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 205<br>local bytes read total (min, med, max (stageId: taskId))<br>15.7 KiB (333.0 B, 731.0 B, 1600.0 B (stage 40764.0: task 117843))<br>merged fetch fallback count: 0<br>local blocks read: 92<br>remote merged chunks fetched: 0<br>remote blocks read: 84<br>data size total (min, med, max (stageId: taskId))<br>24.0 KiB (480.0 B, 1080.0 B, 1320.0 B (stage 40763.0: task 117670))<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>14 ms (0 ms, 0 ms, 0 ms (stage 40763.0: task 117753))<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 40764.0: task 117822))<br>remote bytes read total (min, med, max (stageId: taskId))<br>14.4 KiB (166.0 B, 833.0 B, 1210.0 B (stage 40764.0: task 117837))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>3 ms (0 ms, 0 ms, 1 ms (stage 40764.0: task 117821))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>30.1 KiB (667.0 B, 1270.0 B, 1661.0 B (stage 40763.0: task 117672))" tooltip="Exchange hashpartitioning(worklistShardItemId#569316L, 20), REPARTITION_BY_NUM, [plan_id=241835]"]; subgraph cluster46 { isCluster="true"; id="cluster46"; label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n2.4 s (72 ms, 93 ms, 152 ms (stage 40763.0: task 117692))"; tooltip="WholeStageCodegen (8)"; 47 [id="node47" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalItemId#569294, supplier#569296, worklistShardItemId#569316L, externalProductId#569318, externalPlantId#569319]"]; 48 [id="node48" labelType="html" label="<b>Filter</b><br><br>number of output rows: 205" tooltip="Filter isnotnull(worklistShardItemId#569316L)"]; 49 [id="node49" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 205<br>number of input batches: 25" tooltip="ColumnarToRow"]; } 50 [id="node50" 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.4 s (71 ms, 91 ms, 151 ms (stage 40763.0: task 117692))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 520.6 KiB<br>number of output rows: 205<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalItemId#569294,supplier#569296,worklistShardItemId#569316L,externalProductId#569318,externalPlantId#569319,shardId#569337,sequenceId#569315] Batched: true, DataFilters: [isnotnull(worklistShardItemId#569316L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#569337), isnotnull(sequenceId#569315), (shardId#569337 = 0_1_10000002107), (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; 14->12; 15->14; 17->15; 18->17; 19->18; 21->12; 22->21; 23->22; 25->23; 26->25; 27->26; 28->27; 29->28; 30->29; 31->30; 32->31; 33->27; 35->33; 36->35; 38->36; 39->38; 40->39; 41->40; 42->6; 44->42; 45->44; 47->45; 48->47; 49->48; 50->49; }