digraph G {
subgraph cluster0 {
isCluster="true";
id="cluster0";
label="WholeStageCodegen (2)\n \nduration: 2 ms";
tooltip="WholeStageCodegen (2)";
1 [id="node1" labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 2 ms<br>number of output rows: 1" tooltip="HashAggregate(keys=[], functions=[count(1)])"];
}
2 [id="node2" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 30<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 30<br>local bytes read: 1080.0 B<br>merged fetch fallback count: 0<br>local blocks read: 15<br>remote merged chunks fetched: 0<br>remote blocks read: 15<br>data size total (min, med, max (stageId: taskId))<br>480.0 B (16.0 B, 16.0 B, 16.0 B (stage 1311650.0: task 2446100))<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 1311650.0: task 2446098))<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: 1080.0 B<br>number of partitions: 1<br>remote reqs duration: 3 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>2.1 KiB (72.0 B, 72.0 B, 72.0 B (stage 1311650.0: task 2446100))" tooltip="Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=2854215]"];
subgraph cluster3 {
isCluster="true";
id="cluster3";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n20 ms (0 ms, 0 ms, 3 ms (stage 1311650.0: task 2446111))";
tooltip="WholeStageCodegen (1)";
4 [id="node4" labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build total (min, med, max (stageId: taskId))<br>11 ms (0 ms, 0 ms, 3 ms (stage 1311650.0: task 2446111))<br>number of output rows: 30" tooltip="HashAggregate(keys=[], functions=[partial_count(1)])"];
5 [id="node5" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project"];
6 [id="node6" labelType="html" label="<b>Generate</b><br><br>number of output rows: 0" tooltip="Generate explode(_extract_deliveryDateTime#5502722), false, [numberOfOrderProposalItems#5502694]"];
}
7 [id="node7" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposal#5501319.parentItems.deliveryDateTime AS _extract_deliveryDateTime#5502722]"];
8 [id="node8" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (size(orderProposal#5501319.parentItems.deliveryDateTime, true) > 0)"];
9 [id="node9" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [orderProposal#5501319], [(size(orderProposal#5501319.parentItems.deliveryDateTime, true) > 0)]"];
10 [id="node10" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, named_struct(orderProposalId, _extract_orderProposalId#5501967L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#5501959L, supplierGroup, _extract_supplierGroup#5501960, optimizationGroups, coalesce(optimizationGroups#5501212, []), supplier, _extract_supplier#5501961, supplyingPlant, _extract_supplyingPlant#5501962, orderDateTime, _extract_orderDateTime#5501963, itemGroups, _extract_itemGroups#5501964, previousOrderProposals, _extract_previousOrderProposals#5501965, parentItems, _extract_parentItems#5501966) AS orderProposal#5501319]"];
11 [id="node11" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 0" tooltip="BroadcastHashJoin [coalesce(shardId#5499000, ), isnull(shardId#5499000), coalesce(_extract_orderProposalId#5501967L, 0), isnull(_extract_orderProposalId#5501967L)], [coalesce(shardId#5501215, ), isnull(shardId#5501215), coalesce(orderProposalId#5501216L, 0), isnull(orderProposalId#5501216L)], LeftOuter, BuildRight, false"];
12 [id="node12" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, orderProposal#5501202.orderProposalId AS _extract_orderProposalId#5501958L, orderProposal#5501202.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#5501959L, orderProposal#5501202.supplierGroup AS _extract_supplierGroup#5501960, orderProposal#5501202.supplier AS _extract_supplier#5501961, orderProposal#5501202.supplyingPlant AS _extract_supplyingPlant#5501962, orderProposal#5501202.orderDateTime AS _extract_orderDateTime#5501963, orderProposal#5501202.itemGroups AS _extract_itemGroups#5501964, orderProposal#5501202.previousOrderProposals AS _extract_previousOrderProposals#5501965, orderProposal#5501202.parentItems AS _extract_parentItems#5501966, orderProposal#5501202.orderProposalId AS _extract_orderProposalId#5501967L]"];
13 [id="node13" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, struct(orderProposalId, orderProposalId#5499670L, originalReplenishmentRunId, originalReplenishmentRunId#5501170L, supplierGroup, supplierGroup#5501171, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#5501171) THEN supplier#5501172 END, supplyingPlant, supplyingPlant#5501173, orderDateTime, orderDateTime#5501174, itemGroups, itemGroups#5501175, previousOrderProposals, array_distinct(previousOrderProposals#5501177), parentItems, parentItems#5501176) AS orderProposal#5501202]"];
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>0 ms (0 ms, 0 ms, 0 ms (stage 1311650.0: task 2446100))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5499000, orderProposalId#5499670L], functions=[max(originalReplenishmentRunId#5501108L), max(supplierGroup#5501109), max(supplier#5501110), max(supplyingPlant#5501111), max(orderDateTime#5501112), collect_list(itemGroup#5501169, 0, 0), collect_list(parentItems#5501113, 0, 0), collect_set(previousOrderProposals#5501115, 0, 0)])"];
15 [id="node15" 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#5499000, orderProposalId#5499670L, 30), ENSURE_REQUIREMENTS, [plan_id=2854074]"];
16 [id="node16" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1311649.0: task 2446072))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5499000, orderProposalId#5499670L], functions=[partial_max(originalReplenishmentRunId#5501108L), partial_max(supplierGroup#5501109), partial_max(supplier#5501110), partial_max(supplyingPlant#5501111), partial_max(orderDateTime#5501112), partial_collect_list(itemGroup#5501169, 0, 0), partial_collect_list(parentItems#5501113, 0, 0), partial_collect_set(previousOrderProposals#5501115, 0, 0)])"];
17 [id="node17" 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 1311649.0: task 2446072))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672], functions=[max(originalReplenishmentRunId#5499673L), max(supplierGroup#5499680), max(supplier#5499681), max(supplyingPlant#5499711), max(orderDateTime#5499688), collect_list(parentItem#5501060, 0, 0), collect_set(previousOrderProposal#5499676L, 0, 0), collect_list(item#5501091, 0, 0)])"];
18 [id="node18" 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#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672, 30), ENSURE_REQUIREMENTS, [plan_id=2854071]"];
19 [id="node19" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 0<br>time in aggregation build total (min, med, max (stageId: taskId))<br>20 ms (0 ms, 0 ms, 3 ms (stage 1311648.0: task 2446050))<br>spill size: 0.0 B<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672], functions=[partial_max(originalReplenishmentRunId#5499673L), partial_max(supplierGroup#5499680), partial_max(supplier#5499681), partial_max(supplyingPlant#5499711), partial_max(orderDateTime#5499688), partial_collect_list(parentItem#5501060, 0, 0), partial_collect_set(previousOrderProposal#5499676L, 0, 0), partial_collect_list(item#5501091, 0, 0)])"];
20 [id="node20" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, orderDateTime#5499688, splitIndicator#5499675L, orderProposalItemGroupId#5499672, previousOrderProposal#5499676L, parentItem#5501060, struct(itemId, orderProposalItemId#5499671, supplier, supplier#5499681, supplyingPlant, supplyingPlant#5499711, productGroup, productGroup#5499712, product, product#5499683, plant, plant#5499684, supplierSubRange, subrange#5499682, deliveryDateTime, deliveryDateTime#5499689, orderQuantity, coalesce((qty#5499514 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501094.isOrderUnit, lambda x_10901#5501094, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501095.isOrderUnit, lambda x_10901#5501095, false)), 1, None, false).numerator as double))), qty#5499514), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501096.isOrderUnit, lambda x_10901#5501096, false)), 1, None, false).uom, orderQuantityBaseUom#5499693), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501097.isOrderUnit, lambda x_10901#5501097, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694), orderQuantityInBaseUnit, qty#5499514, orderQuantityBaseUom, ... 13 more fields) AS item#5501091]"];
21 [id="node21" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, previousOrderProposal#5499676L, struct(supplier, supplier#5499681, supplyingPlant, supplyingPlant#5499711, productGroup, productGroup#5499712, product, product#5499683, plant, plant#5499684, supplierSubRange, subrange#5499682, sourceOfSupplyUuid, sourceOfSupplyUuid#5499679, deliveryDateTime, deliveryDateTime#5499689, unitPrice, netPriceAmount#5499698, unitPriceCurrency, netPriceCurrencyCode#5499699, unitPriceQuantity, netPriceQuantity#5499695, unitPriceQuantityUom, netPriceQuantityUom#5499696, unitPriceQuantityUomUuid, ... 31 more fields) AS parentItem#5501060]"];
22 [id="node22" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, sourceOfSupplyUuid#5499679, ... 12 more fields]"];
subgraph cluster23 {
isCluster="true";
id="cluster23";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n3.7 s (30 ms, 139 ms, 352 ms (stage 1311648.0: task 2446050))";
tooltip="WholeStageCodegen (1)";
24 [id="node24" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, ... 11 more fields]"];
25 [id="node25" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter NOT (isFallbackOrderOnly#5499692 <=> true)"];
}
26 [id="node26" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 29" tooltip="InMemoryTableScan [availabilityDateTime#5499690, channelStreamSpecificKpis#5500431, constraintLabels#5499702, constraintOperators#5499703, constraintValues#5499705, deliveryDateTime#5499689, isFallbackOrderOnly#5499692, logisticUnits#5499707, measurements#5499700, minimumOrderQuantity#5499701, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, nextAvailabilityDateTime#5499691, optimizationGroups#5499708, orderDateTime#5499688, orderProposalId#5499670L, orderProposalItemGroupId#5499672, orderProposalItemId#5499671, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, originalReplenishmentRunId#5499673L, plant#5499684, ... 14 more fields], [NOT (isFallbackOrderOnly#5499692 <=> true)]"];
subgraph cluster27 {
isCluster="true";
id="cluster27";
label="WholeStageCodegen (13)\n \nduration: total (min, med, max (stageId: taskId))\n285 ms (2 ms, 4 ms, 28 ms (stage 1311648.0: task 2446041))";
tooltip="WholeStageCodegen (13)";
28 [id="node28" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, ... 17 more fields]"];
29 [id="node29" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 29<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446051))" tooltip="SortMergeJoin [shardId#5499000, worklistShardItemId#5499512L], [shardId#5500438, worklistShardItemId#5500439L], LeftOuter"];
}
subgraph cluster30 {
isCluster="true";
id="cluster30";
label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n2.4 s (6 ms, 49 ms, 196 ms (stage 1311648.0: task 2446050))";
tooltip="WholeStageCodegen (10)";
31 [id="node31" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, ... 16 more fields]"];
32 [id="node32" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 29<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446051))" tooltip="SortMergeJoin [shardId#5499000, worklistShardItemId#5499512L], [shardId#5500425, worklistShardItemId#5500426L], LeftOuter"];
}
subgraph cluster33 {
isCluster="true";
id="cluster33";
label="WholeStageCodegen (7)\n \nduration: total (min, med, max (stageId: taskId))\n4.5 s (10 ms, 92 ms, 368 ms (stage 1311648.0: task 2446050))";
tooltip="WholeStageCodegen (7)";
34 [id="node34" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, ... 15 more fields]"];
35 [id="node35" labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 29<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446051))" tooltip="SortMergeJoin [shardId#5499000, worklistShardItemId#5499512L], [shardId#5500409, worklistShardItemId#5500410L], LeftOuter"];
}
subgraph cluster36 {
isCluster="true";
id="cluster36";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n6.9 s (11 ms, 135 ms, 687 ms (stage 1311648.0: task 2446050))";
tooltip="WholeStageCodegen (4)";
37 [id="node37" 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 1311648.0: task 2446051))<br>peak memory total (min, med, max (stageId: taskId))<br>41.9 MiB (64.0 KiB, 2.1 MiB, 2.1 MiB (stage 1311648.0: task 2446041))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446051))" tooltip="Sort [shardId#5499000 ASC NULLS FIRST, worklistShardItemId#5499512L ASC NULLS FIRST], false, 0"];
}
38 [id="node38" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 29<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 29<br>local bytes read total (min, med, max (stageId: taskId))<br>21.1 KiB (860.0 B, 883.0 B, 2.0 KiB (stage 1311648.0: task 2446040))<br>merged fetch fallback count: 0<br>local blocks read: 20<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 35.7 KiB<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 1 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 total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1311648.0: task 2446041))<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: 21.1 KiB" tooltip="Exchange hashpartitioning(shardId#5499000, worklistShardItemId#5499512L, 30), ENSURE_REQUIREMENTS, [plan_id=2853804]"];
subgraph cluster39 {
isCluster="true";
id="cluster39";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n13 ms (0 ms, 0 ms, 4 ms (stage 1311646.0: task 2445934))";
tooltip="WholeStageCodegen (3)";
40 [id="node40" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, ... 14 more fields]"];
41 [id="node41" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 29" tooltip="BroadcastHashJoin [worklistShardItemId#5499512L], [worklistShardItemId#5499736L], LeftOuter, BuildRight, (shardId#5499000 = 0_1_10000001445), false"];
42 [id="node42" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5499000, item#5499511.worklistShardItemId AS worklistShardItemId#5499512L, item#5499511.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5499513, item#5499511.qty AS qty#5499514]"];
43 [id="node43" labelType="html" label="<b>Generate</b><br><br>number of output rows: 29" tooltip="Generate explode(items#5499002), [shardId#5499000], false, [item#5499511]"];
44 [id="node44" labelType="html" label="<b>Filter</b><br><br>number of output rows: 2" tooltip="Filter ((size(items#5499002, true) > 0) AND isnotnull(items#5499002))"];
}
45 [id="node45" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 2" tooltip="InMemoryTableScan [shardId#5499000, items#5499002], [(size(items#5499002, true) > 0), isnotnull(items#5499002)]"];
subgraph cluster46 {
isCluster="true";
id="cluster46";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
47 [id="node47" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))"];
}
48 [id="node48" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006], [isnotnull(shardId#5499000), (shardId#5499000 = 0_1_10000001445)]"];
subgraph cluster49 {
isCluster="true";
id="cluster49";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
50 [id="node50" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))"];
51 [id="node51" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#5499000,orderProposalId#5499001L,items#5499002,optimizationGroups#5499003,isOptimal#5499004,lastModified#5499005,optimizationInsights#5499006]"];
}
52 [id="node52" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 401 ms<br>number of output rows: 29<br>data size: 1030.4 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2853799]"];
subgraph cluster53 {
isCluster="true";
id="cluster53";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n24 ms (0 ms, 0 ms, 3 ms (stage 1311544.0: task 2445902))";
tooltip="WholeStageCodegen (2)";
54 [id="node54" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#5499736L, orderProposalId#5499713L, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, originalReplenishmentRunId#5499755L, splitIndicator#5499732L, previousOrderProposal#5499733L, sourceOfSupplyUuid#5499727, supplierGroup#5499715, supplier#5499716, subrange#5499719, product#5499722, plant#5499717, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, isFallbackOrderOnly#5499730, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, netPriceAmount#5499749, netPriceCurrencyCode#5499750, ... 11 more fields]"];
}
55 [id="node55" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 29<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 29<br>local bytes read total (min, med, max (stageId: taskId))<br>18.4 KiB (830.0 B, 855.0 B, 1712.0 B (stage 1311544.0: task 2445898))<br>merged fetch fallback count: 0<br>local blocks read: 21<br>remote merged chunks fetched: 0<br>remote blocks read: 6<br>data size total (min, med, max (stageId: taskId))<br>34.5 KiB (1168.0 B, 2.3 KiB, 3.7 KiB (stage 1311543.0: task 2445871))<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>8 ms (0 ms, 0 ms, 0 ms (stage 1311543.0: task 2445884))<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 1311544.0: task 2445888))<br>remote bytes read total (min, med, max (stageId: taskId))<br>5.7 KiB (861.0 B, 1710.0 B, 2.2 KiB (stage 1311544.0: task 2445893))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>12 ms (2 ms, 3 ms, 5 ms (stage 1311544.0: task 2445893))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>24.2 KiB (850.0 B, 1194.0 B, 2.7 KiB (stage 1311543.0: task 2445871))" tooltip="Exchange hashpartitioning(worklistShardItemId#5499736L, 30), REPARTITION_BY_NUM, [plan_id=2853795]"];
subgraph cluster56 {
isCluster="true";
id="cluster56";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n2.4 s (88 ms, 132 ms, 193 ms (stage 1311543.0: task 2445881))";
tooltip="WholeStageCodegen (1)";
57 [id="node57" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, ... 11 more fields]"];
58 [id="node58" labelType="html" label="<b>Filter</b><br><br>number of output rows: 29" tooltip="Filter isnotnull(worklistShardItemId#5499736L)"];
59 [id="node59" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 29<br>number of input batches: 17" tooltip="ColumnarToRow"];
}
60 [id="node60" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 17<br>scan time total (min, med, max (stageId: taskId))<br>1.8 s (87 ms, 104 ms, 120 ms (stage 1311543.0: task 2445876))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 319.0 KiB<br>number of output rows: 29<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#5499713L,orderProposalItemId#5499714,supplierGroup#5499715,supplier#5499716,plant#5499717,deliveryDateTime#5499718,subrange#5499719,supplyingPlant#5499720,productGroup#5499721,product#5499722,orderDateTime#5499723,availabilityDateTime#5499724,nextAvailabilityDateTime#5499725,sourceOfSupplyUuid#5499727,isFallbackOrderOnly#5499730,splitIndicator#5499732L,previousOrderProposal#5499733L,worklistShardItemId#5499736L,orderProposalItemGroupId#5499737,externalProductId#5499738,externalPlantId#5499739,logisticUnits#5499740,orderQuantityBaseUom#5499741,orderQuantityBaseUomUuid#5499742,minimumOrderQuantity#5499743,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#5499736L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5499757), isnotnull(sequenceId#5499735), (shardId#5499757 = 0_1_10000001445), ..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,pla..."];
subgraph cluster61 {
isCluster="true";
id="cluster61";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n1.2 s (4 ms, 7 ms, 213 ms (stage 1311648.0: task 2446041))";
tooltip="WholeStageCodegen (6)";
62 [id="node62" 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 1311648.0: task 2446041))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1311648.0: task 2446041))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446041))" tooltip="Sort [shardId#5500409 ASC NULLS FIRST, worklistShardItemId#5500410L ASC NULLS FIRST], false, 0"];
}
63 [id="node63" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 29<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 29<br>local bytes read total (min, med, max (stageId: taskId))<br>7.2 KiB (593.0 B, 669.0 B, 1369.0 B (stage 1311648.0: task 2446040))<br>merged fetch fallback count: 0<br>local blocks read: 11<br>remote merged chunks fetched: 0<br>remote blocks read: 18<br>data size total (min, med, max (stageId: taskId))<br>33.5 KiB (1184.0 B, 1184.0 B, 4.6 KiB (stage 1311644.0: task 2445927))<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>8 ms (0 ms, 0 ms, 0 ms (stage 1311644.0: task 2446028))<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 1311648.0: task 2446041))<br>remote bytes read total (min, med, max (stageId: taskId))<br>11.4 KiB (593.0 B, 671.0 B, 1264.0 B (stage 1311648.0: task 2446041))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>36 ms (0 ms, 1 ms, 28 ms (stage 1311648.0: task 2446064))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>18.5 KiB (593.0 B, 671.0 B, 2.6 KiB (stage 1311644.0: task 2445927))" tooltip="Exchange hashpartitioning(shardId#5500409, worklistShardItemId#5500410L, 30), ENSURE_REQUIREMENTS, [plan_id=2853810]"];
subgraph cluster64 {
isCluster="true";
id="cluster64";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n842 ms (2 ms, 4 ms, 152 ms (stage 1311644.0: task 2445932))";
tooltip="WholeStageCodegen (5)";
65 [id="node65" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5500409, worklistShardItemId#5500410L, coalesce(kpis#5500414, []) AS prodLocSpecificKpis#5500415]"];
66 [id="node66" labelType="html" label="<b>Filter</b><br><br>number of output rows: 29" tooltip="Filter (((isnull(qty#5500411) AND isnull(demandChannel#5500412)) AND isnull(demandStream#5500413)) AND (isnotnull(shardId#5500409) AND isnotnull(worklistShardItemId#5500410L)))"];
67 [id="node67" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 402" tooltip="Scan ExistingRDD[shardId#5500409,worklistShardItemId#5500410L,qty#5500411,demandChannel#5500412,demandStream#5500413,kpis#5500414]"];
}
subgraph cluster68 {
isCluster="true";
id="cluster68";
label="WholeStageCodegen (9)\n \nduration: total (min, med, max (stageId: taskId))\n778 ms (2 ms, 5 ms, 128 ms (stage 1311648.0: task 2446042))";
tooltip="WholeStageCodegen (9)";
69 [id="node69" 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 1311648.0: task 2446041))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1311648.0: task 2446041))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446041))" tooltip="Sort [shardId#5500425 ASC NULLS FIRST, worklistShardItemId#5500426L ASC NULLS FIRST], false, 0"];
}
70 [id="node70" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 29<br>time in aggregation build total (min, med, max (stageId: taskId))<br>139 ms (0 ms, 1 ms, 24 ms (stage 1311648.0: task 2446041))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446041))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5500425, worklistShardItemId#5500426L], functions=[collect_list(struct(demandChannel, demandChannel#5500428, demandStream, demandStream#5500429, kpis, kpis#5500430), 0, 0)])"];
71 [id="node71" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 45<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 45<br>local bytes read total (min, med, max (stageId: taskId))<br>4.9 KiB (327.0 B, 342.0 B, 1001.0 B (stage 1311648.0: task 2446060))<br>merged fetch fallback count: 0<br>local blocks read: 15<br>remote merged chunks fetched: 0<br>remote blocks read: 30<br>data size total (min, med, max (stageId: taskId))<br>18.3 KiB (408.0 B, 816.0 B, 1632.0 B (stage 1311645.0: task 2445972))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>13 ms (0 ms, 0 ms, 0 ms (stage 1311645.0: task 2445984))<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, 1 ms (stage 1311648.0: task 2446041))<br>remote bytes read total (min, med, max (stageId: taskId))<br>9.7 KiB (319.0 B, 646.0 B, 1007.0 B (stage 1311648.0: task 2446040))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>10 ms (0 ms, 1 ms, 1 ms (stage 1311648.0: task 2446041))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>14.6 KiB (319.0 B, 646.0 B, 1307.0 B (stage 1311645.0: task 2445972))" tooltip="Exchange hashpartitioning(shardId#5500425, worklistShardItemId#5500426L, 30), ENSURE_REQUIREMENTS, [plan_id=2853821]"];
72 [id="node72" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 45<br>time in aggregation build total (min, med, max (stageId: taskId))<br>182 ms (3 ms, 3 ms, 39 ms (stage 1311645.0: task 2445939))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311645.0: task 2445933))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5500425, worklistShardItemId#5500426L], functions=[partial_collect_list(struct(demandChannel, demandChannel#5500428, demandStream, demandStream#5500429, kpis, kpis#5500430), 0, 0)])"];
subgraph cluster73 {
isCluster="true";
id="cluster73";
label="WholeStageCodegen (8)\n \nduration: total (min, med, max (stageId: taskId))\n182 ms (3 ms, 3 ms, 39 ms (stage 1311645.0: task 2445939))";
tooltip="WholeStageCodegen (8)";
74 [id="node74" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5500425, worklistShardItemId#5500426L, demandChannel#5500428, demandStream#5500429, kpis#5500430]"];
75 [id="node75" labelType="html" label="<b>Filter</b><br><br>number of output rows: 46" tooltip="Filter ((((isnull(qty#5500427) AND isnotnull(demandChannel#5500428)) AND isnotnull(demandStream#5500429)) AND (size(kpis#5500430, true) > 0)) AND (isnotnull(shardId#5500425) AND isnotnull(worklistShardItemId#5500426L)))"];
76 [id="node76" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 402" tooltip="Scan ExistingRDD[shardId#5500425,worklistShardItemId#5500426L,qty#5500427,demandChannel#5500428,demandStream#5500429,kpis#5500430]"];
}
subgraph cluster77 {
isCluster="true";
id="cluster77";
label="WholeStageCodegen (12)\n \nduration: total (min, med, max (stageId: taskId))\n241 ms (0 ms, 1 ms, 48 ms (stage 1311648.0: task 2446042))";
tooltip="WholeStageCodegen (12)";
78 [id="node78" 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 1311648.0: task 2446041))<br>peak memory total (min, med, max (stageId: taskId))<br>41.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1311648.0: task 2446041))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446041))" tooltip="Sort [shardId#5500438 ASC NULLS FIRST, worklistShardItemId#5500439L ASC NULLS FIRST], false, 0"];
}
79 [id="node79" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 29<br>time in aggregation build total (min, med, max (stageId: taskId))<br>236 ms (0 ms, 2 ms, 28 ms (stage 1311648.0: task 2446065))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311648.0: task 2446041))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5500438, worklistShardItemId#5500439L], functions=[collect_list(struct(qty, qty#5500440, kpis, kpis#5500443), 0, 0)])"];
80 [id="node80" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 259<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 259<br>local bytes read total (min, med, max (stageId: taskId))<br>69.4 KiB (606.0 B, 3.0 KiB, 9.7 KiB (stage 1311648.0: task 2446040))<br>merged fetch fallback count: 0<br>local blocks read: 107<br>remote merged chunks fetched: 0<br>remote blocks read: 117<br>data size total (min, med, max (stageId: taskId))<br>311.5 KiB (4.8 KiB, 10.4 KiB, 15.2 KiB (stage 1311647.0: task 2445995))<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, 0 ms, 1 ms (stage 1311647.0: task 2446011))<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 1311648.0: task 2446039))<br>remote bytes read total (min, med, max (stageId: taskId))<br>77.3 KiB (606.0 B, 2.5 KiB, 9.7 KiB (stage 1311648.0: task 2446060))<br>number of partitions: 30<br>remote reqs duration total (min, med, max (stageId: taskId))<br>89 ms (0 ms, 1 ms, 26 ms (stage 1311648.0: task 2446063))<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>146.8 KiB (3.1 KiB, 4.8 KiB, 7.2 KiB (stage 1311647.0: task 2445995))" tooltip="Exchange hashpartitioning(shardId#5500438, worklistShardItemId#5500439L, 30), ENSURE_REQUIREMENTS, [plan_id=2853833]"];
81 [id="node81" labelType="html" label="<b>ObjectHashAggregate</b><br><br>number of output rows: 259<br>time in aggregation build total (min, med, max (stageId: taskId))<br>159 ms (2 ms, 3 ms, 36 ms (stage 1311647.0: task 2445941))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1311647.0: task 2445935))<br>number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#5500438, worklistShardItemId#5500439L], functions=[partial_collect_list(struct(qty, qty#5500440, kpis, kpis#5500443), 0, 0)])"];
subgraph cluster82 {
isCluster="true";
id="cluster82";
label="WholeStageCodegen (11)\n \nduration: total (min, med, max (stageId: taskId))\n159 ms (2 ms, 3 ms, 36 ms (stage 1311647.0: task 2445941))";
tooltip="WholeStageCodegen (11)";
83 [id="node83" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [shardId#5500438, worklistShardItemId#5500439L, qty#5500440, kpis#5500443]"];
84 [id="node84" labelType="html" label="<b>Filter</b><br><br>number of output rows: 327" tooltip="Filter ((isnotnull(qty#5500440) AND isnotnull(kpis#5500443)) AND (isnotnull(shardId#5500438) AND isnotnull(worklistShardItemId#5500439L)))"];
85 [id="node85" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 402" tooltip="Scan ExistingRDD[shardId#5500438,worklistShardItemId#5500439L,qty#5500440,demandChannel#5500441,demandStream#5500442,kpis#5500443]"];
}
86 [id="node86" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 1.1 s<br>number of output rows: 0<br>data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[0, bigint, true], 0), isnull(input[0, bigint, true])),false), [plan_id=2854109]"];
87 [id="node87" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#5501216L, shardId#5501215, coalesce(transform(optimizationGroups#5501218, lambdafunction(struct(optGroupId, lambda x_10905#5501213.optGroupId, minOrderProfile, lambda x_10905#5501213.minOrderProfile, assignmentDetails, lambda x_10905#5501213.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_10905#5501213.minOrderGoal.dimensionType, unit, lambda x_10905#5501213.minOrderGoal.unit, unitUuid, lambda x_10905#5501213.minOrderGoal.unitUuid, goalValue, lambda x_10905#5501213.minOrderGoal.minOrderValue, calcValue, lambda x_10905#5501213.minOrderGoal.calculatedOrderValue)), lambda x_10905#5501213, false)), []) AS optimizationGroups#5501212]"];
subgraph cluster88 {
isCluster="true";
id="cluster88";
label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n740 ms (1 ms, 23 ms, 95 ms (stage 1311542.0: task 2445843))";
tooltip="WholeStageCodegen (6)";
89 [id="node89" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 0" tooltip="BroadcastHashJoin [orderProposalId#5501216L], [orderProposalId#5501271L], Inner, BuildLeft, false"];
100 [id="node100" 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>13 ms (0 ms, 0 ms, 4 ms (stage 1311542.0: task 2445849))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1311542.0: task 2445845))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#5501271L], functions=[])"];
}
90 [id="node90" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 4 ms<br>time to collect: 255 ms<br>number of output rows: 2<br>data size: 1024.1 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=2854081]"];
subgraph cluster91 {
isCluster="true";
id="cluster91";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n16 ms (0 ms, 0 ms, 3 ms (stage 1311538.0: task 2445742))";
tooltip="WholeStageCodegen (2)";
92 [id="node92" labelType="html" label="<b>Filter</b><br><br>number of output rows: 2" tooltip="Filter isnotnull(orderProposalId#5501216L)"];
}
93 [id="node93" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 2" tooltip="InMemoryTableScan [shardId#5501215, orderProposalId#5501216L, optimizationGroups#5501218], [isnotnull(orderProposalId#5501216L)]"];
subgraph cluster94 {
isCluster="true";
id="cluster94";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
95 [id="node95" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))"];
}
96 [id="node96" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006], [isnotnull(shardId#5499000), (shardId#5499000 = 0_1_10000001445)]"];
subgraph cluster97 {
isCluster="true";
id="cluster97";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
98 [id="node98" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))"];
99 [id="node99" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#5499000,orderProposalId#5499001L,items#5499002,optimizationGroups#5499003,isOptimal#5499004,lastModified#5499005,optimizationInsights#5499006]"];
}
101 [id="node101" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(orderProposalId#5501271L, 30), ENSURE_REQUIREMENTS, [plan_id=2854103]"];
subgraph cluster102 {
isCluster="true";
id="cluster102";
label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n850 ms (0 ms, 6 ms, 156 ms (stage 1311541.0: task 2445816))";
tooltip="WholeStageCodegen (5)";
103 [id="node103" 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>10 ms (0 ms, 0 ms, 4 ms (stage 1311541.0: task 2445813))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1311541.0: task 2445814))<br>number of output rows: 0<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#5501271L], functions=[])"];
104 [id="node104" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#5501271L]"];
105 [id="node105" labelType="html" label="<b>BroadcastHashJoin</b><br><br>number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#5501223L], [worklistShardItemId#5501294L], Inner, BuildLeft, false"];
119 [id="node119" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [worklistShardItemId#5501294L, orderProposalId#5501271L]"];
}
106 [id="node106" labelType="html" label="<b>BroadcastExchange</b><br><br>time to broadcast: 0 ms<br>time to build: 0 ms<br>time to collect: 154 ms<br>number of output rows: 29<br>data size: 1030.4 KiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2854089]"];
subgraph cluster107 {
isCluster="true";
id="cluster107";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n0 ms (0 ms, 0 ms, 0 ms (stage 1311539.0: task 2445753))";
tooltip="WholeStageCodegen (3)";
108 [id="node108" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [item#5501222L AS worklistShardItemId#5501223L]"];
109 [id="node109" labelType="html" label="<b>Generate</b><br><br>number of output rows: 29" tooltip="Generate explode(_extract_worklistShardItemId#5501863), false, [item#5501222L]"];
110 [id="node110" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [items#5500853.worklistShardItemId AS _extract_worklistShardItemId#5501863]"];
111 [id="node111" labelType="html" label="<b>Filter</b><br><br>number of output rows: 2" tooltip="Filter (((size(items#5500853.worklistShardItemId, true) > 0) AND isnotnull(items#5500853.worklistShardItemId)) AND (shardId#5500851 = 0_1_10000001445))"];
}
112 [id="node112" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 2" tooltip="InMemoryTableScan [items#5500853, shardId#5500851], [(size(items#5500853.worklistShardItemId, true) > 0), isnotnull(items#5500853.worklistShardItemId), (shardId#5500851 = 0_1_10000001445)]"];
subgraph cluster113 {
isCluster="true";
id="cluster113";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
114 [id="node114" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))"];
}
115 [id="node115" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 0" tooltip="InMemoryTableScan [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006], [isnotnull(shardId#5499000), (shardId#5499000 = 0_1_10000001445)]"];
subgraph cluster116 {
isCluster="true";
id="cluster116";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
tooltip="WholeStageCodegen (1)";
117 [id="node117" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))"];
118 [id="node118" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 0" tooltip="Scan ExistingRDD[shardId#5499000,orderProposalId#5499001L,items#5499002,optimizationGroups#5499003,isOptimal#5499004,lastModified#5499005,optimizationInsights#5499006]"];
}
120 [id="node120" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 0<br>local bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 0<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 0.0 B<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#5501294L, 30), REPARTITION_BY_NUM, [plan_id=2854096]"];
subgraph cluster121 {
isCluster="true";
id="cluster121";
label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n1.4 s (57 ms, 77 ms, 106 ms (stage 1311540.0: task 2445795))";
tooltip="WholeStageCodegen (4)";
122 [id="node122" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [orderProposalId#5501271L, worklistShardItemId#5501294L]"];
123 [id="node123" labelType="html" label="<b>Filter</b><br><br>number of output rows: 0" tooltip="Filter ((isnotnull(worklistShardItemId#5501294L) AND NOT (isFallbackOrderOnly#5501288 <=> true)) AND isnotnull(orderProposalId#5501271L))"];
124 [id="node124" labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 0<br>number of input batches: 0" tooltip="ColumnarToRow"];
}
125 [id="node125" labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 17<br>scan time total (min, med, max (stageId: taskId))<br>1.3 s (57 ms, 76 ms, 102 ms (stage 1311540.0: task 2445806))<br>dynamic partition pruning time: 0 ms<br>metadata time: 0 ms<br>size of files read: 319.0 KiB<br>number of output rows: 0<br>number of partitions read: 1" tooltip="FileScan parquet [orderProposalId#5501271L,isFallbackOrderOnly#5501288,worklistShardItemId#5501294L,shardId#5501315,sequenceId#5501293] Batched: true, DataFilters: [isnotnull(worklistShardItemId#5501294L), NOT (isFallbackOrderOnly#5501288 <=> true), isnotnull(o..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#5501315), isnotnull(sequenceId#5501293), (shardId#5501315 = 0_1_10000001445), ..., PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderPro..., ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>"];
2->1;
4->2;
5->4;
6->5;
7->6;
8->7;
9->8;
10->9;
11->10;
12->11;
13->12;
14->13;
15->14;
16->15;
17->16;
18->17;
19->18;
20->19;
21->20;
22->21;
24->22;
25->24;
26->25;
28->26;
29->28;
31->29;
32->31;
34->32;
35->34;
37->35;
38->37;
40->38;
41->40;
42->41;
43->42;
44->43;
45->44;
47->45;
48->47;
50->48;
51->50;
52->41;
54->52;
55->54;
57->55;
58->57;
59->58;
60->59;
62->35;
63->62;
65->63;
66->65;
67->66;
69->32;
70->69;
71->70;
72->71;
74->72;
75->74;
76->75;
78->29;
79->78;
80->79;
81->80;
83->81;
84->83;
85->84;
86->11;
87->86;
89->87;
90->89;
92->90;
93->92;
95->93;
96->95;
98->96;
99->98;
100->89;
101->100;
103->101;
104->103;
105->104;
106->105;
108->106;
109->108;
110->109;
111->110;
112->111;
114->112;
115->114;
117->115;
118->117;
119->105;
120->119;
122->120;
123->122;
124->123;
125->124;
}
== Physical Plan ==
* HashAggregate (97)
+- Exchange (96)
+- * HashAggregate (95)
+- * Project (94)
+- * Generate (93)
+- Project (92)
+- Filter (91)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- Project (90)
+- BroadcastHashJoin LeftOuter BuildRight (89)
:- Project (63)
: +- Project (62)
: +- ObjectHashAggregate (61)
: +- Exchange (60)
: +- ObjectHashAggregate (59)
: +- ObjectHashAggregate (58)
: +- Exchange (57)
: +- ObjectHashAggregate (56)
: +- Project (55)
: +- Project (54)
: +- Project (53)
: +- * Project (52)
: +- * Filter (51)
: +- InMemoryTableScan (3)
: +- InMemoryRelation (4)
: +- * Project (50)
: +- * SortMergeJoin LeftOuter (49)
: :- * Project (41)
: : +- * SortMergeJoin LeftOuter (40)
: : :- * Project (32)
: : : +- * SortMergeJoin LeftOuter (31)
: : : :- * Sort (25)
: : : : +- Exchange (24)
: : : : +- * Project (23)
: : : : +- * BroadcastHashJoin LeftOuter BuildRight (22)
: : : : :- * Project (14)
: : : : : +- * Generate (13)
: : : : : +- * Filter (12)
: : : : : +- InMemoryTableScan (5)
: : : : : +- InMemoryRelation (6)
: : : : : +- * Filter (11)
: : : : : +- InMemoryTableScan (7)
: : : : : +- InMemoryRelation (8)
: : : : : +- * Filter (10)
: : : : : +- * Scan ExistingRDD (9)
: : : : +- BroadcastExchange (21)
: : : : +- * Project (20)
: : : : +- Exchange (19)
: : : : +- * Project (18)
: : : : +- * Filter (17)
: : : : +- * ColumnarToRow (16)
: : : : +- Scan parquet (15)
: : : +- * Sort (30)
: : : +- Exchange (29)
: : : +- * Project (28)
: : : +- * Filter (27)
: : : +- * Scan ExistingRDD (26)
: : +- * Sort (39)
: : +- ObjectHashAggregate (38)
: : +- Exchange (37)
: : +- ObjectHashAggregate (36)
: : +- * Project (35)
: : +- * Filter (34)
: : +- * Scan ExistingRDD (33)
: +- * Sort (48)
: +- ObjectHashAggregate (47)
: +- Exchange (46)
: +- ObjectHashAggregate (45)
: +- * Project (44)
: +- * Filter (43)
: +- * Scan ExistingRDD (42)
+- BroadcastExchange (88)
+- Project (87)
+- * BroadcastHashJoin Inner BuildLeft (86)
:- BroadcastExchange (67)
: +- * Filter (66)
: +- InMemoryTableScan (64)
: +- InMemoryRelation (65)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * HashAggregate (85)
+- Exchange (84)
+- * HashAggregate (83)
+- * Project (82)
+- * BroadcastHashJoin Inner BuildLeft (81)
:- BroadcastExchange (74)
: +- * Project (73)
: +- * Generate (72)
: +- * Project (71)
: +- * Filter (70)
: +- InMemoryTableScan (68)
: +- InMemoryRelation (69)
: +- * Filter (11)
: +- InMemoryTableScan (7)
: +- InMemoryRelation (8)
: +- * Filter (10)
: +- * Scan ExistingRDD (9)
+- * Project (80)
+- Exchange (79)
+- * Project (78)
+- * Filter (77)
+- * ColumnarToRow (76)
+- Scan parquet (75)
(1) InMemoryTableScan
Output [1]: [orderProposal#5501319]
Arguments: [orderProposal#5501319], [(size(orderProposal#5501319.parentItems.deliveryDateTime, true) > 0)]
(2) InMemoryRelation
Arguments: [shardId#5499000, orderProposal#5501319], StorageLevel(disk, memory, 2 replicas)
(3) InMemoryTableScan
Output [39]: [availabilityDateTime#5499690, channelStreamSpecificKpis#5500431, constraintLabels#5499702, constraintOperators#5499703, constraintValues#5499705, deliveryDateTime#5499689, isFallbackOrderOnly#5499692, logisticUnits#5499707, measurements#5499700, minimumOrderQuantity#5499701, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, nextAvailabilityDateTime#5499691, optimizationGroups#5499708, orderDateTime#5499688, orderProposalId#5499670L, orderProposalItemGroupId#5499672, orderProposalItemId#5499671, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, originalReplenishmentRunId#5499673L, plant#5499684, previousOrderProposal#5499676L, prodLocSpecificKpis#5500416, product#5499683, productGroup#5499712, qty#5499514, quantityAfterProdPlantOptimization#5499513, quantityKpis#5500444, shardId#5499000, sourceOfSupplyUuid#5499679, splitIndicator#5499675L, subrange#5499682, supplier#5499681, supplierGroup#5499680, supplyingPlant#5499711]
Arguments: [availabilityDateTime#5499690, channelStreamSpecificKpis#5500431, constraintLabels#5499702, constraintOperators#5499703, constraintValues#5499705, deliveryDateTime#5499689, isFallbackOrderOnly#5499692, logisticUnits#5499707, measurements#5499700, minimumOrderQuantity#5499701, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, nextAvailabilityDateTime#5499691, optimizationGroups#5499708, orderDateTime#5499688, orderProposalId#5499670L, orderProposalItemGroupId#5499672, orderProposalItemId#5499671, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, originalReplenishmentRunId#5499673L, plant#5499684, ... 14 more fields], [NOT (isFallbackOrderOnly#5499692 <=> true)]
(4) InMemoryRelation
Arguments: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, constraintValues#5499705, constraintOperators#5499703, constraintLabels#5499702, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)
(5) InMemoryTableScan
Output [2]: [shardId#5499000, items#5499002]
Arguments: [shardId#5499000, items#5499002], [(size(items#5499002, true) > 0), isnotnull(items#5499002)]
(6) InMemoryRelation
Arguments: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006], StorageLevel(disk, memory, 2 replicas)
(7) InMemoryTableScan
Output [6]: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006]
Arguments: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006], [isnotnull(shardId#5499000), (shardId#5499000 = 0_1_10000001445)]
(8) InMemoryRelation
Arguments: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, lastModified#5499005, optimizationInsights#5499006], StorageLevel(disk, memory, 2 replicas)
(9) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, lastModified#5499005, optimizationInsights#5499006]
Arguments: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, lastModified#5499005, optimizationInsights#5499006], MapPartitionsRDD[387429] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(10) Filter [codegen id : 1]
Input [7]: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, lastModified#5499005, optimizationInsights#5499006]
Condition : (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))
(11) Filter [codegen id : 1]
Input [6]: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006]
Condition : (isnotnull(shardId#5499000) AND (shardId#5499000 = 0_1_10000001445))
(12) Filter [codegen id : 3]
Input [2]: [shardId#5499000, items#5499002]
Condition : ((size(items#5499002, true) > 0) AND isnotnull(items#5499002))
(13) Generate [codegen id : 3]
Input [2]: [shardId#5499000, items#5499002]
Arguments: explode(items#5499002), [shardId#5499000], false, [item#5499511]
(14) Project [codegen id : 3]
Output [4]: [shardId#5499000, item#5499511.worklistShardItemId AS worklistShardItemId#5499512L, item#5499511.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5499513, item#5499511.qty AS qty#5499514]
Input [2]: [shardId#5499000, item#5499511]
(15) Scan parquet
Output [38]: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, measurements#5499754, originalReplenishmentRunId#5499755L, optimizationGroups#5499756, shardId#5499757, sequenceId#5499735]
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/10000001445]
PartitionFilters: [isnotnull(shardId#5499757), isnotnull(sequenceId#5499735), (shardId#5499757 = 0_1_10000001445), (sequenceId#5499735 = 6)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,supplyingPlant:string,productGroup:string,product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,sourceOfSupplyUuid:string,isFallbackOrderOnly:boolean,splitIndicator:bigint,previousOrderProposal:bigint,worklistShardItemId:bigint,orderProposalItemGroupId:string,externalProductId:string,externalPlantId:string,logisticUnits:array<struct<uom:string,uomUuid:string,numerator:int,denominator:int,isOrderUnit:boolean,isPreferred:boolean>>,orderQuantityBaseUom:string,orderQuantityBaseUomUuid:string,minimumOrderQuantity:double,constraintLabels:array<string>,constraintOperators:array<string>,constraintValues:array<double>,netPriceAmount:double,netPriceCurrencyCode:string,netPriceQuantity:double,netPriceQuantityUom:string,netPriceQuantityUomUuid:string,measurements:array<struct<value:double,dimensionType:int,dimensionCode:string,dimensionCodeUuid:string,isoCode:string>>,originalReplenishmentRunId:bigint,optimizationGroups:array<string>>
(16) ColumnarToRow [codegen id : 1]
Input [38]: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, measurements#5499754, originalReplenishmentRunId#5499755L, optimizationGroups#5499756, shardId#5499757, sequenceId#5499735]
(17) Filter [codegen id : 1]
Input [38]: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, measurements#5499754, originalReplenishmentRunId#5499755L, optimizationGroups#5499756, shardId#5499757, sequenceId#5499735]
Condition : isnotnull(worklistShardItemId#5499736L)
(18) Project [codegen id : 1]
Output [36]: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, measurements#5499754, originalReplenishmentRunId#5499755L, optimizationGroups#5499756]
Input [38]: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, measurements#5499754, originalReplenishmentRunId#5499755L, optimizationGroups#5499756, shardId#5499757, sequenceId#5499735]
(19) Exchange
Input [36]: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, measurements#5499754, originalReplenishmentRunId#5499755L, optimizationGroups#5499756]
Arguments: hashpartitioning(worklistShardItemId#5499736L, 30), REPARTITION_BY_NUM, [plan_id=2853795]
(20) Project [codegen id : 2]
Output [36]: [worklistShardItemId#5499736L, orderProposalId#5499713L, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, originalReplenishmentRunId#5499755L, splitIndicator#5499732L, previousOrderProposal#5499733L, sourceOfSupplyUuid#5499727, supplierGroup#5499715, supplier#5499716, subrange#5499719, product#5499722, plant#5499717, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, isFallbackOrderOnly#5499730, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, netPriceAmount#5499749, netPriceCurrencyCode#5499750, measurements#5499754, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, logisticUnits#5499740, optimizationGroups#5499756, externalProductId#5499738, externalPlantId#5499739, supplyingPlant#5499720, productGroup#5499721]
Input [36]: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, sourceOfSupplyUuid#5499727, isFallbackOrderOnly#5499730, splitIndicator#5499732L, previousOrderProposal#5499733L, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, externalProductId#5499738, externalPlantId#5499739, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, measurements#5499754, originalReplenishmentRunId#5499755L, optimizationGroups#5499756]
(21) BroadcastExchange
Input [36]: [worklistShardItemId#5499736L, orderProposalId#5499713L, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, originalReplenishmentRunId#5499755L, splitIndicator#5499732L, previousOrderProposal#5499733L, sourceOfSupplyUuid#5499727, supplierGroup#5499715, supplier#5499716, subrange#5499719, product#5499722, plant#5499717, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, isFallbackOrderOnly#5499730, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, netPriceAmount#5499749, netPriceCurrencyCode#5499750, measurements#5499754, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, logisticUnits#5499740, optimizationGroups#5499756, externalProductId#5499738, externalPlantId#5499739, supplyingPlant#5499720, productGroup#5499721]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2853799]
(22) BroadcastHashJoin [codegen id : 3]
Left keys [1]: [worklistShardItemId#5499512L]
Right keys [1]: [worklistShardItemId#5499736L]
Join type: LeftOuter
Join condition: (shardId#5499000 = 0_1_10000001445)
(23) Project [codegen id : 3]
Output [39]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730]
Input [40]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, worklistShardItemId#5499736L, orderProposalId#5499713L, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, originalReplenishmentRunId#5499755L, splitIndicator#5499732L, previousOrderProposal#5499733L, sourceOfSupplyUuid#5499727, supplierGroup#5499715, supplier#5499716, subrange#5499719, product#5499722, plant#5499717, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, isFallbackOrderOnly#5499730, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, netPriceAmount#5499749, netPriceCurrencyCode#5499750, measurements#5499754, minimumOrderQuantity#5499743, constraintLabels#5499744, constraintOperators#5499745, constraintValues#5499746, logisticUnits#5499740, optimizationGroups#5499756, externalProductId#5499738, externalPlantId#5499739, supplyingPlant#5499720, productGroup#5499721]
(24) Exchange
Input [39]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730]
Arguments: hashpartitioning(shardId#5499000, worklistShardItemId#5499512L, 30), ENSURE_REQUIREMENTS, [plan_id=2853804]
(25) Sort [codegen id : 4]
Input [39]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730]
Arguments: [shardId#5499000 ASC NULLS FIRST, worklistShardItemId#5499512L ASC NULLS FIRST], false, 0
(26) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#5500409, worklistShardItemId#5500410L, qty#5500411, demandChannel#5500412, demandStream#5500413, kpis#5500414]
Arguments: [shardId#5500409, worklistShardItemId#5500410L, qty#5500411, demandChannel#5500412, demandStream#5500413, kpis#5500414], MapPartitionsRDD[387503] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(27) Filter [codegen id : 5]
Input [6]: [shardId#5500409, worklistShardItemId#5500410L, qty#5500411, demandChannel#5500412, demandStream#5500413, kpis#5500414]
Condition : (((isnull(qty#5500411) AND isnull(demandChannel#5500412)) AND isnull(demandStream#5500413)) AND (isnotnull(shardId#5500409) AND isnotnull(worklistShardItemId#5500410L)))
(28) Project [codegen id : 5]
Output [3]: [shardId#5500409, worklistShardItemId#5500410L, coalesce(kpis#5500414, []) AS prodLocSpecificKpis#5500415]
Input [6]: [shardId#5500409, worklistShardItemId#5500410L, qty#5500411, demandChannel#5500412, demandStream#5500413, kpis#5500414]
(29) Exchange
Input [3]: [shardId#5500409, worklistShardItemId#5500410L, prodLocSpecificKpis#5500415]
Arguments: hashpartitioning(shardId#5500409, worklistShardItemId#5500410L, 30), ENSURE_REQUIREMENTS, [plan_id=2853810]
(30) Sort [codegen id : 6]
Input [3]: [shardId#5500409, worklistShardItemId#5500410L, prodLocSpecificKpis#5500415]
Arguments: [shardId#5500409 ASC NULLS FIRST, worklistShardItemId#5500410L ASC NULLS FIRST], false, 0
(31) SortMergeJoin [codegen id : 7]
Left keys [2]: [shardId#5499000, worklistShardItemId#5499512L]
Right keys [2]: [shardId#5500409, worklistShardItemId#5500410L]
Join type: LeftOuter
Join condition: None
(32) Project [codegen id : 7]
Output [40]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730, coalesce(prodLocSpecificKpis#5500415, []) AS prodLocSpecificKpis#5500416]
Input [42]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730, shardId#5500409, worklistShardItemId#5500410L, prodLocSpecificKpis#5500415]
(33) Scan ExistingRDD [codegen id : 8]
Output [6]: [shardId#5500425, worklistShardItemId#5500426L, qty#5500427, demandChannel#5500428, demandStream#5500429, kpis#5500430]
Arguments: [shardId#5500425, worklistShardItemId#5500426L, qty#5500427, demandChannel#5500428, demandStream#5500429, kpis#5500430], MapPartitionsRDD[387503] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(34) Filter [codegen id : 8]
Input [6]: [shardId#5500425, worklistShardItemId#5500426L, qty#5500427, demandChannel#5500428, demandStream#5500429, kpis#5500430]
Condition : ((((isnull(qty#5500427) AND isnotnull(demandChannel#5500428)) AND isnotnull(demandStream#5500429)) AND (size(kpis#5500430, true) > 0)) AND (isnotnull(shardId#5500425) AND isnotnull(worklistShardItemId#5500426L)))
(35) Project [codegen id : 8]
Output [5]: [shardId#5500425, worklistShardItemId#5500426L, demandChannel#5500428, demandStream#5500429, kpis#5500430]
Input [6]: [shardId#5500425, worklistShardItemId#5500426L, qty#5500427, demandChannel#5500428, demandStream#5500429, kpis#5500430]
(36) ObjectHashAggregate
Input [5]: [shardId#5500425, worklistShardItemId#5500426L, demandChannel#5500428, demandStream#5500429, kpis#5500430]
Keys [2]: [shardId#5500425, worklistShardItemId#5500426L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#5500428, demandStream, demandStream#5500429, kpis, kpis#5500430), 0, 0)]
Aggregate Attributes [1]: [buf#5500605]
Results [3]: [shardId#5500425, worklistShardItemId#5500426L, buf#5500606]
(37) Exchange
Input [3]: [shardId#5500425, worklistShardItemId#5500426L, buf#5500606]
Arguments: hashpartitioning(shardId#5500425, worklistShardItemId#5500426L, 30), ENSURE_REQUIREMENTS, [plan_id=2853821]
(38) ObjectHashAggregate
Input [3]: [shardId#5500425, worklistShardItemId#5500426L, buf#5500606]
Keys [2]: [shardId#5500425, worklistShardItemId#5500426L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#5500428, demandStream, demandStream#5500429, kpis, kpis#5500430), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#5500428, demandStream, demandStream#5500429, kpis, kpis#5500430), 0, 0)#5500424]
Results [3]: [shardId#5500425, worklistShardItemId#5500426L, collect_list(struct(demandChannel, demandChannel#5500428, demandStream, demandStream#5500429, kpis, kpis#5500430), 0, 0)#5500424 AS channelStreamSpecificKpis#5500417]
(39) Sort [codegen id : 9]
Input [3]: [shardId#5500425, worklistShardItemId#5500426L, channelStreamSpecificKpis#5500417]
Arguments: [shardId#5500425 ASC NULLS FIRST, worklistShardItemId#5500426L ASC NULLS FIRST], false, 0
(40) SortMergeJoin [codegen id : 10]
Left keys [2]: [shardId#5499000, worklistShardItemId#5499512L]
Right keys [2]: [shardId#5500425, worklistShardItemId#5500426L]
Join type: LeftOuter
Join condition: None
(41) Project [codegen id : 10]
Output [41]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730, prodLocSpecificKpis#5500416, coalesce(channelStreamSpecificKpis#5500417, []) AS channelStreamSpecificKpis#5500431]
Input [43]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730, prodLocSpecificKpis#5500416, shardId#5500425, worklistShardItemId#5500426L, channelStreamSpecificKpis#5500417]
(42) Scan ExistingRDD [codegen id : 11]
Output [6]: [shardId#5500438, worklistShardItemId#5500439L, qty#5500440, demandChannel#5500441, demandStream#5500442, kpis#5500443]
Arguments: [shardId#5500438, worklistShardItemId#5500439L, qty#5500440, demandChannel#5500441, demandStream#5500442, kpis#5500443], MapPartitionsRDD[387503] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(43) Filter [codegen id : 11]
Input [6]: [shardId#5500438, worklistShardItemId#5500439L, qty#5500440, demandChannel#5500441, demandStream#5500442, kpis#5500443]
Condition : ((isnotnull(qty#5500440) AND isnotnull(kpis#5500443)) AND (isnotnull(shardId#5500438) AND isnotnull(worklistShardItemId#5500439L)))
(44) Project [codegen id : 11]
Output [4]: [shardId#5500438, worklistShardItemId#5500439L, qty#5500440, kpis#5500443]
Input [6]: [shardId#5500438, worklistShardItemId#5500439L, qty#5500440, demandChannel#5500441, demandStream#5500442, kpis#5500443]
(45) ObjectHashAggregate
Input [4]: [shardId#5500438, worklistShardItemId#5500439L, qty#5500440, kpis#5500443]
Keys [2]: [shardId#5500438, worklistShardItemId#5500439L]
Functions [1]: [partial_collect_list(struct(qty, qty#5500440, kpis, kpis#5500443), 0, 0)]
Aggregate Attributes [1]: [buf#5500607]
Results [3]: [shardId#5500438, worklistShardItemId#5500439L, buf#5500608]
(46) Exchange
Input [3]: [shardId#5500438, worklistShardItemId#5500439L, buf#5500608]
Arguments: hashpartitioning(shardId#5500438, worklistShardItemId#5500439L, 30), ENSURE_REQUIREMENTS, [plan_id=2853833]
(47) ObjectHashAggregate
Input [3]: [shardId#5500438, worklistShardItemId#5500439L, buf#5500608]
Keys [2]: [shardId#5500438, worklistShardItemId#5500439L]
Functions [1]: [collect_list(struct(qty, qty#5500440, kpis, kpis#5500443), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#5500440, kpis, kpis#5500443), 0, 0)#5500437]
Results [3]: [shardId#5500438, worklistShardItemId#5500439L, map_from_entries(collect_list(struct(qty, qty#5500440, kpis, kpis#5500443), 0, 0)#5500437) AS quantityKpis#5500432]
(48) Sort [codegen id : 12]
Input [3]: [shardId#5500438, worklistShardItemId#5500439L, quantityKpis#5500432]
Arguments: [shardId#5500438 ASC NULLS FIRST, worklistShardItemId#5500439L ASC NULLS FIRST], false, 0
(49) SortMergeJoin [codegen id : 13]
Left keys [2]: [shardId#5499000, worklistShardItemId#5499512L]
Right keys [2]: [shardId#5500438, worklistShardItemId#5500439L]
Join type: LeftOuter
Join condition: None
(50) Project [codegen id : 13]
Output [42]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730, prodLocSpecificKpis#5500416, channelStreamSpecificKpis#5500431, coalesce(quantityKpis#5500432, map(keys: [], values: [])) AS quantityKpis#5500444]
Input [44]: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499713L, originalReplenishmentRunId#5499755L, supplierGroup#5499715, supplier#5499716, supplyingPlant#5499720, productGroup#5499721, product#5499722, plant#5499717, subrange#5499719, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, constraintValues#5499746, constraintOperators#5499745, constraintLabels#5499744, logisticUnits#5499740, orderQuantityBaseUom#5499741, orderQuantityBaseUomUuid#5499742, splitIndicator#5499732L, netPriceAmount#5499749, netPriceCurrencyCode#5499750, netPriceQuantity#5499751, netPriceQuantityUom#5499752, netPriceQuantityUomUuid#5499753, sourceOfSupplyUuid#5499727, minimumOrderQuantity#5499743, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, optimizationGroups#5499756, measurements#5499754, externalProductId#5499738, externalPlantId#5499739, previousOrderProposal#5499733L, isFallbackOrderOnly#5499730, prodLocSpecificKpis#5500416, channelStreamSpecificKpis#5500431, shardId#5500438, worklistShardItemId#5500439L, quantityKpis#5500432]
(51) Filter [codegen id : 1]
Input [39]: [availabilityDateTime#5499690, channelStreamSpecificKpis#5500431, constraintLabels#5499702, constraintOperators#5499703, constraintValues#5499705, deliveryDateTime#5499689, isFallbackOrderOnly#5499692, logisticUnits#5499707, measurements#5499700, minimumOrderQuantity#5499701, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, nextAvailabilityDateTime#5499691, optimizationGroups#5499708, orderDateTime#5499688, orderProposalId#5499670L, orderProposalItemGroupId#5499672, orderProposalItemId#5499671, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, originalReplenishmentRunId#5499673L, plant#5499684, previousOrderProposal#5499676L, prodLocSpecificKpis#5500416, product#5499683, productGroup#5499712, qty#5499514, quantityAfterProdPlantOptimization#5499513, quantityKpis#5500444, shardId#5499000, sourceOfSupplyUuid#5499679, splitIndicator#5499675L, subrange#5499682, supplier#5499681, supplierGroup#5499680, supplyingPlant#5499711]
Condition : NOT (isFallbackOrderOnly#5499692 <=> true)
(52) Project [codegen id : 1]
Output [36]: [shardId#5499000, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, sourceOfSupplyUuid#5499679, minimumOrderQuantity#5499701, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, optimizationGroups#5499708, measurements#5499700, previousOrderProposal#5499676L, prodLocSpecificKpis#5500416, channelStreamSpecificKpis#5500431, quantityKpis#5500444, arrays_zip(constraintLabels#5499702, constraintOperators#5499703, constraintValues#5499705, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#5500858]
Input [39]: [availabilityDateTime#5499690, channelStreamSpecificKpis#5500431, constraintLabels#5499702, constraintOperators#5499703, constraintValues#5499705, deliveryDateTime#5499689, isFallbackOrderOnly#5499692, logisticUnits#5499707, measurements#5499700, minimumOrderQuantity#5499701, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, nextAvailabilityDateTime#5499691, optimizationGroups#5499708, orderDateTime#5499688, orderProposalId#5499670L, orderProposalItemGroupId#5499672, orderProposalItemId#5499671, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, originalReplenishmentRunId#5499673L, plant#5499684, previousOrderProposal#5499676L, prodLocSpecificKpis#5500416, product#5499683, productGroup#5499712, qty#5499514, quantityAfterProdPlantOptimization#5499513, quantityKpis#5500444, shardId#5499000, sourceOfSupplyUuid#5499679, splitIndicator#5499675L, subrange#5499682, supplier#5499681, supplierGroup#5499680, supplyingPlant#5499711]
(53) Project
Output [37]: [shardId#5499000, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, sourceOfSupplyUuid#5499679, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, optimizationGroups#5499708, measurements#5499700, previousOrderProposal#5499676L, prodLocSpecificKpis#5500416, channelStreamSpecificKpis#5500431, quantityKpis#5500444, struct(minServiceLevel, array_min(filter(constraintStructArray#5500858, lambdafunction((lambda x_10855#5500865.constraintLabels = ServiceLevel), lambda x_10855#5500865, false)).constraintValues), minServiceLevelMinStock, null, maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#5500858, lambdafunction((lambda x_10856#5500866.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_10856#5500866, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#5500858, lambdafunction((lambda x_10857#5500867.constraintLabels = RangeOfCoverage), lambda x_10857#5500867, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#5499701, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#5500416, lambdafunction((lambda x_10858#5500868.label = NonListingStartTimestamp), lambda x_10858#5500868, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#5500864, CASE WHEN (qty#5499514 <=> quantityAfterProdPlantOptimization#5499513) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#5499514 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500936.isOrderUnit, lambda x_10859#5500936, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500937.isOrderUnit, lambda x_10859#5500937, false)), 1, None, false).numerator as double))), qty#5499514), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500938.isOrderUnit, lambda x_10859#5500938, false)), 1, None, false).uom, orderQuantityBaseUom#5499693), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500939.isOrderUnit, lambda x_10859#5500939, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694), candidateOrderQuantityInBaseUnit, qty#5499514, orderQuantityBaseUom, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5499694, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10861#5500940.isPreferred AND (((qty#5499514 * cast(lambda x_10861#5500940.denominator as double)) % cast(lambda x_10861#5500940.numerator as double)) = 0.0)), lambda x_10861#5500940, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5499514 * cast(lambda x_10862#5500978.denominator as double)) / cast(lambda x_10862#5500978.numerator as double)), uom, lambda x_10862#5500978.uom, uomUuid, lambda x_10862#5500978.uomUuid), lambda x_10862#5500978, false))).inPreferredQuantity, coalesce((qty#5499514 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500941.isOrderUnit, lambda x_10860#5500941, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500942.isOrderUnit, lambda x_10860#5500942, false)), 1, None, false).numerator as double))), qty#5499514)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10861#5500943.isPreferred AND (((qty#5499514 * cast(lambda x_10861#5500943.denominator as double)) % cast(lambda x_10861#5500943.numerator as double)) = 0.0)), lambda x_10861#5500943, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5499514 * cast(lambda x_10862#5500979.denominator as double)) / cast(lambda x_10862#5500979.numerator as double)), uom, lambda x_10862#5500979.uom, uomUuid, lambda x_10862#5500979.uomUuid), lambda x_10862#5500979, false))).uom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500944.isOrderUnit, lambda x_10860#5500944, false)), 1, None, false).uom, orderQuantityBaseUom#5499693)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10861#5500945.isPreferred AND (((qty#5499514 * cast(lambda x_10861#5500945.denominator as double)) % cast(lambda x_10861#5500945.numerator as double)) = 0.0)), lambda x_10861#5500945, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5499514 * cast(lambda x_10862#5500980.denominator as double)) / cast(lambda x_10862#5500980.numerator as double)), uom, lambda x_10862#5500980.uom, uomUuid, lambda x_10862#5500980.uomUuid), lambda x_10862#5500980, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500946.isOrderUnit, lambda x_10860#5500946, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694)), serviceLevel, coalesce(filter(element_at(quantityKpis#5500444, qty#5499514, None, false), lambdafunction((lambda x_10867#5500947.label = ServiceLevel), lambda x_10867#5500947, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#5499514 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500950.isOrderUnit, lambda x_10859#5500950, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500951.isOrderUnit, lambda x_10859#5500951, false)), 1, None, false).numerator as double))), qty#5499514), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500952.isOrderUnit, lambda x_10859#5500952, false)), 1, None, false).uom, orderQuantityBaseUom#5499693), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10859#5500953.isOrderUnit, lambda x_10859#5500953, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694), candidateOrderQuantityInBaseUnit, qty#5499514, orderQuantityBaseUom, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5499694, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10861#5500954.isPreferred AND (((qty#5499514 * cast(lambda x_10861#5500954.denominator as double)) % cast(lambda x_10861#5500954.numerator as double)) = 0.0)), lambda x_10861#5500954, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5499514 * cast(lambda x_10862#5500981.denominator as double)) / cast(lambda x_10862#5500981.numerator as double)), uom, lambda x_10862#5500981.uom, uomUuid, lambda x_10862#5500981.uomUuid), lambda x_10862#5500981, false))).inPreferredQuantity, coalesce((qty#5499514 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500955.isOrderUnit, lambda x_10860#5500955, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500956.isOrderUnit, lambda x_10860#5500956, false)), 1, None, false).numerator as double))), qty#5499514)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10861#5500957.isPreferred AND (((qty#5499514 * cast(lambda x_10861#5500957.denominator as double)) % cast(lambda x_10861#5500957.numerator as double)) = 0.0)), lambda x_10861#5500957, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5499514 * cast(lambda x_10862#5500982.denominator as double)) / cast(lambda x_10862#5500982.numerator as double)), uom, lambda x_10862#5500982.uom, uomUuid, lambda x_10862#5500982.uomUuid), lambda x_10862#5500982, false))).uom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500958.isOrderUnit, lambda x_10860#5500958, false)), 1, None, false).uom, orderQuantityBaseUom#5499693)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10861#5500959.isPreferred AND (((qty#5499514 * cast(lambda x_10861#5500959.denominator as double)) % cast(lambda x_10861#5500959.numerator as double)) = 0.0)), lambda x_10861#5500959, false)), lambdafunction(struct(inPreferredQuantity, ((qty#5499514 * cast(lambda x_10862#5500983.denominator as double)) / cast(lambda x_10862#5500983.numerator as double)), uom, lambda x_10862#5500983.uom, uomUuid, lambda x_10862#5500983.uomUuid), lambda x_10862#5500983, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10860#5500960.isOrderUnit, lambda x_10860#5500960, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694)), serviceLevel, coalesce(filter(element_at(quantityKpis#5500444, qty#5499514, None, false), lambdafunction((lambda x_10870#5500961.label = ServiceLevel), lambda x_10870#5500961, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#5499513 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10863#5500964.isOrderUnit, lambda x_10863#5500964, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10863#5500965.isOrderUnit, lambda x_10863#5500965, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#5499513), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10863#5500966.isOrderUnit, lambda x_10863#5500966, false)), 1, None, false).uom, orderQuantityBaseUom#5499693), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10863#5500967.isOrderUnit, lambda x_10863#5500967, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#5499513, orderQuantityBaseUom, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#5499694, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10865#5500968.isPreferred AND (((quantityAfterProdPlantOptimization#5499513 * cast(lambda x_10865#5500968.denominator as double)) % cast(lambda x_10865#5500968.numerator as double)) = 0.0)), lambda x_10865#5500968, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5499513 * cast(lambda x_10866#5500984.denominator as double)) / cast(lambda x_10866#5500984.numerator as double)), uom, lambda x_10866#5500984.uom, uomUuid, lambda x_10866#5500984.uomUuid), lambda x_10866#5500984, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#5499513 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10864#5500969.isOrderUnit, lambda x_10864#5500969, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10864#5500970.isOrderUnit, lambda x_10864#5500970, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#5499513)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10865#5500971.isPreferred AND (((quantityAfterProdPlantOptimization#5499513 * cast(lambda x_10865#5500971.denominator as double)) % cast(lambda x_10865#5500971.numerator as double)) = 0.0)), lambda x_10865#5500971, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5499513 * cast(lambda x_10866#5500985.denominator as double)) / cast(lambda x_10866#5500985.numerator as double)), uom, lambda x_10866#5500985.uom, uomUuid, lambda x_10866#5500985.uomUuid), lambda x_10866#5500985, false))).uom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10864#5500972.isOrderUnit, lambda x_10864#5500972, false)), 1, None, false).uom, orderQuantityBaseUom#5499693)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#5499707, lambdafunction((lambda x_10865#5500973.isPreferred AND (((quantityAfterProdPlantOptimization#5499513 * cast(lambda x_10865#5500973.denominator as double)) % cast(lambda x_10865#5500973.numerator as double)) = 0.0)), lambda x_10865#5500973, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#5499513 * cast(lambda x_10866#5500986.denominator as double)) / cast(lambda x_10866#5500986.numerator as double)), uom, lambda x_10866#5500986.uom, uomUuid, lambda x_10866#5500986.uomUuid), lambda x_10866#5500986, false))).uomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10864#5500974.isOrderUnit, lambda x_10864#5500974, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694)), serviceLevel, coalesce(filter(element_at(quantityKpis#5500444, quantityAfterProdPlantOptimization#5499513, None, false), lambdafunction((lambda x_10873#5500975.label = ServiceLevel), lambda x_10873#5500975, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#5500935, coalesce(filter(prodLocSpecificKpis#5500416, lambdafunction((lambda x_10876#5500988.label = InitialStockQty), lambda x_10876#5500988, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#5500987, coalesce(filter(prodLocSpecificKpis#5500416, lambdafunction((lambda x_10877#5500990.label = DemandPeriodEndTimestamp), lambda x_10877#5500990, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#5500989]
Input [36]: [shardId#5499000, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, sourceOfSupplyUuid#5499679, minimumOrderQuantity#5499701, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, optimizationGroups#5499708, measurements#5499700, previousOrderProposal#5499676L, prodLocSpecificKpis#5500416, channelStreamSpecificKpis#5500431, quantityKpis#5500444, constraintStructArray#5500858]
(54) Project
Output [21]: [shardId#5499000, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, previousOrderProposal#5499676L, struct(supplier, supplier#5499681, supplyingPlant, supplyingPlant#5499711, productGroup, productGroup#5499712, product, product#5499683, plant, plant#5499684, supplierSubRange, subrange#5499682, sourceOfSupplyUuid, sourceOfSupplyUuid#5499679, deliveryDateTime, deliveryDateTime#5499689, unitPrice, netPriceAmount#5499698, unitPriceCurrency, netPriceCurrencyCode#5499699, unitPriceQuantity, netPriceQuantity#5499695, unitPriceQuantityUom, netPriceQuantityUom#5499696, unitPriceQuantityUomUuid, ... 31 more fields) AS parentItem#5501060]
Input [37]: [shardId#5499000, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, netPriceCurrencyCode#5499699, netPriceQuantity#5499695, netPriceQuantityUom#5499696, netPriceQuantityUomUuid#5499697, sourceOfSupplyUuid#5499679, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, optimizationGroups#5499708, measurements#5499700, previousOrderProposal#5499676L, prodLocSpecificKpis#5500416, channelStreamSpecificKpis#5500431, quantityKpis#5500444, constraintBenchmark#5500864, calculationAnalysis#5500935, inventoryDateTime#5500987, demandPeriodEndDateTime#5500989]
(55) Project
Output [12]: [shardId#5499000, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, orderDateTime#5499688, splitIndicator#5499675L, orderProposalItemGroupId#5499672, previousOrderProposal#5499676L, parentItem#5501060, struct(itemId, orderProposalItemId#5499671, supplier, supplier#5499681, supplyingPlant, supplyingPlant#5499711, productGroup, productGroup#5499712, product, product#5499683, plant, plant#5499684, supplierSubRange, subrange#5499682, deliveryDateTime, deliveryDateTime#5499689, orderQuantity, coalesce((qty#5499514 * (cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501094.isOrderUnit, lambda x_10901#5501094, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501095.isOrderUnit, lambda x_10901#5501095, false)), 1, None, false).numerator as double))), qty#5499514), orderQuantityUom, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501096.isOrderUnit, lambda x_10901#5501096, false)), 1, None, false).uom, orderQuantityBaseUom#5499693), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#5499707, lambdafunction(lambda x_10901#5501097.isOrderUnit, lambda x_10901#5501097, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#5499694), orderQuantityInBaseUnit, qty#5499514, orderQuantityBaseUom, ... 13 more fields) AS item#5501091]
Input [21]: [shardId#5499000, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, previousOrderProposal#5499676L, parentItem#5501060]
(56) ObjectHashAggregate
Input [12]: [shardId#5499000, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, orderDateTime#5499688, splitIndicator#5499675L, orderProposalItemGroupId#5499672, previousOrderProposal#5499676L, parentItem#5501060, item#5501091]
Keys [4]: [shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672]
Functions [8]: [partial_max(originalReplenishmentRunId#5499673L), partial_max(supplierGroup#5499680), partial_max(supplier#5499681), partial_max(supplyingPlant#5499711), partial_max(orderDateTime#5499688), partial_collect_list(parentItem#5501060, 0, 0), partial_collect_set(previousOrderProposal#5499676L, 0, 0), partial_collect_list(item#5501091, 0, 0)]
Aggregate Attributes [8]: [max#5502342L, max#5502343, max#5502344, max#5502345, max#5502346, buf#5502347, buf#5502348, buf#5502349]
Results [12]: [shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672, max#5502350L, max#5502351, max#5502352, max#5502353, max#5502354, buf#5502355, buf#5502356, buf#5502357]
(57) Exchange
Input [12]: [shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672, max#5502350L, max#5502351, max#5502352, max#5502353, max#5502354, buf#5502355, buf#5502356, buf#5502357]
Arguments: hashpartitioning(shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672, 30), ENSURE_REQUIREMENTS, [plan_id=2854071]
(58) ObjectHashAggregate
Input [12]: [shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672, max#5502350L, max#5502351, max#5502352, max#5502353, max#5502354, buf#5502355, buf#5502356, buf#5502357]
Keys [4]: [shardId#5499000, orderProposalId#5499670L, splitIndicator#5499675L, orderProposalItemGroupId#5499672]
Functions [8]: [max(originalReplenishmentRunId#5499673L), max(supplierGroup#5499680), max(supplier#5499681), max(supplyingPlant#5499711), max(orderDateTime#5499688), collect_list(parentItem#5501060, 0, 0), collect_set(previousOrderProposal#5499676L, 0, 0), collect_list(item#5501091, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#5499673L)#5501160L, max(supplierGroup#5499680)#5501161, max(supplier#5499681)#5501162, max(supplyingPlant#5499711)#5501163, max(orderDateTime#5499688)#5501164, collect_list(parentItem#5501060, 0, 0)#5501165, collect_set(previousOrderProposal#5499676L, 0, 0)#5501167, collect_list(item#5501091, 0, 0)#5501166]
Results [10]: [shardId#5499000, orderProposalId#5499670L, max(originalReplenishmentRunId#5499673L)#5501160L AS originalReplenishmentRunId#5501108L, max(supplierGroup#5499680)#5501161 AS supplierGroup#5501109, max(supplier#5499681)#5501162 AS supplier#5501110, max(supplyingPlant#5499711)#5501163 AS supplyingPlant#5501111, max(orderDateTime#5499688)#5501164 AS orderDateTime#5501112, collect_list(parentItem#5501060, 0, 0)#5501165 AS parentItems#5501113, collect_set(previousOrderProposal#5499676L, 0, 0)#5501167 AS previousOrderProposals#5501115, struct(itemGroupId, coalesce(orderProposalItemGroupId#5499672, cast((monotonically_increasing_id() % 9999999999) as string)), items, collect_list(item#5501091, 0, 0)#5501166) AS itemGroup#5501169]
(59) ObjectHashAggregate
Input [10]: [shardId#5499000, orderProposalId#5499670L, originalReplenishmentRunId#5501108L, supplierGroup#5501109, supplier#5501110, supplyingPlant#5501111, orderDateTime#5501112, parentItems#5501113, previousOrderProposals#5501115, itemGroup#5501169]
Keys [2]: [shardId#5499000, orderProposalId#5499670L]
Functions [8]: [partial_max(originalReplenishmentRunId#5501108L), partial_max(supplierGroup#5501109), partial_max(supplier#5501110), partial_max(supplyingPlant#5501111), partial_max(orderDateTime#5501112), partial_collect_list(itemGroup#5501169, 0, 0), partial_collect_list(parentItems#5501113, 0, 0), partial_collect_set(previousOrderProposals#5501115, 0, 0)]
Aggregate Attributes [8]: [max#5502326L, max#5502327, max#5502328, max#5502329, max#5502330, buf#5502331, buf#5502332, buf#5502333]
Results [10]: [shardId#5499000, orderProposalId#5499670L, max#5502334L, max#5502335, max#5502336, max#5502337, max#5502338, buf#5502339, buf#5502340, buf#5502341]
(60) Exchange
Input [10]: [shardId#5499000, orderProposalId#5499670L, max#5502334L, max#5502335, max#5502336, max#5502337, max#5502338, buf#5502339, buf#5502340, buf#5502341]
Arguments: hashpartitioning(shardId#5499000, orderProposalId#5499670L, 30), ENSURE_REQUIREMENTS, [plan_id=2854074]
(61) ObjectHashAggregate
Input [10]: [shardId#5499000, orderProposalId#5499670L, max#5502334L, max#5502335, max#5502336, max#5502337, max#5502338, buf#5502339, buf#5502340, buf#5502341]
Keys [2]: [shardId#5499000, orderProposalId#5499670L]
Functions [8]: [max(originalReplenishmentRunId#5501108L), max(supplierGroup#5501109), max(supplier#5501110), max(supplyingPlant#5501111), max(orderDateTime#5501112), collect_list(itemGroup#5501169, 0, 0), collect_list(parentItems#5501113, 0, 0), collect_set(previousOrderProposals#5501115, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#5501108L)#5501191L, max(supplierGroup#5501109)#5501192, max(supplier#5501110)#5501193, max(supplyingPlant#5501111)#5501194, max(orderDateTime#5501112)#5501195, collect_list(itemGroup#5501169, 0, 0)#5501196, collect_list(parentItems#5501113, 0, 0)#5501197, collect_set(previousOrderProposals#5501115, 0, 0)#5501198]
Results [10]: [shardId#5499000, orderProposalId#5499670L, max(originalReplenishmentRunId#5501108L)#5501191L AS originalReplenishmentRunId#5501170L, max(supplierGroup#5501109)#5501192 AS supplierGroup#5501171, max(supplier#5501110)#5501193 AS supplier#5501172, max(supplyingPlant#5501111)#5501194 AS supplyingPlant#5501173, max(orderDateTime#5501112)#5501195 AS orderDateTime#5501174, collect_list(itemGroup#5501169, 0, 0)#5501196 AS itemGroups#5501175, flatten(collect_list(parentItems#5501113, 0, 0)#5501197) AS parentItems#5501176, flatten(collect_set(previousOrderProposals#5501115, 0, 0)#5501198) AS previousOrderProposals#5501177]
(62) Project
Output [2]: [shardId#5499000, struct(orderProposalId, orderProposalId#5499670L, originalReplenishmentRunId, originalReplenishmentRunId#5501170L, supplierGroup, supplierGroup#5501171, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#5501171) THEN supplier#5501172 END, supplyingPlant, supplyingPlant#5501173, orderDateTime, orderDateTime#5501174, itemGroups, itemGroups#5501175, previousOrderProposals, array_distinct(previousOrderProposals#5501177), parentItems, parentItems#5501176) AS orderProposal#5501202]
Input [10]: [shardId#5499000, orderProposalId#5499670L, originalReplenishmentRunId#5501170L, supplierGroup#5501171, supplier#5501172, supplyingPlant#5501173, orderDateTime#5501174, itemGroups#5501175, parentItems#5501176, previousOrderProposals#5501177]
(63) Project
Output [11]: [shardId#5499000, orderProposal#5501202.orderProposalId AS _extract_orderProposalId#5501958L, orderProposal#5501202.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#5501959L, orderProposal#5501202.supplierGroup AS _extract_supplierGroup#5501960, orderProposal#5501202.supplier AS _extract_supplier#5501961, orderProposal#5501202.supplyingPlant AS _extract_supplyingPlant#5501962, orderProposal#5501202.orderDateTime AS _extract_orderDateTime#5501963, orderProposal#5501202.itemGroups AS _extract_itemGroups#5501964, orderProposal#5501202.previousOrderProposals AS _extract_previousOrderProposals#5501965, orderProposal#5501202.parentItems AS _extract_parentItems#5501966, orderProposal#5501202.orderProposalId AS _extract_orderProposalId#5501967L]
Input [2]: [shardId#5499000, orderProposal#5501202]
(64) InMemoryTableScan
Output [3]: [shardId#5501215, orderProposalId#5501216L, optimizationGroups#5501218]
Arguments: [shardId#5501215, orderProposalId#5501216L, optimizationGroups#5501218], [isnotnull(orderProposalId#5501216L)]
(65) InMemoryRelation
Arguments: [shardId#5501215, orderProposalId#5501216L, items#5501217, optimizationGroups#5501218, isOptimal#5501219, optimizationInsights#5501221], StorageLevel(disk, memory, 2 replicas)
(66) Filter [codegen id : 2]
Input [3]: [shardId#5501215, orderProposalId#5501216L, optimizationGroups#5501218]
Condition : isnotnull(orderProposalId#5501216L)
(67) BroadcastExchange
Input [3]: [shardId#5501215, orderProposalId#5501216L, optimizationGroups#5501218]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false]),false), [plan_id=2854081]
(68) InMemoryTableScan
Output [2]: [items#5500853, shardId#5500851]
Arguments: [items#5500853, shardId#5500851], [(size(items#5500853.worklistShardItemId, true) > 0), isnotnull(items#5500853.worklistShardItemId), (shardId#5500851 = 0_1_10000001445)]
(69) InMemoryRelation
Arguments: [shardId#5500851, orderProposalId#5500852L, items#5500853, optimizationGroups#5500854, isOptimal#5500855, optimizationInsights#5500857], StorageLevel(disk, memory, 2 replicas)
(70) Filter [codegen id : 3]
Input [2]: [items#5500853, shardId#5500851]
Condition : (((size(items#5500853.worklistShardItemId, true) > 0) AND isnotnull(items#5500853.worklistShardItemId)) AND (shardId#5500851 = 0_1_10000001445))
(71) Project [codegen id : 3]
Output [1]: [items#5500853.worklistShardItemId AS _extract_worklistShardItemId#5501863]
Input [2]: [items#5500853, shardId#5500851]
(72) Generate [codegen id : 3]
Input [1]: [_extract_worklistShardItemId#5501863]
Arguments: explode(_extract_worklistShardItemId#5501863), false, [item#5501222L]
(73) Project [codegen id : 3]
Output [1]: [item#5501222L AS worklistShardItemId#5501223L]
Input [1]: [item#5501222L]
(74) BroadcastExchange
Input [1]: [worklistShardItemId#5501223L]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=2854089]
(75) Scan parquet
Output [5]: [orderProposalId#5501271L, isFallbackOrderOnly#5501288, worklistShardItemId#5501294L, shardId#5501315, sequenceId#5501293]
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/10000001445]
PartitionFilters: [isnotnull(shardId#5501315), isnotnull(sequenceId#5501293), (shardId#5501315 = 0_1_10000001445), (sequenceId#5501293 = 6)]
PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>
(76) ColumnarToRow [codegen id : 4]
Input [5]: [orderProposalId#5501271L, isFallbackOrderOnly#5501288, worklistShardItemId#5501294L, shardId#5501315, sequenceId#5501293]
(77) Filter [codegen id : 4]
Input [5]: [orderProposalId#5501271L, isFallbackOrderOnly#5501288, worklistShardItemId#5501294L, shardId#5501315, sequenceId#5501293]
Condition : ((isnotnull(worklistShardItemId#5501294L) AND NOT (isFallbackOrderOnly#5501288 <=> true)) AND isnotnull(orderProposalId#5501271L))
(78) Project [codegen id : 4]
Output [2]: [orderProposalId#5501271L, worklistShardItemId#5501294L]
Input [5]: [orderProposalId#5501271L, isFallbackOrderOnly#5501288, worklistShardItemId#5501294L, shardId#5501315, sequenceId#5501293]
(79) Exchange
Input [2]: [orderProposalId#5501271L, worklistShardItemId#5501294L]
Arguments: hashpartitioning(worklistShardItemId#5501294L, 30), REPARTITION_BY_NUM, [plan_id=2854096]
(80) Project
Output [2]: [worklistShardItemId#5501294L, orderProposalId#5501271L]
Input [2]: [orderProposalId#5501271L, worklistShardItemId#5501294L]
(81) BroadcastHashJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#5501223L]
Right keys [1]: [worklistShardItemId#5501294L]
Join type: Inner
Join condition: None
(82) Project [codegen id : 5]
Output [1]: [orderProposalId#5501271L]
Input [3]: [worklistShardItemId#5501223L, worklistShardItemId#5501294L, orderProposalId#5501271L]
(83) HashAggregate [codegen id : 5]
Input [1]: [orderProposalId#5501271L]
Keys [1]: [orderProposalId#5501271L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#5501271L]
(84) Exchange
Input [1]: [orderProposalId#5501271L]
Arguments: hashpartitioning(orderProposalId#5501271L, 30), ENSURE_REQUIREMENTS, [plan_id=2854103]
(85) HashAggregate
Input [1]: [orderProposalId#5501271L]
Keys [1]: [orderProposalId#5501271L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#5501271L]
(86) BroadcastHashJoin [codegen id : 6]
Left keys [1]: [orderProposalId#5501216L]
Right keys [1]: [orderProposalId#5501271L]
Join type: Inner
Join condition: None
(87) Project
Output [3]: [orderProposalId#5501216L, shardId#5501215, coalesce(transform(optimizationGroups#5501218, lambdafunction(struct(optGroupId, lambda x_10905#5501213.optGroupId, minOrderProfile, lambda x_10905#5501213.minOrderProfile, assignmentDetails, lambda x_10905#5501213.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_10905#5501213.minOrderGoal.dimensionType, unit, lambda x_10905#5501213.minOrderGoal.unit, unitUuid, lambda x_10905#5501213.minOrderGoal.unitUuid, goalValue, lambda x_10905#5501213.minOrderGoal.minOrderValue, calcValue, lambda x_10905#5501213.minOrderGoal.calculatedOrderValue)), lambda x_10905#5501213, false)), []) AS optimizationGroups#5501212]
Input [4]: [shardId#5501215, orderProposalId#5501216L, optimizationGroups#5501218, orderProposalId#5501271L]
(88) BroadcastExchange
Input [3]: [orderProposalId#5501216L, shardId#5501215, optimizationGroups#5501212]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[0, bigint, true], 0), isnull(input[0, bigint, true])),false), [plan_id=2854109]
(89) BroadcastHashJoin
Left keys [4]: [coalesce(shardId#5499000, ), isnull(shardId#5499000), coalesce(_extract_orderProposalId#5501967L, 0), isnull(_extract_orderProposalId#5501967L)]
Right keys [4]: [coalesce(shardId#5501215, ), isnull(shardId#5501215), coalesce(orderProposalId#5501216L, 0), isnull(orderProposalId#5501216L)]
Join type: LeftOuter
Join condition: None
(90) Project
Output [2]: [shardId#5499000, named_struct(orderProposalId, _extract_orderProposalId#5501967L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#5501959L, supplierGroup, _extract_supplierGroup#5501960, optimizationGroups, coalesce(optimizationGroups#5501212, []), supplier, _extract_supplier#5501961, supplyingPlant, _extract_supplyingPlant#5501962, orderDateTime, _extract_orderDateTime#5501963, itemGroups, _extract_itemGroups#5501964, previousOrderProposals, _extract_previousOrderProposals#5501965, parentItems, _extract_parentItems#5501966) AS orderProposal#5501319]
Input [14]: [shardId#5499000, _extract_orderProposalId#5501958L, _extract_originalReplenishmentRunId#5501959L, _extract_supplierGroup#5501960, _extract_supplier#5501961, _extract_supplyingPlant#5501962, _extract_orderDateTime#5501963, _extract_itemGroups#5501964, _extract_previousOrderProposals#5501965, _extract_parentItems#5501966, _extract_orderProposalId#5501967L, orderProposalId#5501216L, shardId#5501215, optimizationGroups#5501212]
(91) Filter
Input [1]: [orderProposal#5501319]
Condition : (size(orderProposal#5501319.parentItems.deliveryDateTime, true) > 0)
(92) Project
Output [1]: [orderProposal#5501319.parentItems.deliveryDateTime AS _extract_deliveryDateTime#5502722]
Input [1]: [orderProposal#5501319]
(93) Generate [codegen id : 1]
Input [1]: [_extract_deliveryDateTime#5502722]
Arguments: explode(_extract_deliveryDateTime#5502722), false, [numberOfOrderProposalItems#5502694]
(94) Project [codegen id : 1]
Output: []
Input [1]: [numberOfOrderProposalItems#5502694]
(95) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#5502733L]
Results [1]: [count#5502734L]
(96) Exchange
Input [1]: [count#5502734L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=2854215]
(97) HashAggregate [codegen id : 2]
Input [1]: [count#5502734L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#5502699L]
Results [1]: [count(1)#5502699L AS count#5502695L]