digraph G {
0 [id="node0" labelType="html" label="<b>CollectLimit</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<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: 0 ms<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: 0.0 B" tooltip="CollectLimit 1"];
1 [id="node1" labelType="html" label="<br><b>Union</b><br><br>" tooltip="Union"];
subgraph cluster2 {
isCluster="true";
id="cluster2";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n380 ms (0 ms, 23 ms, 27 ms (stage 1657492.0: task 4363186))";
tooltip="WholeStageCodegen (5)";
3 [id="node3" labelType="html" label="<br><b>LocalLimit</b><br><br>" tooltip="LocalLimit 1"];
4 [id="node4" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project"];
5 [id="node5" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter NOT insight#16699998.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)"];
6 [id="node6" labelType="html" label="<b>Generate</b><br><br>number of output rows: 0" tooltip="Generate explode(optimizationInsights#16695834), false, [insight#16699998]"];
7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [optimizationInsights#16695834]"];
8 [id="node8" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 0" tooltip="BroadcastHashJoin [orderProposalId#16695829L], [orderProposalId#16696541L], Inner, BuildLeft, false"];
19 [id="node19" 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>31 ms (0 ms, 0 ms, 5 ms (stage 1657492.0: task 4363182))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1657492.0: task 4363175))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#16696541L], functions=[])"];
}
9 [id="node9" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 48 ms<br>number of output rows: 0<br>data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, false]),false), [plan_id=4966421]"];
subgraph cluster10 {
isCluster="true";
id="cluster10";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n0 ms (0 ms, 0 ms, 0 ms (stage 1657428.0: task 4362934))";
tooltip="WholeStageCodegen (1)";
11 [id="node11" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((isnotnull(orderProposalId#16695829L) AND (size(optimizationInsights#16695834, true) > 0)) AND isnotnull(optimizationInsights#16695834))"];
}
12 [id="node12" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 692" tooltip="InMemoryTableScan [orderProposalId#16695829L, optimizationInsights#16695834], [isnotnull(orderProposalId#16695829L), (size(optimizationInsights#16695834, true) > 0), isnotnull(optimizationInsights#16695834)]"];
subgraph cluster13 {
isCluster="true";
id="cluster13";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
14 [id="node14" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
}
15 [id="node15" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834], [isnotnull(shardId#16695828), (shardId#16695828 = 0_3_10000000548)]"];
subgraph cluster16 {
isCluster="true";
id="cluster16";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
17 [id="node17" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
18 [id="node18" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16695828,orderProposalId#16695829L,items#16695830,optimizationGroups#16695831,isOptimal#16695832,lastModified#16695833,optimizationInsights#16695834]"];
}
20 [id="node20" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(orderProposalId#16696541L, 30), ENSURE_REQUIREMENTS, [plan_id=4966443]"];
subgraph cluster21 {
isCluster="true";
id="cluster21";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n232 ms (0 ms, 14 ms, 17 ms (stage 1657488.0: task 4363093))";
tooltip="WholeStageCodegen (4)";
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 1657488.0: task 4363088))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1657488.0: task 4363088))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#16696541L], functions=[])"];
23 [id="node23" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#16696541L]"];
24 [id="node24" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#16696340L], [worklistShardItemId#16696564L], Inner, BuildLeft, false"];
38 [id="node38" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#16696564L, orderProposalId#16696541L]"];
}
25 [id="node25" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 3 ms<br>time to build: 6 ms<br>time to collect: 57 ms<br>number of output rows: 35,084<br>data size: 3.0 MiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=4966429]"];
subgraph cluster26 {
isCluster="true";
id="cluster26";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n9 ms (0 ms, 0 ms, 2 ms (stage 1657429.0: task 4362973))";
tooltip="WholeStageCodegen (2)";
27 [id="node27" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#16696339L AS worklistShardItemId#16696340L]"];
28 [id="node28" labelType="html" label="<b>Generate</b><br><br>number of output rows: 35,084" tooltip="Generate explode(_extract_worklistShardItemId#16704635), false, [item#16696339L]"];
29 [id="node29" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#16699992.worklistShardItemId AS _extract_worklistShardItemId#16704635]"];
30 [id="node30" labelType="html" label="<b>Filter</b><br><br>number of output rows: 692" tooltip="Filter (((size(items#16699992.worklistShardItemId, true) > 0) AND isnotnull(items#16699992.worklistShardItemId)) AND (shardId#16699990 = 0_3_10000000548))"];
}
31 [id="node31" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 692" tooltip="InMemoryTableScan [items#16699992, shardId#16699990], [(size(items#16699992.worklistShardItemId, true) > 0), isnotnull(items#16699992.worklistShardItemId), (shardId#16699990 = 0_3_10000000548)]"];
subgraph cluster32 {
isCluster="true";
id="cluster32";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
33 [id="node33" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
}
34 [id="node34" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834], [isnotnull(shardId#16695828), (shardId#16695828 = 0_3_10000000548)]"];
subgraph cluster35 {
isCluster="true";
id="cluster35";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
36 [id="node36" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
37 [id="node37" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16695828,orderProposalId#16695829L,items#16695830,optimizationGroups#16695831,isOptimal#16695832,lastModified#16695833,optimizationInsights#16695834]"];
}
39 [id="node39" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#16696564L, 30), REPARTITION_BY_NUM, [plan_id=4966436]"];
subgraph cluster40 {
isCluster="true";
id="cluster40";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n2.7 s (50 ms, 75 ms, 102 ms (stage 1657486.0: task 4363052))";
tooltip="WholeStageCodegen (3)";
41 [id="node41" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#16696541L, worklistShardItemId#16696564L]"];
42 [id="node42" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((isnotnull(worklistShardItemId#16696564L) AND NOT (isFallbackOrderOnly#16696558 <=> true)) AND isnotnull(orderProposalId#16696541L))"];
43 [id="node43" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 0<br>number of input batches: 0" tooltip="ColumnarToRow"];
}
44 [id="node44" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 37<br>scan time total (min, med, max (stageId: taskId))<br>2.7 s (50 ms, 75 ms, 102 ms (stage 1657486.0: task 4363052))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 5.2 MiB<br>number of output rows: 0<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#16696541L,isFallbackOrderOnly#16696558,worklistShardItemId#16696564L,shardId#16696585,sequenceId#16696563] Batched: true, DataFilters: [isnotnull(worklistShardItemId#16696564L), NOT (isFallbackOrderOnly#16696558 <=> true), isnotnull..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#16696585), isnotnull(sequenceId#16696563), (shardId#16696585 = 0_3_10000000548..., PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderPro..., ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>"];
subgraph cluster45 {
isCluster="true";
id="cluster45";
label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n212 ms (3 ms, 10 ms, 12 ms (stage 1657492.0: task 4363120))";
tooltip="WholeStageCodegen (8)";
46 [id="node46" labelType="html" label="<br><b>LocalLimit</b><br><br>" tooltip="LocalLimit 1"];
47 [id="node47" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project"];
}
48 [id="node48" labelType="html" label="<b>BroadcastNestedLoopJoin</b><br><br>number of output rows: 0" tooltip="BroadcastNestedLoopJoin BuildRight, Cross, ((CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55260#16700433.label = OutOfStockProbability), lambda x_55260#16700433, false)), 1, None, false).value) OR isnull(cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55261#16700434.name = OOS_PROBABILITY_THRESHOLD), lambda x_55261#16700434, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55260#16700435.label = OutOfStockProbability), lambda x_55260#16700435, false)), 1, None, false).value >= cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55261#16700436.name = OOS_PROBABILITY_THRESHOLD), lambda x_55261#16700436, false)), 1, None, false).value as double)) END AND CASE WHEN isnull(element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55262#16700437.label = InitialStockQty), lambda x_55262#16700437, false)), 1, None, false).value) THEN false ELSE (element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55262#16700439.label = InitialStockQty), lambda x_55262#16700439, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55263#16700440.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_55263#16700440, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (CASE WHEN isnull(orderDateTime#16700647) THEN true ELSE isnull((cast((unix_timestamp(orderDateTime#16700647, yyyy-MM-dd HH:mm:ss, Some(UTC), false) - 1788358407) as double) / 3600.0)) END OR isnull(cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55264#16700441.name = OFFSET_CURRENT_ORDER_DATE), lambda x_55264#16700441, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#16700647) THEN null ELSE (cast((unix_timestamp(orderDateTime#16700647, yyyy-MM-dd HH:mm:ss, Some(UTC), false) - 1788358407) as double) / 3600.0) END >= cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55264#16700442.name = OFFSET_CURRENT_ORDER_DATE), lambda x_55264#16700442, false)), 1, None, false).value as double)) END)"];
subgraph cluster49 {
isCluster="true";
id="cluster49";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n2.0 s (3 ms, 121 ms, 137 ms (stage 1657492.0: task 4363117))";
tooltip="WholeStageCodegen (6)";
50 [id="node50" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderDateTime#16700647, prodLocSpecificKpis#16697097]"];
51 [id="node51" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter NOT (isFallbackOrderOnly#16700651 <=> true)"];
}
52 [id="node52" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 35,084" tooltip="InMemoryTableScan [isFallbackOrderOnly#16700651, orderDateTime#16700647, prodLocSpecificKpis#16697097], [NOT (isFallbackOrderOnly#16700651 <=> true)]"];
subgraph cluster53 {
isCluster="true";
id="cluster53";
label="WholeStageCodegen (15)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (15)";
54 [id="node54" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 17 more fields]"];
55 [id="node55" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [shardId#16695828, worklistShardItemId#16696340L], [shardId#16697119, worklistShardItemId#16697120L], LeftOuter"];
}
subgraph cluster56 {
isCluster="true";
id="cluster56";
label="WholeStageCodegen (12)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (12)";
57 [id="node57" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 16 more fields]"];
58 [id="node58" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [shardId#16695828, worklistShardItemId#16696340L], [shardId#16697106, worklistShardItemId#16697107L], LeftOuter"];
}
subgraph cluster59 {
isCluster="true";
id="cluster59";
label="WholeStageCodegen (9)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (9)";
60 [id="node60" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 15 more fields]"];
61 [id="node61" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [shardId#16695828, worklistShardItemId#16696340L], [shardId#16697090, worklistShardItemId#16697091L], LeftOuter"];
}
subgraph cluster62 {
isCluster="true";
id="cluster62";
label="WholeStageCodegen (6)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (6)";
63 [id="node63" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16695828 ASC NULLS FIRST, worklistShardItemId#16696340L ASC NULLS FIRST], false, 0"];
}
64 [id="node64" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16695828, worklistShardItemId#16696340L, 30), ENSURE_REQUIREMENTS, [plan_id=4965152]"];
subgraph cluster65 {
isCluster="true";
id="cluster65";
label="WholeStageCodegen (5)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (5)";
66 [id="node66" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 14 more fields]"];
67 [id="node67" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#16696340L], [worklistShardItemId#16696564L], LeftOuter, (shardId#16695828 = 0_3_10000000548)"];
}
subgraph cluster68 {
isCluster="true";
id="cluster68";
label="WholeStageCodegen (2)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (2)";
69 [id="node69" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [worklistShardItemId#16696340L ASC NULLS FIRST], false, 0"];
}
70 [id="node70" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#16696340L, 30), ENSURE_REQUIREMENTS, [plan_id=4965133]"];
subgraph cluster71 {
isCluster="true";
id="cluster71";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
72 [id="node72" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, item#16696339.worklistShardItemId AS worklistShardItemId#16696340L, item#16696339.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#16696341, item#16696339.qty AS qty#16696342]"];
73 [id="node73" labelType="html" label="<b>Generate</b><br><br>number of output rows: 0" tooltip="Generate explode(items#16695830), [shardId#16695828], false, [item#16696339]"];
74 [id="node74" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((size(items#16695830, true) > 0) AND isnotnull(items#16695830))"];
}
75 [id="node75" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#16695828, items#16695830], [(size(items#16695830, true) > 0), isnotnull(items#16695830)]"];
subgraph cluster76 {
isCluster="true";
id="cluster76";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
77 [id="node77" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
}
78 [id="node78" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834], [isnotnull(shardId#16695828), (shardId#16695828 = 0_3_10000000548)]"];
subgraph cluster79 {
isCluster="true";
id="cluster79";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
80 [id="node80" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
81 [id="node81" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16695828,orderProposalId#16695829L,items#16695830,optimizationGroups#16695831,isOptimal#16695832,lastModified#16695833,optimizationInsights#16695834]"];
}
subgraph cluster82 {
isCluster="true";
id="cluster82";
label="WholeStageCodegen (4)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (4)";
83 [id="node83" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [worklistShardItemId#16696564L ASC NULLS FIRST], false, 0"];
84 [id="node84" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#16696564L, orderProposalId#16696541L, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, originalReplenishmentRunId#16696583L, splitIndicator#16696560L, previousOrderProposal#16696561L, sourceOfSupplyUuid#16696555, supplierGroup#16696543, supplier#16696544, subrange#16696547, product#16696550, plant#16696545, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, isFallbackOrderOnly#16696558, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, netPriceAmount#16696577, netPriceCurrencyCode#16696578, ... 11 more fields]"];
}
85 [id="node85" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#16696564L, 30), REPARTITION_BY_NUM, [plan_id=4965143]"];
subgraph cluster86 {
isCluster="true";
id="cluster86";
label="WholeStageCodegen (3)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (3)";
87 [id="node87" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, ... 11 more fields]"];
88 [id="node88" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter isnotnull(worklistShardItemId#16696564L)"];
89 [id="node89" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 0<br>number of input batches: 0" tooltip="ColumnarToRow"];
}
90 [id="node90" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 0<br>scan time: 0 ms<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 0.0 B<br>number of output rows: 0<br>number of partitions read: 0" tooltip="FileScan parquet [orderProposalId#16696541L,orderProposalItemId#16696542,supplierGroup#16696543,supplier#16696544,plant#16696545,deliveryDateTime#16696546,subrange#16696547,supplyingPlant#16696548,productGroup#16696549,product#16696550,orderDateTime#16696551,availabilityDateTime#16696552,nextAvailabilityDateTime#16696553,sourceOfSupplyUuid#16696555,isFallbackOrderOnly#16696558,splitIndicator#16696560L,previousOrderProposal#16696561L,worklistShardItemId#16696564L,orderProposalItemGroupId#16696565,externalProductId#16696566,externalPlantId#16696567,logisticUnits#16696568,orderQuantityBaseUom#16696569,orderQuantityBaseUomUuid#16696570,minimumOrderQuantity#16696571,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#16696564L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#16696585), isnotnull(sequenceId#16696563), (shardId#16696585 = 0_3_10000000548..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,pla..."];
subgraph cluster91 {
isCluster="true";
id="cluster91";
label="WholeStageCodegen (8)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (8)";
92 [id="node92" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16697090 ASC NULLS FIRST, worklistShardItemId#16697091L ASC NULLS FIRST], false, 0"];
}
93 [id="node93" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16697090, worklistShardItemId#16697091L, 30), ENSURE_REQUIREMENTS, [plan_id=4965158]"];
subgraph cluster94 {
isCluster="true";
id="cluster94";
label="WholeStageCodegen (7)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (7)";
95 [id="node95" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16697090, worklistShardItemId#16697091L, coalesce(kpis#16697095, []) AS prodLocSpecificKpis#16697096]"];
96 [id="node96" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (((isnull(qty#16697092) AND isnull(demandChannel#16697093)) AND isnull(demandStream#16697094)) AND (isnotnull(shardId#16697090) AND isnotnull(worklistShardItemId#16697091L)))"];
97 [id="node97" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16697090,worklistShardItemId#16697091L,qty#16697092,demandChannel#16697093,demandStream#16697094,kpis#16697095]"];
}
subgraph cluster98 {
isCluster="true";
id="cluster98";
label="WholeStageCodegen (11)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (11)";
99 [id="node99" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16697106 ASC NULLS FIRST, worklistShardItemId#16697107L ASC NULLS FIRST], false, 0"];
}
100 [id="node100" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697106, worklistShardItemId#16697107L], functions=[collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)])"];
101 [id="node101" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16697106, worklistShardItemId#16697107L, 30), ENSURE_REQUIREMENTS, [plan_id=4965169]"];
102 [id="node102" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697106, worklistShardItemId#16697107L], functions=[partial_collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)])"];
subgraph cluster103 {
isCluster="true";
id="cluster103";
label="WholeStageCodegen (10)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (10)";
104 [id="node104" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16697106, worklistShardItemId#16697107L, demandChannel#16697109, demandStream#16697110, kpis#16697111]"];
105 [id="node105" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((((isnull(qty#16697108) AND isnotnull(demandChannel#16697109)) AND isnotnull(demandStream#16697110)) AND (size(kpis#16697111, true) > 0)) AND (isnotnull(shardId#16697106) AND isnotnull(worklistShardItemId#16697107L)))"];
106 [id="node106" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16697106,worklistShardItemId#16697107L,qty#16697108,demandChannel#16697109,demandStream#16697110,kpis#16697111]"];
}
subgraph cluster107 {
isCluster="true";
id="cluster107";
label="WholeStageCodegen (14)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (14)";
108 [id="node108" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16697119 ASC NULLS FIRST, worklistShardItemId#16697120L ASC NULLS FIRST], false, 0"];
}
109 [id="node109" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697119, worklistShardItemId#16697120L], functions=[collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)])"];
110 [id="node110" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16697119, worklistShardItemId#16697120L, 30), ENSURE_REQUIREMENTS, [plan_id=4965181]"];
111 [id="node111" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697119, worklistShardItemId#16697120L], functions=[partial_collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)])"];
subgraph cluster112 {
isCluster="true";
id="cluster112";
label="WholeStageCodegen (13)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (13)";
113 [id="node113" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, kpis#16697124]"];
114 [id="node114" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((isnotnull(qty#16697121) AND isnotnull(kpis#16697124)) AND (isnotnull(shardId#16697119) AND isnotnull(worklistShardItemId#16697120L)))"];
115 [id="node115" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16697119,worklistShardItemId#16697120L,qty#16697121,demandChannel#16697122,demandStream#16697123,kpis#16697124]"];
}
116 [id="node116" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 257 ms<br>number of output rows: 0<br>data size: 0.0 B" tooltip="BroadcastExchange IdentityBroadcastMode, [plan_id=4966463]"];
117 [id="node117" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=4966462]"];
subgraph cluster118 {
isCluster="true";
id="cluster118";
label="WholeStageCodegen (7)\n \nduration: 113 ms";
tooltip="WholeStageCodegen (7)";
119 [id="node119" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [insightConfigurations#16700428[POTENTIAL_OOS_STOCK_PERIOD].settings AS _extract_settings#16704637]"];
120 [id="node120" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(insightConfigurations#16700428) AND isnotnull(insightConfigurations#16700428[POTENTIAL_OOS_STOCK_PERIOD]))"];
121 [id="node121" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 1<br>number of input batches: 1" tooltip="ColumnarToRow"];
}
122 [id="node122" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 1<br>scan time: 108 ms<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 3.7 KiB<br>number of output rows: 1<br>number of partitions read: 1" tooltip="FileScan parquet [insightConfigurations#16700428,shardId#16700429] Batched: true, DataFilters: [isnotnull(insightConfigurations#16700428), isnotnull(insightConfigurations#16700428[POTENTIAL_OO..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#16700429), (shardId#16700429 = 0_3_10000000548)], PushedFilters: [IsNotNull(insightConfigurations)], ReadSchema: struct<insightConfigurations:map<string,struct<configurationVersion:string,name:string,settings:a..."];
subgraph cluster123 {
isCluster="true";
id="cluster123";
label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n200 ms (2 ms, 9 ms, 11 ms (stage 1657492.0: task 4363156))";
tooltip="WholeStageCodegen (11)";
124 [id="node124" labelType="html" label="<br><b>LocalLimit</b><br><br>" tooltip="LocalLimit 1"];
125 [id="node125" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project"];
}
126 [id="node126" labelType="html" label="<b>BroadcastNestedLoopJoin</b><br><br>number of output rows: 0" tooltip="BroadcastNestedLoopJoin BuildRight, Cross, CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#16700605, qty#16700489, None, false), lambdafunction((lambda x_55266#16700459.label = OutOfStockProbability), lambda x_55266#16700459, false)), 1, None, false).value) OR isnull(cast(element_at(filter(_extract_settings#16704639, lambdafunction((lambda x_55267#16700460.name = OOS_PROBABILITY_THRESHOLD), lambda x_55267#16700460, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#16700605, qty#16700489, None, false), lambdafunction((lambda x_55266#16700461.label = OutOfStockProbability), lambda x_55266#16700461, false)), 1, None, false).value >= cast(element_at(filter(_extract_settings#16704639, lambdafunction((lambda x_55267#16700462.name = OOS_PROBABILITY_THRESHOLD), lambda x_55267#16700462, false)), 1, None, false).value as double)) END"];
subgraph cluster127 {
isCluster="true";
id="cluster127";
label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n1.9 s (3 ms, 119 ms, 126 ms (stage 1657492.0: task 4363156))";
tooltip="WholeStageCodegen (9)";
128 [id="node128" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [qty#16700489, quantityKpis#16700605]"];
129 [id="node129" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter NOT (isFallbackOrderOnly#16700514 <=> true)"];
}
130 [id="node130" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 35,084" tooltip="InMemoryTableScan [isFallbackOrderOnly#16700514, qty#16700489, quantityKpis#16700605], [NOT (isFallbackOrderOnly#16700514 <=> true)]"];
subgraph cluster131 {
isCluster="true";
id="cluster131";
label="WholeStageCodegen (15)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (15)";
132 [id="node132" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 17 more fields]"];
133 [id="node133" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [shardId#16695828, worklistShardItemId#16696340L], [shardId#16697119, worklistShardItemId#16697120L], LeftOuter"];
}
subgraph cluster134 {
isCluster="true";
id="cluster134";
label="WholeStageCodegen (12)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (12)";
135 [id="node135" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 16 more fields]"];
136 [id="node136" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [shardId#16695828, worklistShardItemId#16696340L], [shardId#16697106, worklistShardItemId#16697107L], LeftOuter"];
}
subgraph cluster137 {
isCluster="true";
id="cluster137";
label="WholeStageCodegen (9)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (9)";
138 [id="node138" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 15 more fields]"];
139 [id="node139" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [shardId#16695828, worklistShardItemId#16696340L], [shardId#16697090, worklistShardItemId#16697091L], LeftOuter"];
}
subgraph cluster140 {
isCluster="true";
id="cluster140";
label="WholeStageCodegen (6)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (6)";
141 [id="node141" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16695828 ASC NULLS FIRST, worklistShardItemId#16696340L ASC NULLS FIRST], false, 0"];
}
142 [id="node142" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16695828, worklistShardItemId#16696340L, 30), ENSURE_REQUIREMENTS, [plan_id=4965152]"];
subgraph cluster143 {
isCluster="true";
id="cluster143";
label="WholeStageCodegen (5)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (5)";
144 [id="node144" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, ... 14 more fields]"];
145 [id="node145" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#16696340L], [worklistShardItemId#16696564L], LeftOuter, (shardId#16695828 = 0_3_10000000548)"];
}
subgraph cluster146 {
isCluster="true";
id="cluster146";
label="WholeStageCodegen (2)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (2)";
147 [id="node147" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [worklistShardItemId#16696340L ASC NULLS FIRST], false, 0"];
}
148 [id="node148" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#16696340L, 30), ENSURE_REQUIREMENTS, [plan_id=4965133]"];
subgraph cluster149 {
isCluster="true";
id="cluster149";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
150 [id="node150" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16695828, item#16696339.worklistShardItemId AS worklistShardItemId#16696340L, item#16696339.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#16696341, item#16696339.qty AS qty#16696342]"];
151 [id="node151" labelType="html" label="<b>Generate</b><br><br>number of output rows: 0" tooltip="Generate explode(items#16695830), [shardId#16695828], false, [item#16696339]"];
152 [id="node152" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((size(items#16695830, true) > 0) AND isnotnull(items#16695830))"];
}
153 [id="node153" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#16695828, items#16695830], [(size(items#16695830, true) > 0), isnotnull(items#16695830)]"];
subgraph cluster154 {
isCluster="true";
id="cluster154";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
155 [id="node155" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
}
156 [id="node156" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834], [isnotnull(shardId#16695828), (shardId#16695828 = 0_3_10000000548)]"];
subgraph cluster157 {
isCluster="true";
id="cluster157";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
158 [id="node158" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))"];
159 [id="node159" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16695828,orderProposalId#16695829L,items#16695830,optimizationGroups#16695831,isOptimal#16695832,lastModified#16695833,optimizationInsights#16695834]"];
}
subgraph cluster160 {
isCluster="true";
id="cluster160";
label="WholeStageCodegen (4)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (4)";
161 [id="node161" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [worklistShardItemId#16696564L ASC NULLS FIRST], false, 0"];
162 [id="node162" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#16696564L, orderProposalId#16696541L, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, originalReplenishmentRunId#16696583L, splitIndicator#16696560L, previousOrderProposal#16696561L, sourceOfSupplyUuid#16696555, supplierGroup#16696543, supplier#16696544, subrange#16696547, product#16696550, plant#16696545, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, isFallbackOrderOnly#16696558, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, netPriceAmount#16696577, netPriceCurrencyCode#16696578, ... 11 more fields]"];
}
163 [id="node163" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#16696564L, 30), REPARTITION_BY_NUM, [plan_id=4965143]"];
subgraph cluster164 {
isCluster="true";
id="cluster164";
label="WholeStageCodegen (3)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (3)";
165 [id="node165" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, ... 11 more fields]"];
166 [id="node166" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter isnotnull(worklistShardItemId#16696564L)"];
167 [id="node167" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 0<br>number of input batches: 0" tooltip="ColumnarToRow"];
}
168 [id="node168" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 0<br>scan time: 0 ms<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 0.0 B<br>number of output rows: 0<br>number of partitions read: 0" tooltip="FileScan parquet [orderProposalId#16696541L,orderProposalItemId#16696542,supplierGroup#16696543,supplier#16696544,plant#16696545,deliveryDateTime#16696546,subrange#16696547,supplyingPlant#16696548,productGroup#16696549,product#16696550,orderDateTime#16696551,availabilityDateTime#16696552,nextAvailabilityDateTime#16696553,sourceOfSupplyUuid#16696555,isFallbackOrderOnly#16696558,splitIndicator#16696560L,previousOrderProposal#16696561L,worklistShardItemId#16696564L,orderProposalItemGroupId#16696565,externalProductId#16696566,externalPlantId#16696567,logisticUnits#16696568,orderQuantityBaseUom#16696569,orderQuantityBaseUomUuid#16696570,minimumOrderQuantity#16696571,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#16696564L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#16696585), isnotnull(sequenceId#16696563), (shardId#16696585 = 0_3_10000000548..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,pla..."];
subgraph cluster169 {
isCluster="true";
id="cluster169";
label="WholeStageCodegen (8)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (8)";
170 [id="node170" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16697090 ASC NULLS FIRST, worklistShardItemId#16697091L ASC NULLS FIRST], false, 0"];
}
171 [id="node171" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16697090, worklistShardItemId#16697091L, 30), ENSURE_REQUIREMENTS, [plan_id=4965158]"];
subgraph cluster172 {
isCluster="true";
id="cluster172";
label="WholeStageCodegen (7)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (7)";
173 [id="node173" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16697090, worklistShardItemId#16697091L, coalesce(kpis#16697095, []) AS prodLocSpecificKpis#16697096]"];
174 [id="node174" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (((isnull(qty#16697092) AND isnull(demandChannel#16697093)) AND isnull(demandStream#16697094)) AND (isnotnull(shardId#16697090) AND isnotnull(worklistShardItemId#16697091L)))"];
175 [id="node175" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16697090,worklistShardItemId#16697091L,qty#16697092,demandChannel#16697093,demandStream#16697094,kpis#16697095]"];
}
subgraph cluster176 {
isCluster="true";
id="cluster176";
label="WholeStageCodegen (11)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (11)";
177 [id="node177" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16697106 ASC NULLS FIRST, worklistShardItemId#16697107L ASC NULLS FIRST], false, 0"];
}
178 [id="node178" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697106, worklistShardItemId#16697107L], functions=[collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)])"];
179 [id="node179" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16697106, worklistShardItemId#16697107L, 30), ENSURE_REQUIREMENTS, [plan_id=4965169]"];
180 [id="node180" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697106, worklistShardItemId#16697107L], functions=[partial_collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)])"];
subgraph cluster181 {
isCluster="true";
id="cluster181";
label="WholeStageCodegen (10)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (10)";
182 [id="node182" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16697106, worklistShardItemId#16697107L, demandChannel#16697109, demandStream#16697110, kpis#16697111]"];
183 [id="node183" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((((isnull(qty#16697108) AND isnotnull(demandChannel#16697109)) AND isnotnull(demandStream#16697110)) AND (size(kpis#16697111, true) > 0)) AND (isnotnull(shardId#16697106) AND isnotnull(worklistShardItemId#16697107L)))"];
184 [id="node184" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16697106,worklistShardItemId#16697107L,qty#16697108,demandChannel#16697109,demandStream#16697110,kpis#16697111]"];
}
subgraph cluster185 {
isCluster="true";
id="cluster185";
label="WholeStageCodegen (14)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (14)";
186 [id="node186" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#16697119 ASC NULLS FIRST, worklistShardItemId#16697120L ASC NULLS FIRST], false, 0"];
}
187 [id="node187" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697119, worklistShardItemId#16697120L], functions=[collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)])"];
188 [id="node188" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 0<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#16697119, worklistShardItemId#16697120L, 30), ENSURE_REQUIREMENTS, [plan_id=4965181]"];
189 [id="node189" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build: 0 ms<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#16697119, worklistShardItemId#16697120L], functions=[partial_collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)])"];
subgraph cluster190 {
isCluster="true";
id="cluster190";
label="WholeStageCodegen (13)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (13)";
191 [id="node191" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, kpis#16697124]"];
192 [id="node192" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((isnotnull(qty#16697121) AND isnotnull(kpis#16697124)) AND (isnotnull(shardId#16697119) AND isnotnull(worklistShardItemId#16697120L)))"];
193 [id="node193" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#16697119,worklistShardItemId#16697120L,qty#16697121,demandChannel#16697122,demandStream#16697123,kpis#16697124]"];
}
194 [id="node194" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 268 ms<br>number of output rows: 0<br>data size: 0.0 B" tooltip="BroadcastExchange IdentityBroadcastMode, [plan_id=4966479]"];
195 [id="node195" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<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>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=4966478]"];
subgraph cluster196 {
isCluster="true";
id="cluster196";
label="WholeStageCodegen (10)\n \nduration: 123 ms";
tooltip="WholeStageCodegen (10)";
197 [id="node197" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [insightConfigurations#16700610[POTENTIAL_OOS_DEMAND_PERIOD].settings AS _extract_settings#16704639]"];
198 [id="node198" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(insightConfigurations#16700610) AND isnotnull(insightConfigurations#16700610[POTENTIAL_OOS_DEMAND_PERIOD]))"];
199 [id="node199" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 1<br>number of input batches: 1" tooltip="ColumnarToRow"];
}
200 [id="node200" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 1<br>scan time: 119 ms<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 3.7 KiB<br>number of output rows: 1<br>number of partitions read: 1" tooltip="FileScan parquet [insightConfigurations#16700610,shardId#16700611] Batched: true, DataFilters: [isnotnull(insightConfigurations#16700610), isnotnull(insightConfigurations#16700610[POTENTIAL_OO..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#16700611), (shardId#16700611 = 0_3_10000000548)], PushedFilters: [IsNotNull(insightConfigurations)], ReadSchema: struct<insightConfigurations:map<string,struct<configurationVersion:string,name:string,settings:a..."];
1->0;
3->1;
4->3;
5->4;
6->5;
7->6;
8->7;
9->8;
11->9;
12->11;
14->12;
15->14;
17->15;
18->17;
19->8;
20->19;
22->20;
23->22;
24->23;
25->24;
27->25;
28->27;
29->28;
30->29;
31->30;
33->31;
34->33;
36->34;
37->36;
38->24;
39->38;
41->39;
42->41;
43->42;
44->43;
46->1;
47->46;
48->47;
50->48;
51->50;
52->51;
54->52;
55->54;
57->55;
58->57;
60->58;
61->60;
63->61;
64->63;
66->64;
67->66;
69->67;
70->69;
72->70;
73->72;
74->73;
75->74;
77->75;
78->77;
80->78;
81->80;
83->67;
84->83;
85->84;
87->85;
88->87;
89->88;
90->89;
92->61;
93->92;
95->93;
96->95;
97->96;
99->58;
100->99;
101->100;
102->101;
104->102;
105->104;
106->105;
108->55;
109->108;
110->109;
111->110;
113->111;
114->113;
115->114;
116->48;
117->116;
119->117;
120->119;
121->120;
122->121;
124->1;
125->124;
126->125;
128->126;
129->128;
130->129;
132->130;
133->132;
135->133;
136->135;
138->136;
139->138;
141->139;
142->141;
144->142;
145->144;
147->145;
148->147;
150->148;
151->150;
152->151;
153->152;
155->153;
156->155;
158->156;
159->158;
161->145;
162->161;
163->162;
165->163;
166->165;
167->166;
168->167;
170->139;
171->170;
173->171;
174->173;
175->174;
177->136;
178->177;
179->178;
180->179;
182->180;
183->182;
184->183;
186->133;
187->186;
188->187;
189->188;
191->189;
192->191;
193->192;
194->126;
195->194;
197->195;
198->197;
199->198;
200->199;
}
== Physical Plan ==
CollectLimit (104)
+- Union (103)
:- * LocalLimit (33)
: +- * Project (32)
: +- * Filter (31)
: +- * Generate (30)
: +- * Project (29)
: +- * BroadcastHashJoin Inner BuildLeft (28)
: :- BroadcastExchange (9)
: : +- * Filter (8)
: : +- InMemoryTableScan (1)
: : +- InMemoryRelation (2)
: : +- * Filter (7)
: : +- InMemoryTableScan (3)
: : +- InMemoryRelation (4)
: : +- * Filter (6)
: : +- * Scan ExistingRDD (5)
: +- * HashAggregate (27)
: +- Exchange (26)
: +- * HashAggregate (25)
: +- * Project (24)
: +- * BroadcastHashJoin Inner BuildLeft (23)
: :- BroadcastExchange (16)
: : +- * Project (15)
: : +- * Generate (14)
: : +- * Project (13)
: : +- * Filter (12)
: : +- InMemoryTableScan (10)
: : +- InMemoryRelation (11)
: : +- * Filter (7)
: : +- InMemoryTableScan (3)
: : +- InMemoryRelation (4)
: : +- * Filter (6)
: : +- * Scan ExistingRDD (5)
: +- * Project (22)
: +- Exchange (21)
: +- * Project (20)
: +- * Filter (19)
: +- * ColumnarToRow (18)
: +- Scan parquet (17)
:- * LocalLimit (89)
: +- * Project (88)
: +- BroadcastNestedLoopJoin Cross BuildRight (87)
: :- * Project (80)
: : +- * Filter (79)
: : +- InMemoryTableScan (34)
: : +- InMemoryRelation (35)
: : +- * Project (78)
: : +- * SortMergeJoin LeftOuter (77)
: : :- * Project (69)
: : : +- * SortMergeJoin LeftOuter (68)
: : : :- * Project (60)
: : : : +- * SortMergeJoin LeftOuter (59)
: : : : :- * Sort (53)
: : : : : +- Exchange (52)
: : : : : +- * Project (51)
: : : : : +- * SortMergeJoin LeftOuter (50)
: : : : : :- * Sort (42)
: : : : : : +- Exchange (41)
: : : : : : +- * Project (40)
: : : : : : +- * Generate (39)
: : : : : : +- * Filter (38)
: : : : : : +- InMemoryTableScan (36)
: : : : : : +- InMemoryRelation (37)
: : : : : : +- * Filter (7)
: : : : : : +- InMemoryTableScan (3)
: : : : : : +- InMemoryRelation (4)
: : : : : : +- * Filter (6)
: : : : : : +- * Scan ExistingRDD (5)
: : : : : +- * Sort (49)
: : : : : +- * Project (48)
: : : : : +- Exchange (47)
: : : : : +- * Project (46)
: : : : : +- * Filter (45)
: : : : : +- * ColumnarToRow (44)
: : : : : +- Scan parquet (43)
: : : : +- * Sort (58)
: : : : +- Exchange (57)
: : : : +- * Project (56)
: : : : +- * Filter (55)
: : : : +- * Scan ExistingRDD (54)
: : : +- * Sort (67)
: : : +- ObjectHashAggregate (66)
: : : +- Exchange (65)
: : : +- ObjectHashAggregate (64)
: : : +- * Project (63)
: : : +- * Filter (62)
: : : +- * Scan ExistingRDD (61)
: : +- * Sort (76)
: : +- ObjectHashAggregate (75)
: : +- Exchange (74)
: : +- ObjectHashAggregate (73)
: : +- * Project (72)
: : +- * Filter (71)
: : +- * Scan ExistingRDD (70)
: +- BroadcastExchange (86)
: +- Exchange (85)
: +- * Project (84)
: +- * Filter (83)
: +- * ColumnarToRow (82)
: +- Scan parquet (81)
+- * LocalLimit (102)
+- * Project (101)
+- BroadcastNestedLoopJoin Cross BuildRight (100)
:- * Project (93)
: +- * Filter (92)
: +- InMemoryTableScan (90)
: +- InMemoryRelation (91)
: +- * Project (78)
: +- * SortMergeJoin LeftOuter (77)
: :- * Project (69)
: : +- * SortMergeJoin LeftOuter (68)
: : :- * Project (60)
: : : +- * SortMergeJoin LeftOuter (59)
: : : :- * Sort (53)
: : : : +- Exchange (52)
: : : : +- * Project (51)
: : : : +- * SortMergeJoin LeftOuter (50)
: : : : :- * Sort (42)
: : : : : +- Exchange (41)
: : : : : +- * Project (40)
: : : : : +- * Generate (39)
: : : : : +- * Filter (38)
: : : : : +- InMemoryTableScan (36)
: : : : : +- InMemoryRelation (37)
: : : : : +- * Filter (7)
: : : : : +- InMemoryTableScan (3)
: : : : : +- InMemoryRelation (4)
: : : : : +- * Filter (6)
: : : : : +- * Scan ExistingRDD (5)
: : : : +- * Sort (49)
: : : : +- * Project (48)
: : : : +- Exchange (47)
: : : : +- * Project (46)
: : : : +- * Filter (45)
: : : : +- * ColumnarToRow (44)
: : : : +- Scan parquet (43)
: : : +- * Sort (58)
: : : +- Exchange (57)
: : : +- * Project (56)
: : : +- * Filter (55)
: : : +- * Scan ExistingRDD (54)
: : +- * Sort (67)
: : +- ObjectHashAggregate (66)
: : +- Exchange (65)
: : +- ObjectHashAggregate (64)
: : +- * Project (63)
: : +- * Filter (62)
: : +- * Scan ExistingRDD (61)
: +- * Sort (76)
: +- ObjectHashAggregate (75)
: +- Exchange (74)
: +- ObjectHashAggregate (73)
: +- * Project (72)
: +- * Filter (71)
: +- * Scan ExistingRDD (70)
+- BroadcastExchange (99)
+- Exchange (98)
+- * Project (97)
+- * Filter (96)
+- * ColumnarToRow (95)
+- Scan parquet (94)
(1) InMemoryTableScan
Output [2]: [orderProposalId#16695829L, optimizationInsights#16695834]
Arguments: [orderProposalId#16695829L, optimizationInsights#16695834], [isnotnull(orderProposalId#16695829L), (size(optimizationInsights#16695834, true) > 0), isnotnull(optimizationInsights#16695834)]
(2) InMemoryRelation
Arguments: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834], StorageLevel(disk, memory, 2 replicas)
(3) InMemoryTableScan
Output [6]: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834]
Arguments: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834], [isnotnull(shardId#16695828), (shardId#16695828 = 0_3_10000000548)]
(4) InMemoryRelation
Arguments: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, lastModified#16695833, optimizationInsights#16695834], StorageLevel(disk, memory, 2 replicas)
(5) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, lastModified#16695833, optimizationInsights#16695834]
Arguments: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, lastModified#16695833, optimizationInsights#16695834], MapPartitionsRDD[710108] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(6) Filter [codegen id : 1]
Input [7]: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, lastModified#16695833, optimizationInsights#16695834]
Condition : (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))
(7) Filter [codegen id : 1]
Input [6]: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834]
Condition : (isnotnull(shardId#16695828) AND (shardId#16695828 = 0_3_10000000548))
(8) Filter [codegen id : 1]
Input [2]: [orderProposalId#16695829L, optimizationInsights#16695834]
Condition : ((isnotnull(orderProposalId#16695829L) AND (size(optimizationInsights#16695834, true) > 0)) AND isnotnull(optimizationInsights#16695834))
(9) BroadcastExchange
Input [2]: [orderProposalId#16695829L, optimizationInsights#16695834]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, false]),false), [plan_id=4966421]
(10) InMemoryTableScan
Output [2]: [items#16699992, shardId#16699990]
Arguments: [items#16699992, shardId#16699990], [(size(items#16699992.worklistShardItemId, true) > 0), isnotnull(items#16699992.worklistShardItemId), (shardId#16699990 = 0_3_10000000548)]
(11) InMemoryRelation
Arguments: [shardId#16699990, orderProposalId#16699991L, items#16699992, optimizationGroups#16699993, isOptimal#16699994, optimizationInsights#16699996], StorageLevel(disk, memory, 2 replicas)
(12) Filter [codegen id : 2]
Input [2]: [items#16699992, shardId#16699990]
Condition : (((size(items#16699992.worklistShardItemId, true) > 0) AND isnotnull(items#16699992.worklistShardItemId)) AND (shardId#16699990 = 0_3_10000000548))
(13) Project [codegen id : 2]
Output [1]: [items#16699992.worklistShardItemId AS _extract_worklistShardItemId#16704635]
Input [2]: [items#16699992, shardId#16699990]
(14) Generate [codegen id : 2]
Input [1]: [_extract_worklistShardItemId#16704635]
Arguments: explode(_extract_worklistShardItemId#16704635), false, [item#16696339L]
(15) Project [codegen id : 2]
Output [1]: [item#16696339L AS worklistShardItemId#16696340L]
Input [1]: [item#16696339L]
(16) BroadcastExchange
Input [1]: [worklistShardItemId#16696340L]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=4966429]
(17) Scan parquet
Output [5]: [orderProposalId#16696541L, isFallbackOrderOnly#16696558, worklistShardItemId#16696564L, shardId#16696585, sequenceId#16696563]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000548]
PartitionFilters: [isnotnull(shardId#16696585), isnotnull(sequenceId#16696563), (shardId#16696585 = 0_3_10000000548), (sequenceId#16696563 = 25)]
PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>
(18) ColumnarToRow [codegen id : 3]
Input [5]: [orderProposalId#16696541L, isFallbackOrderOnly#16696558, worklistShardItemId#16696564L, shardId#16696585, sequenceId#16696563]
(19) Filter [codegen id : 3]
Input [5]: [orderProposalId#16696541L, isFallbackOrderOnly#16696558, worklistShardItemId#16696564L, shardId#16696585, sequenceId#16696563]
Condition : ((isnotnull(worklistShardItemId#16696564L) AND NOT (isFallbackOrderOnly#16696558 <=> true)) AND isnotnull(orderProposalId#16696541L))
(20) Project [codegen id : 3]
Output [2]: [orderProposalId#16696541L, worklistShardItemId#16696564L]
Input [5]: [orderProposalId#16696541L, isFallbackOrderOnly#16696558, worklistShardItemId#16696564L, shardId#16696585, sequenceId#16696563]
(21) Exchange
Input [2]: [orderProposalId#16696541L, worklistShardItemId#16696564L]
Arguments: hashpartitioning(worklistShardItemId#16696564L, 30), REPARTITION_BY_NUM, [plan_id=4966436]
(22) Project
Output [2]: [worklistShardItemId#16696564L, orderProposalId#16696541L]
Input [2]: [orderProposalId#16696541L, worklistShardItemId#16696564L]
(23) BroadcastHashJoin [codegen id : 4]
Left keys [1]: [worklistShardItemId#16696340L]
Right keys [1]: [worklistShardItemId#16696564L]
Join type: Inner
Join condition: None
(24) Project [codegen id : 4]
Output [1]: [orderProposalId#16696541L]
Input [3]: [worklistShardItemId#16696340L, worklistShardItemId#16696564L, orderProposalId#16696541L]
(25) HashAggregate [codegen id : 4]
Input [1]: [orderProposalId#16696541L]
Keys [1]: [orderProposalId#16696541L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#16696541L]
(26) Exchange
Input [1]: [orderProposalId#16696541L]
Arguments: hashpartitioning(orderProposalId#16696541L, 30), ENSURE_REQUIREMENTS, [plan_id=4966443]
(27) HashAggregate
Input [1]: [orderProposalId#16696541L]
Keys [1]: [orderProposalId#16696541L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#16696541L]
(28) BroadcastHashJoin [codegen id : 5]
Left keys [1]: [orderProposalId#16695829L]
Right keys [1]: [orderProposalId#16696541L]
Join type: Inner
Join condition: None
(29) Project [codegen id : 5]
Output [1]: [optimizationInsights#16695834]
Input [3]: [orderProposalId#16695829L, optimizationInsights#16695834, orderProposalId#16696541L]
(30) Generate [codegen id : 5]
Input [1]: [optimizationInsights#16695834]
Arguments: explode(optimizationInsights#16695834), false, [insight#16699998]
(31) Filter [codegen id : 5]
Input [1]: [insight#16699998]
Condition : NOT insight#16699998.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)
(32) Project [codegen id : 5]
Output: []
Input [1]: [insight#16699998]
(33) LocalLimit [codegen id : 5]
Input: []
Arguments: 1
(34) InMemoryTableScan
Output [3]: [isFallbackOrderOnly#16700651, orderDateTime#16700647, prodLocSpecificKpis#16697097]
Arguments: [isFallbackOrderOnly#16700651, orderDateTime#16700647, prodLocSpecificKpis#16697097], [NOT (isFallbackOrderOnly#16700651 <=> true)]
(35) InMemoryRelation
Arguments: [shardId#16700616, worklistShardItemId#16700624L, quantityAfterProdPlantOptimization#16700625, qty#16700626, orderProposalId#16700629L, originalReplenishmentRunId#16700632L, supplierGroup#16700639, supplier#16700640, supplyingPlant#16700670, productGroup#16700671, product#16700642, plant#16700643, subrange#16700641, orderDateTime#16700647, deliveryDateTime#16700648, availabilityDateTime#16700649, nextAvailabilityDateTime#16700650, constraintValues#16700664, constraintOperators#16700662, constraintLabels#16700661, logisticUnits#16700666, orderQuantityBaseUom#16700652, orderQuantityBaseUomUuid#16700653, splitIndicator#16700634L, netPriceAmount#16700657, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)
(36) InMemoryTableScan
Output [2]: [shardId#16695828, items#16695830]
Arguments: [shardId#16695828, items#16695830], [(size(items#16695830, true) > 0), isnotnull(items#16695830)]
(37) InMemoryRelation
Arguments: [shardId#16695828, orderProposalId#16695829L, items#16695830, optimizationGroups#16695831, isOptimal#16695832, optimizationInsights#16695834], StorageLevel(disk, memory, 2 replicas)
(38) Filter [codegen id : 1]
Input [2]: [shardId#16695828, items#16695830]
Condition : ((size(items#16695830, true) > 0) AND isnotnull(items#16695830))
(39) Generate [codegen id : 1]
Input [2]: [shardId#16695828, items#16695830]
Arguments: explode(items#16695830), [shardId#16695828], false, [item#16696339]
(40) Project [codegen id : 1]
Output [4]: [shardId#16695828, item#16696339.worklistShardItemId AS worklistShardItemId#16696340L, item#16696339.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#16696341, item#16696339.qty AS qty#16696342]
Input [2]: [shardId#16695828, item#16696339]
(41) Exchange
Input [4]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342]
Arguments: hashpartitioning(worklistShardItemId#16696340L, 30), ENSURE_REQUIREMENTS, [plan_id=4965133]
(42) Sort [codegen id : 2]
Input [4]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342]
Arguments: [worklistShardItemId#16696340L ASC NULLS FIRST], false, 0
(43) Scan parquet
Output [38]: [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, measurements#16696582, originalReplenishmentRunId#16696583L, optimizationGroups#16696584, shardId#16696585, sequenceId#16696563]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000548]
PartitionFilters: [isnotnull(shardId#16696585), isnotnull(sequenceId#16696563), (shardId#16696585 = 0_3_10000000548), (sequenceId#16696563 = 25)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,supplyingPlant:string,productGroup:string,product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,sourceOfSupplyUuid:string,isFallbackOrderOnly:boolean,splitIndicator:bigint,previousOrderProposal:bigint,worklistShardItemId:bigint,orderProposalItemGroupId:string,externalProductId:string,externalPlantId:string,logisticUnits:array<struct<uom:string,uomUuid:string,numerator:int,denominator:int,isOrderUnit:boolean,isPreferred:boolean>>,orderQuantityBaseUom:string,orderQuantityBaseUomUuid:string,minimumOrderQuantity:double,constraintLabels:array<string>,constraintOperators:array<string>,constraintValues:array<double>,netPriceAmount:double,netPriceCurrencyCode:string,netPriceQuantity:double,netPriceQuantityUom:string,netPriceQuantityUomUuid:string,measurements:array<struct<value:double,dimensionType:int,dimensionCode:string,dimensionCodeUuid:string,isoCode:string>>,originalReplenishmentRunId:bigint,optimizationGroups:array<string>>
(44) ColumnarToRow [codegen id : 3]
Input [38]: [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, measurements#16696582, originalReplenishmentRunId#16696583L, optimizationGroups#16696584, shardId#16696585, sequenceId#16696563]
(45) Filter [codegen id : 3]
Input [38]: [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, measurements#16696582, originalReplenishmentRunId#16696583L, optimizationGroups#16696584, shardId#16696585, sequenceId#16696563]
Condition : isnotnull(worklistShardItemId#16696564L)
(46) Project [codegen id : 3]
Output [36]: [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, measurements#16696582, originalReplenishmentRunId#16696583L, optimizationGroups#16696584]
Input [38]: [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, measurements#16696582, originalReplenishmentRunId#16696583L, optimizationGroups#16696584, shardId#16696585, sequenceId#16696563]
(47) Exchange
Input [36]: [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, measurements#16696582, originalReplenishmentRunId#16696583L, optimizationGroups#16696584]
Arguments: hashpartitioning(worklistShardItemId#16696564L, 30), REPARTITION_BY_NUM, [plan_id=4965143]
(48) Project [codegen id : 4]
Output [36]: [worklistShardItemId#16696564L, orderProposalId#16696541L, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, originalReplenishmentRunId#16696583L, splitIndicator#16696560L, previousOrderProposal#16696561L, sourceOfSupplyUuid#16696555, supplierGroup#16696543, supplier#16696544, subrange#16696547, product#16696550, plant#16696545, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, isFallbackOrderOnly#16696558, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, netPriceAmount#16696577, netPriceCurrencyCode#16696578, measurements#16696582, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, logisticUnits#16696568, optimizationGroups#16696584, externalProductId#16696566, externalPlantId#16696567, supplyingPlant#16696548, productGroup#16696549]
Input [36]: [orderProposalId#16696541L, orderProposalItemId#16696542, supplierGroup#16696543, supplier#16696544, plant#16696545, deliveryDateTime#16696546, subrange#16696547, supplyingPlant#16696548, productGroup#16696549, product#16696550, orderDateTime#16696551, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, sourceOfSupplyUuid#16696555, isFallbackOrderOnly#16696558, splitIndicator#16696560L, previousOrderProposal#16696561L, worklistShardItemId#16696564L, orderProposalItemGroupId#16696565, externalProductId#16696566, externalPlantId#16696567, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, measurements#16696582, originalReplenishmentRunId#16696583L, optimizationGroups#16696584]
(49) Sort [codegen id : 4]
Input [36]: [worklistShardItemId#16696564L, orderProposalId#16696541L, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, originalReplenishmentRunId#16696583L, splitIndicator#16696560L, previousOrderProposal#16696561L, sourceOfSupplyUuid#16696555, supplierGroup#16696543, supplier#16696544, subrange#16696547, product#16696550, plant#16696545, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, isFallbackOrderOnly#16696558, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, netPriceAmount#16696577, netPriceCurrencyCode#16696578, measurements#16696582, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, logisticUnits#16696568, optimizationGroups#16696584, externalProductId#16696566, externalPlantId#16696567, supplyingPlant#16696548, productGroup#16696549]
Arguments: [worklistShardItemId#16696564L ASC NULLS FIRST], false, 0
(50) SortMergeJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#16696340L]
Right keys [1]: [worklistShardItemId#16696564L]
Join type: LeftOuter
Join condition: (shardId#16695828 = 0_3_10000000548)
(51) Project [codegen id : 5]
Output [39]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558]
Input [40]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, worklistShardItemId#16696564L, orderProposalId#16696541L, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, originalReplenishmentRunId#16696583L, splitIndicator#16696560L, previousOrderProposal#16696561L, sourceOfSupplyUuid#16696555, supplierGroup#16696543, supplier#16696544, subrange#16696547, product#16696550, plant#16696545, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, isFallbackOrderOnly#16696558, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, netPriceAmount#16696577, netPriceCurrencyCode#16696578, measurements#16696582, minimumOrderQuantity#16696571, constraintLabels#16696572, constraintOperators#16696573, constraintValues#16696574, logisticUnits#16696568, optimizationGroups#16696584, externalProductId#16696566, externalPlantId#16696567, supplyingPlant#16696548, productGroup#16696549]
(52) Exchange
Input [39]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558]
Arguments: hashpartitioning(shardId#16695828, worklistShardItemId#16696340L, 30), ENSURE_REQUIREMENTS, [plan_id=4965152]
(53) Sort [codegen id : 6]
Input [39]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558]
Arguments: [shardId#16695828 ASC NULLS FIRST, worklistShardItemId#16696340L ASC NULLS FIRST], false, 0
(54) Scan ExistingRDD [codegen id : 7]
Output [6]: [shardId#16697090, worklistShardItemId#16697091L, qty#16697092, demandChannel#16697093, demandStream#16697094, kpis#16697095]
Arguments: [shardId#16697090, worklistShardItemId#16697091L, qty#16697092, demandChannel#16697093, demandStream#16697094, kpis#16697095], MapPartitionsRDD[710172] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(55) Filter [codegen id : 7]
Input [6]: [shardId#16697090, worklistShardItemId#16697091L, qty#16697092, demandChannel#16697093, demandStream#16697094, kpis#16697095]
Condition : (((isnull(qty#16697092) AND isnull(demandChannel#16697093)) AND isnull(demandStream#16697094)) AND (isnotnull(shardId#16697090) AND isnotnull(worklistShardItemId#16697091L)))
(56) Project [codegen id : 7]
Output [3]: [shardId#16697090, worklistShardItemId#16697091L, coalesce(kpis#16697095, []) AS prodLocSpecificKpis#16697096]
Input [6]: [shardId#16697090, worklistShardItemId#16697091L, qty#16697092, demandChannel#16697093, demandStream#16697094, kpis#16697095]
(57) Exchange
Input [3]: [shardId#16697090, worklistShardItemId#16697091L, prodLocSpecificKpis#16697096]
Arguments: hashpartitioning(shardId#16697090, worklistShardItemId#16697091L, 30), ENSURE_REQUIREMENTS, [plan_id=4965158]
(58) Sort [codegen id : 8]
Input [3]: [shardId#16697090, worklistShardItemId#16697091L, prodLocSpecificKpis#16697096]
Arguments: [shardId#16697090 ASC NULLS FIRST, worklistShardItemId#16697091L ASC NULLS FIRST], false, 0
(59) SortMergeJoin [codegen id : 9]
Left keys [2]: [shardId#16695828, worklistShardItemId#16696340L]
Right keys [2]: [shardId#16697090, worklistShardItemId#16697091L]
Join type: LeftOuter
Join condition: None
(60) Project [codegen id : 9]
Output [40]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558, coalesce(prodLocSpecificKpis#16697096, []) AS prodLocSpecificKpis#16697097]
Input [42]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558, shardId#16697090, worklistShardItemId#16697091L, prodLocSpecificKpis#16697096]
(61) Scan ExistingRDD [codegen id : 10]
Output [6]: [shardId#16697106, worklistShardItemId#16697107L, qty#16697108, demandChannel#16697109, demandStream#16697110, kpis#16697111]
Arguments: [shardId#16697106, worklistShardItemId#16697107L, qty#16697108, demandChannel#16697109, demandStream#16697110, kpis#16697111], MapPartitionsRDD[710172] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(62) Filter [codegen id : 10]
Input [6]: [shardId#16697106, worklistShardItemId#16697107L, qty#16697108, demandChannel#16697109, demandStream#16697110, kpis#16697111]
Condition : ((((isnull(qty#16697108) AND isnotnull(demandChannel#16697109)) AND isnotnull(demandStream#16697110)) AND (size(kpis#16697111, true) > 0)) AND (isnotnull(shardId#16697106) AND isnotnull(worklistShardItemId#16697107L)))
(63) Project [codegen id : 10]
Output [5]: [shardId#16697106, worklistShardItemId#16697107L, demandChannel#16697109, demandStream#16697110, kpis#16697111]
Input [6]: [shardId#16697106, worklistShardItemId#16697107L, qty#16697108, demandChannel#16697109, demandStream#16697110, kpis#16697111]
(64) ObjectHashAggregate
Input [5]: [shardId#16697106, worklistShardItemId#16697107L, demandChannel#16697109, demandStream#16697110, kpis#16697111]
Keys [2]: [shardId#16697106, worklistShardItemId#16697107L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)]
Aggregate Attributes [1]: [buf#16697286]
Results [3]: [shardId#16697106, worklistShardItemId#16697107L, buf#16697287]
(65) Exchange
Input [3]: [shardId#16697106, worklistShardItemId#16697107L, buf#16697287]
Arguments: hashpartitioning(shardId#16697106, worklistShardItemId#16697107L, 30), ENSURE_REQUIREMENTS, [plan_id=4965169]
(66) ObjectHashAggregate
Input [3]: [shardId#16697106, worklistShardItemId#16697107L, buf#16697287]
Keys [2]: [shardId#16697106, worklistShardItemId#16697107L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)#16697105]
Results [3]: [shardId#16697106, worklistShardItemId#16697107L, collect_list(struct(demandChannel, demandChannel#16697109, demandStream, demandStream#16697110, kpis, kpis#16697111), 0, 0)#16697105 AS channelStreamSpecificKpis#16697098]
(67) Sort [codegen id : 11]
Input [3]: [shardId#16697106, worklistShardItemId#16697107L, channelStreamSpecificKpis#16697098]
Arguments: [shardId#16697106 ASC NULLS FIRST, worklistShardItemId#16697107L ASC NULLS FIRST], false, 0
(68) SortMergeJoin [codegen id : 12]
Left keys [2]: [shardId#16695828, worklistShardItemId#16696340L]
Right keys [2]: [shardId#16697106, worklistShardItemId#16697107L]
Join type: LeftOuter
Join condition: None
(69) Project [codegen id : 12]
Output [41]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558, prodLocSpecificKpis#16697097, coalesce(channelStreamSpecificKpis#16697098, []) AS channelStreamSpecificKpis#16697112]
Input [43]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558, prodLocSpecificKpis#16697097, shardId#16697106, worklistShardItemId#16697107L, channelStreamSpecificKpis#16697098]
(70) Scan ExistingRDD [codegen id : 13]
Output [6]: [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, demandChannel#16697122, demandStream#16697123, kpis#16697124]
Arguments: [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, demandChannel#16697122, demandStream#16697123, kpis#16697124], MapPartitionsRDD[710172] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(71) Filter [codegen id : 13]
Input [6]: [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, demandChannel#16697122, demandStream#16697123, kpis#16697124]
Condition : ((isnotnull(qty#16697121) AND isnotnull(kpis#16697124)) AND (isnotnull(shardId#16697119) AND isnotnull(worklistShardItemId#16697120L)))
(72) Project [codegen id : 13]
Output [4]: [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, kpis#16697124]
Input [6]: [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, demandChannel#16697122, demandStream#16697123, kpis#16697124]
(73) ObjectHashAggregate
Input [4]: [shardId#16697119, worklistShardItemId#16697120L, qty#16697121, kpis#16697124]
Keys [2]: [shardId#16697119, worklistShardItemId#16697120L]
Functions [1]: [partial_collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)]
Aggregate Attributes [1]: [buf#16697288]
Results [3]: [shardId#16697119, worklistShardItemId#16697120L, buf#16697289]
(74) Exchange
Input [3]: [shardId#16697119, worklistShardItemId#16697120L, buf#16697289]
Arguments: hashpartitioning(shardId#16697119, worklistShardItemId#16697120L, 30), ENSURE_REQUIREMENTS, [plan_id=4965181]
(75) ObjectHashAggregate
Input [3]: [shardId#16697119, worklistShardItemId#16697120L, buf#16697289]
Keys [2]: [shardId#16697119, worklistShardItemId#16697120L]
Functions [1]: [collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)#16697118]
Results [3]: [shardId#16697119, worklistShardItemId#16697120L, map_from_entries(collect_list(struct(qty, qty#16697121, kpis, kpis#16697124), 0, 0)#16697118) AS quantityKpis#16697113]
(76) Sort [codegen id : 14]
Input [3]: [shardId#16697119, worklistShardItemId#16697120L, quantityKpis#16697113]
Arguments: [shardId#16697119 ASC NULLS FIRST, worklistShardItemId#16697120L ASC NULLS FIRST], false, 0
(77) SortMergeJoin [codegen id : 15]
Left keys [2]: [shardId#16695828, worklistShardItemId#16696340L]
Right keys [2]: [shardId#16697119, worklistShardItemId#16697120L]
Join type: LeftOuter
Join condition: None
(78) Project [codegen id : 15]
Output [42]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558, prodLocSpecificKpis#16697097, channelStreamSpecificKpis#16697112, coalesce(quantityKpis#16697113, map(keys: [], values: [])) AS quantityKpis#16697125]
Input [44]: [shardId#16695828, worklistShardItemId#16696340L, quantityAfterProdPlantOptimization#16696341, qty#16696342, orderProposalId#16696541L, originalReplenishmentRunId#16696583L, supplierGroup#16696543, supplier#16696544, supplyingPlant#16696548, productGroup#16696549, product#16696550, plant#16696545, subrange#16696547, orderDateTime#16696551, deliveryDateTime#16696546, availabilityDateTime#16696552, nextAvailabilityDateTime#16696553, constraintValues#16696574, constraintOperators#16696573, constraintLabels#16696572, logisticUnits#16696568, orderQuantityBaseUom#16696569, orderQuantityBaseUomUuid#16696570, splitIndicator#16696560L, netPriceAmount#16696577, netPriceCurrencyCode#16696578, netPriceQuantity#16696579, netPriceQuantityUom#16696580, netPriceQuantityUomUuid#16696581, sourceOfSupplyUuid#16696555, minimumOrderQuantity#16696571, orderProposalItemId#16696542, orderProposalItemGroupId#16696565, optimizationGroups#16696584, measurements#16696582, externalProductId#16696566, externalPlantId#16696567, previousOrderProposal#16696561L, isFallbackOrderOnly#16696558, prodLocSpecificKpis#16697097, channelStreamSpecificKpis#16697112, shardId#16697119, worklistShardItemId#16697120L, quantityKpis#16697113]
(79) Filter [codegen id : 6]
Input [3]: [isFallbackOrderOnly#16700651, orderDateTime#16700647, prodLocSpecificKpis#16697097]
Condition : NOT (isFallbackOrderOnly#16700651 <=> true)
(80) Project [codegen id : 6]
Output [2]: [orderDateTime#16700647, prodLocSpecificKpis#16697097]
Input [3]: [isFallbackOrderOnly#16700651, orderDateTime#16700647, prodLocSpecificKpis#16697097]
(81) Scan parquet
Output [2]: [insightConfigurations#16700428, shardId#16700429]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000000548]
PartitionFilters: [isnotnull(shardId#16700429), (shardId#16700429 = 0_3_10000000548)]
PushedFilters: [IsNotNull(insightConfigurations)]
ReadSchema: struct<insightConfigurations:map<string,struct<configurationVersion:string,name:string,settings:array<struct<name:string,type:string,value:string>>,status:string>>>
(82) ColumnarToRow [codegen id : 7]
Input [2]: [insightConfigurations#16700428, shardId#16700429]
(83) Filter [codegen id : 7]
Input [2]: [insightConfigurations#16700428, shardId#16700429]
Condition : (isnotnull(insightConfigurations#16700428) AND isnotnull(insightConfigurations#16700428[POTENTIAL_OOS_STOCK_PERIOD]))
(84) Project [codegen id : 7]
Output [1]: [insightConfigurations#16700428[POTENTIAL_OOS_STOCK_PERIOD].settings AS _extract_settings#16704637]
Input [2]: [insightConfigurations#16700428, shardId#16700429]
(85) Exchange
Input [1]: [_extract_settings#16704637]
Arguments: RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=4966462]
(86) BroadcastExchange
Input [1]: [_extract_settings#16704637]
Arguments: IdentityBroadcastMode, [plan_id=4966463]
(87) BroadcastNestedLoopJoin
Join type: Cross
Join condition: ((CASE WHEN (isnull(element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55260#16700433.label = OutOfStockProbability), lambda x_55260#16700433, false)), 1, None, false).value) OR isnull(cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55261#16700434.name = OOS_PROBABILITY_THRESHOLD), lambda x_55261#16700434, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55260#16700435.label = OutOfStockProbability), lambda x_55260#16700435, false)), 1, None, false).value >= cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55261#16700436.name = OOS_PROBABILITY_THRESHOLD), lambda x_55261#16700436, false)), 1, None, false).value as double)) END AND CASE WHEN isnull(element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55262#16700437.label = InitialStockQty), lambda x_55262#16700437, false)), 1, None, false).value) THEN false ELSE (element_at(filter(prodLocSpecificKpis#16697097, lambdafunction((lambda x_55262#16700439.label = InitialStockQty), lambda x_55262#16700439, false)), 1, None, false).value > CASE WHEN cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55263#16700440.name = CURRENT_STOCK_ABOVE_ZERO), lambda x_55263#16700440, false)), 1, None, false).value as boolean) THEN 0.0 ELSE -Infinity END) END) AND CASE WHEN (CASE WHEN isnull(orderDateTime#16700647) THEN true ELSE isnull((cast((unix_timestamp(orderDateTime#16700647, yyyy-MM-dd HH:mm:ss, Some(UTC), false) - 1788358407) as double) / 3600.0)) END OR isnull(cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55264#16700441.name = OFFSET_CURRENT_ORDER_DATE), lambda x_55264#16700441, false)), 1, None, false).value as double))) THEN false ELSE (CASE WHEN isnull(orderDateTime#16700647) THEN null ELSE (cast((unix_timestamp(orderDateTime#16700647, yyyy-MM-dd HH:mm:ss, Some(UTC), false) - 1788358407) as double) / 3600.0) END >= cast(element_at(filter(_extract_settings#16704637, lambdafunction((lambda x_55264#16700442.name = OFFSET_CURRENT_ORDER_DATE), lambda x_55264#16700442, false)), 1, None, false).value as double)) END)
(88) Project [codegen id : 8]
Output: []
Input [3]: [orderDateTime#16700647, prodLocSpecificKpis#16697097, _extract_settings#16704637]
(89) LocalLimit [codegen id : 8]
Input: []
Arguments: 1
(90) InMemoryTableScan
Output [3]: [isFallbackOrderOnly#16700514, qty#16700489, quantityKpis#16700605]
Arguments: [isFallbackOrderOnly#16700514, qty#16700489, quantityKpis#16700605], [NOT (isFallbackOrderOnly#16700514 <=> true)]
(91) InMemoryRelation
Arguments: [shardId#16700479, worklistShardItemId#16700487L, quantityAfterProdPlantOptimization#16700488, qty#16700489, orderProposalId#16700492L, originalReplenishmentRunId#16700495L, supplierGroup#16700502, supplier#16700503, supplyingPlant#16700533, productGroup#16700534, product#16700505, plant#16700506, subrange#16700504, orderDateTime#16700510, deliveryDateTime#16700511, availabilityDateTime#16700512, nextAvailabilityDateTime#16700513, constraintValues#16700527, constraintOperators#16700525, constraintLabels#16700524, logisticUnits#16700529, orderQuantityBaseUom#16700515, orderQuantityBaseUomUuid#16700516, splitIndicator#16700497L, netPriceAmount#16700520, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)
(92) Filter [codegen id : 9]
Input [3]: [isFallbackOrderOnly#16700514, qty#16700489, quantityKpis#16700605]
Condition : NOT (isFallbackOrderOnly#16700514 <=> true)
(93) Project [codegen id : 9]
Output [2]: [qty#16700489, quantityKpis#16700605]
Input [3]: [isFallbackOrderOnly#16700514, qty#16700489, quantityKpis#16700605]
(94) Scan parquet
Output [2]: [insightConfigurations#16700610, shardId#16700611]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/common-data-snapshot/10000000548]
PartitionFilters: [isnotnull(shardId#16700611), (shardId#16700611 = 0_3_10000000548)]
PushedFilters: [IsNotNull(insightConfigurations)]
ReadSchema: struct<insightConfigurations:map<string,struct<configurationVersion:string,name:string,settings:array<struct<name:string,type:string,value:string>>,status:string>>>
(95) ColumnarToRow [codegen id : 10]
Input [2]: [insightConfigurations#16700610, shardId#16700611]
(96) Filter [codegen id : 10]
Input [2]: [insightConfigurations#16700610, shardId#16700611]
Condition : (isnotnull(insightConfigurations#16700610) AND isnotnull(insightConfigurations#16700610[POTENTIAL_OOS_DEMAND_PERIOD]))
(97) Project [codegen id : 10]
Output [1]: [insightConfigurations#16700610[POTENTIAL_OOS_DEMAND_PERIOD].settings AS _extract_settings#16704639]
Input [2]: [insightConfigurations#16700610, shardId#16700611]
(98) Exchange
Input [1]: [_extract_settings#16704639]
Arguments: RoundRobinPartitioning(30), REPARTITION_BY_NUM, [plan_id=4966478]
(99) BroadcastExchange
Input [1]: [_extract_settings#16704639]
Arguments: IdentityBroadcastMode, [plan_id=4966479]
(100) BroadcastNestedLoopJoin
Join type: Cross
Join condition: CASE WHEN (isnull(element_at(filter(element_at(quantityKpis#16700605, qty#16700489, None, false), lambdafunction((lambda x_55266#16700459.label = OutOfStockProbability), lambda x_55266#16700459, false)), 1, None, false).value) OR isnull(cast(element_at(filter(_extract_settings#16704639, lambdafunction((lambda x_55267#16700460.name = OOS_PROBABILITY_THRESHOLD), lambda x_55267#16700460, false)), 1, None, false).value as double))) THEN false ELSE (element_at(filter(element_at(quantityKpis#16700605, qty#16700489, None, false), lambdafunction((lambda x_55266#16700461.label = OutOfStockProbability), lambda x_55266#16700461, false)), 1, None, false).value >= cast(element_at(filter(_extract_settings#16704639, lambdafunction((lambda x_55267#16700462.name = OOS_PROBABILITY_THRESHOLD), lambda x_55267#16700462, false)), 1, None, false).value as double)) END
(101) Project [codegen id : 11]
Output: []
Input [3]: [qty#16700489, quantityKpis#16700605, _extract_settings#16704639]
(102) LocalLimit [codegen id : 11]
Input: []
Arguments: 1
(103) Union
(104) CollectLimit
Input: []
Arguments: 1