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: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 1<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=2831428]"];
subgraph cluster4 {
isCluster="true";
id="cluster4";
label="WholeStageCodegen (15)\n \nduration: total (min, med, max (stageId: taskId))\n115 ms (0 ms, 4 ms, 14 ms (stage 1300728.0: task 2424710))";
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>7 ms (0 ms, 0 ms, 4 ms (stage 1300728.0: task 2424716))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1300728.0: task 2424711))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#5451213, resultSeparationId#5456938L], functions=[])"];
}
6 [id="node6" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#5451213, resultSeparationId#5456938L, 30), ENSURE_REQUIREMENTS, [plan_id=2831424]"];
subgraph cluster7 {
isCluster="true";
id="cluster7";
label="WholeStageCodegen (14)\n \nduration: total (min, med, max (stageId: taskId))\n692 ms (0 ms, 22 ms, 93 ms (stage 1300727.0: task 2424680))";
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>15 ms (0 ms, 0 ms, 4 ms (stage 1300727.0: task 2424689))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1300727.0: task 2424679))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#5451213, resultSeparationId#5456938L], functions=[])"];
}
9 [id="node9" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1300727.0: task 2424679))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5451213, orderProposalId#5452230L], functions=[collect_list(parentItems#5453733, 0, 0)])"];
10 [id="node10" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#5451213, orderProposalId#5452230L, 30), ENSURE_REQUIREMENTS, [plan_id=2831419]"];
11 [id="node11" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1300726.0: task 2424660))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5451213, orderProposalId#5452230L], functions=[partial_collect_list(parentItems#5453733, 0, 0)])"];
12 [id="node12" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1300726.0: task 2424660))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254], functions=[collect_list(parentItem#5453680, 0, 0)])"];
13 [id="node13" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, 30), ENSURE_REQUIREMENTS, [plan_id=2831416]"];
14 [id="node14" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>120 ms (0 ms, 4 ms, 16 ms (stage 1300725.0: task 2424632))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254], functions=[partial_collect_list(parentItem#5453680, 0, 0)])"];
15 [id="node15" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, struct(supplier, supplier#5452233, supplyingPlant, supplyingPlant#5452237, productGroup, productGroup#5452238, product, product#5452239, plant, plant#5452234, supplierSubRange, subrange#5452236, sourceOfSupplyUuid, sourceOfSupplyUuid#5452244, deliveryDateTime, deliveryDateTime#5452235, unitPrice, netPriceAmount#5452266, unitPriceCurrency, netPriceCurrencyCode#5452267, unitPriceQuantity, netPriceQuantity#5452268, unitPriceQuantityUom, netPriceQuantityUom#5452269, unitPriceQuantityUomUuid, ... 31 more fields) AS parentItem#5453680]"];
16 [id="node16" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, ... 7 more fields]"];
subgraph cluster17 {
isCluster="true";
id="cluster17";
label="WholeStageCodegen (13)\n \nduration: total (min, med, max (stageId: taskId))\n2.7 s (22 ms, 101 ms, 257 ms (stage 1300725.0: task 2424627))";
tooltip="WholeStageCodegen (13)";
18 [id="node18" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, ... 6 more fields]"];
19 [id="node19" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300725.0: task 2424623))" tooltip="SortMergeJoin [shardId#5451213, worklistShardItemId#5451799L], [shardId#5453006, worklistShardItemId#5453007L], LeftOuter"];
}
subgraph cluster20 {
isCluster="true";
id="cluster20";
label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n3.6 s (22 ms, 134 ms, 364 ms (stage 1300725.0: task 2424632))";
tooltip="WholeStageCodegen (10)";
21 [id="node21" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, ... 8 more fields]"];
22 [id="node22" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300725.0: task 2424623))" tooltip="SortMergeJoin [shardId#5451213, worklistShardItemId#5451799L], [shardId#5452993, worklistShardItemId#5452994L], LeftOuter"];
}
subgraph cluster23 {
isCluster="true";
id="cluster23";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n4.6 s (22 ms, 179 ms, 464 ms (stage 1300725.0: task 2424632))";
tooltip="WholeStageCodegen (7)";
24 [id="node24" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, ... 7 more fields]"];
25 [id="node25" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 0<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300725.0: task 2424623))" tooltip="SortMergeJoin [shardId#5451213, worklistShardItemId#5451799L], [shardId#5452977, worklistShardItemId#5452978L], LeftOuter"];
}
subgraph cluster26 {
isCluster="true";
id="cluster26";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n5.4 s (23 ms, 224 ms, 561 ms (stage 1300725.0: task 2424632))";
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 1300725.0: task 2424623))<br>peak memory total (min, med, max (stageId: taskId))<br>1920.0 KiB (64.0 KiB, 64.0 KiB, 64.0 KiB (stage 1300725.0: task 2424623))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300725.0: task 2424623))" tooltip="Sort [shardId#5451213 ASC NULLS FIRST, worklistShardItemId#5451799L ASC NULLS FIRST], false, 0"];
}
28 [id="node28" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#5451213, worklistShardItemId#5451799L, 30), ENSURE_REQUIREMENTS, [plan_id=2831375]"];
subgraph cluster29 {
isCluster="true";
id="cluster29";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n1.0 s (0 ms, 20 ms, 357 ms (stage 1300721.0: task 2424598))";
tooltip="WholeStageCodegen (3)";
30 [id="node30" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, ... 6 more fields]"];
31 [id="node31" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter NOT (isFallbackOrderOnly#5452247 <=> true)"];
32 [id="node32" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 9" tooltip="BroadcastHashJoin [worklistShardItemId#5451799L], [worklistShardItemId#5452253L], LeftOuter, BuildRight, (shardId#5451213 = 0_1_10000001444), false"];
33 [id="node33" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, item#5451798.worklistShardItemId AS worklistShardItemId#5451799L, item#5451798.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5451800, item#5451798.qty AS qty#5451801]"];
34 [id="node34" labelType="html" label="<b>Generate</b><br><br>number of output rows: 9" tooltip="Generate explode(items#5451215), [shardId#5451213], false, [item#5451798]"];
35 [id="node35" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5451213, items#5451215]"];
36 [id="node36" labelType="html" label="<b>Filter</b><br><br>number of output rows: 3" tooltip="Filter ((isnotnull(shardId#5451213) AND (shardId#5451213 = 0_1_10000001444)) AND ((size(items#5451215, true) > 0) AND isnotnull(items#5451215)))"];
37 [id="node37" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 3" tooltip="Scan ExistingRDD[shardId#5451213,orderProposalId#5451214L,items#5451215,optimizationGroups#5451216,isOptimal#5451217,lastModified#5451218,optimizationInsights#5451219]"];
}
38 [id="node38" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 404 ms<br>number of output rows: 9<br>data size: 1028.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2831369]"];
subgraph cluster39 {
isCluster="true";
id="cluster39";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n18 ms (0 ms, 0 ms, 3 ms (stage 1300534.0: task 2424470))";
tooltip="WholeStageCodegen (2)";
40 [id="node40" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#5452253L, orderProposalId#5452230L, orderProposalItemGroupId#5452254, splitIndicator#5452249L, sourceOfSupplyUuid#5452244, supplier#5452233, subrange#5452236, product#5452239, plant#5452234, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, isFallbackOrderOnly#5452247, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, netPriceAmount#5452266, netPriceCurrencyCode#5452267, measurements#5452271, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, ... 4 more fields]"];
}
41 [id="node41" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 9<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 9<br>local bytes read total (min, med, max (stageId: taskId))<br>6.7 KiB (749.0 B, 760.0 B, 772.0 B (stage 1300534.0: task 2424474))<br>merged fetch fallback count: 0<br>local blocks read: 9<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>9.3 KiB (1056.0 B, 1064.0 B, 2.1 KiB (stage 1300533.0: task 2424460))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>16 ms (0 ms, 0 ms, 7 ms (stage 1300533.0: task 2424464))<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 1300534.0: task 2424469))<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.7 KiB (749.0 B, 769.0 B, 1515.0 B (stage 1300533.0: task 2424460))" tooltip="Exchange hashpartitioning(worklistShardItemId#5452253L, 30), REPARTITION_BY_NUM, [plan_id=2831365]"];
subgraph cluster42 {
isCluster="true";
id="cluster42";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n1.2 s (117 ms, 126 ms, 200 ms (stage 1300533.0: task 2424463))";
tooltip="WholeStageCodegen (1)";
43 [id="node43" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, ... 4 more fields]"];
44 [id="node44" labelType="html" label="<b>Filter</b><br><br>number of output rows: 9" tooltip="Filter isnotnull(worklistShardItemId#5452253L)"];
45 [id="node45" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 9<br>number of input batches: 8" tooltip="ColumnarToRow"];
}
46 [id="node46" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 8<br>scan time total (min, med, max (stageId: taskId))<br>819 ms (92 ms, 101 ms, 122 ms (stage 1300533.0: task 2424463))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 147.0 KiB<br>number of output rows: 9<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#5452230L,supplier#5452233,plant#5452234,deliveryDateTime#5452235,subrange#5452236,supplyingPlant#5452237,productGroup#5452238,product#5452239,availabilityDateTime#5452241,nextAvailabilityDateTime#5452242,sourceOfSupplyUuid#5452244,isFallbackOrderOnly#5452247,splitIndicator#5452249L,worklistShardItemId#5452253L,orderProposalItemGroupId#5452254,logisticUnits#5452257,orderQuantityBaseUom#5452258,orderQuantityBaseUomUuid#5452259,minimumOrderQuantity#5452260,constraintLabels#5452261,constraintOperators#5452262,constraintValues#5452263,netPriceAmount#5452266,netPriceCurrencyCode#5452267,netPriceQuantity#5452268,... 6 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#5452253L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5452274), isnotnull(sequenceId#5452252), (shardId#5452274 = 0_1_10000001444), ..., 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: 0 ms";
tooltip="WholeStageCodegen (6)";
48 [id="node48" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#5452977 ASC NULLS FIRST, worklistShardItemId#5452978L ASC NULLS FIRST], false, 0"];
}
49 [id="node49" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 9<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read total (min, med, max (stageId: taskId))<br>5.6 KiB (601.0 B, 676.0 B, 1294.0 B (stage 1300725.0: task 2424622))<br>merged fetch fallback count: 0<br>local blocks read: 9<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>10.4 KiB (1184.0 B, 1184.0 B, 1184.0 B (stage 1300723.0: task 2424517))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>4 ms (0 ms, 0 ms, 0 ms (stage 1300723.0: task 2424523))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>5.6 KiB (601.0 B, 647.0 B, 679.0 B (stage 1300723.0: task 2424524))" tooltip="Exchange hashpartitioning(shardId#5452977, worklistShardItemId#5452978L, 30), ENSURE_REQUIREMENTS, [plan_id=2831381]"];
subgraph cluster50 {
isCluster="true";
id="cluster50";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n103 ms (2 ms, 3 ms, 8 ms (stage 1300723.0: task 2424544))";
tooltip="WholeStageCodegen (5)";
51 [id="node51" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5452977, worklistShardItemId#5452978L, coalesce(kpis#5452982, []) AS prodLocSpecificKpis#5452983]"];
52 [id="node52" labelType="html" label="<b>Filter</b><br><br>number of output rows: 9" tooltip="Filter (((isnull(qty#5452979) AND isnull(demandChannel#5452980)) AND isnull(demandStream#5452981)) AND (((shardId#5452977 = 0_1_10000001444) AND isnotnull(shardId#5452977)) AND isnotnull(worklistShardItemId#5452978L)))"];
53 [id="node53" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 126" tooltip="Scan ExistingRDD[shardId#5452977,worklistShardItemId#5452978L,qty#5452979,demandChannel#5452980,demandStream#5452981,kpis#5452982]"];
}
subgraph cluster54 {
isCluster="true";
id="cluster54";
label="WholeStageCodegen (9)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (9)";
55 [id="node55" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#5452993 ASC NULLS FIRST, worklistShardItemId#5452994L ASC NULLS FIRST], false, 0"];
}
56 [id="node56" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>39 ms (0 ms, 0 ms, 26 ms (stage 1300725.0: task 2424619))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300725.0: task 2424623))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5452993, worklistShardItemId#5452994L], functions=[collect_list(struct(demandChannel, demandChannel#5452996, demandStream, demandStream#5452997, kpis, kpis#5452998), 0, 0)])"];
57 [id="node57" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 9<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 9<br>local bytes read total (min, med, max (stageId: taskId))<br>1348.0 B (331.0 B, 343.0 B, 343.0 B (stage 1300725.0: task 2424620))<br>merged fetch fallback count: 0<br>local blocks read: 4<br>remote merged chunks fetched: 0<br>remote blocks read: 5<br>data size total (min, med, max (stageId: taskId))<br>3.7 KiB (416.0 B, 416.0 B, 416.0 B (stage 1300722.0: task 2424526))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>4 ms (0 ms, 0 ms, 0 ms (stage 1300722.0: task 2424519))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>4 ms (0 ms, 0 ms, 2 ms (stage 1300725.0: task 2424623))<br>remote bytes read total (min, med, max (stageId: taskId))<br>1631.0 B (319.0 B, 319.0 B, 343.0 B (stage 1300725.0: task 2424621))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>6 ms (0 ms, 1 ms, 2 ms (stage 1300725.0: task 2424623))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>2.9 KiB (319.0 B, 331.0 B, 343.0 B (stage 1300722.0: task 2424526))" tooltip="Exchange hashpartitioning(shardId#5452993, worklistShardItemId#5452994L, 30), ENSURE_REQUIREMENTS, [plan_id=2831392]"];
58 [id="node58" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 9<br>time in aggregation build total (min, med, max (stageId: taskId))<br>685 ms (2 ms, 2 ms, 267 ms (stage 1300722.0: task 2424599))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300722.0: task 2424526))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5452993, worklistShardItemId#5452994L], functions=[partial_collect_list(struct(demandChannel, demandChannel#5452996, demandStream, demandStream#5452997, kpis, kpis#5452998), 0, 0)])"];
subgraph cluster59 {
isCluster="true";
id="cluster59";
label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n686 ms (2 ms, 2 ms, 267 ms (stage 1300722.0: task 2424599))";
tooltip="WholeStageCodegen (8)";
60 [id="node60" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5452993, worklistShardItemId#5452994L, demandChannel#5452996, demandStream#5452997, kpis#5452998]"];
61 [id="node61" labelType="html" label="<b>Filter</b><br><br>number of output rows: 9" tooltip="Filter ((((isnull(qty#5452995) AND isnotnull(demandChannel#5452996)) AND isnotnull(demandStream#5452997)) AND (size(kpis#5452998, true) > 0)) AND (((shardId#5452993 = 0_1_10000001444) AND isnotnull(shardId#5452993)) AND isnotnull(worklistShardItemId#5452994L)))"];
62 [id="node62" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 126" tooltip="Scan ExistingRDD[shardId#5452993,worklistShardItemId#5452994L,qty#5452995,demandChannel#5452996,demandStream#5452997,kpis#5452998]"];
}
subgraph cluster63 {
isCluster="true";
id="cluster63";
label="WholeStageCodegen (12)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (12)";
64 [id="node64" labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 0.0 B<br>spill size: 0.0 B" tooltip="Sort [shardId#5453006 ASC NULLS FIRST, worklistShardItemId#5453007L ASC NULLS FIRST], false, 0"];
}
65 [id="node65" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>36 ms (0 ms, 0 ms, 23 ms (stage 1300725.0: task 2424619))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300725.0: task 2424623))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5453006, worklistShardItemId#5453007L], functions=[collect_list(struct(qty, qty#5453008, kpis, kpis#5453011), 0, 0)])"];
66 [id="node66" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 73<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 73<br>local bytes read total (min, med, max (stageId: taskId))<br>25.9 KiB (603.0 B, 610.0 B, 10.0 KiB (stage 1300725.0: task 2424633))<br>merged fetch fallback count: 0<br>local blocks read: 40<br>remote merged chunks fetched: 0<br>remote blocks read: 33<br>data size total (min, med, max (stageId: taskId))<br>101.9 KiB (992.0 B, 2.9 KiB, 5.7 KiB (stage 1300724.0: task 2424614))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>14 ms (0 ms, 0 ms, 0 ms (stage 1300724.0: task 2424595))<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>1 ms (0 ms, 0 ms, 1 ms (stage 1300725.0: task 2424623))<br>remote bytes read total (min, med, max (stageId: taskId))<br>21.4 KiB (604.0 B, 1826.0 B, 7.5 KiB (stage 1300725.0: task 2424633))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>6 ms (0 ms, 1 ms, 1 ms (stage 1300725.0: task 2424623))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>47.4 KiB (637.0 B, 1875.0 B, 2.7 KiB (stage 1300724.0: task 2424614))" tooltip="Exchange hashpartitioning(shardId#5453006, worklistShardItemId#5453007L, 30), ENSURE_REQUIREMENTS, [plan_id=2831404]"];
67 [id="node67" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 73<br>time in aggregation build total (min, med, max (stageId: taskId))<br>208 ms (2 ms, 3 ms, 58 ms (stage 1300724.0: task 2424521))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1300724.0: task 2424554))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5453006, worklistShardItemId#5453007L], functions=[partial_collect_list(struct(qty, qty#5453008, kpis, kpis#5453011), 0, 0)])"];
subgraph cluster68 {
isCluster="true";
id="cluster68";
label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n208 ms (2 ms, 3 ms, 58 ms (stage 1300724.0: task 2424521))";
tooltip="WholeStageCodegen (11)";
69 [id="node69" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5453006, worklistShardItemId#5453007L, qty#5453008, kpis#5453011]"];
70 [id="node70" labelType="html" label="<b>Filter</b><br><br>number of output rows: 108" tooltip="Filter ((isnotnull(qty#5453008) AND isnotnull(kpis#5453011)) AND (((shardId#5453006 = 0_1_10000001444) AND isnotnull(shardId#5453006)) AND isnotnull(worklistShardItemId#5453007L)))"];
71 [id="node71" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 126" tooltip="Scan ExistingRDD[shardId#5453006,worklistShardItemId#5453007L,qty#5453008,demandChannel#5453009,demandStream#5453010,kpis#5453011]"];
}
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#5451213, orderProposalId#5451214L, items#5451215, optimizationGroups#5451216, isOptimal#5451217, lastModified#5451218, optimizationInsights#5451219]
Arguments: [shardId#5451213, orderProposalId#5451214L, items#5451215, optimizationGroups#5451216, isOptimal#5451217, lastModified#5451218, optimizationInsights#5451219], MapPartitionsRDD[383618] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 3]
Input [7]: [shardId#5451213, orderProposalId#5451214L, items#5451215, optimizationGroups#5451216, isOptimal#5451217, lastModified#5451218, optimizationInsights#5451219]
Condition : ((isnotnull(shardId#5451213) AND (shardId#5451213 = 0_1_10000001444)) AND ((size(items#5451215, true) > 0) AND isnotnull(items#5451215)))
(3) Project [codegen id : 3]
Output [2]: [shardId#5451213, items#5451215]
Input [7]: [shardId#5451213, orderProposalId#5451214L, items#5451215, optimizationGroups#5451216, isOptimal#5451217, lastModified#5451218, optimizationInsights#5451219]
(4) Generate [codegen id : 3]
Input [2]: [shardId#5451213, items#5451215]
Arguments: explode(items#5451215), [shardId#5451213], false, [item#5451798]
(5) Project [codegen id : 3]
Output [4]: [shardId#5451213, item#5451798.worklistShardItemId AS worklistShardItemId#5451799L, item#5451798.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5451800, item#5451798.qty AS qty#5451801]
Input [2]: [shardId#5451213, item#5451798]
(6) Scan parquet
Output [31]: [orderProposalId#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, measurements#5452271, optimizationGroups#5452273, shardId#5452274, sequenceId#5452252]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000001444]
PartitionFilters: [isnotnull(shardId#5452274), isnotnull(sequenceId#5452252), (shardId#5452274 = 0_1_10000001444), (sequenceId#5452252 = 8)]
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#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, measurements#5452271, optimizationGroups#5452273, shardId#5452274, sequenceId#5452252]
(8) Filter [codegen id : 1]
Input [31]: [orderProposalId#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, measurements#5452271, optimizationGroups#5452273, shardId#5452274, sequenceId#5452252]
Condition : isnotnull(worklistShardItemId#5452253L)
(9) Project [codegen id : 1]
Output [29]: [orderProposalId#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, measurements#5452271, optimizationGroups#5452273]
Input [31]: [orderProposalId#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, measurements#5452271, optimizationGroups#5452273, shardId#5452274, sequenceId#5452252]
(10) Exchange
Input [29]: [orderProposalId#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, measurements#5452271, optimizationGroups#5452273]
Arguments: hashpartitioning(worklistShardItemId#5452253L, 30), REPARTITION_BY_NUM, [plan_id=2831365]
(11) Project [codegen id : 2]
Output [29]: [worklistShardItemId#5452253L, orderProposalId#5452230L, orderProposalItemGroupId#5452254, splitIndicator#5452249L, sourceOfSupplyUuid#5452244, supplier#5452233, subrange#5452236, product#5452239, plant#5452234, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, isFallbackOrderOnly#5452247, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, netPriceAmount#5452266, netPriceCurrencyCode#5452267, measurements#5452271, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, logisticUnits#5452257, optimizationGroups#5452273, supplyingPlant#5452237, productGroup#5452238]
Input [29]: [orderProposalId#5452230L, supplier#5452233, plant#5452234, deliveryDateTime#5452235, subrange#5452236, supplyingPlant#5452237, productGroup#5452238, product#5452239, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, sourceOfSupplyUuid#5452244, isFallbackOrderOnly#5452247, splitIndicator#5452249L, worklistShardItemId#5452253L, orderProposalItemGroupId#5452254, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, measurements#5452271, optimizationGroups#5452273]
(12) BroadcastExchange
Input [29]: [worklistShardItemId#5452253L, orderProposalId#5452230L, orderProposalItemGroupId#5452254, splitIndicator#5452249L, sourceOfSupplyUuid#5452244, supplier#5452233, subrange#5452236, product#5452239, plant#5452234, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, isFallbackOrderOnly#5452247, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, netPriceAmount#5452266, netPriceCurrencyCode#5452267, measurements#5452271, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, logisticUnits#5452257, optimizationGroups#5452273, supplyingPlant#5452237, productGroup#5452238]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2831369]
(13) BroadcastHashJoin [codegen id : 3]
Left keys [1]: [worklistShardItemId#5451799L]
Right keys [1]: [worklistShardItemId#5452253L]
Join type: LeftOuter
Join condition: (shardId#5451213 = 0_1_10000001444)
(14) Filter [codegen id : 3]
Input [33]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, worklistShardItemId#5452253L, orderProposalId#5452230L, orderProposalItemGroupId#5452254, splitIndicator#5452249L, sourceOfSupplyUuid#5452244, supplier#5452233, subrange#5452236, product#5452239, plant#5452234, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, isFallbackOrderOnly#5452247, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, netPriceAmount#5452266, netPriceCurrencyCode#5452267, measurements#5452271, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, logisticUnits#5452257, optimizationGroups#5452273, supplyingPlant#5452237, productGroup#5452238]
Condition : NOT (isFallbackOrderOnly#5452247 <=> true)
(15) Project [codegen id : 3]
Output [31]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271]
Input [33]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, worklistShardItemId#5452253L, orderProposalId#5452230L, orderProposalItemGroupId#5452254, splitIndicator#5452249L, sourceOfSupplyUuid#5452244, supplier#5452233, subrange#5452236, product#5452239, plant#5452234, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, isFallbackOrderOnly#5452247, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, netPriceAmount#5452266, netPriceCurrencyCode#5452267, measurements#5452271, minimumOrderQuantity#5452260, constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, logisticUnits#5452257, optimizationGroups#5452273, supplyingPlant#5452237, productGroup#5452238]
(16) Exchange
Input [31]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271]
Arguments: hashpartitioning(shardId#5451213, worklistShardItemId#5451799L, 30), ENSURE_REQUIREMENTS, [plan_id=2831375]
(17) Sort [codegen id : 4]
Input [31]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271]
Arguments: [shardId#5451213 ASC NULLS FIRST, worklistShardItemId#5451799L ASC NULLS FIRST], false, 0
(18) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#5452977, worklistShardItemId#5452978L, qty#5452979, demandChannel#5452980, demandStream#5452981, kpis#5452982]
Arguments: [shardId#5452977, worklistShardItemId#5452978L, qty#5452979, demandChannel#5452980, demandStream#5452981, kpis#5452982], MapPartitionsRDD[383744] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(19) Filter [codegen id : 5]
Input [6]: [shardId#5452977, worklistShardItemId#5452978L, qty#5452979, demandChannel#5452980, demandStream#5452981, kpis#5452982]
Condition : (((isnull(qty#5452979) AND isnull(demandChannel#5452980)) AND isnull(demandStream#5452981)) AND (((shardId#5452977 = 0_1_10000001444) AND isnotnull(shardId#5452977)) AND isnotnull(worklistShardItemId#5452978L)))
(20) Project [codegen id : 5]
Output [3]: [shardId#5452977, worklistShardItemId#5452978L, coalesce(kpis#5452982, []) AS prodLocSpecificKpis#5452983]
Input [6]: [shardId#5452977, worklistShardItemId#5452978L, qty#5452979, demandChannel#5452980, demandStream#5452981, kpis#5452982]
(21) Exchange
Input [3]: [shardId#5452977, worklistShardItemId#5452978L, prodLocSpecificKpis#5452983]
Arguments: hashpartitioning(shardId#5452977, worklistShardItemId#5452978L, 30), ENSURE_REQUIREMENTS, [plan_id=2831381]
(22) Sort [codegen id : 6]
Input [3]: [shardId#5452977, worklistShardItemId#5452978L, prodLocSpecificKpis#5452983]
Arguments: [shardId#5452977 ASC NULLS FIRST, worklistShardItemId#5452978L ASC NULLS FIRST], false, 0
(23) SortMergeJoin [codegen id : 7]
Left keys [2]: [shardId#5451213, worklistShardItemId#5451799L]
Right keys [2]: [shardId#5452977, worklistShardItemId#5452978L]
Join type: LeftOuter
Join condition: None
(24) Project [codegen id : 7]
Output [32]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, coalesce(prodLocSpecificKpis#5452983, []) AS prodLocSpecificKpis#5452984]
Input [34]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, shardId#5452977, worklistShardItemId#5452978L, prodLocSpecificKpis#5452983]
(25) Scan ExistingRDD [codegen id : 8]
Output [6]: [shardId#5452993, worklistShardItemId#5452994L, qty#5452995, demandChannel#5452996, demandStream#5452997, kpis#5452998]
Arguments: [shardId#5452993, worklistShardItemId#5452994L, qty#5452995, demandChannel#5452996, demandStream#5452997, kpis#5452998], MapPartitionsRDD[383744] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(26) Filter [codegen id : 8]
Input [6]: [shardId#5452993, worklistShardItemId#5452994L, qty#5452995, demandChannel#5452996, demandStream#5452997, kpis#5452998]
Condition : ((((isnull(qty#5452995) AND isnotnull(demandChannel#5452996)) AND isnotnull(demandStream#5452997)) AND (size(kpis#5452998, true) > 0)) AND (((shardId#5452993 = 0_1_10000001444) AND isnotnull(shardId#5452993)) AND isnotnull(worklistShardItemId#5452994L)))
(27) Project [codegen id : 8]
Output [5]: [shardId#5452993, worklistShardItemId#5452994L, demandChannel#5452996, demandStream#5452997, kpis#5452998]
Input [6]: [shardId#5452993, worklistShardItemId#5452994L, qty#5452995, demandChannel#5452996, demandStream#5452997, kpis#5452998]
(28) ObjectHashAggregate
Input [5]: [shardId#5452993, worklistShardItemId#5452994L, demandChannel#5452996, demandStream#5452997, kpis#5452998]
Keys [2]: [shardId#5452993, worklistShardItemId#5452994L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#5452996, demandStream, demandStream#5452997, kpis, kpis#5452998), 0, 0)]
Aggregate Attributes [1]: [buf#5453225]
Results [3]: [shardId#5452993, worklistShardItemId#5452994L, buf#5453226]
(29) Exchange
Input [3]: [shardId#5452993, worklistShardItemId#5452994L, buf#5453226]
Arguments: hashpartitioning(shardId#5452993, worklistShardItemId#5452994L, 30), ENSURE_REQUIREMENTS, [plan_id=2831392]
(30) ObjectHashAggregate
Input [3]: [shardId#5452993, worklistShardItemId#5452994L, buf#5453226]
Keys [2]: [shardId#5452993, worklistShardItemId#5452994L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#5452996, demandStream, demandStream#5452997, kpis, kpis#5452998), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#5452996, demandStream, demandStream#5452997, kpis, kpis#5452998), 0, 0)#5452992]
Results [3]: [shardId#5452993, worklistShardItemId#5452994L, collect_list(struct(demandChannel, demandChannel#5452996, demandStream, demandStream#5452997, kpis, kpis#5452998), 0, 0)#5452992 AS channelStreamSpecificKpis#5452985]
(31) Sort [codegen id : 9]
Input [3]: [shardId#5452993, worklistShardItemId#5452994L, channelStreamSpecificKpis#5452985]
Arguments: [shardId#5452993 ASC NULLS FIRST, worklistShardItemId#5452994L ASC NULLS FIRST], false, 0
(32) SortMergeJoin [codegen id : 10]
Left keys [2]: [shardId#5451213, worklistShardItemId#5451799L]
Right keys [2]: [shardId#5452993, worklistShardItemId#5452994L]
Join type: LeftOuter
Join condition: None
(33) Project [codegen id : 10]
Output [33]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, prodLocSpecificKpis#5452984, coalesce(channelStreamSpecificKpis#5452985, []) AS channelStreamSpecificKpis#5452999]
Input [35]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, prodLocSpecificKpis#5452984, shardId#5452993, worklistShardItemId#5452994L, channelStreamSpecificKpis#5452985]
(34) Scan ExistingRDD [codegen id : 11]
Output [6]: [shardId#5453006, worklistShardItemId#5453007L, qty#5453008, demandChannel#5453009, demandStream#5453010, kpis#5453011]
Arguments: [shardId#5453006, worklistShardItemId#5453007L, qty#5453008, demandChannel#5453009, demandStream#5453010, kpis#5453011], MapPartitionsRDD[383744] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(35) Filter [codegen id : 11]
Input [6]: [shardId#5453006, worklistShardItemId#5453007L, qty#5453008, demandChannel#5453009, demandStream#5453010, kpis#5453011]
Condition : ((isnotnull(qty#5453008) AND isnotnull(kpis#5453011)) AND (((shardId#5453006 = 0_1_10000001444) AND isnotnull(shardId#5453006)) AND isnotnull(worklistShardItemId#5453007L)))
(36) Project [codegen id : 11]
Output [4]: [shardId#5453006, worklistShardItemId#5453007L, qty#5453008, kpis#5453011]
Input [6]: [shardId#5453006, worklistShardItemId#5453007L, qty#5453008, demandChannel#5453009, demandStream#5453010, kpis#5453011]
(37) ObjectHashAggregate
Input [4]: [shardId#5453006, worklistShardItemId#5453007L, qty#5453008, kpis#5453011]
Keys [2]: [shardId#5453006, worklistShardItemId#5453007L]
Functions [1]: [partial_collect_list(struct(qty, qty#5453008, kpis, kpis#5453011), 0, 0)]
Aggregate Attributes [1]: [buf#5453227]
Results [3]: [shardId#5453006, worklistShardItemId#5453007L, buf#5453228]
(38) Exchange
Input [3]: [shardId#5453006, worklistShardItemId#5453007L, buf#5453228]
Arguments: hashpartitioning(shardId#5453006, worklistShardItemId#5453007L, 30), ENSURE_REQUIREMENTS, [plan_id=2831404]
(39) ObjectHashAggregate
Input [3]: [shardId#5453006, worklistShardItemId#5453007L, buf#5453228]
Keys [2]: [shardId#5453006, worklistShardItemId#5453007L]
Functions [1]: [collect_list(struct(qty, qty#5453008, kpis, kpis#5453011), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#5453008, kpis, kpis#5453011), 0, 0)#5453005]
Results [3]: [shardId#5453006, worklistShardItemId#5453007L, map_from_entries(collect_list(struct(qty, qty#5453008, kpis, kpis#5453011), 0, 0)#5453005) AS quantityKpis#5453000]
(40) Sort [codegen id : 12]
Input [3]: [shardId#5453006, worklistShardItemId#5453007L, quantityKpis#5453000]
Arguments: [shardId#5453006 ASC NULLS FIRST, worklistShardItemId#5453007L ASC NULLS FIRST], false, 0
(41) SortMergeJoin [codegen id : 13]
Left keys [2]: [shardId#5451213, worklistShardItemId#5451799L]
Right keys [2]: [shardId#5453006, worklistShardItemId#5453007L]
Join type: LeftOuter
Join condition: None
(42) Project [codegen id : 13]
Output [31]: [shardId#5451213, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, prodLocSpecificKpis#5452984, channelStreamSpecificKpis#5452999, coalesce(quantityKpis#5453000, map(keys: [], values: [])) AS quantityKpis#5453012, arrays_zip(constraintLabels#5452261, constraintOperators#5452262, constraintValues#5452263, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#5453478]
Input [36]: [shardId#5451213, worklistShardItemId#5451799L, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, constraintValues#5452263, constraintOperators#5452262, constraintLabels#5452261, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, prodLocSpecificKpis#5452984, channelStreamSpecificKpis#5452999, shardId#5453006, worklistShardItemId#5453007L, quantityKpis#5453000]
(43) Project
Output [32]: [shardId#5451213, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, prodLocSpecificKpis#5452984, channelStreamSpecificKpis#5452999, quantityKpis#5453012, struct(minServiceLevel, array_min(filter(constraintStructArray#5453478, lambdafunction((lambda x_10778#5453485.constraintLabels = ServiceLevel), lambda x_10778#5453485, false)).constraintValues), minServiceLevelMinStock, null, maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#5453478, lambdafunction((lambda x_10779#5453486.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_10779#5453486, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#5453478, lambdafunction((lambda x_10780#5453487.constraintLabels = RangeOfCoverage), lambda x_10780#5453487, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#5452260, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#5452984, lambdafunction((lambda x_10781#5453488.label = NonListingStartTimestamp), lambda x_10781#5453488, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#5453484, CASE WHEN (qty#5451801 <=> quantityAfterProdPlantOptimization#5451800) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#5451801 * (cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453556.isOrderUnit, lambda x_10782#5453556, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453557.isOrderUnit, lambda x_10782#5453557, false)), 1, None, false).numerator as double))), qty#5451801), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453558.isOrderUnit, lambda x_10782#5453558, false)), 1, None, false).uom, orderQuantityBaseUom#5452258), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453559.isOrderUnit, lambda x_10782#5453559, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5452259), candidateOrderQuantityInBaseUnit, qty#5451801, orderQuantityBaseUom, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5452259, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10784#5453560.isPreferred AND (((qty#5451801 * cast(lambda x_10784#5453560.denominator as double)) % cast(lambda x_10784#5453560.numerator as double)) = 0.0)), lambda x_10784#5453560, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5451801 * cast(lambda x_10785#5453598.denominator as double)) / cast(lambda x_10785#5453598.numerator as double)), uom, lambda x_10785#5453598.uom, uomUuid, lambda x_10785#5453598.uomUuid), lambda x_10785#5453598, false))).inPreferredQuantity, coalesce((qty#5451801 * (cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453561.isOrderUnit, lambda x_10783#5453561, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453562.isOrderUnit, lambda x_10783#5453562, false)), 1, None, false).numerator as double))), qty#5451801)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10784#5453563.isPreferred AND (((qty#5451801 * cast(lambda x_10784#5453563.denominator as double)) % cast(lambda x_10784#5453563.numerator as double)) = 0.0)), lambda x_10784#5453563, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5451801 * cast(lambda x_10785#5453599.denominator as double)) / cast(lambda x_10785#5453599.numerator as double)), uom, lambda x_10785#5453599.uom, uomUuid, lambda x_10785#5453599.uomUuid), lambda x_10785#5453599, false))).uom, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453564.isOrderUnit, lambda x_10783#5453564, false)), 1, None, false).uom, orderQuantityBaseUom#5452258)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10784#5453565.isPreferred AND (((qty#5451801 * cast(lambda x_10784#5453565.denominator as double)) % cast(lambda x_10784#5453565.numerator as double)) = 0.0)), lambda x_10784#5453565, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5451801 * cast(lambda x_10785#5453600.denominator as double)) / cast(lambda x_10785#5453600.numerator as double)), uom, lambda x_10785#5453600.uom, uomUuid, lambda x_10785#5453600.uomUuid), lambda x_10785#5453600, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453566.isOrderUnit, lambda x_10783#5453566, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5452259)), serviceLevel, coalesce(filter(element_at(quantityKpis#5453012, qty#5451801, None, false), lambdafunction((lambda x_10790#5453567.label = ServiceLevel), lambda x_10790#5453567, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#5451801 * (cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453570.isOrderUnit, lambda x_10782#5453570, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453571.isOrderUnit, lambda x_10782#5453571, false)), 1, None, false).numerator as double))), qty#5451801), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453572.isOrderUnit, lambda x_10782#5453572, false)), 1, None, false).uom, orderQuantityBaseUom#5452258), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10782#5453573.isOrderUnit, lambda x_10782#5453573, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5452259), candidateOrderQuantityInBaseUnit, qty#5451801, orderQuantityBaseUom, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5452259, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10784#5453574.isPreferred AND (((qty#5451801 * cast(lambda x_10784#5453574.denominator as double)) % cast(lambda x_10784#5453574.numerator as double)) = 0.0)), lambda x_10784#5453574, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5451801 * cast(lambda x_10785#5453601.denominator as double)) / cast(lambda x_10785#5453601.numerator as double)), uom, lambda x_10785#5453601.uom, uomUuid, lambda x_10785#5453601.uomUuid), lambda x_10785#5453601, false))).inPreferredQuantity, coalesce((qty#5451801 * (cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453575.isOrderUnit, lambda x_10783#5453575, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453576.isOrderUnit, lambda x_10783#5453576, false)), 1, None, false).numerator as double))), qty#5451801)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10784#5453577.isPreferred AND (((qty#5451801 * cast(lambda x_10784#5453577.denominator as double)) % cast(lambda x_10784#5453577.numerator as double)) = 0.0)), lambda x_10784#5453577, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5451801 * cast(lambda x_10785#5453602.denominator as double)) / cast(lambda x_10785#5453602.numerator as double)), uom, lambda x_10785#5453602.uom, uomUuid, lambda x_10785#5453602.uomUuid), lambda x_10785#5453602, false))).uom, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453578.isOrderUnit, lambda x_10783#5453578, false)), 1, None, false).uom, orderQuantityBaseUom#5452258)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10784#5453579.isPreferred AND (((qty#5451801 * cast(lambda x_10784#5453579.denominator as double)) % cast(lambda x_10784#5453579.numerator as double)) = 0.0)), lambda x_10784#5453579, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5451801 * cast(lambda x_10785#5453603.denominator as double)) / cast(lambda x_10785#5453603.numerator as double)), uom, lambda x_10785#5453603.uom, uomUuid, lambda x_10785#5453603.uomUuid), lambda x_10785#5453603, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10783#5453580.isOrderUnit, lambda x_10783#5453580, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5452259)), serviceLevel, coalesce(filter(element_at(quantityKpis#5453012, qty#5451801, None, false), lambdafunction((lambda x_10793#5453581.label = ServiceLevel), lambda x_10793#5453581, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#5451800 * (cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10786#5453584.isOrderUnit, lambda x_10786#5453584, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10786#5453585.isOrderUnit, lambda x_10786#5453585, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#5451800), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10786#5453586.isOrderUnit, lambda x_10786#5453586, false)), 1, None, false).uom, orderQuantityBaseUom#5452258), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10786#5453587.isOrderUnit, lambda x_10786#5453587, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5452259), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#5451800, orderQuantityBaseUom, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5452259, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10788#5453588.isPreferred AND (((quantityAfterProdPlantOptimization#5451800 * cast(lambda x_10788#5453588.denominator as double)) % cast(lambda x_10788#5453588.numerator as double)) = 0.0)), lambda x_10788#5453588, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5451800 * cast(lambda x_10789#5453604.denominator as double)) / cast(lambda x_10789#5453604.numerator as double)), uom, lambda x_10789#5453604.uom, uomUuid, lambda x_10789#5453604.uomUuid), lambda x_10789#5453604, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#5451800 * (cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10787#5453589.isOrderUnit, lambda x_10787#5453589, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10787#5453590.isOrderUnit, lambda x_10787#5453590, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#5451800)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10788#5453591.isPreferred AND (((quantityAfterProdPlantOptimization#5451800 * cast(lambda x_10788#5453591.denominator as double)) % cast(lambda x_10788#5453591.numerator as double)) = 0.0)), lambda x_10788#5453591, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5451800 * cast(lambda x_10789#5453605.denominator as double)) / cast(lambda x_10789#5453605.numerator as double)), uom, lambda x_10789#5453605.uom, uomUuid, lambda x_10789#5453605.uomUuid), lambda x_10789#5453605, false))).uom, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10787#5453592.isOrderUnit, lambda x_10787#5453592, false)), 1, None, false).uom, orderQuantityBaseUom#5452258)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5452257, lambdafunction((lambda x_10788#5453593.isPreferred AND (((quantityAfterProdPlantOptimization#5451800 * cast(lambda x_10788#5453593.denominator as double)) % cast(lambda x_10788#5453593.numerator as double)) = 0.0)), lambda x_10788#5453593, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5451800 * cast(lambda x_10789#5453606.denominator as double)) / cast(lambda x_10789#5453606.numerator as double)), uom, lambda x_10789#5453606.uom, uomUuid, lambda x_10789#5453606.uomUuid), lambda x_10789#5453606, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5452257, lambdafunction(lambda x_10787#5453594.isOrderUnit, lambda x_10787#5453594, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5452259)), serviceLevel, coalesce(filter(element_at(quantityKpis#5453012, quantityAfterProdPlantOptimization#5451800, None, false), lambdafunction((lambda x_10796#5453595.label = ServiceLevel), lambda x_10796#5453595, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#5453555, coalesce(filter(prodLocSpecificKpis#5452984, lambdafunction((lambda x_10799#5453608.label = InitialStockQty), lambda x_10799#5453608, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#5453607, coalesce(filter(prodLocSpecificKpis#5452984, lambdafunction((lambda x_10800#5453610.label = DemandPeriodEndTimestamp), lambda x_10800#5453610, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#5453609]
Input [31]: [shardId#5451213, quantityAfterProdPlantOptimization#5451800, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, minimumOrderQuantity#5452260, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, prodLocSpecificKpis#5452984, channelStreamSpecificKpis#5452999, quantityKpis#5453012, constraintStructArray#5453478]
(44) Project
Output [5]: [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, struct(supplier, supplier#5452233, supplyingPlant, supplyingPlant#5452237, productGroup, productGroup#5452238, product, product#5452239, plant, plant#5452234, supplierSubRange, subrange#5452236, sourceOfSupplyUuid, sourceOfSupplyUuid#5452244, deliveryDateTime, deliveryDateTime#5452235, unitPrice, netPriceAmount#5452266, unitPriceCurrency, netPriceCurrencyCode#5452267, unitPriceQuantity, netPriceQuantity#5452268, unitPriceQuantityUom, netPriceQuantityUom#5452269, unitPriceQuantityUomUuid, ... 31 more fields) AS parentItem#5453680]
Input [32]: [shardId#5451213, qty#5451801, orderProposalId#5452230L, supplier#5452233, supplyingPlant#5452237, productGroup#5452238, product#5452239, plant#5452234, subrange#5452236, deliveryDateTime#5452235, availabilityDateTime#5452241, nextAvailabilityDateTime#5452242, logisticUnits#5452257, orderQuantityBaseUom#5452258, orderQuantityBaseUomUuid#5452259, splitIndicator#5452249L, netPriceAmount#5452266, netPriceCurrencyCode#5452267, netPriceQuantity#5452268, netPriceQuantityUom#5452269, netPriceQuantityUomUuid#5452270, sourceOfSupplyUuid#5452244, orderProposalItemGroupId#5452254, optimizationGroups#5452273, measurements#5452271, prodLocSpecificKpis#5452984, channelStreamSpecificKpis#5452999, quantityKpis#5453012, constraintBenchmark#5453484, calculationAnalysis#5453555, inventoryDateTime#5453607, demandPeriodEndDateTime#5453609]
(45) ObjectHashAggregate
Input [5]: [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, parentItem#5453680]
Keys [4]: [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254]
Functions [1]: [partial_collect_list(parentItem#5453680, 0, 0)]
Aggregate Attributes [1]: [buf#5455066]
Results [5]: [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, buf#5455074]
(46) Exchange
Input [5]: [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, buf#5455074]
Arguments: hashpartitioning(shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, 30), ENSURE_REQUIREMENTS, [plan_id=2831416]
(47) ObjectHashAggregate
Input [5]: [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254, buf#5455074]
Keys [4]: [shardId#5451213, orderProposalId#5452230L, splitIndicator#5452249L, orderProposalItemGroupId#5452254]
Functions [1]: [collect_list(parentItem#5453680, 0, 0)]
Aggregate Attributes [1]: [collect_list(parentItem#5453680, 0, 0)#5453785]
Results [3]: [shardId#5451213, orderProposalId#5452230L, collect_list(parentItem#5453680, 0, 0)#5453785 AS parentItems#5453733]
(48) ObjectHashAggregate
Input [3]: [shardId#5451213, orderProposalId#5452230L, parentItems#5453733]
Keys [2]: [shardId#5451213, orderProposalId#5452230L]
Functions [1]: [partial_collect_list(parentItems#5453733, 0, 0)]
Aggregate Attributes [1]: [buf#5455051]
Results [3]: [shardId#5451213, orderProposalId#5452230L, buf#5455059]
(49) Exchange
Input [3]: [shardId#5451213, orderProposalId#5452230L, buf#5455059]
Arguments: hashpartitioning(shardId#5451213, orderProposalId#5452230L, 30), ENSURE_REQUIREMENTS, [plan_id=2831419]
(50) ObjectHashAggregate
Input [3]: [shardId#5451213, orderProposalId#5452230L, buf#5455059]
Keys [2]: [shardId#5451213, orderProposalId#5452230L]
Functions [1]: [collect_list(parentItems#5453733, 0, 0)]
Aggregate Attributes [1]: [collect_list(parentItems#5453733, 0, 0)#5453817]
Results [2]: [shardId#5451213, CASE WHEN (size(flatten(collect_list(parentItems#5453733, 0, 0)#5453817), true) > 2000) THEN xxhash64(orderProposalId#5452230L, 42) ELSE xxhash64(pmod(cast(orderProposalId#5452230L as decimal(20,0)), 0), 42) END AS resultSeparationId#5456938L]
(51) HashAggregate [codegen id : 14]
Input [2]: [shardId#5451213, resultSeparationId#5456938L]
Keys [2]: [shardId#5451213, resultSeparationId#5456938L]
Functions: []
Aggregate Attributes: []
Results [2]: [shardId#5451213, resultSeparationId#5456938L]
(52) Exchange
Input [2]: [shardId#5451213, resultSeparationId#5456938L]
Arguments: hashpartitioning(shardId#5451213, resultSeparationId#5456938L, 30), ENSURE_REQUIREMENTS, [plan_id=2831424]
(53) HashAggregate [codegen id : 15]
Input [2]: [shardId#5451213, resultSeparationId#5456938L]
Keys [2]: [shardId#5451213, resultSeparationId#5456938L]
Functions: []
Aggregate Attributes: []
Results [2]: [shardId#5451213, resultSeparationId#5456938L]
(54) Exchange
Input [2]: [shardId#5451213, resultSeparationId#5456938L]
Arguments: SinglePartition, REPARTITION_BY_NUM, [plan_id=2831428]
(55) Project [codegen id : 16]
Output: []
Input [2]: [shardId#5451213, resultSeparationId#5456938L]
(56) CollectLimit
Input: []
Arguments: 1