digraph G {
subgraph cluster0 {
isCluster="true";
id="cluster0";
label="WholeStageCodegen (2)\n \nduration: 3 ms";
tooltip="WholeStageCodegen (2)";
1 [id="node1" labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 3 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: 2.2 KiB<br>merged fetch fallback count: 0<br>local blocks read: 30<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>480.0 B (16.0 B, 16.0 B, 16.0 B (stage 307780.0: task 890005))<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>36 ms (0 ms, 0 ms, 20 ms (stage 307780.0: task 890016))<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: 1<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>2.2 KiB (75.0 B, 75.0 B, 75.0 B (stage 307780.0: task 890005))" tooltip="Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=979619]"];
subgraph cluster3 {
isCluster="true";
id="cluster3";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n166 ms (2 ms, 3 ms, 26 ms (stage 307780.0: task 890015))";
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>137 ms (2 ms, 2 ms, 26 ms (stage 307780.0: task 890015))<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: 39,968" tooltip="Generate explode(_extract_deliveryDateTime#3400725), false, [numberOfOrderProposalItems#3400697]"];
}
7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposal#3399126.parentItems.deliveryDateTime AS _extract_deliveryDateTime#3400725]"];
8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 792" tooltip="Filter (size(orderProposal#3399126.parentItems.deliveryDateTime, true) > 0)"];
9 [id="node9" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 792" tooltip="InMemoryTableScan [orderProposal#3399126], [(size(orderProposal#3399126.parentItems.deliveryDateTime, true) > 0)]"];
10 [id="node10" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, named_struct(orderProposalId, _extract_orderProposalId#3399954L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#3399946L, supplierGroup, _extract_supplierGroup#3399947, optimizationGroups, coalesce(optimizationGroups#3399019, []), supplier, _extract_supplier#3399948, supplyingPlant, _extract_supplyingPlant#3399949, orderDateTime, _extract_orderDateTime#3399950, itemGroups, _extract_itemGroups#3399951, previousOrderProposals, _extract_previousOrderProposals#3399952, parentItems, _extract_parentItems#3399953) AS orderProposal#3399126]"];
11 [id="node11" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 792<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307780.0: task 890005))" tooltip="SortMergeJoin [coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L)], [coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L)], 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 307780.0: task 890005))<br>peak memory total (min, med, max (stageId: taskId))<br>115.9 MiB (2.1 MiB, 4.1 MiB, 4.1 MiB (stage 307780.0: task 890005))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307780.0: task 890005))" tooltip="Sort [coalesce(shardId#3394574, ) ASC NULLS FIRST, isnull(shardId#3394574) ASC NULLS FIRST, coalesce(_extract_orderProposalId#3399954L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#3399954L) ASC NULLS FIRST], false, 0"];
13 [id="node13" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 792<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 792<br>local bytes read total (min, med, max (stageId: taskId))<br>6.8 MiB (158.1 KiB, 229.5 KiB, 312.5 KiB (stage 307780.0: task 890021))<br>merged fetch fallback count: 0<br>local blocks read: 517<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>72.5 MiB (1394.5 KiB, 2.5 MiB, 3.7 MiB (stage 307779.0: task 889977))<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>50 ms (1 ms, 1 ms, 2 ms (stage 307779.0: task 889983))<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 307780.0: task 890005))<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 total (min, med, max (stageId: taskId))<br>6.8 MiB (131.7 KiB, 241.5 KiB, 355.8 KiB (stage 307779.0: task 889977))" tooltip="Exchange hashpartitioning(coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L), 30), ENSURE_REQUIREMENTS, [plan_id=979453]"];
14 [id="node14" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399945L, orderProposal#3399007.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#3399946L, orderProposal#3399007.supplierGroup AS _extract_supplierGroup#3399947, orderProposal#3399007.supplier AS _extract_supplier#3399948, orderProposal#3399007.supplyingPlant AS _extract_supplyingPlant#3399949, orderProposal#3399007.orderDateTime AS _extract_orderDateTime#3399950, orderProposal#3399007.itemGroups AS _extract_itemGroups#3399951, orderProposal#3399007.previousOrderProposals AS _extract_previousOrderProposals#3399952, orderProposal#3399007.parentItems AS _extract_parentItems#3399953, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399954L]"];
15 [id="node15" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, struct(orderProposalId, orderProposalId#3395775L, originalReplenishmentRunId, originalReplenishmentRunId#3398975L, supplierGroup, supplierGroup#3398976, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#3398976) THEN supplier#3398977 END, supplyingPlant, supplyingPlant#3398978, orderDateTime, orderDateTime#3398979, itemGroups, itemGroups#3398980, previousOrderProposals, array_distinct(previousOrderProposals#3398982), parentItems, parentItems#3398981) AS orderProposal#3399007]"];
16 [id="node16" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 792<br>time in aggregation build total (min, med, max (stageId: taskId))<br>539 ms (10 ms, 13 ms, 45 ms (stage 307779.0: task 889984))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307779.0: task 889958))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L], functions=[max(originalReplenishmentRunId#3398913L), max(supplierGroup#3398914), max(supplier#3398915), max(supplyingPlant#3398916), max(orderDateTime#3398917), collect_list(itemGroup#3398974, 0, 0), collect_list(parentItems#3398918, 0, 0), collect_set(previousOrderProposals#3398920, 0, 0)])"];
17 [id="node17" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 792<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 792<br>local bytes read total (min, med, max (stageId: taskId))<br>6.9 MiB (131.8 KiB, 243.1 KiB, 355.7 KiB (stage 307779.0: task 889977))<br>merged fetch fallback count: 0<br>local blocks read: 513<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>72.5 MiB (1570.9 KiB, 2.3 MiB, 3.5 MiB (stage 307774.0: task 889952))<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>88 ms (1 ms, 1 ms, 42 ms (stage 307774.0: task 889950))<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 307779.0: task 889958))<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 total (min, med, max (stageId: taskId))<br>6.9 MiB (148.4 KiB, 224.6 KiB, 341.6 KiB (stage 307774.0: task 889952))" tooltip="Exchange hashpartitioning(shardId#3394574, orderProposalId#3395775L, 30), ENSURE_REQUIREMENTS, [plan_id=979449]"];
18 [id="node18" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 792<br>time in aggregation build total (min, med, max (stageId: taskId))<br>130 ms (3 ms, 3 ms, 30 ms (stage 307774.0: task 889922))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307774.0: task 889922))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L], functions=[partial_max(originalReplenishmentRunId#3398913L), partial_max(supplierGroup#3398914), partial_max(supplier#3398915), partial_max(supplyingPlant#3398916), partial_max(orderDateTime#3398917), partial_collect_list(itemGroup#3398974, 0, 0), partial_collect_list(parentItems#3398918, 0, 0), partial_collect_set(previousOrderProposals#3398920, 0, 0)])"];
19 [id="node19" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 792<br>time in aggregation build total (min, med, max (stageId: taskId))<br>641 ms (13 ms, 14 ms, 99 ms (stage 307774.0: task 889922))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307774.0: task 889922))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777], functions=[max(originalReplenishmentRunId#3395778L), max(supplierGroup#3395785), max(supplier#3395786), max(supplyingPlant#3395816), max(orderDateTime#3395793), collect_list(parentItem#3398865, 0, 0), collect_set(previousOrderProposal#3395781L, 0, 0), collect_list(item#3398896, 0, 0)])"];
20 [id="node20" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 19,473<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 19,473<br>local bytes read total (min, med, max (stageId: taskId))<br>8.8 MiB (194.6 KiB, 291.1 KiB, 431.3 KiB (stage 307774.0: task 889952))<br>merged fetch fallback count: 0<br>local blocks read: 840<br>remote merged chunks fetched: 0<br>remote blocks read: 60<br>data size total (min, med, max (stageId: taskId))<br>77.5 MiB (2.5 MiB, 2.6 MiB, 2.7 MiB (stage 307773.0: task 889825))<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>105 ms (1 ms, 2 ms, 39 ms (stage 307773.0: task 889891))<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 307774.0: task 889922))<br>remote bytes read total (min, med, max (stageId: taskId))<br>627.6 KiB (13.1 KiB, 20.6 KiB, 28.5 KiB (stage 307774.0: task 889952))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>98 ms (3 ms, 3 ms, 9 ms (stage 307774.0: task 889934))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>9.4 MiB (307.8 KiB, 322.8 KiB, 331.4 KiB (stage 307773.0: task 889811))" tooltip="Exchange hashpartitioning(shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, 30), ENSURE_REQUIREMENTS, [plan_id=979446]"];
21 [id="node21" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 19,473<br>time in aggregation build total (min, med, max (stageId: taskId))<br>6.5 s (107 ms, 140 ms, 955 ms (stage 307773.0: task 889875))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889733))<br>number of sort fallback tasks: 30" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777], functions=[partial_max(originalReplenishmentRunId#3395778L), partial_max(supplierGroup#3395785), partial_max(supplier#3395786), partial_max(supplyingPlant#3395816), partial_max(orderDateTime#3395793), partial_collect_list(parentItem#3398865, 0, 0), partial_collect_set(previousOrderProposal#3395781L, 0, 0), partial_collect_list(item#3398896, 0, 0)])"];
22 [id="node22" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, orderDateTime#3395793, splitIndicator#3395780L, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865, struct(itemId, orderProposalItemId#3395776, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, deliveryDateTime, deliveryDateTime#3395794, orderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398899.isOrderUnit, lambda x_11242#3398899, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398900.isOrderUnit, lambda x_11242#3398900, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398901.isOrderUnit, lambda x_11242#3398901, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398902.isOrderUnit, lambda x_11242#3398902, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), orderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, ... 13 more fields) AS item#3398896]"];
23 [id="node23" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, struct(itemId, orderProposalItemId#3395776, itemGroupId, orderProposalItemGroupId#3395777, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, sourceOfSupplyUuid, sourceOfSupplyUuid#3395784, deliveryDateTime, deliveryDateTime#3395794, unitPrice, netPriceAmount#3395803, unitPriceCurrency, netPriceCurrencyCode#3395804, unitPriceQuantity, ... 37 more fields) AS parentItem#3398865]"];
24 [id="node24" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, ... 12 more fields]"];
subgraph cluster25 {
isCluster="true";
id="cluster25";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n9.1 s (144 ms, 199 ms, 1.3 s (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (1)";
26 [id="node26" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, ... 11 more fields]"];
27 [id="node27" labelType="html" label="<b>Filter</b><br><br>number of output rows: 39,968" tooltip="Filter NOT (isFallbackOrderOnly#3395797 <=> true)"];
}
28 [id="node28" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 39,968" tooltip="InMemoryTableScan [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, ... 14 more fields], [NOT (isFallbackOrderOnly#3395797 <=> true)]"];
subgraph cluster29 {
isCluster="true";
id="cluster29";
label="WholeStageCodegen (15)\n \nduration: total (min, med, max (stageId: taskId))\n13.6 s (346 ms, 415 ms, 629 ms (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (15)";
30 [id="node30" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 17 more fields]"];
31 [id="node31" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 39,968<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889733))" tooltip="SortMergeJoin [shardId#3394574, worklistShardItemId#3395327L], [shardId#3398236, worklistShardItemId#3398237L], LeftOuter"];
}
subgraph cluster32 {
isCluster="true";
id="cluster32";
label="WholeStageCodegen (12)\n \nduration: total (min, med, max (stageId: taskId))\n19.8 s (469 ms, 573 ms, 1.3 s (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (12)";
33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 16 more fields]"];
34 [id="node34" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 39,968<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889733))" tooltip="SortMergeJoin [shardId#3394574, worklistShardItemId#3395327L], [shardId#3398223, worklistShardItemId#3398224L], LeftOuter"];
}
subgraph cluster35 {
isCluster="true";
id="cluster35";
label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n23.5 s (551 ms, 661 ms, 1.9 s (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (9)";
36 [id="node36" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 15 more fields]"];
37 [id="node37" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 39,968<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889733))" tooltip="SortMergeJoin [shardId#3394574, worklistShardItemId#3395327L], [shardId#3398207, worklistShardItemId#3398208L], LeftOuter"];
}
subgraph cluster38 {
isCluster="true";
id="cluster38";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n24.2 s (553 ms, 663 ms, 2.4 s (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (6)";
39 [id="node39" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>7 ms (0 ms, 0 ms, 2 ms (stage 307773.0: task 889875))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 307773.0: task 889723))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889723))" tooltip="Sort [shardId#3394574 ASC NULLS FIRST, worklistShardItemId#3395327L ASC NULLS FIRST], false, 0"];
}
40 [id="node40" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 39,968<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 39,968<br>local bytes read total (min, med, max (stageId: taskId))<br>4.8 MiB (160.7 KiB, 174.1 KiB, 185.9 KiB (stage 307773.0: task 889834))<br>merged fetch fallback count: 0<br>local blocks read: 448<br>remote merged chunks fetched: 0<br>remote blocks read: 452<br>data size total (min, med, max (stageId: taskId))<br>46.1 MiB (1506.9 KiB, 1570.5 KiB, 1651.1 KiB (stage 307772.0: task 888932))<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>98 ms (1 ms, 2 ms, 26 ms (stage 307772.0: task 888958))<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 307773.0: task 889723))<br>remote bytes read total (min, med, max (stageId: taskId))<br>4.8 MiB (141.3 KiB, 153.4 KiB, 320.0 KiB (stage 307773.0: task 889875))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>182 ms (1 ms, 2 ms, 42 ms (stage 307773.0: task 889910))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>9.5 MiB (313.5 KiB, 325.0 KiB, 340.5 KiB (stage 307772.0: task 888932))" tooltip="Exchange hashpartitioning(shardId#3394574, worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979150]"];
subgraph cluster41 {
isCluster="true";
id="cluster41";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n917 ms (19 ms, 27 ms, 57 ms (stage 307772.0: task 889038))";
tooltip="WholeStageCodegen (5)";
42 [id="node42" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 14 more fields]"];
43 [id="node43" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 39,968<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307772.0: task 888894))" tooltip="SortMergeJoin [worklistShardItemId#3395327L], [worklistShardItemId#3395999L], LeftOuter, (shardId#3394574 = 0_7_10000000532)"];
}
subgraph cluster44 {
isCluster="true";
id="cluster44";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n1.1 s (19 ms, 28 ms, 141 ms (stage 307772.0: task 888959))";
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 307772.0: task 888894))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 307772.0: task 888894))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307772.0: task 888894))" tooltip="Sort [worklistShardItemId#3395327L ASC NULLS FIRST], false, 0"];
}
46 [id="node46" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 39,968<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 39,968<br>local bytes read total (min, med, max (stageId: taskId))<br>180.2 KiB (3.0 KiB, 8.3 KiB, 8.8 KiB (stage 307772.0: task 888931))<br>merged fetch fallback count: 0<br>local blocks read: 448<br>remote merged chunks fetched: 0<br>remote blocks read: 452<br>data size total (min, med, max (stageId: taskId))<br>2.1 MiB (69.2 KiB, 72.5 KiB, 78.1 KiB (stage 307767.0: task 888713))<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>54 ms (1 ms, 1 ms, 2 ms (stage 307767.0: task 888701))<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>24 ms (0 ms, 0 ms, 12 ms (stage 307772.0: task 889002))<br>remote bytes read total (min, med, max (stageId: taskId))<br>181.5 KiB (3.4 KiB, 3.7 KiB, 9.2 KiB (stage 307772.0: task 888981))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>154 ms (4 ms, 4 ms, 19 ms (stage 307772.0: task 889002))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>361.7 KiB (11.6 KiB, 12.0 KiB, 12.7 KiB (stage 307767.0: task 888725))" tooltip="Exchange hashpartitioning(worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979131]"];
subgraph cluster47 {
isCluster="true";
id="cluster47";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n156 ms (3 ms, 5 ms, 17 ms (stage 307767.0: task 888724))";
tooltip="WholeStageCodegen (1)";
48 [id="node48" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3394574, item#3395326.worklistShardItemId AS worklistShardItemId#3395327L, item#3395326.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395328, item#3395326.qty AS qty#3395329]"];
49 [id="node49" labelType="html" label="<b>Generate</b><br><br>number of output rows: 39,968" tooltip="Generate explode(items#3394576), [shardId#3394574], false, [item#3395326]"];
50 [id="node50" labelType="html" label="<b>Filter</b><br><br>number of output rows: 792" tooltip="Filter ((size(items#3394576, true) > 0) AND isnotnull(items#3394576))"];
}
51 [id="node51" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 792" tooltip="InMemoryTableScan [shardId#3394574, items#3394576], [(size(items#3394576, true) > 0), isnotnull(items#3394576)]"];
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#3394574) AND (shardId#3394574 = 0_7_10000000532))"];
}
54 [id="node54" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]"];
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#3394574) AND (shardId#3394574 = 0_7_10000000532))"];
57 [id="node57" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#3394574,orderProposalId#3394575L,items#3394576,optimizationGroups#3394577,isOptimal#3394578,lastModified#3394579,optimizationInsights#3394580]"];
}
subgraph cluster58 {
isCluster="true";
id="cluster58";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n1.1 s (19 ms, 28 ms, 110 ms (stage 307772.0: task 888959))";
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 307772.0: task 888894))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 307772.0: task 888894))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307772.0: task 888894))" tooltip="Sort [worklistShardItemId#3395999L ASC NULLS FIRST], false, 0"];
60 [id="node60" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, ... 11 more fields]"];
}
61 [id="node61" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 39,968<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 39,968<br>local bytes read total (min, med, max (stageId: taskId))<br>4.0 MiB (111.6 KiB, 135.0 KiB, 156.7 KiB (stage 307772.0: task 889020))<br>merged fetch fallback count: 0<br>local blocks read: 492<br>remote merged chunks fetched: 0<br>remote blocks read: 618<br>data size total (min, med, max (stageId: taskId))<br>44.6 MiB (1175.0 KiB, 1232.2 KiB, 1301.6 KiB (stage 307768.0: task 888747))<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>89 ms (1 ms, 1 ms, 17 ms (stage 307768.0: task 888778))<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>13 ms (0 ms, 0 ms, 12 ms (stage 307772.0: task 889020))<br>remote bytes read total (min, med, max (stageId: taskId))<br>5.0 MiB (151.6 KiB, 174.8 KiB, 194.2 KiB (stage 307772.0: task 888932))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>207 ms (4 ms, 5 ms, 29 ms (stage 307772.0: task 889020))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>9.0 MiB (237.6 KiB, 250.1 KiB, 262.2 KiB (stage 307768.0: task 888747))" tooltip="Exchange hashpartitioning(worklistShardItemId#3395999L, 30), REPARTITION_BY_NUM, [plan_id=979141]"];
subgraph cluster62 {
isCluster="true";
id="cluster62";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n5.0 s (99 ms, 121 ms, 374 ms (stage 307768.0: task 888801))";
tooltip="WholeStageCodegen (3)";
63 [id="node63" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, ... 11 more fields]"];
64 [id="node64" labelType="html" label="<b>Filter</b><br><br>number of output rows: 39,968" tooltip="Filter isnotnull(worklistShardItemId#3395999L)"];
65 [id="node65" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 39,968<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>4.2 s (92 ms, 111 ms, 165 ms (stage 307768.0: task 888822))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 5.9 MiB<br>number of output rows: 39,968<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#3395976L,orderProposalItemId#3395977,supplierGroup#3395978,supplier#3395979,plant#3395980,deliveryDateTime#3395981,subrange#3395982,supplyingPlant#3395983,productGroup#3395984,product#3395985,orderDateTime#3395986,availabilityDateTime#3395987,nextAvailabilityDateTime#3395988,sourceOfSupplyUuid#3395990,isFallbackOrderOnly#3395993,splitIndicator#3395995L,previousOrderProposal#3395996L,worklistShardItemId#3395999L,orderProposalItemGroupId#3396000,externalProductId#3396001,externalPlantId#3396002,logisticUnits#3396003,orderQuantityBaseUom#3396004,orderQuantityBaseUomUuid#3396005,minimumOrderQuantity#3396006,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#3395999L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#3396020), isnotnull(sequenceId#3395998), (shardId#3396020 = 0_7_10000000532), ..., 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))\n11.9 s (275 ms, 330 ms, 1.1 s (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (8)";
68 [id="node68" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>889 ms (17 ms, 23 ms, 57 ms (stage 307773.0: task 889826))<br>peak memory total (min, med, max (stageId: taskId))<br>675.0 MiB (22.5 MiB, 22.5 MiB, 22.5 MiB (stage 307773.0: task 889723))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889723))" tooltip="Sort [shardId#3398207 ASC NULLS FIRST, worklistShardItemId#3398208L ASC NULLS FIRST], false, 0"];
}
69 [id="node69" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 597,098<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 597,098<br>local bytes read total (min, med, max (stageId: taskId))<br>7.3 MiB (231.0 KiB, 240.3 KiB, 360.3 KiB (stage 307773.0: task 889875))<br>merged fetch fallback count: 0<br>local blocks read: 248<br>remote merged chunks fetched: 0<br>remote blocks read: 652<br>data size total (min, med, max (stageId: taskId))<br>610.4 MiB (20.1 MiB, 20.4 MiB, 20.6 MiB (stage 307771.0: task 889580))<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>96 ms (2 ms, 2 ms, 7 ms (stage 307771.0: task 888705))<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 307773.0: task 889723))<br>remote bytes read total (min, med, max (stageId: taskId))<br>19.0 MiB (539.0 KiB, 658.4 KiB, 668.4 KiB (stage 307773.0: task 889834))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>402 ms (5 ms, 7 ms, 79 ms (stage 307773.0: task 889910))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>26.3 MiB (882.1 KiB, 898.3 KiB, 908.4 KiB (stage 307771.0: task 889188))" tooltip="Exchange hashpartitioning(shardId#3398207, worklistShardItemId#3398208L, 30), ENSURE_REQUIREMENTS, [plan_id=979156]"];
subgraph cluster70 {
isCluster="true";
id="cluster70";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n26.5 s (752 ms, 859 ms, 1.2 s (stage 307771.0: task 888715))";
tooltip="WholeStageCodegen (7)";
71 [id="node71" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3398207, worklistShardItemId#3398208L, coalesce(kpis#3398212, []) AS prodLocSpecificKpis#3398213]"];
72 [id="node72" labelType="html" label="<b>Filter</b><br><br>number of output rows: 597,098" tooltip="Filter (((isnull(qty#3398209) AND isnull(demandChannel#3398210)) AND isnull(demandStream#3398211)) AND (isnotnull(shardId#3398207) AND isnotnull(worklistShardItemId#3398208L)))"];
73 [id="node73" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 2,388,392" tooltip="Scan ExistingRDD[shardId#3398207,worklistShardItemId#3398208L,qty#3398209,demandChannel#3398210,demandStream#3398211,kpis#3398212]"];
}
subgraph cluster74 {
isCluster="true";
id="cluster74";
label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n10.2 s (235 ms, 287 ms, 783 ms (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (11)";
75 [id="node75" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>60 ms (1 ms, 1 ms, 26 ms (stage 307773.0: task 889859))<br>peak memory total (min, med, max (stageId: taskId))<br>255.0 MiB (8.5 MiB, 8.5 MiB, 8.5 MiB (stage 307773.0: task 889723))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889723))" tooltip="Sort [shardId#3398223 ASC NULLS FIRST, worklistShardItemId#3398224L ASC NULLS FIRST], false, 0"];
}
76 [id="node76" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 597,098<br>time in aggregation build total (min, med, max (stageId: taskId))<br>1.2 s (23 ms, 39 ms, 100 ms (stage 307773.0: task 889875))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889733))<br>number of sort fallback tasks: 30" tooltip="ObjectHashAggregate(keys=[shardId#3398223, worklistShardItemId#3398224L], functions=[collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)])"];
77 [id="node77" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 597,098<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 597,098<br>local bytes read total (min, med, max (stageId: taskId))<br>2.1 MiB (69.7 KiB, 71.2 KiB, 78.8 KiB (stage 307773.0: task 889879))<br>merged fetch fallback count: 0<br>local blocks read: 272<br>remote merged chunks fetched: 0<br>remote blocks read: 628<br>data size total (min, med, max (stageId: taskId))<br>236.9 MiB (7.8 MiB, 7.9 MiB, 8.0 MiB (stage 307769.0: task 888954))<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>60 ms (1 ms, 1 ms, 2 ms (stage 307769.0: task 888814))<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>27 ms (0 ms, 0 ms, 9 ms (stage 307773.0: task 889903))<br>remote bytes read total (min, med, max (stageId: taskId))<br>4.8 MiB (157.3 KiB, 165.6 KiB, 169.3 KiB (stage 307773.0: task 889859))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>396 ms (4 ms, 7 ms, 78 ms (stage 307773.0: task 889910))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>6.9 MiB (235.1 KiB, 237.1 KiB, 238.3 KiB (stage 307769.0: task 888954))" tooltip="Exchange hashpartitioning(shardId#3398223, worklistShardItemId#3398224L, 30), ENSURE_REQUIREMENTS, [plan_id=979167]"];
78 [id="node78" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 597,098<br>time in aggregation build total (min, med, max (stageId: taskId))<br>26.3 s (758 ms, 856 ms, 1.1 s (stage 307769.0: task 888703))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307769.0: task 888709))<br>number of sort fallback tasks: 30" tooltip="ObjectHashAggregate(keys=[shardId#3398223, worklistShardItemId#3398224L], functions=[partial_collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)])"];
subgraph cluster79 {
isCluster="true";
id="cluster79";
label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n25.8 s (743 ms, 839 ms, 1.1 s (stage 307769.0: task 888703))";
tooltip="WholeStageCodegen (10)";
80 [id="node80" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3398223, worklistShardItemId#3398224L, demandChannel#3398226, demandStream#3398227, kpis#3398228]"];
81 [id="node81" labelType="html" label="<b>Filter</b><br><br>number of output rows: 597,098" tooltip="Filter ((((isnull(qty#3398225) AND isnotnull(demandChannel#3398226)) AND isnotnull(demandStream#3398227)) AND (size(kpis#3398228, true) > 0)) AND (isnotnull(shardId#3398223) AND isnotnull(worklistShardItemId#3398224L)))"];
82 [id="node82" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 2,388,392" tooltip="Scan ExistingRDD[shardId#3398223,worklistShardItemId#3398224L,qty#3398225,demandChannel#3398226,demandStream#3398227,kpis#3398228]"];
}
subgraph cluster83 {
isCluster="true";
id="cluster83";
label="WholeStageCodegen (14)\n \nduration: total (min, med, max (stageId: taskId))\n7.1 s (173 ms, 207 ms, 432 ms (stage 307773.0: task 889875))";
tooltip="WholeStageCodegen (14)";
84 [id="node84" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>61 ms (1 ms, 1 ms, 28 ms (stage 307773.0: task 889820))<br>peak memory total (min, med, max (stageId: taskId))<br>735.0 MiB (24.5 MiB, 24.5 MiB, 24.5 MiB (stage 307773.0: task 889723))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889723))" tooltip="Sort [shardId#3398236 ASC NULLS FIRST, worklistShardItemId#3398237L ASC NULLS FIRST], false, 0"];
}
85 [id="node85" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 597,098<br>time in aggregation build total (min, med, max (stageId: taskId))<br>2.5 s (50 ms, 81 ms, 160 ms (stage 307773.0: task 889902))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307773.0: task 889733))<br>number of sort fallback tasks: 30" tooltip="ObjectHashAggregate(keys=[shardId#3398236, worklistShardItemId#3398237L], functions=[collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)])"];
86 [id="node86" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 1,173,819<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1,173,819<br>local bytes read total (min, med, max (stageId: taskId))<br>8.7 MiB (278.5 KiB, 287.2 KiB, 442.5 KiB (stage 307773.0: task 889875))<br>merged fetch fallback count: 0<br>local blocks read: 342<br>remote merged chunks fetched: 0<br>remote blocks read: 558<br>data size total (min, med, max (stageId: taskId))<br>727.3 MiB (24.1 MiB, 24.2 MiB, 24.4 MiB (stage 307770.0: task 889345))<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>84 ms (2 ms, 2 ms, 3 ms (stage 307770.0: task 889673))<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 307773.0: task 889723))<br>remote bytes read total (min, med, max (stageId: taskId))<br>14.2 MiB (338.8 KiB, 495.0 KiB, 501.9 KiB (stage 307773.0: task 889859))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>349 ms (4 ms, 6 ms, 42 ms (stage 307773.0: task 889903))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>22.9 MiB (777.0 KiB, 781.3 KiB, 787.6 KiB (stage 307770.0: task 889345))" tooltip="Exchange hashpartitioning(shardId#3398236, worklistShardItemId#3398237L, 30), ENSURE_REQUIREMENTS, [plan_id=979179]"];
87 [id="node87" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 1,173,819<br>time in aggregation build total (min, med, max (stageId: taskId))<br>29.0 s (782 ms, 827 ms, 2.4 s (stage 307770.0: task 888712))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307770.0: task 888704))<br>number of sort fallback tasks: 30" tooltip="ObjectHashAggregate(keys=[shardId#3398236, worklistShardItemId#3398237L], functions=[partial_collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)])"];
subgraph cluster88 {
isCluster="true";
id="cluster88";
label="WholeStageCodegen (13)\n \nduration: total (min, med, max (stageId: taskId))\n27.6 s (743 ms, 787 ms, 2.3 s (stage 307770.0: task 888712))";
tooltip="WholeStageCodegen (13)";
89 [id="node89" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, kpis#3398241]"];
90 [id="node90" labelType="html" label="<b>Filter</b><br><br>number of output rows: 1,194,196" tooltip="Filter ((isnotnull(qty#3398238) AND isnotnull(kpis#3398241)) AND (isnotnull(shardId#3398236) AND isnotnull(worklistShardItemId#3398237L)))"];
91 [id="node91" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 2,388,392" tooltip="Scan ExistingRDD[shardId#3398236,worklistShardItemId#3398237L,qty#3398238,demandChannel#3398239,demandStream#3398240,kpis#3398241]"];
}
subgraph cluster92 {
isCluster="true";
id="cluster92";
label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n1.5 s (15 ms, 29 ms, 243 ms (stage 307780.0: task 890004))";
tooltip="WholeStageCodegen (9)";
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 307780.0: task 890005))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 307780.0: task 890005))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307780.0: task 890005))" tooltip="Sort [coalesce(shardId#3399022, ) ASC NULLS FIRST, isnull(shardId#3399022) ASC NULLS FIRST, coalesce(orderProposalId#3399023L, 0) ASC NULLS FIRST, isnull(orderProposalId#3399023L) ASC NULLS FIRST], false, 0"];
}
94 [id="node94" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 792<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 792<br>local bytes read total (min, med, max (stageId: taskId))<br>43.6 KiB (959.0 B, 1490.0 B, 1976.0 B (stage 307780.0: task 890021))<br>merged fetch fallback count: 0<br>local blocks read: 373<br>remote merged chunks fetched: 0<br>remote blocks read: 161<br>data size total (min, med, max (stageId: taskId))<br>43.3 KiB (952.0 B, 1456.0 B, 2.1 KiB (stage 307778.0: task 889175))<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>43 ms (0 ms, 1 ms, 13 ms (stage 307778.0: task 889133))<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>17 ms (0 ms, 0 ms, 16 ms (stage 307780.0: task 890027))<br>remote bytes read total (min, med, max (stageId: taskId))<br>18.8 KiB (224.0 B, 701.0 B, 1005.0 B (stage 307780.0: task 890023))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>149 ms (0 ms, 4 ms, 29 ms (stage 307780.0: task 890027))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>62.4 KiB (1424.0 B, 2.1 KiB, 2.8 KiB (stage 307778.0: task 889175))" tooltip="Exchange hashpartitioning(coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L), 30), ENSURE_REQUIREMENTS, [plan_id=979492]"];
95 [id="node95" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#3399023L, shardId#3399022, coalesce(transform(optimizationGroups#3399025, lambdafunction(struct(optGroupId, lambda x_11246#3399020.optGroupId, minOrderProfile, lambda x_11246#3399020.minOrderProfile, assignmentDetails, lambda x_11246#3399020.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_11246#3399020.minOrderGoal.dimensionType, unit, lambda x_11246#3399020.minOrderGoal.unit, unitUuid, lambda x_11246#3399020.minOrderGoal.unitUuid, goalValue, lambda x_11246#3399020.minOrderGoal.minOrderValue, calcValue, lambda x_11246#3399020.minOrderGoal.calculatedOrderValue), transportLoadProfile, null, transportLoadGoal, null), lambda x_11246#3399020, false)), []) AS optimizationGroups#3399019]"];
subgraph cluster96 {
isCluster="true";
id="cluster96";
label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n789 ms (6 ms, 7 ms, 209 ms (stage 307778.0: task 889016))";
tooltip="WholeStageCodegen (8)";
97 [id="node97" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 792<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307778.0: task 889040))" tooltip="SortMergeJoin [orderProposalId#3399023L], [orderProposalId#3399078L], Inner"];
}
subgraph cluster98 {
isCluster="true";
id="cluster98";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n2.8 s (7 ms, 8 ms, 1.1 s (stage 307778.0: task 889017))";
tooltip="WholeStageCodegen (3)";
99 [id="node99" 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 307778.0: task 889040))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 307778.0: task 889040))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307778.0: task 889040))" tooltip="Sort [orderProposalId#3399023L ASC NULLS FIRST], false, 0"];
}
100 [id="node100" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 792<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 792<br>local bytes read total (min, med, max (stageId: taskId))<br>35.1 KiB (365.0 B, 1412.0 B, 1986.0 B (stage 307778.0: task 889144))<br>merged fetch fallback count: 0<br>local blocks read: 299<br>remote merged chunks fetched: 0<br>remote blocks read: 226<br>data size total (min, med, max (stageId: taskId))<br>43.3 KiB (1400.0 B, 1456.0 B, 1568.0 B (stage 307777.0: task 888757))<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>34 ms (0 ms, 1 ms, 1 ms (stage 307777.0: task 888754))<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>47 ms (0 ms, 0 ms, 33 ms (stage 307778.0: task 889168))<br>remote bytes read total (min, med, max (stageId: taskId))<br>26.4 KiB (224.0 B, 759.0 B, 2.2 KiB (stage 307778.0: task 889175))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>164 ms (1 ms, 4 ms, 40 ms (stage 307778.0: task 889168))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>61.5 KiB (1552.0 B, 2.0 KiB, 2.3 KiB (stage 307777.0: task 888761))" tooltip="Exchange hashpartitioning(orderProposalId#3399023L, 30), ENSURE_REQUIREMENTS, [plan_id=979458]"];
subgraph cluster101 {
isCluster="true";
id="cluster101";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n325 ms (2 ms, 2 ms, 189 ms (stage 307777.0: task 888723))";
tooltip="WholeStageCodegen (2)";
102 [id="node102" labelType="html" label="<b>Filter</b><br><br>number of output rows: 792" tooltip="Filter isnotnull(orderProposalId#3399023L)"];
}
103 [id="node103" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 792" tooltip="InMemoryTableScan [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025], [isnotnull(orderProposalId#3399023L)]"];
subgraph cluster104 {
isCluster="true";
id="cluster104";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
105 [id="node105" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"];
}
106 [id="node106" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]"];
subgraph cluster107 {
isCluster="true";
id="cluster107";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
108 [id="node108" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"];
109 [id="node109" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#3394574,orderProposalId#3394575L,items#3394576,optimizationGroups#3394577,isOptimal#3394578,lastModified#3394579,optimizationInsights#3394580]"];
}
subgraph cluster110 {
isCluster="true";
id="cluster110";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n1.8 s (7 ms, 8 ms, 668 ms (stage 307778.0: task 889017))";
tooltip="WholeStageCodegen (7)";
111 [id="node111" 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 307778.0: task 889040))<br>peak memory total (min, med, max (stageId: taskId))<br>61.9 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 307778.0: task 889040))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307778.0: task 889040))" tooltip="Sort [orderProposalId#3399078L ASC NULLS FIRST], false, 0"];
112 [id="node112" 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>57 ms (1 ms, 2 ms, 4 ms (stage 307778.0: task 889017))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 307778.0: task 889040))<br>number of output rows: 792<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#3399078L], functions=[])"];
}
113 [id="node113" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 19,399<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 19,399<br>local bytes read total (min, med, max (stageId: taskId))<br>57.1 KiB (447.0 B, 661.0 B, 9.2 KiB (stage 307778.0: task 889175))<br>merged fetch fallback count: 0<br>local blocks read: 195<br>remote merged chunks fetched: 0<br>remote blocks read: 705<br>data size total (min, med, max (stageId: taskId))<br>303.1 KiB (9.9 KiB, 10.1 KiB, 10.4 KiB (stage 307776.0: task 888977))<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>63 ms (1 ms, 1 ms, 13 ms (stage 307776.0: task 888984))<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 307778.0: task 889040))<br>remote bytes read total (min, med, max (stageId: taskId))<br>207.6 KiB (1548.0 B, 7.9 KiB, 10.7 KiB (stage 307778.0: task 889181))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>176 ms (3 ms, 4 ms, 39 ms (stage 307778.0: task 889168))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>264.6 KiB (8.6 KiB, 8.8 KiB, 9.0 KiB (stage 307776.0: task 888977))" tooltip="Exchange hashpartitioning(orderProposalId#3399078L, 30), ENSURE_REQUIREMENTS, [plan_id=979483]"];
subgraph cluster114 {
isCluster="true";
id="cluster114";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n662 ms (7 ms, 9 ms, 212 ms (stage 307776.0: task 888890))";
tooltip="WholeStageCodegen (6)";
115 [id="node115" 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>206 ms (3 ms, 4 ms, 28 ms (stage 307776.0: task 888964))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 307776.0: task 888884))<br>number of output rows: 19,399<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#3399078L], functions=[])"];
116 [id="node116" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#3399078L]"];
117 [id="node117" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 39,968" tooltip="BroadcastHashJoin [worklistShardItemId#3399030L], [worklistShardItemId#3399101L], Inner, BuildLeft, false"];
131 [id="node131" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#3399101L, orderProposalId#3399078L]"];
}
118 [id="node118" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 4 ms<br>time to build: 7 ms<br>time to collect: 274 ms<br>number of output rows: 39,968<br>data size: 3.0 MiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=979469]"];
subgraph cluster119 {
isCluster="true";
id="cluster119";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n47 ms (0 ms, 1 ms, 6 ms (stage 307650.0: task 888620))";
tooltip="WholeStageCodegen (4)";
120 [id="node120" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#3399029L AS worklistShardItemId#3399030L]"];
121 [id="node121" labelType="html" label="<b>Generate</b><br><br>number of output rows: 39,968" tooltip="Generate explode(_extract_worklistShardItemId#3399670), false, [item#3399029L]"];
122 [id="node122" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#3398651.worklistShardItemId AS _extract_worklistShardItemId#3399670]"];
123 [id="node123" labelType="html" label="<b>Filter</b><br><br>number of output rows: 792" tooltip="Filter (((size(items#3398651.worklistShardItemId, true) > 0) AND isnotnull(items#3398651.worklistShardItemId)) AND (shardId#3398649 = 0_7_10000000532))"];
}
124 [id="node124" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 792" tooltip="InMemoryTableScan [items#3398651, shardId#3398649], [(size(items#3398651.worklistShardItemId, true) > 0), isnotnull(items#3398651.worklistShardItemId), (shardId#3398649 = 0_7_10000000532)]"];
subgraph cluster125 {
isCluster="true";
id="cluster125";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
126 [id="node126" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"];
}
127 [id="node127" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]"];
subgraph cluster128 {
isCluster="true";
id="cluster128";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
129 [id="node129" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"];
130 [id="node130" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#3394574,orderProposalId#3394575L,items#3394576,optimizationGroups#3394577,isOptimal#3394578,lastModified#3394579,optimizationInsights#3394580]"];
}
132 [id="node132" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 39,968<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 39,968<br>local bytes read total (min, med, max (stageId: taskId))<br>246.6 KiB (4.1 KiB, 9.0 KiB, 9.7 KiB (stage 307776.0: task 888960))<br>merged fetch fallback count: 0<br>local blocks read: 431<br>remote merged chunks fetched: 0<br>remote blocks read: 679<br>data size total (min, med, max (stageId: taskId))<br>936.8 KiB (24.1 KiB, 25.3 KiB, 26.7 KiB (stage 307775.0: task 888692))<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>71 ms (1 ms, 1 ms, 4 ms (stage 307775.0: task 888784))<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>30 ms (0 ms, 0 ms, 11 ms (stage 307776.0: task 888961))<br>remote bytes read total (min, med, max (stageId: taskId))<br>381.9 KiB (11.4 KiB, 12.1 KiB, 16.6 KiB (stage 307776.0: task 888994))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>203 ms (4 ms, 4 ms, 28 ms (stage 307776.0: task 888884))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>628.5 KiB (16.3 KiB, 16.9 KiB, 17.8 KiB (stage 307775.0: task 888692))" tooltip="Exchange hashpartitioning(worklistShardItemId#3399101L, 30), REPARTITION_BY_NUM, [plan_id=979476]"];
subgraph cluster133 {
isCluster="true";
id="cluster133";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n5.4 s (111 ms, 135 ms, 305 ms (stage 307775.0: task 888784))";
tooltip="WholeStageCodegen (5)";
134 [id="node134" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#3399078L, worklistShardItemId#3399101L]"];
135 [id="node135" labelType="html" label="<b>Filter</b><br><br>number of output rows: 39,968" tooltip="Filter ((isnotnull(worklistShardItemId#3399101L) AND NOT (isFallbackOrderOnly#3399095 <=> true)) AND isnotnull(orderProposalId#3399078L))"];
136 [id="node136" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 39,968<br>number of input batches: 37" tooltip="ColumnarToRow"];
}
137 [id="node137" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 37<br>scan time total (min, med, max (stageId: taskId))<br>5.0 s (107 ms, 129 ms, 254 ms (stage 307775.0: task 888696))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 5.9 MiB<br>number of output rows: 39,968<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#3399078L,isFallbackOrderOnly#3399095,worklistShardItemId#3399101L,shardId#3399122,sequenceId#3399100] Batched: true, DataFilters: [isnotnull(worklistShardItemId#3399101L), NOT (isFallbackOrderOnly#3399095 <=> true), isnotnull(o..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#3399122), isnotnull(sequenceId#3399100), (shardId#3399122 = 0_7_10000000532), ..., 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;
99->97;
100->99;
102->100;
103->102;
105->103;
106->105;
108->106;
109->108;
111->97;
112->111;
113->112;
115->113;
116->115;
117->116;
118->117;
120->118;
121->120;
122->121;
123->122;
124->123;
126->124;
127->126;
129->127;
130->129;
131->117;
132->131;
134->132;
135->134;
136->135;
137->136;
}
== Physical Plan ==
* HashAggregate (104)
+- Exchange (103)
+- * HashAggregate (102)
+- * Project (101)
+- * Generate (100)
+- Project (99)
+- Filter (98)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- Project (97)
+- SortMergeJoin LeftOuter (96)
:- 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 (95)
+- Exchange (94)
+- Project (93)
+- * SortMergeJoin Inner (92)
:- * Sort (72)
: +- Exchange (71)
: +- * Filter (70)
: +- InMemoryTableScan (68)
: +- InMemoryRelation (69)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * Sort (91)
+- * HashAggregate (90)
+- Exchange (89)
+- * HashAggregate (88)
+- * Project (87)
+- * BroadcastHashJoin Inner BuildLeft (86)
:- BroadcastExchange (79)
: +- * Project (78)
: +- * Generate (77)
: +- * Project (76)
: +- * Filter (75)
: +- InMemoryTableScan (73)
: +- InMemoryRelation (74)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * Project (85)
+- Exchange (84)
+- * Project (83)
+- * Filter (82)
+- * ColumnarToRow (81)
+- Scan parquet (80)
(1) InMemoryTableScan
Output [1]: [orderProposal#3399126]
Arguments: [orderProposal#3399126], [(size(orderProposal#3399126.parentItems.deliveryDateTime, true) > 0)]
(2) InMemoryRelation
Arguments: [shardId#3394574, orderProposal#3399126], StorageLevel(disk, memory, 2 replicas)
(3) InMemoryTableScan
Output [39]: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, product#3395788, productGroup#3395817, qty#3395329, quantityAfterProdPlantOptimization#3395328, quantityKpis#3398242, shardId#3394574, sourceOfSupplyUuid#3395784, splitIndicator#3395780L, subrange#3395787, supplier#3395786, supplierGroup#3395785, supplyingPlant#3395816]
Arguments: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, ... 14 more fields], [NOT (isFallbackOrderOnly#3395797 <=> true)]
(4) InMemoryRelation
Arguments: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, constraintValues#3395810, constraintOperators#3395808, constraintLabels#3395807, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)
(5) InMemoryTableScan
Output [2]: [shardId#3394574, items#3394576]
Arguments: [shardId#3394574, items#3394576], [(size(items#3394576, true) > 0), isnotnull(items#3394576)]
(6) InMemoryRelation
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], StorageLevel(disk, memory, 2 replicas)
(7) InMemoryTableScan
Output [6]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580]
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]
(8) InMemoryRelation
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580], StorageLevel(disk, memory, 2 replicas)
(9) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580]
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580], MapPartitionsRDD[144316] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(10) Filter [codegen id : 1]
Input [7]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580]
Condition : (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))
(11) Filter [codegen id : 1]
Input [6]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580]
Condition : (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))
(12) Filter [codegen id : 1]
Input [2]: [shardId#3394574, items#3394576]
Condition : ((size(items#3394576, true) > 0) AND isnotnull(items#3394576))
(13) Generate [codegen id : 1]
Input [2]: [shardId#3394574, items#3394576]
Arguments: explode(items#3394576), [shardId#3394574], false, [item#3395326]
(14) Project [codegen id : 1]
Output [4]: [shardId#3394574, item#3395326.worklistShardItemId AS worklistShardItemId#3395327L, item#3395326.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395328, item#3395326.qty AS qty#3395329]
Input [2]: [shardId#3394574, item#3395326]
(15) Exchange
Input [4]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329]
Arguments: hashpartitioning(worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979131]
(16) Sort [codegen id : 2]
Input [4]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329]
Arguments: [worklistShardItemId#3395327L ASC NULLS FIRST], false, 0
(17) Scan parquet
Output [38]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532]
PartitionFilters: [isnotnull(shardId#3396020), isnotnull(sequenceId#3395998), (shardId#3396020 = 0_7_10000000532), (sequenceId#3395998 = 6)]
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#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]
(19) Filter [codegen id : 3]
Input [38]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]
Condition : isnotnull(worklistShardItemId#3395999L)
(20) Project [codegen id : 3]
Output [36]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019]
Input [38]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]
(21) Exchange
Input [36]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019]
Arguments: hashpartitioning(worklistShardItemId#3395999L, 30), REPARTITION_BY_NUM, [plan_id=979141]
(22) Project [codegen id : 4]
Output [36]: [worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, measurements#3396017, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, logisticUnits#3396003, optimizationGroups#3396019, externalProductId#3396001, externalPlantId#3396002, supplyingPlant#3395983, productGroup#3395984]
Input [36]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019]
(23) Sort [codegen id : 4]
Input [36]: [worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, measurements#3396017, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, logisticUnits#3396003, optimizationGroups#3396019, externalProductId#3396001, externalPlantId#3396002, supplyingPlant#3395983, productGroup#3395984]
Arguments: [worklistShardItemId#3395999L ASC NULLS FIRST], false, 0
(24) SortMergeJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#3395327L]
Right keys [1]: [worklistShardItemId#3395999L]
Join type: LeftOuter
Join condition: (shardId#3394574 = 0_7_10000000532)
(25) Project [codegen id : 5]
Output [39]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993]
Input [40]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, measurements#3396017, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, logisticUnits#3396003, optimizationGroups#3396019, externalProductId#3396001, externalPlantId#3396002, supplyingPlant#3395983, productGroup#3395984]
(26) Exchange
Input [39]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993]
Arguments: hashpartitioning(shardId#3394574, worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979150]
(27) Sort [codegen id : 6]
Input [39]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993]
Arguments: [shardId#3394574 ASC NULLS FIRST, worklistShardItemId#3395327L ASC NULLS FIRST], false, 0
(28) Scan ExistingRDD [codegen id : 7]
Output [6]: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212]
Arguments: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212], MapPartitionsRDD[144530] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(29) Filter [codegen id : 7]
Input [6]: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212]
Condition : (((isnull(qty#3398209) AND isnull(demandChannel#3398210)) AND isnull(demandStream#3398211)) AND (isnotnull(shardId#3398207) AND isnotnull(worklistShardItemId#3398208L)))
(30) Project [codegen id : 7]
Output [3]: [shardId#3398207, worklistShardItemId#3398208L, coalesce(kpis#3398212, []) AS prodLocSpecificKpis#3398213]
Input [6]: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212]
(31) Exchange
Input [3]: [shardId#3398207, worklistShardItemId#3398208L, prodLocSpecificKpis#3398213]
Arguments: hashpartitioning(shardId#3398207, worklistShardItemId#3398208L, 30), ENSURE_REQUIREMENTS, [plan_id=979156]
(32) Sort [codegen id : 8]
Input [3]: [shardId#3398207, worklistShardItemId#3398208L, prodLocSpecificKpis#3398213]
Arguments: [shardId#3398207 ASC NULLS FIRST, worklistShardItemId#3398208L ASC NULLS FIRST], false, 0
(33) SortMergeJoin [codegen id : 9]
Left keys [2]: [shardId#3394574, worklistShardItemId#3395327L]
Right keys [2]: [shardId#3398207, worklistShardItemId#3398208L]
Join type: LeftOuter
Join condition: None
(34) Project [codegen id : 9]
Output [40]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, coalesce(prodLocSpecificKpis#3398213, []) AS prodLocSpecificKpis#3398214]
Input [42]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, shardId#3398207, worklistShardItemId#3398208L, prodLocSpecificKpis#3398213]
(35) Scan ExistingRDD [codegen id : 10]
Output [6]: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Arguments: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228], MapPartitionsRDD[144530] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(36) Filter [codegen id : 10]
Input [6]: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Condition : ((((isnull(qty#3398225) AND isnotnull(demandChannel#3398226)) AND isnotnull(demandStream#3398227)) AND (size(kpis#3398228, true) > 0)) AND (isnotnull(shardId#3398223) AND isnotnull(worklistShardItemId#3398224L)))
(37) Project [codegen id : 10]
Output [5]: [shardId#3398223, worklistShardItemId#3398224L, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Input [6]: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228]
(38) ObjectHashAggregate
Input [5]: [shardId#3398223, worklistShardItemId#3398224L, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Keys [2]: [shardId#3398223, worklistShardItemId#3398224L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)]
Aggregate Attributes [1]: [buf#3398403]
Results [3]: [shardId#3398223, worklistShardItemId#3398224L, buf#3398404]
(39) Exchange
Input [3]: [shardId#3398223, worklistShardItemId#3398224L, buf#3398404]
Arguments: hashpartitioning(shardId#3398223, worklistShardItemId#3398224L, 30), ENSURE_REQUIREMENTS, [plan_id=979167]
(40) ObjectHashAggregate
Input [3]: [shardId#3398223, worklistShardItemId#3398224L, buf#3398404]
Keys [2]: [shardId#3398223, worklistShardItemId#3398224L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)#3398222]
Results [3]: [shardId#3398223, worklistShardItemId#3398224L, collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)#3398222 AS channelStreamSpecificKpis#3398215]
(41) Sort [codegen id : 11]
Input [3]: [shardId#3398223, worklistShardItemId#3398224L, channelStreamSpecificKpis#3398215]
Arguments: [shardId#3398223 ASC NULLS FIRST, worklistShardItemId#3398224L ASC NULLS FIRST], false, 0
(42) SortMergeJoin [codegen id : 12]
Left keys [2]: [shardId#3394574, worklistShardItemId#3395327L]
Right keys [2]: [shardId#3398223, worklistShardItemId#3398224L]
Join type: LeftOuter
Join condition: None
(43) Project [codegen id : 12]
Output [41]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, coalesce(channelStreamSpecificKpis#3398215, []) AS channelStreamSpecificKpis#3398229]
Input [43]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, shardId#3398223, worklistShardItemId#3398224L, channelStreamSpecificKpis#3398215]
(44) Scan ExistingRDD [codegen id : 13]
Output [6]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241]
Arguments: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241], MapPartitionsRDD[144530] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)
(45) Filter [codegen id : 13]
Input [6]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241]
Condition : ((isnotnull(qty#3398238) AND isnotnull(kpis#3398241)) AND (isnotnull(shardId#3398236) AND isnotnull(worklistShardItemId#3398237L)))
(46) Project [codegen id : 13]
Output [4]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, kpis#3398241]
Input [6]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241]
(47) ObjectHashAggregate
Input [4]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, kpis#3398241]
Keys [2]: [shardId#3398236, worklistShardItemId#3398237L]
Functions [1]: [partial_collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)]
Aggregate Attributes [1]: [buf#3398405]
Results [3]: [shardId#3398236, worklistShardItemId#3398237L, buf#3398406]
(48) Exchange
Input [3]: [shardId#3398236, worklistShardItemId#3398237L, buf#3398406]
Arguments: hashpartitioning(shardId#3398236, worklistShardItemId#3398237L, 30), ENSURE_REQUIREMENTS, [plan_id=979179]
(49) ObjectHashAggregate
Input [3]: [shardId#3398236, worklistShardItemId#3398237L, buf#3398406]
Keys [2]: [shardId#3398236, worklistShardItemId#3398237L]
Functions [1]: [collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)#3398235]
Results [3]: [shardId#3398236, worklistShardItemId#3398237L, map_from_entries(collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)#3398235) AS quantityKpis#3398230]
(50) Sort [codegen id : 14]
Input [3]: [shardId#3398236, worklistShardItemId#3398237L, quantityKpis#3398230]
Arguments: [shardId#3398236 ASC NULLS FIRST, worklistShardItemId#3398237L ASC NULLS FIRST], false, 0
(51) SortMergeJoin [codegen id : 15]
Left keys [2]: [shardId#3394574, worklistShardItemId#3395327L]
Right keys [2]: [shardId#3398236, worklistShardItemId#3398237L]
Join type: LeftOuter
Join condition: None
(52) Project [codegen id : 15]
Output [42]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, coalesce(quantityKpis#3398230, map(keys: [], values: [])) AS quantityKpis#3398242]
Input [44]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, shardId#3398236, worklistShardItemId#3398237L, quantityKpis#3398230]
(53) Filter [codegen id : 1]
Input [39]: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, product#3395788, productGroup#3395817, qty#3395329, quantityAfterProdPlantOptimization#3395328, quantityKpis#3398242, shardId#3394574, sourceOfSupplyUuid#3395784, splitIndicator#3395780L, subrange#3395787, supplier#3395786, supplierGroup#3395785, supplyingPlant#3395816]
Condition : NOT (isFallbackOrderOnly#3395797 <=> true)
(54) Project [codegen id : 1]
Output [36]: [shardId#3394574, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, minimumOrderQuantity#3395806, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, arrays_zip(constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#3398656]
Input [39]: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, product#3395788, productGroup#3395817, qty#3395329, quantityAfterProdPlantOptimization#3395328, quantityKpis#3398242, shardId#3394574, sourceOfSupplyUuid#3395784, splitIndicator#3395780L, subrange#3395787, supplier#3395786, supplierGroup#3395785, supplyingPlant#3395816]
(55) Project
Output [37]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, struct(minServiceLevel, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11192#3398663.constraintLabels = ServiceLevel), lambda x_11192#3398663, false)).constraintValues), minServiceLevelMinStock, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11193#3398664.constraintLabels = ServiceLevelMinimumStock), lambda x_11193#3398664, false)).constraintValues), maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11194#3398665.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_11194#3398665, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11195#3398666.constraintLabels = RangeOfCoverage), lambda x_11195#3398666, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#3395806, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#3398214, lambdafunction((lambda x_11196#3398667.label = NonListingStartTimestamp), lambda x_11196#3398667, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#3398662, CASE WHEN (qty#3395329 <=> quantityAfterProdPlantOptimization#3395328) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398735.isOrderUnit, lambda x_11197#3398735, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398736.isOrderUnit, lambda x_11197#3398736, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398737.isOrderUnit, lambda x_11197#3398737, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398738.isOrderUnit, lambda x_11197#3398738, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), candidateOrderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3395799, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398739.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398739.denominator as double)) % cast(lambda x_11199#3398739.numerator as double)) = 0.0)), lambda x_11199#3398739, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398780.denominator as double)) / cast(lambda x_11200#3398780.numerator as double)), uom, lambda x_11200#3398780.uom, uomUuid, lambda x_11200#3398780.uomUuid), lambda x_11200#3398780, false))).inPreferredQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398740.isOrderUnit, lambda x_11198#3398740, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398741.isOrderUnit, lambda x_11198#3398741, false)), 1, None, false).numerator as double))), qty#3395329)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398742.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398742.denominator as double)) % cast(lambda x_11199#3398742.numerator as double)) = 0.0)), lambda x_11199#3398742, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398781.denominator as double)) / cast(lambda x_11200#3398781.numerator as double)), uom, lambda x_11200#3398781.uom, uomUuid, lambda x_11200#3398781.uomUuid), lambda x_11200#3398781, false))).uom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398743.isOrderUnit, lambda x_11198#3398743, false)), 1, None, false).uom, orderQuantityBaseUom#3395798)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398744.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398744.denominator as double)) % cast(lambda x_11199#3398744.numerator as double)) = 0.0)), lambda x_11199#3398744, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398782.denominator as double)) / cast(lambda x_11200#3398782.numerator as double)), uom, lambda x_11200#3398782.uom, uomUuid, lambda x_11200#3398782.uomUuid), lambda x_11200#3398782, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398745.isOrderUnit, lambda x_11198#3398745, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799)), serviceLevel, coalesce(filter(element_at(quantityKpis#3398242, qty#3395329, None, false), lambdafunction((lambda x_11205#3398746.label = ServiceLevel), lambda x_11205#3398746, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398750.isOrderUnit, lambda x_11197#3398750, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398751.isOrderUnit, lambda x_11197#3398751, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398752.isOrderUnit, lambda x_11197#3398752, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398753.isOrderUnit, lambda x_11197#3398753, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), candidateOrderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3395799, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398754.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398754.denominator as double)) % cast(lambda x_11199#3398754.numerator as double)) = 0.0)), lambda x_11199#3398754, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398783.denominator as double)) / cast(lambda x_11200#3398783.numerator as double)), uom, lambda x_11200#3398783.uom, uomUuid, lambda x_11200#3398783.uomUuid), lambda x_11200#3398783, false))).inPreferredQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398755.isOrderUnit, lambda x_11198#3398755, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398756.isOrderUnit, lambda x_11198#3398756, false)), 1, None, false).numerator as double))), qty#3395329)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398757.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398757.denominator as double)) % cast(lambda x_11199#3398757.numerator as double)) = 0.0)), lambda x_11199#3398757, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398784.denominator as double)) / cast(lambda x_11200#3398784.numerator as double)), uom, lambda x_11200#3398784.uom, uomUuid, lambda x_11200#3398784.uomUuid), lambda x_11200#3398784, false))).uom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398758.isOrderUnit, lambda x_11198#3398758, false)), 1, None, false).uom, orderQuantityBaseUom#3395798)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398759.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398759.denominator as double)) % cast(lambda x_11199#3398759.numerator as double)) = 0.0)), lambda x_11199#3398759, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398785.denominator as double)) / cast(lambda x_11200#3398785.numerator as double)), uom, lambda x_11200#3398785.uom, uomUuid, lambda x_11200#3398785.uomUuid), lambda x_11200#3398785, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398760.isOrderUnit, lambda x_11198#3398760, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799)), serviceLevel, coalesce(filter(element_at(quantityKpis#3398242, qty#3395329, None, false), lambdafunction((lambda x_11209#3398761.label = ServiceLevel), lambda x_11209#3398761, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#3395328 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398765.isOrderUnit, lambda x_11201#3398765, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398766.isOrderUnit, lambda x_11201#3398766, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#3395328), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398767.isOrderUnit, lambda x_11201#3398767, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398768.isOrderUnit, lambda x_11201#3398768, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#3395328, orderQuantityBaseUom, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3395799, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11203#3398769.isPreferred AND (((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11203#3398769.denominator as double)) % cast(lambda x_11203#3398769.numerator as double)) = 0.0)), lambda x_11203#3398769, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11204#3398786.denominator as double)) / cast(lambda x_11204#3398786.numerator as double)), uom, lambda x_11204#3398786.uom, uomUuid, lambda x_11204#3398786.uomUuid), lambda x_11204#3398786, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#3395328 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398770.isOrderUnit, lambda x_11202#3398770, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398771.isOrderUnit, lambda x_11202#3398771, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#3395328)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11203#3398772.isPreferred AND (((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11203#3398772.denominator as double)) % cast(lambda x_11203#3398772.numerator as double)) = 0.0)), lambda x_11203#3398772, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11204#3398787.denominator as double)) / cast(lambda x_11204#3398787.numerator as double)), uom, lambda x_11204#3398787.uom, uomUuid, lambda x_11204#3398787.uomUuid), lambda x_11204#3398787, false))).uom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398773.isOrderUnit, lambda x_11202#3398773, false)), 1, None, false).uom, orderQuantityBaseUom#3395798)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11203#3398774.isPreferred AND (((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11203#3398774.denominator as double)) % cast(lambda x_11203#3398774.numerator as double)) = 0.0)), lambda x_11203#3398774, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11204#3398788.denominator as double)) / cast(lambda x_11204#3398788.numerator as double)), uom, lambda x_11204#3398788.uom, uomUuid, lambda x_11204#3398788.uomUuid), lambda x_11204#3398788, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398775.isOrderUnit, lambda x_11202#3398775, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799)), serviceLevel, coalesce(filter(element_at(quantityKpis#3398242, quantityAfterProdPlantOptimization#3395328, None, false), lambdafunction((lambda x_11213#3398776.label = ServiceLevel), lambda x_11213#3398776, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#3398734, coalesce(filter(prodLocSpecificKpis#3398214, lambdafunction((lambda x_11217#3398790.label = InitialStockQty), lambda x_11217#3398790, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#3398789, coalesce(filter(prodLocSpecificKpis#3398214, lambdafunction((lambda x_11218#3398792.label = DemandPeriodEndTimestamp), lambda x_11218#3398792, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#3398791]
Input [36]: [shardId#3394574, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, minimumOrderQuantity#3395806, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, constraintStructArray#3398656]
(56) Project
Output [21]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, struct(itemId, orderProposalItemId#3395776, itemGroupId, orderProposalItemGroupId#3395777, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, sourceOfSupplyUuid, sourceOfSupplyUuid#3395784, deliveryDateTime, deliveryDateTime#3395794, unitPrice, netPriceAmount#3395803, unitPriceCurrency, netPriceCurrencyCode#3395804, unitPriceQuantity, ... 37 more fields) AS parentItem#3398865]
Input [37]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, constraintBenchmark#3398662, calculationAnalysis#3398734, inventoryDateTime#3398789, demandPeriodEndDateTime#3398791]
(57) Project
Output [12]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, orderDateTime#3395793, splitIndicator#3395780L, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865, struct(itemId, orderProposalItemId#3395776, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, deliveryDateTime, deliveryDateTime#3395794, orderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398899.isOrderUnit, lambda x_11242#3398899, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398900.isOrderUnit, lambda x_11242#3398900, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398901.isOrderUnit, lambda x_11242#3398901, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398902.isOrderUnit, lambda x_11242#3398902, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), orderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, ... 13 more fields) AS item#3398896]
Input [21]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865]
(58) ObjectHashAggregate
Input [12]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, orderDateTime#3395793, splitIndicator#3395780L, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865, item#3398896]
Keys [4]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777]
Functions [8]: [partial_max(originalReplenishmentRunId#3395778L), partial_max(supplierGroup#3395785), partial_max(supplier#3395786), partial_max(supplyingPlant#3395816), partial_max(orderDateTime#3395793), partial_collect_list(parentItem#3398865, 0, 0), partial_collect_set(previousOrderProposal#3395781L, 0, 0), partial_collect_list(item#3398896, 0, 0)]
Aggregate Attributes [8]: [max#3400329L, max#3400330, max#3400331, max#3400332, max#3400333, buf#3400334, buf#3400335, buf#3400336]
Results [12]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, max#3400337L, max#3400338, max#3400339, max#3400340, max#3400341, buf#3400342, buf#3400343, buf#3400344]
(59) Exchange
Input [12]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, max#3400337L, max#3400338, max#3400339, max#3400340, max#3400341, buf#3400342, buf#3400343, buf#3400344]
Arguments: hashpartitioning(shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, 30), ENSURE_REQUIREMENTS, [plan_id=979446]
(60) ObjectHashAggregate
Input [12]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, max#3400337L, max#3400338, max#3400339, max#3400340, max#3400341, buf#3400342, buf#3400343, buf#3400344]
Keys [4]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777]
Functions [8]: [max(originalReplenishmentRunId#3395778L), max(supplierGroup#3395785), max(supplier#3395786), max(supplyingPlant#3395816), max(orderDateTime#3395793), collect_list(parentItem#3398865, 0, 0), collect_set(previousOrderProposal#3395781L, 0, 0), collect_list(item#3398896, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#3395778L)#3398965L, max(supplierGroup#3395785)#3398966, max(supplier#3395786)#3398967, max(supplyingPlant#3395816)#3398968, max(orderDateTime#3395793)#3398969, collect_list(parentItem#3398865, 0, 0)#3398970, collect_set(previousOrderProposal#3395781L, 0, 0)#3398972, collect_list(item#3398896, 0, 0)#3398971]
Results [10]: [shardId#3394574, orderProposalId#3395775L, max(originalReplenishmentRunId#3395778L)#3398965L AS originalReplenishmentRunId#3398913L, max(supplierGroup#3395785)#3398966 AS supplierGroup#3398914, max(supplier#3395786)#3398967 AS supplier#3398915, max(supplyingPlant#3395816)#3398968 AS supplyingPlant#3398916, max(orderDateTime#3395793)#3398969 AS orderDateTime#3398917, collect_list(parentItem#3398865, 0, 0)#3398970 AS parentItems#3398918, collect_set(previousOrderProposal#3395781L, 0, 0)#3398972 AS previousOrderProposals#3398920, struct(itemGroupId, orderProposalItemGroupId#3395777, items, collect_list(item#3398896, 0, 0)#3398971) AS itemGroup#3398974]
(61) ObjectHashAggregate
Input [10]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3398913L, supplierGroup#3398914, supplier#3398915, supplyingPlant#3398916, orderDateTime#3398917, parentItems#3398918, previousOrderProposals#3398920, itemGroup#3398974]
Keys [2]: [shardId#3394574, orderProposalId#3395775L]
Functions [8]: [partial_max(originalReplenishmentRunId#3398913L), partial_max(supplierGroup#3398914), partial_max(supplier#3398915), partial_max(supplyingPlant#3398916), partial_max(orderDateTime#3398917), partial_collect_list(itemGroup#3398974, 0, 0), partial_collect_list(parentItems#3398918, 0, 0), partial_collect_set(previousOrderProposals#3398920, 0, 0)]
Aggregate Attributes [8]: [max#3400313L, max#3400314, max#3400315, max#3400316, max#3400317, buf#3400318, buf#3400319, buf#3400320]
Results [10]: [shardId#3394574, orderProposalId#3395775L, max#3400321L, max#3400322, max#3400323, max#3400324, max#3400325, buf#3400326, buf#3400327, buf#3400328]
(62) Exchange
Input [10]: [shardId#3394574, orderProposalId#3395775L, max#3400321L, max#3400322, max#3400323, max#3400324, max#3400325, buf#3400326, buf#3400327, buf#3400328]
Arguments: hashpartitioning(shardId#3394574, orderProposalId#3395775L, 30), ENSURE_REQUIREMENTS, [plan_id=979449]
(63) ObjectHashAggregate
Input [10]: [shardId#3394574, orderProposalId#3395775L, max#3400321L, max#3400322, max#3400323, max#3400324, max#3400325, buf#3400326, buf#3400327, buf#3400328]
Keys [2]: [shardId#3394574, orderProposalId#3395775L]
Functions [8]: [max(originalReplenishmentRunId#3398913L), max(supplierGroup#3398914), max(supplier#3398915), max(supplyingPlant#3398916), max(orderDateTime#3398917), collect_list(itemGroup#3398974, 0, 0), collect_list(parentItems#3398918, 0, 0), collect_set(previousOrderProposals#3398920, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#3398913L)#3398996L, max(supplierGroup#3398914)#3398997, max(supplier#3398915)#3398998, max(supplyingPlant#3398916)#3398999, max(orderDateTime#3398917)#3399000, collect_list(itemGroup#3398974, 0, 0)#3399001, collect_list(parentItems#3398918, 0, 0)#3399002, collect_set(previousOrderProposals#3398920, 0, 0)#3399003]
Results [10]: [shardId#3394574, orderProposalId#3395775L, max(originalReplenishmentRunId#3398913L)#3398996L AS originalReplenishmentRunId#3398975L, max(supplierGroup#3398914)#3398997 AS supplierGroup#3398976, max(supplier#3398915)#3398998 AS supplier#3398977, max(supplyingPlant#3398916)#3398999 AS supplyingPlant#3398978, max(orderDateTime#3398917)#3399000 AS orderDateTime#3398979, collect_list(itemGroup#3398974, 0, 0)#3399001 AS itemGroups#3398980, flatten(collect_list(parentItems#3398918, 0, 0)#3399002) AS parentItems#3398981, flatten(collect_set(previousOrderProposals#3398920, 0, 0)#3399003) AS previousOrderProposals#3398982]
(64) Project
Output [2]: [shardId#3394574, struct(orderProposalId, orderProposalId#3395775L, originalReplenishmentRunId, originalReplenishmentRunId#3398975L, supplierGroup, supplierGroup#3398976, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#3398976) THEN supplier#3398977 END, supplyingPlant, supplyingPlant#3398978, orderDateTime, orderDateTime#3398979, itemGroups, itemGroups#3398980, previousOrderProposals, array_distinct(previousOrderProposals#3398982), parentItems, parentItems#3398981) AS orderProposal#3399007]
Input [10]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3398975L, supplierGroup#3398976, supplier#3398977, supplyingPlant#3398978, orderDateTime#3398979, itemGroups#3398980, parentItems#3398981, previousOrderProposals#3398982]
(65) Project
Output [11]: [shardId#3394574, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399945L, orderProposal#3399007.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#3399946L, orderProposal#3399007.supplierGroup AS _extract_supplierGroup#3399947, orderProposal#3399007.supplier AS _extract_supplier#3399948, orderProposal#3399007.supplyingPlant AS _extract_supplyingPlant#3399949, orderProposal#3399007.orderDateTime AS _extract_orderDateTime#3399950, orderProposal#3399007.itemGroups AS _extract_itemGroups#3399951, orderProposal#3399007.previousOrderProposals AS _extract_previousOrderProposals#3399952, orderProposal#3399007.parentItems AS _extract_parentItems#3399953, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399954L]
Input [2]: [shardId#3394574, orderProposal#3399007]
(66) Exchange
Input [11]: [shardId#3394574, _extract_orderProposalId#3399945L, _extract_originalReplenishmentRunId#3399946L, _extract_supplierGroup#3399947, _extract_supplier#3399948, _extract_supplyingPlant#3399949, _extract_orderDateTime#3399950, _extract_itemGroups#3399951, _extract_previousOrderProposals#3399952, _extract_parentItems#3399953, _extract_orderProposalId#3399954L]
Arguments: hashpartitioning(coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L), 30), ENSURE_REQUIREMENTS, [plan_id=979453]
(67) Sort
Input [11]: [shardId#3394574, _extract_orderProposalId#3399945L, _extract_originalReplenishmentRunId#3399946L, _extract_supplierGroup#3399947, _extract_supplier#3399948, _extract_supplyingPlant#3399949, _extract_orderDateTime#3399950, _extract_itemGroups#3399951, _extract_previousOrderProposals#3399952, _extract_parentItems#3399953, _extract_orderProposalId#3399954L]
Arguments: [coalesce(shardId#3394574, ) ASC NULLS FIRST, isnull(shardId#3394574) ASC NULLS FIRST, coalesce(_extract_orderProposalId#3399954L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#3399954L) ASC NULLS FIRST], false, 0
(68) InMemoryTableScan
Output [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Arguments: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025], [isnotnull(orderProposalId#3399023L)]
(69) InMemoryRelation
Arguments: [shardId#3399022, orderProposalId#3399023L, items#3399024, optimizationGroups#3399025, isOptimal#3399026, optimizationInsights#3399028], StorageLevel(disk, memory, 2 replicas)
(70) Filter [codegen id : 2]
Input [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Condition : isnotnull(orderProposalId#3399023L)
(71) Exchange
Input [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Arguments: hashpartitioning(orderProposalId#3399023L, 30), ENSURE_REQUIREMENTS, [plan_id=979458]
(72) Sort [codegen id : 3]
Input [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Arguments: [orderProposalId#3399023L ASC NULLS FIRST], false, 0
(73) InMemoryTableScan
Output [2]: [items#3398651, shardId#3398649]
Arguments: [items#3398651, shardId#3398649], [(size(items#3398651.worklistShardItemId, true) > 0), isnotnull(items#3398651.worklistShardItemId), (shardId#3398649 = 0_7_10000000532)]
(74) InMemoryRelation
Arguments: [shardId#3398649, orderProposalId#3398650L, items#3398651, optimizationGroups#3398652, isOptimal#3398653, optimizationInsights#3398655], StorageLevel(disk, memory, 2 replicas)
(75) Filter [codegen id : 4]
Input [2]: [items#3398651, shardId#3398649]
Condition : (((size(items#3398651.worklistShardItemId, true) > 0) AND isnotnull(items#3398651.worklistShardItemId)) AND (shardId#3398649 = 0_7_10000000532))
(76) Project [codegen id : 4]
Output [1]: [items#3398651.worklistShardItemId AS _extract_worklistShardItemId#3399670]
Input [2]: [items#3398651, shardId#3398649]
(77) Generate [codegen id : 4]
Input [1]: [_extract_worklistShardItemId#3399670]
Arguments: explode(_extract_worklistShardItemId#3399670), false, [item#3399029L]
(78) Project [codegen id : 4]
Output [1]: [item#3399029L AS worklistShardItemId#3399030L]
Input [1]: [item#3399029L]
(79) BroadcastExchange
Input [1]: [worklistShardItemId#3399030L]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=979469]
(80) Scan parquet
Output [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532]
PartitionFilters: [isnotnull(shardId#3399122), isnotnull(sequenceId#3399100), (shardId#3399122 = 0_7_10000000532), (sequenceId#3399100 = 6)]
PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>
(81) ColumnarToRow [codegen id : 5]
Input [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]
(82) Filter [codegen id : 5]
Input [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]
Condition : ((isnotnull(worklistShardItemId#3399101L) AND NOT (isFallbackOrderOnly#3399095 <=> true)) AND isnotnull(orderProposalId#3399078L))
(83) Project [codegen id : 5]
Output [2]: [orderProposalId#3399078L, worklistShardItemId#3399101L]
Input [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]
(84) Exchange
Input [2]: [orderProposalId#3399078L, worklistShardItemId#3399101L]
Arguments: hashpartitioning(worklistShardItemId#3399101L, 30), REPARTITION_BY_NUM, [plan_id=979476]
(85) Project
Output [2]: [worklistShardItemId#3399101L, orderProposalId#3399078L]
Input [2]: [orderProposalId#3399078L, worklistShardItemId#3399101L]
(86) BroadcastHashJoin [codegen id : 6]
Left keys [1]: [worklistShardItemId#3399030L]
Right keys [1]: [worklistShardItemId#3399101L]
Join type: Inner
Join condition: None
(87) Project [codegen id : 6]
Output [1]: [orderProposalId#3399078L]
Input [3]: [worklistShardItemId#3399030L, worklistShardItemId#3399101L, orderProposalId#3399078L]
(88) HashAggregate [codegen id : 6]
Input [1]: [orderProposalId#3399078L]
Keys [1]: [orderProposalId#3399078L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#3399078L]
(89) Exchange
Input [1]: [orderProposalId#3399078L]
Arguments: hashpartitioning(orderProposalId#3399078L, 30), ENSURE_REQUIREMENTS, [plan_id=979483]
(90) HashAggregate [codegen id : 7]
Input [1]: [orderProposalId#3399078L]
Keys [1]: [orderProposalId#3399078L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#3399078L]
(91) Sort [codegen id : 7]
Input [1]: [orderProposalId#3399078L]
Arguments: [orderProposalId#3399078L ASC NULLS FIRST], false, 0
(92) SortMergeJoin [codegen id : 8]
Left keys [1]: [orderProposalId#3399023L]
Right keys [1]: [orderProposalId#3399078L]
Join type: Inner
Join condition: None
(93) Project
Output [3]: [orderProposalId#3399023L, shardId#3399022, coalesce(transform(optimizationGroups#3399025, lambdafunction(struct(optGroupId, lambda x_11246#3399020.optGroupId, minOrderProfile, lambda x_11246#3399020.minOrderProfile, assignmentDetails, lambda x_11246#3399020.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_11246#3399020.minOrderGoal.dimensionType, unit, lambda x_11246#3399020.minOrderGoal.unit, unitUuid, lambda x_11246#3399020.minOrderGoal.unitUuid, goalValue, lambda x_11246#3399020.minOrderGoal.minOrderValue, calcValue, lambda x_11246#3399020.minOrderGoal.calculatedOrderValue), transportLoadProfile, null, transportLoadGoal, null), lambda x_11246#3399020, false)), []) AS optimizationGroups#3399019]
Input [4]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025, orderProposalId#3399078L]
(94) Exchange
Input [3]: [orderProposalId#3399023L, shardId#3399022, optimizationGroups#3399019]
Arguments: hashpartitioning(coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L), 30), ENSURE_REQUIREMENTS, [plan_id=979492]
(95) Sort [codegen id : 9]
Input [3]: [orderProposalId#3399023L, shardId#3399022, optimizationGroups#3399019]
Arguments: [coalesce(shardId#3399022, ) ASC NULLS FIRST, isnull(shardId#3399022) ASC NULLS FIRST, coalesce(orderProposalId#3399023L, 0) ASC NULLS FIRST, isnull(orderProposalId#3399023L) ASC NULLS FIRST], false, 0
(96) SortMergeJoin
Left keys [4]: [coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L)]
Right keys [4]: [coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L)]
Join type: LeftOuter
Join condition: None
(97) Project
Output [2]: [shardId#3394574, named_struct(orderProposalId, _extract_orderProposalId#3399954L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#3399946L, supplierGroup, _extract_supplierGroup#3399947, optimizationGroups, coalesce(optimizationGroups#3399019, []), supplier, _extract_supplier#3399948, supplyingPlant, _extract_supplyingPlant#3399949, orderDateTime, _extract_orderDateTime#3399950, itemGroups, _extract_itemGroups#3399951, previousOrderProposals, _extract_previousOrderProposals#3399952, parentItems, _extract_parentItems#3399953) AS orderProposal#3399126]
Input [14]: [shardId#3394574, _extract_orderProposalId#3399945L, _extract_originalReplenishmentRunId#3399946L, _extract_supplierGroup#3399947, _extract_supplier#3399948, _extract_supplyingPlant#3399949, _extract_orderDateTime#3399950, _extract_itemGroups#3399951, _extract_previousOrderProposals#3399952, _extract_parentItems#3399953, _extract_orderProposalId#3399954L, orderProposalId#3399023L, shardId#3399022, optimizationGroups#3399019]
(98) Filter
Input [1]: [orderProposal#3399126]
Condition : (size(orderProposal#3399126.parentItems.deliveryDateTime, true) > 0)
(99) Project
Output [1]: [orderProposal#3399126.parentItems.deliveryDateTime AS _extract_deliveryDateTime#3400725]
Input [1]: [orderProposal#3399126]
(100) Generate [codegen id : 1]
Input [1]: [_extract_deliveryDateTime#3400725]
Arguments: explode(_extract_deliveryDateTime#3400725), false, [numberOfOrderProposalItems#3400697]
(101) Project [codegen id : 1]
Output: []
Input [1]: [numberOfOrderProposalItems#3400697]
(102) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#3400736L]
Results [1]: [count#3400737L]
(103) Exchange
Input [1]: [count#3400737L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=979619]
(104) HashAggregate [codegen id : 2]
Input [1]: [count#3400737L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#3400702L]
Results [1]: [count(1)#3400702L AS count#3400698L]