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: 2 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: 30<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 30<br>local bytes read: 1152.0 B<br>merged fetch fallback count: 0<br>local blocks read: 16<br>remote merged chunks fetched: 0<br>remote blocks read: 14<br>data size total (min, med, max (stageId: taskId))<br>480.0 B (16.0 B, 16.0 B, 16.0 B (stage 1575733.0: task 2944812))<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 1575733.0: task 2944804))<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: 1008.0 B<br>number of partitions: 1<br>remote reqs duration: 4 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>2.1 KiB (72.0 B, 72.0 B, 72.0 B (stage 1575733.0: task 2944812))" tooltip="Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=3473980]"];
subgraph cluster3 {
isCluster="true";
id="cluster3";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n30 ms (0 ms, 1 ms, 3 ms (stage 1575733.0: task 2944810))";
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>17 ms (0 ms, 0 ms, 3 ms (stage 1575733.0: task 2944801))<br>number of output rows: 30" 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: 0" tooltip="Generate explode(_extract_deliveryDateTime#6611969), false, [numberOfOrderProposalItems#6611941]"];
}
7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposal#6610550.parentItems.deliveryDateTime AS _extract_deliveryDateTime#6611969]"];
8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (size(orderProposal#6610550.parentItems.deliveryDateTime, true) > 0)"];
9 [id="node9" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [orderProposal#6610550], [(size(orderProposal#6610550.parentItems.deliveryDateTime, true) > 0)]"];
10 [id="node10" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, named_struct(orderProposalId, _extract_orderProposalId#6611198L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#6611190L, supplierGroup, _extract_supplierGroup#6611191, optimizationGroups, coalesce(optimizationGroups#6610443, []), supplier, _extract_supplier#6611192, supplyingPlant, _extract_supplyingPlant#6611193, orderDateTime, _extract_orderDateTime#6611194, itemGroups, _extract_itemGroups#6611195, previousOrderProposals, _extract_previousOrderProposals#6611196, parentItems, _extract_parentItems#6611197) AS orderProposal#6610550]"];
11 [id="node11" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575733.0: task 2944812))" tooltip="SortMergeJoin [coalesce(shardId#6608407, ), isnull(shardId#6608407), coalesce(_extract_orderProposalId#6611198L, 0), isnull(_extract_orderProposalId#6611198L)], [coalesce(shardId#6610446, ), isnull(shardId#6610446), coalesce(orderProposalId#6610447L, 0), isnull(orderProposalId#6610447L)], 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 1575733.0: task 2944812))<br>peak memory total (min, med, max (stageId: taskId))<br>1920.0 KiB (64.0 KiB, 64.0 KiB, 64.0 KiB (stage 1575733.0: task 2944812))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575733.0: task 2944812))" tooltip="Sort [coalesce(shardId#6608407, ) ASC NULLS FIRST, isnull(shardId#6608407) ASC NULLS FIRST, coalesce(_extract_orderProposalId#6611198L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#6611198L) ASC NULLS FIRST], false, 0"];
13 [id="node13" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#6608407, ), isnull(shardId#6608407), coalesce(_extract_orderProposalId#6611198L, 0), isnull(_extract_orderProposalId#6611198L), 30), ENSURE_REQUIREMENTS, [plan_id=3473829]"];
14 [id="node14" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, orderProposal#6610433.orderProposalId AS _extract_orderProposalId#6611189L, orderProposal#6610433.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#6611190L, orderProposal#6610433.supplierGroup AS _extract_supplierGroup#6611191, orderProposal#6610433.supplier AS _extract_supplier#6611192, orderProposal#6610433.supplyingPlant AS _extract_supplyingPlant#6611193, orderProposal#6610433.orderDateTime AS _extract_orderDateTime#6611194, orderProposal#6610433.itemGroups AS _extract_itemGroups#6611195, orderProposal#6610433.previousOrderProposals AS _extract_previousOrderProposals#6611196, orderProposal#6610433.parentItems AS _extract_parentItems#6611197, orderProposal#6610433.orderProposalId AS _extract_orderProposalId#6611198L]"];
15 [id="node15" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, struct(orderProposalId, orderProposalId#6609077L, originalReplenishmentRunId, originalReplenishmentRunId#6610401L, supplierGroup, supplierGroup#6610402, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#6610402) THEN supplier#6610403 END, supplyingPlant, supplyingPlant#6610404, orderDateTime, orderDateTime#6610405, itemGroups, itemGroups#6610406, previousOrderProposals, array_distinct(previousOrderProposals#6610408), parentItems, parentItems#6610407) AS orderProposal#6610433]"];
16 [id="node16" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1575732.0: task 2944774))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6608407, orderProposalId#6609077L], functions=[max(originalReplenishmentRunId#6610339L), max(supplierGroup#6610340), max(supplier#6610341), max(supplyingPlant#6610342), max(orderDateTime#6610343), collect_list(itemGroup#6610400, 0, 0), collect_list(parentItems#6610344, 0, 0), collect_set(previousOrderProposals#6610346, 0, 0)])"];
17 [id="node17" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#6608407, orderProposalId#6609077L, 30), ENSURE_REQUIREMENTS, [plan_id=3473825]"];
18 [id="node18" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1575728.0: task 2944751))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6608407, orderProposalId#6609077L], functions=[partial_max(originalReplenishmentRunId#6610339L), partial_max(supplierGroup#6610340), partial_max(supplier#6610341), partial_max(supplyingPlant#6610342), partial_max(orderDateTime#6610343), partial_collect_list(itemGroup#6610400, 0, 0), partial_collect_list(parentItems#6610344, 0, 0), partial_collect_set(previousOrderProposals#6610346, 0, 0)])"];
19 [id="node19" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1575728.0: task 2944751))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079], functions=[max(originalReplenishmentRunId#6609080L), max(supplierGroup#6609087), max(supplier#6609088), max(supplyingPlant#6609118), max(orderDateTime#6609095), collect_list(parentItem#6610291, 0, 0), collect_set(previousOrderProposal#6609083L, 0, 0), collect_list(item#6610322, 0, 0)])"];
20 [id="node20" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079, 30), ENSURE_REQUIREMENTS, [plan_id=3473822]"];
21 [id="node21" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>10 ms (0 ms, 0 ms, 1 ms (stage 1575727.0: task 2944697))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079], functions=[partial_max(originalReplenishmentRunId#6609080L), partial_max(supplierGroup#6609087), partial_max(supplier#6609088), partial_max(supplyingPlant#6609118), partial_max(orderDateTime#6609095), partial_collect_list(parentItem#6610291, 0, 0), partial_collect_set(previousOrderProposal#6609083L, 0, 0), partial_collect_list(item#6610322, 0, 0)])"];
22 [id="node22" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, orderDateTime#6609095, splitIndicator#6609082L, orderProposalItemGroupId#6609079, previousOrderProposal#6609083L, parentItem#6610291, struct(itemId, orderProposalItemId#6609078, supplier, supplier#6609088, supplyingPlant, supplyingPlant#6609118, productGroup, productGroup#6609119, product, product#6609090, plant, plant#6609091, supplierSubRange, subrange#6609089, deliveryDateTime, deliveryDateTime#6609096, orderQuantity, coalesce((qty#6608921 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610325.isOrderUnit, lambda x_12837#6610325, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610326.isOrderUnit, lambda x_12837#6610326, false)), 1, None, false).numerator as double))), qty#6608921), orderQuantityUom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610327.isOrderUnit, lambda x_12837#6610327, false)), 1, None, false).uom, orderQuantityBaseUom#6609100), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610328.isOrderUnit, lambda x_12837#6610328, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101), orderQuantityInBaseUnit, qty#6608921, orderQuantityBaseUom, ... 13 more fields) AS item#6610322]"];
23 [id="node23" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, orderProposalItemId#6609078, orderProposalItemGroupId#6609079, previousOrderProposal#6609083L, struct(supplier, supplier#6609088, supplyingPlant, supplyingPlant#6609118, productGroup, productGroup#6609119, product, product#6609090, plant, plant#6609091, supplierSubRange, subrange#6609089, sourceOfSupplyUuid, sourceOfSupplyUuid#6609086, deliveryDateTime, deliveryDateTime#6609096, unitPrice, netPriceAmount#6609105, unitPriceCurrency, netPriceCurrencyCode#6609106, unitPriceQuantity, netPriceQuantity#6609102, unitPriceQuantityUom, netPriceQuantityUom#6609103, unitPriceQuantityUomUuid, ... 31 more fields) AS parentItem#6610291]"];
24 [id="node24" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, availabilityDateTime#6609097, nextAvailabilityDateTime#6609098, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, sourceOfSupplyUuid#6609086, ... 12 more fields]"];
subgraph cluster25 {
isCluster="true";
id="cluster25";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n2.1 s (31 ms, 33 ms, 147 ms (stage 1575727.0: task 2944699))";
tooltip="WholeStageCodegen (1)";
26 [id="node26" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, availabilityDateTime#6609097, nextAvailabilityDateTime#6609098, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, ... 11 more fields]"];
27 [id="node27" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter NOT (isFallbackOrderOnly#6609099 <=> true)"];
}
28 [id="node28" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 415" tooltip="InMemoryTableScan [availabilityDateTime#6609097, channelStreamSpecificKpis#6609662, constraintLabels#6609109, constraintOperators#6609110, constraintValues#6609112, deliveryDateTime#6609096, isFallbackOrderOnly#6609099, logisticUnits#6609114, measurements#6609107, minimumOrderQuantity#6609108, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, nextAvailabilityDateTime#6609098, optimizationGroups#6609115, orderDateTime#6609095, orderProposalId#6609077L, orderProposalItemGroupId#6609079, orderProposalItemId#6609078, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, originalReplenishmentRunId#6609080L, plant#6609091, ... 14 more fields], [NOT (isFallbackOrderOnly#6609099 <=> true)]"];
subgraph cluster29 {
isCluster="true";
id="cluster29";
label="WholeStageCodegen (15)\n \nduration: total (min, med, max (stageId: taskId))\n423 ms (4 ms, 8 ms, 29 ms (stage 1575727.0: task 2944696))";
tooltip="WholeStageCodegen (15)";
30 [id="node30" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, ... 17 more fields]"];
31 [id="node31" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 415<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))" tooltip="SortMergeJoin [shardId#6608407, worklistShardItemId#6608919L], [shardId#6609669, worklistShardItemId#6609670L], LeftOuter"];
}
subgraph cluster32 {
isCluster="true";
id="cluster32";
label="WholeStageCodegen (12)\n \nduration: total (min, med, max (stageId: taskId))\n2.0 s (11 ms, 19 ms, 171 ms (stage 1575727.0: task 2944699))";
tooltip="WholeStageCodegen (12)";
33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, ... 16 more fields]"];
34 [id="node34" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 415<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))" tooltip="SortMergeJoin [shardId#6608407, worklistShardItemId#6608919L], [shardId#6609656, worklistShardItemId#6609657L], LeftOuter"];
}
subgraph cluster35 {
isCluster="true";
id="cluster35";
label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n3.3 s (18 ms, 27 ms, 302 ms (stage 1575727.0: task 2944699))";
tooltip="WholeStageCodegen (9)";
36 [id="node36" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, ... 15 more fields]"];
37 [id="node37" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 415<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))" tooltip="SortMergeJoin [shardId#6608407, worklistShardItemId#6608919L], [shardId#6609640, worklistShardItemId#6609641L], LeftOuter"];
}
subgraph cluster38 {
isCluster="true";
id="cluster38";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n4.1 s (19 ms, 28 ms, 379 ms (stage 1575727.0: task 2944697))";
tooltip="WholeStageCodegen (6)";
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 1575727.0: task 2944697))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1575727.0: task 2944697))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))" tooltip="Sort [shardId#6608407 ASC NULLS FIRST, worklistShardItemId#6608919L ASC NULLS FIRST], false, 0"];
}
40 [id="node40" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 415<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 415<br>local bytes read total (min, med, max (stageId: taskId))<br>185.1 KiB (2.7 KiB, 6.1 KiB, 13.5 KiB (stage 1575727.0: task 2944737))<br>merged fetch fallback count: 0<br>local blocks read: 184<br>remote merged chunks fetched: 0<br>remote blocks read: 166<br>data size total (min, med, max (stageId: taskId))<br>535.0 KiB (10.2 KiB, 19.3 KiB, 29.0 KiB (stage 1575725.0: task 2944652))<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>27 ms (0 ms, 0 ms, 1 ms (stage 1575725.0: task 2944669))<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 1575727.0: task 2944697))<br>remote bytes read total (min, med, max (stageId: taskId))<br>165.9 KiB (857.0 B, 5.4 KiB, 9.4 KiB (stage 1575727.0: task 2944725))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>34 ms (0 ms, 1 ms, 5 ms (stage 1575727.0: task 2944738))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>351.0 KiB (6.9 KiB, 12.4 KiB, 18.3 KiB (stage 1575725.0: task 2944652))" tooltip="Exchange hashpartitioning(shardId#6608407, worklistShardItemId#6608919L, 30), ENSURE_REQUIREMENTS, [plan_id=3473541]"];
subgraph cluster41 {
isCluster="true";
id="cluster41";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n158 ms (2 ms, 5 ms, 8 ms (stage 1575725.0: task 2944656))";
tooltip="WholeStageCodegen (5)";
42 [id="node42" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, ... 14 more fields]"];
43 [id="node43" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 415<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575725.0: task 2944658))" tooltip="SortMergeJoin [worklistShardItemId#6608919L], [worklistShardItemId#6609143L], LeftOuter, (shardId#6608407 = 0_1_10000002290)"];
}
subgraph cluster44 {
isCluster="true";
id="cluster44";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n1.6 s (3 ms, 6 ms, 157 ms (stage 1575725.0: task 2944651))";
tooltip="WholeStageCodegen (2)";
45 [id="node45" 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 1575725.0: task 2944658))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1575725.0: task 2944658))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575725.0: task 2944658))" tooltip="Sort [worklistShardItemId#6608919L ASC NULLS FIRST], false, 0"];
}
46 [id="node46" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 415<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 415<br>local bytes read total (min, med, max (stageId: taskId))<br>12.6 KiB (199.0 B, 473.0 B, 667.0 B (stage 1575725.0: task 2944667))<br>merged fetch fallback count: 0<br>local blocks read: 111<br>remote merged chunks fetched: 0<br>remote blocks read: 116<br>data size total (min, med, max (stageId: taskId))<br>22.7 KiB (56.0 B, 1288.0 B, 3.6 KiB (stage 1575722.0: task 2944453))<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>15 ms (0 ms, 0 ms, 1 ms (stage 1575722.0: task 2944486))<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 1575725.0: task 2944658))<br>remote bytes read total (min, med, max (stageId: taskId))<br>12.9 KiB (118.0 B, 449.0 B, 780.0 B (stage 1575725.0: task 2944649))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>25 ms (0 ms, 1 ms, 1 ms (stage 1575725.0: task 2944658))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>25.5 KiB (100.0 B, 1677.0 B, 3.2 KiB (stage 1575722.0: task 2944460))" tooltip="Exchange hashpartitioning(worklistShardItemId#6608919L, 30), ENSURE_REQUIREMENTS, [plan_id=3473522]"];
subgraph cluster47 {
isCluster="true";
id="cluster47";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n38 ms (0 ms, 1 ms, 5 ms (stage 1575722.0: task 2944441))";
tooltip="WholeStageCodegen (1)";
48 [id="node48" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6608407, item#6608918.worklistShardItemId AS worklistShardItemId#6608919L, item#6608918.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#6608920, item#6608918.qty AS qty#6608921]"];
49 [id="node49" labelType="html" label="<b>Generate</b><br><br>number of output rows: 415" tooltip="Generate explode(items#6608409), [shardId#6608407], false, [item#6608918]"];
50 [id="node50" labelType="html" label="<b>Filter</b><br><br>number of output rows: 22" tooltip="Filter ((size(items#6608409, true) > 0) AND isnotnull(items#6608409))"];
}
51 [id="node51" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 22" tooltip="InMemoryTableScan [shardId#6608407, items#6608409], [(size(items#6608409, true) > 0), isnotnull(items#6608409)]"];
subgraph cluster52 {
isCluster="true";
id="cluster52";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
53 [id="node53" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))"];
}
54 [id="node54" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, optimizationInsights#6608413], [isnotnull(shardId#6608407), (shardId#6608407 = 0_1_10000002290)]"];
subgraph cluster55 {
isCluster="true";
id="cluster55";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
56 [id="node56" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))"];
57 [id="node57" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#6608407,orderProposalId#6608408L,items#6608409,optimizationGroups#6608410,isOptimal#6608411,lastModified#6608412,optimizationInsights#6608413]"];
}
subgraph cluster58 {
isCluster="true";
id="cluster58";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n861 ms (2 ms, 5 ms, 87 ms (stage 1575725.0: task 2944651))";
tooltip="WholeStageCodegen (4)";
59 [id="node59" 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 1575725.0: task 2944658))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1575725.0: task 2944658))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575725.0: task 2944658))" tooltip="Sort [worklistShardItemId#6609143L ASC NULLS FIRST], false, 0"];
60 [id="node60" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#6609143L, orderProposalId#6609120L, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, originalReplenishmentRunId#6609162L, splitIndicator#6609139L, previousOrderProposal#6609140L, sourceOfSupplyUuid#6609134, supplierGroup#6609122, supplier#6609123, subrange#6609126, product#6609129, plant#6609124, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, isFallbackOrderOnly#6609137, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, netPriceAmount#6609156, netPriceCurrencyCode#6609157, ... 11 more fields]"];
}
61 [id="node61" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 415<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 415<br>local bytes read total (min, med, max (stageId: taskId))<br>152.0 KiB (1818.0 B, 5.1 KiB, 9.4 KiB (stage 1575725.0: task 2944652))<br>merged fetch fallback count: 0<br>local blocks read: 154<br>remote merged chunks fetched: 0<br>remote blocks read: 195<br>data size total (min, med, max (stageId: taskId))<br>518.8 KiB (3.4 KiB, 13.4 KiB, 28.5 KiB (stage 1575721.0: task 2944440))<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>29 ms (0 ms, 0 ms, 1 ms (stage 1575721.0: task 2944555))<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>4 ms (0 ms, 0 ms, 2 ms (stage 1575725.0: task 2944682))<br>remote bytes read total (min, med, max (stageId: taskId))<br>191.2 KiB (1820.0 B, 6.5 KiB, 10.2 KiB (stage 1575725.0: task 2944650))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>97 ms (0 ms, 4 ms, 5 ms (stage 1575725.0: task 2944676))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>343.1 KiB (2.5 KiB, 8.9 KiB, 18.3 KiB (stage 1575721.0: task 2944440))" tooltip="Exchange hashpartitioning(worklistShardItemId#6609143L, 30), REPARTITION_BY_NUM, [plan_id=3473532]"];
subgraph cluster62 {
isCluster="true";
id="cluster62";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n3.5 s (69 ms, 88 ms, 271 ms (stage 1575721.0: task 2944450))";
tooltip="WholeStageCodegen (3)";
63 [id="node63" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, ... 11 more fields]"];
64 [id="node64" labelType="html" label="<b>Filter</b><br><br>number of output rows: 415" tooltip="Filter isnotnull(worklistShardItemId#6609143L)"];
65 [id="node65" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 415<br>number of input batches: 37" tooltip="ColumnarToRow"];
}
66 [id="node66" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 37<br>scan time total (min, med, max (stageId: taskId))<br>3.2 s (68 ms, 85 ms, 113 ms (stage 1575721.0: task 2944450))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 787.6 KiB<br>number of output rows: 415<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#6609120L,orderProposalItemId#6609121,supplierGroup#6609122,supplier#6609123,plant#6609124,deliveryDateTime#6609125,subrange#6609126,supplyingPlant#6609127,productGroup#6609128,product#6609129,orderDateTime#6609130,availabilityDateTime#6609131,nextAvailabilityDateTime#6609132,sourceOfSupplyUuid#6609134,isFallbackOrderOnly#6609137,splitIndicator#6609139L,previousOrderProposal#6609140L,worklistShardItemId#6609143L,orderProposalItemGroupId#6609144,externalProductId#6609145,externalPlantId#6609146,logisticUnits#6609147,orderQuantityBaseUom#6609148,orderQuantityBaseUomUuid#6609149,minimumOrderQuantity#6609150,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#6609143L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#6609164), isnotnull(sequenceId#6609142), (shardId#6609164 = 0_1_10000002290), ..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,pla..."];
subgraph cluster67 {
isCluster="true";
id="cluster67";
label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n1.9 s (9 ms, 13 ms, 181 ms (stage 1575727.0: task 2944699))";
tooltip="WholeStageCodegen (8)";
68 [id="node68" 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 1575727.0: task 2944697))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1575727.0: task 2944697))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))" tooltip="Sort [shardId#6609640 ASC NULLS FIRST, worklistShardItemId#6609641L ASC NULLS FIRST], false, 0"];
}
69 [id="node69" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 415<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 415<br>local bytes read total (min, med, max (stageId: taskId))<br>97.2 KiB (1242.0 B, 3.2 KiB, 5.2 KiB (stage 1575727.0: task 2944725))<br>merged fetch fallback count: 0<br>local blocks read: 153<br>remote merged chunks fetched: 0<br>remote blocks read: 185<br>data size total (min, med, max (stageId: taskId))<br>434.5 KiB (6.3 KiB, 14.7 KiB, 20.9 KiB (stage 1575723.0: task 2944474))<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>24 ms (0 ms, 0 ms, 1 ms (stage 1575723.0: task 2944474))<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 1575727.0: task 2944697))<br>remote bytes read total (min, med, max (stageId: taskId))<br>116.0 KiB (1250.0 B, 4.0 KiB, 7.1 KiB (stage 1575727.0: task 2944737))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>70 ms (0 ms, 2 ms, 7 ms (stage 1575727.0: task 2944738))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>213.3 KiB (3.1 KiB, 7.3 KiB, 10.5 KiB (stage 1575723.0: task 2944474))" tooltip="Exchange hashpartitioning(shardId#6609640, worklistShardItemId#6609641L, 30), ENSURE_REQUIREMENTS, [plan_id=3473547]"];
subgraph cluster70 {
isCluster="true";
id="cluster70";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n261 ms (5 ms, 6 ms, 64 ms (stage 1575723.0: task 2944442))";
tooltip="WholeStageCodegen (7)";
71 [id="node71" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6609640, worklistShardItemId#6609641L, coalesce(kpis#6609645, []) AS prodLocSpecificKpis#6609646]"];
72 [id="node72" labelType="html" label="<b>Filter</b><br><br>number of output rows: 415" tooltip="Filter (((isnull(qty#6609642) AND isnull(demandChannel#6609643)) AND isnull(demandStream#6609644)) AND (isnotnull(shardId#6609640) AND isnotnull(worklistShardItemId#6609641L)))"];
73 [id="node73" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 4,867" tooltip="Scan ExistingRDD[shardId#6609640,worklistShardItemId#6609641L,qty#6609642,demandChannel#6609643,demandStream#6609644,kpis#6609645]"];
}
subgraph cluster74 {
isCluster="true";
id="cluster74";
label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n1.3 s (5 ms, 10 ms, 115 ms (stage 1575727.0: task 2944699))";
tooltip="WholeStageCodegen (11)";
75 [id="node75" 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 1575727.0: task 2944697))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1575727.0: task 2944697))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))" tooltip="Sort [shardId#6609656 ASC NULLS FIRST, worklistShardItemId#6609657L ASC NULLS FIRST], false, 0"];
}
76 [id="node76" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 412<br>time in aggregation build total (min, med, max (stageId: taskId))<br>221 ms (2 ms, 3 ms, 18 ms (stage 1575727.0: task 2944699))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6609656, worklistShardItemId#6609657L], functions=[collect_list(struct(demandChannel, demandChannel#6609659, demandStream, demandStream#6609660, kpis, kpis#6609661), 0, 0)])"];
77 [id="node77" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 412<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 412<br>local bytes read total (min, med, max (stageId: taskId))<br>59.9 KiB (1029.0 B, 2002.0 B, 3.2 KiB (stage 1575727.0: task 2944696))<br>merged fetch fallback count: 0<br>local blocks read: 173<br>remote merged chunks fetched: 0<br>remote blocks read: 159<br>data size total (min, med, max (stageId: taskId))<br>167.4 KiB (2.0 KiB, 5.3 KiB, 9.3 KiB (stage 1575726.0: task 2944560))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>23 ms (0 ms, 0 ms, 1 ms (stage 1575726.0: task 2944516))<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>2 ms (0 ms, 0 ms, 2 ms (stage 1575727.0: task 2944738))<br>remote bytes read total (min, med, max (stageId: taskId))<br>55.3 KiB (682.0 B, 1751.0 B, 3.1 KiB (stage 1575727.0: task 2944699))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>84 ms (0 ms, 3 ms, 6 ms (stage 1575727.0: task 2944738))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>115.2 KiB (1711.0 B, 3.7 KiB, 5.7 KiB (stage 1575726.0: task 2944560))" tooltip="Exchange hashpartitioning(shardId#6609656, worklistShardItemId#6609657L, 30), ENSURE_REQUIREMENTS, [plan_id=3473558]"];
78 [id="node78" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 412<br>time in aggregation build total (min, med, max (stageId: taskId))<br>311 ms (4 ms, 4 ms, 84 ms (stage 1575726.0: task 2944444))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575726.0: task 2944449))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6609656, worklistShardItemId#6609657L], functions=[partial_collect_list(struct(demandChannel, demandChannel#6609659, demandStream, demandStream#6609660, kpis, kpis#6609661), 0, 0)])"];
subgraph cluster79 {
isCluster="true";
id="cluster79";
label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n311 ms (4 ms, 4 ms, 84 ms (stage 1575726.0: task 2944444))";
tooltip="WholeStageCodegen (10)";
80 [id="node80" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6609656, worklistShardItemId#6609657L, demandChannel#6609659, demandStream#6609660, kpis#6609661]"];
81 [id="node81" labelType="html" label="<b>Filter</b><br><br>number of output rows: 412" tooltip="Filter ((((isnull(qty#6609658) AND isnotnull(demandChannel#6609659)) AND isnotnull(demandStream#6609660)) AND (size(kpis#6609661, true) > 0)) AND (isnotnull(shardId#6609656) AND isnotnull(worklistShardItemId#6609657L)))"];
82 [id="node82" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 4,867" tooltip="Scan ExistingRDD[shardId#6609656,worklistShardItemId#6609657L,qty#6609658,demandChannel#6609659,demandStream#6609660,kpis#6609661]"];
}
subgraph cluster83 {
isCluster="true";
id="cluster83";
label="WholeStageCodegen (14)\n \nduration: total (min, med, max (stageId: taskId))\n504 ms (2 ms, 4 ms, 46 ms (stage 1575727.0: task 2944699))";
tooltip="WholeStageCodegen (14)";
84 [id="node84" 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 1575727.0: task 2944697))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1575727.0: task 2944697))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))" tooltip="Sort [shardId#6609669 ASC NULLS FIRST, worklistShardItemId#6609670L ASC NULLS FIRST], false, 0"];
}
85 [id="node85" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 415<br>time in aggregation build total (min, med, max (stageId: taskId))<br>274 ms (3 ms, 4 ms, 22 ms (stage 1575727.0: task 2944718))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575727.0: task 2944697))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6609669, worklistShardItemId#6609670L], functions=[collect_list(struct(qty, qty#6609671, kpis, kpis#6609674), 0, 0)])"];
86 [id="node86" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 3,323<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 3,323<br>local bytes read total (min, med, max (stageId: taskId))<br>266.7 KiB (3.7 KiB, 5.8 KiB, 18.1 KiB (stage 1575727.0: task 2944734))<br>merged fetch fallback count: 0<br>local blocks read: 395<br>remote merged chunks fetched: 0<br>remote blocks read: 489<br>data size total (min, med, max (stageId: taskId))<br>2.2 MiB (68.7 KiB, 74.4 KiB, 79.6 KiB (stage 1575724.0: task 2944542))<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>44 ms (1 ms, 1 ms, 2 ms (stage 1575724.0: task 2944495))<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>5 ms (0 ms, 0 ms, 2 ms (stage 1575727.0: task 2944735))<br>remote bytes read total (min, med, max (stageId: taskId))<br>333.0 KiB (2.7 KiB, 13.7 KiB, 19.7 KiB (stage 1575727.0: task 2944696))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>135 ms (2 ms, 4 ms, 7 ms (stage 1575727.0: task 2944697))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>599.7 KiB (18.9 KiB, 20.0 KiB, 21.0 KiB (stage 1575724.0: task 2944558))" tooltip="Exchange hashpartitioning(shardId#6609669, worklistShardItemId#6609670L, 30), ENSURE_REQUIREMENTS, [plan_id=3473570]"];
87 [id="node87" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 3,323<br>time in aggregation build total (min, med, max (stageId: taskId))<br>235 ms (4 ms, 4 ms, 51 ms (stage 1575724.0: task 2944448))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575724.0: task 2944448))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#6609669, worklistShardItemId#6609670L], functions=[partial_collect_list(struct(qty, qty#6609671, kpis, kpis#6609674), 0, 0)])"];
subgraph cluster88 {
isCluster="true";
id="cluster88";
label="WholeStageCodegen (13)\n \nduration: total (min, med, max (stageId: taskId))\n236 ms (4 ms, 4 ms, 51 ms (stage 1575724.0: task 2944448))";
tooltip="WholeStageCodegen (13)";
89 [id="node89" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#6609669, worklistShardItemId#6609670L, qty#6609671, kpis#6609674]"];
90 [id="node90" labelType="html" label="<b>Filter</b><br><br>number of output rows: 4,040" tooltip="Filter ((isnotnull(qty#6609671) AND isnotnull(kpis#6609674)) AND (isnotnull(shardId#6609669) AND isnotnull(worklistShardItemId#6609670L)))"];
91 [id="node91" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 4,867" tooltip="Scan ExistingRDD[shardId#6609669,worklistShardItemId#6609670L,qty#6609671,demandChannel#6609672,demandStream#6609673,kpis#6609674]"];
}
subgraph cluster92 {
isCluster="true";
id="cluster92";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n4.4 s (6 ms, 135 ms, 563 ms (stage 1575733.0: task 2944810))";
tooltip="WholeStageCodegen (7)";
93 [id="node93" 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 1575733.0: task 2944812))<br>peak memory total (min, med, max (stageId: taskId))<br>1920.0 KiB (64.0 KiB, 64.0 KiB, 64.0 KiB (stage 1575733.0: task 2944812))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1575733.0: task 2944812))" tooltip="Sort [coalesce(shardId#6610446, ) ASC NULLS FIRST, isnull(shardId#6610446) ASC NULLS FIRST, coalesce(orderProposalId#6610447L, 0) ASC NULLS FIRST, isnull(orderProposalId#6610447L) ASC NULLS FIRST], false, 0"];
}
94 [id="node94" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#6610446, ), isnull(shardId#6610446), coalesce(orderProposalId#6610447L, 0), isnull(orderProposalId#6610447L), 30), ENSURE_REQUIREMENTS, [plan_id=3473862]"];
95 [id="node95" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#6610447L, shardId#6610446, coalesce(transform(optimizationGroups#6610449, lambdafunction(struct(optGroupId, lambda x_12841#6610444.optGroupId, minOrderProfile, lambda x_12841#6610444.minOrderProfile, assignmentDetails, lambda x_12841#6610444.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_12841#6610444.minOrderGoal.dimensionType, unit, lambda x_12841#6610444.minOrderGoal.unit, unitUuid, lambda x_12841#6610444.minOrderGoal.unitUuid, goalValue, lambda x_12841#6610444.minOrderGoal.minOrderValue, calcValue, lambda x_12841#6610444.minOrderGoal.calculatedOrderValue)), lambda x_12841#6610444, false)), []) AS optimizationGroups#6610443]"];
subgraph cluster96 {
isCluster="true";
id="cluster96";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n1.3 s (1 ms, 39 ms, 163 ms (stage 1575731.0: task 2944663))";
tooltip="WholeStageCodegen (6)";
97 [id="node97" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 0" tooltip="BroadcastHashJoin [orderProposalId#6610447L], [orderProposalId#6610502L], Inner, BuildLeft, false"];
108 [id="node108" 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, 4 ms (stage 1575731.0: task 2944661))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1575731.0: task 2944664))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#6610502L], functions=[])"];
}
98 [id="node98" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 4 ms<br>time to collect: 146 ms<br>number of output rows: 22<br>data size: 1025.0 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=3473834]"];
subgraph cluster99 {
isCluster="true";
id="cluster99";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n6 ms (0 ms, 0 ms, 1 ms (stage 1575588.0: task 2944383))";
tooltip="WholeStageCodegen (2)";
100 [id="node100" labelType="html" label="<b>Filter</b><br><br>number of output rows: 22" tooltip="Filter isnotnull(orderProposalId#6610447L)"];
}
101 [id="node101" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 22" tooltip="InMemoryTableScan [shardId#6610446, orderProposalId#6610447L, optimizationGroups#6610449], [isnotnull(orderProposalId#6610447L)]"];
subgraph cluster102 {
isCluster="true";
id="cluster102";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
103 [id="node103" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))"];
}
104 [id="node104" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, optimizationInsights#6608413], [isnotnull(shardId#6608407), (shardId#6608407 = 0_1_10000002290)]"];
subgraph cluster105 {
isCluster="true";
id="cluster105";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
106 [id="node106" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))"];
107 [id="node107" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#6608407,orderProposalId#6608408L,items#6608409,optimizationGroups#6608410,isOptimal#6608411,lastModified#6608412,optimizationInsights#6608413]"];
}
109 [id="node109" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(orderProposalId#6610502L, 30), ENSURE_REQUIREMENTS, [plan_id=3473856]"];
subgraph cluster110 {
isCluster="true";
id="cluster110";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n528 ms (0 ms, 0 ms, 146 ms (stage 1575730.0: task 2944608))";
tooltip="WholeStageCodegen (5)";
111 [id="node111" 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>2 ms (0 ms, 0 ms, 1 ms (stage 1575730.0: task 2944608))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1575730.0: task 2944607))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#6610502L], functions=[])"];
112 [id="node112" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#6610502L]"];
113 [id="node113" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#6610454L], [worklistShardItemId#6610525L], Inner, BuildLeft, false"];
127 [id="node127" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#6610525L, orderProposalId#6610502L]"];
}
114 [id="node114" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 240 ms<br>number of output rows: 415<br>data size: 1036.9 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=3473842]"];
subgraph cluster115 {
isCluster="true";
id="cluster115";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n25 ms (0 ms, 0 ms, 4 ms (stage 1575587.0: task 2944368))";
tooltip="WholeStageCodegen (3)";
116 [id="node116" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#6610453L AS worklistShardItemId#6610454L]"];
117 [id="node117" labelType="html" label="<b>Generate</b><br><br>number of output rows: 415" tooltip="Generate explode(_extract_worklistShardItemId#6611094), false, [item#6610453L]"];
118 [id="node118" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#6610084.worklistShardItemId AS _extract_worklistShardItemId#6611094]"];
119 [id="node119" labelType="html" label="<b>Filter</b><br><br>number of output rows: 22" tooltip="Filter (((size(items#6610084.worklistShardItemId, true) > 0) AND isnotnull(items#6610084.worklistShardItemId)) AND (shardId#6610082 = 0_1_10000002290))"];
}
120 [id="node120" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 22" tooltip="InMemoryTableScan [items#6610084, shardId#6610082], [(size(items#6610084.worklistShardItemId, true) > 0), isnotnull(items#6610084.worklistShardItemId), (shardId#6610082 = 0_1_10000002290)]"];
subgraph cluster121 {
isCluster="true";
id="cluster121";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
122 [id="node122" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))"];
}
123 [id="node123" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, optimizationInsights#6608413], [isnotnull(shardId#6608407), (shardId#6608407 = 0_1_10000002290)]"];
subgraph cluster124 {
isCluster="true";
id="cluster124";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
125 [id="node125" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))"];
126 [id="node126" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#6608407,orderProposalId#6608408L,items#6608409,optimizationGroups#6608410,isOptimal#6608411,lastModified#6608412,optimizationInsights#6608413]"];
}
128 [id="node128" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#6610525L, 30), REPARTITION_BY_NUM, [plan_id=3473849]"];
subgraph cluster129 {
isCluster="true";
id="cluster129";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n2.5 s (49 ms, 62 ms, 132 ms (stage 1575729.0: task 2944436))";
tooltip="WholeStageCodegen (4)";
130 [id="node130" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#6610502L, worklistShardItemId#6610525L]"];
131 [id="node131" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((isnotnull(worklistShardItemId#6610525L) AND NOT (isFallbackOrderOnly#6610519 <=> true)) AND isnotnull(orderProposalId#6610502L))"];
132 [id="node132" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 0<br>number of input batches: 0" tooltip="ColumnarToRow"];
}
133 [id="node133" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 37<br>scan time total (min, med, max (stageId: taskId))<br>2.5 s (49 ms, 61 ms, 127 ms (stage 1575729.0: task 2944436))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 787.6 KiB<br>number of output rows: 0<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#6610502L,isFallbackOrderOnly#6610519,worklistShardItemId#6610525L,shardId#6610546,sequenceId#6610524] Batched: true, DataFilters: [isnotnull(worklistShardItemId#6610525L), NOT (isFallbackOrderOnly#6610519 <=> true), isnotnull(o..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#6610546), isnotnull(sequenceId#6610524), (shardId#6610546 = 0_1_10000002290), ..., 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;
45->43;
46->45;
48->46;
49->48;
50->49;
51->50;
53->51;
54->53;
56->54;
57->56;
59->43;
60->59;
61->60;
63->61;
64->63;
65->64;
66->65;
68->37;
69->68;
71->69;
72->71;
73->72;
75->34;
76->75;
77->76;
78->77;
80->78;
81->80;
82->81;
84->31;
85->84;
86->85;
87->86;
89->87;
90->89;
91->90;
93->11;
94->93;
95->94;
97->95;
98->97;
100->98;
101->100;
103->101;
104->103;
106->104;
107->106;
108->97;
109->108;
111->109;
112->111;
113->112;
114->113;
116->114;
117->116;
118->117;
119->118;
120->119;
122->120;
123->122;
125->123;
126->125;
127->113;
128->127;
130->128;
131->130;
132->131;
133->132;
}
== Physical Plan ==
* HashAggregate (102)
+- Exchange (101)
+- * HashAggregate (100)
+- * Project (99)
+- * Generate (98)
+- Project (97)
+- Filter (96)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- Project (95)
+- SortMergeJoin LeftOuter (94)
:- Sort (67)
: +- Exchange (66)
: +- Project (65)
: +- Project (64)
: +- ObjectHashAggregate (63)
: +- Exchange (62)
: +- ObjectHashAggregate (61)
: +- ObjectHashAggregate (60)
: +- Exchange (59)
: +- ObjectHashAggregate (58)
: +- Project (57)
: +- Project (56)
: +- Project (55)
: +- * Project (54)
: +- * Filter (53)
: +- InMemoryTableScan (3)
: +- InMemoryRelation (4)
: +- * Project (52)
: +- * SortMergeJoin LeftOuter (51)
: :- * Project (43)
: : +- * SortMergeJoin LeftOuter (42)
: : :- * Project (34)
: : : +- * SortMergeJoin LeftOuter (33)
: : : :- * Sort (27)
: : : : +- Exchange (26)
: : : : +- * Project (25)
: : : : +- * SortMergeJoin LeftOuter (24)
: : : : :- * Sort (16)
: : : : : +- Exchange (15)
: : : : : +- * Project (14)
: : : : : +- * Generate (13)
: : : : : +- * Filter (12)
: : : : : +- InMemoryTableScan (5)
: : : : : +- InMemoryRelation (6)
: : : : : +- * Filter (11)
: : : : : +- InMemoryTableScan (7)
: : : : : +- InMemoryRelation (8)
: : : : : +- * Filter (10)
: : : : : +- * Scan ExistingRDD (9)
: : : : +- * Sort (23)
: : : : +- * Project (22)
: : : : +- Exchange (21)
: : : : +- * Project (20)
: : : : +- * Filter (19)
: : : : +- * ColumnarToRow (18)
: : : : +- Scan parquet (17)
: : : +- * Sort (32)
: : : +- Exchange (31)
: : : +- * Project (30)
: : : +- * Filter (29)
: : : +- * Scan ExistingRDD (28)
: : +- * Sort (41)
: : +- ObjectHashAggregate (40)
: : +- Exchange (39)
: : +- ObjectHashAggregate (38)
: : +- * Project (37)
: : +- * Filter (36)
: : +- * Scan ExistingRDD (35)
: +- * Sort (50)
: +- ObjectHashAggregate (49)
: +- Exchange (48)
: +- ObjectHashAggregate (47)
: +- * Project (46)
: +- * Filter (45)
: +- * Scan ExistingRDD (44)
+- * Sort (93)
+- Exchange (92)
+- Project (91)
+- * BroadcastHashJoin Inner BuildLeft (90)
:- BroadcastExchange (71)
: +- * Filter (70)
: +- InMemoryTableScan (68)
: +- InMemoryRelation (69)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * HashAggregate (89)
+- Exchange (88)
+- * HashAggregate (87)
+- * Project (86)
+- * BroadcastHashJoin Inner BuildLeft (85)
:- BroadcastExchange (78)
: +- * Project (77)
: +- * Generate (76)
: +- * Project (75)
: +- * Filter (74)
: +- InMemoryTableScan (72)
: +- InMemoryRelation (73)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * Project (84)
+- Exchange (83)
+- * Project (82)
+- * Filter (81)
+- * ColumnarToRow (80)
+- Scan parquet (79)
(1) InMemoryTableScan
Output [1]: [orderProposal#6610550]
Arguments: [orderProposal#6610550], [(size(orderProposal#6610550.parentItems.deliveryDateTime, true) > 0)]
(2) InMemoryRelation
Arguments: [shardId#6608407, orderProposal#6610550], StorageLevel(disk, memory, 2 replicas)
(3) InMemoryTableScan
Output [39]: [availabilityDateTime#6609097, channelStreamSpecificKpis#6609662, constraintLabels#6609109, constraintOperators#6609110, constraintValues#6609112, deliveryDateTime#6609096, isFallbackOrderOnly#6609099, logisticUnits#6609114, measurements#6609107, minimumOrderQuantity#6609108, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, nextAvailabilityDateTime#6609098, optimizationGroups#6609115, orderDateTime#6609095, orderProposalId#6609077L, orderProposalItemGroupId#6609079, orderProposalItemId#6609078, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, originalReplenishmentRunId#6609080L, plant#6609091, previousOrderProposal#6609083L, prodLocSpecificKpis#6609647, product#6609090, productGroup#6609119, qty#6608921, quantityAfterProdPlantOptimization#6608920, quantityKpis#6609675, shardId#6608407, sourceOfSupplyUuid#6609086, splitIndicator#6609082L, subrange#6609089, supplier#6609088, supplierGroup#6609087, supplyingPlant#6609118]
Arguments: [availabilityDateTime#6609097, channelStreamSpecificKpis#6609662, constraintLabels#6609109, constraintOperators#6609110, constraintValues#6609112, deliveryDateTime#6609096, isFallbackOrderOnly#6609099, logisticUnits#6609114, measurements#6609107, minimumOrderQuantity#6609108, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, nextAvailabilityDateTime#6609098, optimizationGroups#6609115, orderDateTime#6609095, orderProposalId#6609077L, orderProposalItemGroupId#6609079, orderProposalItemId#6609078, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, originalReplenishmentRunId#6609080L, plant#6609091, ... 14 more fields], [NOT (isFallbackOrderOnly#6609099 <=> true)]
(4) InMemoryRelation
Arguments: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, availabilityDateTime#6609097, nextAvailabilityDateTime#6609098, constraintValues#6609112, constraintOperators#6609110, constraintLabels#6609109, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, netPriceAmount#6609105, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)
(5) InMemoryTableScan
Output [2]: [shardId#6608407, items#6608409]
Arguments: [shardId#6608407, items#6608409], [(size(items#6608409, true) > 0), isnotnull(items#6608409)]
(6) InMemoryRelation
Arguments: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, optimizationInsights#6608413], StorageLevel(disk, memory, 2 replicas)
(7) InMemoryTableScan
Output [6]: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, optimizationInsights#6608413]
Arguments: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, optimizationInsights#6608413], [isnotnull(shardId#6608407), (shardId#6608407 = 0_1_10000002290)]
(8) InMemoryRelation
Arguments: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, lastModified#6608412, optimizationInsights#6608413], StorageLevel(disk, memory, 2 replicas)
(9) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, lastModified#6608412, optimizationInsights#6608413]
Arguments: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, lastModified#6608412, optimizationInsights#6608413], MapPartitionsRDD[467832] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(10) Filter [codegen id : 1]
Input [7]: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, lastModified#6608412, optimizationInsights#6608413]
Condition : (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))
(11) Filter [codegen id : 1]
Input [6]: [shardId#6608407, orderProposalId#6608408L, items#6608409, optimizationGroups#6608410, isOptimal#6608411, optimizationInsights#6608413]
Condition : (isnotnull(shardId#6608407) AND (shardId#6608407 = 0_1_10000002290))
(12) Filter [codegen id : 1]
Input [2]: [shardId#6608407, items#6608409]
Condition : ((size(items#6608409, true) > 0) AND isnotnull(items#6608409))
(13) Generate [codegen id : 1]
Input [2]: [shardId#6608407, items#6608409]
Arguments: explode(items#6608409), [shardId#6608407], false, [item#6608918]
(14) Project [codegen id : 1]
Output [4]: [shardId#6608407, item#6608918.worklistShardItemId AS worklistShardItemId#6608919L, item#6608918.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#6608920, item#6608918.qty AS qty#6608921]
Input [2]: [shardId#6608407, item#6608918]
(15) Exchange
Input [4]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921]
Arguments: hashpartitioning(worklistShardItemId#6608919L, 30), ENSURE_REQUIREMENTS, [plan_id=3473522]
(16) Sort [codegen id : 2]
Input [4]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921]
Arguments: [worklistShardItemId#6608919L ASC NULLS FIRST], false, 0
(17) Scan parquet
Output [38]: [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, measurements#6609161, originalReplenishmentRunId#6609162L, optimizationGroups#6609163, shardId#6609164, sequenceId#6609142]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002290]
PartitionFilters: [isnotnull(shardId#6609164), isnotnull(sequenceId#6609142), (shardId#6609164 = 0_1_10000002290), (sequenceId#6609142 = 3)]
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>>
(18) ColumnarToRow [codegen id : 3]
Input [38]: [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, measurements#6609161, originalReplenishmentRunId#6609162L, optimizationGroups#6609163, shardId#6609164, sequenceId#6609142]
(19) Filter [codegen id : 3]
Input [38]: [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, measurements#6609161, originalReplenishmentRunId#6609162L, optimizationGroups#6609163, shardId#6609164, sequenceId#6609142]
Condition : isnotnull(worklistShardItemId#6609143L)
(20) Project [codegen id : 3]
Output [36]: [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, measurements#6609161, originalReplenishmentRunId#6609162L, optimizationGroups#6609163]
Input [38]: [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, measurements#6609161, originalReplenishmentRunId#6609162L, optimizationGroups#6609163, shardId#6609164, sequenceId#6609142]
(21) Exchange
Input [36]: [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, measurements#6609161, originalReplenishmentRunId#6609162L, optimizationGroups#6609163]
Arguments: hashpartitioning(worklistShardItemId#6609143L, 30), REPARTITION_BY_NUM, [plan_id=3473532]
(22) Project [codegen id : 4]
Output [36]: [worklistShardItemId#6609143L, orderProposalId#6609120L, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, originalReplenishmentRunId#6609162L, splitIndicator#6609139L, previousOrderProposal#6609140L, sourceOfSupplyUuid#6609134, supplierGroup#6609122, supplier#6609123, subrange#6609126, product#6609129, plant#6609124, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, isFallbackOrderOnly#6609137, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, netPriceAmount#6609156, netPriceCurrencyCode#6609157, measurements#6609161, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, logisticUnits#6609147, optimizationGroups#6609163, externalProductId#6609145, externalPlantId#6609146, supplyingPlant#6609127, productGroup#6609128]
Input [36]: [orderProposalId#6609120L, orderProposalItemId#6609121, supplierGroup#6609122, supplier#6609123, plant#6609124, deliveryDateTime#6609125, subrange#6609126, supplyingPlant#6609127, productGroup#6609128, product#6609129, orderDateTime#6609130, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, sourceOfSupplyUuid#6609134, isFallbackOrderOnly#6609137, splitIndicator#6609139L, previousOrderProposal#6609140L, worklistShardItemId#6609143L, orderProposalItemGroupId#6609144, externalProductId#6609145, externalPlantId#6609146, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, measurements#6609161, originalReplenishmentRunId#6609162L, optimizationGroups#6609163]
(23) Sort [codegen id : 4]
Input [36]: [worklistShardItemId#6609143L, orderProposalId#6609120L, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, originalReplenishmentRunId#6609162L, splitIndicator#6609139L, previousOrderProposal#6609140L, sourceOfSupplyUuid#6609134, supplierGroup#6609122, supplier#6609123, subrange#6609126, product#6609129, plant#6609124, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, isFallbackOrderOnly#6609137, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, netPriceAmount#6609156, netPriceCurrencyCode#6609157, measurements#6609161, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, logisticUnits#6609147, optimizationGroups#6609163, externalProductId#6609145, externalPlantId#6609146, supplyingPlant#6609127, productGroup#6609128]
Arguments: [worklistShardItemId#6609143L ASC NULLS FIRST], false, 0
(24) SortMergeJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#6608919L]
Right keys [1]: [worklistShardItemId#6609143L]
Join type: LeftOuter
Join condition: (shardId#6608407 = 0_1_10000002290)
(25) Project [codegen id : 5]
Output [39]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137]
Input [40]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, worklistShardItemId#6609143L, orderProposalId#6609120L, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, originalReplenishmentRunId#6609162L, splitIndicator#6609139L, previousOrderProposal#6609140L, sourceOfSupplyUuid#6609134, supplierGroup#6609122, supplier#6609123, subrange#6609126, product#6609129, plant#6609124, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, isFallbackOrderOnly#6609137, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, netPriceAmount#6609156, netPriceCurrencyCode#6609157, measurements#6609161, minimumOrderQuantity#6609150, constraintLabels#6609151, constraintOperators#6609152, constraintValues#6609153, logisticUnits#6609147, optimizationGroups#6609163, externalProductId#6609145, externalPlantId#6609146, supplyingPlant#6609127, productGroup#6609128]
(26) Exchange
Input [39]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137]
Arguments: hashpartitioning(shardId#6608407, worklistShardItemId#6608919L, 30), ENSURE_REQUIREMENTS, [plan_id=3473541]
(27) Sort [codegen id : 6]
Input [39]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137]
Arguments: [shardId#6608407 ASC NULLS FIRST, worklistShardItemId#6608919L ASC NULLS FIRST], false, 0
(28) Scan ExistingRDD [codegen id : 7]
Output [6]: [shardId#6609640, worklistShardItemId#6609641L, qty#6609642, demandChannel#6609643, demandStream#6609644, kpis#6609645]
Arguments: [shardId#6609640, worklistShardItemId#6609641L, qty#6609642, demandChannel#6609643, demandStream#6609644, kpis#6609645], MapPartitionsRDD[467892] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(29) Filter [codegen id : 7]
Input [6]: [shardId#6609640, worklistShardItemId#6609641L, qty#6609642, demandChannel#6609643, demandStream#6609644, kpis#6609645]
Condition : (((isnull(qty#6609642) AND isnull(demandChannel#6609643)) AND isnull(demandStream#6609644)) AND (isnotnull(shardId#6609640) AND isnotnull(worklistShardItemId#6609641L)))
(30) Project [codegen id : 7]
Output [3]: [shardId#6609640, worklistShardItemId#6609641L, coalesce(kpis#6609645, []) AS prodLocSpecificKpis#6609646]
Input [6]: [shardId#6609640, worklistShardItemId#6609641L, qty#6609642, demandChannel#6609643, demandStream#6609644, kpis#6609645]
(31) Exchange
Input [3]: [shardId#6609640, worklistShardItemId#6609641L, prodLocSpecificKpis#6609646]
Arguments: hashpartitioning(shardId#6609640, worklistShardItemId#6609641L, 30), ENSURE_REQUIREMENTS, [plan_id=3473547]
(32) Sort [codegen id : 8]
Input [3]: [shardId#6609640, worklistShardItemId#6609641L, prodLocSpecificKpis#6609646]
Arguments: [shardId#6609640 ASC NULLS FIRST, worklistShardItemId#6609641L ASC NULLS FIRST], false, 0
(33) SortMergeJoin [codegen id : 9]
Left keys [2]: [shardId#6608407, worklistShardItemId#6608919L]
Right keys [2]: [shardId#6609640, worklistShardItemId#6609641L]
Join type: LeftOuter
Join condition: None
(34) Project [codegen id : 9]
Output [40]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137, coalesce(prodLocSpecificKpis#6609646, []) AS prodLocSpecificKpis#6609647]
Input [42]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137, shardId#6609640, worklistShardItemId#6609641L, prodLocSpecificKpis#6609646]
(35) Scan ExistingRDD [codegen id : 10]
Output [6]: [shardId#6609656, worklistShardItemId#6609657L, qty#6609658, demandChannel#6609659, demandStream#6609660, kpis#6609661]
Arguments: [shardId#6609656, worklistShardItemId#6609657L, qty#6609658, demandChannel#6609659, demandStream#6609660, kpis#6609661], MapPartitionsRDD[467892] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(36) Filter [codegen id : 10]
Input [6]: [shardId#6609656, worklistShardItemId#6609657L, qty#6609658, demandChannel#6609659, demandStream#6609660, kpis#6609661]
Condition : ((((isnull(qty#6609658) AND isnotnull(demandChannel#6609659)) AND isnotnull(demandStream#6609660)) AND (size(kpis#6609661, true) > 0)) AND (isnotnull(shardId#6609656) AND isnotnull(worklistShardItemId#6609657L)))
(37) Project [codegen id : 10]
Output [5]: [shardId#6609656, worklistShardItemId#6609657L, demandChannel#6609659, demandStream#6609660, kpis#6609661]
Input [6]: [shardId#6609656, worklistShardItemId#6609657L, qty#6609658, demandChannel#6609659, demandStream#6609660, kpis#6609661]
(38) ObjectHashAggregate
Input [5]: [shardId#6609656, worklistShardItemId#6609657L, demandChannel#6609659, demandStream#6609660, kpis#6609661]
Keys [2]: [shardId#6609656, worklistShardItemId#6609657L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#6609659, demandStream, demandStream#6609660, kpis, kpis#6609661), 0, 0)]
Aggregate Attributes [1]: [buf#6609836]
Results [3]: [shardId#6609656, worklistShardItemId#6609657L, buf#6609837]
(39) Exchange
Input [3]: [shardId#6609656, worklistShardItemId#6609657L, buf#6609837]
Arguments: hashpartitioning(shardId#6609656, worklistShardItemId#6609657L, 30), ENSURE_REQUIREMENTS, [plan_id=3473558]
(40) ObjectHashAggregate
Input [3]: [shardId#6609656, worklistShardItemId#6609657L, buf#6609837]
Keys [2]: [shardId#6609656, worklistShardItemId#6609657L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#6609659, demandStream, demandStream#6609660, kpis, kpis#6609661), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#6609659, demandStream, demandStream#6609660, kpis, kpis#6609661), 0, 0)#6609655]
Results [3]: [shardId#6609656, worklistShardItemId#6609657L, collect_list(struct(demandChannel, demandChannel#6609659, demandStream, demandStream#6609660, kpis, kpis#6609661), 0, 0)#6609655 AS channelStreamSpecificKpis#6609648]
(41) Sort [codegen id : 11]
Input [3]: [shardId#6609656, worklistShardItemId#6609657L, channelStreamSpecificKpis#6609648]
Arguments: [shardId#6609656 ASC NULLS FIRST, worklistShardItemId#6609657L ASC NULLS FIRST], false, 0
(42) SortMergeJoin [codegen id : 12]
Left keys [2]: [shardId#6608407, worklistShardItemId#6608919L]
Right keys [2]: [shardId#6609656, worklistShardItemId#6609657L]
Join type: LeftOuter
Join condition: None
(43) Project [codegen id : 12]
Output [41]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137, prodLocSpecificKpis#6609647, coalesce(channelStreamSpecificKpis#6609648, []) AS channelStreamSpecificKpis#6609662]
Input [43]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137, prodLocSpecificKpis#6609647, shardId#6609656, worklistShardItemId#6609657L, channelStreamSpecificKpis#6609648]
(44) Scan ExistingRDD [codegen id : 13]
Output [6]: [shardId#6609669, worklistShardItemId#6609670L, qty#6609671, demandChannel#6609672, demandStream#6609673, kpis#6609674]
Arguments: [shardId#6609669, worklistShardItemId#6609670L, qty#6609671, demandChannel#6609672, demandStream#6609673, kpis#6609674], MapPartitionsRDD[467892] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(45) Filter [codegen id : 13]
Input [6]: [shardId#6609669, worklistShardItemId#6609670L, qty#6609671, demandChannel#6609672, demandStream#6609673, kpis#6609674]
Condition : ((isnotnull(qty#6609671) AND isnotnull(kpis#6609674)) AND (isnotnull(shardId#6609669) AND isnotnull(worklistShardItemId#6609670L)))
(46) Project [codegen id : 13]
Output [4]: [shardId#6609669, worklistShardItemId#6609670L, qty#6609671, kpis#6609674]
Input [6]: [shardId#6609669, worklistShardItemId#6609670L, qty#6609671, demandChannel#6609672, demandStream#6609673, kpis#6609674]
(47) ObjectHashAggregate
Input [4]: [shardId#6609669, worklistShardItemId#6609670L, qty#6609671, kpis#6609674]
Keys [2]: [shardId#6609669, worklistShardItemId#6609670L]
Functions [1]: [partial_collect_list(struct(qty, qty#6609671, kpis, kpis#6609674), 0, 0)]
Aggregate Attributes [1]: [buf#6609838]
Results [3]: [shardId#6609669, worklistShardItemId#6609670L, buf#6609839]
(48) Exchange
Input [3]: [shardId#6609669, worklistShardItemId#6609670L, buf#6609839]
Arguments: hashpartitioning(shardId#6609669, worklistShardItemId#6609670L, 30), ENSURE_REQUIREMENTS, [plan_id=3473570]
(49) ObjectHashAggregate
Input [3]: [shardId#6609669, worklistShardItemId#6609670L, buf#6609839]
Keys [2]: [shardId#6609669, worklistShardItemId#6609670L]
Functions [1]: [collect_list(struct(qty, qty#6609671, kpis, kpis#6609674), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#6609671, kpis, kpis#6609674), 0, 0)#6609668]
Results [3]: [shardId#6609669, worklistShardItemId#6609670L, map_from_entries(collect_list(struct(qty, qty#6609671, kpis, kpis#6609674), 0, 0)#6609668) AS quantityKpis#6609663]
(50) Sort [codegen id : 14]
Input [3]: [shardId#6609669, worklistShardItemId#6609670L, quantityKpis#6609663]
Arguments: [shardId#6609669 ASC NULLS FIRST, worklistShardItemId#6609670L ASC NULLS FIRST], false, 0
(51) SortMergeJoin [codegen id : 15]
Left keys [2]: [shardId#6608407, worklistShardItemId#6608919L]
Right keys [2]: [shardId#6609669, worklistShardItemId#6609670L]
Join type: LeftOuter
Join condition: None
(52) Project [codegen id : 15]
Output [42]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137, prodLocSpecificKpis#6609647, channelStreamSpecificKpis#6609662, coalesce(quantityKpis#6609663, map(keys: [], values: [])) AS quantityKpis#6609675]
Input [44]: [shardId#6608407, worklistShardItemId#6608919L, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609120L, originalReplenishmentRunId#6609162L, supplierGroup#6609122, supplier#6609123, supplyingPlant#6609127, productGroup#6609128, product#6609129, plant#6609124, subrange#6609126, orderDateTime#6609130, deliveryDateTime#6609125, availabilityDateTime#6609131, nextAvailabilityDateTime#6609132, constraintValues#6609153, constraintOperators#6609152, constraintLabels#6609151, logisticUnits#6609147, orderQuantityBaseUom#6609148, orderQuantityBaseUomUuid#6609149, splitIndicator#6609139L, netPriceAmount#6609156, netPriceCurrencyCode#6609157, netPriceQuantity#6609158, netPriceQuantityUom#6609159, netPriceQuantityUomUuid#6609160, sourceOfSupplyUuid#6609134, minimumOrderQuantity#6609150, orderProposalItemId#6609121, orderProposalItemGroupId#6609144, optimizationGroups#6609163, measurements#6609161, externalProductId#6609145, externalPlantId#6609146, previousOrderProposal#6609140L, isFallbackOrderOnly#6609137, prodLocSpecificKpis#6609647, channelStreamSpecificKpis#6609662, shardId#6609669, worklistShardItemId#6609670L, quantityKpis#6609663]
(53) Filter [codegen id : 1]
Input [39]: [availabilityDateTime#6609097, channelStreamSpecificKpis#6609662, constraintLabels#6609109, constraintOperators#6609110, constraintValues#6609112, deliveryDateTime#6609096, isFallbackOrderOnly#6609099, logisticUnits#6609114, measurements#6609107, minimumOrderQuantity#6609108, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, nextAvailabilityDateTime#6609098, optimizationGroups#6609115, orderDateTime#6609095, orderProposalId#6609077L, orderProposalItemGroupId#6609079, orderProposalItemId#6609078, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, originalReplenishmentRunId#6609080L, plant#6609091, previousOrderProposal#6609083L, prodLocSpecificKpis#6609647, product#6609090, productGroup#6609119, qty#6608921, quantityAfterProdPlantOptimization#6608920, quantityKpis#6609675, shardId#6608407, sourceOfSupplyUuid#6609086, splitIndicator#6609082L, subrange#6609089, supplier#6609088, supplierGroup#6609087, supplyingPlant#6609118]
Condition : NOT (isFallbackOrderOnly#6609099 <=> true)
(54) Project [codegen id : 1]
Output [36]: [shardId#6608407, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, availabilityDateTime#6609097, nextAvailabilityDateTime#6609098, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, sourceOfSupplyUuid#6609086, minimumOrderQuantity#6609108, orderProposalItemId#6609078, orderProposalItemGroupId#6609079, optimizationGroups#6609115, measurements#6609107, previousOrderProposal#6609083L, prodLocSpecificKpis#6609647, channelStreamSpecificKpis#6609662, quantityKpis#6609675, arrays_zip(constraintLabels#6609109, constraintOperators#6609110, constraintValues#6609112, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#6610089]
Input [39]: [availabilityDateTime#6609097, channelStreamSpecificKpis#6609662, constraintLabels#6609109, constraintOperators#6609110, constraintValues#6609112, deliveryDateTime#6609096, isFallbackOrderOnly#6609099, logisticUnits#6609114, measurements#6609107, minimumOrderQuantity#6609108, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, nextAvailabilityDateTime#6609098, optimizationGroups#6609115, orderDateTime#6609095, orderProposalId#6609077L, orderProposalItemGroupId#6609079, orderProposalItemId#6609078, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, originalReplenishmentRunId#6609080L, plant#6609091, previousOrderProposal#6609083L, prodLocSpecificKpis#6609647, product#6609090, productGroup#6609119, qty#6608921, quantityAfterProdPlantOptimization#6608920, quantityKpis#6609675, shardId#6608407, sourceOfSupplyUuid#6609086, splitIndicator#6609082L, subrange#6609089, supplier#6609088, supplierGroup#6609087, supplyingPlant#6609118]
(55) Project
Output [37]: [shardId#6608407, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, availabilityDateTime#6609097, nextAvailabilityDateTime#6609098, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, sourceOfSupplyUuid#6609086, orderProposalItemId#6609078, orderProposalItemGroupId#6609079, optimizationGroups#6609115, measurements#6609107, previousOrderProposal#6609083L, prodLocSpecificKpis#6609647, channelStreamSpecificKpis#6609662, quantityKpis#6609675, struct(minServiceLevel, array_min(filter(constraintStructArray#6610089, lambdafunction((lambda x_12791#6610096.constraintLabels = ServiceLevel), lambda x_12791#6610096, false)).constraintValues), minServiceLevelMinStock, null, maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#6610089, lambdafunction((lambda x_12792#6610097.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_12792#6610097, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#6610089, lambdafunction((lambda x_12793#6610098.constraintLabels = RangeOfCoverage), lambda x_12793#6610098, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#6609108, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#6609647, lambdafunction((lambda x_12794#6610099.label = NonListingStartTimestamp), lambda x_12794#6610099, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#6610095, CASE WHEN (qty#6608921 <=> quantityAfterProdPlantOptimization#6608920) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#6608921 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610167.isOrderUnit, lambda x_12795#6610167, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610168.isOrderUnit, lambda x_12795#6610168, false)), 1, None, false).numerator as double))), qty#6608921), orderQuantityUom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610169.isOrderUnit, lambda x_12795#6610169, false)), 1, None, false).uom, orderQuantityBaseUom#6609100), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610170.isOrderUnit, lambda x_12795#6610170, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101), candidateOrderQuantityInBaseUnit, qty#6608921, orderQuantityBaseUom, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#6609101, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12797#6610171.isPreferred AND (((qty#6608921 * cast(lambda x_12797#6610171.denominator as double)) % cast(lambda x_12797#6610171.numerator as double)) = 0.0)), lambda x_12797#6610171, false)), lambdafunction(struct(inPreferredQuantity, ((qty#6608921 * cast(lambda x_12798#6610209.denominator as double)) / cast(lambda x_12798#6610209.numerator as double)), uom, lambda x_12798#6610209.uom, uomUuid, lambda x_12798#6610209.uomUuid), lambda x_12798#6610209, false))).inPreferredQuantity, coalesce((qty#6608921 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610172.isOrderUnit, lambda x_12796#6610172, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610173.isOrderUnit, lambda x_12796#6610173, false)), 1, None, false).numerator as double))), qty#6608921)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12797#6610174.isPreferred AND (((qty#6608921 * cast(lambda x_12797#6610174.denominator as double)) % cast(lambda x_12797#6610174.numerator as double)) = 0.0)), lambda x_12797#6610174, false)), lambdafunction(struct(inPreferredQuantity, ((qty#6608921 * cast(lambda x_12798#6610210.denominator as double)) / cast(lambda x_12798#6610210.numerator as double)), uom, lambda x_12798#6610210.uom, uomUuid, lambda x_12798#6610210.uomUuid), lambda x_12798#6610210, false))).uom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610175.isOrderUnit, lambda x_12796#6610175, false)), 1, None, false).uom, orderQuantityBaseUom#6609100)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12797#6610176.isPreferred AND (((qty#6608921 * cast(lambda x_12797#6610176.denominator as double)) % cast(lambda x_12797#6610176.numerator as double)) = 0.0)), lambda x_12797#6610176, false)), lambdafunction(struct(inPreferredQuantity, ((qty#6608921 * cast(lambda x_12798#6610211.denominator as double)) / cast(lambda x_12798#6610211.numerator as double)), uom, lambda x_12798#6610211.uom, uomUuid, lambda x_12798#6610211.uomUuid), lambda x_12798#6610211, false))).uomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610177.isOrderUnit, lambda x_12796#6610177, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101)), serviceLevel, coalesce(filter(element_at(quantityKpis#6609675, qty#6608921, None, false), lambdafunction((lambda x_12803#6610178.label = ServiceLevel), lambda x_12803#6610178, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#6608921 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610181.isOrderUnit, lambda x_12795#6610181, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610182.isOrderUnit, lambda x_12795#6610182, false)), 1, None, false).numerator as double))), qty#6608921), orderQuantityUom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610183.isOrderUnit, lambda x_12795#6610183, false)), 1, None, false).uom, orderQuantityBaseUom#6609100), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12795#6610184.isOrderUnit, lambda x_12795#6610184, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101), candidateOrderQuantityInBaseUnit, qty#6608921, orderQuantityBaseUom, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#6609101, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12797#6610185.isPreferred AND (((qty#6608921 * cast(lambda x_12797#6610185.denominator as double)) % cast(lambda x_12797#6610185.numerator as double)) = 0.0)), lambda x_12797#6610185, false)), lambdafunction(struct(inPreferredQuantity, ((qty#6608921 * cast(lambda x_12798#6610212.denominator as double)) / cast(lambda x_12798#6610212.numerator as double)), uom, lambda x_12798#6610212.uom, uomUuid, lambda x_12798#6610212.uomUuid), lambda x_12798#6610212, false))).inPreferredQuantity, coalesce((qty#6608921 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610186.isOrderUnit, lambda x_12796#6610186, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610187.isOrderUnit, lambda x_12796#6610187, false)), 1, None, false).numerator as double))), qty#6608921)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12797#6610188.isPreferred AND (((qty#6608921 * cast(lambda x_12797#6610188.denominator as double)) % cast(lambda x_12797#6610188.numerator as double)) = 0.0)), lambda x_12797#6610188, false)), lambdafunction(struct(inPreferredQuantity, ((qty#6608921 * cast(lambda x_12798#6610213.denominator as double)) / cast(lambda x_12798#6610213.numerator as double)), uom, lambda x_12798#6610213.uom, uomUuid, lambda x_12798#6610213.uomUuid), lambda x_12798#6610213, false))).uom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610189.isOrderUnit, lambda x_12796#6610189, false)), 1, None, false).uom, orderQuantityBaseUom#6609100)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12797#6610190.isPreferred AND (((qty#6608921 * cast(lambda x_12797#6610190.denominator as double)) % cast(lambda x_12797#6610190.numerator as double)) = 0.0)), lambda x_12797#6610190, false)), lambdafunction(struct(inPreferredQuantity, ((qty#6608921 * cast(lambda x_12798#6610214.denominator as double)) / cast(lambda x_12798#6610214.numerator as double)), uom, lambda x_12798#6610214.uom, uomUuid, lambda x_12798#6610214.uomUuid), lambda x_12798#6610214, false))).uomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12796#6610191.isOrderUnit, lambda x_12796#6610191, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101)), serviceLevel, coalesce(filter(element_at(quantityKpis#6609675, qty#6608921, None, false), lambdafunction((lambda x_12806#6610192.label = ServiceLevel), lambda x_12806#6610192, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#6608920 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12799#6610195.isOrderUnit, lambda x_12799#6610195, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12799#6610196.isOrderUnit, lambda x_12799#6610196, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#6608920), orderQuantityUom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12799#6610197.isOrderUnit, lambda x_12799#6610197, false)), 1, None, false).uom, orderQuantityBaseUom#6609100), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12799#6610198.isOrderUnit, lambda x_12799#6610198, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#6608920, orderQuantityBaseUom, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#6609101, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12801#6610199.isPreferred AND (((quantityAfterProdPlantOptimization#6608920 * cast(lambda x_12801#6610199.denominator as double)) % cast(lambda x_12801#6610199.numerator as double)) = 0.0)), lambda x_12801#6610199, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#6608920 * cast(lambda x_12802#6610215.denominator as double)) / cast(lambda x_12802#6610215.numerator as double)), uom, lambda x_12802#6610215.uom, uomUuid, lambda x_12802#6610215.uomUuid), lambda x_12802#6610215, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#6608920 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12800#6610200.isOrderUnit, lambda x_12800#6610200, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12800#6610201.isOrderUnit, lambda x_12800#6610201, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#6608920)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12801#6610202.isPreferred AND (((quantityAfterProdPlantOptimization#6608920 * cast(lambda x_12801#6610202.denominator as double)) % cast(lambda x_12801#6610202.numerator as double)) = 0.0)), lambda x_12801#6610202, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#6608920 * cast(lambda x_12802#6610216.denominator as double)) / cast(lambda x_12802#6610216.numerator as double)), uom, lambda x_12802#6610216.uom, uomUuid, lambda x_12802#6610216.uomUuid), lambda x_12802#6610216, false))).uom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12800#6610203.isOrderUnit, lambda x_12800#6610203, false)), 1, None, false).uom, orderQuantityBaseUom#6609100)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#6609114, lambdafunction((lambda x_12801#6610204.isPreferred AND (((quantityAfterProdPlantOptimization#6608920 * cast(lambda x_12801#6610204.denominator as double)) % cast(lambda x_12801#6610204.numerator as double)) = 0.0)), lambda x_12801#6610204, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#6608920 * cast(lambda x_12802#6610217.denominator as double)) / cast(lambda x_12802#6610217.numerator as double)), uom, lambda x_12802#6610217.uom, uomUuid, lambda x_12802#6610217.uomUuid), lambda x_12802#6610217, false))).uomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12800#6610205.isOrderUnit, lambda x_12800#6610205, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101)), serviceLevel, coalesce(filter(element_at(quantityKpis#6609675, quantityAfterProdPlantOptimization#6608920, None, false), lambdafunction((lambda x_12809#6610206.label = ServiceLevel), lambda x_12809#6610206, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#6610166, coalesce(filter(prodLocSpecificKpis#6609647, lambdafunction((lambda x_12812#6610219.label = InitialStockQty), lambda x_12812#6610219, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#6610218, coalesce(filter(prodLocSpecificKpis#6609647, lambdafunction((lambda x_12813#6610221.label = DemandPeriodEndTimestamp), lambda x_12813#6610221, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#6610220]
Input [36]: [shardId#6608407, quantityAfterProdPlantOptimization#6608920, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, availabilityDateTime#6609097, nextAvailabilityDateTime#6609098, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, sourceOfSupplyUuid#6609086, minimumOrderQuantity#6609108, orderProposalItemId#6609078, orderProposalItemGroupId#6609079, optimizationGroups#6609115, measurements#6609107, previousOrderProposal#6609083L, prodLocSpecificKpis#6609647, channelStreamSpecificKpis#6609662, quantityKpis#6609675, constraintStructArray#6610089]
(56) Project
Output [21]: [shardId#6608407, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, orderProposalItemId#6609078, orderProposalItemGroupId#6609079, previousOrderProposal#6609083L, struct(supplier, supplier#6609088, supplyingPlant, supplyingPlant#6609118, productGroup, productGroup#6609119, product, product#6609090, plant, plant#6609091, supplierSubRange, subrange#6609089, sourceOfSupplyUuid, sourceOfSupplyUuid#6609086, deliveryDateTime, deliveryDateTime#6609096, unitPrice, netPriceAmount#6609105, unitPriceCurrency, netPriceCurrencyCode#6609106, unitPriceQuantity, netPriceQuantity#6609102, unitPriceQuantityUom, netPriceQuantityUom#6609103, unitPriceQuantityUomUuid, ... 31 more fields) AS parentItem#6610291]
Input [37]: [shardId#6608407, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, availabilityDateTime#6609097, nextAvailabilityDateTime#6609098, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, netPriceAmount#6609105, netPriceCurrencyCode#6609106, netPriceQuantity#6609102, netPriceQuantityUom#6609103, netPriceQuantityUomUuid#6609104, sourceOfSupplyUuid#6609086, orderProposalItemId#6609078, orderProposalItemGroupId#6609079, optimizationGroups#6609115, measurements#6609107, previousOrderProposal#6609083L, prodLocSpecificKpis#6609647, channelStreamSpecificKpis#6609662, quantityKpis#6609675, constraintBenchmark#6610095, calculationAnalysis#6610166, inventoryDateTime#6610218, demandPeriodEndDateTime#6610220]
(57) Project
Output [12]: [shardId#6608407, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, orderDateTime#6609095, splitIndicator#6609082L, orderProposalItemGroupId#6609079, previousOrderProposal#6609083L, parentItem#6610291, struct(itemId, orderProposalItemId#6609078, supplier, supplier#6609088, supplyingPlant, supplyingPlant#6609118, productGroup, productGroup#6609119, product, product#6609090, plant, plant#6609091, supplierSubRange, subrange#6609089, deliveryDateTime, deliveryDateTime#6609096, orderQuantity, coalesce((qty#6608921 * (cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610325.isOrderUnit, lambda x_12837#6610325, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610326.isOrderUnit, lambda x_12837#6610326, false)), 1, None, false).numerator as double))), qty#6608921), orderQuantityUom, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610327.isOrderUnit, lambda x_12837#6610327, false)), 1, None, false).uom, orderQuantityBaseUom#6609100), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#6609114, lambdafunction(lambda x_12837#6610328.isOrderUnit, lambda x_12837#6610328, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#6609101), orderQuantityInBaseUnit, qty#6608921, orderQuantityBaseUom, ... 13 more fields) AS item#6610322]
Input [21]: [shardId#6608407, qty#6608921, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, productGroup#6609119, product#6609090, plant#6609091, subrange#6609089, orderDateTime#6609095, deliveryDateTime#6609096, logisticUnits#6609114, orderQuantityBaseUom#6609100, orderQuantityBaseUomUuid#6609101, splitIndicator#6609082L, orderProposalItemId#6609078, orderProposalItemGroupId#6609079, previousOrderProposal#6609083L, parentItem#6610291]
(58) ObjectHashAggregate
Input [12]: [shardId#6608407, orderProposalId#6609077L, originalReplenishmentRunId#6609080L, supplierGroup#6609087, supplier#6609088, supplyingPlant#6609118, orderDateTime#6609095, splitIndicator#6609082L, orderProposalItemGroupId#6609079, previousOrderProposal#6609083L, parentItem#6610291, item#6610322]
Keys [4]: [shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079]
Functions [8]: [partial_max(originalReplenishmentRunId#6609080L), partial_max(supplierGroup#6609087), partial_max(supplier#6609088), partial_max(supplyingPlant#6609118), partial_max(orderDateTime#6609095), partial_collect_list(parentItem#6610291, 0, 0), partial_collect_set(previousOrderProposal#6609083L, 0, 0), partial_collect_list(item#6610322, 0, 0)]
Aggregate Attributes [8]: [max#6611573L, max#6611574, max#6611575, max#6611576, max#6611577, buf#6611578, buf#6611579, buf#6611580]
Results [12]: [shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079, max#6611581L, max#6611582, max#6611583, max#6611584, max#6611585, buf#6611586, buf#6611587, buf#6611588]
(59) Exchange
Input [12]: [shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079, max#6611581L, max#6611582, max#6611583, max#6611584, max#6611585, buf#6611586, buf#6611587, buf#6611588]
Arguments: hashpartitioning(shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079, 30), ENSURE_REQUIREMENTS, [plan_id=3473822]
(60) ObjectHashAggregate
Input [12]: [shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079, max#6611581L, max#6611582, max#6611583, max#6611584, max#6611585, buf#6611586, buf#6611587, buf#6611588]
Keys [4]: [shardId#6608407, orderProposalId#6609077L, splitIndicator#6609082L, orderProposalItemGroupId#6609079]
Functions [8]: [max(originalReplenishmentRunId#6609080L), max(supplierGroup#6609087), max(supplier#6609088), max(supplyingPlant#6609118), max(orderDateTime#6609095), collect_list(parentItem#6610291, 0, 0), collect_set(previousOrderProposal#6609083L, 0, 0), collect_list(item#6610322, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#6609080L)#6610391L, max(supplierGroup#6609087)#6610392, max(supplier#6609088)#6610393, max(supplyingPlant#6609118)#6610394, max(orderDateTime#6609095)#6610395, collect_list(parentItem#6610291, 0, 0)#6610396, collect_set(previousOrderProposal#6609083L, 0, 0)#6610398, collect_list(item#6610322, 0, 0)#6610397]
Results [10]: [shardId#6608407, orderProposalId#6609077L, max(originalReplenishmentRunId#6609080L)#6610391L AS originalReplenishmentRunId#6610339L, max(supplierGroup#6609087)#6610392 AS supplierGroup#6610340, max(supplier#6609088)#6610393 AS supplier#6610341, max(supplyingPlant#6609118)#6610394 AS supplyingPlant#6610342, max(orderDateTime#6609095)#6610395 AS orderDateTime#6610343, collect_list(parentItem#6610291, 0, 0)#6610396 AS parentItems#6610344, collect_set(previousOrderProposal#6609083L, 0, 0)#6610398 AS previousOrderProposals#6610346, struct(itemGroupId, coalesce(orderProposalItemGroupId#6609079, cast((monotonically_increasing_id() % 9999999999) as string)), items, collect_list(item#6610322, 0, 0)#6610397) AS itemGroup#6610400]
(61) ObjectHashAggregate
Input [10]: [shardId#6608407, orderProposalId#6609077L, originalReplenishmentRunId#6610339L, supplierGroup#6610340, supplier#6610341, supplyingPlant#6610342, orderDateTime#6610343, parentItems#6610344, previousOrderProposals#6610346, itemGroup#6610400]
Keys [2]: [shardId#6608407, orderProposalId#6609077L]
Functions [8]: [partial_max(originalReplenishmentRunId#6610339L), partial_max(supplierGroup#6610340), partial_max(supplier#6610341), partial_max(supplyingPlant#6610342), partial_max(orderDateTime#6610343), partial_collect_list(itemGroup#6610400, 0, 0), partial_collect_list(parentItems#6610344, 0, 0), partial_collect_set(previousOrderProposals#6610346, 0, 0)]
Aggregate Attributes [8]: [max#6611557L, max#6611558, max#6611559, max#6611560, max#6611561, buf#6611562, buf#6611563, buf#6611564]
Results [10]: [shardId#6608407, orderProposalId#6609077L, max#6611565L, max#6611566, max#6611567, max#6611568, max#6611569, buf#6611570, buf#6611571, buf#6611572]
(62) Exchange
Input [10]: [shardId#6608407, orderProposalId#6609077L, max#6611565L, max#6611566, max#6611567, max#6611568, max#6611569, buf#6611570, buf#6611571, buf#6611572]
Arguments: hashpartitioning(shardId#6608407, orderProposalId#6609077L, 30), ENSURE_REQUIREMENTS, [plan_id=3473825]
(63) ObjectHashAggregate
Input [10]: [shardId#6608407, orderProposalId#6609077L, max#6611565L, max#6611566, max#6611567, max#6611568, max#6611569, buf#6611570, buf#6611571, buf#6611572]
Keys [2]: [shardId#6608407, orderProposalId#6609077L]
Functions [8]: [max(originalReplenishmentRunId#6610339L), max(supplierGroup#6610340), max(supplier#6610341), max(supplyingPlant#6610342), max(orderDateTime#6610343), collect_list(itemGroup#6610400, 0, 0), collect_list(parentItems#6610344, 0, 0), collect_set(previousOrderProposals#6610346, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#6610339L)#6610422L, max(supplierGroup#6610340)#6610423, max(supplier#6610341)#6610424, max(supplyingPlant#6610342)#6610425, max(orderDateTime#6610343)#6610426, collect_list(itemGroup#6610400, 0, 0)#6610427, collect_list(parentItems#6610344, 0, 0)#6610428, collect_set(previousOrderProposals#6610346, 0, 0)#6610429]
Results [10]: [shardId#6608407, orderProposalId#6609077L, max(originalReplenishmentRunId#6610339L)#6610422L AS originalReplenishmentRunId#6610401L, max(supplierGroup#6610340)#6610423 AS supplierGroup#6610402, max(supplier#6610341)#6610424 AS supplier#6610403, max(supplyingPlant#6610342)#6610425 AS supplyingPlant#6610404, max(orderDateTime#6610343)#6610426 AS orderDateTime#6610405, collect_list(itemGroup#6610400, 0, 0)#6610427 AS itemGroups#6610406, flatten(collect_list(parentItems#6610344, 0, 0)#6610428) AS parentItems#6610407, flatten(collect_set(previousOrderProposals#6610346, 0, 0)#6610429) AS previousOrderProposals#6610408]
(64) Project
Output [2]: [shardId#6608407, struct(orderProposalId, orderProposalId#6609077L, originalReplenishmentRunId, originalReplenishmentRunId#6610401L, supplierGroup, supplierGroup#6610402, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#6610402) THEN supplier#6610403 END, supplyingPlant, supplyingPlant#6610404, orderDateTime, orderDateTime#6610405, itemGroups, itemGroups#6610406, previousOrderProposals, array_distinct(previousOrderProposals#6610408), parentItems, parentItems#6610407) AS orderProposal#6610433]
Input [10]: [shardId#6608407, orderProposalId#6609077L, originalReplenishmentRunId#6610401L, supplierGroup#6610402, supplier#6610403, supplyingPlant#6610404, orderDateTime#6610405, itemGroups#6610406, parentItems#6610407, previousOrderProposals#6610408]
(65) Project
Output [11]: [shardId#6608407, orderProposal#6610433.orderProposalId AS _extract_orderProposalId#6611189L, orderProposal#6610433.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#6611190L, orderProposal#6610433.supplierGroup AS _extract_supplierGroup#6611191, orderProposal#6610433.supplier AS _extract_supplier#6611192, orderProposal#6610433.supplyingPlant AS _extract_supplyingPlant#6611193, orderProposal#6610433.orderDateTime AS _extract_orderDateTime#6611194, orderProposal#6610433.itemGroups AS _extract_itemGroups#6611195, orderProposal#6610433.previousOrderProposals AS _extract_previousOrderProposals#6611196, orderProposal#6610433.parentItems AS _extract_parentItems#6611197, orderProposal#6610433.orderProposalId AS _extract_orderProposalId#6611198L]
Input [2]: [shardId#6608407, orderProposal#6610433]
(66) Exchange
Input [11]: [shardId#6608407, _extract_orderProposalId#6611189L, _extract_originalReplenishmentRunId#6611190L, _extract_supplierGroup#6611191, _extract_supplier#6611192, _extract_supplyingPlant#6611193, _extract_orderDateTime#6611194, _extract_itemGroups#6611195, _extract_previousOrderProposals#6611196, _extract_parentItems#6611197, _extract_orderProposalId#6611198L]
Arguments: hashpartitioning(coalesce(shardId#6608407, ), isnull(shardId#6608407), coalesce(_extract_orderProposalId#6611198L, 0), isnull(_extract_orderProposalId#6611198L), 30), ENSURE_REQUIREMENTS, [plan_id=3473829]
(67) Sort
Input [11]: [shardId#6608407, _extract_orderProposalId#6611189L, _extract_originalReplenishmentRunId#6611190L, _extract_supplierGroup#6611191, _extract_supplier#6611192, _extract_supplyingPlant#6611193, _extract_orderDateTime#6611194, _extract_itemGroups#6611195, _extract_previousOrderProposals#6611196, _extract_parentItems#6611197, _extract_orderProposalId#6611198L]
Arguments: [coalesce(shardId#6608407, ) ASC NULLS FIRST, isnull(shardId#6608407) ASC NULLS FIRST, coalesce(_extract_orderProposalId#6611198L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#6611198L) ASC NULLS FIRST], false, 0
(68) InMemoryTableScan
Output [3]: [shardId#6610446, orderProposalId#6610447L, optimizationGroups#6610449]
Arguments: [shardId#6610446, orderProposalId#6610447L, optimizationGroups#6610449], [isnotnull(orderProposalId#6610447L)]
(69) InMemoryRelation
Arguments: [shardId#6610446, orderProposalId#6610447L, items#6610448, optimizationGroups#6610449, isOptimal#6610450, optimizationInsights#6610452], StorageLevel(disk, memory, 2 replicas)
(70) Filter [codegen id : 2]
Input [3]: [shardId#6610446, orderProposalId#6610447L, optimizationGroups#6610449]
Condition : isnotnull(orderProposalId#6610447L)
(71) BroadcastExchange
Input [3]: [shardId#6610446, orderProposalId#6610447L, optimizationGroups#6610449]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=3473834]
(72) InMemoryTableScan
Output [2]: [items#6610084, shardId#6610082]
Arguments: [items#6610084, shardId#6610082], [(size(items#6610084.worklistShardItemId, true) > 0), isnotnull(items#6610084.worklistShardItemId), (shardId#6610082 = 0_1_10000002290)]
(73) InMemoryRelation
Arguments: [shardId#6610082, orderProposalId#6610083L, items#6610084, optimizationGroups#6610085, isOptimal#6610086, optimizationInsights#6610088], StorageLevel(disk, memory, 2 replicas)
(74) Filter [codegen id : 3]
Input [2]: [items#6610084, shardId#6610082]
Condition : (((size(items#6610084.worklistShardItemId, true) > 0) AND isnotnull(items#6610084.worklistShardItemId)) AND (shardId#6610082 = 0_1_10000002290))
(75) Project [codegen id : 3]
Output [1]: [items#6610084.worklistShardItemId AS _extract_worklistShardItemId#6611094]
Input [2]: [items#6610084, shardId#6610082]
(76) Generate [codegen id : 3]
Input [1]: [_extract_worklistShardItemId#6611094]
Arguments: explode(_extract_worklistShardItemId#6611094), false, [item#6610453L]
(77) Project [codegen id : 3]
Output [1]: [item#6610453L AS worklistShardItemId#6610454L]
Input [1]: [item#6610453L]
(78) BroadcastExchange
Input [1]: [worklistShardItemId#6610454L]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=3473842]
(79) Scan parquet
Output [5]: [orderProposalId#6610502L, isFallbackOrderOnly#6610519, worklistShardItemId#6610525L, shardId#6610546, sequenceId#6610524]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://dac252a8-bd1b-4f30-995e-f6d4a08836d2.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002290]
PartitionFilters: [isnotnull(shardId#6610546), isnotnull(sequenceId#6610524), (shardId#6610546 = 0_1_10000002290), (sequenceId#6610524 = 3)]
PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>
(80) ColumnarToRow [codegen id : 4]
Input [5]: [orderProposalId#6610502L, isFallbackOrderOnly#6610519, worklistShardItemId#6610525L, shardId#6610546, sequenceId#6610524]
(81) Filter [codegen id : 4]
Input [5]: [orderProposalId#6610502L, isFallbackOrderOnly#6610519, worklistShardItemId#6610525L, shardId#6610546, sequenceId#6610524]
Condition : ((isnotnull(worklistShardItemId#6610525L) AND NOT (isFallbackOrderOnly#6610519 <=> true)) AND isnotnull(orderProposalId#6610502L))
(82) Project [codegen id : 4]
Output [2]: [orderProposalId#6610502L, worklistShardItemId#6610525L]
Input [5]: [orderProposalId#6610502L, isFallbackOrderOnly#6610519, worklistShardItemId#6610525L, shardId#6610546, sequenceId#6610524]
(83) Exchange
Input [2]: [orderProposalId#6610502L, worklistShardItemId#6610525L]
Arguments: hashpartitioning(worklistShardItemId#6610525L, 30), REPARTITION_BY_NUM, [plan_id=3473849]
(84) Project
Output [2]: [worklistShardItemId#6610525L, orderProposalId#6610502L]
Input [2]: [orderProposalId#6610502L, worklistShardItemId#6610525L]
(85) BroadcastHashJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#6610454L]
Right keys [1]: [worklistShardItemId#6610525L]
Join type: Inner
Join condition: None
(86) Project [codegen id : 5]
Output [1]: [orderProposalId#6610502L]
Input [3]: [worklistShardItemId#6610454L, worklistShardItemId#6610525L, orderProposalId#6610502L]
(87) HashAggregate [codegen id : 5]
Input [1]: [orderProposalId#6610502L]
Keys [1]: [orderProposalId#6610502L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#6610502L]
(88) Exchange
Input [1]: [orderProposalId#6610502L]
Arguments: hashpartitioning(orderProposalId#6610502L, 30), ENSURE_REQUIREMENTS, [plan_id=3473856]
(89) HashAggregate
Input [1]: [orderProposalId#6610502L]
Keys [1]: [orderProposalId#6610502L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#6610502L]
(90) BroadcastHashJoin [codegen id : 6]
Left keys [1]: [orderProposalId#6610447L]
Right keys [1]: [orderProposalId#6610502L]
Join type: Inner
Join condition: None
(91) Project
Output [3]: [orderProposalId#6610447L, shardId#6610446, coalesce(transform(optimizationGroups#6610449, lambdafunction(struct(optGroupId, lambda x_12841#6610444.optGroupId, minOrderProfile, lambda x_12841#6610444.minOrderProfile, assignmentDetails, lambda x_12841#6610444.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_12841#6610444.minOrderGoal.dimensionType, unit, lambda x_12841#6610444.minOrderGoal.unit, unitUuid, lambda x_12841#6610444.minOrderGoal.unitUuid, goalValue, lambda x_12841#6610444.minOrderGoal.minOrderValue, calcValue, lambda x_12841#6610444.minOrderGoal.calculatedOrderValue)), lambda x_12841#6610444, false)), []) AS optimizationGroups#6610443]
Input [4]: [shardId#6610446, orderProposalId#6610447L, optimizationGroups#6610449, orderProposalId#6610502L]
(92) Exchange
Input [3]: [orderProposalId#6610447L, shardId#6610446, optimizationGroups#6610443]
Arguments: hashpartitioning(coalesce(shardId#6610446, ), isnull(shardId#6610446), coalesce(orderProposalId#6610447L, 0), isnull(orderProposalId#6610447L), 30), ENSURE_REQUIREMENTS, [plan_id=3473862]
(93) Sort [codegen id : 7]
Input [3]: [orderProposalId#6610447L, shardId#6610446, optimizationGroups#6610443]
Arguments: [coalesce(shardId#6610446, ) ASC NULLS FIRST, isnull(shardId#6610446) ASC NULLS FIRST, coalesce(orderProposalId#6610447L, 0) ASC NULLS FIRST, isnull(orderProposalId#6610447L) ASC NULLS FIRST], false, 0
(94) SortMergeJoin
Left keys [4]: [coalesce(shardId#6608407, ), isnull(shardId#6608407), coalesce(_extract_orderProposalId#6611198L, 0), isnull(_extract_orderProposalId#6611198L)]
Right keys [4]: [coalesce(shardId#6610446, ), isnull(shardId#6610446), coalesce(orderProposalId#6610447L, 0), isnull(orderProposalId#6610447L)]
Join type: LeftOuter
Join condition: None
(95) Project
Output [2]: [shardId#6608407, named_struct(orderProposalId, _extract_orderProposalId#6611198L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#6611190L, supplierGroup, _extract_supplierGroup#6611191, optimizationGroups, coalesce(optimizationGroups#6610443, []), supplier, _extract_supplier#6611192, supplyingPlant, _extract_supplyingPlant#6611193, orderDateTime, _extract_orderDateTime#6611194, itemGroups, _extract_itemGroups#6611195, previousOrderProposals, _extract_previousOrderProposals#6611196, parentItems, _extract_parentItems#6611197) AS orderProposal#6610550]
Input [14]: [shardId#6608407, _extract_orderProposalId#6611189L, _extract_originalReplenishmentRunId#6611190L, _extract_supplierGroup#6611191, _extract_supplier#6611192, _extract_supplyingPlant#6611193, _extract_orderDateTime#6611194, _extract_itemGroups#6611195, _extract_previousOrderProposals#6611196, _extract_parentItems#6611197, _extract_orderProposalId#6611198L, orderProposalId#6610447L, shardId#6610446, optimizationGroups#6610443]
(96) Filter
Input [1]: [orderProposal#6610550]
Condition : (size(orderProposal#6610550.parentItems.deliveryDateTime, true) > 0)
(97) Project
Output [1]: [orderProposal#6610550.parentItems.deliveryDateTime AS _extract_deliveryDateTime#6611969]
Input [1]: [orderProposal#6610550]
(98) Generate [codegen id : 1]
Input [1]: [_extract_deliveryDateTime#6611969]
Arguments: explode(_extract_deliveryDateTime#6611969), false, [numberOfOrderProposalItems#6611941]
(99) Project [codegen id : 1]
Output: []
Input [1]: [numberOfOrderProposalItems#6611941]
(100) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#6611980L]
Results [1]: [count#6611981L]
(101) Exchange
Input [1]: [count#6611981L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=3473980]
(102) HashAggregate [codegen id : 2]
Input [1]: [count#6611981L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#6611946L]
Results [1]: [count(1)#6611946L AS count#6611942L]