digraph G {
subgraph cluster0 {
isCluster="true";
id="cluster0";
label="WholeStageCodegen (2)\n \nduration: 2 ms";
tooltip="WholeStageCodegen (2)";
1 [id="node1" labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 1 ms<br>number of output rows: 1" tooltip="HashAggregate(keys=[], functions=[count(1)])"];
}
2 [id="node2" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 20<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 20<br>local bytes read: 600.0 B<br>merged fetch fallback count: 0<br>local blocks read: 8<br>remote merged chunks fetched: 0<br>remote blocks read: 12<br>data size total (min, med, max (stageId: taskId))<br>320.0 B (16.0 B, 16.0 B, 16.0 B (stage 43905.0: task 124644))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>3 ms (0 ms, 0 ms, 0 ms (stage 43905.0: task 124643))<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: 876.0 B<br>number of partitions: 1<br>remote reqs duration: 1 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>1476.0 B (72.0 B, 75.0 B, 75.0 B (stage 43905.0: task 124644))" tooltip="Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=251046]"];
subgraph cluster3 {
isCluster="true";
id="cluster3";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n22 ms (0 ms, 1 ms, 3 ms (stage 43905.0: task 124690))";
tooltip="WholeStageCodegen (1)";
4 [id="node4" labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build total (min, med, max (stageId: taskId))<br>15 ms (0 ms, 1 ms, 2 ms (stage 43905.0: task 124644))<br>number of output rows: 20" tooltip="HashAggregate(keys=[], functions=[partial_count(1)])"];
5 [id="node5" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project"];
6 [id="node6" labelType="html" label="<b>Generate</b><br><br>number of output rows: 205" tooltip="Generate explode(_extract_deliveryDateTime#596078), false, [numberOfOrderProposalItems#596050]"];
}
7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposal#594659.parentItems.deliveryDateTime AS _extract_deliveryDateTime#596078]"];
8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 14" tooltip="Filter (size(orderProposal#594659.parentItems.deliveryDateTime, true) > 0)"];
9 [id="node9" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 14" tooltip="InMemoryTableScan [orderProposal#594659], [(size(orderProposal#594659.parentItems.deliveryDateTime, true) > 0)]"];
10 [id="node10" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, named_struct(orderProposalId, _extract_orderProposalId#595307L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#595299L, supplierGroup, _extract_supplierGroup#595300, optimizationGroups, coalesce(optimizationGroups#594552, []), supplier, _extract_supplier#595301, supplyingPlant, _extract_supplyingPlant#595302, orderDateTime, _extract_orderDateTime#595303, itemGroups, _extract_itemGroups#595304, previousOrderProposals, _extract_previousOrderProposals#595305, parentItems, _extract_parentItems#595306) AS orderProposal#594659]"];
11 [id="node11" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 14<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43905.0: task 124644))" tooltip="SortMergeJoin [coalesce(shardId#589610, ), isnull(shardId#589610), coalesce(_extract_orderProposalId#595307L, 0), isnull(_extract_orderProposalId#595307L)], [coalesce(shardId#594555, ), isnull(shardId#594555), coalesce(orderProposalId#594556L, 0), isnull(orderProposalId#594556L)], LeftOuter"];
12 [id="node12" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43905.0: task 124644))<br>peak memory total (min, med, max (stageId: taskId))<br>25.3 MiB (64.0 KiB, 2.1 MiB, 2.1 MiB (stage 43905.0: task 124644))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43905.0: task 124644))" tooltip="Sort [coalesce(shardId#589610, ) ASC NULLS FIRST, isnull(shardId#589610) ASC NULLS FIRST, coalesce(_extract_orderProposalId#595307L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#595307L) ASC NULLS FIRST], false, 0"];
13 [id="node13" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 14<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 14<br>local bytes read total (min, med, max (stageId: taskId))<br>47.8 KiB (1816.0 B, 4.9 KiB, 5.3 KiB (stage 43905.0: task 124691))<br>merged fetch fallback count: 0<br>local blocks read: 13<br>remote merged chunks fetched: 0<br>remote blocks read: 1<br>data size total (min, med, max (stageId: taskId))<br>415.6 KiB (12.5 KiB, 39.5 KiB, 82.9 KiB (stage 43904.0: task 124623))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>5 ms (0 ms, 0 ms, 0 ms (stage 43904.0: task 124620))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43905.0: task 124644))<br>remote bytes read: 5.4 KiB<br>number of partitions: 20<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>53.3 KiB (2.0 KiB, 4.9 KiB, 10.3 KiB (stage 43904.0: task 124623))" tooltip="Exchange hashpartitioning(coalesce(shardId#589610, ), isnull(shardId#589610), coalesce(_extract_orderProposalId#595307L, 0), isnull(_extract_orderProposalId#595307L), 20), ENSURE_REQUIREMENTS, [plan_id=250895]"];
14 [id="node14" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, orderProposal#594532.orderProposalId AS _extract_orderProposalId#595298L, orderProposal#594532.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#595299L, orderProposal#594532.supplierGroup AS _extract_supplierGroup#595300, orderProposal#594532.supplier AS _extract_supplier#595301, orderProposal#594532.supplyingPlant AS _extract_supplyingPlant#595302, orderProposal#594532.orderDateTime AS _extract_orderDateTime#595303, orderProposal#594532.itemGroups AS _extract_itemGroups#595304, orderProposal#594532.previousOrderProposals AS _extract_previousOrderProposals#595305, orderProposal#594532.parentItems AS _extract_parentItems#595306, orderProposal#594532.orderProposalId AS _extract_orderProposalId#595307L]"];
15 [id="node15" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, struct(orderProposalId, orderProposalId#590280L, originalReplenishmentRunId, originalReplenishmentRunId#594500L, supplierGroup, supplierGroup#594501, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#594501) THEN supplier#594502 END, supplyingPlant, supplyingPlant#594503, orderDateTime, orderDateTime#594504, itemGroups, itemGroups#594505, previousOrderProposals, array_distinct(previousOrderProposals#594507), parentItems, parentItems#594506) AS orderProposal#594532]"];
16 [id="node16" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 14<br>time in aggregation build total (min, med, max (stageId: taskId))<br>462 ms (0 ms, 10 ms, 60 ms (stage 43904.0: task 124622))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43904.0: task 124568))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#589610, orderProposalId#590280L], functions=[max(originalReplenishmentRunId#594438L), max(supplierGroup#594439), max(supplier#594440), max(supplyingPlant#594441), max(orderDateTime#594442), collect_list(itemGroup#594499, 0, 0), collect_list(parentItems#594443, 0, 0), collect_set(previousOrderProposals#594445, 0, 0)])"];
17 [id="node17" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 21<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 21<br>local bytes read total (min, med, max (stageId: taskId))<br>43.4 KiB (2.1 KiB, 4.3 KiB, 7.2 KiB (stage 43904.0: task 124623))<br>merged fetch fallback count: 0<br>local blocks read: 16<br>remote merged chunks fetched: 0<br>remote blocks read: 4<br>data size total (min, med, max (stageId: taskId))<br>419.4 KiB (10.6 KiB, 38.1 KiB, 60.8 KiB (stage 43900.0: task 124547))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>5 ms (0 ms, 0 ms, 0 ms (stage 43900.0: task 124524))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43904.0: task 124568))<br>remote bytes read total (min, med, max (stageId: taskId))<br>12.1 KiB (3.2 KiB, 4.0 KiB, 4.9 KiB (stage 43904.0: task 124567))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>2 ms (0 ms, 1 ms, 1 ms (stage 43904.0: task 124567))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>55.5 KiB (1890.0 B, 5.0 KiB, 7.5 KiB (stage 43900.0: task 124547))" tooltip="Exchange hashpartitioning(shardId#589610, orderProposalId#590280L, 20), ENSURE_REQUIREMENTS, [plan_id=250891]"];
18 [id="node18" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 21<br>time in aggregation build total (min, med, max (stageId: taskId))<br>285 ms (0 ms, 2 ms, 40 ms (stage 43900.0: task 124525))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43900.0: task 124526))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#589610, orderProposalId#590280L], functions=[partial_max(originalReplenishmentRunId#594438L), partial_max(supplierGroup#594439), partial_max(supplier#594440), partial_max(supplyingPlant#594441), partial_max(orderDateTime#594442), partial_collect_list(itemGroup#594499, 0, 0), partial_collect_list(parentItems#594443, 0, 0), partial_collect_set(previousOrderProposals#594445, 0, 0)])"];
19 [id="node19" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 23<br>time in aggregation build total (min, med, max (stageId: taskId))<br>1.1 s (0 ms, 8 ms, 140 ms (stage 43900.0: task 124527))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43900.0: task 124526))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282], functions=[max(originalReplenishmentRunId#590283L), max(supplierGroup#590290), max(supplier#590291), max(supplyingPlant#590321), max(orderDateTime#590298), collect_list(parentItem#594390, 0, 0), collect_set(previousOrderProposal#590286L, 0, 0), collect_list(item#594421, 0, 0)])"];
20 [id="node20" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 171<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 171<br>local bytes read total (min, med, max (stageId: taskId))<br>100.8 KiB (3.9 KiB, 6.5 KiB, 16.8 KiB (stage 43900.0: task 124547))<br>merged fetch fallback count: 0<br>local blocks read: 73<br>remote merged chunks fetched: 0<br>remote blocks read: 57<br>data size total (min, med, max (stageId: taskId))<br>455.9 KiB (6.8 KiB, 22.4 KiB, 35.4 KiB (stage 43899.0: task 124506))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>14 ms (0 ms, 0 ms, 2 ms (stage 43899.0: task 124499))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43900.0: task 124526))<br>remote bytes read total (min, med, max (stageId: taskId))<br>80.6 KiB (1235.0 B, 7.3 KiB, 15.0 KiB (stage 43900.0: task 124528))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>2 ms (0 ms, 0 ms, 1 ms (stage 43900.0: task 124524))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>181.4 KiB (3.5 KiB, 9.6 KiB, 14.3 KiB (stage 43899.0: task 124506))" tooltip="Exchange hashpartitioning(shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282, 20), ENSURE_REQUIREMENTS, [plan_id=250888]"];
21 [id="node21" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 171<br>time in aggregation build total (min, med, max (stageId: taskId))<br>1.2 s (3 ms, 109 ms, 114 ms (stage 43899.0: task 124487))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282], functions=[partial_max(originalReplenishmentRunId#590283L), partial_max(supplierGroup#590290), partial_max(supplier#590291), partial_max(supplyingPlant#590321), partial_max(orderDateTime#590298), partial_collect_list(parentItem#594390, 0, 0), partial_collect_set(previousOrderProposal#590286L, 0, 0), partial_collect_list(item#594421, 0, 0)])"];
22 [id="node22" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, orderDateTime#590298, splitIndicator#590285L, orderProposalItemGroupId#590282, previousOrderProposal#590286L, parentItem#594390, struct(itemId, orderProposalItemId#590281, supplier, supplier#590291, supplyingPlant, supplyingPlant#590321, productGroup, productGroup#590322, product, product#590293, plant, plant#590294, supplierSubRange, subrange#590292, deliveryDateTime, deliveryDateTime#590299, orderQuantity, coalesce((qty#590124 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594424.isOrderUnit, lambda x_1569#594424, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594425.isOrderUnit, lambda x_1569#594425, false)), 1, None, false).numerator as double))), qty#590124), orderQuantityUom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594426.isOrderUnit, lambda x_1569#594426, false)), 1, None, false).uom, orderQuantityBaseUom#590303), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594427.isOrderUnit, lambda x_1569#594427, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304), orderQuantityInBaseUnit, qty#590124, orderQuantityBaseUom, ... 13 more fields) AS item#594421]"];
23 [id="node23" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, orderProposalItemId#590281, orderProposalItemGroupId#590282, previousOrderProposal#590286L, struct(itemId, 123456, itemGroupId, 123456, supplier, supplier#590291, supplyingPlant, supplyingPlant#590321, productGroup, productGroup#590322, product, product#590293, plant, plant#590294, supplierSubRange, subrange#590292, sourceOfSupplyUuid, sourceOfSupplyUuid#590289, deliveryDateTime, deliveryDateTime#590299, unitPrice, netPriceAmount#590308, unitPriceCurrency, netPriceCurrencyCode#590309, unitPriceQuantity, ... 37 more fields) AS parentItem#594390]"];
24 [id="node24" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, sourceOfSupplyUuid#590289, ... 12 more fields]"];
subgraph cluster25 {
isCluster="true";
id="cluster25";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n3.2 s (29 ms, 281 ms, 287 ms (stage 43899.0: task 124492))";
tooltip="WholeStageCodegen (1)";
26 [id="node26" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, ... 11 more fields]"];
27 [id="node27" labelType="html" label="<b>Filter</b><br><br>number of output rows: 205" tooltip="Filter NOT (isFallbackOrderOnly#590302 <=> true)"];
}
28 [id="node28" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 205" tooltip="InMemoryTableScan [availabilityDateTime#590300, channelStreamSpecificKpis#593752, constraintLabels#590312, constraintOperators#590313, constraintValues#590315, deliveryDateTime#590299, isFallbackOrderOnly#590302, logisticUnits#590317, measurements#590310, minimumOrderQuantity#590311, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, nextAvailabilityDateTime#590301, optimizationGroups#590318, orderDateTime#590298, orderProposalId#590280L, orderProposalItemGroupId#590282, orderProposalItemId#590281, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, originalReplenishmentRunId#590283L, plant#590294, ... 14 more fields], [NOT (isFallbackOrderOnly#590302 <=> true)]"];
subgraph cluster29 {
isCluster="true";
id="cluster29";
label="WholeStageCodegen (13)\n \nduration: total (min, med, max (stageId: taskId))\n464 ms (4 ms, 40 ms, 44 ms (stage 43899.0: task 124491))";
tooltip="WholeStageCodegen (13)";
30 [id="node30" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, ... 17 more fields]"];
31 [id="node31" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 205<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))" tooltip="SortMergeJoin [shardId#589610, worklistShardItemId#590122L], [shardId#593759, worklistShardItemId#593760L], LeftOuter"];
}
subgraph cluster32 {
isCluster="true";
id="cluster32";
label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n2.5 s (8 ms, 230 ms, 242 ms (stage 43899.0: task 124490))";
tooltip="WholeStageCodegen (10)";
33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, ... 16 more fields]"];
34 [id="node34" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 205<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))" tooltip="SortMergeJoin [shardId#589610, worklistShardItemId#590122L], [shardId#593746, worklistShardItemId#593747L], LeftOuter"];
}
subgraph cluster35 {
isCluster="true";
id="cluster35";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n4.4 s (13 ms, 416 ms, 427 ms (stage 43899.0: task 124487))";
tooltip="WholeStageCodegen (7)";
36 [id="node36" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, ... 15 more fields]"];
37 [id="node37" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 205<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))" tooltip="SortMergeJoin [shardId#589610, worklistShardItemId#590122L], [shardId#593730, worklistShardItemId#593731L], LeftOuter"];
}
subgraph cluster38 {
isCluster="true";
id="cluster38";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n7.1 s (15 ms, 487 ms, 745 ms (stage 43899.0: task 124487))";
tooltip="WholeStageCodegen (4)";
39 [id="node39" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 43899.0: task 124491))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))" tooltip="Sort [shardId#589610 ASC NULLS FIRST, worklistShardItemId#590122L ASC NULLS FIRST], false, 0"];
}
40 [id="node40" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 205<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 205<br>local bytes read total (min, med, max (stageId: taskId))<br>60.9 KiB (932.0 B, 2.6 KiB, 6.2 KiB (stage 43899.0: task 124484))<br>merged fetch fallback count: 0<br>local blocks read: 50<br>remote merged chunks fetched: 0<br>remote blocks read: 54<br>data size total (min, med, max (stageId: taskId))<br>258.2 KiB (8.1 KiB, 25.2 KiB, 76.0 KiB (stage 43897.0: task 124407))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>6 ms (0 ms, 0 ms, 0 ms (stage 43897.0: task 124414))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>remote bytes read total (min, med, max (stageId: taskId))<br>62.4 KiB (860.0 B, 2.9 KiB, 6.6 KiB (stage 43899.0: task 124506))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>5 ms (0 ms, 0 ms, 1 ms (stage 43899.0: task 124501))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>123.2 KiB (6.0 KiB, 11.9 KiB, 28.7 KiB (stage 43897.0: task 124407))" tooltip="Exchange hashpartitioning(shardId#589610, worklistShardItemId#590122L, 20), ENSURE_REQUIREMENTS, [plan_id=250616]"];
subgraph cluster41 {
isCluster="true";
id="cluster41";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n41 ms (0 ms, 1 ms, 12 ms (stage 43897.0: task 124395))";
tooltip="WholeStageCodegen (3)";
42 [id="node42" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, ... 14 more fields]"];
43 [id="node43" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 205" tooltip="BroadcastHashJoin [worklistShardItemId#590122L], [worklistShardItemId#590346L], LeftOuter, BuildRight, (shardId#589610 = 0_1_10000002107), false"];
44 [id="node44" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#589610, item#590121.worklistShardItemId AS worklistShardItemId#590122L, item#590121.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#590123, item#590121.qty AS qty#590124]"];
45 [id="node45" labelType="html" label="<b>Generate</b><br><br>number of output rows: 205" tooltip="Generate explode(items#589612), [shardId#589610], false, [item#590121]"];
46 [id="node46" labelType="html" label="<b>Filter</b><br><br>number of output rows: 14" tooltip="Filter ((size(items#589612, true) > 0) AND isnotnull(items#589612))"];
}
47 [id="node47" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 14" tooltip="InMemoryTableScan [shardId#589610, items#589612], [(size(items#589612, true) > 0), isnotnull(items#589612)]"];
subgraph cluster48 {
isCluster="true";
id="cluster48";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
49 [id="node49" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))"];
}
50 [id="node50" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616], [isnotnull(shardId#589610), (shardId#589610 = 0_1_10000002107)]"];
subgraph cluster51 {
isCluster="true";
id="cluster51";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
52 [id="node52" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))"];
53 [id="node53" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#589610,orderProposalId#589611L,items#589612,optimizationGroups#589613,isOptimal#589614,lastModified#589615,optimizationInsights#589616]"];
}
54 [id="node54" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 1 ms<br>time to collect: 606 ms<br>number of output rows: 205<br>data size: 1032.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=250611]"];
subgraph cluster55 {
isCluster="true";
id="cluster55";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n31 ms (0 ms, 2 ms, 3 ms (stage 43842.0: task 124368))";
tooltip="WholeStageCodegen (2)";
56 [id="node56" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#590346L, orderProposalId#590323L, orderProposalItemId#590324, orderProposalItemGroupId#590347, originalReplenishmentRunId#590365L, splitIndicator#590342L, previousOrderProposal#590343L, sourceOfSupplyUuid#590337, supplierGroup#590325, supplier#590326, subrange#590329, product#590332, plant#590327, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, isFallbackOrderOnly#590340, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, netPriceAmount#590359, netPriceCurrencyCode#590360, ... 11 more fields]"];
}
57 [id="node57" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 205<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 205<br>local bytes read total (min, med, max (stageId: taskId))<br>90.1 KiB (1744.0 B, 4.9 KiB, 7.2 KiB (stage 43842.0: task 124370))<br>merged fetch fallback count: 0<br>local blocks read: 94<br>remote merged chunks fetched: 0<br>remote blocks read: 80<br>data size total (min, med, max (stageId: taskId))<br>250.2 KiB (4.8 KiB, 10.5 KiB, 13.5 KiB (stage 43841.0: task 124307))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>13 ms (0 ms, 0 ms, 0 ms (stage 43841.0: task 124323))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43842.0: task 124359))<br>remote bytes read total (min, med, max (stageId: taskId))<br>73.5 KiB (977.0 B, 3.3 KiB, 7.0 KiB (stage 43842.0: task 124368))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>9 ms (0 ms, 0 ms, 1 ms (stage 43842.0: task 124370))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>163.6 KiB (3.5 KiB, 6.7 KiB, 9.2 KiB (stage 43841.0: task 124307))" tooltip="Exchange hashpartitioning(worklistShardItemId#590346L, 20), REPARTITION_BY_NUM, [plan_id=250607]"];
subgraph cluster58 {
isCluster="true";
id="cluster58";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n2.4 s (73 ms, 85 ms, 158 ms (stage 43841.0: task 124309))";
tooltip="WholeStageCodegen (1)";
59 [id="node59" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, ... 11 more fields]"];
60 [id="node60" labelType="html" label="<b>Filter</b><br><br>number of output rows: 205" tooltip="Filter isnotnull(worklistShardItemId#590346L)"];
61 [id="node61" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 205<br>number of input batches: 25" tooltip="ColumnarToRow"];
}
62 [id="node62" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 25<br>scan time total (min, med, max (stageId: taskId))<br>2.1 s (72 ms, 83 ms, 113 ms (stage 43841.0: task 124309))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 520.6 KiB<br>number of output rows: 205<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#590323L,orderProposalItemId#590324,supplierGroup#590325,supplier#590326,plant#590327,deliveryDateTime#590328,subrange#590329,supplyingPlant#590330,productGroup#590331,product#590332,orderDateTime#590333,availabilityDateTime#590334,nextAvailabilityDateTime#590335,sourceOfSupplyUuid#590337,isFallbackOrderOnly#590340,splitIndicator#590342L,previousOrderProposal#590343L,worklistShardItemId#590346L,orderProposalItemGroupId#590347,externalProductId#590348,externalPlantId#590349,logisticUnits#590350,orderQuantityBaseUom#590351,orderQuantityBaseUomUuid#590352,minimumOrderQuantity#590353,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#590346L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#590367), isnotnull(sequenceId#590345), (shardId#590367 = 0_1_10000002107), (se..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,pla..."];
subgraph cluster63 {
isCluster="true";
id="cluster63";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n2.6 s (7 ms, 242 ms, 253 ms (stage 43899.0: task 124490))";
tooltip="WholeStageCodegen (6)";
64 [id="node64" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 43899.0: task 124491))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))" tooltip="Sort [shardId#593730 ASC NULLS FIRST, worklistShardItemId#593731L ASC NULLS FIRST], false, 0"];
}
65 [id="node65" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 205<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 205<br>local bytes read total (min, med, max (stageId: taskId))<br>55.3 KiB (1370.0 B, 2.9 KiB, 5.3 KiB (stage 43899.0: task 124499))<br>merged fetch fallback count: 0<br>local blocks read: 96<br>remote merged chunks fetched: 0<br>remote blocks read: 68<br>data size total (min, med, max (stageId: taskId))<br>214.6 KiB (6.3 KiB, 10.5 KiB, 16.8 KiB (stage 43895.0: task 124437))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>11 ms (0 ms, 0 ms, 0 ms (stage 43895.0: task 124434))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>remote bytes read total (min, med, max (stageId: taskId))<br>38.8 KiB (564.0 B, 1239.0 B, 4.5 KiB (stage 43899.0: task 124509))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>12 ms (0 ms, 0 ms, 2 ms (stage 43899.0: task 124491))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>94.1 KiB (3.3 KiB, 4.7 KiB, 7.2 KiB (stage 43895.0: task 124437))" tooltip="Exchange hashpartitioning(shardId#593730, worklistShardItemId#593731L, 20), ENSURE_REQUIREMENTS, [plan_id=250622]"];
subgraph cluster66 {
isCluster="true";
id="cluster66";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n294 ms (3 ms, 4 ms, 114 ms (stage 43895.0: task 124393))";
tooltip="WholeStageCodegen (5)";
67 [id="node67" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#593730, worklistShardItemId#593731L, coalesce(kpis#593735, []) AS prodLocSpecificKpis#593736]"];
68 [id="node68" labelType="html" label="<b>Filter</b><br><br>number of output rows: 205" tooltip="Filter (((isnull(qty#593732) AND isnull(demandChannel#593733)) AND isnull(demandStream#593734)) AND (isnotnull(shardId#593730) AND isnotnull(worklistShardItemId#593731L)))"];
69 [id="node69" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 817" tooltip="Scan ExistingRDD[shardId#593730,worklistShardItemId#593731L,qty#593732,demandChannel#593733,demandStream#593734,kpis#593735]"];
}
subgraph cluster70 {
isCluster="true";
id="cluster70";
label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n1.7 s (4 ms, 157 ms, 160 ms (stage 43899.0: task 124490))";
tooltip="WholeStageCodegen (9)";
71 [id="node71" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 43899.0: task 124491))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))" tooltip="Sort [shardId#593746 ASC NULLS FIRST, worklistShardItemId#593747L ASC NULLS FIRST], false, 0"];
}
72 [id="node72" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 202<br>time in aggregation build total (min, med, max (stageId: taskId))<br>266 ms (1 ms, 23 ms, 26 ms (stage 43899.0: task 124490))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#593746, worklistShardItemId#593747L], functions=[collect_list(struct(demandChannel, demandChannel#593749, demandStream, demandStream#593750, kpis, kpis#593751), 0, 0)])"];
73 [id="node73" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 202<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 202<br>local bytes read total (min, med, max (stageId: taskId))<br>21.0 KiB (313.0 B, 995.0 B, 2.2 KiB (stage 43899.0: task 124503))<br>merged fetch fallback count: 0<br>local blocks read: 66<br>remote merged chunks fetched: 0<br>remote blocks read: 88<br>data size total (min, med, max (stageId: taskId))<br>82.1 KiB (2.0 KiB, 4.5 KiB, 6.1 KiB (stage 43898.0: task 124467))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>12 ms (0 ms, 0 ms, 0 ms (stage 43898.0: task 124467))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>remote bytes read total (min, med, max (stageId: taskId))<br>27.6 KiB (363.0 B, 1569.0 B, 2.3 KiB (stage 43899.0: task 124506))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>8 ms (0 ms, 0 ms, 1 ms (stage 43899.0: task 124491))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>48.6 KiB (1306.0 B, 2.5 KiB, 3.8 KiB (stage 43898.0: task 124477))" tooltip="Exchange hashpartitioning(shardId#593746, worklistShardItemId#593747L, 20), ENSURE_REQUIREMENTS, [plan_id=250633]"];
74 [id="node74" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 202<br>time in aggregation build total (min, med, max (stageId: taskId))<br>380 ms (2 ms, 3 ms, 150 ms (stage 43898.0: task 124396))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43898.0: task 124392))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#593746, worklistShardItemId#593747L], functions=[partial_collect_list(struct(demandChannel, demandChannel#593749, demandStream, demandStream#593750, kpis, kpis#593751), 0, 0)])"];
subgraph cluster75 {
isCluster="true";
id="cluster75";
label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n380 ms (2 ms, 3 ms, 150 ms (stage 43898.0: task 124396))";
tooltip="WholeStageCodegen (8)";
76 [id="node76" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#593746, worklistShardItemId#593747L, demandChannel#593749, demandStream#593750, kpis#593751]"];
77 [id="node77" labelType="html" label="<b>Filter</b><br><br>number of output rows: 202" tooltip="Filter ((((isnull(qty#593748) AND isnotnull(demandChannel#593749)) AND isnotnull(demandStream#593750)) AND (size(kpis#593751, true) > 0)) AND (isnotnull(shardId#593746) AND isnotnull(worklistShardItemId#593747L)))"];
78 [id="node78" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 817" tooltip="Scan ExistingRDD[shardId#593746,worklistShardItemId#593747L,qty#593748,demandChannel#593749,demandStream#593750,kpis#593751]"];
}
subgraph cluster79 {
isCluster="true";
id="cluster79";
label="WholeStageCodegen (12)\n \nduration: total (min, med, max (stageId: taskId))\n667 ms (2 ms, 64 ms, 65 ms (stage 43899.0: task 124487))";
tooltip="WholeStageCodegen (12)";
80 [id="node80" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 43899.0: task 124491))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))" tooltip="Sort [shardId#593759 ASC NULLS FIRST, worklistShardItemId#593760L ASC NULLS FIRST], false, 0"];
}
81 [id="node81" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 205<br>time in aggregation build total (min, med, max (stageId: taskId))<br>279 ms (1 ms, 24 ms, 28 ms (stage 43899.0: task 124488))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43899.0: task 124491))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#593759, worklistShardItemId#593760L], functions=[collect_list(struct(qty, qty#593761, kpis, kpis#593764), 0, 0)])"];
82 [id="node82" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 401<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 401<br>local bytes read total (min, med, max (stageId: taskId))<br>72.0 KiB (459.0 B, 4.3 KiB, 6.8 KiB (stage 43899.0: task 124503))<br>merged fetch fallback count: 0<br>local blocks read: 151<br>remote merged chunks fetched: 0<br>remote blocks read: 106<br>data size total (min, med, max (stageId: taskId))<br>255.5 KiB (8.8 KiB, 13.0 KiB, 16.8 KiB (stage 43896.0: task 124460))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>16 ms (0 ms, 0 ms, 1 ms (stage 43896.0: task 124451))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43899.0: task 124491))<br>remote bytes read total (min, med, max (stageId: taskId))<br>50.6 KiB (459.0 B, 1863.0 B, 6.8 KiB (stage 43899.0: task 124484))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>11 ms (0 ms, 1 ms, 1 ms (stage 43899.0: task 124491))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>122.6 KiB (4.7 KiB, 6.2 KiB, 8.2 KiB (stage 43896.0: task 124460))" tooltip="Exchange hashpartitioning(shardId#593759, worklistShardItemId#593760L, 20), ENSURE_REQUIREMENTS, [plan_id=250645]"];
83 [id="node83" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 401<br>time in aggregation build total (min, med, max (stageId: taskId))<br>450 ms (3 ms, 3 ms, 181 ms (stage 43896.0: task 124394))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43896.0: task 124394))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#593759, worklistShardItemId#593760L], functions=[partial_collect_list(struct(qty, qty#593761, kpis, kpis#593764), 0, 0)])"];
subgraph cluster84 {
isCluster="true";
id="cluster84";
label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n450 ms (3 ms, 3 ms, 181 ms (stage 43896.0: task 124394))";
tooltip="WholeStageCodegen (11)";
85 [id="node85" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#593759, worklistShardItemId#593760L, qty#593761, kpis#593764]"];
86 [id="node86" labelType="html" label="<b>Filter</b><br><br>number of output rows: 410" tooltip="Filter ((isnotnull(qty#593761) AND isnotnull(kpis#593764)) AND (isnotnull(shardId#593759) AND isnotnull(worklistShardItemId#593760L)))"];
87 [id="node87" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 817" tooltip="Scan ExistingRDD[shardId#593759,worklistShardItemId#593760L,qty#593761,demandChannel#593762,demandStream#593763,kpis#593764]"];
}
subgraph cluster88 {
isCluster="true";
id="cluster88";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n2.6 s (6 ms, 207 ms, 253 ms (stage 43905.0: task 124644))";
tooltip="WholeStageCodegen (7)";
89 [id="node89" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43905.0: task 124644))<br>peak memory total (min, med, max (stageId: taskId))<br>25.3 MiB (64.0 KiB, 2.1 MiB, 2.1 MiB (stage 43905.0: task 124644))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 43905.0: task 124644))" tooltip="Sort [coalesce(shardId#594555, ) ASC NULLS FIRST, isnull(shardId#594555) ASC NULLS FIRST, coalesce(orderProposalId#594556L, 0) ASC NULLS FIRST, isnull(orderProposalId#594556L) ASC NULLS FIRST], false, 0"];
}
90 [id="node90" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 14<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 14<br>local bytes read total (min, med, max (stageId: taskId))<br>2.8 KiB (113.0 B, 520.0 B, 730.0 B (stage 43905.0: task 124643))<br>merged fetch fallback count: 0<br>local blocks read: 7<br>remote merged chunks fetched: 0<br>remote blocks read: 7<br>data size total (min, med, max (stageId: taskId))<br>7.3 KiB (56.0 B, 544.0 B, 1040.0 B (stage 43903.0: task 124541))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>4 ms (0 ms, 0 ms, 0 ms (stage 43903.0: task 124536))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43905.0: task 124644))<br>remote bytes read total (min, med, max (stageId: taskId))<br>3.7 KiB (478.0 B, 511.0 B, 735.0 B (stage 43905.0: task 124729))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>2 ms (0 ms, 0 ms, 1 ms (stage 43905.0: task 124641))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>6.5 KiB (113.0 B, 513.0 B, 984.0 B (stage 43903.0: task 124571))" tooltip="Exchange hashpartitioning(coalesce(shardId#594555, ), isnull(shardId#594555), coalesce(orderProposalId#594556L, 0), isnull(orderProposalId#594556L), 20), ENSURE_REQUIREMENTS, [plan_id=250928]"];
91 [id="node91" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#594556L, shardId#594555, coalesce(transform(optimizationGroups#594558, lambdafunction(struct(optGroupId, lambda x_1573#594553.optGroupId, minOrderProfile, lambda x_1573#594553.minOrderProfile, assignmentDetails, lambda x_1573#594553.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_1573#594553.minOrderGoal.dimensionType, unit, lambda x_1573#594553.minOrderGoal.unit, unitUuid, lambda x_1573#594553.minOrderGoal.unitUuid, goalValue, lambda x_1573#594553.minOrderGoal.minOrderValue, calcValue, lambda x_1573#594553.minOrderGoal.calculatedOrderValue), transportLoadProfile, DummyTloProfile01, transportLoadGoal, [3,5000.0,false,PAL,a7f3c91d204eb8f56d12a09e3b785c4f,TON,b4e8d1f0c73a92e61d05b8f4a291c07e,40.0]), lambda x_1573#594553, false)), []) AS optimizationGroups#594552]"];
subgraph cluster92 {
isCluster="true";
id="cluster92";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n400 ms (1 ms, 3 ms, 213 ms (stage 43903.0: task 124534))";
tooltip="WholeStageCodegen (6)";
93 [id="node93" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 14" tooltip="BroadcastHashJoin [orderProposalId#594556L], [orderProposalId#594611L], Inner, BuildLeft, false"];
104 [id="node104" 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>11 ms (0 ms, 0 ms, 2 ms (stage 43903.0: task 124561))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 43903.0: task 124534))<br>number of output rows: 14<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#594611L], functions=[])"];
}
94 [id="node94" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 285 ms<br>number of output rows: 14<br>data size: 1024.5 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=250900]"];
subgraph cluster95 {
isCluster="true";
id="cluster95";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n9 ms (0 ms, 0 ms, 2 ms (stage 43840.0: task 124320))";
tooltip="WholeStageCodegen (2)";
96 [id="node96" labelType="html" label="<b>Filter</b><br><br>number of output rows: 14" tooltip="Filter isnotnull(orderProposalId#594556L)"];
}
97 [id="node97" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 14" tooltip="InMemoryTableScan [shardId#594555, orderProposalId#594556L, optimizationGroups#594558], [isnotnull(orderProposalId#594556L)]"];
subgraph cluster98 {
isCluster="true";
id="cluster98";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
99 [id="node99" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))"];
}
100 [id="node100" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616], [isnotnull(shardId#589610), (shardId#589610 = 0_1_10000002107)]"];
subgraph cluster101 {
isCluster="true";
id="cluster101";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
102 [id="node102" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))"];
103 [id="node103" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#589610,orderProposalId#589611L,items#589612,optimizationGroups#589613,isOptimal#589614,lastModified#589615,optimizationInsights#589616]"];
}
105 [id="node105" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 143<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 143<br>local bytes read total (min, med, max (stageId: taskId))<br>7.9 KiB (75.0 B, 825.0 B, 1180.0 B (stage 43903.0: task 124536))<br>merged fetch fallback count: 0<br>local blocks read: 106<br>remote merged chunks fetched: 0<br>remote blocks read: 23<br>data size total (min, med, max (stageId: taskId))<br>2.2 KiB (64.0 B, 112.0 B, 160.0 B (stage 43902.0: task 124496))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>13 ms (0 ms, 0 ms, 1 ms (stage 43902.0: task 124515))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43903.0: task 124534))<br>remote bytes read total (min, med, max (stageId: taskId))<br>1780.0 B (75.0 B, 225.0 B, 300.0 B (stage 43903.0: task 124541))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>1 ms (0 ms, 0 ms, 1 ms (stage 43903.0: task 124573))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>9.6 KiB (236.0 B, 450.0 B, 750.0 B (stage 43902.0: task 124496))" tooltip="Exchange hashpartitioning(orderProposalId#594611L, 20), ENSURE_REQUIREMENTS, [plan_id=250922]"];
subgraph cluster106 {
isCluster="true";
id="cluster106";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n683 ms (1 ms, 32 ms, 74 ms (stage 43902.0: task 124523))";
tooltip="WholeStageCodegen (5)";
107 [id="node107" 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>49 ms (0 ms, 1 ms, 30 ms (stage 43902.0: task 124515))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 43902.0: task 124497))<br>number of output rows: 143<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#594611L], functions=[])"];
108 [id="node108" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#594611L]"];
109 [id="node109" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 205" tooltip="BroadcastHashJoin [worklistShardItemId#594563L], [worklistShardItemId#594634L], Inner, BuildLeft, false"];
123 [id="node123" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#594634L, orderProposalId#594611L]"];
}
110 [id="node110" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 1 ms<br>time to build: 1 ms<br>time to collect: 160 ms<br>number of output rows: 205<br>data size: 1032.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=250908]"];
subgraph cluster111 {
isCluster="true";
id="cluster111";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n14 ms (0 ms, 1 ms, 2 ms (stage 43839.0: task 124297))";
tooltip="WholeStageCodegen (3)";
112 [id="node112" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#594562L AS worklistShardItemId#594563L]"];
113 [id="node113" labelType="html" label="<b>Generate</b><br><br>number of output rows: 205" tooltip="Generate explode(_extract_worklistShardItemId#595203), false, [item#594562L]"];
114 [id="node114" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#594174.worklistShardItemId AS _extract_worklistShardItemId#595203]"];
115 [id="node115" labelType="html" label="<b>Filter</b><br><br>number of output rows: 14" tooltip="Filter (((size(items#594174.worklistShardItemId, true) > 0) AND isnotnull(items#594174.worklistShardItemId)) AND (shardId#594172 = 0_1_10000002107))"];
}
116 [id="node116" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 14" tooltip="InMemoryTableScan [items#594174, shardId#594172], [(size(items#594174.worklistShardItemId, true) > 0), isnotnull(items#594174.worklistShardItemId), (shardId#594172 = 0_1_10000002107)]"];
subgraph cluster117 {
isCluster="true";
id="cluster117";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
118 [id="node118" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))"];
}
119 [id="node119" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616], [isnotnull(shardId#589610), (shardId#589610 = 0_1_10000002107)]"];
subgraph cluster120 {
isCluster="true";
id="cluster120";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
121 [id="node121" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))"];
122 [id="node122" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#589610,orderProposalId#589611L,items#589612,optimizationGroups#589613,isOptimal#589614,lastModified#589615,optimizationInsights#589616]"];
}
124 [id="node124" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 205<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 205<br>local bytes read total (min, med, max (stageId: taskId))<br>7.9 KiB (84.0 B, 420.0 B, 687.0 B (stage 43902.0: task 124515))<br>merged fetch fallback count: 0<br>local blocks read: 93<br>remote merged chunks fetched: 0<br>remote blocks read: 81<br>data size total (min, med, max (stageId: taskId))<br>4.8 KiB (96.0 B, 216.0 B, 264.0 B (stage 43901.0: task 124380))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>13 ms (0 ms, 0 ms, 0 ms (stage 43901.0: task 124420))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 43902.0: task 124497))<br>remote bytes read total (min, med, max (stageId: taskId))<br>6.9 KiB (168.0 B, 420.0 B, 704.0 B (stage 43902.0: task 124495))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>3 ms (0 ms, 0 ms, 1 ms (stage 43902.0: task 124511))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>14.7 KiB (336.0 B, 618.0 B, 856.0 B (stage 43901.0: task 124380))" tooltip="Exchange hashpartitioning(worklistShardItemId#594634L, 20), REPARTITION_BY_NUM, [plan_id=250915]"];
subgraph cluster125 {
isCluster="true";
id="cluster125";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n3.1 s (88 ms, 118 ms, 173 ms (stage 43901.0: task 124483))";
tooltip="WholeStageCodegen (4)";
126 [id="node126" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#594611L, worklistShardItemId#594634L]"];
127 [id="node127" labelType="html" label="<b>Filter</b><br><br>number of output rows: 205" tooltip="Filter ((isnotnull(worklistShardItemId#594634L) AND NOT (isFallbackOrderOnly#594628 <=> true)) AND isnotnull(orderProposalId#594611L))"];
128 [id="node128" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 205<br>number of input batches: 25" tooltip="ColumnarToRow"];
}
129 [id="node129" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 25<br>scan time total (min, med, max (stageId: taskId))<br>2.8 s (87 ms, 107 ms, 172 ms (stage 43901.0: task 124483))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 520.6 KiB<br>number of output rows: 205<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#594611L,isFallbackOrderOnly#594628,worklistShardItemId#594634L,shardId#594655,sequenceId#594633] Batched: true, DataFilters: [isnotnull(worklistShardItemId#594634L), NOT (isFallbackOrderOnly#594628 <=> true), isnotnull(ord..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#594655), isnotnull(sequenceId#594633), (shardId#594655 = 0_1_10000002107), (se..., PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderPro..., ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>"];
2->1;
4->2;
5->4;
6->5;
7->6;
8->7;
9->8;
10->9;
11->10;
12->11;
13->12;
14->13;
15->14;
16->15;
17->16;
18->17;
19->18;
20->19;
21->20;
22->21;
23->22;
24->23;
26->24;
27->26;
28->27;
30->28;
31->30;
33->31;
34->33;
36->34;
37->36;
39->37;
40->39;
42->40;
43->42;
44->43;
45->44;
46->45;
47->46;
49->47;
50->49;
52->50;
53->52;
54->43;
56->54;
57->56;
59->57;
60->59;
61->60;
62->61;
64->37;
65->64;
67->65;
68->67;
69->68;
71->34;
72->71;
73->72;
74->73;
76->74;
77->76;
78->77;
80->31;
81->80;
82->81;
83->82;
85->83;
86->85;
87->86;
89->11;
90->89;
91->90;
93->91;
94->93;
96->94;
97->96;
99->97;
100->99;
102->100;
103->102;
104->93;
105->104;
107->105;
108->107;
109->108;
110->109;
112->110;
113->112;
114->113;
115->114;
116->115;
118->116;
119->118;
121->119;
122->121;
123->109;
124->123;
126->124;
127->126;
128->127;
129->128;
}
== Physical Plan ==
* HashAggregate (100)
+- Exchange (99)
+- * HashAggregate (98)
+- * Project (97)
+- * Generate (96)
+- Project (95)
+- Filter (94)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- Project (93)
+- SortMergeJoin LeftOuter (92)
:- Sort (65)
: +- Exchange (64)
: +- Project (63)
: +- Project (62)
: +- ObjectHashAggregate (61)
: +- Exchange (60)
: +- ObjectHashAggregate (59)
: +- ObjectHashAggregate (58)
: +- Exchange (57)
: +- ObjectHashAggregate (56)
: +- Project (55)
: +- Project (54)
: +- Project (53)
: +- * Project (52)
: +- * Filter (51)
: +- InMemoryTableScan (3)
: +- InMemoryRelation (4)
: +- * Project (50)
: +- * SortMergeJoin LeftOuter (49)
: :- * Project (41)
: : +- * SortMergeJoin LeftOuter (40)
: : :- * Project (32)
: : : +- * SortMergeJoin LeftOuter (31)
: : : :- * Sort (25)
: : : : +- Exchange (24)
: : : : +- * Project (23)
: : : : +- * BroadcastHashJoin LeftOuter BuildRight (22)
: : : : :- * Project (14)
: : : : : +- * Generate (13)
: : : : : +- * Filter (12)
: : : : : +- InMemoryTableScan (5)
: : : : : +- InMemoryRelation (6)
: : : : : +- * Filter (11)
: : : : : +- InMemoryTableScan (7)
: : : : : +- InMemoryRelation (8)
: : : : : +- * Filter (10)
: : : : : +- * Scan ExistingRDD (9)
: : : : +- BroadcastExchange (21)
: : : : +- * Project (20)
: : : : +- Exchange (19)
: : : : +- * Project (18)
: : : : +- * Filter (17)
: : : : +- * ColumnarToRow (16)
: : : : +- Scan parquet (15)
: : : +- * Sort (30)
: : : +- Exchange (29)
: : : +- * Project (28)
: : : +- * Filter (27)
: : : +- * Scan ExistingRDD (26)
: : +- * Sort (39)
: : +- ObjectHashAggregate (38)
: : +- Exchange (37)
: : +- ObjectHashAggregate (36)
: : +- * Project (35)
: : +- * Filter (34)
: : +- * Scan ExistingRDD (33)
: +- * Sort (48)
: +- ObjectHashAggregate (47)
: +- Exchange (46)
: +- ObjectHashAggregate (45)
: +- * Project (44)
: +- * Filter (43)
: +- * Scan ExistingRDD (42)
+- * Sort (91)
+- Exchange (90)
+- Project (89)
+- * BroadcastHashJoin Inner BuildLeft (88)
:- BroadcastExchange (69)
: +- * Filter (68)
: +- InMemoryTableScan (66)
: +- InMemoryRelation (67)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * HashAggregate (87)
+- Exchange (86)
+- * HashAggregate (85)
+- * Project (84)
+- * BroadcastHashJoin Inner BuildLeft (83)
:- BroadcastExchange (76)
: +- * Project (75)
: +- * Generate (74)
: +- * Project (73)
: +- * Filter (72)
: +- InMemoryTableScan (70)
: +- InMemoryRelation (71)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * Project (82)
+- Exchange (81)
+- * Project (80)
+- * Filter (79)
+- * ColumnarToRow (78)
+- Scan parquet (77)
(1) InMemoryTableScan
Output [1]: [orderProposal#594659]
Arguments: [orderProposal#594659], [(size(orderProposal#594659.parentItems.deliveryDateTime, true) > 0)]
(2) InMemoryRelation
Arguments: [shardId#589610, orderProposal#594659], StorageLevel(disk, memory, 2 replicas)
(3) InMemoryTableScan
Output [39]: [availabilityDateTime#590300, channelStreamSpecificKpis#593752, constraintLabels#590312, constraintOperators#590313, constraintValues#590315, deliveryDateTime#590299, isFallbackOrderOnly#590302, logisticUnits#590317, measurements#590310, minimumOrderQuantity#590311, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, nextAvailabilityDateTime#590301, optimizationGroups#590318, orderDateTime#590298, orderProposalId#590280L, orderProposalItemGroupId#590282, orderProposalItemId#590281, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, originalReplenishmentRunId#590283L, plant#590294, previousOrderProposal#590286L, prodLocSpecificKpis#593737, product#590293, productGroup#590322, qty#590124, quantityAfterProdPlantOptimization#590123, quantityKpis#593765, shardId#589610, sourceOfSupplyUuid#590289, splitIndicator#590285L, subrange#590292, supplier#590291, supplierGroup#590290, supplyingPlant#590321]
Arguments: [availabilityDateTime#590300, channelStreamSpecificKpis#593752, constraintLabels#590312, constraintOperators#590313, constraintValues#590315, deliveryDateTime#590299, isFallbackOrderOnly#590302, logisticUnits#590317, measurements#590310, minimumOrderQuantity#590311, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, nextAvailabilityDateTime#590301, optimizationGroups#590318, orderDateTime#590298, orderProposalId#590280L, orderProposalItemGroupId#590282, orderProposalItemId#590281, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, originalReplenishmentRunId#590283L, plant#590294, ... 14 more fields], [NOT (isFallbackOrderOnly#590302 <=> true)]
(4) InMemoryRelation
Arguments: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, constraintValues#590315, constraintOperators#590313, constraintLabels#590312, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)
(5) InMemoryTableScan
Output [2]: [shardId#589610, items#589612]
Arguments: [shardId#589610, items#589612], [(size(items#589612, true) > 0), isnotnull(items#589612)]
(6) InMemoryRelation
Arguments: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616], StorageLevel(disk, memory, 2 replicas)
(7) InMemoryTableScan
Output [6]: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616]
Arguments: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616], [isnotnull(shardId#589610), (shardId#589610 = 0_1_10000002107)]
(8) InMemoryRelation
Arguments: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, lastModified#589615, optimizationInsights#589616], StorageLevel(disk, memory, 2 replicas)
(9) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, lastModified#589615, optimizationInsights#589616]
Arguments: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, lastModified#589615, optimizationInsights#589616], MapPartitionsRDD[28419] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(10) Filter [codegen id : 1]
Input [7]: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, lastModified#589615, optimizationInsights#589616]
Condition : (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))
(11) Filter [codegen id : 1]
Input [6]: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616]
Condition : (isnotnull(shardId#589610) AND (shardId#589610 = 0_1_10000002107))
(12) Filter [codegen id : 3]
Input [2]: [shardId#589610, items#589612]
Condition : ((size(items#589612, true) > 0) AND isnotnull(items#589612))
(13) Generate [codegen id : 3]
Input [2]: [shardId#589610, items#589612]
Arguments: explode(items#589612), [shardId#589610], false, [item#590121]
(14) Project [codegen id : 3]
Output [4]: [shardId#589610, item#590121.worklistShardItemId AS worklistShardItemId#590122L, item#590121.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#590123, item#590121.qty AS qty#590124]
Input [2]: [shardId#589610, item#590121]
(15) Scan parquet
Output [38]: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, measurements#590364, originalReplenishmentRunId#590365L, optimizationGroups#590366, shardId#590367, sequenceId#590345]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002107]
PartitionFilters: [isnotnull(shardId#590367), isnotnull(sequenceId#590345), (shardId#590367 = 0_1_10000002107), (sequenceId#590345 = 2)]
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>>
(16) ColumnarToRow [codegen id : 1]
Input [38]: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, measurements#590364, originalReplenishmentRunId#590365L, optimizationGroups#590366, shardId#590367, sequenceId#590345]
(17) Filter [codegen id : 1]
Input [38]: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, measurements#590364, originalReplenishmentRunId#590365L, optimizationGroups#590366, shardId#590367, sequenceId#590345]
Condition : isnotnull(worklistShardItemId#590346L)
(18) Project [codegen id : 1]
Output [36]: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, measurements#590364, originalReplenishmentRunId#590365L, optimizationGroups#590366]
Input [38]: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, measurements#590364, originalReplenishmentRunId#590365L, optimizationGroups#590366, shardId#590367, sequenceId#590345]
(19) Exchange
Input [36]: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, measurements#590364, originalReplenishmentRunId#590365L, optimizationGroups#590366]
Arguments: hashpartitioning(worklistShardItemId#590346L, 20), REPARTITION_BY_NUM, [plan_id=250607]
(20) Project [codegen id : 2]
Output [36]: [worklistShardItemId#590346L, orderProposalId#590323L, orderProposalItemId#590324, orderProposalItemGroupId#590347, originalReplenishmentRunId#590365L, splitIndicator#590342L, previousOrderProposal#590343L, sourceOfSupplyUuid#590337, supplierGroup#590325, supplier#590326, subrange#590329, product#590332, plant#590327, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, isFallbackOrderOnly#590340, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, netPriceAmount#590359, netPriceCurrencyCode#590360, measurements#590364, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, logisticUnits#590350, optimizationGroups#590366, externalProductId#590348, externalPlantId#590349, supplyingPlant#590330, productGroup#590331]
Input [36]: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, sourceOfSupplyUuid#590337, isFallbackOrderOnly#590340, splitIndicator#590342L, previousOrderProposal#590343L, worklistShardItemId#590346L, orderProposalItemGroupId#590347, externalProductId#590348, externalPlantId#590349, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, measurements#590364, originalReplenishmentRunId#590365L, optimizationGroups#590366]
(21) BroadcastExchange
Input [36]: [worklistShardItemId#590346L, orderProposalId#590323L, orderProposalItemId#590324, orderProposalItemGroupId#590347, originalReplenishmentRunId#590365L, splitIndicator#590342L, previousOrderProposal#590343L, sourceOfSupplyUuid#590337, supplierGroup#590325, supplier#590326, subrange#590329, product#590332, plant#590327, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, isFallbackOrderOnly#590340, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, netPriceAmount#590359, netPriceCurrencyCode#590360, measurements#590364, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, logisticUnits#590350, optimizationGroups#590366, externalProductId#590348, externalPlantId#590349, supplyingPlant#590330, productGroup#590331]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=250611]
(22) BroadcastHashJoin [codegen id : 3]
Left keys [1]: [worklistShardItemId#590122L]
Right keys [1]: [worklistShardItemId#590346L]
Join type: LeftOuter
Join condition: (shardId#589610 = 0_1_10000002107)
(23) Project [codegen id : 3]
Output [39]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340]
Input [40]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, worklistShardItemId#590346L, orderProposalId#590323L, orderProposalItemId#590324, orderProposalItemGroupId#590347, originalReplenishmentRunId#590365L, splitIndicator#590342L, previousOrderProposal#590343L, sourceOfSupplyUuid#590337, supplierGroup#590325, supplier#590326, subrange#590329, product#590332, plant#590327, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, isFallbackOrderOnly#590340, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, netPriceAmount#590359, netPriceCurrencyCode#590360, measurements#590364, minimumOrderQuantity#590353, constraintLabels#590354, constraintOperators#590355, constraintValues#590356, logisticUnits#590350, optimizationGroups#590366, externalProductId#590348, externalPlantId#590349, supplyingPlant#590330, productGroup#590331]
(24) Exchange
Input [39]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340]
Arguments: hashpartitioning(shardId#589610, worklistShardItemId#590122L, 20), ENSURE_REQUIREMENTS, [plan_id=250616]
(25) Sort [codegen id : 4]
Input [39]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340]
Arguments: [shardId#589610 ASC NULLS FIRST, worklistShardItemId#590122L ASC NULLS FIRST], false, 0
(26) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#593730, worklistShardItemId#593731L, qty#593732, demandChannel#593733, demandStream#593734, kpis#593735]
Arguments: [shardId#593730, worklistShardItemId#593731L, qty#593732, demandChannel#593733, demandStream#593734, kpis#593735], MapPartitionsRDD[28553] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(27) Filter [codegen id : 5]
Input [6]: [shardId#593730, worklistShardItemId#593731L, qty#593732, demandChannel#593733, demandStream#593734, kpis#593735]
Condition : (((isnull(qty#593732) AND isnull(demandChannel#593733)) AND isnull(demandStream#593734)) AND (isnotnull(shardId#593730) AND isnotnull(worklistShardItemId#593731L)))
(28) Project [codegen id : 5]
Output [3]: [shardId#593730, worklistShardItemId#593731L, coalesce(kpis#593735, []) AS prodLocSpecificKpis#593736]
Input [6]: [shardId#593730, worklistShardItemId#593731L, qty#593732, demandChannel#593733, demandStream#593734, kpis#593735]
(29) Exchange
Input [3]: [shardId#593730, worklistShardItemId#593731L, prodLocSpecificKpis#593736]
Arguments: hashpartitioning(shardId#593730, worklistShardItemId#593731L, 20), ENSURE_REQUIREMENTS, [plan_id=250622]
(30) Sort [codegen id : 6]
Input [3]: [shardId#593730, worklistShardItemId#593731L, prodLocSpecificKpis#593736]
Arguments: [shardId#593730 ASC NULLS FIRST, worklistShardItemId#593731L ASC NULLS FIRST], false, 0
(31) SortMergeJoin [codegen id : 7]
Left keys [2]: [shardId#589610, worklistShardItemId#590122L]
Right keys [2]: [shardId#593730, worklistShardItemId#593731L]
Join type: LeftOuter
Join condition: None
(32) Project [codegen id : 7]
Output [40]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340, coalesce(prodLocSpecificKpis#593736, []) AS prodLocSpecificKpis#593737]
Input [42]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340, shardId#593730, worklistShardItemId#593731L, prodLocSpecificKpis#593736]
(33) Scan ExistingRDD [codegen id : 8]
Output [6]: [shardId#593746, worklistShardItemId#593747L, qty#593748, demandChannel#593749, demandStream#593750, kpis#593751]
Arguments: [shardId#593746, worklistShardItemId#593747L, qty#593748, demandChannel#593749, demandStream#593750, kpis#593751], MapPartitionsRDD[28553] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(34) Filter [codegen id : 8]
Input [6]: [shardId#593746, worklistShardItemId#593747L, qty#593748, demandChannel#593749, demandStream#593750, kpis#593751]
Condition : ((((isnull(qty#593748) AND isnotnull(demandChannel#593749)) AND isnotnull(demandStream#593750)) AND (size(kpis#593751, true) > 0)) AND (isnotnull(shardId#593746) AND isnotnull(worklistShardItemId#593747L)))
(35) Project [codegen id : 8]
Output [5]: [shardId#593746, worklistShardItemId#593747L, demandChannel#593749, demandStream#593750, kpis#593751]
Input [6]: [shardId#593746, worklistShardItemId#593747L, qty#593748, demandChannel#593749, demandStream#593750, kpis#593751]
(36) ObjectHashAggregate
Input [5]: [shardId#593746, worklistShardItemId#593747L, demandChannel#593749, demandStream#593750, kpis#593751]
Keys [2]: [shardId#593746, worklistShardItemId#593747L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#593749, demandStream, demandStream#593750, kpis, kpis#593751), 0, 0)]
Aggregate Attributes [1]: [buf#593926]
Results [3]: [shardId#593746, worklistShardItemId#593747L, buf#593927]
(37) Exchange
Input [3]: [shardId#593746, worklistShardItemId#593747L, buf#593927]
Arguments: hashpartitioning(shardId#593746, worklistShardItemId#593747L, 20), ENSURE_REQUIREMENTS, [plan_id=250633]
(38) ObjectHashAggregate
Input [3]: [shardId#593746, worklistShardItemId#593747L, buf#593927]
Keys [2]: [shardId#593746, worklistShardItemId#593747L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#593749, demandStream, demandStream#593750, kpis, kpis#593751), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#593749, demandStream, demandStream#593750, kpis, kpis#593751), 0, 0)#593745]
Results [3]: [shardId#593746, worklistShardItemId#593747L, collect_list(struct(demandChannel, demandChannel#593749, demandStream, demandStream#593750, kpis, kpis#593751), 0, 0)#593745 AS channelStreamSpecificKpis#593738]
(39) Sort [codegen id : 9]
Input [3]: [shardId#593746, worklistShardItemId#593747L, channelStreamSpecificKpis#593738]
Arguments: [shardId#593746 ASC NULLS FIRST, worklistShardItemId#593747L ASC NULLS FIRST], false, 0
(40) SortMergeJoin [codegen id : 10]
Left keys [2]: [shardId#589610, worklistShardItemId#590122L]
Right keys [2]: [shardId#593746, worklistShardItemId#593747L]
Join type: LeftOuter
Join condition: None
(41) Project [codegen id : 10]
Output [41]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340, prodLocSpecificKpis#593737, coalesce(channelStreamSpecificKpis#593738, []) AS channelStreamSpecificKpis#593752]
Input [43]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340, prodLocSpecificKpis#593737, shardId#593746, worklistShardItemId#593747L, channelStreamSpecificKpis#593738]
(42) Scan ExistingRDD [codegen id : 11]
Output [6]: [shardId#593759, worklistShardItemId#593760L, qty#593761, demandChannel#593762, demandStream#593763, kpis#593764]
Arguments: [shardId#593759, worklistShardItemId#593760L, qty#593761, demandChannel#593762, demandStream#593763, kpis#593764], MapPartitionsRDD[28553] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(43) Filter [codegen id : 11]
Input [6]: [shardId#593759, worklistShardItemId#593760L, qty#593761, demandChannel#593762, demandStream#593763, kpis#593764]
Condition : ((isnotnull(qty#593761) AND isnotnull(kpis#593764)) AND (isnotnull(shardId#593759) AND isnotnull(worklistShardItemId#593760L)))
(44) Project [codegen id : 11]
Output [4]: [shardId#593759, worklistShardItemId#593760L, qty#593761, kpis#593764]
Input [6]: [shardId#593759, worklistShardItemId#593760L, qty#593761, demandChannel#593762, demandStream#593763, kpis#593764]
(45) ObjectHashAggregate
Input [4]: [shardId#593759, worklistShardItemId#593760L, qty#593761, kpis#593764]
Keys [2]: [shardId#593759, worklistShardItemId#593760L]
Functions [1]: [partial_collect_list(struct(qty, qty#593761, kpis, kpis#593764), 0, 0)]
Aggregate Attributes [1]: [buf#593928]
Results [3]: [shardId#593759, worklistShardItemId#593760L, buf#593929]
(46) Exchange
Input [3]: [shardId#593759, worklistShardItemId#593760L, buf#593929]
Arguments: hashpartitioning(shardId#593759, worklistShardItemId#593760L, 20), ENSURE_REQUIREMENTS, [plan_id=250645]
(47) ObjectHashAggregate
Input [3]: [shardId#593759, worklistShardItemId#593760L, buf#593929]
Keys [2]: [shardId#593759, worklistShardItemId#593760L]
Functions [1]: [collect_list(struct(qty, qty#593761, kpis, kpis#593764), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#593761, kpis, kpis#593764), 0, 0)#593758]
Results [3]: [shardId#593759, worklistShardItemId#593760L, map_from_entries(collect_list(struct(qty, qty#593761, kpis, kpis#593764), 0, 0)#593758) AS quantityKpis#593753]
(48) Sort [codegen id : 12]
Input [3]: [shardId#593759, worklistShardItemId#593760L, quantityKpis#593753]
Arguments: [shardId#593759 ASC NULLS FIRST, worklistShardItemId#593760L ASC NULLS FIRST], false, 0
(49) SortMergeJoin [codegen id : 13]
Left keys [2]: [shardId#589610, worklistShardItemId#590122L]
Right keys [2]: [shardId#593759, worklistShardItemId#593760L]
Join type: LeftOuter
Join condition: None
(50) Project [codegen id : 13]
Output [42]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340, prodLocSpecificKpis#593737, channelStreamSpecificKpis#593752, coalesce(quantityKpis#593753, map(keys: [], values: [])) AS quantityKpis#593765]
Input [44]: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590323L, originalReplenishmentRunId#590365L, supplierGroup#590325, supplier#590326, supplyingPlant#590330, productGroup#590331, product#590332, plant#590327, subrange#590329, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, constraintValues#590356, constraintOperators#590355, constraintLabels#590354, logisticUnits#590350, orderQuantityBaseUom#590351, orderQuantityBaseUomUuid#590352, splitIndicator#590342L, netPriceAmount#590359, netPriceCurrencyCode#590360, netPriceQuantity#590361, netPriceQuantityUom#590362, netPriceQuantityUomUuid#590363, sourceOfSupplyUuid#590337, minimumOrderQuantity#590353, orderProposalItemId#590324, orderProposalItemGroupId#590347, optimizationGroups#590366, measurements#590364, externalProductId#590348, externalPlantId#590349, previousOrderProposal#590343L, isFallbackOrderOnly#590340, prodLocSpecificKpis#593737, channelStreamSpecificKpis#593752, shardId#593759, worklistShardItemId#593760L, quantityKpis#593753]
(51) Filter [codegen id : 1]
Input [39]: [availabilityDateTime#590300, channelStreamSpecificKpis#593752, constraintLabels#590312, constraintOperators#590313, constraintValues#590315, deliveryDateTime#590299, isFallbackOrderOnly#590302, logisticUnits#590317, measurements#590310, minimumOrderQuantity#590311, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, nextAvailabilityDateTime#590301, optimizationGroups#590318, orderDateTime#590298, orderProposalId#590280L, orderProposalItemGroupId#590282, orderProposalItemId#590281, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, originalReplenishmentRunId#590283L, plant#590294, previousOrderProposal#590286L, prodLocSpecificKpis#593737, product#590293, productGroup#590322, qty#590124, quantityAfterProdPlantOptimization#590123, quantityKpis#593765, shardId#589610, sourceOfSupplyUuid#590289, splitIndicator#590285L, subrange#590292, supplier#590291, supplierGroup#590290, supplyingPlant#590321]
Condition : NOT (isFallbackOrderOnly#590302 <=> true)
(52) Project [codegen id : 1]
Output [36]: [shardId#589610, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, sourceOfSupplyUuid#590289, minimumOrderQuantity#590311, orderProposalItemId#590281, orderProposalItemGroupId#590282, optimizationGroups#590318, measurements#590310, previousOrderProposal#590286L, prodLocSpecificKpis#593737, channelStreamSpecificKpis#593752, quantityKpis#593765, arrays_zip(constraintLabels#590312, constraintOperators#590313, constraintValues#590315, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#594179]
Input [39]: [availabilityDateTime#590300, channelStreamSpecificKpis#593752, constraintLabels#590312, constraintOperators#590313, constraintValues#590315, deliveryDateTime#590299, isFallbackOrderOnly#590302, logisticUnits#590317, measurements#590310, minimumOrderQuantity#590311, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, nextAvailabilityDateTime#590301, optimizationGroups#590318, orderDateTime#590298, orderProposalId#590280L, orderProposalItemGroupId#590282, orderProposalItemId#590281, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, originalReplenishmentRunId#590283L, plant#590294, previousOrderProposal#590286L, prodLocSpecificKpis#593737, product#590293, productGroup#590322, qty#590124, quantityAfterProdPlantOptimization#590123, quantityKpis#593765, shardId#589610, sourceOfSupplyUuid#590289, splitIndicator#590285L, subrange#590292, supplier#590291, supplierGroup#590290, supplyingPlant#590321]
(53) Project
Output [37]: [shardId#589610, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, sourceOfSupplyUuid#590289, orderProposalItemId#590281, orderProposalItemGroupId#590282, optimizationGroups#590318, measurements#590310, previousOrderProposal#590286L, prodLocSpecificKpis#593737, channelStreamSpecificKpis#593752, quantityKpis#593765, struct(minServiceLevel, array_min(filter(constraintStructArray#594179, lambdafunction((lambda x_1523#594186.constraintLabels = ServiceLevel), lambda x_1523#594186, false)).constraintValues), minServiceLevelMinStock, null, maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#594179, lambdafunction((lambda x_1524#594187.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_1524#594187, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#594179, lambdafunction((lambda x_1525#594188.constraintLabels = RangeOfCoverage), lambda x_1525#594188, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#590311, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#593737, lambdafunction((lambda x_1526#594189.label = NonListingStartTimestamp), lambda x_1526#594189, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#594185, CASE WHEN (qty#590124 <=> quantityAfterProdPlantOptimization#590123) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#590124 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594257.isOrderUnit, lambda x_1527#594257, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594258.isOrderUnit, lambda x_1527#594258, false)), 1, None, false).numerator as double))), qty#590124), orderQuantityUom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594259.isOrderUnit, lambda x_1527#594259, false)), 1, None, false).uom, orderQuantityBaseUom#590303), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594260.isOrderUnit, lambda x_1527#594260, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304), candidateOrderQuantityInBaseUnit, qty#590124, orderQuantityBaseUom, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#590304, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1529#594261.isPreferred AND (((qty#590124 * cast(lambda x_1529#594261.denominator as double)) % cast(lambda x_1529#594261.numerator as double)) = 0.0)), lambda x_1529#594261, false)), lambdafunction(struct(inPreferredQuantity, ((qty#590124 * cast(lambda x_1530#594299.denominator as double)) / cast(lambda x_1530#594299.numerator as double)), uom, lambda x_1530#594299.uom, uomUuid, lambda x_1530#594299.uomUuid), lambda x_1530#594299, false))).inPreferredQuantity, coalesce((qty#590124 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594262.isOrderUnit, lambda x_1528#594262, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594263.isOrderUnit, lambda x_1528#594263, false)), 1, None, false).numerator as double))), qty#590124)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1529#594264.isPreferred AND (((qty#590124 * cast(lambda x_1529#594264.denominator as double)) % cast(lambda x_1529#594264.numerator as double)) = 0.0)), lambda x_1529#594264, false)), lambdafunction(struct(inPreferredQuantity, ((qty#590124 * cast(lambda x_1530#594300.denominator as double)) / cast(lambda x_1530#594300.numerator as double)), uom, lambda x_1530#594300.uom, uomUuid, lambda x_1530#594300.uomUuid), lambda x_1530#594300, false))).uom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594265.isOrderUnit, lambda x_1528#594265, false)), 1, None, false).uom, orderQuantityBaseUom#590303)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1529#594266.isPreferred AND (((qty#590124 * cast(lambda x_1529#594266.denominator as double)) % cast(lambda x_1529#594266.numerator as double)) = 0.0)), lambda x_1529#594266, false)), lambdafunction(struct(inPreferredQuantity, ((qty#590124 * cast(lambda x_1530#594301.denominator as double)) / cast(lambda x_1530#594301.numerator as double)), uom, lambda x_1530#594301.uom, uomUuid, lambda x_1530#594301.uomUuid), lambda x_1530#594301, false))).uomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594267.isOrderUnit, lambda x_1528#594267, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304)), serviceLevel, coalesce(filter(element_at(quantityKpis#593765, qty#590124, None, false), lambdafunction((lambda x_1535#594268.label = ServiceLevel), lambda x_1535#594268, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#590124 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594271.isOrderUnit, lambda x_1527#594271, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594272.isOrderUnit, lambda x_1527#594272, false)), 1, None, false).numerator as double))), qty#590124), orderQuantityUom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594273.isOrderUnit, lambda x_1527#594273, false)), 1, None, false).uom, orderQuantityBaseUom#590303), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1527#594274.isOrderUnit, lambda x_1527#594274, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304), candidateOrderQuantityInBaseUnit, qty#590124, orderQuantityBaseUom, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#590304, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1529#594275.isPreferred AND (((qty#590124 * cast(lambda x_1529#594275.denominator as double)) % cast(lambda x_1529#594275.numerator as double)) = 0.0)), lambda x_1529#594275, false)), lambdafunction(struct(inPreferredQuantity, ((qty#590124 * cast(lambda x_1530#594302.denominator as double)) / cast(lambda x_1530#594302.numerator as double)), uom, lambda x_1530#594302.uom, uomUuid, lambda x_1530#594302.uomUuid), lambda x_1530#594302, false))).inPreferredQuantity, coalesce((qty#590124 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594276.isOrderUnit, lambda x_1528#594276, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594277.isOrderUnit, lambda x_1528#594277, false)), 1, None, false).numerator as double))), qty#590124)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1529#594278.isPreferred AND (((qty#590124 * cast(lambda x_1529#594278.denominator as double)) % cast(lambda x_1529#594278.numerator as double)) = 0.0)), lambda x_1529#594278, false)), lambdafunction(struct(inPreferredQuantity, ((qty#590124 * cast(lambda x_1530#594303.denominator as double)) / cast(lambda x_1530#594303.numerator as double)), uom, lambda x_1530#594303.uom, uomUuid, lambda x_1530#594303.uomUuid), lambda x_1530#594303, false))).uom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594279.isOrderUnit, lambda x_1528#594279, false)), 1, None, false).uom, orderQuantityBaseUom#590303)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1529#594280.isPreferred AND (((qty#590124 * cast(lambda x_1529#594280.denominator as double)) % cast(lambda x_1529#594280.numerator as double)) = 0.0)), lambda x_1529#594280, false)), lambdafunction(struct(inPreferredQuantity, ((qty#590124 * cast(lambda x_1530#594304.denominator as double)) / cast(lambda x_1530#594304.numerator as double)), uom, lambda x_1530#594304.uom, uomUuid, lambda x_1530#594304.uomUuid), lambda x_1530#594304, false))).uomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1528#594281.isOrderUnit, lambda x_1528#594281, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304)), serviceLevel, coalesce(filter(element_at(quantityKpis#593765, qty#590124, None, false), lambdafunction((lambda x_1538#594282.label = ServiceLevel), lambda x_1538#594282, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#590123 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1531#594285.isOrderUnit, lambda x_1531#594285, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1531#594286.isOrderUnit, lambda x_1531#594286, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#590123), orderQuantityUom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1531#594287.isOrderUnit, lambda x_1531#594287, false)), 1, None, false).uom, orderQuantityBaseUom#590303), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1531#594288.isOrderUnit, lambda x_1531#594288, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#590123, orderQuantityBaseUom, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#590304, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1533#594289.isPreferred AND (((quantityAfterProdPlantOptimization#590123 * cast(lambda x_1533#594289.denominator as double)) % cast(lambda x_1533#594289.numerator as double)) = 0.0)), lambda x_1533#594289, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#590123 * cast(lambda x_1534#594305.denominator as double)) / cast(lambda x_1534#594305.numerator as double)), uom, lambda x_1534#594305.uom, uomUuid, lambda x_1534#594305.uomUuid), lambda x_1534#594305, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#590123 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1532#594290.isOrderUnit, lambda x_1532#594290, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1532#594291.isOrderUnit, lambda x_1532#594291, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#590123)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1533#594292.isPreferred AND (((quantityAfterProdPlantOptimization#590123 * cast(lambda x_1533#594292.denominator as double)) % cast(lambda x_1533#594292.numerator as double)) = 0.0)), lambda x_1533#594292, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#590123 * cast(lambda x_1534#594306.denominator as double)) / cast(lambda x_1534#594306.numerator as double)), uom, lambda x_1534#594306.uom, uomUuid, lambda x_1534#594306.uomUuid), lambda x_1534#594306, false))).uom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1532#594293.isOrderUnit, lambda x_1532#594293, false)), 1, None, false).uom, orderQuantityBaseUom#590303)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#590317, lambdafunction((lambda x_1533#594294.isPreferred AND (((quantityAfterProdPlantOptimization#590123 * cast(lambda x_1533#594294.denominator as double)) % cast(lambda x_1533#594294.numerator as double)) = 0.0)), lambda x_1533#594294, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#590123 * cast(lambda x_1534#594307.denominator as double)) / cast(lambda x_1534#594307.numerator as double)), uom, lambda x_1534#594307.uom, uomUuid, lambda x_1534#594307.uomUuid), lambda x_1534#594307, false))).uomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1532#594295.isOrderUnit, lambda x_1532#594295, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304)), serviceLevel, coalesce(filter(element_at(quantityKpis#593765, quantityAfterProdPlantOptimization#590123, None, false), lambdafunction((lambda x_1541#594296.label = ServiceLevel), lambda x_1541#594296, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#594256, coalesce(filter(prodLocSpecificKpis#593737, lambdafunction((lambda x_1544#594309.label = InitialStockQty), lambda x_1544#594309, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#594308, coalesce(filter(prodLocSpecificKpis#593737, lambdafunction((lambda x_1545#594311.label = DemandPeriodEndTimestamp), lambda x_1545#594311, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#594310]
Input [36]: [shardId#589610, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, sourceOfSupplyUuid#590289, minimumOrderQuantity#590311, orderProposalItemId#590281, orderProposalItemGroupId#590282, optimizationGroups#590318, measurements#590310, previousOrderProposal#590286L, prodLocSpecificKpis#593737, channelStreamSpecificKpis#593752, quantityKpis#593765, constraintStructArray#594179]
(54) Project
Output [21]: [shardId#589610, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, orderProposalItemId#590281, orderProposalItemGroupId#590282, previousOrderProposal#590286L, struct(itemId, 123456, itemGroupId, 123456, supplier, supplier#590291, supplyingPlant, supplyingPlant#590321, productGroup, productGroup#590322, product, product#590293, plant, plant#590294, supplierSubRange, subrange#590292, sourceOfSupplyUuid, sourceOfSupplyUuid#590289, deliveryDateTime, deliveryDateTime#590299, unitPrice, netPriceAmount#590308, unitPriceCurrency, netPriceCurrencyCode#590309, unitPriceQuantity, ... 37 more fields) AS parentItem#594390]
Input [37]: [shardId#589610, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, netPriceCurrencyCode#590309, netPriceQuantity#590305, netPriceQuantityUom#590306, netPriceQuantityUomUuid#590307, sourceOfSupplyUuid#590289, orderProposalItemId#590281, orderProposalItemGroupId#590282, optimizationGroups#590318, measurements#590310, previousOrderProposal#590286L, prodLocSpecificKpis#593737, channelStreamSpecificKpis#593752, quantityKpis#593765, constraintBenchmark#594185, calculationAnalysis#594256, inventoryDateTime#594308, demandPeriodEndDateTime#594310]
(55) Project
Output [12]: [shardId#589610, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, orderDateTime#590298, splitIndicator#590285L, orderProposalItemGroupId#590282, previousOrderProposal#590286L, parentItem#594390, struct(itemId, orderProposalItemId#590281, supplier, supplier#590291, supplyingPlant, supplyingPlant#590321, productGroup, productGroup#590322, product, product#590293, plant, plant#590294, supplierSubRange, subrange#590292, deliveryDateTime, deliveryDateTime#590299, orderQuantity, coalesce((qty#590124 * (cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594424.isOrderUnit, lambda x_1569#594424, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594425.isOrderUnit, lambda x_1569#594425, false)), 1, None, false).numerator as double))), qty#590124), orderQuantityUom, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594426.isOrderUnit, lambda x_1569#594426, false)), 1, None, false).uom, orderQuantityBaseUom#590303), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#590317, lambdafunction(lambda x_1569#594427.isOrderUnit, lambda x_1569#594427, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#590304), orderQuantityInBaseUnit, qty#590124, orderQuantityBaseUom, ... 13 more fields) AS item#594421]
Input [21]: [shardId#589610, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, orderProposalItemId#590281, orderProposalItemGroupId#590282, previousOrderProposal#590286L, parentItem#594390]
(56) ObjectHashAggregate
Input [12]: [shardId#589610, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, orderDateTime#590298, splitIndicator#590285L, orderProposalItemGroupId#590282, previousOrderProposal#590286L, parentItem#594390, item#594421]
Keys [4]: [shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282]
Functions [8]: [partial_max(originalReplenishmentRunId#590283L), partial_max(supplierGroup#590290), partial_max(supplier#590291), partial_max(supplyingPlant#590321), partial_max(orderDateTime#590298), partial_collect_list(parentItem#594390, 0, 0), partial_collect_set(previousOrderProposal#590286L, 0, 0), partial_collect_list(item#594421, 0, 0)]
Aggregate Attributes [8]: [max#595682L, max#595683, max#595684, max#595685, max#595686, buf#595687, buf#595688, buf#595689]
Results [12]: [shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282, max#595690L, max#595691, max#595692, max#595693, max#595694, buf#595695, buf#595696, buf#595697]
(57) Exchange
Input [12]: [shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282, max#595690L, max#595691, max#595692, max#595693, max#595694, buf#595695, buf#595696, buf#595697]
Arguments: hashpartitioning(shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282, 20), ENSURE_REQUIREMENTS, [plan_id=250888]
(58) ObjectHashAggregate
Input [12]: [shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282, max#595690L, max#595691, max#595692, max#595693, max#595694, buf#595695, buf#595696, buf#595697]
Keys [4]: [shardId#589610, orderProposalId#590280L, splitIndicator#590285L, orderProposalItemGroupId#590282]
Functions [8]: [max(originalReplenishmentRunId#590283L), max(supplierGroup#590290), max(supplier#590291), max(supplyingPlant#590321), max(orderDateTime#590298), collect_list(parentItem#594390, 0, 0), collect_set(previousOrderProposal#590286L, 0, 0), collect_list(item#594421, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#590283L)#594490L, max(supplierGroup#590290)#594491, max(supplier#590291)#594492, max(supplyingPlant#590321)#594493, max(orderDateTime#590298)#594494, collect_list(parentItem#594390, 0, 0)#594495, collect_set(previousOrderProposal#590286L, 0, 0)#594497, collect_list(item#594421, 0, 0)#594496]
Results [10]: [shardId#589610, orderProposalId#590280L, max(originalReplenishmentRunId#590283L)#594490L AS originalReplenishmentRunId#594438L, max(supplierGroup#590290)#594491 AS supplierGroup#594439, max(supplier#590291)#594492 AS supplier#594440, max(supplyingPlant#590321)#594493 AS supplyingPlant#594441, max(orderDateTime#590298)#594494 AS orderDateTime#594442, collect_list(parentItem#594390, 0, 0)#594495 AS parentItems#594443, collect_set(previousOrderProposal#590286L, 0, 0)#594497 AS previousOrderProposals#594445, struct(itemGroupId, coalesce(orderProposalItemGroupId#590282, cast((monotonically_increasing_id() % 9999999999) as string)), items, collect_list(item#594421, 0, 0)#594496) AS itemGroup#594499]
(59) ObjectHashAggregate
Input [10]: [shardId#589610, orderProposalId#590280L, originalReplenishmentRunId#594438L, supplierGroup#594439, supplier#594440, supplyingPlant#594441, orderDateTime#594442, parentItems#594443, previousOrderProposals#594445, itemGroup#594499]
Keys [2]: [shardId#589610, orderProposalId#590280L]
Functions [8]: [partial_max(originalReplenishmentRunId#594438L), partial_max(supplierGroup#594439), partial_max(supplier#594440), partial_max(supplyingPlant#594441), partial_max(orderDateTime#594442), partial_collect_list(itemGroup#594499, 0, 0), partial_collect_list(parentItems#594443, 0, 0), partial_collect_set(previousOrderProposals#594445, 0, 0)]
Aggregate Attributes [8]: [max#595666L, max#595667, max#595668, max#595669, max#595670, buf#595671, buf#595672, buf#595673]
Results [10]: [shardId#589610, orderProposalId#590280L, max#595674L, max#595675, max#595676, max#595677, max#595678, buf#595679, buf#595680, buf#595681]
(60) Exchange
Input [10]: [shardId#589610, orderProposalId#590280L, max#595674L, max#595675, max#595676, max#595677, max#595678, buf#595679, buf#595680, buf#595681]
Arguments: hashpartitioning(shardId#589610, orderProposalId#590280L, 20), ENSURE_REQUIREMENTS, [plan_id=250891]
(61) ObjectHashAggregate
Input [10]: [shardId#589610, orderProposalId#590280L, max#595674L, max#595675, max#595676, max#595677, max#595678, buf#595679, buf#595680, buf#595681]
Keys [2]: [shardId#589610, orderProposalId#590280L]
Functions [8]: [max(originalReplenishmentRunId#594438L), max(supplierGroup#594439), max(supplier#594440), max(supplyingPlant#594441), max(orderDateTime#594442), collect_list(itemGroup#594499, 0, 0), collect_list(parentItems#594443, 0, 0), collect_set(previousOrderProposals#594445, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#594438L)#594521L, max(supplierGroup#594439)#594522, max(supplier#594440)#594523, max(supplyingPlant#594441)#594524, max(orderDateTime#594442)#594525, collect_list(itemGroup#594499, 0, 0)#594526, collect_list(parentItems#594443, 0, 0)#594527, collect_set(previousOrderProposals#594445, 0, 0)#594528]
Results [10]: [shardId#589610, orderProposalId#590280L, max(originalReplenishmentRunId#594438L)#594521L AS originalReplenishmentRunId#594500L, max(supplierGroup#594439)#594522 AS supplierGroup#594501, max(supplier#594440)#594523 AS supplier#594502, max(supplyingPlant#594441)#594524 AS supplyingPlant#594503, max(orderDateTime#594442)#594525 AS orderDateTime#594504, collect_list(itemGroup#594499, 0, 0)#594526 AS itemGroups#594505, flatten(collect_list(parentItems#594443, 0, 0)#594527) AS parentItems#594506, flatten(collect_set(previousOrderProposals#594445, 0, 0)#594528) AS previousOrderProposals#594507]
(62) Project
Output [2]: [shardId#589610, struct(orderProposalId, orderProposalId#590280L, originalReplenishmentRunId, originalReplenishmentRunId#594500L, supplierGroup, supplierGroup#594501, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#594501) THEN supplier#594502 END, supplyingPlant, supplyingPlant#594503, orderDateTime, orderDateTime#594504, itemGroups, itemGroups#594505, previousOrderProposals, array_distinct(previousOrderProposals#594507), parentItems, parentItems#594506) AS orderProposal#594532]
Input [10]: [shardId#589610, orderProposalId#590280L, originalReplenishmentRunId#594500L, supplierGroup#594501, supplier#594502, supplyingPlant#594503, orderDateTime#594504, itemGroups#594505, parentItems#594506, previousOrderProposals#594507]
(63) Project
Output [11]: [shardId#589610, orderProposal#594532.orderProposalId AS _extract_orderProposalId#595298L, orderProposal#594532.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#595299L, orderProposal#594532.supplierGroup AS _extract_supplierGroup#595300, orderProposal#594532.supplier AS _extract_supplier#595301, orderProposal#594532.supplyingPlant AS _extract_supplyingPlant#595302, orderProposal#594532.orderDateTime AS _extract_orderDateTime#595303, orderProposal#594532.itemGroups AS _extract_itemGroups#595304, orderProposal#594532.previousOrderProposals AS _extract_previousOrderProposals#595305, orderProposal#594532.parentItems AS _extract_parentItems#595306, orderProposal#594532.orderProposalId AS _extract_orderProposalId#595307L]
Input [2]: [shardId#589610, orderProposal#594532]
(64) Exchange
Input [11]: [shardId#589610, _extract_orderProposalId#595298L, _extract_originalReplenishmentRunId#595299L, _extract_supplierGroup#595300, _extract_supplier#595301, _extract_supplyingPlant#595302, _extract_orderDateTime#595303, _extract_itemGroups#595304, _extract_previousOrderProposals#595305, _extract_parentItems#595306, _extract_orderProposalId#595307L]
Arguments: hashpartitioning(coalesce(shardId#589610, ), isnull(shardId#589610), coalesce(_extract_orderProposalId#595307L, 0), isnull(_extract_orderProposalId#595307L), 20), ENSURE_REQUIREMENTS, [plan_id=250895]
(65) Sort
Input [11]: [shardId#589610, _extract_orderProposalId#595298L, _extract_originalReplenishmentRunId#595299L, _extract_supplierGroup#595300, _extract_supplier#595301, _extract_supplyingPlant#595302, _extract_orderDateTime#595303, _extract_itemGroups#595304, _extract_previousOrderProposals#595305, _extract_parentItems#595306, _extract_orderProposalId#595307L]
Arguments: [coalesce(shardId#589610, ) ASC NULLS FIRST, isnull(shardId#589610) ASC NULLS FIRST, coalesce(_extract_orderProposalId#595307L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#595307L) ASC NULLS FIRST], false, 0
(66) InMemoryTableScan
Output [3]: [shardId#594555, orderProposalId#594556L, optimizationGroups#594558]
Arguments: [shardId#594555, orderProposalId#594556L, optimizationGroups#594558], [isnotnull(orderProposalId#594556L)]
(67) InMemoryRelation
Arguments: [shardId#594555, orderProposalId#594556L, items#594557, optimizationGroups#594558, isOptimal#594559, optimizationInsights#594561], StorageLevel(disk, memory, 2 replicas)
(68) Filter [codegen id : 2]
Input [3]: [shardId#594555, orderProposalId#594556L, optimizationGroups#594558]
Condition : isnotnull(orderProposalId#594556L)
(69) BroadcastExchange
Input [3]: [shardId#594555, orderProposalId#594556L, optimizationGroups#594558]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=250900]
(70) InMemoryTableScan
Output [2]: [items#594174, shardId#594172]
Arguments: [items#594174, shardId#594172], [(size(items#594174.worklistShardItemId, true) > 0), isnotnull(items#594174.worklistShardItemId), (shardId#594172 = 0_1_10000002107)]
(71) InMemoryRelation
Arguments: [shardId#594172, orderProposalId#594173L, items#594174, optimizationGroups#594175, isOptimal#594176, optimizationInsights#594178], StorageLevel(disk, memory, 2 replicas)
(72) Filter [codegen id : 3]
Input [2]: [items#594174, shardId#594172]
Condition : (((size(items#594174.worklistShardItemId, true) > 0) AND isnotnull(items#594174.worklistShardItemId)) AND (shardId#594172 = 0_1_10000002107))
(73) Project [codegen id : 3]
Output [1]: [items#594174.worklistShardItemId AS _extract_worklistShardItemId#595203]
Input [2]: [items#594174, shardId#594172]
(74) Generate [codegen id : 3]
Input [1]: [_extract_worklistShardItemId#595203]
Arguments: explode(_extract_worklistShardItemId#595203), false, [item#594562L]
(75) Project [codegen id : 3]
Output [1]: [item#594562L AS worklistShardItemId#594563L]
Input [1]: [item#594562L]
(76) BroadcastExchange
Input [1]: [worklistShardItemId#594563L]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=250908]
(77) Scan parquet
Output [5]: [orderProposalId#594611L, isFallbackOrderOnly#594628, worklistShardItemId#594634L, shardId#594655, sequenceId#594633]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002107]
PartitionFilters: [isnotnull(shardId#594655), isnotnull(sequenceId#594633), (shardId#594655 = 0_1_10000002107), (sequenceId#594633 = 2)]
PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>
(78) ColumnarToRow [codegen id : 4]
Input [5]: [orderProposalId#594611L, isFallbackOrderOnly#594628, worklistShardItemId#594634L, shardId#594655, sequenceId#594633]
(79) Filter [codegen id : 4]
Input [5]: [orderProposalId#594611L, isFallbackOrderOnly#594628, worklistShardItemId#594634L, shardId#594655, sequenceId#594633]
Condition : ((isnotnull(worklistShardItemId#594634L) AND NOT (isFallbackOrderOnly#594628 <=> true)) AND isnotnull(orderProposalId#594611L))
(80) Project [codegen id : 4]
Output [2]: [orderProposalId#594611L, worklistShardItemId#594634L]
Input [5]: [orderProposalId#594611L, isFallbackOrderOnly#594628, worklistShardItemId#594634L, shardId#594655, sequenceId#594633]
(81) Exchange
Input [2]: [orderProposalId#594611L, worklistShardItemId#594634L]
Arguments: hashpartitioning(worklistShardItemId#594634L, 20), REPARTITION_BY_NUM, [plan_id=250915]
(82) Project
Output [2]: [worklistShardItemId#594634L, orderProposalId#594611L]
Input [2]: [orderProposalId#594611L, worklistShardItemId#594634L]
(83) BroadcastHashJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#594563L]
Right keys [1]: [worklistShardItemId#594634L]
Join type: Inner
Join condition: None
(84) Project [codegen id : 5]
Output [1]: [orderProposalId#594611L]
Input [3]: [worklistShardItemId#594563L, worklistShardItemId#594634L, orderProposalId#594611L]
(85) HashAggregate [codegen id : 5]
Input [1]: [orderProposalId#594611L]
Keys [1]: [orderProposalId#594611L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#594611L]
(86) Exchange
Input [1]: [orderProposalId#594611L]
Arguments: hashpartitioning(orderProposalId#594611L, 20), ENSURE_REQUIREMENTS, [plan_id=250922]
(87) HashAggregate
Input [1]: [orderProposalId#594611L]
Keys [1]: [orderProposalId#594611L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#594611L]
(88) BroadcastHashJoin [codegen id : 6]
Left keys [1]: [orderProposalId#594556L]
Right keys [1]: [orderProposalId#594611L]
Join type: Inner
Join condition: None
(89) Project
Output [3]: [orderProposalId#594556L, shardId#594555, coalesce(transform(optimizationGroups#594558, lambdafunction(struct(optGroupId, lambda x_1573#594553.optGroupId, minOrderProfile, lambda x_1573#594553.minOrderProfile, assignmentDetails, lambda x_1573#594553.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_1573#594553.minOrderGoal.dimensionType, unit, lambda x_1573#594553.minOrderGoal.unit, unitUuid, lambda x_1573#594553.minOrderGoal.unitUuid, goalValue, lambda x_1573#594553.minOrderGoal.minOrderValue, calcValue, lambda x_1573#594553.minOrderGoal.calculatedOrderValue), transportLoadProfile, DummyTloProfile01, transportLoadGoal, [3,5000.0,false,PAL,a7f3c91d204eb8f56d12a09e3b785c4f,TON,b4e8d1f0c73a92e61d05b8f4a291c07e,40.0]), lambda x_1573#594553, false)), []) AS optimizationGroups#594552]
Input [4]: [shardId#594555, orderProposalId#594556L, optimizationGroups#594558, orderProposalId#594611L]
(90) Exchange
Input [3]: [orderProposalId#594556L, shardId#594555, optimizationGroups#594552]
Arguments: hashpartitioning(coalesce(shardId#594555, ), isnull(shardId#594555), coalesce(orderProposalId#594556L, 0), isnull(orderProposalId#594556L), 20), ENSURE_REQUIREMENTS, [plan_id=250928]
(91) Sort [codegen id : 7]
Input [3]: [orderProposalId#594556L, shardId#594555, optimizationGroups#594552]
Arguments: [coalesce(shardId#594555, ) ASC NULLS FIRST, isnull(shardId#594555) ASC NULLS FIRST, coalesce(orderProposalId#594556L, 0) ASC NULLS FIRST, isnull(orderProposalId#594556L) ASC NULLS FIRST], false, 0
(92) SortMergeJoin
Left keys [4]: [coalesce(shardId#589610, ), isnull(shardId#589610), coalesce(_extract_orderProposalId#595307L, 0), isnull(_extract_orderProposalId#595307L)]
Right keys [4]: [coalesce(shardId#594555, ), isnull(shardId#594555), coalesce(orderProposalId#594556L, 0), isnull(orderProposalId#594556L)]
Join type: LeftOuter
Join condition: None
(93) Project
Output [2]: [shardId#589610, named_struct(orderProposalId, _extract_orderProposalId#595307L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#595299L, supplierGroup, _extract_supplierGroup#595300, optimizationGroups, coalesce(optimizationGroups#594552, []), supplier, _extract_supplier#595301, supplyingPlant, _extract_supplyingPlant#595302, orderDateTime, _extract_orderDateTime#595303, itemGroups, _extract_itemGroups#595304, previousOrderProposals, _extract_previousOrderProposals#595305, parentItems, _extract_parentItems#595306) AS orderProposal#594659]
Input [14]: [shardId#589610, _extract_orderProposalId#595298L, _extract_originalReplenishmentRunId#595299L, _extract_supplierGroup#595300, _extract_supplier#595301, _extract_supplyingPlant#595302, _extract_orderDateTime#595303, _extract_itemGroups#595304, _extract_previousOrderProposals#595305, _extract_parentItems#595306, _extract_orderProposalId#595307L, orderProposalId#594556L, shardId#594555, optimizationGroups#594552]
(94) Filter
Input [1]: [orderProposal#594659]
Condition : (size(orderProposal#594659.parentItems.deliveryDateTime, true) > 0)
(95) Project
Output [1]: [orderProposal#594659.parentItems.deliveryDateTime AS _extract_deliveryDateTime#596078]
Input [1]: [orderProposal#594659]
(96) Generate [codegen id : 1]
Input [1]: [_extract_deliveryDateTime#596078]
Arguments: explode(_extract_deliveryDateTime#596078), false, [numberOfOrderProposalItems#596050]
(97) Project [codegen id : 1]
Output: []
Input [1]: [numberOfOrderProposalItems#596050]
(98) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#596089L]
Results [1]: [count#596090L]
(99) Exchange
Input [1]: [count#596090L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=251046]
(100) HashAggregate [codegen id : 2]
Input [1]: [count#596090L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#596055L]
Results [1]: [count(1)#596055L AS count#596051L]