digraph G { 0 [id="node0" labelType="html" label="<b>CollectLimit</b><br><br>shuffle records written: 4<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1<br>local bytes read: 186.0 B<br>merged fetch fallback count: 0<br>local blocks read: 3<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>local merged bytes read: 0.0 B<br>remote reqs duration: 0 ms<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 51222.0: task 137349))<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>248.0 B (62.0 B, 62.0 B, 62.0 B (stage 51222.0: task 137320))" tooltip="CollectLimit 1"]; 1 [id="node1" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 23" tooltip="InMemoryTableScan"]; subgraph cluster2 { isCluster="true"; id="cluster2"; label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n80 ms (0 ms, 3 ms, 16 ms (stage 51222.0: task 137323))"; tooltip="WholeStageCodegen (11)"; 3 [id="node3" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [CASE WHEN (insightTypeInfo#658828.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(objectType, OrderProposal, objectId, cast(orderProposalId#643169L as string)), struct(objectType, OrderProposalItem, objectId, orderProposalItemId#658145)) END END END END END END END END END END END END END END END AS anchorObject#658964, CASE WHEN (insightTypeInfo#658828.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#658828.supplierSubrange), struct(variableName, InitialValue, variableValue, cast(reachedValue#657624 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#657625)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#658828.supplierGroup), struct(variableName, InitialValue, variableValue, cast(reachedValue#657624 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#657625)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, InitialValue, variableValue, cast(reachedValue#657624 as string)), struct(variableName, InitialUoM, variableValue, unitOfMeasure#657625)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#658828.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#658828.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#658828.supplierSubrange), struct(variableName, ProductID, variableValue, externalProductId#658169), struct(variableName, LocationID, variableValue, externalPlantId#658170)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#658828.supplierGroup), struct(variableName, ProductID, variableValue, externalProductId#658169), struct(variableName, LocationID, variableValue, externalPlantId#658170)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, ProductID, variableValue, externalProductId#658169), struct(variableName, LocationID, variableValue, externalPlantId#658170)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#658828.supplierSubrange), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#657625), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#657624 as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#658828.supplierGroup), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#657625), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#657624 as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, MinOrderRestrictionValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, MinOrderRestrictionUoM, variableValue, unitOfMeasure#657625), struct(variableName, CalculatedRestrictionValue, variableValue, cast(reachedValue#657624 as string))) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, SupplierSubrangeID, variableValue, insightTypeInfo#658828.supplierSubrange), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#657625)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierGroupName, variableValue, insightTypeInfo#658828.supplierGroup), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#657625)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array(struct(variableName, SupplierID, variableValue, insightTypeInfo#658828.supplier), struct(variableName, AcceptanceThresholdValue, variableValue, cast(thresholdValue#657623 as string)), struct(variableName, CalculatedThresholdUoM, variableValue, unitOfMeasure#657625)) END END END END END END END END END END END END END END END AS messageVariables#659059, CASE WHEN (insightTypeInfo#658828.insightType = OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#658828.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#658828.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#658828.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#658828.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#658828.supplierSubrange), struct(objectType, Product, objectId, externalProductId#658169), struct(objectType, Location, objectId, externalPlantId#658170)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#658828.supplierGroup), struct(objectType, Product, objectId, externalProductId#658169), struct(objectType, Location, objectId, externalPlantId#658170)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_OPT_MISSING_MD) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier), struct(objectType, Product, objectId, externalProductId#658169), struct(objectType, Location, objectId, externalPlantId#658170)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SUBR_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#658828.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SG_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#658828.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_SUP_MIN_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier), struct(objectType, SupplierSubrange, objectId, insightTypeInfo#658828.supplierSubrange)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, SupplierGroup, objectId, insightTypeInfo#658828.supplierGroup)) ELSE CASE WHEN (insightTypeInfo#658828.insightType = OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET) THEN array([ReplenishmentRunId,10000002106], struct(objectType, Supplier, objectId, insightTypeInfo#658828.supplier)) END END END END END END END END END END END END END END END AS triggerObject#658915, Daily_grocery AS marketUnit#659062, NEW AS situationStatus#659061, insightTypeInfo#658828.insightType AS situationType#659063]"]; } 4 [id="node4" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#643169L, thresholdValue#657623, reachedValue#657624, unitOfMeasure#657625, externalProductId#658169, externalPlantId#658170, orderProposalItemId#658145, struct(insightType, CASE WHEN (internalInsightType#657621 = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (internalInsightType#657621 = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (internalInsightType#657621 = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (internalInsightType#657621 = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (internalInsightType#657621 = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, 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#657626, 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#657626, 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#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE internalInsightType#657621 END, supplierGroup, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 1) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue END, supplier, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 2) THEN from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[0] WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 5) THEN supplier#658147 END, supplierSubrange, CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevel = 3) THEN split(from_json(StructField(assignLevelValue,StringType,true), cast(unbase64(assignmentDetails#657626, false) as string), Some(UTC), false).assignLevelValue, ~~, -1)[1] END) AS insightTypeInfo#658828]"]; subgraph cluster5 { isCluster="true"; id="cluster5"; label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n1.2 s (3 ms, 89 ms, 186 ms (stage 51222.0: task 137320))"; tooltip="WholeStageCodegen (10)"; 6 [id="node6" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 23" tooltip="BroadcastHashJoin [worklistShardItemId#657622L], [worklistShardItemId#658167L], LeftOuter, BuildRight, (shardId#643168 = 0_1_10000002106), false"]; 7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, orderProposalId#643169L, insight#657620.internalInsightType AS internalInsightType#657621, insight#657620.worklistShardItemId AS worklistShardItemId#657622L, insight#657620.thresholdValue AS thresholdValue#657623, insight#657620.reachedValue AS reachedValue#657624, insight#657620.unitOfMeasure AS unitOfMeasure#657625, insight#657620.assignmentDetails AS assignmentDetails#657626]"]; } 8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 23" tooltip="Filter (insight#657620.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#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_SUBR_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_SG_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SUBR_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SG_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SUBR_OPT_MISSING_MD) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SG_OPT_MISSING_MD) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SUP_OPT_MISSING_MD) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_SUBR_MIN_NOT_MET) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_SG_MIN_NOT_MET) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_SUP_MIN_NOT_MET) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SUBR_ACCEPT_THR_NOT_MET) OR ((CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.internalInsightType END <=> OP_CALC_ITEM_SG_ACCEPT_THR_NOT_MET) OR (CASE WHEN (insight#657620.internalInsightType = OP_CALC_MIN_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_SUP_MIN_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_LOCKED_QUANTITY_PREVENTS_DISCARDING_INSIGHT) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_SUP_NEGL_THR_NOT_MET_QTY_CALC_LOCK END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_ACCEPT_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_ACCEPT_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_NEGL_THR_NOT_MET) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_NEGL_THR_NOT_MET END WHEN (insight#657620.internalInsightType = OP_CALC_ITEM_OPT_MISSING_MD) THEN CASE WHEN (from_json(StructField(assignLevel,StringType,true), cast(unbase64(insight#657620.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#657620.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#657620.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#657620.assignmentDetails, false) as string), Some(UTC), false).assignLevel = 5) THEN OP_CALC_ITEM_SUP_OPT_MISSING_MD END ELSE insight#657620.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))\n2.0 s (10 ms, 140 ms, 290 ms (stage 51222.0: task 137323))"; tooltip="WholeStageCodegen (7)"; 10 [id="node10" labelType="html" label="<b>Generate</b><br><br>number of output rows: 113" tooltip="Generate explode(optimizationInsights#643174), [orderProposalId#643169L, shardId#643168], false, [insight#657620]"]; 11 [id="node11" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#643169L, shardId#643168, optimizationInsights#643174]"]; 12 [id="node12" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 11<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 51222.0: task 137321))" tooltip="SortMergeJoin [orderProposalId#643169L], [orderProposalId#645037L], Inner"]; } subgraph cluster13 { isCluster="true"; id="cluster13"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n1.9 s (11 ms, 175 ms, 182 ms (stage 51222.0: task 137320))"; 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 51222.0: task 137321))<br>peak memory total (min, med, max (stageId: taskId))<br>17.3 MiB (64.0 KiB, 64.0 KiB, 2.1 MiB (stage 51222.0: task 137320))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 51222.0: task 137321))" tooltip="Sort [orderProposalId#643169L ASC NULLS FIRST], false, 0"]; } 15 [id="node15" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 11<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 11<br>local bytes read total (min, med, max (stageId: taskId))<br>3.4 KiB (255.0 B, 368.0 B, 881.0 B (stage 51222.0: task 137347))<br>merged fetch fallback count: 0<br>local blocks read: 9<br>remote merged chunks fetched: 0<br>remote blocks read: 2<br>data size total (min, med, max (stageId: taskId))<br>21.5 KiB (240.0 B, 1600.0 B, 9.3 KiB (stage 51221.0: task 137302))<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>3 ms (0 ms, 0 ms, 0 ms (stage 51221.0: task 137310))<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 51222.0: task 137320))<br>remote bytes read total (min, med, max (stageId: taskId))<br>719.0 B (290.0 B, 429.0 B, 429.0 B (stage 51222.0: task 137349))<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 51222.0: task 137323))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>4.1 KiB (255.0 B, 344.0 B, 881.0 B (stage 51221.0: task 137302))" tooltip="Exchange hashpartitioning(orderProposalId#643169L, 20), ENSURE_REQUIREMENTS, [plan_id=268020]"]; subgraph cluster16 { isCluster="true"; id="cluster16"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n160 ms (0 ms, 8 ms, 11 ms (stage 51221.0: task 137306))"; tooltip="WholeStageCodegen (1)"; 17 [id="node17" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, orderProposalId#643169L, optimizationInsights#643174]"]; 18 [id="node18" labelType="html" label="<b>Filter</b><br><br>number of output rows: 11" tooltip="Filter ((isnotnull(shardId#643168) AND (shardId#643168 = 0_1_10000002106)) AND ((isnotnull(orderProposalId#643169L) AND (size(optimizationInsights#643174, true) > 0)) AND isnotnull(optimizationInsights#643174)))"]; 19 [id="node19" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 59" tooltip="Scan ExistingRDD[shardId#643168,orderProposalId#643169L,items#643170,optimizationGroups#643171,isOptimal#643172,lastModified#643173,optimizationInsights#643174]"]; } subgraph cluster20 { isCluster="true"; id="cluster20"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n373 ms (15 ms, 178 ms, 180 ms (stage 51222.0: task 137323))"; 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 51222.0: task 137320))<br>peak memory total (min, med, max (stageId: taskId))<br>16.5 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 51222.0: task 137320))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 51222.0: task 137320))" tooltip="Sort [orderProposalId#645037L 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 51222.0: task 137320))<br>peak memory total (min, med, max (stageId: taskId))<br>2.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 51222.0: task 137320))<br>number of output rows: 29<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#645037L], functions=[])"]; } 23 [id="node23" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 59<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 29<br>local bytes read total (min, med, max (stageId: taskId))<br>2.4 KiB (75.0 B, 150.0 B, 225.0 B (stage 51222.0: task 137337))<br>merged fetch fallback count: 0<br>local blocks read: 32<br>remote merged chunks fetched: 0<br>remote blocks read: 25<br>data size total (min, med, max (stageId: taskId))<br>944.0 B (16.0 B, 48.0 B, 96.0 B (stage 51220.0: task 137286))<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>8 ms (0 ms, 0 ms, 0 ms (stage 51220.0: task 137286))<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 51222.0: task 137320))<br>remote bytes read total (min, med, max (stageId: taskId))<br>1874.0 B (75.0 B, 150.0 B, 225.0 B (stage 51222.0: task 137323))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>6 ms (0 ms, 0 ms, 2 ms (stage 51222.0: task 137347))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>4.2 KiB (75.0 B, 224.0 B, 450.0 B (stage 51220.0: task 137286))" tooltip="Exchange hashpartitioning(orderProposalId#645037L, 20), ENSURE_REQUIREMENTS, [plan_id=268040]"]; subgraph cluster24 { isCluster="true"; id="cluster24"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n214 ms (3 ms, 12 ms, 15 ms (stage 51220.0: task 137270))"; 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>158 ms (0 ms, 8 ms, 11 ms (stage 51220.0: task 137270))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 51220.0: task 137271))<br>number of output rows: 59<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#645037L], functions=[])"]; 26 [id="node26" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#645037L]"]; 27 [id="node27" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 980" tooltip="BroadcastHashJoin [worklistShardItemId#643816L], [worklistShardItemId#645060L], Inner, BuildRight, false"]; 28 [id="node28" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#643815L AS worklistShardItemId#643816L]"]; 29 [id="node29" labelType="html" label="<b>Generate</b><br><br>number of output rows: 980" tooltip="Generate explode(_extract_worklistShardItemId#659080), false, [item#643815L]"]; 30 [id="node30" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#657614.worklistShardItemId AS _extract_worklistShardItemId#659080]"]; 31 [id="node31" labelType="html" label="<b>Filter</b><br><br>number of output rows: 59" tooltip="Filter ((isnotnull(shardId#657612) AND (shardId#657612 = 0_1_10000002106)) AND ((size(items#657614.worklistShardItemId, true) > 0) AND isnotnull(items#657614.worklistShardItemId)))"]; 32 [id="node32" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 59" tooltip="Scan ExistingRDD[shardId#657612,orderProposalId#657613L,items#657614,optimizationGroups#657615,isOptimal#657616,lastModified#657617,optimizationInsights#657618]"]; } 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: 567 ms<br>number of output rows: 980<br>data size: 1056.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=268034]"]; subgraph cluster34 { isCluster="true"; id="cluster34"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n30 ms (1 ms, 1 ms, 3 ms (stage 51128.0: task 137223))"; tooltip="WholeStageCodegen (4)"; 35 [id="node35" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#645060L, orderProposalId#645037L]"]; } 36 [id="node36" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 980<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 980<br>local bytes read total (min, med, max (stageId: taskId))<br>20.9 KiB (754.0 B, 1046.0 B, 1360.0 B (stage 51128.0: task 137227))<br>merged fetch fallback count: 0<br>local blocks read: 203<br>remote merged chunks fetched: 0<br>remote blocks read: 233<br>data size total (min, med, max (stageId: taskId))<br>23.0 KiB (648.0 B, 960.0 B, 1152.0 B (stage 51127.0: task 137162))<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>23 ms (0 ms, 0 ms, 1 ms (stage 51127.0: task 137177))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>1 ms (0 ms, 0 ms, 1 ms (stage 51128.0: task 137224))<br>remote bytes read total (min, med, max (stageId: taskId))<br>23.7 KiB (839.0 B, 1278.0 B, 1527.0 B (stage 51128.0: task 137217))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>17 ms (0 ms, 1 ms, 2 ms (stage 51128.0: task 137224))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>44.6 KiB (1511.0 B, 1790.0 B, 2.1 KiB (stage 51127.0: task 137161))" tooltip="Exchange hashpartitioning(worklistShardItemId#645060L, 20), REPARTITION_BY_NUM, [plan_id=268030]"]; subgraph cluster37 { isCluster="true"; id="cluster37"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n2.7 s (89 ms, 106 ms, 149 ms (stage 51127.0: task 137164))"; tooltip="WholeStageCodegen (3)"; 38 [id="node38" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#645037L, worklistShardItemId#645060L]"]; 39 [id="node39" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter ((isnotnull(worklistShardItemId#645060L) AND NOT (isFallbackOrderOnly#645054 <=> true)) AND isnotnull(orderProposalId#645037L))"]; 40 [id="node40" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 980<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.6 s (87 ms, 104 ms, 147 ms (stage 51127.0: task 137164))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 674.1 KiB<br>number of output rows: 980<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#645037L,isFallbackOrderOnly#645054,worklistShardItemId#645060L,shardId#645081,sequenceId#645059] Batched: true, DataFilters: [isnotnull(worklistShardItemId#645060L), NOT (isFallbackOrderOnly#645054 <=> true), isnotnull(ord..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#645081), isnotnull(sequenceId#645059), (shardId#645081 = 0_1_10000002106), (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: 1 ms<br>time to collect: 782 ms<br>number of output rows: 980<br>data size: 1056.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=268062]"]; subgraph cluster43 { isCluster="true"; id="cluster43"; label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n32 ms (1 ms, 2 ms, 2 ms (stage 51130.0: task 137243))"; tooltip="WholeStageCodegen (9)"; 44 [id="node44" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#658167L, orderProposalItemId#658145, supplier#658147, externalProductId#658169, externalPlantId#658170]"]; } 45 [id="node45" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 980<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 980<br>local bytes read total (min, med, max (stageId: taskId))<br>39.7 KiB (1605.0 B, 2026.0 B, 2.6 KiB (stage 51130.0: task 137250))<br>merged fetch fallback count: 0<br>local blocks read: 171<br>remote merged chunks fetched: 0<br>remote blocks read: 265<br>data size total (min, med, max (stageId: taskId))<br>114.8 KiB (3.2 KiB, 4.7 KiB, 5.6 KiB (stage 51129.0: task 137172))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>22 ms (0 ms, 0 ms, 1 ms (stage 51129.0: task 137173))<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 51130.0: task 137243))<br>remote bytes read total (min, med, max (stageId: taskId))<br>61.1 KiB (2.2 KiB, 3.2 KiB, 3.5 KiB (stage 51130.0: task 137259))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>20 ms (0 ms, 1 ms, 2 ms (stage 51130.0: task 137239))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>100.8 KiB (3.3 KiB, 4.0 KiB, 4.6 KiB (stage 51129.0: task 137170))" tooltip="Exchange hashpartitioning(worklistShardItemId#658167L, 20), REPARTITION_BY_NUM, [plan_id=268058]"]; subgraph cluster46 { isCluster="true"; id="cluster46"; label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n2.1 s (72 ms, 85 ms, 99 ms (stage 51129.0: task 137170))"; tooltip="WholeStageCodegen (8)"; 47 [id="node47" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalItemId#658145, supplier#658147, worklistShardItemId#658167L, externalProductId#658169, externalPlantId#658170]"]; 48 [id="node48" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter isnotnull(worklistShardItemId#658167L)"]; 49 [id="node49" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 980<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.1 s (70 ms, 83 ms, 95 ms (stage 51129.0: task 137171))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 674.1 KiB<br>number of output rows: 980<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalItemId#658145,supplier#658147,worklistShardItemId#658167L,externalProductId#658169,externalPlantId#658170,shardId#658188,sequenceId#658166] Batched: true, DataFilters: [isnotnull(worklistShardItemId#658167L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#658188), isnotnull(sequenceId#658166), (shardId#658188 = 0_1_10000002106), (se..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalItemId:string,supplier:string,worklistShardItemId:bigint,externalProductId:st..."]; 1->0; 3->1; 4->3; 6->4; 7->6; 8->7; 10->8; 11->10; 12->11; 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; }