crp-order-qty-opt-service - Details for Query 12697

Submitted Time: 2026/08/31 13:55:43
Duration: 2 s
Succeeded Jobs: 17723

Plan Visualization

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { subgraph cluster0 { isCluster="true"; id="cluster0"; label="WholeStageCodegen (2)\n \nduration: 4 ms"; tooltip="WholeStageCodegen (2)"; 1 [id="node1" labelType="html" label="HashAggregate time in aggregation build: 4 ms number of output rows: 1" tooltip="HashAggregate(keys=[], functions=[count(1)])"]; } 2 [id="node2" labelType="html" label="Exchange shuffle records written: 30 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 30 local bytes read: 900.0 B merged fetch fallback count: 0 local blocks read: 12 remote merged chunks fetched: 0 remote blocks read: 18 data size total (min, med, max (stageId: taskId)) 480.0 B (16.0 B, 16.0 B, 16.0 B (stage 307837.0: task 890082)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 5 ms (0 ms, 0 ms, 0 ms (stage 307837.0: task 890113)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 1 ms remote bytes read: 1308.0 B number of partitions: 1 remote reqs duration: 4 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 2.2 KiB (72.0 B, 75.0 B, 75.0 B (stage 307837.0: task 890082))" tooltip="Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=981026]"]; subgraph cluster3 { isCluster="true"; id="cluster3"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n131 ms (0 ms, 3 ms, 30 ms (stage 307837.0: task 890111))"; tooltip="WholeStageCodegen (1)"; 4 [id="node4" labelType="html" label="HashAggregate time in aggregation build total (min, med, max (stageId: taskId)) 119 ms (0 ms, 2 ms, 30 ms (stage 307837.0: task 890111)) number of output rows: 30" tooltip="HashAggregate(keys=[], functions=[partial_count(1)])"]; } 5 [id="node5" labelType="html" label="InMemoryTableScan number of output rows: 20" tooltip="InMemoryTableScan"]; 6 [id="node6" labelType="html" label="ObjectHashAggregate number of output rows: 20 time in aggregation build total (min, med, max (stageId: taskId)) 423 ms (0 ms, 11 ms, 89 ms (stage 307837.0: task 890082)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307837.0: task 890082)) number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, resultSeparationId#3406319L], functions=[collect_list(orderProposal#3399126, 0, 0)])"]; 7 [id="node7" labelType="html" label="Exchange shuffle records written: 447 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 447 local bytes read total (min, med, max (stageId: taskId)) 3.6 MiB (107.1 KiB, 206.0 KiB, 564.8 KiB (stage 307837.0: task 890087)) merged fetch fallback count: 0 local blocks read: 197 remote merged chunks fetched: 0 remote blocks read: 182 data size total (min, med, max (stageId: taskId)) 72.5 MiB (1677.5 KiB, 2.4 MiB, 3.2 MiB (stage 307836.0: task 890056)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 72 ms (1 ms, 1 ms, 28 ms (stage 307836.0: task 890074)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 307837.0: task 890082)) remote bytes read total (min, med, max (stageId: taskId)) 3.3 MiB (94.4 KiB, 188.3 KiB, 465.0 KiB (stage 307837.0: task 890087)) number of partitions: 30 remote reqs duration total (min, med, max (stageId: taskId)) 51 ms (1 ms, 2 ms, 23 ms (stage 307837.0: task 890082)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 6.9 MiB (159.1 KiB, 230.7 KiB, 314.5 KiB (stage 307836.0: task 890056))" tooltip="Exchange hashpartitioning(shardId#3394574, resultSeparationId#3406319L, 30), ENSURE_REQUIREMENTS, [plan_id=981002]"]; 8 [id="node8" labelType="html" label="ObjectHashAggregate number of output rows: 447 time in aggregation build total (min, med, max (stageId: taskId)) 314 ms (2 ms, 3 ms, 54 ms (stage 307836.0: task 890044)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307836.0: task 890048)) number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, resultSeparationId#3406319L], functions=[partial_collect_list(orderProposal#3399126, 0, 0)])"]; 9 [id="node9" labelType="html" label=" Project " tooltip="Project [shardId#3394574, orderProposal#3399126, CASE WHEN (size(orderProposal#3399126.parentItems, true) > 2000) THEN xxhash64(orderProposal#3399126.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#3399126.orderProposalId as decimal(20,0)), 20), 42) END AS resultSeparationId#3406319L]"]; 10 [id="node10" labelType="html" label="InMemoryTableScan number of output rows: 792" tooltip="InMemoryTableScan [orderProposal#3399126, shardId#3394574]"]; 11 [id="node11" labelType="html" label=" Project " tooltip="Project [shardId#3394574, named_struct(orderProposalId, _extract_orderProposalId#3399954L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#3399946L, supplierGroup, _extract_supplierGroup#3399947, optimizationGroups, coalesce(optimizationGroups#3399019, []), supplier, _extract_supplier#3399948, supplyingPlant, _extract_supplyingPlant#3399949, orderDateTime, _extract_orderDateTime#3399950, itemGroups, _extract_itemGroups#3399951, previousOrderProposals, _extract_previousOrderProposals#3399952, parentItems, _extract_parentItems#3399953) AS orderProposal#3399126]"]; 12 [id="node12" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L)], [coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L)], LeftOuter"]; 13 [id="node13" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#3394574, ) ASC NULLS FIRST, isnull(shardId#3394574) ASC NULLS FIRST, coalesce(_extract_orderProposalId#3399954L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#3399954L) ASC NULLS FIRST], false, 0"]; 14 [id="node14" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L), 30), ENSURE_REQUIREMENTS, [plan_id=979453]"]; 15 [id="node15" labelType="html" label=" Project " tooltip="Project [shardId#3394574, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399945L, orderProposal#3399007.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#3399946L, orderProposal#3399007.supplierGroup AS _extract_supplierGroup#3399947, orderProposal#3399007.supplier AS _extract_supplier#3399948, orderProposal#3399007.supplyingPlant AS _extract_supplyingPlant#3399949, orderProposal#3399007.orderDateTime AS _extract_orderDateTime#3399950, orderProposal#3399007.itemGroups AS _extract_itemGroups#3399951, orderProposal#3399007.previousOrderProposals AS _extract_previousOrderProposals#3399952, orderProposal#3399007.parentItems AS _extract_parentItems#3399953, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399954L]"]; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [shardId#3394574, struct(orderProposalId, orderProposalId#3395775L, originalReplenishmentRunId, originalReplenishmentRunId#3398975L, supplierGroup, supplierGroup#3398976, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#3398976) THEN supplier#3398977 END, supplyingPlant, supplyingPlant#3398978, orderDateTime, orderDateTime#3398979, itemGroups, itemGroups#3398980, previousOrderProposals, array_distinct(previousOrderProposals#3398982), parentItems, parentItems#3398981) AS orderProposal#3399007]"]; 17 [id="node17" labelType="html" label="ObjectHashAggregate number of output rows: 0 time in aggregation build: 0 ms spill size: 0.0 B number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L], functions=[max(originalReplenishmentRunId#3398913L), max(supplierGroup#3398914), max(supplier#3398915), max(supplyingPlant#3398916), max(orderDateTime#3398917), collect_list(itemGroup#3398974, 0, 0), collect_list(parentItems#3398918, 0, 0), collect_set(previousOrderProposals#3398920, 0, 0)])"]; 18 [id="node18" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#3394574, orderProposalId#3395775L, 30), ENSURE_REQUIREMENTS, [plan_id=979449]"]; 19 [id="node19" labelType="html" label="ObjectHashAggregate number of output rows: 0 time in aggregation build: 0 ms spill size: 0.0 B number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L], functions=[partial_max(originalReplenishmentRunId#3398913L), partial_max(supplierGroup#3398914), partial_max(supplier#3398915), partial_max(supplyingPlant#3398916), partial_max(orderDateTime#3398917), partial_collect_list(itemGroup#3398974, 0, 0), partial_collect_list(parentItems#3398918, 0, 0), partial_collect_set(previousOrderProposals#3398920, 0, 0)])"]; 20 [id="node20" labelType="html" label="ObjectHashAggregate number of output rows: 0 time in aggregation build: 0 ms spill size: 0.0 B number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777], functions=[max(originalReplenishmentRunId#3395778L), max(supplierGroup#3395785), max(supplier#3395786), max(supplyingPlant#3395816), max(orderDateTime#3395793), collect_list(parentItem#3398865, 0, 0), collect_set(previousOrderProposal#3395781L, 0, 0), collect_list(item#3398896, 0, 0)])"]; 21 [id="node21" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, 30), ENSURE_REQUIREMENTS, [plan_id=979446]"]; 22 [id="node22" labelType="html" label="ObjectHashAggregate number of output rows: 0 time in aggregation build: 0 ms spill size: 0.0 B number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777], functions=[partial_max(originalReplenishmentRunId#3395778L), partial_max(supplierGroup#3395785), partial_max(supplier#3395786), partial_max(supplyingPlant#3395816), partial_max(orderDateTime#3395793), partial_collect_list(parentItem#3398865, 0, 0), partial_collect_set(previousOrderProposal#3395781L, 0, 0), partial_collect_list(item#3398896, 0, 0)])"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, orderDateTime#3395793, splitIndicator#3395780L, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865, struct(itemId, orderProposalItemId#3395776, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, deliveryDateTime, deliveryDateTime#3395794, orderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398899.isOrderUnit, lambda x_11242#3398899, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398900.isOrderUnit, lambda x_11242#3398900, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398901.isOrderUnit, lambda x_11242#3398901, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398902.isOrderUnit, lambda x_11242#3398902, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), orderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, ... 13 more fields) AS item#3398896]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, struct(itemId, orderProposalItemId#3395776, itemGroupId, orderProposalItemGroupId#3395777, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, sourceOfSupplyUuid, sourceOfSupplyUuid#3395784, deliveryDateTime, deliveryDateTime#3395794, unitPrice, netPriceAmount#3395803, unitPriceCurrency, netPriceCurrencyCode#3395804, unitPriceQuantity, ... 37 more fields) AS parentItem#3398865]"]; 25 [id="node25" labelType="html" label=" Project " tooltip="Project [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, ... 12 more fields]"]; subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 27 [id="node27" labelType="html" label=" Project " tooltip="Project [shardId#3394574, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, ... 11 more fields]"]; 28 [id="node28" labelType="html" label="Filter number of output rows: 0" tooltip="Filter NOT (isFallbackOrderOnly#3395797 <=> true)"]; } 29 [id="node29" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, ... 14 more fields], [NOT (isFallbackOrderOnly#3395797 <=> true)]"]; subgraph cluster30 { isCluster="true"; id="cluster30"; label="WholeStageCodegen (15)"; tooltip="WholeStageCodegen (15)"; 31 [id="node31" labelType="html" label=" Project " tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 17 more fields]"]; 32 [id="node32" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#3394574, worklistShardItemId#3395327L], [shardId#3398236, worklistShardItemId#3398237L], LeftOuter"]; } subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (12)"; tooltip="WholeStageCodegen (12)"; 34 [id="node34" labelType="html" label=" Project " tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 16 more fields]"]; 35 [id="node35" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#3394574, worklistShardItemId#3395327L], [shardId#3398223, worklistShardItemId#3398224L], LeftOuter"]; } subgraph cluster36 { isCluster="true"; id="cluster36"; label="WholeStageCodegen (9)"; tooltip="WholeStageCodegen (9)"; 37 [id="node37" labelType="html" label=" Project " tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 15 more fields]"]; 38 [id="node38" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#3394574, worklistShardItemId#3395327L], [shardId#3398207, worklistShardItemId#3398208L], LeftOuter"]; } subgraph cluster39 { isCluster="true"; id="cluster39"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 40 [id="node40" labelType="html" label=" Sort " tooltip="Sort [shardId#3394574 ASC NULLS FIRST, worklistShardItemId#3395327L ASC NULLS FIRST], false, 0"]; } 41 [id="node41" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3394574, worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979150]"]; subgraph cluster42 { isCluster="true"; id="cluster42"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 43 [id="node43" labelType="html" label=" Project " tooltip="Project [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, ... 14 more fields]"]; 44 [id="node44" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#3395327L], [worklistShardItemId#3395999L], LeftOuter, (shardId#3394574 = 0_7_10000000532)"]; } subgraph cluster45 { isCluster="true"; id="cluster45"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 46 [id="node46" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#3395327L ASC NULLS FIRST], false, 0"]; } 47 [id="node47" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979131]"]; subgraph cluster48 { isCluster="true"; id="cluster48"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 49 [id="node49" labelType="html" label=" Project " tooltip="Project [shardId#3394574, item#3395326.worklistShardItemId AS worklistShardItemId#3395327L, item#3395326.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395328, item#3395326.qty AS qty#3395329]"]; 50 [id="node50" labelType="html" label=" Generate " tooltip="Generate explode(items#3394576), [shardId#3394574], false, [item#3395326]"]; 51 [id="node51" labelType="html" label=" Filter " tooltip="Filter ((size(items#3394576, true) > 0) AND isnotnull(items#3394576))"]; } 52 [id="node52" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3394574, items#3394576], [(size(items#3394576, true) > 0), isnotnull(items#3394576)]"]; subgraph cluster53 { isCluster="true"; id="cluster53"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 54 [id="node54" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"]; } 55 [id="node55" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]"]; subgraph cluster56 { isCluster="true"; id="cluster56"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 57 [id="node57" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"]; 58 [id="node58" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3394574,orderProposalId#3394575L,items#3394576,optimizationGroups#3394577,isOptimal#3394578,lastModified#3394579,optimizationInsights#3394580]"]; } subgraph cluster59 { isCluster="true"; id="cluster59"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 60 [id="node60" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#3395999L ASC NULLS FIRST], false, 0"]; 61 [id="node61" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, ... 11 more fields]"]; } 62 [id="node62" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#3395999L, 30), REPARTITION_BY_NUM, [plan_id=979141]"]; subgraph cluster63 { isCluster="true"; id="cluster63"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 64 [id="node64" labelType="html" label=" Project " tooltip="Project [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, ... 11 more fields]"]; 65 [id="node65" labelType="html" label=" Filter " tooltip="Filter isnotnull(worklistShardItemId#3395999L)"]; 66 [id="node66" labelType="html" label=" ColumnarToRow " tooltip="ColumnarToRow"]; } 67 [id="node67" labelType="html" label=" Scan parquet " tooltip="FileScan parquet [orderProposalId#3395976L,orderProposalItemId#3395977,supplierGroup#3395978,supplier#3395979,plant#3395980,deliveryDateTime#3395981,subrange#3395982,supplyingPlant#3395983,productGroup#3395984,product#3395985,orderDateTime#3395986,availabilityDateTime#3395987,nextAvailabilityDateTime#3395988,sourceOfSupplyUuid#3395990,isFallbackOrderOnly#3395993,splitIndicator#3395995L,previousOrderProposal#3395996L,worklistShardItemId#3395999L,orderProposalItemGroupId#3396000,externalProductId#3396001,externalPlantId#3396002,logisticUnits#3396003,orderQuantityBaseUom#3396004,orderQuantityBaseUomUuid#3396005,minimumOrderQuantity#3396006,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#3395999L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#3396020), isnotnull(sequenceId#3395998), (shardId#3396020 = 0_7_10000000532), ..., PushedFilters: [IsNotNull(worklistShardItemId)], ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,pla..."]; subgraph cluster68 { isCluster="true"; id="cluster68"; label="WholeStageCodegen (8)"; tooltip="WholeStageCodegen (8)"; 69 [id="node69" labelType="html" label=" Sort " tooltip="Sort [shardId#3398207 ASC NULLS FIRST, worklistShardItemId#3398208L ASC NULLS FIRST], false, 0"]; } 70 [id="node70" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3398207, worklistShardItemId#3398208L, 30), ENSURE_REQUIREMENTS, [plan_id=979156]"]; subgraph cluster71 { isCluster="true"; id="cluster71"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 72 [id="node72" labelType="html" label=" Project " tooltip="Project [shardId#3398207, worklistShardItemId#3398208L, coalesce(kpis#3398212, []) AS prodLocSpecificKpis#3398213]"]; 73 [id="node73" labelType="html" label=" Filter " tooltip="Filter (((isnull(qty#3398209) AND isnull(demandChannel#3398210)) AND isnull(demandStream#3398211)) AND (isnotnull(shardId#3398207) AND isnotnull(worklistShardItemId#3398208L)))"]; 74 [id="node74" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3398207,worklistShardItemId#3398208L,qty#3398209,demandChannel#3398210,demandStream#3398211,kpis#3398212]"]; } subgraph cluster75 { isCluster="true"; id="cluster75"; label="WholeStageCodegen (11)"; tooltip="WholeStageCodegen (11)"; 76 [id="node76" labelType="html" label=" Sort " tooltip="Sort [shardId#3398223 ASC NULLS FIRST, worklistShardItemId#3398224L ASC NULLS FIRST], false, 0"]; } 77 [id="node77" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3398223, worklistShardItemId#3398224L], functions=[collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)])"]; 78 [id="node78" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3398223, worklistShardItemId#3398224L, 30), ENSURE_REQUIREMENTS, [plan_id=979167]"]; 79 [id="node79" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3398223, worklistShardItemId#3398224L], functions=[partial_collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)])"]; subgraph cluster80 { isCluster="true"; id="cluster80"; label="WholeStageCodegen (10)"; tooltip="WholeStageCodegen (10)"; 81 [id="node81" labelType="html" label=" Project " tooltip="Project [shardId#3398223, worklistShardItemId#3398224L, demandChannel#3398226, demandStream#3398227, kpis#3398228]"]; 82 [id="node82" labelType="html" label=" Filter " tooltip="Filter ((((isnull(qty#3398225) AND isnotnull(demandChannel#3398226)) AND isnotnull(demandStream#3398227)) AND (size(kpis#3398228, true) > 0)) AND (isnotnull(shardId#3398223) AND isnotnull(worklistShardItemId#3398224L)))"]; 83 [id="node83" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3398223,worklistShardItemId#3398224L,qty#3398225,demandChannel#3398226,demandStream#3398227,kpis#3398228]"]; } subgraph cluster84 { isCluster="true"; id="cluster84"; label="WholeStageCodegen (14)"; tooltip="WholeStageCodegen (14)"; 85 [id="node85" labelType="html" label=" Sort " tooltip="Sort [shardId#3398236 ASC NULLS FIRST, worklistShardItemId#3398237L ASC NULLS FIRST], false, 0"]; } 86 [id="node86" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3398236, worklistShardItemId#3398237L], functions=[collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)])"]; 87 [id="node87" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3398236, worklistShardItemId#3398237L, 30), ENSURE_REQUIREMENTS, [plan_id=979179]"]; 88 [id="node88" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3398236, worklistShardItemId#3398237L], functions=[partial_collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)])"]; subgraph cluster89 { isCluster="true"; id="cluster89"; label="WholeStageCodegen (13)"; tooltip="WholeStageCodegen (13)"; 90 [id="node90" labelType="html" label=" Project " tooltip="Project [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, kpis#3398241]"]; 91 [id="node91" labelType="html" label=" Filter " tooltip="Filter ((isnotnull(qty#3398238) AND isnotnull(kpis#3398241)) AND (isnotnull(shardId#3398236) AND isnotnull(worklistShardItemId#3398237L)))"]; 92 [id="node92" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3398236,worklistShardItemId#3398237L,qty#3398238,demandChannel#3398239,demandStream#3398240,kpis#3398241]"]; } subgraph cluster93 { isCluster="true"; id="cluster93"; label="WholeStageCodegen (9)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (9)"; 94 [id="node94" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#3399022, ) ASC NULLS FIRST, isnull(shardId#3399022) ASC NULLS FIRST, coalesce(orderProposalId#3399023L, 0) ASC NULLS FIRST, isnull(orderProposalId#3399023L) ASC NULLS FIRST], false, 0"]; } 95 [id="node95" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L), 30), ENSURE_REQUIREMENTS, [plan_id=979492]"]; 96 [id="node96" labelType="html" label=" Project " tooltip="Project [orderProposalId#3399023L, shardId#3399022, coalesce(transform(optimizationGroups#3399025, lambdafunction(struct(optGroupId, lambda x_11246#3399020.optGroupId, minOrderProfile, lambda x_11246#3399020.minOrderProfile, assignmentDetails, lambda x_11246#3399020.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_11246#3399020.minOrderGoal.dimensionType, unit, lambda x_11246#3399020.minOrderGoal.unit, unitUuid, lambda x_11246#3399020.minOrderGoal.unitUuid, goalValue, lambda x_11246#3399020.minOrderGoal.minOrderValue, calcValue, lambda x_11246#3399020.minOrderGoal.calculatedOrderValue), transportLoadProfile, null, transportLoadGoal, null), lambda x_11246#3399020, false)), []) AS optimizationGroups#3399019]"]; subgraph cluster97 { isCluster="true"; id="cluster97"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 98 [id="node98" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [orderProposalId#3399023L], [orderProposalId#3399078L], Inner"]; } subgraph cluster99 { isCluster="true"; id="cluster99"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 100 [id="node100" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [orderProposalId#3399023L ASC NULLS FIRST], false, 0"]; } 101 [id="node101" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(orderProposalId#3399023L, 30), ENSURE_REQUIREMENTS, [plan_id=979458]"]; subgraph cluster102 { isCluster="true"; id="cluster102"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 103 [id="node103" labelType="html" label="Filter number of output rows: 0" tooltip="Filter isnotnull(orderProposalId#3399023L)"]; } 104 [id="node104" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025], [isnotnull(orderProposalId#3399023L)]"]; subgraph cluster105 { isCluster="true"; id="cluster105"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 106 [id="node106" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"]; } 107 [id="node107" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]"]; subgraph cluster108 { isCluster="true"; id="cluster108"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 109 [id="node109" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"]; 110 [id="node110" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3394574,orderProposalId#3394575L,items#3394576,optimizationGroups#3394577,isOptimal#3394578,lastModified#3394579,optimizationInsights#3394580]"]; } subgraph cluster111 { isCluster="true"; id="cluster111"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 112 [id="node112" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [orderProposalId#3399078L ASC NULLS FIRST], false, 0"]; 113 [id="node113" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#3399078L], functions=[])"]; } 114 [id="node114" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(orderProposalId#3399078L, 30), ENSURE_REQUIREMENTS, [plan_id=979483]"]; subgraph cluster115 { isCluster="true"; id="cluster115"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 116 [id="node116" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[orderProposalId#3399078L], functions=[])"]; 117 [id="node117" labelType="html" label=" Project " tooltip="Project [orderProposalId#3399078L]"]; 118 [id="node118" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#3399030L], [worklistShardItemId#3399101L], Inner, BuildLeft, false"]; 132 [id="node132" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#3399101L, orderProposalId#3399078L]"]; } 119 [id="node119" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=979469]"]; subgraph cluster120 { isCluster="true"; id="cluster120"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 121 [id="node121" labelType="html" label=" Project " tooltip="Project [item#3399029L AS worklistShardItemId#3399030L]"]; 122 [id="node122" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_worklistShardItemId#3399670), false, [item#3399029L]"]; 123 [id="node123" labelType="html" label=" Project " tooltip="Project [items#3398651.worklistShardItemId AS _extract_worklistShardItemId#3399670]"]; 124 [id="node124" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (((size(items#3398651.worklistShardItemId, true) > 0) AND isnotnull(items#3398651.worklistShardItemId)) AND (shardId#3398649 = 0_7_10000000532))"]; } 125 [id="node125" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [items#3398651, shardId#3398649], [(size(items#3398651.worklistShardItemId, true) > 0), isnotnull(items#3398651.worklistShardItemId), (shardId#3398649 = 0_7_10000000532)]"]; subgraph cluster126 { isCluster="true"; id="cluster126"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 127 [id="node127" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"]; } 128 [id="node128" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]"]; subgraph cluster129 { isCluster="true"; id="cluster129"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 130 [id="node130" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))"]; 131 [id="node131" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3394574,orderProposalId#3394575L,items#3394576,optimizationGroups#3394577,isOptimal#3394578,lastModified#3394579,optimizationInsights#3394580]"]; } 133 [id="node133" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#3399101L, 30), REPARTITION_BY_NUM, [plan_id=979476]"]; subgraph cluster134 { isCluster="true"; id="cluster134"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 135 [id="node135" labelType="html" label=" Project " tooltip="Project [orderProposalId#3399078L, worklistShardItemId#3399101L]"]; 136 [id="node136" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnotnull(worklistShardItemId#3399101L) AND NOT (isFallbackOrderOnly#3399095 <=> true)) AND isnotnull(orderProposalId#3399078L))"]; 137 [id="node137" labelType="html" label="ColumnarToRow number of output rows: 0 number of input batches: 0" tooltip="ColumnarToRow"]; } 138 [id="node138" labelType="html" label="Scan parquet number of files read: 0 scan time: 0 ms dynamic partition pruning time: 0 ms metadata time: 0 ms size of files read: 0.0 B number of output rows: 0 number of partitions read: 0" tooltip="FileScan parquet [orderProposalId#3399078L,isFallbackOrderOnly#3399095,worklistShardItemId#3399101L,shardId#3399122,sequenceId#3399100] Batched: true, DataFilters: [isnotnull(worklistShardItemId#3399101L), NOT (isFallbackOrderOnly#3399095 <=> true), isnotnull(o..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#3399122), isnotnull(sequenceId#3399100), (shardId#3399122 = 0_7_10000000532), ..., PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderPro..., ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>"]; 2->1; 4->2; 5->4; 6->5; 7->6; 8->7; 9->8; 10->9; 11->10; 12->11; 13->12; 14->13; 15->14; 16->15; 17->16; 18->17; 19->18; 20->19; 21->20; 22->21; 23->22; 24->23; 25->24; 27->25; 28->27; 29->28; 31->29; 32->31; 34->32; 35->34; 37->35; 38->37; 40->38; 41->40; 43->41; 44->43; 46->44; 47->46; 49->47; 50->49; 51->50; 52->51; 54->52; 55->54; 57->55; 58->57; 60->44; 61->60; 62->61; 64->62; 65->64; 66->65; 67->66; 69->38; 70->69; 72->70; 73->72; 74->73; 76->35; 77->76; 78->77; 79->78; 81->79; 82->81; 83->82; 85->32; 86->85; 87->86; 88->87; 90->88; 91->90; 92->91; 94->12; 95->94; 96->95; 98->96; 100->98; 101->100; 103->101; 104->103; 106->104; 107->106; 109->107; 110->109; 112->98; 113->112; 114->113; 116->114; 117->116; 118->117; 119->118; 121->119; 122->121; 123->122; 124->123; 125->124; 127->125; 128->127; 130->128; 131->130; 132->118; 133->132; 135->133; 136->135; 137->136; 138->137; }

Details

== Physical Plan ==
* HashAggregate (106)
+- Exchange (105)
   +- * HashAggregate (104)
      +- InMemoryTableScan (1)
            +- InMemoryRelation (2)
                  +- ObjectHashAggregate (103)
                     +- Exchange (102)
                        +- ObjectHashAggregate (101)
                           +- Project (100)
                              +- InMemoryTableScan (3)
                                    +- InMemoryRelation (4)
                                          +- Project (99)
                                             +- SortMergeJoin LeftOuter (98)
                                                :- Sort (69)
                                                :  +- Exchange (68)
                                                :     +- Project (67)
                                                :        +- Project (66)
                                                :           +- ObjectHashAggregate (65)
                                                :              +- Exchange (64)
                                                :                 +- ObjectHashAggregate (63)
                                                :                    +- ObjectHashAggregate (62)
                                                :                       +- Exchange (61)
                                                :                          +- ObjectHashAggregate (60)
                                                :                             +- Project (59)
                                                :                                +- Project (58)
                                                :                                   +- Project (57)
                                                :                                      +- * Project (56)
                                                :                                         +- * Filter (55)
                                                :                                            +- InMemoryTableScan (5)
                                                :                                                  +- InMemoryRelation (6)
                                                :                                                        +- * Project (54)
                                                :                                                           +- * SortMergeJoin LeftOuter (53)
                                                :                                                              :- * Project (45)
                                                :                                                              :  +- * SortMergeJoin LeftOuter (44)
                                                :                                                              :     :- * Project (36)
                                                :                                                              :     :  +- * SortMergeJoin LeftOuter (35)
                                                :                                                              :     :     :- * Sort (29)
                                                :                                                              :     :     :  +- Exchange (28)
                                                :                                                              :     :     :     +- * Project (27)
                                                :                                                              :     :     :        +- * SortMergeJoin LeftOuter (26)
                                                :                                                              :     :     :           :- * Sort (18)
                                                :                                                              :     :     :           :  +- Exchange (17)
                                                :                                                              :     :     :           :     +- * Project (16)
                                                :                                                              :     :     :           :        +- * Generate (15)
                                                :                                                              :     :     :           :           +- * Filter (14)
                                                :                                                              :     :     :           :              +- InMemoryTableScan (7)
                                                :                                                              :     :     :           :                    +- InMemoryRelation (8)
                                                :                                                              :     :     :           :                          +- * Filter (13)
                                                :                                                              :     :     :           :                             +- InMemoryTableScan (9)
                                                :                                                              :     :     :           :                                   +- InMemoryRelation (10)
                                                :                                                              :     :     :           :                                         +- * Filter (12)
                                                :                                                              :     :     :           :                                            +- * Scan ExistingRDD (11)
                                                :                                                              :     :     :           +- * Sort (25)
                                                :                                                              :     :     :              +- * Project (24)
                                                :                                                              :     :     :                 +- Exchange (23)
                                                :                                                              :     :     :                    +- * Project (22)
                                                :                                                              :     :     :                       +- * Filter (21)
                                                :                                                              :     :     :                          +- * ColumnarToRow (20)
                                                :                                                              :     :     :                             +- Scan parquet  (19)
                                                :                                                              :     :     +- * Sort (34)
                                                :                                                              :     :        +- Exchange (33)
                                                :                                                              :     :           +- * Project (32)
                                                :                                                              :     :              +- * Filter (31)
                                                :                                                              :     :                 +- * Scan ExistingRDD (30)
                                                :                                                              :     +- * Sort (43)
                                                :                                                              :        +- ObjectHashAggregate (42)
                                                :                                                              :           +- Exchange (41)
                                                :                                                              :              +- ObjectHashAggregate (40)
                                                :                                                              :                 +- * Project (39)
                                                :                                                              :                    +- * Filter (38)
                                                :                                                              :                       +- * Scan ExistingRDD (37)
                                                :                                                              +- * Sort (52)
                                                :                                                                 +- ObjectHashAggregate (51)
                                                :                                                                    +- Exchange (50)
                                                :                                                                       +- ObjectHashAggregate (49)
                                                :                                                                          +- * Project (48)
                                                :                                                                             +- * Filter (47)
                                                :                                                                                +- * Scan ExistingRDD (46)
                                                +- * Sort (97)
                                                   +- Exchange (96)
                                                      +- Project (95)
                                                         +- * SortMergeJoin Inner (94)
                                                            :- * Sort (74)
                                                            :  +- Exchange (73)
                                                            :     +- * Filter (72)
                                                            :        +- InMemoryTableScan (70)
                                                            :              +- InMemoryRelation (71)
                                                            :                    +- * Filter (13)
                                                            :                       +- InMemoryTableScan (9)
                                                            :                             +- InMemoryRelation (10)
                                                            :                                   +- * Filter (12)
                                                            :                                      +- * Scan ExistingRDD (11)
                                                            +- * Sort (93)
                                                               +- * HashAggregate (92)
                                                                  +- Exchange (91)
                                                                     +- * HashAggregate (90)
                                                                        +- * Project (89)
                                                                           +- * BroadcastHashJoin Inner BuildLeft (88)
                                                                              :- BroadcastExchange (81)
                                                                              :  +- * Project (80)
                                                                              :     +- * Generate (79)
                                                                              :        +- * Project (78)
                                                                              :           +- * Filter (77)
                                                                              :              +- InMemoryTableScan (75)
                                                                              :                    +- InMemoryRelation (76)
                                                                              :                          +- * Filter (13)
                                                                              :                             +- InMemoryTableScan (9)
                                                                              :                                   +- InMemoryRelation (10)
                                                                              :                                         +- * Filter (12)
                                                                              :                                            +- * Scan ExistingRDD (11)
                                                                              +- * Project (87)
                                                                                 +- Exchange (86)
                                                                                    +- * Project (85)
                                                                                       +- * Filter (84)
                                                                                          +- * ColumnarToRow (83)
                                                                                             +- Scan parquet  (82)


(1) InMemoryTableScan
Output: []

(2) InMemoryRelation
Arguments: [shardId#3394574, resultSeparationId#3406319L, orderProposals#3406323], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [2]: [orderProposal#3399126, shardId#3394574]
Arguments: [orderProposal#3399126, shardId#3394574]

(4) InMemoryRelation
Arguments: [shardId#3394574, orderProposal#3399126], StorageLevel(disk, memory, 2 replicas)

(5) InMemoryTableScan
Output [39]: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, product#3395788, productGroup#3395817, qty#3395329, quantityAfterProdPlantOptimization#3395328, quantityKpis#3398242, shardId#3394574, sourceOfSupplyUuid#3395784, splitIndicator#3395780L, subrange#3395787, supplier#3395786, supplierGroup#3395785, supplyingPlant#3395816]
Arguments: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, ... 14 more fields], [NOT (isFallbackOrderOnly#3395797 <=> true)]

(6) InMemoryRelation
Arguments: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, constraintValues#3395810, constraintOperators#3395808, constraintLabels#3395807, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)

(7) InMemoryTableScan
Output [2]: [shardId#3394574, items#3394576]
Arguments: [shardId#3394574, items#3394576], [(size(items#3394576, true) > 0), isnotnull(items#3394576)]

(8) InMemoryRelation
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], StorageLevel(disk, memory, 2 replicas)

(9) InMemoryTableScan
Output [6]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580]
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580], [isnotnull(shardId#3394574), (shardId#3394574 = 0_7_10000000532)]

(10) InMemoryRelation
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580], StorageLevel(disk, memory, 2 replicas)

(11) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580]
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580], MapPartitionsRDD[144316] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(12) Filter [codegen id : 1]
Input [7]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580]
Condition : (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))

(13) Filter [codegen id : 1]
Input [6]: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580]
Condition : (isnotnull(shardId#3394574) AND (shardId#3394574 = 0_7_10000000532))

(14) Filter [codegen id : 1]
Input [2]: [shardId#3394574, items#3394576]
Condition : ((size(items#3394576, true) > 0) AND isnotnull(items#3394576))

(15) Generate [codegen id : 1]
Input [2]: [shardId#3394574, items#3394576]
Arguments: explode(items#3394576), [shardId#3394574], false, [item#3395326]

(16) Project [codegen id : 1]
Output [4]: [shardId#3394574, item#3395326.worklistShardItemId AS worklistShardItemId#3395327L, item#3395326.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395328, item#3395326.qty AS qty#3395329]
Input [2]: [shardId#3394574, item#3395326]

(17) Exchange
Input [4]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329]
Arguments: hashpartitioning(worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979131]

(18) Sort [codegen id : 2]
Input [4]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329]
Arguments: [worklistShardItemId#3395327L ASC NULLS FIRST], false, 0

(19) Scan parquet 
Output [38]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532]
PartitionFilters: [isnotnull(shardId#3396020), isnotnull(sequenceId#3395998), (shardId#3396020 = 0_7_10000000532), (sequenceId#3395998 = 6)]
PushedFilters: [IsNotNull(worklistShardItemId)]
ReadSchema: struct<orderProposalId:bigint,orderProposalItemId:string,supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,supplyingPlant:string,productGroup:string,product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,sourceOfSupplyUuid:string,isFallbackOrderOnly:boolean,splitIndicator:bigint,previousOrderProposal:bigint,worklistShardItemId:bigint,orderProposalItemGroupId:string,externalProductId:string,externalPlantId:string,logisticUnits:array<struct<uom:string,uomUuid:string,numerator:int,denominator:int,isOrderUnit:boolean,isPreferred:boolean>>,orderQuantityBaseUom:string,orderQuantityBaseUomUuid:string,minimumOrderQuantity:double,constraintLabels:array<string>,constraintOperators:array<string>,constraintValues:array<double>,netPriceAmount:double,netPriceCurrencyCode:string,netPriceQuantity:double,netPriceQuantityUom:string,netPriceQuantityUomUuid:string,measurements:array<struct<value:double,dimensionType:int,dimensionCode:string,dimensionCodeUuid:string,isoCode:string>>,originalReplenishmentRunId:bigint,optimizationGroups:array<string>>

(20) ColumnarToRow [codegen id : 3]
Input [38]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]

(21) Filter [codegen id : 3]
Input [38]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]
Condition : isnotnull(worklistShardItemId#3395999L)

(22) Project [codegen id : 3]
Output [36]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019]
Input [38]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019, shardId#3396020, sequenceId#3395998]

(23) Exchange
Input [36]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019]
Arguments: hashpartitioning(worklistShardItemId#3395999L, 30), REPARTITION_BY_NUM, [plan_id=979141]

(24) Project [codegen id : 4]
Output [36]: [worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, measurements#3396017, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, logisticUnits#3396003, optimizationGroups#3396019, externalProductId#3396001, externalPlantId#3396002, supplyingPlant#3395983, productGroup#3395984]
Input [36]: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, sourceOfSupplyUuid#3395990, isFallbackOrderOnly#3395993, splitIndicator#3395995L, previousOrderProposal#3395996L, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, externalProductId#3396001, externalPlantId#3396002, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, measurements#3396017, originalReplenishmentRunId#3396018L, optimizationGroups#3396019]

(25) Sort [codegen id : 4]
Input [36]: [worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, measurements#3396017, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, logisticUnits#3396003, optimizationGroups#3396019, externalProductId#3396001, externalPlantId#3396002, supplyingPlant#3395983, productGroup#3395984]
Arguments: [worklistShardItemId#3395999L ASC NULLS FIRST], false, 0

(26) SortMergeJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#3395327L]
Right keys [1]: [worklistShardItemId#3395999L]
Join type: LeftOuter
Join condition: (shardId#3394574 = 0_7_10000000532)

(27) Project [codegen id : 5]
Output [39]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993]
Input [40]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, splitIndicator#3395995L, previousOrderProposal#3395996L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, netPriceAmount#3396012, netPriceCurrencyCode#3396013, measurements#3396017, minimumOrderQuantity#3396006, constraintLabels#3396007, constraintOperators#3396008, constraintValues#3396009, logisticUnits#3396003, optimizationGroups#3396019, externalProductId#3396001, externalPlantId#3396002, supplyingPlant#3395983, productGroup#3395984]

(28) Exchange
Input [39]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993]
Arguments: hashpartitioning(shardId#3394574, worklistShardItemId#3395327L, 30), ENSURE_REQUIREMENTS, [plan_id=979150]

(29) Sort [codegen id : 6]
Input [39]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993]
Arguments: [shardId#3394574 ASC NULLS FIRST, worklistShardItemId#3395327L ASC NULLS FIRST], false, 0

(30) Scan ExistingRDD [codegen id : 7]
Output [6]: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212]
Arguments: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212], MapPartitionsRDD[144530] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(31) Filter [codegen id : 7]
Input [6]: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212]
Condition : (((isnull(qty#3398209) AND isnull(demandChannel#3398210)) AND isnull(demandStream#3398211)) AND (isnotnull(shardId#3398207) AND isnotnull(worklistShardItemId#3398208L)))

(32) Project [codegen id : 7]
Output [3]: [shardId#3398207, worklistShardItemId#3398208L, coalesce(kpis#3398212, []) AS prodLocSpecificKpis#3398213]
Input [6]: [shardId#3398207, worklistShardItemId#3398208L, qty#3398209, demandChannel#3398210, demandStream#3398211, kpis#3398212]

(33) Exchange
Input [3]: [shardId#3398207, worklistShardItemId#3398208L, prodLocSpecificKpis#3398213]
Arguments: hashpartitioning(shardId#3398207, worklistShardItemId#3398208L, 30), ENSURE_REQUIREMENTS, [plan_id=979156]

(34) Sort [codegen id : 8]
Input [3]: [shardId#3398207, worklistShardItemId#3398208L, prodLocSpecificKpis#3398213]
Arguments: [shardId#3398207 ASC NULLS FIRST, worklistShardItemId#3398208L ASC NULLS FIRST], false, 0

(35) SortMergeJoin [codegen id : 9]
Left keys [2]: [shardId#3394574, worklistShardItemId#3395327L]
Right keys [2]: [shardId#3398207, worklistShardItemId#3398208L]
Join type: LeftOuter
Join condition: None

(36) Project [codegen id : 9]
Output [40]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, coalesce(prodLocSpecificKpis#3398213, []) AS prodLocSpecificKpis#3398214]
Input [42]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, shardId#3398207, worklistShardItemId#3398208L, prodLocSpecificKpis#3398213]

(37) Scan ExistingRDD [codegen id : 10]
Output [6]: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Arguments: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228], MapPartitionsRDD[144530] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(38) Filter [codegen id : 10]
Input [6]: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Condition : ((((isnull(qty#3398225) AND isnotnull(demandChannel#3398226)) AND isnotnull(demandStream#3398227)) AND (size(kpis#3398228, true) > 0)) AND (isnotnull(shardId#3398223) AND isnotnull(worklistShardItemId#3398224L)))

(39) Project [codegen id : 10]
Output [5]: [shardId#3398223, worklistShardItemId#3398224L, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Input [6]: [shardId#3398223, worklistShardItemId#3398224L, qty#3398225, demandChannel#3398226, demandStream#3398227, kpis#3398228]

(40) ObjectHashAggregate
Input [5]: [shardId#3398223, worklistShardItemId#3398224L, demandChannel#3398226, demandStream#3398227, kpis#3398228]
Keys [2]: [shardId#3398223, worklistShardItemId#3398224L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)]
Aggregate Attributes [1]: [buf#3398403]
Results [3]: [shardId#3398223, worklistShardItemId#3398224L, buf#3398404]

(41) Exchange
Input [3]: [shardId#3398223, worklistShardItemId#3398224L, buf#3398404]
Arguments: hashpartitioning(shardId#3398223, worklistShardItemId#3398224L, 30), ENSURE_REQUIREMENTS, [plan_id=979167]

(42) ObjectHashAggregate
Input [3]: [shardId#3398223, worklistShardItemId#3398224L, buf#3398404]
Keys [2]: [shardId#3398223, worklistShardItemId#3398224L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)#3398222]
Results [3]: [shardId#3398223, worklistShardItemId#3398224L, collect_list(struct(demandChannel, demandChannel#3398226, demandStream, demandStream#3398227, kpis, kpis#3398228), 0, 0)#3398222 AS channelStreamSpecificKpis#3398215]

(43) Sort [codegen id : 11]
Input [3]: [shardId#3398223, worklistShardItemId#3398224L, channelStreamSpecificKpis#3398215]
Arguments: [shardId#3398223 ASC NULLS FIRST, worklistShardItemId#3398224L ASC NULLS FIRST], false, 0

(44) SortMergeJoin [codegen id : 12]
Left keys [2]: [shardId#3394574, worklistShardItemId#3395327L]
Right keys [2]: [shardId#3398223, worklistShardItemId#3398224L]
Join type: LeftOuter
Join condition: None

(45) Project [codegen id : 12]
Output [41]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, coalesce(channelStreamSpecificKpis#3398215, []) AS channelStreamSpecificKpis#3398229]
Input [43]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, shardId#3398223, worklistShardItemId#3398224L, channelStreamSpecificKpis#3398215]

(46) Scan ExistingRDD [codegen id : 13]
Output [6]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241]
Arguments: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241], MapPartitionsRDD[144530] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(47) Filter [codegen id : 13]
Input [6]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241]
Condition : ((isnotnull(qty#3398238) AND isnotnull(kpis#3398241)) AND (isnotnull(shardId#3398236) AND isnotnull(worklistShardItemId#3398237L)))

(48) Project [codegen id : 13]
Output [4]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, kpis#3398241]
Input [6]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, demandChannel#3398239, demandStream#3398240, kpis#3398241]

(49) ObjectHashAggregate
Input [4]: [shardId#3398236, worklistShardItemId#3398237L, qty#3398238, kpis#3398241]
Keys [2]: [shardId#3398236, worklistShardItemId#3398237L]
Functions [1]: [partial_collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)]
Aggregate Attributes [1]: [buf#3398405]
Results [3]: [shardId#3398236, worklistShardItemId#3398237L, buf#3398406]

(50) Exchange
Input [3]: [shardId#3398236, worklistShardItemId#3398237L, buf#3398406]
Arguments: hashpartitioning(shardId#3398236, worklistShardItemId#3398237L, 30), ENSURE_REQUIREMENTS, [plan_id=979179]

(51) ObjectHashAggregate
Input [3]: [shardId#3398236, worklistShardItemId#3398237L, buf#3398406]
Keys [2]: [shardId#3398236, worklistShardItemId#3398237L]
Functions [1]: [collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)#3398235]
Results [3]: [shardId#3398236, worklistShardItemId#3398237L, map_from_entries(collect_list(struct(qty, qty#3398238, kpis, kpis#3398241), 0, 0)#3398235) AS quantityKpis#3398230]

(52) Sort [codegen id : 14]
Input [3]: [shardId#3398236, worklistShardItemId#3398237L, quantityKpis#3398230]
Arguments: [shardId#3398236 ASC NULLS FIRST, worklistShardItemId#3398237L ASC NULLS FIRST], false, 0

(53) SortMergeJoin [codegen id : 15]
Left keys [2]: [shardId#3394574, worklistShardItemId#3395327L]
Right keys [2]: [shardId#3398236, worklistShardItemId#3398237L]
Join type: LeftOuter
Join condition: None

(54) Project [codegen id : 15]
Output [42]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, coalesce(quantityKpis#3398230, map(keys: [], values: [])) AS quantityKpis#3398242]
Input [44]: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395976L, originalReplenishmentRunId#3396018L, supplierGroup#3395978, supplier#3395979, supplyingPlant#3395983, productGroup#3395984, product#3395985, plant#3395980, subrange#3395982, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, constraintValues#3396009, constraintOperators#3396008, constraintLabels#3396007, logisticUnits#3396003, orderQuantityBaseUom#3396004, orderQuantityBaseUomUuid#3396005, splitIndicator#3395995L, netPriceAmount#3396012, netPriceCurrencyCode#3396013, netPriceQuantity#3396014, netPriceQuantityUom#3396015, netPriceQuantityUomUuid#3396016, sourceOfSupplyUuid#3395990, minimumOrderQuantity#3396006, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, optimizationGroups#3396019, measurements#3396017, externalProductId#3396001, externalPlantId#3396002, previousOrderProposal#3395996L, isFallbackOrderOnly#3395993, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, shardId#3398236, worklistShardItemId#3398237L, quantityKpis#3398230]

(55) Filter [codegen id : 1]
Input [39]: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, product#3395788, productGroup#3395817, qty#3395329, quantityAfterProdPlantOptimization#3395328, quantityKpis#3398242, shardId#3394574, sourceOfSupplyUuid#3395784, splitIndicator#3395780L, subrange#3395787, supplier#3395786, supplierGroup#3395785, supplyingPlant#3395816]
Condition : NOT (isFallbackOrderOnly#3395797 <=> true)

(56) Project [codegen id : 1]
Output [36]: [shardId#3394574, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, minimumOrderQuantity#3395806, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, arrays_zip(constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#3398656]
Input [39]: [availabilityDateTime#3395795, channelStreamSpecificKpis#3398229, constraintLabels#3395807, constraintOperators#3395808, constraintValues#3395810, deliveryDateTime#3395794, isFallbackOrderOnly#3395797, logisticUnits#3395812, measurements#3395805, minimumOrderQuantity#3395806, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, nextAvailabilityDateTime#3395796, optimizationGroups#3395813, orderDateTime#3395793, orderProposalId#3395775L, orderProposalItemGroupId#3395777, orderProposalItemId#3395776, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, originalReplenishmentRunId#3395778L, plant#3395789, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, product#3395788, productGroup#3395817, qty#3395329, quantityAfterProdPlantOptimization#3395328, quantityKpis#3398242, shardId#3394574, sourceOfSupplyUuid#3395784, splitIndicator#3395780L, subrange#3395787, supplier#3395786, supplierGroup#3395785, supplyingPlant#3395816]

(57) Project
Output [37]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, struct(minServiceLevel, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11192#3398663.constraintLabels = ServiceLevel), lambda x_11192#3398663, false)).constraintValues), minServiceLevelMinStock, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11193#3398664.constraintLabels = ServiceLevelMinimumStock), lambda x_11193#3398664, false)).constraintValues), maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11194#3398665.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_11194#3398665, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#3398656, lambdafunction((lambda x_11195#3398666.constraintLabels = RangeOfCoverage), lambda x_11195#3398666, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#3395806, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#3398214, lambdafunction((lambda x_11196#3398667.label = NonListingStartTimestamp), lambda x_11196#3398667, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#3398662, CASE WHEN (qty#3395329 <=> quantityAfterProdPlantOptimization#3395328) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398735.isOrderUnit, lambda x_11197#3398735, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398736.isOrderUnit, lambda x_11197#3398736, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398737.isOrderUnit, lambda x_11197#3398737, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398738.isOrderUnit, lambda x_11197#3398738, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), candidateOrderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3395799, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398739.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398739.denominator as double)) % cast(lambda x_11199#3398739.numerator as double)) = 0.0)), lambda x_11199#3398739, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398780.denominator as double)) / cast(lambda x_11200#3398780.numerator as double)), uom, lambda x_11200#3398780.uom, uomUuid, lambda x_11200#3398780.uomUuid), lambda x_11200#3398780, false))).inPreferredQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398740.isOrderUnit, lambda x_11198#3398740, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398741.isOrderUnit, lambda x_11198#3398741, false)), 1, None, false).numerator as double))), qty#3395329)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398742.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398742.denominator as double)) % cast(lambda x_11199#3398742.numerator as double)) = 0.0)), lambda x_11199#3398742, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398781.denominator as double)) / cast(lambda x_11200#3398781.numerator as double)), uom, lambda x_11200#3398781.uom, uomUuid, lambda x_11200#3398781.uomUuid), lambda x_11200#3398781, false))).uom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398743.isOrderUnit, lambda x_11198#3398743, false)), 1, None, false).uom, orderQuantityBaseUom#3395798)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398744.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398744.denominator as double)) % cast(lambda x_11199#3398744.numerator as double)) = 0.0)), lambda x_11199#3398744, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398782.denominator as double)) / cast(lambda x_11200#3398782.numerator as double)), uom, lambda x_11200#3398782.uom, uomUuid, lambda x_11200#3398782.uomUuid), lambda x_11200#3398782, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398745.isOrderUnit, lambda x_11198#3398745, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799)), serviceLevel, coalesce(filter(element_at(quantityKpis#3398242, qty#3395329, None, false), lambdafunction((lambda x_11205#3398746.label = ServiceLevel), lambda x_11205#3398746, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398750.isOrderUnit, lambda x_11197#3398750, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398751.isOrderUnit, lambda x_11197#3398751, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398752.isOrderUnit, lambda x_11197#3398752, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11197#3398753.isOrderUnit, lambda x_11197#3398753, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), candidateOrderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3395799, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398754.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398754.denominator as double)) % cast(lambda x_11199#3398754.numerator as double)) = 0.0)), lambda x_11199#3398754, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398783.denominator as double)) / cast(lambda x_11200#3398783.numerator as double)), uom, lambda x_11200#3398783.uom, uomUuid, lambda x_11200#3398783.uomUuid), lambda x_11200#3398783, false))).inPreferredQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398755.isOrderUnit, lambda x_11198#3398755, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398756.isOrderUnit, lambda x_11198#3398756, false)), 1, None, false).numerator as double))), qty#3395329)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398757.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398757.denominator as double)) % cast(lambda x_11199#3398757.numerator as double)) = 0.0)), lambda x_11199#3398757, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398784.denominator as double)) / cast(lambda x_11200#3398784.numerator as double)), uom, lambda x_11200#3398784.uom, uomUuid, lambda x_11200#3398784.uomUuid), lambda x_11200#3398784, false))).uom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398758.isOrderUnit, lambda x_11198#3398758, false)), 1, None, false).uom, orderQuantityBaseUom#3395798)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11199#3398759.isPreferred AND (((qty#3395329 * cast(lambda x_11199#3398759.denominator as double)) % cast(lambda x_11199#3398759.numerator as double)) = 0.0)), lambda x_11199#3398759, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395329 * cast(lambda x_11200#3398785.denominator as double)) / cast(lambda x_11200#3398785.numerator as double)), uom, lambda x_11200#3398785.uom, uomUuid, lambda x_11200#3398785.uomUuid), lambda x_11200#3398785, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11198#3398760.isOrderUnit, lambda x_11198#3398760, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799)), serviceLevel, coalesce(filter(element_at(quantityKpis#3398242, qty#3395329, None, false), lambdafunction((lambda x_11209#3398761.label = ServiceLevel), lambda x_11209#3398761, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#3395328 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398765.isOrderUnit, lambda x_11201#3398765, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398766.isOrderUnit, lambda x_11201#3398766, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#3395328), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398767.isOrderUnit, lambda x_11201#3398767, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11201#3398768.isOrderUnit, lambda x_11201#3398768, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#3395328, orderQuantityBaseUom, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3395799, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11203#3398769.isPreferred AND (((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11203#3398769.denominator as double)) % cast(lambda x_11203#3398769.numerator as double)) = 0.0)), lambda x_11203#3398769, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11204#3398786.denominator as double)) / cast(lambda x_11204#3398786.numerator as double)), uom, lambda x_11204#3398786.uom, uomUuid, lambda x_11204#3398786.uomUuid), lambda x_11204#3398786, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#3395328 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398770.isOrderUnit, lambda x_11202#3398770, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398771.isOrderUnit, lambda x_11202#3398771, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#3395328)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11203#3398772.isPreferred AND (((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11203#3398772.denominator as double)) % cast(lambda x_11203#3398772.numerator as double)) = 0.0)), lambda x_11203#3398772, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11204#3398787.denominator as double)) / cast(lambda x_11204#3398787.numerator as double)), uom, lambda x_11204#3398787.uom, uomUuid, lambda x_11204#3398787.uomUuid), lambda x_11204#3398787, false))).uom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398773.isOrderUnit, lambda x_11202#3398773, false)), 1, None, false).uom, orderQuantityBaseUom#3395798)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3395812, lambdafunction((lambda x_11203#3398774.isPreferred AND (((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11203#3398774.denominator as double)) % cast(lambda x_11203#3398774.numerator as double)) = 0.0)), lambda x_11203#3398774, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395328 * cast(lambda x_11204#3398788.denominator as double)) / cast(lambda x_11204#3398788.numerator as double)), uom, lambda x_11204#3398788.uom, uomUuid, lambda x_11204#3398788.uomUuid), lambda x_11204#3398788, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11202#3398775.isOrderUnit, lambda x_11202#3398775, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799)), serviceLevel, coalesce(filter(element_at(quantityKpis#3398242, quantityAfterProdPlantOptimization#3395328, None, false), lambdafunction((lambda x_11213#3398776.label = ServiceLevel), lambda x_11213#3398776, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#3398734, coalesce(filter(prodLocSpecificKpis#3398214, lambdafunction((lambda x_11217#3398790.label = InitialStockQty), lambda x_11217#3398790, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#3398789, coalesce(filter(prodLocSpecificKpis#3398214, lambdafunction((lambda x_11218#3398792.label = DemandPeriodEndTimestamp), lambda x_11218#3398792, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#3398791]
Input [36]: [shardId#3394574, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, minimumOrderQuantity#3395806, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, constraintStructArray#3398656]

(58) Project
Output [21]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, struct(itemId, orderProposalItemId#3395776, itemGroupId, orderProposalItemGroupId#3395777, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, sourceOfSupplyUuid, sourceOfSupplyUuid#3395784, deliveryDateTime, deliveryDateTime#3395794, unitPrice, netPriceAmount#3395803, unitPriceCurrency, netPriceCurrencyCode#3395804, unitPriceQuantity, ... 37 more fields) AS parentItem#3398865]
Input [37]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, netPriceCurrencyCode#3395804, netPriceQuantity#3395800, netPriceQuantityUom#3395801, netPriceQuantityUomUuid#3395802, sourceOfSupplyUuid#3395784, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, optimizationGroups#3395813, measurements#3395805, previousOrderProposal#3395781L, prodLocSpecificKpis#3398214, channelStreamSpecificKpis#3398229, quantityKpis#3398242, constraintBenchmark#3398662, calculationAnalysis#3398734, inventoryDateTime#3398789, demandPeriodEndDateTime#3398791]

(59) Project
Output [12]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, orderDateTime#3395793, splitIndicator#3395780L, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865, struct(itemId, orderProposalItemId#3395776, supplier, supplier#3395786, supplyingPlant, supplyingPlant#3395816, productGroup, productGroup#3395817, product, product#3395788, plant, plant#3395789, supplierSubRange, subrange#3395787, deliveryDateTime, deliveryDateTime#3395794, orderQuantity, coalesce((qty#3395329 * (cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398899.isOrderUnit, lambda x_11242#3398899, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398900.isOrderUnit, lambda x_11242#3398900, false)), 1, None, false).numerator as double))), qty#3395329), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398901.isOrderUnit, lambda x_11242#3398901, false)), 1, None, false).uom, orderQuantityBaseUom#3395798), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3395812, lambdafunction(lambda x_11242#3398902.isOrderUnit, lambda x_11242#3398902, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3395799), orderQuantityInBaseUnit, qty#3395329, orderQuantityBaseUom, ... 13 more fields) AS item#3398896]
Input [21]: [shardId#3394574, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865]

(60) ObjectHashAggregate
Input [12]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, orderDateTime#3395793, splitIndicator#3395780L, orderProposalItemGroupId#3395777, previousOrderProposal#3395781L, parentItem#3398865, item#3398896]
Keys [4]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777]
Functions [8]: [partial_max(originalReplenishmentRunId#3395778L), partial_max(supplierGroup#3395785), partial_max(supplier#3395786), partial_max(supplyingPlant#3395816), partial_max(orderDateTime#3395793), partial_collect_list(parentItem#3398865, 0, 0), partial_collect_set(previousOrderProposal#3395781L, 0, 0), partial_collect_list(item#3398896, 0, 0)]
Aggregate Attributes [8]: [max#3400329L, max#3400330, max#3400331, max#3400332, max#3400333, buf#3400334, buf#3400335, buf#3400336]
Results [12]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, max#3400337L, max#3400338, max#3400339, max#3400340, max#3400341, buf#3400342, buf#3400343, buf#3400344]

(61) Exchange
Input [12]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, max#3400337L, max#3400338, max#3400339, max#3400340, max#3400341, buf#3400342, buf#3400343, buf#3400344]
Arguments: hashpartitioning(shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, 30), ENSURE_REQUIREMENTS, [plan_id=979446]

(62) ObjectHashAggregate
Input [12]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777, max#3400337L, max#3400338, max#3400339, max#3400340, max#3400341, buf#3400342, buf#3400343, buf#3400344]
Keys [4]: [shardId#3394574, orderProposalId#3395775L, splitIndicator#3395780L, orderProposalItemGroupId#3395777]
Functions [8]: [max(originalReplenishmentRunId#3395778L), max(supplierGroup#3395785), max(supplier#3395786), max(supplyingPlant#3395816), max(orderDateTime#3395793), collect_list(parentItem#3398865, 0, 0), collect_set(previousOrderProposal#3395781L, 0, 0), collect_list(item#3398896, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#3395778L)#3398965L, max(supplierGroup#3395785)#3398966, max(supplier#3395786)#3398967, max(supplyingPlant#3395816)#3398968, max(orderDateTime#3395793)#3398969, collect_list(parentItem#3398865, 0, 0)#3398970, collect_set(previousOrderProposal#3395781L, 0, 0)#3398972, collect_list(item#3398896, 0, 0)#3398971]
Results [10]: [shardId#3394574, orderProposalId#3395775L, max(originalReplenishmentRunId#3395778L)#3398965L AS originalReplenishmentRunId#3398913L, max(supplierGroup#3395785)#3398966 AS supplierGroup#3398914, max(supplier#3395786)#3398967 AS supplier#3398915, max(supplyingPlant#3395816)#3398968 AS supplyingPlant#3398916, max(orderDateTime#3395793)#3398969 AS orderDateTime#3398917, collect_list(parentItem#3398865, 0, 0)#3398970 AS parentItems#3398918, collect_set(previousOrderProposal#3395781L, 0, 0)#3398972 AS previousOrderProposals#3398920, struct(itemGroupId, orderProposalItemGroupId#3395777, items, collect_list(item#3398896, 0, 0)#3398971) AS itemGroup#3398974]

(63) ObjectHashAggregate
Input [10]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3398913L, supplierGroup#3398914, supplier#3398915, supplyingPlant#3398916, orderDateTime#3398917, parentItems#3398918, previousOrderProposals#3398920, itemGroup#3398974]
Keys [2]: [shardId#3394574, orderProposalId#3395775L]
Functions [8]: [partial_max(originalReplenishmentRunId#3398913L), partial_max(supplierGroup#3398914), partial_max(supplier#3398915), partial_max(supplyingPlant#3398916), partial_max(orderDateTime#3398917), partial_collect_list(itemGroup#3398974, 0, 0), partial_collect_list(parentItems#3398918, 0, 0), partial_collect_set(previousOrderProposals#3398920, 0, 0)]
Aggregate Attributes [8]: [max#3400313L, max#3400314, max#3400315, max#3400316, max#3400317, buf#3400318, buf#3400319, buf#3400320]
Results [10]: [shardId#3394574, orderProposalId#3395775L, max#3400321L, max#3400322, max#3400323, max#3400324, max#3400325, buf#3400326, buf#3400327, buf#3400328]

(64) Exchange
Input [10]: [shardId#3394574, orderProposalId#3395775L, max#3400321L, max#3400322, max#3400323, max#3400324, max#3400325, buf#3400326, buf#3400327, buf#3400328]
Arguments: hashpartitioning(shardId#3394574, orderProposalId#3395775L, 30), ENSURE_REQUIREMENTS, [plan_id=979449]

(65) ObjectHashAggregate
Input [10]: [shardId#3394574, orderProposalId#3395775L, max#3400321L, max#3400322, max#3400323, max#3400324, max#3400325, buf#3400326, buf#3400327, buf#3400328]
Keys [2]: [shardId#3394574, orderProposalId#3395775L]
Functions [8]: [max(originalReplenishmentRunId#3398913L), max(supplierGroup#3398914), max(supplier#3398915), max(supplyingPlant#3398916), max(orderDateTime#3398917), collect_list(itemGroup#3398974, 0, 0), collect_list(parentItems#3398918, 0, 0), collect_set(previousOrderProposals#3398920, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#3398913L)#3398996L, max(supplierGroup#3398914)#3398997, max(supplier#3398915)#3398998, max(supplyingPlant#3398916)#3398999, max(orderDateTime#3398917)#3399000, collect_list(itemGroup#3398974, 0, 0)#3399001, collect_list(parentItems#3398918, 0, 0)#3399002, collect_set(previousOrderProposals#3398920, 0, 0)#3399003]
Results [10]: [shardId#3394574, orderProposalId#3395775L, max(originalReplenishmentRunId#3398913L)#3398996L AS originalReplenishmentRunId#3398975L, max(supplierGroup#3398914)#3398997 AS supplierGroup#3398976, max(supplier#3398915)#3398998 AS supplier#3398977, max(supplyingPlant#3398916)#3398999 AS supplyingPlant#3398978, max(orderDateTime#3398917)#3399000 AS orderDateTime#3398979, collect_list(itemGroup#3398974, 0, 0)#3399001 AS itemGroups#3398980, flatten(collect_list(parentItems#3398918, 0, 0)#3399002) AS parentItems#3398981, flatten(collect_set(previousOrderProposals#3398920, 0, 0)#3399003) AS previousOrderProposals#3398982]

(66) Project
Output [2]: [shardId#3394574, struct(orderProposalId, orderProposalId#3395775L, originalReplenishmentRunId, originalReplenishmentRunId#3398975L, supplierGroup, supplierGroup#3398976, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#3398976) THEN supplier#3398977 END, supplyingPlant, supplyingPlant#3398978, orderDateTime, orderDateTime#3398979, itemGroups, itemGroups#3398980, previousOrderProposals, array_distinct(previousOrderProposals#3398982), parentItems, parentItems#3398981) AS orderProposal#3399007]
Input [10]: [shardId#3394574, orderProposalId#3395775L, originalReplenishmentRunId#3398975L, supplierGroup#3398976, supplier#3398977, supplyingPlant#3398978, orderDateTime#3398979, itemGroups#3398980, parentItems#3398981, previousOrderProposals#3398982]

(67) Project
Output [11]: [shardId#3394574, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399945L, orderProposal#3399007.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#3399946L, orderProposal#3399007.supplierGroup AS _extract_supplierGroup#3399947, orderProposal#3399007.supplier AS _extract_supplier#3399948, orderProposal#3399007.supplyingPlant AS _extract_supplyingPlant#3399949, orderProposal#3399007.orderDateTime AS _extract_orderDateTime#3399950, orderProposal#3399007.itemGroups AS _extract_itemGroups#3399951, orderProposal#3399007.previousOrderProposals AS _extract_previousOrderProposals#3399952, orderProposal#3399007.parentItems AS _extract_parentItems#3399953, orderProposal#3399007.orderProposalId AS _extract_orderProposalId#3399954L]
Input [2]: [shardId#3394574, orderProposal#3399007]

(68) Exchange
Input [11]: [shardId#3394574, _extract_orderProposalId#3399945L, _extract_originalReplenishmentRunId#3399946L, _extract_supplierGroup#3399947, _extract_supplier#3399948, _extract_supplyingPlant#3399949, _extract_orderDateTime#3399950, _extract_itemGroups#3399951, _extract_previousOrderProposals#3399952, _extract_parentItems#3399953, _extract_orderProposalId#3399954L]
Arguments: hashpartitioning(coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L), 30), ENSURE_REQUIREMENTS, [plan_id=979453]

(69) Sort
Input [11]: [shardId#3394574, _extract_orderProposalId#3399945L, _extract_originalReplenishmentRunId#3399946L, _extract_supplierGroup#3399947, _extract_supplier#3399948, _extract_supplyingPlant#3399949, _extract_orderDateTime#3399950, _extract_itemGroups#3399951, _extract_previousOrderProposals#3399952, _extract_parentItems#3399953, _extract_orderProposalId#3399954L]
Arguments: [coalesce(shardId#3394574, ) ASC NULLS FIRST, isnull(shardId#3394574) ASC NULLS FIRST, coalesce(_extract_orderProposalId#3399954L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#3399954L) ASC NULLS FIRST], false, 0

(70) InMemoryTableScan
Output [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Arguments: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025], [isnotnull(orderProposalId#3399023L)]

(71) InMemoryRelation
Arguments: [shardId#3399022, orderProposalId#3399023L, items#3399024, optimizationGroups#3399025, isOptimal#3399026, optimizationInsights#3399028], StorageLevel(disk, memory, 2 replicas)

(72) Filter [codegen id : 2]
Input [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Condition : isnotnull(orderProposalId#3399023L)

(73) Exchange
Input [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Arguments: hashpartitioning(orderProposalId#3399023L, 30), ENSURE_REQUIREMENTS, [plan_id=979458]

(74) Sort [codegen id : 3]
Input [3]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025]
Arguments: [orderProposalId#3399023L ASC NULLS FIRST], false, 0

(75) InMemoryTableScan
Output [2]: [items#3398651, shardId#3398649]
Arguments: [items#3398651, shardId#3398649], [(size(items#3398651.worklistShardItemId, true) > 0), isnotnull(items#3398651.worklistShardItemId), (shardId#3398649 = 0_7_10000000532)]

(76) InMemoryRelation
Arguments: [shardId#3398649, orderProposalId#3398650L, items#3398651, optimizationGroups#3398652, isOptimal#3398653, optimizationInsights#3398655], StorageLevel(disk, memory, 2 replicas)

(77) Filter [codegen id : 4]
Input [2]: [items#3398651, shardId#3398649]
Condition : (((size(items#3398651.worklistShardItemId, true) > 0) AND isnotnull(items#3398651.worklistShardItemId)) AND (shardId#3398649 = 0_7_10000000532))

(78) Project [codegen id : 4]
Output [1]: [items#3398651.worklistShardItemId AS _extract_worklistShardItemId#3399670]
Input [2]: [items#3398651, shardId#3398649]

(79) Generate [codegen id : 4]
Input [1]: [_extract_worklistShardItemId#3399670]
Arguments: explode(_extract_worklistShardItemId#3399670), false, [item#3399029L]

(80) Project [codegen id : 4]
Output [1]: [item#3399029L AS worklistShardItemId#3399030L]
Input [1]: [item#3399029L]

(81) BroadcastExchange
Input [1]: [worklistShardItemId#3399030L]
Arguments: HashedRelationBroadcastMode(List(input[0, bigint, true]),false), [plan_id=979469]

(82) Scan parquet 
Output [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532]
PartitionFilters: [isnotnull(shardId#3399122), isnotnull(sequenceId#3399100), (shardId#3399122 = 0_7_10000000532), (sequenceId#3399100 = 6)]
PushedFilters: [IsNotNull(worklistShardItemId), Not(EqualNullSafe(isFallbackOrderOnly,true)), IsNotNull(orderProposalId)]
ReadSchema: struct<orderProposalId:bigint,isFallbackOrderOnly:boolean,worklistShardItemId:bigint>

(83) ColumnarToRow [codegen id : 5]
Input [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]

(84) Filter [codegen id : 5]
Input [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]
Condition : ((isnotnull(worklistShardItemId#3399101L) AND NOT (isFallbackOrderOnly#3399095 <=> true)) AND isnotnull(orderProposalId#3399078L))

(85) Project [codegen id : 5]
Output [2]: [orderProposalId#3399078L, worklistShardItemId#3399101L]
Input [5]: [orderProposalId#3399078L, isFallbackOrderOnly#3399095, worklistShardItemId#3399101L, shardId#3399122, sequenceId#3399100]

(86) Exchange
Input [2]: [orderProposalId#3399078L, worklistShardItemId#3399101L]
Arguments: hashpartitioning(worklistShardItemId#3399101L, 30), REPARTITION_BY_NUM, [plan_id=979476]

(87) Project
Output [2]: [worklistShardItemId#3399101L, orderProposalId#3399078L]
Input [2]: [orderProposalId#3399078L, worklistShardItemId#3399101L]

(88) BroadcastHashJoin [codegen id : 6]
Left keys [1]: [worklistShardItemId#3399030L]
Right keys [1]: [worklistShardItemId#3399101L]
Join type: Inner
Join condition: None

(89) Project [codegen id : 6]
Output [1]: [orderProposalId#3399078L]
Input [3]: [worklistShardItemId#3399030L, worklistShardItemId#3399101L, orderProposalId#3399078L]

(90) HashAggregate [codegen id : 6]
Input [1]: [orderProposalId#3399078L]
Keys [1]: [orderProposalId#3399078L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#3399078L]

(91) Exchange
Input [1]: [orderProposalId#3399078L]
Arguments: hashpartitioning(orderProposalId#3399078L, 30), ENSURE_REQUIREMENTS, [plan_id=979483]

(92) HashAggregate [codegen id : 7]
Input [1]: [orderProposalId#3399078L]
Keys [1]: [orderProposalId#3399078L]
Functions: []
Aggregate Attributes: []
Results [1]: [orderProposalId#3399078L]

(93) Sort [codegen id : 7]
Input [1]: [orderProposalId#3399078L]
Arguments: [orderProposalId#3399078L ASC NULLS FIRST], false, 0

(94) SortMergeJoin [codegen id : 8]
Left keys [1]: [orderProposalId#3399023L]
Right keys [1]: [orderProposalId#3399078L]
Join type: Inner
Join condition: None

(95) Project
Output [3]: [orderProposalId#3399023L, shardId#3399022, coalesce(transform(optimizationGroups#3399025, lambdafunction(struct(optGroupId, lambda x_11246#3399020.optGroupId, minOrderProfile, lambda x_11246#3399020.minOrderProfile, assignmentDetails, lambda x_11246#3399020.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_11246#3399020.minOrderGoal.dimensionType, unit, lambda x_11246#3399020.minOrderGoal.unit, unitUuid, lambda x_11246#3399020.minOrderGoal.unitUuid, goalValue, lambda x_11246#3399020.minOrderGoal.minOrderValue, calcValue, lambda x_11246#3399020.minOrderGoal.calculatedOrderValue), transportLoadProfile, null, transportLoadGoal, null), lambda x_11246#3399020, false)), []) AS optimizationGroups#3399019]
Input [4]: [shardId#3399022, orderProposalId#3399023L, optimizationGroups#3399025, orderProposalId#3399078L]

(96) Exchange
Input [3]: [orderProposalId#3399023L, shardId#3399022, optimizationGroups#3399019]
Arguments: hashpartitioning(coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L), 30), ENSURE_REQUIREMENTS, [plan_id=979492]

(97) Sort [codegen id : 9]
Input [3]: [orderProposalId#3399023L, shardId#3399022, optimizationGroups#3399019]
Arguments: [coalesce(shardId#3399022, ) ASC NULLS FIRST, isnull(shardId#3399022) ASC NULLS FIRST, coalesce(orderProposalId#3399023L, 0) ASC NULLS FIRST, isnull(orderProposalId#3399023L) ASC NULLS FIRST], false, 0

(98) SortMergeJoin
Left keys [4]: [coalesce(shardId#3394574, ), isnull(shardId#3394574), coalesce(_extract_orderProposalId#3399954L, 0), isnull(_extract_orderProposalId#3399954L)]
Right keys [4]: [coalesce(shardId#3399022, ), isnull(shardId#3399022), coalesce(orderProposalId#3399023L, 0), isnull(orderProposalId#3399023L)]
Join type: LeftOuter
Join condition: None

(99) Project
Output [2]: [shardId#3394574, named_struct(orderProposalId, _extract_orderProposalId#3399954L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#3399946L, supplierGroup, _extract_supplierGroup#3399947, optimizationGroups, coalesce(optimizationGroups#3399019, []), supplier, _extract_supplier#3399948, supplyingPlant, _extract_supplyingPlant#3399949, orderDateTime, _extract_orderDateTime#3399950, itemGroups, _extract_itemGroups#3399951, previousOrderProposals, _extract_previousOrderProposals#3399952, parentItems, _extract_parentItems#3399953) AS orderProposal#3399126]
Input [14]: [shardId#3394574, _extract_orderProposalId#3399945L, _extract_originalReplenishmentRunId#3399946L, _extract_supplierGroup#3399947, _extract_supplier#3399948, _extract_supplyingPlant#3399949, _extract_orderDateTime#3399950, _extract_itemGroups#3399951, _extract_previousOrderProposals#3399952, _extract_parentItems#3399953, _extract_orderProposalId#3399954L, orderProposalId#3399023L, shardId#3399022, optimizationGroups#3399019]

(100) Project
Output [3]: [shardId#3394574, orderProposal#3399126, CASE WHEN (size(orderProposal#3399126.parentItems, true) > 2000) THEN xxhash64(orderProposal#3399126.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#3399126.orderProposalId as decimal(20,0)), 20), 42) END AS resultSeparationId#3406319L]
Input [2]: [orderProposal#3399126, shardId#3394574]

(101) ObjectHashAggregate
Input [3]: [shardId#3394574, orderProposal#3399126, resultSeparationId#3406319L]
Keys [2]: [shardId#3394574, resultSeparationId#3406319L]
Functions [1]: [partial_collect_list(orderProposal#3399126, 0, 0)]
Aggregate Attributes [1]: [buf#3406358]
Results [3]: [shardId#3394574, resultSeparationId#3406319L, buf#3406359]

(102) Exchange
Input [3]: [shardId#3394574, resultSeparationId#3406319L, buf#3406359]
Arguments: hashpartitioning(shardId#3394574, resultSeparationId#3406319L, 30), ENSURE_REQUIREMENTS, [plan_id=981002]

(103) ObjectHashAggregate
Input [3]: [shardId#3394574, resultSeparationId#3406319L, buf#3406359]
Keys [2]: [shardId#3394574, resultSeparationId#3406319L]
Functions [1]: [collect_list(orderProposal#3399126, 0, 0)]
Aggregate Attributes [1]: [collect_list(orderProposal#3399126, 0, 0)#3406327]
Results [3]: [shardId#3394574, resultSeparationId#3406319L, collect_list(orderProposal#3399126, 0, 0)#3406327 AS orderProposals#3406323]

(104) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#3406436L]
Results [1]: [count#3406437L]

(105) Exchange
Input [1]: [count#3406437L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=981026]

(106) HashAggregate [codegen id : 2]
Input [1]: [count#3406437L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#3406390L]
Results [1]: [count(1)#3406390L AS count#3406386L]

SQL / DataFrame Properties

Name	Value
spark.activity.clearDeltaLogCache	false
spark.activity.clearSqlCache	false
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	9
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.optimizer.pruneFiltersCanPruneStreamingSubplan	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
spark.sql.shuffle.partitions	30
spark.sql.streaming.aggregation.stateFormatVersion	2
spark.sql.streaming.flatMapGroupsWithState.stateFormatVersion	2
spark.sql.streaming.join.stateFormatVersion	2
spark.sql.streaming.multipleWatermarkPolicy	min
spark.sql.streaming.stateStore.compression.codec	lz4
spark.sql.streaming.stateStore.encodingFormat	unsaferow
spark.sql.streaming.stateStore.providerClass	org.apache.spark.sql.execution.streaming.state.HDFSBackedStateStoreProvider
spark.sql.streaming.stateStore.rocksdb.formatVersion	5
spark.sql.streaming.statefulOperator.useStrictDistribution	true
temporal.activity.id	fb7f6fa8-0c21-3699-9dc3-f9db990e9763
temporal.activity.type	RunStreamWithId