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

Submitted Time: 2026/08/31 13:55:48
Duration: 1 s
Succeeded Jobs: 17727

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: 2 ms"; tooltip="WholeStageCodegen (2)"; 1 [id="node1" labelType="html" label="HashAggregate time in aggregation build: 2 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: 450.0 B merged fetch fallback count: 0 local blocks read: 6 remote merged chunks fetched: 0 remote blocks read: 24 data size total (min, med, max (stageId: taskId)) 480.0 B (16.0 B, 16.0 B, 16.0 B (stage 307861.0: task 890537)) 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 307861.0: task 890553)) 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: 1788.0 B number of partitions: 1 remote reqs duration: 2 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 307861.0: task 890537))" tooltip="Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=981321]"]; subgraph cluster3 { isCluster="true"; id="cluster3"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n254 ms (0 ms, 7 ms, 32 ms (stage 307861.0: task 890556))"; tooltip="WholeStageCodegen (1)"; 4 [id="node4" labelType="html" label="HashAggregate time in aggregation build total (min, med, max (stageId: taskId)) 243 ms (0 ms, 7 ms, 32 ms (stage 307861.0: task 890556)) number of output rows: 30" tooltip="HashAggregate(keys=[], functions=[partial_count(1)])"]; } 5 [id="node5" labelType="html" label="InMemoryTableScan number of output rows: 60" tooltip="InMemoryTableScan"]; 6 [id="node6" labelType="html" label="ObjectHashAggregate number of output rows: 60 time in aggregation build total (min, med, max (stageId: taskId)) 1.0 s (0 ms, 30 ms, 64 ms (stage 307861.0: task 890564)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307861.0: task 890537)) number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3395105, resultSeparationId#3406938L], functions=[collect_list(orderProposal#3401811, 0, 0)])"]; 7 [id="node7" labelType="html" label="Exchange shuffle records written: 1,317 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1,317 local bytes read total (min, med, max (stageId: taskId)) 10.9 MiB (103.6 KiB, 414.2 KiB, 891.8 KiB (stage 307861.0: task 890556)) merged fetch fallback count: 0 local blocks read: 371 remote merged chunks fetched: 0 remote blocks read: 332 data size total (min, med, max (stageId: taskId)) 217.3 MiB (5.7 MiB, 7.2 MiB, 9.8 MiB (stage 307860.0: task 890464)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 86 ms (2 ms, 2 ms, 4 ms (stage 307860.0: task 890513)) 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)) 1 ms (0 ms, 0 ms, 1 ms (stage 307861.0: task 890553)) remote bytes read total (min, med, max (stageId: taskId)) 9.9 MiB (62.5 KiB, 325.7 KiB, 1509.1 KiB (stage 307861.0: task 890585)) number of partitions: 30 remote reqs duration total (min, med, max (stageId: taskId)) 245 ms (4 ms, 8 ms, 25 ms (stage 307861.0: task 890570)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 20.8 MiB (556.8 KiB, 701.5 KiB, 960.1 KiB (stage 307860.0: task 890464))" tooltip="Exchange hashpartitioning(shardId#3395105, resultSeparationId#3406938L, 30), ENSURE_REQUIREMENTS, [plan_id=981297]"]; 8 [id="node8" labelType="html" label="ObjectHashAggregate number of output rows: 1,317 time in aggregation build total (min, med, max (stageId: taskId)) 1.4 s (7 ms, 13 ms, 167 ms (stage 307860.0: task 890465)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 307860.0: task 890474)) number of sort fallback tasks: 0" tooltip="ObjectHashAggregate(keys=[shardId#3395105, resultSeparationId#3406938L], functions=[partial_collect_list(orderProposal#3401811, 0, 0)])"]; 9 [id="node9" labelType="html" label=" Project " tooltip="Project [shardId#3395105, orderProposal#3401811, CASE WHEN (size(orderProposal#3401811.parentItems, true) > 2000) THEN xxhash64(orderProposal#3401811.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#3401811.orderProposalId as decimal(20,0)), 60), 42) END AS resultSeparationId#3406938L]"]; 10 [id="node10" labelType="html" label="InMemoryTableScan number of output rows: 2,360" tooltip="InMemoryTableScan [orderProposal#3401811, shardId#3395105]"]; 11 [id="node11" labelType="html" label=" Project " tooltip="Project [shardId#3395105, named_struct(orderProposalId, _extract_orderProposalId#3402530L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#3402522L, supplierGroup, _extract_supplierGroup#3402523, optimizationGroups, coalesce(optimizationGroups#3401704, []), supplier, _extract_supplier#3402524, supplyingPlant, _extract_supplyingPlant#3402525, orderDateTime, _extract_orderDateTime#3402526, itemGroups, _extract_itemGroups#3402527, previousOrderProposals, _extract_previousOrderProposals#3402528, parentItems, _extract_parentItems#3402529) AS orderProposal#3401811]"]; 12 [id="node12" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#3395105, ), isnull(shardId#3395105), coalesce(_extract_orderProposalId#3402530L, 0), isnull(_extract_orderProposalId#3402530L)], [coalesce(shardId#3401707, ), isnull(shardId#3401707), coalesce(orderProposalId#3401708L, 0), isnull(orderProposalId#3401708L)], 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#3395105, ) ASC NULLS FIRST, isnull(shardId#3395105) ASC NULLS FIRST, coalesce(_extract_orderProposalId#3402530L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#3402530L) 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#3395105, ), isnull(shardId#3395105), coalesce(_extract_orderProposalId#3402530L, 0), isnull(_extract_orderProposalId#3402530L), 30), ENSURE_REQUIREMENTS, [plan_id=980142]"]; 15 [id="node15" labelType="html" label=" Project " tooltip="Project [shardId#3395105, orderProposal#3401692.orderProposalId AS _extract_orderProposalId#3402521L, orderProposal#3401692.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#3402522L, orderProposal#3401692.supplierGroup AS _extract_supplierGroup#3402523, orderProposal#3401692.supplier AS _extract_supplier#3402524, orderProposal#3401692.supplyingPlant AS _extract_supplyingPlant#3402525, orderProposal#3401692.orderDateTime AS _extract_orderDateTime#3402526, orderProposal#3401692.itemGroups AS _extract_itemGroups#3402527, orderProposal#3401692.previousOrderProposals AS _extract_previousOrderProposals#3402528, orderProposal#3401692.parentItems AS _extract_parentItems#3402529, orderProposal#3401692.orderProposalId AS _extract_orderProposalId#3402530L]"]; 16 [id="node16" labelType="html" label=" Project " tooltip="Project [shardId#3395105, struct(orderProposalId, orderProposalId#3396170L, originalReplenishmentRunId, originalReplenishmentRunId#3401660L, supplierGroup, supplierGroup#3401661, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#3401661) THEN supplier#3401662 END, supplyingPlant, supplyingPlant#3401663, orderDateTime, orderDateTime#3401664, itemGroups, itemGroups#3401665, previousOrderProposals, array_distinct(previousOrderProposals#3401667), parentItems, parentItems#3401666) AS orderProposal#3401692]"]; 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#3395105, orderProposalId#3396170L], functions=[max(originalReplenishmentRunId#3401598L), max(supplierGroup#3401599), max(supplier#3401600), max(supplyingPlant#3401601), max(orderDateTime#3401602), collect_list(itemGroup#3401659, 0, 0), collect_list(parentItems#3401603, 0, 0), collect_set(previousOrderProposals#3401605, 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#3395105, orderProposalId#3396170L, 30), ENSURE_REQUIREMENTS, [plan_id=980138]"]; 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#3395105, orderProposalId#3396170L], functions=[partial_max(originalReplenishmentRunId#3401598L), partial_max(supplierGroup#3401599), partial_max(supplier#3401600), partial_max(supplyingPlant#3401601), partial_max(orderDateTime#3401602), partial_collect_list(itemGroup#3401659, 0, 0), partial_collect_list(parentItems#3401603, 0, 0), partial_collect_set(previousOrderProposals#3401605, 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#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172], functions=[max(originalReplenishmentRunId#3396173L), max(supplierGroup#3396180), max(supplier#3396181), max(supplyingPlant#3396211), max(orderDateTime#3396188), collect_list(parentItem#3401550, 0, 0), collect_set(previousOrderProposal#3396176L, 0, 0), collect_list(item#3401581, 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#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172, 30), ENSURE_REQUIREMENTS, [plan_id=980135]"]; 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#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172], functions=[partial_max(originalReplenishmentRunId#3396173L), partial_max(supplierGroup#3396180), partial_max(supplier#3396181), partial_max(supplyingPlant#3396211), partial_max(orderDateTime#3396188), partial_collect_list(parentItem#3401550, 0, 0), partial_collect_set(previousOrderProposal#3396176L, 0, 0), partial_collect_list(item#3401581, 0, 0)])"]; 23 [id="node23" labelType="html" label=" Project " tooltip="Project [shardId#3395105, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, orderDateTime#3396188, splitIndicator#3396175L, orderProposalItemGroupId#3396172, previousOrderProposal#3396176L, parentItem#3401550, struct(itemId, orderProposalItemId#3396171, supplier, supplier#3396181, supplyingPlant, supplyingPlant#3396211, productGroup, productGroup#3396212, product, product#3396183, plant, plant#3396184, supplierSubRange, subrange#3396182, deliveryDateTime, deliveryDateTime#3396189, orderQuantity, coalesce((qty#3395822 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401584.isOrderUnit, lambda x_11297#3401584, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401585.isOrderUnit, lambda x_11297#3401585, false)), 1, None, false).numerator as double))), qty#3395822), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401586.isOrderUnit, lambda x_11297#3401586, false)), 1, None, false).uom, orderQuantityBaseUom#3396193), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401587.isOrderUnit, lambda x_11297#3401587, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194), orderQuantityInBaseUnit, qty#3395822, orderQuantityBaseUom, ... 13 more fields) AS item#3401581]"]; 24 [id="node24" labelType="html" label=" Project " tooltip="Project [shardId#3395105, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, previousOrderProposal#3396176L, struct(itemId, orderProposalItemId#3396171, itemGroupId, orderProposalItemGroupId#3396172, supplier, supplier#3396181, supplyingPlant, supplyingPlant#3396211, productGroup, productGroup#3396212, product, product#3396183, plant, plant#3396184, supplierSubRange, subrange#3396182, sourceOfSupplyUuid, sourceOfSupplyUuid#3396179, deliveryDateTime, deliveryDateTime#3396189, unitPrice, netPriceAmount#3396198, unitPriceCurrency, netPriceCurrencyCode#3396199, unitPriceQuantity, ... 37 more fields) AS parentItem#3401550]"]; 25 [id="node25" labelType="html" label=" Project " tooltip="Project [shardId#3395105, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, sourceOfSupplyUuid#3396179, ... 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#3395105, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, ... 11 more fields]"]; 28 [id="node28" labelType="html" label="Filter number of output rows: 0" tooltip="Filter NOT (isFallbackOrderOnly#3396192 <=> true)"]; } 29 [id="node29" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [availabilityDateTime#3396190, channelStreamSpecificKpis#3399791, constraintLabels#3396202, constraintOperators#3396203, constraintValues#3396205, deliveryDateTime#3396189, isFallbackOrderOnly#3396192, logisticUnits#3396207, measurements#3396200, minimumOrderQuantity#3396201, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, nextAvailabilityDateTime#3396191, optimizationGroups#3396208, orderDateTime#3396188, orderProposalId#3396170L, orderProposalItemGroupId#3396172, orderProposalItemId#3396171, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, originalReplenishmentRunId#3396173L, plant#3396184, ... 14 more fields], [NOT (isFallbackOrderOnly#3396192 <=> true)]"]; subgraph cluster30 { isCluster="true"; id="cluster30"; label="WholeStageCodegen (15)"; tooltip="WholeStageCodegen (15)"; 31 [id="node31" labelType="html" label=" Project " tooltip="Project [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, ... 17 more fields]"]; 32 [id="node32" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#3395105, worklistShardItemId#3395820L], [shardId#3399798, worklistShardItemId#3399799L], LeftOuter"]; } subgraph cluster33 { isCluster="true"; id="cluster33"; label="WholeStageCodegen (12)"; tooltip="WholeStageCodegen (12)"; 34 [id="node34" labelType="html" label=" Project " tooltip="Project [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, ... 16 more fields]"]; 35 [id="node35" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#3395105, worklistShardItemId#3395820L], [shardId#3399785, worklistShardItemId#3399786L], LeftOuter"]; } subgraph cluster36 { isCluster="true"; id="cluster36"; label="WholeStageCodegen (9)"; tooltip="WholeStageCodegen (9)"; 37 [id="node37" labelType="html" label=" Project " tooltip="Project [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, ... 15 more fields]"]; 38 [id="node38" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [shardId#3395105, worklistShardItemId#3395820L], [shardId#3399769, worklistShardItemId#3399770L], LeftOuter"]; } subgraph cluster39 { isCluster="true"; id="cluster39"; label="WholeStageCodegen (6)"; tooltip="WholeStageCodegen (6)"; 40 [id="node40" labelType="html" label=" Sort " tooltip="Sort [shardId#3395105 ASC NULLS FIRST, worklistShardItemId#3395820L ASC NULLS FIRST], false, 0"]; } 41 [id="node41" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3395105, worklistShardItemId#3395820L, 30), ENSURE_REQUIREMENTS, [plan_id=979815]"]; subgraph cluster42 { isCluster="true"; id="cluster42"; label="WholeStageCodegen (5)"; tooltip="WholeStageCodegen (5)"; 43 [id="node43" labelType="html" label=" Project " tooltip="Project [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, ... 14 more fields]"]; 44 [id="node44" labelType="html" label=" SortMergeJoin " tooltip="SortMergeJoin [worklistShardItemId#3395820L], [worklistShardItemId#3396326L], LeftOuter, (shardId#3395105 = 0_5_10000000532)"]; } subgraph cluster45 { isCluster="true"; id="cluster45"; label="WholeStageCodegen (2)"; tooltip="WholeStageCodegen (2)"; 46 [id="node46" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#3395820L ASC NULLS FIRST], false, 0"]; } 47 [id="node47" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#3395820L, 30), ENSURE_REQUIREMENTS, [plan_id=979796]"]; subgraph cluster48 { isCluster="true"; id="cluster48"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 49 [id="node49" labelType="html" label=" Project " tooltip="Project [shardId#3395105, item#3395819.worklistShardItemId AS worklistShardItemId#3395820L, item#3395819.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395821, item#3395819.qty AS qty#3395822]"]; 50 [id="node50" labelType="html" label=" Generate " tooltip="Generate explode(items#3395107), [shardId#3395105], false, [item#3395819]"]; 51 [id="node51" labelType="html" label=" Filter " tooltip="Filter ((size(items#3395107, true) > 0) AND isnotnull(items#3395107))"]; } 52 [id="node52" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3395105, items#3395107], [(size(items#3395107, true) > 0), isnotnull(items#3395107)]"]; subgraph cluster53 { isCluster="true"; id="cluster53"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 54 [id="node54" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))"]; } 55 [id="node55" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111], [isnotnull(shardId#3395105), (shardId#3395105 = 0_5_10000000532)]"]; subgraph cluster56 { isCluster="true"; id="cluster56"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 57 [id="node57" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))"]; 58 [id="node58" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3395105,orderProposalId#3395106L,items#3395107,optimizationGroups#3395108,isOptimal#3395109,lastModified#3395110,optimizationInsights#3395111]"]; } subgraph cluster59 { isCluster="true"; id="cluster59"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 60 [id="node60" labelType="html" label=" Sort " tooltip="Sort [worklistShardItemId#3396326L ASC NULLS FIRST], false, 0"]; 61 [id="node61" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#3396326L, orderProposalId#3396303L, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, originalReplenishmentRunId#3396345L, splitIndicator#3396322L, previousOrderProposal#3396323L, sourceOfSupplyUuid#3396317, supplierGroup#3396305, supplier#3396306, subrange#3396309, product#3396312, plant#3396307, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, isFallbackOrderOnly#3396320, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, netPriceAmount#3396339, netPriceCurrencyCode#3396340, ... 11 more fields]"]; } 62 [id="node62" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(worklistShardItemId#3396326L, 30), REPARTITION_BY_NUM, [plan_id=979806]"]; subgraph cluster63 { isCluster="true"; id="cluster63"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 64 [id="node64" labelType="html" label=" Project " tooltip="Project [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, ... 11 more fields]"]; 65 [id="node65" labelType="html" label=" Filter " tooltip="Filter isnotnull(worklistShardItemId#3396326L)"]; 66 [id="node66" labelType="html" label=" ColumnarToRow " tooltip="ColumnarToRow"]; } 67 [id="node67" labelType="html" label=" Scan parquet " tooltip="FileScan parquet [orderProposalId#3396303L,orderProposalItemId#3396304,supplierGroup#3396305,supplier#3396306,plant#3396307,deliveryDateTime#3396308,subrange#3396309,supplyingPlant#3396310,productGroup#3396311,product#3396312,orderDateTime#3396313,availabilityDateTime#3396314,nextAvailabilityDateTime#3396315,sourceOfSupplyUuid#3396317,isFallbackOrderOnly#3396320,splitIndicator#3396322L,previousOrderProposal#3396323L,worklistShardItemId#3396326L,orderProposalItemGroupId#3396327,externalProductId#3396328,externalPlantId#3396329,logisticUnits#3396330,orderQuantityBaseUom#3396331,orderQuantityBaseUomUuid#3396332,minimumOrderQuantity#3396333,... 13 more fields] Batched: true, DataFilters: [isnotnull(worklistShardItemId#3396326L)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#3396347), isnotnull(sequenceId#3396325), (shardId#3396347 = 0_5_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#3399769 ASC NULLS FIRST, worklistShardItemId#3399770L ASC NULLS FIRST], false, 0"]; } 70 [id="node70" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3399769, worklistShardItemId#3399770L, 30), ENSURE_REQUIREMENTS, [plan_id=979821]"]; subgraph cluster71 { isCluster="true"; id="cluster71"; label="WholeStageCodegen (7)"; tooltip="WholeStageCodegen (7)"; 72 [id="node72" labelType="html" label=" Project " tooltip="Project [shardId#3399769, worklistShardItemId#3399770L, coalesce(kpis#3399774, []) AS prodLocSpecificKpis#3399775]"]; 73 [id="node73" labelType="html" label=" Filter " tooltip="Filter (((isnull(qty#3399771) AND isnull(demandChannel#3399772)) AND isnull(demandStream#3399773)) AND (isnotnull(shardId#3399769) AND isnotnull(worklistShardItemId#3399770L)))"]; 74 [id="node74" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3399769,worklistShardItemId#3399770L,qty#3399771,demandChannel#3399772,demandStream#3399773,kpis#3399774]"]; } subgraph cluster75 { isCluster="true"; id="cluster75"; label="WholeStageCodegen (11)"; tooltip="WholeStageCodegen (11)"; 76 [id="node76" labelType="html" label=" Sort " tooltip="Sort [shardId#3399785 ASC NULLS FIRST, worklistShardItemId#3399786L ASC NULLS FIRST], false, 0"]; } 77 [id="node77" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3399785, worklistShardItemId#3399786L], functions=[collect_list(struct(demandChannel, demandChannel#3399788, demandStream, demandStream#3399789, kpis, kpis#3399790), 0, 0)])"]; 78 [id="node78" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3399785, worklistShardItemId#3399786L, 30), ENSURE_REQUIREMENTS, [plan_id=979832]"]; 79 [id="node79" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3399785, worklistShardItemId#3399786L], functions=[partial_collect_list(struct(demandChannel, demandChannel#3399788, demandStream, demandStream#3399789, kpis, kpis#3399790), 0, 0)])"]; subgraph cluster80 { isCluster="true"; id="cluster80"; label="WholeStageCodegen (10)"; tooltip="WholeStageCodegen (10)"; 81 [id="node81" labelType="html" label=" Project " tooltip="Project [shardId#3399785, worklistShardItemId#3399786L, demandChannel#3399788, demandStream#3399789, kpis#3399790]"]; 82 [id="node82" labelType="html" label=" Filter " tooltip="Filter ((((isnull(qty#3399787) AND isnotnull(demandChannel#3399788)) AND isnotnull(demandStream#3399789)) AND (size(kpis#3399790, true) > 0)) AND (isnotnull(shardId#3399785) AND isnotnull(worklistShardItemId#3399786L)))"]; 83 [id="node83" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3399785,worklistShardItemId#3399786L,qty#3399787,demandChannel#3399788,demandStream#3399789,kpis#3399790]"]; } subgraph cluster84 { isCluster="true"; id="cluster84"; label="WholeStageCodegen (14)"; tooltip="WholeStageCodegen (14)"; 85 [id="node85" labelType="html" label=" Sort " tooltip="Sort [shardId#3399798 ASC NULLS FIRST, worklistShardItemId#3399799L ASC NULLS FIRST], false, 0"]; } 86 [id="node86" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3399798, worklistShardItemId#3399799L], functions=[collect_list(struct(qty, qty#3399800, kpis, kpis#3399803), 0, 0)])"]; 87 [id="node87" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#3399798, worklistShardItemId#3399799L, 30), ENSURE_REQUIREMENTS, [plan_id=979844]"]; 88 [id="node88" labelType="html" label=" ObjectHashAggregate " tooltip="ObjectHashAggregate(keys=[shardId#3399798, worklistShardItemId#3399799L], functions=[partial_collect_list(struct(qty, qty#3399800, kpis, kpis#3399803), 0, 0)])"]; subgraph cluster89 { isCluster="true"; id="cluster89"; label="WholeStageCodegen (13)"; tooltip="WholeStageCodegen (13)"; 90 [id="node90" labelType="html" label=" Project " tooltip="Project [shardId#3399798, worklistShardItemId#3399799L, qty#3399800, kpis#3399803]"]; 91 [id="node91" labelType="html" label=" Filter " tooltip="Filter ((isnotnull(qty#3399800) AND isnotnull(kpis#3399803)) AND (isnotnull(shardId#3399798) AND isnotnull(worklistShardItemId#3399799L)))"]; 92 [id="node92" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3399798,worklistShardItemId#3399799L,qty#3399800,demandChannel#3399801,demandStream#3399802,kpis#3399803]"]; } 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#3401707, ) ASC NULLS FIRST, isnull(shardId#3401707) ASC NULLS FIRST, coalesce(orderProposalId#3401708L, 0) ASC NULLS FIRST, isnull(orderProposalId#3401708L) 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#3401707, ), isnull(shardId#3401707), coalesce(orderProposalId#3401708L, 0), isnull(orderProposalId#3401708L), 30), ENSURE_REQUIREMENTS, [plan_id=980181]"]; 96 [id="node96" labelType="html" label=" Project " tooltip="Project [orderProposalId#3401708L, shardId#3401707, coalesce(transform(optimizationGroups#3401710, lambdafunction(struct(optGroupId, lambda x_11301#3401705.optGroupId, minOrderProfile, lambda x_11301#3401705.minOrderProfile, assignmentDetails, lambda x_11301#3401705.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_11301#3401705.minOrderGoal.dimensionType, unit, lambda x_11301#3401705.minOrderGoal.unit, unitUuid, lambda x_11301#3401705.minOrderGoal.unitUuid, goalValue, lambda x_11301#3401705.minOrderGoal.minOrderValue, calcValue, lambda x_11301#3401705.minOrderGoal.calculatedOrderValue), transportLoadProfile, null, transportLoadGoal, null), lambda x_11301#3401705, false)), []) AS optimizationGroups#3401704]"]; 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#3401708L], [orderProposalId#3401763L], 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#3401708L 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#3401708L, 30), ENSURE_REQUIREMENTS, [plan_id=980147]"]; 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#3401708L)"]; } 104 [id="node104" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#3401707, orderProposalId#3401708L, optimizationGroups#3401710], [isnotnull(orderProposalId#3401708L)]"]; subgraph cluster105 { isCluster="true"; id="cluster105"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 106 [id="node106" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))"]; } 107 [id="node107" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111], [isnotnull(shardId#3395105), (shardId#3395105 = 0_5_10000000532)]"]; subgraph cluster108 { isCluster="true"; id="cluster108"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 109 [id="node109" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))"]; 110 [id="node110" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3395105,orderProposalId#3395106L,items#3395107,optimizationGroups#3395108,isOptimal#3395109,lastModified#3395110,optimizationInsights#3395111]"]; } 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#3401763L 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#3401763L], 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#3401763L, 30), ENSURE_REQUIREMENTS, [plan_id=980172]"]; 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#3401763L], functions=[])"]; 117 [id="node117" labelType="html" label=" Project " tooltip="Project [orderProposalId#3401763L]"]; 118 [id="node118" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#3401715L], [worklistShardItemId#3401786L], Inner, BuildLeft, false"]; 132 [id="node132" labelType="html" label=" Project " tooltip="Project [worklistShardItemId#3401786L, orderProposalId#3401763L]"]; } 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=980158]"]; 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#3401714L AS worklistShardItemId#3401715L]"]; 122 [id="node122" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_worklistShardItemId#3402355), false, [item#3401714L]"]; 123 [id="node123" labelType="html" label=" Project " tooltip="Project [items#3401336.worklistShardItemId AS _extract_worklistShardItemId#3402355]"]; 124 [id="node124" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (((size(items#3401336.worklistShardItemId, true) > 0) AND isnotnull(items#3401336.worklistShardItemId)) AND (shardId#3401334 = 0_5_10000000532))"]; } 125 [id="node125" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [items#3401336, shardId#3401334], [(size(items#3401336.worklistShardItemId, true) > 0), isnotnull(items#3401336.worklistShardItemId), (shardId#3401334 = 0_5_10000000532)]"]; subgraph cluster126 { isCluster="true"; id="cluster126"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 127 [id="node127" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))"]; } 128 [id="node128" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111], [isnotnull(shardId#3395105), (shardId#3395105 = 0_5_10000000532)]"]; subgraph cluster129 { isCluster="true"; id="cluster129"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 130 [id="node130" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))"]; 131 [id="node131" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3395105,orderProposalId#3395106L,items#3395107,optimizationGroups#3395108,isOptimal#3395109,lastModified#3395110,optimizationInsights#3395111]"]; } 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#3401786L, 30), REPARTITION_BY_NUM, [plan_id=980165]"]; 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#3401763L, worklistShardItemId#3401786L]"]; 136 [id="node136" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnotnull(worklistShardItemId#3401786L) AND NOT (isFallbackOrderOnly#3401780 <=> true)) AND isnotnull(orderProposalId#3401763L))"]; 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#3401763L,isFallbackOrderOnly#3401780,worklistShardItemId#3401786L,shardId#3401807,sequenceId#3401785] Batched: true, DataFilters: [isnotnull(worklistShardItemId#3401786L), NOT (isFallbackOrderOnly#3401780 <=> true), isnotnull(o..., Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20...., PartitionFilters: [isnotnull(shardId#3401807), isnotnull(sequenceId#3401785), (shardId#3401807 = 0_5_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#3395105, resultSeparationId#3406938L, orderProposals#3406942], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [2]: [orderProposal#3401811, shardId#3395105]
Arguments: [orderProposal#3401811, shardId#3395105]

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

(5) InMemoryTableScan
Output [39]: [availabilityDateTime#3396190, channelStreamSpecificKpis#3399791, constraintLabels#3396202, constraintOperators#3396203, constraintValues#3396205, deliveryDateTime#3396189, isFallbackOrderOnly#3396192, logisticUnits#3396207, measurements#3396200, minimumOrderQuantity#3396201, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, nextAvailabilityDateTime#3396191, optimizationGroups#3396208, orderDateTime#3396188, orderProposalId#3396170L, orderProposalItemGroupId#3396172, orderProposalItemId#3396171, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, originalReplenishmentRunId#3396173L, plant#3396184, previousOrderProposal#3396176L, prodLocSpecificKpis#3399776, product#3396183, productGroup#3396212, qty#3395822, quantityAfterProdPlantOptimization#3395821, quantityKpis#3399804, shardId#3395105, sourceOfSupplyUuid#3396179, splitIndicator#3396175L, subrange#3396182, supplier#3396181, supplierGroup#3396180, supplyingPlant#3396211]
Arguments: [availabilityDateTime#3396190, channelStreamSpecificKpis#3399791, constraintLabels#3396202, constraintOperators#3396203, constraintValues#3396205, deliveryDateTime#3396189, isFallbackOrderOnly#3396192, logisticUnits#3396207, measurements#3396200, minimumOrderQuantity#3396201, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, nextAvailabilityDateTime#3396191, optimizationGroups#3396208, orderDateTime#3396188, orderProposalId#3396170L, orderProposalItemGroupId#3396172, orderProposalItemId#3396171, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, originalReplenishmentRunId#3396173L, plant#3396184, ... 14 more fields], [NOT (isFallbackOrderOnly#3396192 <=> true)]

(6) InMemoryRelation
Arguments: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, constraintValues#3396205, constraintOperators#3396203, constraintLabels#3396202, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, ... 17 more fields], StorageLevel(disk, memory, 2 replicas)

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

(8) InMemoryRelation
Arguments: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111], StorageLevel(disk, memory, 2 replicas)

(9) InMemoryTableScan
Output [6]: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111]
Arguments: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111], [isnotnull(shardId#3395105), (shardId#3395105 = 0_5_10000000532)]

(10) InMemoryRelation
Arguments: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, lastModified#3395110, optimizationInsights#3395111], StorageLevel(disk, memory, 2 replicas)

(11) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, lastModified#3395110, optimizationInsights#3395111]
Arguments: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, lastModified#3395110, optimizationInsights#3395111], MapPartitionsRDD[144348] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(12) Filter [codegen id : 1]
Input [7]: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, lastModified#3395110, optimizationInsights#3395111]
Condition : (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))

(13) Filter [codegen id : 1]
Input [6]: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111]
Condition : (isnotnull(shardId#3395105) AND (shardId#3395105 = 0_5_10000000532))

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

(15) Generate [codegen id : 1]
Input [2]: [shardId#3395105, items#3395107]
Arguments: explode(items#3395107), [shardId#3395105], false, [item#3395819]

(16) Project [codegen id : 1]
Output [4]: [shardId#3395105, item#3395819.worklistShardItemId AS worklistShardItemId#3395820L, item#3395819.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395821, item#3395819.qty AS qty#3395822]
Input [2]: [shardId#3395105, item#3395819]

(17) Exchange
Input [4]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822]
Arguments: hashpartitioning(worklistShardItemId#3395820L, 30), ENSURE_REQUIREMENTS, [plan_id=979796]

(18) Sort [codegen id : 2]
Input [4]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822]
Arguments: [worklistShardItemId#3395820L ASC NULLS FIRST], false, 0

(19) Scan parquet 
Output [38]: [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, measurements#3396344, originalReplenishmentRunId#3396345L, optimizationGroups#3396346, shardId#3396347, sequenceId#3396325]
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#3396347), isnotnull(sequenceId#3396325), (shardId#3396347 = 0_5_10000000532), (sequenceId#3396325 = 2)]
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#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, measurements#3396344, originalReplenishmentRunId#3396345L, optimizationGroups#3396346, shardId#3396347, sequenceId#3396325]

(21) Filter [codegen id : 3]
Input [38]: [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, measurements#3396344, originalReplenishmentRunId#3396345L, optimizationGroups#3396346, shardId#3396347, sequenceId#3396325]
Condition : isnotnull(worklistShardItemId#3396326L)

(22) Project [codegen id : 3]
Output [36]: [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, measurements#3396344, originalReplenishmentRunId#3396345L, optimizationGroups#3396346]
Input [38]: [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, measurements#3396344, originalReplenishmentRunId#3396345L, optimizationGroups#3396346, shardId#3396347, sequenceId#3396325]

(23) Exchange
Input [36]: [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, measurements#3396344, originalReplenishmentRunId#3396345L, optimizationGroups#3396346]
Arguments: hashpartitioning(worklistShardItemId#3396326L, 30), REPARTITION_BY_NUM, [plan_id=979806]

(24) Project [codegen id : 4]
Output [36]: [worklistShardItemId#3396326L, orderProposalId#3396303L, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, originalReplenishmentRunId#3396345L, splitIndicator#3396322L, previousOrderProposal#3396323L, sourceOfSupplyUuid#3396317, supplierGroup#3396305, supplier#3396306, subrange#3396309, product#3396312, plant#3396307, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, isFallbackOrderOnly#3396320, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, netPriceAmount#3396339, netPriceCurrencyCode#3396340, measurements#3396344, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, logisticUnits#3396330, optimizationGroups#3396346, externalProductId#3396328, externalPlantId#3396329, supplyingPlant#3396310, productGroup#3396311]
Input [36]: [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, sourceOfSupplyUuid#3396317, isFallbackOrderOnly#3396320, splitIndicator#3396322L, previousOrderProposal#3396323L, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, externalProductId#3396328, externalPlantId#3396329, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, measurements#3396344, originalReplenishmentRunId#3396345L, optimizationGroups#3396346]

(25) Sort [codegen id : 4]
Input [36]: [worklistShardItemId#3396326L, orderProposalId#3396303L, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, originalReplenishmentRunId#3396345L, splitIndicator#3396322L, previousOrderProposal#3396323L, sourceOfSupplyUuid#3396317, supplierGroup#3396305, supplier#3396306, subrange#3396309, product#3396312, plant#3396307, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, isFallbackOrderOnly#3396320, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, netPriceAmount#3396339, netPriceCurrencyCode#3396340, measurements#3396344, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, logisticUnits#3396330, optimizationGroups#3396346, externalProductId#3396328, externalPlantId#3396329, supplyingPlant#3396310, productGroup#3396311]
Arguments: [worklistShardItemId#3396326L ASC NULLS FIRST], false, 0

(26) SortMergeJoin [codegen id : 5]
Left keys [1]: [worklistShardItemId#3395820L]
Right keys [1]: [worklistShardItemId#3396326L]
Join type: LeftOuter
Join condition: (shardId#3395105 = 0_5_10000000532)

(27) Project [codegen id : 5]
Output [39]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320]
Input [40]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, worklistShardItemId#3396326L, orderProposalId#3396303L, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, originalReplenishmentRunId#3396345L, splitIndicator#3396322L, previousOrderProposal#3396323L, sourceOfSupplyUuid#3396317, supplierGroup#3396305, supplier#3396306, subrange#3396309, product#3396312, plant#3396307, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, isFallbackOrderOnly#3396320, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, netPriceAmount#3396339, netPriceCurrencyCode#3396340, measurements#3396344, minimumOrderQuantity#3396333, constraintLabels#3396334, constraintOperators#3396335, constraintValues#3396336, logisticUnits#3396330, optimizationGroups#3396346, externalProductId#3396328, externalPlantId#3396329, supplyingPlant#3396310, productGroup#3396311]

(28) Exchange
Input [39]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320]
Arguments: hashpartitioning(shardId#3395105, worklistShardItemId#3395820L, 30), ENSURE_REQUIREMENTS, [plan_id=979815]

(29) Sort [codegen id : 6]
Input [39]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320]
Arguments: [shardId#3395105 ASC NULLS FIRST, worklistShardItemId#3395820L ASC NULLS FIRST], false, 0

(30) Scan ExistingRDD [codegen id : 7]
Output [6]: [shardId#3399769, worklistShardItemId#3399770L, qty#3399771, demandChannel#3399772, demandStream#3399773, kpis#3399774]
Arguments: [shardId#3399769, worklistShardItemId#3399770L, qty#3399771, demandChannel#3399772, demandStream#3399773, kpis#3399774], MapPartitionsRDD[144539] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(31) Filter [codegen id : 7]
Input [6]: [shardId#3399769, worklistShardItemId#3399770L, qty#3399771, demandChannel#3399772, demandStream#3399773, kpis#3399774]
Condition : (((isnull(qty#3399771) AND isnull(demandChannel#3399772)) AND isnull(demandStream#3399773)) AND (isnotnull(shardId#3399769) AND isnotnull(worklistShardItemId#3399770L)))

(32) Project [codegen id : 7]
Output [3]: [shardId#3399769, worklistShardItemId#3399770L, coalesce(kpis#3399774, []) AS prodLocSpecificKpis#3399775]
Input [6]: [shardId#3399769, worklistShardItemId#3399770L, qty#3399771, demandChannel#3399772, demandStream#3399773, kpis#3399774]

(33) Exchange
Input [3]: [shardId#3399769, worklistShardItemId#3399770L, prodLocSpecificKpis#3399775]
Arguments: hashpartitioning(shardId#3399769, worklistShardItemId#3399770L, 30), ENSURE_REQUIREMENTS, [plan_id=979821]

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

(35) SortMergeJoin [codegen id : 9]
Left keys [2]: [shardId#3395105, worklistShardItemId#3395820L]
Right keys [2]: [shardId#3399769, worklistShardItemId#3399770L]
Join type: LeftOuter
Join condition: None

(36) Project [codegen id : 9]
Output [40]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320, coalesce(prodLocSpecificKpis#3399775, []) AS prodLocSpecificKpis#3399776]
Input [42]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320, shardId#3399769, worklistShardItemId#3399770L, prodLocSpecificKpis#3399775]

(37) Scan ExistingRDD [codegen id : 10]
Output [6]: [shardId#3399785, worklistShardItemId#3399786L, qty#3399787, demandChannel#3399788, demandStream#3399789, kpis#3399790]
Arguments: [shardId#3399785, worklistShardItemId#3399786L, qty#3399787, demandChannel#3399788, demandStream#3399789, kpis#3399790], MapPartitionsRDD[144539] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(38) Filter [codegen id : 10]
Input [6]: [shardId#3399785, worklistShardItemId#3399786L, qty#3399787, demandChannel#3399788, demandStream#3399789, kpis#3399790]
Condition : ((((isnull(qty#3399787) AND isnotnull(demandChannel#3399788)) AND isnotnull(demandStream#3399789)) AND (size(kpis#3399790, true) > 0)) AND (isnotnull(shardId#3399785) AND isnotnull(worklistShardItemId#3399786L)))

(39) Project [codegen id : 10]
Output [5]: [shardId#3399785, worklistShardItemId#3399786L, demandChannel#3399788, demandStream#3399789, kpis#3399790]
Input [6]: [shardId#3399785, worklistShardItemId#3399786L, qty#3399787, demandChannel#3399788, demandStream#3399789, kpis#3399790]

(40) ObjectHashAggregate
Input [5]: [shardId#3399785, worklistShardItemId#3399786L, demandChannel#3399788, demandStream#3399789, kpis#3399790]
Keys [2]: [shardId#3399785, worklistShardItemId#3399786L]
Functions [1]: [partial_collect_list(struct(demandChannel, demandChannel#3399788, demandStream, demandStream#3399789, kpis, kpis#3399790), 0, 0)]
Aggregate Attributes [1]: [buf#3401088]
Results [3]: [shardId#3399785, worklistShardItemId#3399786L, buf#3401089]

(41) Exchange
Input [3]: [shardId#3399785, worklistShardItemId#3399786L, buf#3401089]
Arguments: hashpartitioning(shardId#3399785, worklistShardItemId#3399786L, 30), ENSURE_REQUIREMENTS, [plan_id=979832]

(42) ObjectHashAggregate
Input [3]: [shardId#3399785, worklistShardItemId#3399786L, buf#3401089]
Keys [2]: [shardId#3399785, worklistShardItemId#3399786L]
Functions [1]: [collect_list(struct(demandChannel, demandChannel#3399788, demandStream, demandStream#3399789, kpis, kpis#3399790), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(demandChannel, demandChannel#3399788, demandStream, demandStream#3399789, kpis, kpis#3399790), 0, 0)#3399784]
Results [3]: [shardId#3399785, worklistShardItemId#3399786L, collect_list(struct(demandChannel, demandChannel#3399788, demandStream, demandStream#3399789, kpis, kpis#3399790), 0, 0)#3399784 AS channelStreamSpecificKpis#3399777]

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

(44) SortMergeJoin [codegen id : 12]
Left keys [2]: [shardId#3395105, worklistShardItemId#3395820L]
Right keys [2]: [shardId#3399785, worklistShardItemId#3399786L]
Join type: LeftOuter
Join condition: None

(45) Project [codegen id : 12]
Output [41]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320, prodLocSpecificKpis#3399776, coalesce(channelStreamSpecificKpis#3399777, []) AS channelStreamSpecificKpis#3399791]
Input [43]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320, prodLocSpecificKpis#3399776, shardId#3399785, worklistShardItemId#3399786L, channelStreamSpecificKpis#3399777]

(46) Scan ExistingRDD [codegen id : 13]
Output [6]: [shardId#3399798, worklistShardItemId#3399799L, qty#3399800, demandChannel#3399801, demandStream#3399802, kpis#3399803]
Arguments: [shardId#3399798, worklistShardItemId#3399799L, qty#3399800, demandChannel#3399801, demandStream#3399802, kpis#3399803], MapPartitionsRDD[144539] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(47) Filter [codegen id : 13]
Input [6]: [shardId#3399798, worklistShardItemId#3399799L, qty#3399800, demandChannel#3399801, demandStream#3399802, kpis#3399803]
Condition : ((isnotnull(qty#3399800) AND isnotnull(kpis#3399803)) AND (isnotnull(shardId#3399798) AND isnotnull(worklistShardItemId#3399799L)))

(48) Project [codegen id : 13]
Output [4]: [shardId#3399798, worklistShardItemId#3399799L, qty#3399800, kpis#3399803]
Input [6]: [shardId#3399798, worklistShardItemId#3399799L, qty#3399800, demandChannel#3399801, demandStream#3399802, kpis#3399803]

(49) ObjectHashAggregate
Input [4]: [shardId#3399798, worklistShardItemId#3399799L, qty#3399800, kpis#3399803]
Keys [2]: [shardId#3399798, worklistShardItemId#3399799L]
Functions [1]: [partial_collect_list(struct(qty, qty#3399800, kpis, kpis#3399803), 0, 0)]
Aggregate Attributes [1]: [buf#3401090]
Results [3]: [shardId#3399798, worklistShardItemId#3399799L, buf#3401091]

(50) Exchange
Input [3]: [shardId#3399798, worklistShardItemId#3399799L, buf#3401091]
Arguments: hashpartitioning(shardId#3399798, worklistShardItemId#3399799L, 30), ENSURE_REQUIREMENTS, [plan_id=979844]

(51) ObjectHashAggregate
Input [3]: [shardId#3399798, worklistShardItemId#3399799L, buf#3401091]
Keys [2]: [shardId#3399798, worklistShardItemId#3399799L]
Functions [1]: [collect_list(struct(qty, qty#3399800, kpis, kpis#3399803), 0, 0)]
Aggregate Attributes [1]: [collect_list(struct(qty, qty#3399800, kpis, kpis#3399803), 0, 0)#3399797]
Results [3]: [shardId#3399798, worklistShardItemId#3399799L, map_from_entries(collect_list(struct(qty, qty#3399800, kpis, kpis#3399803), 0, 0)#3399797) AS quantityKpis#3399792]

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

(53) SortMergeJoin [codegen id : 15]
Left keys [2]: [shardId#3395105, worklistShardItemId#3395820L]
Right keys [2]: [shardId#3399798, worklistShardItemId#3399799L]
Join type: LeftOuter
Join condition: None

(54) Project [codegen id : 15]
Output [42]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320, prodLocSpecificKpis#3399776, channelStreamSpecificKpis#3399791, coalesce(quantityKpis#3399792, map(keys: [], values: [])) AS quantityKpis#3399804]
Input [44]: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396303L, originalReplenishmentRunId#3396345L, supplierGroup#3396305, supplier#3396306, supplyingPlant#3396310, productGroup#3396311, product#3396312, plant#3396307, subrange#3396309, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, constraintValues#3396336, constraintOperators#3396335, constraintLabels#3396334, logisticUnits#3396330, orderQuantityBaseUom#3396331, orderQuantityBaseUomUuid#3396332, splitIndicator#3396322L, netPriceAmount#3396339, netPriceCurrencyCode#3396340, netPriceQuantity#3396341, netPriceQuantityUom#3396342, netPriceQuantityUomUuid#3396343, sourceOfSupplyUuid#3396317, minimumOrderQuantity#3396333, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, optimizationGroups#3396346, measurements#3396344, externalProductId#3396328, externalPlantId#3396329, previousOrderProposal#3396323L, isFallbackOrderOnly#3396320, prodLocSpecificKpis#3399776, channelStreamSpecificKpis#3399791, shardId#3399798, worklistShardItemId#3399799L, quantityKpis#3399792]

(55) Filter [codegen id : 1]
Input [39]: [availabilityDateTime#3396190, channelStreamSpecificKpis#3399791, constraintLabels#3396202, constraintOperators#3396203, constraintValues#3396205, deliveryDateTime#3396189, isFallbackOrderOnly#3396192, logisticUnits#3396207, measurements#3396200, minimumOrderQuantity#3396201, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, nextAvailabilityDateTime#3396191, optimizationGroups#3396208, orderDateTime#3396188, orderProposalId#3396170L, orderProposalItemGroupId#3396172, orderProposalItemId#3396171, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, originalReplenishmentRunId#3396173L, plant#3396184, previousOrderProposal#3396176L, prodLocSpecificKpis#3399776, product#3396183, productGroup#3396212, qty#3395822, quantityAfterProdPlantOptimization#3395821, quantityKpis#3399804, shardId#3395105, sourceOfSupplyUuid#3396179, splitIndicator#3396175L, subrange#3396182, supplier#3396181, supplierGroup#3396180, supplyingPlant#3396211]
Condition : NOT (isFallbackOrderOnly#3396192 <=> true)

(56) Project [codegen id : 1]
Output [36]: [shardId#3395105, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, sourceOfSupplyUuid#3396179, minimumOrderQuantity#3396201, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, optimizationGroups#3396208, measurements#3396200, previousOrderProposal#3396176L, prodLocSpecificKpis#3399776, channelStreamSpecificKpis#3399791, quantityKpis#3399804, arrays_zip(constraintLabels#3396202, constraintOperators#3396203, constraintValues#3396205, constraintLabels, constraintOperators, constraintValues) AS constraintStructArray#3401341]
Input [39]: [availabilityDateTime#3396190, channelStreamSpecificKpis#3399791, constraintLabels#3396202, constraintOperators#3396203, constraintValues#3396205, deliveryDateTime#3396189, isFallbackOrderOnly#3396192, logisticUnits#3396207, measurements#3396200, minimumOrderQuantity#3396201, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, nextAvailabilityDateTime#3396191, optimizationGroups#3396208, orderDateTime#3396188, orderProposalId#3396170L, orderProposalItemGroupId#3396172, orderProposalItemId#3396171, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, originalReplenishmentRunId#3396173L, plant#3396184, previousOrderProposal#3396176L, prodLocSpecificKpis#3399776, product#3396183, productGroup#3396212, qty#3395822, quantityAfterProdPlantOptimization#3395821, quantityKpis#3399804, shardId#3395105, sourceOfSupplyUuid#3396179, splitIndicator#3396175L, subrange#3396182, supplier#3396181, supplierGroup#3396180, supplyingPlant#3396211]

(57) Project
Output [37]: [shardId#3395105, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, sourceOfSupplyUuid#3396179, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, optimizationGroups#3396208, measurements#3396200, previousOrderProposal#3396176L, prodLocSpecificKpis#3399776, channelStreamSpecificKpis#3399791, quantityKpis#3399804, struct(minServiceLevel, array_min(filter(constraintStructArray#3401341, lambdafunction((lambda x_11247#3401348.constraintLabels = ServiceLevel), lambda x_11247#3401348, false)).constraintValues), minServiceLevelMinStock, array_min(filter(constraintStructArray#3401341, lambdafunction((lambda x_11248#3401349.constraintLabels = ServiceLevelMinimumStock), lambda x_11248#3401349, false)).constraintValues), maxServiceLevelEndOfListing, array_min(filter(constraintStructArray#3401341, lambdafunction((lambda x_11249#3401350.constraintLabels = ServiceLevelAtStartOfDelisting), lambda x_11249#3401350, false)).constraintValues), maxRoc, array_min(filter(constraintStructArray#3401341, lambdafunction((lambda x_11250#3401351.constraintLabels = RangeOfCoverage), lambda x_11250#3401351, false)).constraintValues), minimumOrderQuantity, minimumOrderQuantity#3396201, endOfListingDateTime, coalesce(filter(prodLocSpecificKpis#3399776, lambdafunction((lambda x_11251#3401352.label = NonListingStartTimestamp), lambda x_11251#3401352, false))[0].dateTime, 1970-01-01 00:00:00)) AS constraintBenchmark#3401347, CASE WHEN (qty#3395822 <=> quantityAfterProdPlantOptimization#3395821) THEN array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((qty#3395822 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401420.isOrderUnit, lambda x_11252#3401420, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401421.isOrderUnit, lambda x_11252#3401421, false)), 1, None, false).numerator as double))), qty#3395822), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401422.isOrderUnit, lambda x_11252#3401422, false)), 1, None, false).uom, orderQuantityBaseUom#3396193), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401423.isOrderUnit, lambda x_11252#3401423, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194), candidateOrderQuantityInBaseUnit, qty#3395822, orderQuantityBaseUom, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3396194, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11254#3401424.isPreferred AND (((qty#3395822 * cast(lambda x_11254#3401424.denominator as double)) % cast(lambda x_11254#3401424.numerator as double)) = 0.0)), lambda x_11254#3401424, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395822 * cast(lambda x_11255#3401465.denominator as double)) / cast(lambda x_11255#3401465.numerator as double)), uom, lambda x_11255#3401465.uom, uomUuid, lambda x_11255#3401465.uomUuid), lambda x_11255#3401465, false))).inPreferredQuantity, coalesce((qty#3395822 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401425.isOrderUnit, lambda x_11253#3401425, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401426.isOrderUnit, lambda x_11253#3401426, false)), 1, None, false).numerator as double))), qty#3395822)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11254#3401427.isPreferred AND (((qty#3395822 * cast(lambda x_11254#3401427.denominator as double)) % cast(lambda x_11254#3401427.numerator as double)) = 0.0)), lambda x_11254#3401427, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395822 * cast(lambda x_11255#3401466.denominator as double)) / cast(lambda x_11255#3401466.numerator as double)), uom, lambda x_11255#3401466.uom, uomUuid, lambda x_11255#3401466.uomUuid), lambda x_11255#3401466, false))).uom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401428.isOrderUnit, lambda x_11253#3401428, false)), 1, None, false).uom, orderQuantityBaseUom#3396193)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11254#3401429.isPreferred AND (((qty#3395822 * cast(lambda x_11254#3401429.denominator as double)) % cast(lambda x_11254#3401429.numerator as double)) = 0.0)), lambda x_11254#3401429, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395822 * cast(lambda x_11255#3401467.denominator as double)) / cast(lambda x_11255#3401467.numerator as double)), uom, lambda x_11255#3401467.uom, uomUuid, lambda x_11255#3401467.uomUuid), lambda x_11255#3401467, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401430.isOrderUnit, lambda x_11253#3401430, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194)), serviceLevel, coalesce(filter(element_at(quantityKpis#3399804, qty#3395822, None, false), lambdafunction((lambda x_11260#3401431.label = ServiceLevel), lambda x_11260#3401431, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) ELSE array(struct(isProposedCandidate, true, isProdlocOptimalCandidate, false, candidateOrderQuantity, coalesce((qty#3395822 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401435.isOrderUnit, lambda x_11252#3401435, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401436.isOrderUnit, lambda x_11252#3401436, false)), 1, None, false).numerator as double))), qty#3395822), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401437.isOrderUnit, lambda x_11252#3401437, false)), 1, None, false).uom, orderQuantityBaseUom#3396193), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11252#3401438.isOrderUnit, lambda x_11252#3401438, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194), candidateOrderQuantityInBaseUnit, qty#3395822, orderQuantityBaseUom, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3396194, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11254#3401439.isPreferred AND (((qty#3395822 * cast(lambda x_11254#3401439.denominator as double)) % cast(lambda x_11254#3401439.numerator as double)) = 0.0)), lambda x_11254#3401439, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395822 * cast(lambda x_11255#3401468.denominator as double)) / cast(lambda x_11255#3401468.numerator as double)), uom, lambda x_11255#3401468.uom, uomUuid, lambda x_11255#3401468.uomUuid), lambda x_11255#3401468, false))).inPreferredQuantity, coalesce((qty#3395822 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401440.isOrderUnit, lambda x_11253#3401440, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401441.isOrderUnit, lambda x_11253#3401441, false)), 1, None, false).numerator as double))), qty#3395822)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11254#3401442.isPreferred AND (((qty#3395822 * cast(lambda x_11254#3401442.denominator as double)) % cast(lambda x_11254#3401442.numerator as double)) = 0.0)), lambda x_11254#3401442, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395822 * cast(lambda x_11255#3401469.denominator as double)) / cast(lambda x_11255#3401469.numerator as double)), uom, lambda x_11255#3401469.uom, uomUuid, lambda x_11255#3401469.uomUuid), lambda x_11255#3401469, false))).uom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401443.isOrderUnit, lambda x_11253#3401443, false)), 1, None, false).uom, orderQuantityBaseUom#3396193)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11254#3401444.isPreferred AND (((qty#3395822 * cast(lambda x_11254#3401444.denominator as double)) % cast(lambda x_11254#3401444.numerator as double)) = 0.0)), lambda x_11254#3401444, false)), lambdafunction(struct(inPreferredQuantity, ((qty#3395822 * cast(lambda x_11255#3401470.denominator as double)) / cast(lambda x_11255#3401470.numerator as double)), uom, lambda x_11255#3401470.uom, uomUuid, lambda x_11255#3401470.uomUuid), lambda x_11255#3401470, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11253#3401445.isOrderUnit, lambda x_11253#3401445, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194)), serviceLevel, coalesce(filter(element_at(quantityKpis#3399804, qty#3395822, None, false), lambdafunction((lambda x_11264#3401446.label = ServiceLevel), lambda x_11264#3401446, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields), struct(isProposedCandidate, false, isProdlocOptimalCandidate, true, candidateOrderQuantity, coalesce((quantityAfterProdPlantOptimization#3395821 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11256#3401450.isOrderUnit, lambda x_11256#3401450, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11256#3401451.isOrderUnit, lambda x_11256#3401451, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#3395821), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11256#3401452.isOrderUnit, lambda x_11256#3401452, false)), 1, None, false).uom, orderQuantityBaseUom#3396193), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11256#3401453.isOrderUnit, lambda x_11256#3401453, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194), candidateOrderQuantityInBaseUnit, quantityAfterProdPlantOptimization#3395821, orderQuantityBaseUom, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid, orderQuantityBaseUomUuid#3396194, candidateOrderQuantityInPreferredUnit, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11258#3401454.isPreferred AND (((quantityAfterProdPlantOptimization#3395821 * cast(lambda x_11258#3401454.denominator as double)) % cast(lambda x_11258#3401454.numerator as double)) = 0.0)), lambda x_11258#3401454, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395821 * cast(lambda x_11259#3401471.denominator as double)) / cast(lambda x_11259#3401471.numerator as double)), uom, lambda x_11259#3401471.uom, uomUuid, lambda x_11259#3401471.uomUuid), lambda x_11259#3401471, false))).inPreferredQuantity, coalesce((quantityAfterProdPlantOptimization#3395821 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11257#3401455.isOrderUnit, lambda x_11257#3401455, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11257#3401456.isOrderUnit, lambda x_11257#3401456, false)), 1, None, false).numerator as double))), quantityAfterProdPlantOptimization#3395821)), orderQuantityPreferredUom, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11258#3401457.isPreferred AND (((quantityAfterProdPlantOptimization#3395821 * cast(lambda x_11258#3401457.denominator as double)) % cast(lambda x_11258#3401457.numerator as double)) = 0.0)), lambda x_11258#3401457, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395821 * cast(lambda x_11259#3401472.denominator as double)) / cast(lambda x_11259#3401472.numerator as double)), uom, lambda x_11259#3401472.uom, uomUuid, lambda x_11259#3401472.uomUuid), lambda x_11259#3401472, false))).uom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11257#3401458.isOrderUnit, lambda x_11257#3401458, false)), 1, None, false).uom, orderQuantityBaseUom#3396193)), orderQuantityPreferredUomUuid, coalesce(array_min(transform(filter(logisticUnits#3396207, lambdafunction((lambda x_11258#3401459.isPreferred AND (((quantityAfterProdPlantOptimization#3395821 * cast(lambda x_11258#3401459.denominator as double)) % cast(lambda x_11258#3401459.numerator as double)) = 0.0)), lambda x_11258#3401459, false)), lambdafunction(struct(inPreferredQuantity, ((quantityAfterProdPlantOptimization#3395821 * cast(lambda x_11259#3401473.denominator as double)) / cast(lambda x_11259#3401473.numerator as double)), uom, lambda x_11259#3401473.uom, uomUuid, lambda x_11259#3401473.uomUuid), lambda x_11259#3401473, false))).uomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11257#3401460.isOrderUnit, lambda x_11257#3401460, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194)), serviceLevel, coalesce(filter(element_at(quantityKpis#3399804, quantityAfterProdPlantOptimization#3395821, None, false), lambdafunction((lambda x_11268#3401461.label = ServiceLevel), lambda x_11268#3401461, false))[0].value, 0.0), serviceLevelMinStock, ... 5 more fields)) END AS calculationAnalysis#3401419, coalesce(filter(prodLocSpecificKpis#3399776, lambdafunction((lambda x_11272#3401475.label = InitialStockQty), lambda x_11272#3401475, false))[0].dateTime, 1970-01-01 00:00:00) AS inventoryDateTime#3401474, coalesce(filter(prodLocSpecificKpis#3399776, lambdafunction((lambda x_11273#3401477.label = DemandPeriodEndTimestamp), lambda x_11273#3401477, false))[0].dateTime, 1970-01-01 00:00:00) AS demandPeriodEndDateTime#3401476]
Input [36]: [shardId#3395105, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, sourceOfSupplyUuid#3396179, minimumOrderQuantity#3396201, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, optimizationGroups#3396208, measurements#3396200, previousOrderProposal#3396176L, prodLocSpecificKpis#3399776, channelStreamSpecificKpis#3399791, quantityKpis#3399804, constraintStructArray#3401341]

(58) Project
Output [21]: [shardId#3395105, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, previousOrderProposal#3396176L, struct(itemId, orderProposalItemId#3396171, itemGroupId, orderProposalItemGroupId#3396172, supplier, supplier#3396181, supplyingPlant, supplyingPlant#3396211, productGroup, productGroup#3396212, product, product#3396183, plant, plant#3396184, supplierSubRange, subrange#3396182, sourceOfSupplyUuid, sourceOfSupplyUuid#3396179, deliveryDateTime, deliveryDateTime#3396189, unitPrice, netPriceAmount#3396198, unitPriceCurrency, netPriceCurrencyCode#3396199, unitPriceQuantity, ... 37 more fields) AS parentItem#3401550]
Input [37]: [shardId#3395105, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, netPriceCurrencyCode#3396199, netPriceQuantity#3396195, netPriceQuantityUom#3396196, netPriceQuantityUomUuid#3396197, sourceOfSupplyUuid#3396179, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, optimizationGroups#3396208, measurements#3396200, previousOrderProposal#3396176L, prodLocSpecificKpis#3399776, channelStreamSpecificKpis#3399791, quantityKpis#3399804, constraintBenchmark#3401347, calculationAnalysis#3401419, inventoryDateTime#3401474, demandPeriodEndDateTime#3401476]

(59) Project
Output [12]: [shardId#3395105, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, orderDateTime#3396188, splitIndicator#3396175L, orderProposalItemGroupId#3396172, previousOrderProposal#3396176L, parentItem#3401550, struct(itemId, orderProposalItemId#3396171, supplier, supplier#3396181, supplyingPlant, supplyingPlant#3396211, productGroup, productGroup#3396212, product, product#3396183, plant, plant#3396184, supplierSubRange, subrange#3396182, deliveryDateTime, deliveryDateTime#3396189, orderQuantity, coalesce((qty#3395822 * (cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401584.isOrderUnit, lambda x_11297#3401584, false)), 1, None, false).denominator as double) / cast(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401585.isOrderUnit, lambda x_11297#3401585, false)), 1, None, false).numerator as double))), qty#3395822), orderQuantityUom, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401586.isOrderUnit, lambda x_11297#3401586, false)), 1, None, false).uom, orderQuantityBaseUom#3396193), orderQuantityUomUuid, coalesce(element_at(filter(logisticUnits#3396207, lambdafunction(lambda x_11297#3401587.isOrderUnit, lambda x_11297#3401587, false)), 1, None, false).uomUuid, orderQuantityBaseUomUuid#3396194), orderQuantityInBaseUnit, qty#3395822, orderQuantityBaseUom, ... 13 more fields) AS item#3401581]
Input [21]: [shardId#3395105, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, previousOrderProposal#3396176L, parentItem#3401550]

(60) ObjectHashAggregate
Input [12]: [shardId#3395105, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, orderDateTime#3396188, splitIndicator#3396175L, orderProposalItemGroupId#3396172, previousOrderProposal#3396176L, parentItem#3401550, item#3401581]
Keys [4]: [shardId#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172]
Functions [8]: [partial_max(originalReplenishmentRunId#3396173L), partial_max(supplierGroup#3396180), partial_max(supplier#3396181), partial_max(supplyingPlant#3396211), partial_max(orderDateTime#3396188), partial_collect_list(parentItem#3401550, 0, 0), partial_collect_set(previousOrderProposal#3396176L, 0, 0), partial_collect_list(item#3401581, 0, 0)]
Aggregate Attributes [8]: [max#3402905L, max#3402906, max#3402907, max#3402908, max#3402909, buf#3402910, buf#3402911, buf#3402912]
Results [12]: [shardId#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172, max#3402913L, max#3402914, max#3402915, max#3402916, max#3402917, buf#3402918, buf#3402919, buf#3402920]

(61) Exchange
Input [12]: [shardId#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172, max#3402913L, max#3402914, max#3402915, max#3402916, max#3402917, buf#3402918, buf#3402919, buf#3402920]
Arguments: hashpartitioning(shardId#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172, 30), ENSURE_REQUIREMENTS, [plan_id=980135]

(62) ObjectHashAggregate
Input [12]: [shardId#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172, max#3402913L, max#3402914, max#3402915, max#3402916, max#3402917, buf#3402918, buf#3402919, buf#3402920]
Keys [4]: [shardId#3395105, orderProposalId#3396170L, splitIndicator#3396175L, orderProposalItemGroupId#3396172]
Functions [8]: [max(originalReplenishmentRunId#3396173L), max(supplierGroup#3396180), max(supplier#3396181), max(supplyingPlant#3396211), max(orderDateTime#3396188), collect_list(parentItem#3401550, 0, 0), collect_set(previousOrderProposal#3396176L, 0, 0), collect_list(item#3401581, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#3396173L)#3401650L, max(supplierGroup#3396180)#3401651, max(supplier#3396181)#3401652, max(supplyingPlant#3396211)#3401653, max(orderDateTime#3396188)#3401654, collect_list(parentItem#3401550, 0, 0)#3401655, collect_set(previousOrderProposal#3396176L, 0, 0)#3401657, collect_list(item#3401581, 0, 0)#3401656]
Results [10]: [shardId#3395105, orderProposalId#3396170L, max(originalReplenishmentRunId#3396173L)#3401650L AS originalReplenishmentRunId#3401598L, max(supplierGroup#3396180)#3401651 AS supplierGroup#3401599, max(supplier#3396181)#3401652 AS supplier#3401600, max(supplyingPlant#3396211)#3401653 AS supplyingPlant#3401601, max(orderDateTime#3396188)#3401654 AS orderDateTime#3401602, collect_list(parentItem#3401550, 0, 0)#3401655 AS parentItems#3401603, collect_set(previousOrderProposal#3396176L, 0, 0)#3401657 AS previousOrderProposals#3401605, struct(itemGroupId, orderProposalItemGroupId#3396172, items, collect_list(item#3401581, 0, 0)#3401656) AS itemGroup#3401659]

(63) ObjectHashAggregate
Input [10]: [shardId#3395105, orderProposalId#3396170L, originalReplenishmentRunId#3401598L, supplierGroup#3401599, supplier#3401600, supplyingPlant#3401601, orderDateTime#3401602, parentItems#3401603, previousOrderProposals#3401605, itemGroup#3401659]
Keys [2]: [shardId#3395105, orderProposalId#3396170L]
Functions [8]: [partial_max(originalReplenishmentRunId#3401598L), partial_max(supplierGroup#3401599), partial_max(supplier#3401600), partial_max(supplyingPlant#3401601), partial_max(orderDateTime#3401602), partial_collect_list(itemGroup#3401659, 0, 0), partial_collect_list(parentItems#3401603, 0, 0), partial_collect_set(previousOrderProposals#3401605, 0, 0)]
Aggregate Attributes [8]: [max#3402889L, max#3402890, max#3402891, max#3402892, max#3402893, buf#3402894, buf#3402895, buf#3402896]
Results [10]: [shardId#3395105, orderProposalId#3396170L, max#3402897L, max#3402898, max#3402899, max#3402900, max#3402901, buf#3402902, buf#3402903, buf#3402904]

(64) Exchange
Input [10]: [shardId#3395105, orderProposalId#3396170L, max#3402897L, max#3402898, max#3402899, max#3402900, max#3402901, buf#3402902, buf#3402903, buf#3402904]
Arguments: hashpartitioning(shardId#3395105, orderProposalId#3396170L, 30), ENSURE_REQUIREMENTS, [plan_id=980138]

(65) ObjectHashAggregate
Input [10]: [shardId#3395105, orderProposalId#3396170L, max#3402897L, max#3402898, max#3402899, max#3402900, max#3402901, buf#3402902, buf#3402903, buf#3402904]
Keys [2]: [shardId#3395105, orderProposalId#3396170L]
Functions [8]: [max(originalReplenishmentRunId#3401598L), max(supplierGroup#3401599), max(supplier#3401600), max(supplyingPlant#3401601), max(orderDateTime#3401602), collect_list(itemGroup#3401659, 0, 0), collect_list(parentItems#3401603, 0, 0), collect_set(previousOrderProposals#3401605, 0, 0)]
Aggregate Attributes [8]: [max(originalReplenishmentRunId#3401598L)#3401681L, max(supplierGroup#3401599)#3401682, max(supplier#3401600)#3401683, max(supplyingPlant#3401601)#3401684, max(orderDateTime#3401602)#3401685, collect_list(itemGroup#3401659, 0, 0)#3401686, collect_list(parentItems#3401603, 0, 0)#3401687, collect_set(previousOrderProposals#3401605, 0, 0)#3401688]
Results [10]: [shardId#3395105, orderProposalId#3396170L, max(originalReplenishmentRunId#3401598L)#3401681L AS originalReplenishmentRunId#3401660L, max(supplierGroup#3401599)#3401682 AS supplierGroup#3401661, max(supplier#3401600)#3401683 AS supplier#3401662, max(supplyingPlant#3401601)#3401684 AS supplyingPlant#3401663, max(orderDateTime#3401602)#3401685 AS orderDateTime#3401664, collect_list(itemGroup#3401659, 0, 0)#3401686 AS itemGroups#3401665, flatten(collect_list(parentItems#3401603, 0, 0)#3401687) AS parentItems#3401666, flatten(collect_set(previousOrderProposals#3401605, 0, 0)#3401688) AS previousOrderProposals#3401667]

(66) Project
Output [2]: [shardId#3395105, struct(orderProposalId, orderProposalId#3396170L, originalReplenishmentRunId, originalReplenishmentRunId#3401660L, supplierGroup, supplierGroup#3401661, optimizationGroups, null, supplier, CASE WHEN isnull(supplierGroup#3401661) THEN supplier#3401662 END, supplyingPlant, supplyingPlant#3401663, orderDateTime, orderDateTime#3401664, itemGroups, itemGroups#3401665, previousOrderProposals, array_distinct(previousOrderProposals#3401667), parentItems, parentItems#3401666) AS orderProposal#3401692]
Input [10]: [shardId#3395105, orderProposalId#3396170L, originalReplenishmentRunId#3401660L, supplierGroup#3401661, supplier#3401662, supplyingPlant#3401663, orderDateTime#3401664, itemGroups#3401665, parentItems#3401666, previousOrderProposals#3401667]

(67) Project
Output [11]: [shardId#3395105, orderProposal#3401692.orderProposalId AS _extract_orderProposalId#3402521L, orderProposal#3401692.originalReplenishmentRunId AS _extract_originalReplenishmentRunId#3402522L, orderProposal#3401692.supplierGroup AS _extract_supplierGroup#3402523, orderProposal#3401692.supplier AS _extract_supplier#3402524, orderProposal#3401692.supplyingPlant AS _extract_supplyingPlant#3402525, orderProposal#3401692.orderDateTime AS _extract_orderDateTime#3402526, orderProposal#3401692.itemGroups AS _extract_itemGroups#3402527, orderProposal#3401692.previousOrderProposals AS _extract_previousOrderProposals#3402528, orderProposal#3401692.parentItems AS _extract_parentItems#3402529, orderProposal#3401692.orderProposalId AS _extract_orderProposalId#3402530L]
Input [2]: [shardId#3395105, orderProposal#3401692]

(68) Exchange
Input [11]: [shardId#3395105, _extract_orderProposalId#3402521L, _extract_originalReplenishmentRunId#3402522L, _extract_supplierGroup#3402523, _extract_supplier#3402524, _extract_supplyingPlant#3402525, _extract_orderDateTime#3402526, _extract_itemGroups#3402527, _extract_previousOrderProposals#3402528, _extract_parentItems#3402529, _extract_orderProposalId#3402530L]
Arguments: hashpartitioning(coalesce(shardId#3395105, ), isnull(shardId#3395105), coalesce(_extract_orderProposalId#3402530L, 0), isnull(_extract_orderProposalId#3402530L), 30), ENSURE_REQUIREMENTS, [plan_id=980142]

(69) Sort
Input [11]: [shardId#3395105, _extract_orderProposalId#3402521L, _extract_originalReplenishmentRunId#3402522L, _extract_supplierGroup#3402523, _extract_supplier#3402524, _extract_supplyingPlant#3402525, _extract_orderDateTime#3402526, _extract_itemGroups#3402527, _extract_previousOrderProposals#3402528, _extract_parentItems#3402529, _extract_orderProposalId#3402530L]
Arguments: [coalesce(shardId#3395105, ) ASC NULLS FIRST, isnull(shardId#3395105) ASC NULLS FIRST, coalesce(_extract_orderProposalId#3402530L, 0) ASC NULLS FIRST, isnull(_extract_orderProposalId#3402530L) ASC NULLS FIRST], false, 0

(70) InMemoryTableScan
Output [3]: [shardId#3401707, orderProposalId#3401708L, optimizationGroups#3401710]
Arguments: [shardId#3401707, orderProposalId#3401708L, optimizationGroups#3401710], [isnotnull(orderProposalId#3401708L)]

(71) InMemoryRelation
Arguments: [shardId#3401707, orderProposalId#3401708L, items#3401709, optimizationGroups#3401710, isOptimal#3401711, optimizationInsights#3401713], StorageLevel(disk, memory, 2 replicas)

(72) Filter [codegen id : 2]
Input [3]: [shardId#3401707, orderProposalId#3401708L, optimizationGroups#3401710]
Condition : isnotnull(orderProposalId#3401708L)

(73) Exchange
Input [3]: [shardId#3401707, orderProposalId#3401708L, optimizationGroups#3401710]
Arguments: hashpartitioning(orderProposalId#3401708L, 30), ENSURE_REQUIREMENTS, [plan_id=980147]

(74) Sort [codegen id : 3]
Input [3]: [shardId#3401707, orderProposalId#3401708L, optimizationGroups#3401710]
Arguments: [orderProposalId#3401708L ASC NULLS FIRST], false, 0

(75) InMemoryTableScan
Output [2]: [items#3401336, shardId#3401334]
Arguments: [items#3401336, shardId#3401334], [(size(items#3401336.worklistShardItemId, true) > 0), isnotnull(items#3401336.worklistShardItemId), (shardId#3401334 = 0_5_10000000532)]

(76) InMemoryRelation
Arguments: [shardId#3401334, orderProposalId#3401335L, items#3401336, optimizationGroups#3401337, isOptimal#3401338, optimizationInsights#3401340], StorageLevel(disk, memory, 2 replicas)

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

(78) Project [codegen id : 4]
Output [1]: [items#3401336.worklistShardItemId AS _extract_worklistShardItemId#3402355]
Input [2]: [items#3401336, shardId#3401334]

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

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

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

(82) Scan parquet 
Output [5]: [orderProposalId#3401763L, isFallbackOrderOnly#3401780, worklistShardItemId#3401786L, shardId#3401807, sequenceId#3401785]
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#3401807), isnotnull(sequenceId#3401785), (shardId#3401807 = 0_5_10000000532), (sequenceId#3401785 = 2)]
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#3401763L, isFallbackOrderOnly#3401780, worklistShardItemId#3401786L, shardId#3401807, sequenceId#3401785]

(84) Filter [codegen id : 5]
Input [5]: [orderProposalId#3401763L, isFallbackOrderOnly#3401780, worklistShardItemId#3401786L, shardId#3401807, sequenceId#3401785]
Condition : ((isnotnull(worklistShardItemId#3401786L) AND NOT (isFallbackOrderOnly#3401780 <=> true)) AND isnotnull(orderProposalId#3401763L))

(85) Project [codegen id : 5]
Output [2]: [orderProposalId#3401763L, worklistShardItemId#3401786L]
Input [5]: [orderProposalId#3401763L, isFallbackOrderOnly#3401780, worklistShardItemId#3401786L, shardId#3401807, sequenceId#3401785]

(86) Exchange
Input [2]: [orderProposalId#3401763L, worklistShardItemId#3401786L]
Arguments: hashpartitioning(worklistShardItemId#3401786L, 30), REPARTITION_BY_NUM, [plan_id=980165]

(87) Project
Output [2]: [worklistShardItemId#3401786L, orderProposalId#3401763L]
Input [2]: [orderProposalId#3401763L, worklistShardItemId#3401786L]

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

(89) Project [codegen id : 6]
Output [1]: [orderProposalId#3401763L]
Input [3]: [worklistShardItemId#3401715L, worklistShardItemId#3401786L, orderProposalId#3401763L]

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

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

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

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

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

(95) Project
Output [3]: [orderProposalId#3401708L, shardId#3401707, coalesce(transform(optimizationGroups#3401710, lambdafunction(struct(optGroupId, lambda x_11301#3401705.optGroupId, minOrderProfile, lambda x_11301#3401705.minOrderProfile, assignmentDetails, lambda x_11301#3401705.assignmentDetails, minOrdBenchmark, struct(dimensionType, lambda x_11301#3401705.minOrderGoal.dimensionType, unit, lambda x_11301#3401705.minOrderGoal.unit, unitUuid, lambda x_11301#3401705.minOrderGoal.unitUuid, goalValue, lambda x_11301#3401705.minOrderGoal.minOrderValue, calcValue, lambda x_11301#3401705.minOrderGoal.calculatedOrderValue), transportLoadProfile, null, transportLoadGoal, null), lambda x_11301#3401705, false)), []) AS optimizationGroups#3401704]
Input [4]: [shardId#3401707, orderProposalId#3401708L, optimizationGroups#3401710, orderProposalId#3401763L]

(96) Exchange
Input [3]: [orderProposalId#3401708L, shardId#3401707, optimizationGroups#3401704]
Arguments: hashpartitioning(coalesce(shardId#3401707, ), isnull(shardId#3401707), coalesce(orderProposalId#3401708L, 0), isnull(orderProposalId#3401708L), 30), ENSURE_REQUIREMENTS, [plan_id=980181]

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

(98) SortMergeJoin
Left keys [4]: [coalesce(shardId#3395105, ), isnull(shardId#3395105), coalesce(_extract_orderProposalId#3402530L, 0), isnull(_extract_orderProposalId#3402530L)]
Right keys [4]: [coalesce(shardId#3401707, ), isnull(shardId#3401707), coalesce(orderProposalId#3401708L, 0), isnull(orderProposalId#3401708L)]
Join type: LeftOuter
Join condition: None

(99) Project
Output [2]: [shardId#3395105, named_struct(orderProposalId, _extract_orderProposalId#3402530L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#3402522L, supplierGroup, _extract_supplierGroup#3402523, optimizationGroups, coalesce(optimizationGroups#3401704, []), supplier, _extract_supplier#3402524, supplyingPlant, _extract_supplyingPlant#3402525, orderDateTime, _extract_orderDateTime#3402526, itemGroups, _extract_itemGroups#3402527, previousOrderProposals, _extract_previousOrderProposals#3402528, parentItems, _extract_parentItems#3402529) AS orderProposal#3401811]
Input [14]: [shardId#3395105, _extract_orderProposalId#3402521L, _extract_originalReplenishmentRunId#3402522L, _extract_supplierGroup#3402523, _extract_supplier#3402524, _extract_supplyingPlant#3402525, _extract_orderDateTime#3402526, _extract_itemGroups#3402527, _extract_previousOrderProposals#3402528, _extract_parentItems#3402529, _extract_orderProposalId#3402530L, orderProposalId#3401708L, shardId#3401707, optimizationGroups#3401704]

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

(101) ObjectHashAggregate
Input [3]: [shardId#3395105, orderProposal#3401811, resultSeparationId#3406938L]
Keys [2]: [shardId#3395105, resultSeparationId#3406938L]
Functions [1]: [partial_collect_list(orderProposal#3401811, 0, 0)]
Aggregate Attributes [1]: [buf#3406977]
Results [3]: [shardId#3395105, resultSeparationId#3406938L, buf#3406978]

(102) Exchange
Input [3]: [shardId#3395105, resultSeparationId#3406938L, buf#3406978]
Arguments: hashpartitioning(shardId#3395105, resultSeparationId#3406938L, 30), ENSURE_REQUIREMENTS, [plan_id=981297]

(103) ObjectHashAggregate
Input [3]: [shardId#3395105, resultSeparationId#3406938L, buf#3406978]
Keys [2]: [shardId#3395105, resultSeparationId#3406938L]
Functions [1]: [collect_list(orderProposal#3401811, 0, 0)]
Aggregate Attributes [1]: [collect_list(orderProposal#3401811, 0, 0)#3406946]
Results [3]: [shardId#3395105, resultSeparationId#3406938L, collect_list(orderProposal#3401811, 0, 0)#3406946 AS orderProposals#3406942]

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

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

(106) HashAggregate [codegen id : 2]
Input [1]: [count#3407056L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#3407009L]
Results [1]: [count(1)#3407009L AS count#3407005L]

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	6
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	b13104f5-e344-322f-bff3-a09d5377c4e4
temporal.activity.type	RunStreamWithId