digraph G {
0 [id="node0" labelType="html" label="<b>CollectLimit</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>local merged bytes read: 0.0 B<br>remote reqs duration: 0 ms<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="CollectLimit 1"];
subgraph cluster1 {
isCluster="true";
id="cluster1";
label="WholeStageCodegen (16)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (16)";
2 [id="node2" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project"];
}
3 [id="node3" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 1<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1<br>local bytes read: 100.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 40.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 1<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 100.0 B" tooltip="Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=270979]"];
subgraph cluster4 {
isCluster="true";
id="cluster4";
label="WholeStageCodegen (15)\n \nduration: total (min, med, max (stageId: taskId))\n77 ms (0 ms, 6 ms, 9 ms (stage 52655.0: task 139853))";
tooltip="WholeStageCodegen (15)";
5 [id="node5" 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>9 ms (0 ms, 0 ms, 3 ms (stage 52655.0: task 139845))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 52655.0: task 139850))<br>number of output rows: 1<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#643168, resultSeparationId#657383L], functions=[])"];
}
6 [id="node6" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 18<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 18<br>local bytes read: 1800.0 B<br>merged fetch fallback count: 0<br>local blocks read: 18<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>720.0 B (40.0 B, 40.0 B, 40.0 B (stage 52654.0: task 139825))<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>7 ms (0 ms, 0 ms, 0 ms (stage 52654.0: task 139827))<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: 20<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>1800.0 B (100.0 B, 100.0 B, 100.0 B (stage 52654.0: task 139825))" tooltip="Exchange hashpartitioning(shardId#643168, resultSeparationId#657383L, 20), ENSURE_REQUIREMENTS, [plan_id=270975]"];
subgraph cluster7 {
isCluster="true";
id="cluster7";
label="WholeStageCodegen (14)\n \nduration: total (min, med, max (stageId: taskId))\n272 ms (1 ms, 1 ms, 39 ms (stage 52654.0: task 139825))";
tooltip="WholeStageCodegen (14)";
8 [id="node8" 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>8 ms (0 ms, 0 ms, 2 ms (stage 52654.0: task 139825))<br>peak memory total (min, med, max (stageId: taskId))<br>5.0 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 52654.0: task 139830))<br>number of output rows: 18<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#643168, resultSeparationId#657383L], functions=[])"];
}
9 [id="node9" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 59<br>time in aggregation build total (min, med, max (stageId: taskId))<br>245 ms (0 ms, 1 ms, 47 ms (stage 52654.0: task 139828))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52654.0: task 139825))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#643168, orderProposalId#645037L], functions=[collect_list(parentItems#648807, 0, 0)])"];
10 [id="node10" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 78<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 78<br>local bytes read total (min, med, max (stageId: taskId))<br>223.0 KiB (959.0 B, 9.8 KiB, 26.4 KiB (stage 52654.0: task 139834))<br>merged fetch fallback count: 0<br>local blocks read: 70<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>1578.0 KiB (1792.0 B, 71.6 KiB, 217.8 KiB (stage 52653.0: task 139812))<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>10 ms (0 ms, 0 ms, 0 ms (stage 52653.0: task 139812))<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 52654.0: task 139825))<br>remote bytes read: 0.0 B<br>number of partitions: 20<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>223.0 KiB (1053.0 B, 10.5 KiB, 28.1 KiB (stage 52653.0: task 139812))" tooltip="Exchange hashpartitioning(shardId#643168, orderProposalId#645037L, 20), ENSURE_REQUIREMENTS, [plan_id=270970]"];
11 [id="node11" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 78<br>time in aggregation build total (min, med, max (stageId: taskId))<br>8 ms (0 ms, 0 ms, 4 ms (stage 52653.0: task 139808))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52653.0: task 139806))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#643168, orderProposalId#645037L], functions=[partial_collect_list(parentItems#648807, 0, 0)])"];
12 [id="node12" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 78<br>time in aggregation build total (min, med, max (stageId: taskId))<br>318 ms (4 ms, 9 ms, 44 ms (stage 52653.0: task 139807))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52653.0: task 139806))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061], functions=[collect_list(parentItem#648754, 0, 0)])"];
13 [id="node13" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 643<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 643<br>local bytes read total (min, med, max (stageId: taskId))<br>500.3 KiB (1067.0 B, 24.4 KiB, 51.0 KiB (stage 52653.0: task 139812))<br>merged fetch fallback count: 0<br>local blocks read: 318<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>1630.3 KiB (69.5 KiB, 80.7 KiB, 98.4 KiB (stage 52652.0: task 139798))<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>19 ms (0 ms, 0 ms, 1 ms (stage 52652.0: task 139793))<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 52653.0: task 139806))<br>remote bytes read: 0.0 B<br>number of partitions: 20<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>500.3 KiB (21.1 KiB, 24.3 KiB, 29.3 KiB (stage 52652.0: task 139793))" tooltip="Exchange hashpartitioning(shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, 20), ENSURE_REQUIREMENTS, [plan_id=270967]"];
14 [id="node14" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 643<br>time in aggregation build total (min, med, max (stageId: taskId))<br>597 ms (9 ms, 13 ms, 74 ms (stage 52652.0: task 139787))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061], functions=[partial_collect_list(parentItem#648754, 0, 0)])"];
15 [id="node15" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, struct(itemId, 123456, itemGroupId, 123456, supplier, supplier#645040, supplyingPlant, supplyingPlant#645044, productGroup, productGroup#645045, product, product#645046, plant, plant#645041, supplierSubRange, subrange#645043, sourceOfSupplyUuid, sourceOfSupplyUuid#645051, deliveryDateTime, deliveryDateTime#645042, unitPrice, netPriceAmount#645073, unitPriceCurrency, netPriceCurrencyCode#645074, unitPriceQuantity, ... 37 more fields) AS parentItem#648754]"];
16 [id="node16" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, ... 7 more fields]"];
subgraph cluster17 {
isCluster="true";
id="cluster17";
label="WholeStageCodegen (13)\n \nduration: total (min, med, max (stageId: taskId))\n1.5 s (29 ms, 48 ms, 189 ms (stage 52652.0: task 139789))";
tooltip="WholeStageCodegen (13)";
18 [id="node18" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, ... 6 more fields]"];
19 [id="node19" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 980<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))" tooltip="SortMergeJoin [shardId#643168, worklistShardItemId#643816L], [shardId#647223, worklistShardItemId#647224L], LeftOuter"];
}
subgraph cluster20 {
isCluster="true";
id="cluster20";
label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n2.0 s (32 ms, 51 ms, 285 ms (stage 52652.0: task 139789))";
tooltip="WholeStageCodegen (10)";
21 [id="node21" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, ... 8 more fields]"];
22 [id="node22" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 980<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))" tooltip="SortMergeJoin [shardId#643168, worklistShardItemId#643816L], [shardId#647210, worklistShardItemId#647211L], LeftOuter"];
}
subgraph cluster23 {
isCluster="true";
id="cluster23";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n2.5 s (36 ms, 54 ms, 373 ms (stage 52652.0: task 139789))";
tooltip="WholeStageCodegen (7)";
24 [id="node24" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, ... 7 more fields]"];
25 [id="node25" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 980<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))" tooltip="SortMergeJoin [shardId#643168, worklistShardItemId#643816L], [shardId#647194, worklistShardItemId#647195L], LeftOuter"];
}
subgraph cluster26 {
isCluster="true";
id="cluster26";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n3.1 s (37 ms, 55 ms, 479 ms (stage 52652.0: task 139787))";
tooltip="WholeStageCodegen (4)";
27 [id="node27" 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 52652.0: task 139787))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 52652.0: task 139787))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))" tooltip="Sort [shardId#643168 ASC NULLS FIRST, worklistShardItemId#643816L ASC NULLS FIRST], false, 0"];
}
28 [id="node28" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 980<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 980<br>local bytes read total (min, med, max (stageId: taskId))<br>434.7 KiB (17.4 KiB, 21.8 KiB, 25.3 KiB (stage 52652.0: task 139802))<br>merged fetch fallback count: 0<br>local blocks read: 253<br>remote merged chunks fetched: 0<br>remote blocks read: 37<br>data size total (min, med, max (stageId: taskId))<br>1175.2 KiB (1224.0 B, 55.4 KiB, 168.8 KiB (stage 52648.0: task 139726))<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>18 ms (0 ms, 0 ms, 1 ms (stage 52648.0: task 139733))<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 52652.0: task 139787))<br>remote bytes read total (min, med, max (stageId: taskId))<br>39.8 KiB (785.0 B, 2.2 KiB, 3.5 KiB (stage 52652.0: task 139804))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>16 ms (0 ms, 1 ms, 3 ms (stage 52652.0: task 139794))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>474.5 KiB (855.0 B, 23.1 KiB, 54.4 KiB (stage 52648.0: task 139726))" tooltip="Exchange hashpartitioning(shardId#643168, worklistShardItemId#643816L, 20), ENSURE_REQUIREMENTS, [plan_id=270926]"];
subgraph cluster29 {
isCluster="true";
id="cluster29";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n954 ms (8 ms, 35 ms, 130 ms (stage 52648.0: task 139710))";
tooltip="WholeStageCodegen (3)";
30 [id="node30" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, ... 6 more fields]"];
31 [id="node31" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter NOT (isFallbackOrderOnly#645054 <=> true)"];
32 [id="node32" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 980" tooltip="BroadcastHashJoin [worklistShardItemId#643816L], [worklistShardItemId#645060L], LeftOuter, BuildRight, (shardId#643168 = 0_1_10000002106), false"];
33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, item#643815.worklistShardItemId AS worklistShardItemId#643816L, item#643815.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#643817, item#643815.qty AS qty#643818]"];
34 [id="node34" labelType="html" label="<b>Generate</b><br><br>number of output rows: 980" tooltip="Generate explode(items#643170), [shardId#643168], false, [item#643815]"];
35 [id="node35" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#643168, items#643170]"];
36 [id="node36" labelType="html" label="<b>Filter</b><br><br>number of output rows: 59" tooltip="Filter ((isnotnull(shardId#643168) AND (shardId#643168 = 0_1_10000002106)) AND ((size(items#643170, true) > 0) AND isnotnull(items#643170)))"];
37 [id="node37" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 59" tooltip="Scan ExistingRDD[shardId#643168,orderProposalId#643169L,items#643170,optimizationGroups#643171,isOptimal#643172,lastModified#643173,optimizationInsights#643174]"];
}
38 [id="node38" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 2 ms<br>time to build: 2 ms<br>time to collect: 545 ms<br>number of output rows: 980<br>data size: 2.0 MiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=270920]"];
subgraph cluster39 {
isCluster="true";
id="cluster39";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n67 ms (2 ms, 3 ms, 5 ms (stage 52562.0: task 139686))";
tooltip="WholeStageCodegen (2)";
40 [id="node40" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemGroupId#645061, splitIndicator#645056L, sourceOfSupplyUuid#645051, supplier#645040, subrange#645043, product#645046, plant#645041, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, netPriceAmount#645073, netPriceCurrencyCode#645074, measurements#645078, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, ... 4 more fields]"];
}
41 [id="node41" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 980<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 980<br>local bytes read total (min, med, max (stageId: taskId))<br>295.2 KiB (10.4 KiB, 14.4 KiB, 21.8 KiB (stage 52562.0: task 139690))<br>merged fetch fallback count: 0<br>local blocks read: 223<br>remote merged chunks fetched: 0<br>remote blocks read: 213<br>data size total (min, med, max (stageId: taskId))<br>1144.6 KiB (31.1 KiB, 45.7 KiB, 56.1 KiB (stage 52561.0: task 139662))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>24 ms (0 ms, 0 ms, 1 ms (stage 52561.0: task 139660))<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 52562.0: task 139688))<br>remote bytes read total (min, med, max (stageId: taskId))<br>287.2 KiB (5.4 KiB, 16.0 KiB, 19.6 KiB (stage 52562.0: task 139691))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>27 ms (1 ms, 1 ms, 2 ms (stage 52562.0: task 139689))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>582.4 KiB (18.3 KiB, 23.2 KiB, 27.3 KiB (stage 52561.0: task 139661))" tooltip="Exchange hashpartitioning(worklistShardItemId#645060L, 20), REPARTITION_BY_NUM, [plan_id=270916]"];
subgraph cluster42 {
isCluster="true";
id="cluster42";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n2.5 s (78 ms, 92 ms, 127 ms (stage 52561.0: task 139670))";
tooltip="WholeStageCodegen (1)";
43 [id="node43" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, ... 4 more fields]"];
44 [id="node44" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter isnotnull(worklistShardItemId#645060L)"];
45 [id="node45" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 980<br>number of input batches: 25" tooltip="ColumnarToRow"];
}
46 [id="node46" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 25<br>scan time total (min, med, max (stageId: taskId))<br>2.2 s (75 ms, 89 ms, 108 ms (stage 52561.0: task 139667))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 674.1 KiB<br>number of output rows: 980<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#645037L,supplier#645040,plant#645041,deliveryDateTime#645042,subrange#645043,supplyingPlant#645044,productGroup#645045,product#645046,availabilityDateTime#645048,nextAvailabilityDateTime#645049,sourceOfSupplyUuid#645051,isFallbackOrderOnly#645054,splitIndicator#645056L,worklistShardItemId#645060L,orderProposalItemGroupId#645061,logisticUnits#645064,orderQuantityBaseUom#645065,orderQuantityBaseUomUuid#645066,minimumOrderQuantity#645067,constraintLabels#645068,constraintOperators#645069,constraintValues#645070,netPriceAmount#645073,netPriceCurrencyCode#645074,netPriceQuantity#645075,... 6 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#645060L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#645081), isnotnull(sequenceId#645059), (shardId#645081 = 0_1_10000002106), (se..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:st..."];
subgraph cluster47 {
isCluster="true";
id="cluster47";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n2.7 s (36 ms, 54 ms, 407 ms (stage 52652.0: task 139789))";
tooltip="WholeStageCodegen (6)";
48 [id="node48" 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 52652.0: task 139787))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 52652.0: task 139787))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))" tooltip="Sort [shardId#647194 ASC NULLS FIRST, worklistShardItemId#647195L ASC NULLS FIRST], false, 0"];
}
49 [id="node49" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 980<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 980<br>local bytes read total (min, med, max (stageId: taskId))<br>56.6 KiB (2.0 KiB, 2.9 KiB, 3.6 KiB (stage 52652.0: task 139799))<br>merged fetch fallback count: 0<br>local blocks read: 76<br>remote merged chunks fetched: 0<br>remote blocks read: 298<br>data size total (min, med, max (stageId: taskId))<br>1025.9 KiB (45.0 KiB, 51.3 KiB, 59.7 KiB (stage 52649.0: task 139742))<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>20 ms (0 ms, 0 ms, 1 ms (stage 52649.0: task 139720))<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 52652.0: task 139787))<br>remote bytes read total (min, med, max (stageId: taskId))<br>223.9 KiB (10.1 KiB, 11.2 KiB, 13.0 KiB (stage 52652.0: task 139798))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>37 ms (1 ms, 2 ms, 3 ms (stage 52652.0: task 139794))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>280.4 KiB (12.9 KiB, 14.1 KiB, 15.1 KiB (stage 52649.0: task 139735))" tooltip="Exchange hashpartitioning(shardId#647194, worklistShardItemId#647195L, 20), ENSURE_REQUIREMENTS, [plan_id=270932]"];
subgraph cluster50 {
isCluster="true";
id="cluster50";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n140 ms (5 ms, 7 ms, 12 ms (stage 52649.0: task 139715))";
tooltip="WholeStageCodegen (5)";
51 [id="node51" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#647194, worklistShardItemId#647195L, coalesce(kpis#647199, []) AS prodLocSpecificKpis#647200]"];
52 [id="node52" labelType="html" label="<b>Filter</b><br><br>number of output rows: 980" tooltip="Filter (((isnull(qty#647196) AND isnull(demandChannel#647197)) AND isnull(demandStream#647198)) AND (((shardId#647194 = 0_1_10000002106) AND isnotnull(shardId#647194)) AND isnotnull(worklistShardItemId#647195L)))"];
53 [id="node53" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 4,129" tooltip="Scan ExistingRDD[shardId#647194,worklistShardItemId#647195L,qty#647196,demandChannel#647197,demandStream#647198,kpis#647199]"];
}
subgraph cluster54 {
isCluster="true";
id="cluster54";
label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n2.2 s (33 ms, 51 ms, 321 ms (stage 52652.0: task 139787))";
tooltip="WholeStageCodegen (9)";
55 [id="node55" 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 52652.0: task 139787))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 52652.0: task 139787))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))" tooltip="Sort [shardId#647210 ASC NULLS FIRST, worklistShardItemId#647211L ASC NULLS FIRST], false, 0"];
}
56 [id="node56" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 966<br>time in aggregation build total (min, med, max (stageId: taskId))<br>172 ms (2 ms, 4 ms, 25 ms (stage 52652.0: task 139787))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#647210, worklistShardItemId#647211L], functions=[collect_list(struct(demandChannel, demandChannel#647213, demandStream, demandStream#647214, kpis, kpis#647215), 0, 0)])"];
57 [id="node57" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 966<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 966<br>local bytes read total (min, med, max (stageId: taskId))<br>34.7 KiB (1023.0 B, 1898.0 B, 2.1 KiB (stage 52652.0: task 139799))<br>merged fetch fallback count: 0<br>local blocks read: 92<br>remote merged chunks fetched: 0<br>remote blocks read: 265<br>data size total (min, med, max (stageId: taskId))<br>392.4 KiB (17.1 KiB, 19.1 KiB, 23.6 KiB (stage 52651.0: task 139781))<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>21 ms (0 ms, 1 ms, 1 ms (stage 52651.0: task 139724))<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>7 ms (0 ms, 0 ms, 2 ms (stage 52652.0: task 139790))<br>remote bytes read total (min, med, max (stageId: taskId))<br>99.1 KiB (4.1 KiB, 5.1 KiB, 5.7 KiB (stage 52652.0: task 139793))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>42 ms (1 ms, 2 ms, 4 ms (stage 52652.0: task 139794))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>133.9 KiB (5.8 KiB, 6.7 KiB, 7.4 KiB (stage 52651.0: task 139782))" tooltip="Exchange hashpartitioning(shardId#647210, worklistShardItemId#647211L, 20), ENSURE_REQUIREMENTS, [plan_id=270943]"];
58 [id="node58" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 966<br>time in aggregation build total (min, med, max (stageId: taskId))<br>396 ms (4 ms, 5 ms, 88 ms (stage 52651.0: task 139745))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52651.0: task 139752))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#647210, worklistShardItemId#647211L], functions=[partial_collect_list(struct(demandChannel, demandChannel#647213, demandStream, demandStream#647214, kpis, kpis#647215), 0, 0)])"];
subgraph cluster59 {
isCluster="true";
id="cluster59";
label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n396 ms (4 ms, 5 ms, 88 ms (stage 52651.0: task 139745))";
tooltip="WholeStageCodegen (8)";
60 [id="node60" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#647210, worklistShardItemId#647211L, demandChannel#647213, demandStream#647214, kpis#647215]"];
61 [id="node61" labelType="html" label="<b>Filter</b><br><br>number of output rows: 966" tooltip="Filter ((((isnull(qty#647212) AND isnotnull(demandChannel#647213)) AND isnotnull(demandStream#647214)) AND (size(kpis#647215, true) > 0)) AND (((shardId#647210 = 0_1_10000002106) AND isnotnull(shardId#647210)) AND isnotnull(worklistShardItemId#647211L)))"];
62 [id="node62" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 4,129" tooltip="Scan ExistingRDD[shardId#647210,worklistShardItemId#647211L,qty#647212,demandChannel#647213,demandStream#647214,kpis#647215]"];
}
subgraph cluster63 {
isCluster="true";
id="cluster63";
label="WholeStageCodegen (12)\n \nduration: total (min, med, max (stageId: taskId))\n1.7 s (30 ms, 48 ms, 231 ms (stage 52652.0: task 139789))";
tooltip="WholeStageCodegen (12)";
64 [id="node64" labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 52652.0: task 139787))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 52652.0: task 139787))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))" tooltip="Sort [shardId#647223 ASC NULLS FIRST, worklistShardItemId#647224L ASC NULLS FIRST], false, 0"];
}
65 [id="node65" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 980<br>time in aggregation build total (min, med, max (stageId: taskId))<br>176 ms (2 ms, 3 ms, 28 ms (stage 52652.0: task 139789))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52652.0: task 139787))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#647223, worklistShardItemId#647224L], functions=[collect_list(struct(qty, qty#647225, kpis, kpis#647228), 0, 0)])"];
66 [id="node66" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 2,091<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 2,091<br>local bytes read total (min, med, max (stageId: taskId))<br>27.4 KiB (1071.0 B, 1450.0 B, 1588.0 B (stage 52652.0: task 139791))<br>merged fetch fallback count: 0<br>local blocks read: 40<br>remote merged chunks fetched: 0<br>remote blocks read: 357<br>data size total (min, med, max (stageId: taskId))<br>1357.2 KiB (60.5 KiB, 69.1 KiB, 72.7 KiB (stage 52650.0: task 139773))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>23 ms (0 ms, 1 ms, 1 ms (stage 52650.0: task 139744))<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 52652.0: task 139787))<br>remote bytes read total (min, med, max (stageId: taskId))<br>242.3 KiB (10.5 KiB, 12.1 KiB, 13.5 KiB (stage 52652.0: task 139798))<br>number of partitions: 20<br>remote reqs duration total (min, med, max (stageId: taskId))<br>28 ms (0 ms, 1 ms, 2 ms (stage 52652.0: task 139787))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>269.7 KiB (12.6 KiB, 13.5 KiB, 14.2 KiB (stage 52650.0: task 139753))" tooltip="Exchange hashpartitioning(shardId#647223, worklistShardItemId#647224L, 20), ENSURE_REQUIREMENTS, [plan_id=270955]"];
67 [id="node67" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 2,091<br>time in aggregation build total (min, med, max (stageId: taskId))<br>333 ms (4 ms, 4 ms, 83 ms (stage 52650.0: task 139719))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 52650.0: task 139751))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#647223, worklistShardItemId#647224L], functions=[partial_collect_list(struct(qty, qty#647225, kpis, kpis#647228), 0, 0)])"];
subgraph cluster68 {
isCluster="true";
id="cluster68";
label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n333 ms (4 ms, 4 ms, 83 ms (stage 52650.0: task 139719))";
tooltip="WholeStageCodegen (11)";
69 [id="node69" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#647223, worklistShardItemId#647224L, qty#647225, kpis#647228]"];
70 [id="node70" labelType="html" label="<b>Filter</b><br><br>number of output rows: 2,183" tooltip="Filter ((isnotnull(qty#647225) AND isnotnull(kpis#647228)) AND (((shardId#647223 = 0_1_10000002106) AND isnotnull(shardId#647223)) AND isnotnull(worklistShardItemId#647224L)))"];
71 [id="node71" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 4,129" tooltip="Scan ExistingRDD[shardId#647223,worklistShardItemId#647224L,qty#647225,demandChannel#647226,demandStream#647227,kpis#647228]"];
}
2->0;
3->2;
5->3;
6->5;
8->6;
9->8;
10->9;
11->10;
12->11;
13->12;
14->13;
15->14;
16->15;
18->16;
19->18;
21->19;
22->21;
24->22;
25->24;
27->25;
28->27;
30->28;
31->30;
32->31;
33->32;
34->33;
35->34;
36->35;
37->36;
38->32;
40->38;
41->40;
43->41;
44->43;
45->44;
46->45;
48->25;
49->48;
51->49;
52->51;
53->52;
55->22;
56->55;
57->56;
58->57;
60->58;
61->60;
62->61;
64->19;
65->64;
66->65;
67->66;
69->67;
70->69;
71->70;
}
== Physical Plan ==
CollectLimit (56)
+- * Project (55)
+- Exchange (54)
+- * HashAggregate (53)
+- Exchange (52)
+- * HashAggregate (51)
+- ObjectHashAggregate (50)
+- Exchange (49)
+- ObjectHashAggregate (48)
+- ObjectHashAggregate (47)
+- Exchange (46)
+- ObjectHashAggregate (45)
+- Project (44)
+- Project (43)
+- * Project (42)
+- * SortMergeJoin LeftOuter (41)
:- * Project (33)
: +- * SortMergeJoin LeftOuter (32)
: :- * Project (24)
: : +- * SortMergeJoin LeftOuter (23)
: : :- * Sort (17)
: : : +- Exchange (16)
: : : +- * Project (15)
: : : +- * Filter (14)
: : : +- * BroadcastHashJoin LeftOuter BuildRight (13)
: : : :- * Project (5)
: : : : +- * Generate (4)
: : : : +- * Project (3)
: : : : +- * Filter (2)
: : : : +- * Scan ExistingRDD (1)
: : : +- BroadcastExchange (12)
: : : +- * Project (11)
: : : +- Exchange (10)
: : : +- * Project (9)
: : : +- * Filter (8)
: : : +- * ColumnarToRow (7)
: : : +- Scan parquet (6)
: : +- * Sort (22)
: : +- Exchange (21)
: : +- * Project (20)
: : +- * Filter (19)
: : +- * Scan ExistingRDD (18)
: +- * Sort (31)
: +- ObjectHashAggregate (30)
: +- Exchange (29)
: +- ObjectHashAggregate (28)
: +- * Project (27)
: +- * Filter (26)
: +- * Scan ExistingRDD (25)
+- * Sort (40)
+- ObjectHashAggregate (39)
+- Exchange (38)
+- ObjectHashAggregate (37)
+- * Project (36)
+- * Filter (35)
+- * Scan ExistingRDD (34)
(1) Scan ExistingRDD [codegen id : 3]
Output [7]: [shardId#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, lastModified#643173, optimizationInsights#643174]
Arguments: [shardId#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, lastModified#643173, optimizationInsights#643174], MapPartitionsRDD[30592] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 3]
Input [7]: [shardId#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, lastModified#643173, optimizationInsights#643174]
Condition : ((isnotnull(shardId#643168) AND (shardId#643168 = 0_1_10000002106)) AND ((size(items#643170, true) > 0) AND isnotnull(items#643170)))
(3) Project [codegen id : 3]
Output [2]: [shardId#643168, items#643170]
Input [7]: [shardId#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, lastModified#643173, optimizationInsights#643174]
(4) Generate [codegen id : 3]
Input [2]: [shardId#643168, items#643170]
Arguments: explode(items#643170), [shardId#643168], false, [item#643815]
(5) Project [codegen id : 3]
Output [4]: [shardId#643168, item#643815.worklistShardItemId AS worklistShardItemId#643816L, item#643815.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#643817, item#643815.qty AS qty#643818]
Input [2]: [shardId#643168, item#643815]
(6) Scan parquet
Output [31]: [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, measurements#645078, optimizationGroups#645080, shardId#645081, sequenceId#645059]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000002106]
PartitionFilters: [isnotnull(shardId#645081), isnotnull(sequenceId#645059), (shardId#645081 = 0_1_10000002106), (sequenceId#645059 = 2)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,supplyingPlant:string,productGroup:string,product:string,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,sourceOfSupplyUuid:string,isFallbackOrderOnly:boolean,splitIndicator:bigint,worklistShardItemId:bigint,orderProposalItemGroupId: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>>,optimizationGroups:array<string>>
(7) ColumnarToRow [codegen id : 1]
Input [31]: [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, measurements#645078, optimizationGroups#645080, shardId#645081, sequenceId#645059]
(8) Filter [codegen id : 1]
Input [31]: [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, measurements#645078, optimizationGroups#645080, shardId#645081, sequenceId#645059]
Condition : isnotnull(worklistShardItemId#645060L)
(9) Project [codegen id : 1]
Output [29]: [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, measurements#645078, optimizationGroups#645080]
Input [31]: [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, measurements#645078, optimizationGroups#645080, shardId#645081, sequenceId#645059]
(10) Exchange
Input [29]: [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, measurements#645078, optimizationGroups#645080]
Arguments: hashpartitioning(worklistShardItemId#645060L, 20), REPARTITION_BY_NUM, [plan_id=270916]
(11) Project [codegen id : 2]
Output [29]: [worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemGroupId#645061, splitIndicator#645056L, sourceOfSupplyUuid#645051, supplier#645040, subrange#645043, product#645046, plant#645041, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, netPriceAmount#645073, netPriceCurrencyCode#645074, measurements#645078, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, logisticUnits#645064, optimizationGroups#645080, supplyingPlant#645044, productGroup#645045]
Input [29]: [orderProposalId#645037L, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, availabilityDateTime#645048, nextAvailabilityDateTime#645049, sourceOfSupplyUuid#645051, isFallbackOrderOnly#645054, splitIndicator#645056L, worklistShardItemId#645060L, orderProposalItemGroupId#645061, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, measurements#645078, optimizationGroups#645080]
(12) BroadcastExchange
Input [29]: [worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemGroupId#645061, splitIndicator#645056L, sourceOfSupplyUuid#645051, supplier#645040, subrange#645043, product#645046, plant#645041, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, netPriceAmount#645073, netPriceCurrencyCode#645074, measurements#645078, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, logisticUnits#645064, optimizationGroups#645080, supplyingPlant#645044, productGroup#645045]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=270920]
(13) BroadcastHashJoin [codegen id : 3]
Left keys [1]: [worklistShardItemId#643816L]
Right keys [1]: [worklistShardItemId#645060L]
Join type: LeftOuter
Join condition: (shardId#643168 = 0_1_10000002106)
(14) Filter [codegen id : 3]
Input [33]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemGroupId#645061, splitIndicator#645056L, sourceOfSupplyUuid#645051, supplier#645040, subrange#645043, product#645046, plant#645041, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, netPriceAmount#645073, netPriceCurrencyCode#645074, measurements#645078, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, logisticUnits#645064, optimizationGroups#645080, supplyingPlant#645044, productGroup#645045]
Condition : NOT (isFallbackOrderOnly#645054 <=> true)
(15) Project [codegen id : 3]
Output [31]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078]
Input [33]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemGroupId#645061, splitIndicator#645056L, sourceOfSupplyUuid#645051, supplier#645040, subrange#645043, product#645046, plant#645041, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, netPriceAmount#645073, netPriceCurrencyCode#645074, measurements#645078, minimumOrderQuantity#645067, constraintLabels#645068, constraintOperators#645069, constraintValues#645070, logisticUnits#645064, optimizationGroups#645080, supplyingPlant#645044, productGroup#645045]
(16) Exchange
Input [31]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078]
Arguments: hashpartitioning(shardId#643168, worklistShardItemId#643816L, 20), ENSURE_REQUIREMENTS, [plan_id=270926]
(17) Sort [codegen id : 4]
Input [31]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078]
Arguments: [shardId#643168 ASC NULLS FIRST, worklistShardItemId#643816L ASC NULLS FIRST], false, 0
(18) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#647194, worklistShardItemId#647195L, qty#647196, demandChannel#647197, demandStream#647198, kpis#647199]
Arguments: [shardId#647194, worklistShardItemId#647195L, qty#647196, demandChannel#647197, demandStream#647198, kpis#647199], MapPartitionsRDD[30878] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(19) Filter [codegen id : 5]
Input [6]: [shardId#647194, worklistShardItemId#647195L, qty#647196, demandChannel#647197, demandStream#647198, kpis#647199]
Condition : (((isnull(qty#647196) AND isnull(demandChannel#647197)) AND isnull(demandStream#647198)) AND (((shardId#647194 = 0_1_10000002106) AND isnotnull(shardId#647194)) AND isnotnull(worklistShardItemId#647195L)))
(20) Project [codegen id : 5]
Output [3]: [shardId#647194, worklistShardItemId#647195L, coalesce(kpis#647199, []) AS prodLocSpecificKpis#647200]
Input [6]: [shardId#647194, worklistShardItemId#647195L, qty#647196, demandChannel#647197, demandStream#647198, kpis#647199]
(21) Exchange
Input [3]: [shardId#647194, worklistShardItemId#647195L, prodLocSpecificKpis#647200]
Arguments: hashpartitioning(shardId#647194, worklistShardItemId#647195L, 20), ENSURE_REQUIREMENTS, [plan_id=270932]
(22) Sort [codegen id : 6]
Input [3]: [shardId#647194, worklistShardItemId#647195L, prodLocSpecificKpis#647200]
Arguments: [shardId#647194 ASC NULLS FIRST, worklistShardItemId#647195L ASC NULLS FIRST], false, 0
(23) SortMergeJoin [codegen id : 7]
Left keys [2]: [shardId#643168, worklistShardItemId#643816L]
Right keys [2]: [shardId#647194, worklistShardItemId#647195L]
Join type: LeftOuter
Join condition: None
(24) Project [codegen id : 7]
Output [32]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, coalesce(prodLocSpecificKpis#647200, []) AS prodLocSpecificKpis#647201]
Input [34]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, shardId#647194, worklistShardItemId#647195L, prodLocSpecificKpis#647200]
(25) Scan ExistingRDD [codegen id : 8]
Output [6]: [shardId#647210, worklistShardItemId#647211L, qty#647212, demandChannel#647213, demandStream#647214, kpis#647215]
Arguments: [shardId#647210, worklistShardItemId#647211L, qty#647212, demandChannel#647213, demandStream#647214, kpis#647215], MapPartitionsRDD[30878] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(26) Filter [codegen id : 8]
Input [6]: [shardId#647210, worklistShardItemId#647211L, qty#647212, demandChannel#647213, demandStream#647214, kpis#647215]
Condition : ((((isnull(qty#647212) AND isnotnull(demandChannel#647213)) AND isnotnull(demandStream#647214)) AND (size(kpis#647215, true) > 0)) AND (((shardId#647210 = 0_1_10000002106) AND isnotnull(shardId#647210)) AND isnotnull(worklistShardItemId#647211L)))
(27) Project [codegen id : 8]
Output [5]: [shardId#647210, worklistShardItemId#647211L, demandChannel#647213, demandStream#647214, kpis#647215]
Input [6]: [shardId#647210, worklistShardItemId#647211L, qty#647212, demandChannel#647213, demandStream#647214, kpis#647215]
(28) ObjectHashAggregate
Input [5]: [shardId#647210, worklistShardItemId#647211L, demandChannel#647213, demandStream#647214, kpis#647215]
Keys [2]: [shardId#647210, worklistShardItemId#647211L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#647213, demandStream, demandStream#647214, kpis, kpis#647215), 0, 0)]
Aggregate Attributes [1]: [buf#648290]
Results [3]: [shardId#647210, worklistShardItemId#647211L, buf#648291]
(29) Exchange
Input [3]: [shardId#647210, worklistShardItemId#647211L, buf#648291]
Arguments: hashpartitioning(shardId#647210, worklistShardItemId#647211L, 20), ENSURE_REQUIREMENTS, [plan_id=270943]
(30) ObjectHashAggregate
Input [3]: [shardId#647210, worklistShardItemId#647211L, buf#648291]
Keys [2]: [shardId#647210, worklistShardItemId#647211L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#647213, demandStream, demandStream#647214, kpis, kpis#647215), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#647213, demandStream, demandStream#647214, kpis, kpis#647215), 0, 0)#647209]
Results [3]: [shardId#647210, worklistShardItemId#647211L, collect_list(struct(demandChannel, demandChannel#647213, demandStream, demandStream#647214, kpis, kpis#647215), 0, 0)#647209 AS channelStreamSpecificKpis#647202]
(31) Sort [codegen id : 9]
Input [3]: [shardId#647210, worklistShardItemId#647211L, channelStreamSpecificKpis#647202]
Arguments: [shardId#647210 ASC NULLS FIRST, worklistShardItemId#647211L ASC NULLS FIRST], false, 0
(32) SortMergeJoin [codegen id : 10]
Left keys [2]: [shardId#643168, worklistShardItemId#643816L]
Right keys [2]: [shardId#647210, worklistShardItemId#647211L]
Join type: LeftOuter
Join condition: None
(33) Project [codegen id : 10]
Output [33]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, prodLocSpecificKpis#647201, coalesce(channelStreamSpecificKpis#647202, []) AS channelStreamSpecificKpis#647216]
Input [35]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, prodLocSpecificKpis#647201, shardId#647210, worklistShardItemId#647211L, channelStreamSpecificKpis#647202]
(34) Scan ExistingRDD [codegen id : 11]
Output [6]: [shardId#647223, worklistShardItemId#647224L, qty#647225, demandChannel#647226, demandStream#647227, kpis#647228]
Arguments: [shardId#647223, worklistShardItemId#647224L, qty#647225, demandChannel#647226, demandStream#647227, kpis#647228], MapPartitionsRDD[30878] at start at FileStorageAdapterImpl.java:592, ExistingRDD, UnknownPartitioning(0)
(35) Filter [codegen id : 11]
Input [6]: [shardId#647223, worklistShardItemId#647224L, qty#647225, demandChannel#647226, demandStream#647227, kpis#647228]
Condition : ((isnotnull(qty#647225) AND isnotnull(kpis#647228)) AND (((shardId#647223 = 0_1_10000002106) AND isnotnull(shardId#647223)) AND isnotnull(worklistShardItemId#647224L)))
(36) Project [codegen id : 11]
Output [4]: [shardId#647223, worklistShardItemId#647224L, qty#647225, kpis#647228]
Input [6]: [shardId#647223, worklistShardItemId#647224L, qty#647225, demandChannel#647226, demandStream#647227, kpis#647228]
(37) ObjectHashAggregate
Input [4]: [shardId#647223, worklistShardItemId#647224L, qty#647225, kpis#647228]
Keys [2]: [shardId#647223, worklistShardItemId#647224L]
Functions [1]: [partial_collect_list(struct(qty, qty#647225, kpis, kpis#647228), 0, 0)]
Aggregate Attributes [1]: [buf#648292]
Results [3]: [shardId#647223, worklistShardItemId#647224L, buf#648293]
(38) Exchange
Input [3]: [shardId#647223, worklistShardItemId#647224L, buf#648293]
Arguments: hashpartitioning(shardId#647223, worklistShardItemId#647224L, 20), ENSURE_REQUIREMENTS, [plan_id=270955]
(39) ObjectHashAggregate
Input [3]: [shardId#647223, worklistShardItemId#647224L, buf#648293]
Keys [2]: [shardId#647223, worklistShardItemId#647224L]
Functions [1]: [collect_list(struct(qty, qty#647225, kpis, kpis#647228), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#647225, kpis, kpis#647228), 0, 0)#647222]
Results [3]: [shardId#647223, worklistShardItemId#647224L, map_from_entries(collect_list(struct(qty, qty#647225, kpis, kpis#647228), 0, 0)#647222) AS quantityKpis#647217]
(40) Sort [codegen id : 12]
Input [3]: [shardId#647223, worklistShardItemId#647224L, quantityKpis#647217]
Arguments: [shardId#647223 ASC NULLS FIRST, worklistShardItemId#647224L ASC NULLS FIRST], false, 0
(41) SortMergeJoin [codegen id : 13]
Left keys [2]: [shardId#643168, worklistShardItemId#643816L]
Right keys [2]: [shardId#647223, worklistShardItemId#647224L]
Join type: LeftOuter
Join condition: None
(42) Project [codegen id : 13]
Output [31]: [shardId#643168, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, prodLocSpecificKpis#647201, channelStreamSpecificKpis#647216, coalesce(quantityKpis#647217, map(keys: [], values: [])) AS quantityKpis#647229, arrays_zip(constraintLabels#645068, constraintOperators#645069, constraintValues#645070, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#648543]
Input [36]: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, constraintValues#645070, constraintOperators#645069, constraintLabels#645068, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, prodLocSpecificKpis#647201, channelStreamSpecificKpis#647216, shardId#647223, worklistShardItemId#647224L, quantityKpis#647217]
(43) Project
Output [32]: [shardId#643168, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, prodLocSpecificKpis#647201, channelStreamSpecificKpis#647216, quantityKpis#647229, struct(minServiceLevel, array_min(filter(constraintStructArray#648543, lambdafunction((lambda x_1656#648550.constraintLabels = ServiceLevel), lambda x_1656#648550, false)).constraintValues), minServiceLevelMinStock, null, maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#648543, lambdafunction((lambda x_1657#648551.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_1657#648551, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#648543, lambdafunction((lambda x_1658#648552.constraintLabels = RangeOfCoverage), lambda x_1658#648552, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#645067, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1659#648553.label = NonListingStartTimestamp), lambda x_1659#648553, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#648549, CASE WHEN (qty#643818 <=> quantityAfterProdPlantOptimization#643817) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#643818 * (cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648621.isOrderUnit, lambda x_1660#648621, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648622.isOrderUnit, lambda x_1660#648622, false)), 1, None, false).numerator as double))), qty#643818), orderQuantityUom, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648623.isOrderUnit, lambda x_1660#648623, false)), 1, None, false).uom, orderQuantityBaseUom#645065), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648624.isOrderUnit, lambda x_1660#648624, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#645066), candidateOrderQuantityInBaseUnit, qty#643818, orderQuantityBaseUom, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#645066, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1662#648625.isPreferred AND (((qty#643818 * cast(lambda x_1662#648625.denominator as double)) % cast(lambda x_1662#648625.numerator as double)) = 0.0)), lambda x_1662#648625, false)), lambdafunction(struct(inPreferredQuantity, ((qty#643818 * cast(lambda x_1663#648663.denominator as double)) / cast(lambda x_1663#648663.numerator as double)), uom, lambda x_1663#648663.uom, uomUuid, lambda x_1663#648663.uomUuid), lambda x_1663#648663, false))).inPreferredQuantity, coalesce((qty#643818 * (cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648626.isOrderUnit, lambda x_1661#648626, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648627.isOrderUnit, lambda x_1661#648627, false)), 1, None, false).numerator as double))), qty#643818)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1662#648628.isPreferred AND (((qty#643818 * cast(lambda x_1662#648628.denominator as double)) % cast(lambda x_1662#648628.numerator as double)) = 0.0)), lambda x_1662#648628, false)), lambdafunction(struct(inPreferredQuantity, ((qty#643818 * cast(lambda x_1663#648664.denominator as double)) / cast(lambda x_1663#648664.numerator as double)), uom, lambda x_1663#648664.uom, uomUuid, lambda x_1663#648664.uomUuid), lambda x_1663#648664, false))).uom, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648629.isOrderUnit, lambda x_1661#648629, false)), 1, None, false).uom, orderQuantityBaseUom#645065)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1662#648630.isPreferred AND (((qty#643818 * cast(lambda x_1662#648630.denominator as double)) % cast(lambda x_1662#648630.numerator as double)) = 0.0)), lambda x_1662#648630, false)), lambdafunction(struct(inPreferredQuantity, ((qty#643818 * cast(lambda x_1663#648665.denominator as double)) / cast(lambda x_1663#648665.numerator as double)), uom, lambda x_1663#648665.uom, uomUuid, lambda x_1663#648665.uomUuid), lambda x_1663#648665, false))).uomUuid, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648631.isOrderUnit, lambda x_1661#648631, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#645066)), serviceLevel, coalesce(filter(element_at(quantityKpis#647229, qty#643818, None, false), lambdafunction((lambda x_1668#648632.label = ServiceLevel), lambda x_1668#648632, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#643818 * (cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648635.isOrderUnit, lambda x_1660#648635, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648636.isOrderUnit, lambda x_1660#648636, false)), 1, None, false).numerator as double))), qty#643818), orderQuantityUom, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648637.isOrderUnit, lambda x_1660#648637, false)), 1, None, false).uom, orderQuantityBaseUom#645065), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1660#648638.isOrderUnit, lambda x_1660#648638, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#645066), candidateOrderQuantityInBaseUnit, qty#643818, orderQuantityBaseUom, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#645066, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1662#648639.isPreferred AND (((qty#643818 * cast(lambda x_1662#648639.denominator as double)) % cast(lambda x_1662#648639.numerator as double)) = 0.0)), lambda x_1662#648639, false)), lambdafunction(struct(inPreferredQuantity, ((qty#643818 * cast(lambda x_1663#648666.denominator as double)) / cast(lambda x_1663#648666.numerator as double)), uom, lambda x_1663#648666.uom, uomUuid, lambda x_1663#648666.uomUuid), lambda x_1663#648666, false))).inPreferredQuantity, coalesce((qty#643818 * (cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648640.isOrderUnit, lambda x_1661#648640, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648641.isOrderUnit, lambda x_1661#648641, false)), 1, None, false).numerator as double))), qty#643818)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1662#648642.isPreferred AND (((qty#643818 * cast(lambda x_1662#648642.denominator as double)) % cast(lambda x_1662#648642.numerator as double)) = 0.0)), lambda x_1662#648642, false)), lambdafunction(struct(inPreferredQuantity, ((qty#643818 * cast(lambda x_1663#648667.denominator as double)) / cast(lambda x_1663#648667.numerator as double)), uom, lambda x_1663#648667.uom, uomUuid, lambda x_1663#648667.uomUuid), lambda x_1663#648667, false))).uom, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648643.isOrderUnit, lambda x_1661#648643, false)), 1, None, false).uom, orderQuantityBaseUom#645065)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1662#648644.isPreferred AND (((qty#643818 * cast(lambda x_1662#648644.denominator as double)) % cast(lambda x_1662#648644.numerator as double)) = 0.0)), lambda x_1662#648644, false)), lambdafunction(struct(inPreferredQuantity, ((qty#643818 * cast(lambda x_1663#648668.denominator as double)) / cast(lambda x_1663#648668.numerator as double)), uom, lambda x_1663#648668.uom, uomUuid, lambda x_1663#648668.uomUuid), lambda x_1663#648668, false))).uomUuid, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1661#648645.isOrderUnit, lambda x_1661#648645, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#645066)), serviceLevel, coalesce(filter(element_at(quantityKpis#647229, qty#643818, None, false), lambdafunction((lambda x_1671#648646.label = ServiceLevel), lambda x_1671#648646, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#643817 * (cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1664#648649.isOrderUnit, lambda x_1664#648649, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1664#648650.isOrderUnit, lambda x_1664#648650, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#643817), orderQuantityUom, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1664#648651.isOrderUnit, lambda x_1664#648651, false)), 1, None, false).uom, orderQuantityBaseUom#645065), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1664#648652.isOrderUnit, lambda x_1664#648652, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#645066), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#643817, orderQuantityBaseUom, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#645066, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1666#648653.isPreferred AND (((quantityAfterProdPlantOptimization#643817 * cast(lambda x_1666#648653.denominator as double)) % cast(lambda x_1666#648653.numerator as double)) = 0.0)), lambda x_1666#648653, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#643817 * cast(lambda x_1667#648669.denominator as double)) / cast(lambda x_1667#648669.numerator as double)), uom, lambda x_1667#648669.uom, uomUuid, lambda x_1667#648669.uomUuid), lambda x_1667#648669, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#643817 * (cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1665#648654.isOrderUnit, lambda x_1665#648654, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1665#648655.isOrderUnit, lambda x_1665#648655, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#643817)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1666#648656.isPreferred AND (((quantityAfterProdPlantOptimization#643817 * cast(lambda x_1666#648656.denominator as double)) % cast(lambda x_1666#648656.numerator as double)) = 0.0)), lambda x_1666#648656, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#643817 * cast(lambda x_1667#648670.denominator as double)) / cast(lambda x_1667#648670.numerator as double)), uom, lambda x_1667#648670.uom, uomUuid, lambda x_1667#648670.uomUuid), lambda x_1667#648670, false))).uom, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1665#648657.isOrderUnit, lambda x_1665#648657, false)), 1, None, false).uom, orderQuantityBaseUom#645065)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#645064, lambdafunction((lambda x_1666#648658.isPreferred AND (((quantityAfterProdPlantOptimization#643817 * cast(lambda x_1666#648658.denominator as double)) % cast(lambda x_1666#648658.numerator as double)) = 0.0)), lambda x_1666#648658, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#643817 * cast(lambda x_1667#648671.denominator as double)) / cast(lambda x_1667#648671.numerator as double)), uom, lambda x_1667#648671.uom, uomUuid, lambda x_1667#648671.uomUuid), lambda x_1667#648671, false))).uomUuid, coalesce(element_at(filter(logisticUnits#645064, lambdafunction(lambda x_1665#648659.isOrderUnit, lambda x_1665#648659, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#645066)), serviceLevel, coalesce(filter(element_at(quantityKpis#647229, quantityAfterProdPlantOptimization#643817, None, false), lambdafunction((lambda x_1674#648660.label = ServiceLevel), lambda x_1674#648660, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#648620, coalesce(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1677#648673.label = InitialStockQty), lambda x_1677#648673, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#648672, coalesce(filter(prodLocSpecificKpis#647201, lambdafunction((lambda x_1678#648675.label = DemandPeriodEndTimestamp), lambda x_1678#648675, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#648674]
Input [31]: [shardId#643168, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, minimumOrderQuantity#645067, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, prodLocSpecificKpis#647201, channelStreamSpecificKpis#647216, quantityKpis#647229, constraintStructArray#648543]
(44) Project
Output [5]: [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, struct(itemId, 123456, itemGroupId, 123456, supplier, supplier#645040, supplyingPlant, supplyingPlant#645044, productGroup, productGroup#645045, product, product#645046, plant, plant#645041, supplierSubRange, subrange#645043, sourceOfSupplyUuid, sourceOfSupplyUuid#645051, deliveryDateTime, deliveryDateTime#645042, unitPrice, netPriceAmount#645073, unitPriceCurrency, netPriceCurrencyCode#645074, unitPriceQuantity, ... 37 more fields) AS parentItem#648754]
Input [32]: [shardId#643168, qty#643818, orderProposalId#645037L, supplier#645040, supplyingPlant#645044, productGroup#645045, product#645046, plant#645041, subrange#645043, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, logisticUnits#645064, orderQuantityBaseUom#645065, orderQuantityBaseUomUuid#645066, splitIndicator#645056L, netPriceAmount#645073, netPriceCurrencyCode#645074, netPriceQuantity#645075, netPriceQuantityUom#645076, netPriceQuantityUomUuid#645077, sourceOfSupplyUuid#645051, orderProposalItemGroupId#645061, optimizationGroups#645080, measurements#645078, prodLocSpecificKpis#647201, channelStreamSpecificKpis#647216, quantityKpis#647229, constraintBenchmark#648549, calculationAnalysis#648620, inventoryDateTime#648672, demandPeriodEndDateTime#648674]
(45) ObjectHashAggregate
Input [5]: [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, parentItem#648754]
Keys [4]: [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061]
Functions [1]: [partial_collect_list(parentItem#648754, 0, 0)]
Aggregate Attributes [1]: [buf#650121]
Results [5]: [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, buf#650129]
(46) Exchange
Input [5]: [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, buf#650129]
Arguments: hashpartitioning(shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, 20), ENSURE_REQUIREMENTS, [plan_id=270967]
(47) ObjectHashAggregate
Input [5]: [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061, buf#650129]
Keys [4]: [shardId#643168, orderProposalId#645037L, splitIndicator#645056L, orderProposalItemGroupId#645061]
Functions [1]: [collect_list(parentItem#648754, 0, 0)]
Aggregate Attributes [1]: [collect_list(parentItem#648754, 0, 0)#648859]
Results [3]: [shardId#643168, orderProposalId#645037L, collect_list(parentItem#648754, 0, 0)#648859 AS parentItems#648807]
(48) ObjectHashAggregate
Input [3]: [shardId#643168, orderProposalId#645037L, parentItems#648807]
Keys [2]: [shardId#643168, orderProposalId#645037L]
Functions [1]: [partial_collect_list(parentItems#648807, 0, 0)]
Aggregate Attributes [1]: [buf#650106]
Results [3]: [shardId#643168, orderProposalId#645037L, buf#650114]
(49) Exchange
Input [3]: [shardId#643168, orderProposalId#645037L, buf#650114]
Arguments: hashpartitioning(shardId#643168, orderProposalId#645037L, 20), ENSURE_REQUIREMENTS, [plan_id=270970]
(50) ObjectHashAggregate
Input [3]: [shardId#643168, orderProposalId#645037L, buf#650114]
Keys [2]: [shardId#643168, orderProposalId#645037L]
Functions [1]: [collect_list(parentItems#648807, 0, 0)]
Aggregate Attributes [1]: [collect_list(parentItems#648807, 0, 0)#648891]
Results [2]: [shardId#643168, CASE WHEN (size(flatten(collect_list(parentItems#648807, 0, 0)#648891), true) > 2000) THEN xxhash64(orderProposalId#645037L, 42) ELSE xxhash64(pmod(cast(orderProposalId#645037L as decimal(20,0)), 1), 42) END AS resultSeparationId#657383L]
(51) HashAggregate [codegen id : 14]
Input [2]: [shardId#643168, resultSeparationId#657383L]
Keys [2]: [shardId#643168, resultSeparationId#657383L]
Functions: []
Aggregate Attributes: []
Results [2]: [shardId#643168, resultSeparationId#657383L]
(52) Exchange
Input [2]: [shardId#643168, resultSeparationId#657383L]
Arguments: hashpartitioning(shardId#643168, resultSeparationId#657383L, 20), ENSURE_REQUIREMENTS, [plan_id=270975]
(53) HashAggregate [codegen id : 15]
Input [2]: [shardId#643168, resultSeparationId#657383L]
Keys [2]: [shardId#643168, resultSeparationId#657383L]
Functions: []
Aggregate Attributes: []
Results [2]: [shardId#643168, resultSeparationId#657383L]
(54) Exchange
Input [2]: [shardId#643168, resultSeparationId#657383L]
Arguments: SinglePartition, REPARTITION_BY_NUM, [plan_id=270979]
(55) Project [codegen id : 16]
Output: []
Input [2]: [shardId#643168, resultSeparationId#657383L]
(56) CollectLimit
Input: []
Arguments: 1