== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Filter (24)
+- Project (23)
+- Project (22)
+- Project (21)
+- Project (20)
+- Join (19)
:- Project (9)
: +- Project (8)
: +- Generate (7)
: +- Project (6)
: +- Filter (5)
: +- Filter (4)
: +- LogicalRDD (3)
+- Union (18)
:- LocalRelation (10)
+- Project (17)
+- Project (16)
+- Project (15)
+- Filter (14)
+- RepartitionByExpression (13)
+- Filter (12)
+- LogicalRelation (11)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.delta.sources.DeltaDataSource@49e5610d, [path=hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000532/stream-10000000532-1/shardId=0_7_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, lastModified#3394579, optimizationInsights#3394580], false
(4) Filter
Arguments: shardId#3394574 IN (0_7_10000000532)
(5) Filter
Arguments: shardId#3394574 IN (0_7_10000000532)
(6) Project
Arguments: [shardId#3394574, orderProposalId#3394575L, items#3394576, optimizationGroups#3394577, isOptimal#3394578, optimizationInsights#3394580]
(7) Generate
Arguments: explode(items#3394576), false, [item#3395326]
(8) Project
Arguments: [shardId#3394574, item#3395326]
(9) Project
Arguments: [shardId#3394574, item#3395326.worklistShardItemId AS worklistShardItemId#3395327L, item#3395326.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395328, item#3395326.qty AS qty#3395329]
(10) LocalRelation
Arguments: <empty>, [shardId#3395773, worklistShardItemId#3395774L, orderProposalId#3395775L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, originalReplenishmentRunId#3395778L, orderProposalHorizonGroupingId#3395779L, splitIndicator#3395780L, previousOrderProposal#3395781L, clusterId#3395782L, sequenceId#3395783L, sourceOfSupplyUuid#3395784, supplierGroup#3395785, supplier#3395786, subrange#3395787, product#3395788, plant#3395789, purchasingOrg#3395790, purchasingGroup#3395791, mrpController#3395792, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, isFallbackOrderOnly#3395797, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, mrpController#3395989, sourceOfSupplyUuid#3395990, purchasingOrg#3395991, purchasingGroup#3395992, isFallbackOrderOnly#3395993, orderProposalHorizonGroupingId#3395994L, splitIndicator#3395995L, previousOrderProposal#3395996L, clusterId#3395997L, sequenceId#3395998, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3396020 = 0_7_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3395999L], 30
(14) Filter
Arguments: (sequenceId#3395998 = 6)
(15) Project
Arguments: [orderProposalId#3395976L, orderProposalItemId#3395977, supplierGroup#3395978, supplier#3395979, plant#3395980, deliveryDateTime#3395981, subrange#3395982, supplyingPlant#3395983, productGroup#3395984, product#3395985, orderDateTime#3395986, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, mrpController#3395989, sourceOfSupplyUuid#3395990, purchasingOrg#3395991, purchasingGroup#3395992, isFallbackOrderOnly#3395993, orderProposalHorizonGroupingId#3395994L, splitIndicator#3395995L, previousOrderProposal#3395996L, clusterId#3395997L, sequenceId#3395998, worklistShardItemId#3395999L, orderProposalItemGroupId#3396000, ... 20 more fields]
(16) Project
Arguments: [shardId#3396022, worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, orderProposalHorizonGroupingId#3395994L, splitIndicator#3395995L, previousOrderProposal#3395996L, clusterId#3395997L, sequenceId#3395998, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, purchasingOrg#3395991, purchasingGroup#3395992, mrpController#3395989, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, ... 20 more fields]
(17) Project
Arguments: [shardId#3396022, worklistShardItemId#3395999L, orderProposalId#3395976L, orderProposalItemId#3395977, orderProposalItemGroupId#3396000, originalReplenishmentRunId#3396018L, orderProposalHorizonGroupingId#3395994L, splitIndicator#3395995L, previousOrderProposal#3395996L, clusterId#3395997L, cast(sequenceId#3395998 as bigint) AS sequenceId#3396023L, sourceOfSupplyUuid#3395990, supplierGroup#3395978, supplier#3395979, subrange#3395982, product#3395985, plant#3395980, purchasingOrg#3395991, purchasingGroup#3395992, mrpController#3395989, orderDateTime#3395986, deliveryDateTime#3395981, availabilityDateTime#3395987, nextAvailabilityDateTime#3395988, isFallbackOrderOnly#3395993, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3394574 = shardId#3395773) AND (worklistShardItemId#3395327L = worklistShardItemId#3395774L))
(20) Project
Arguments: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, orderProposalItemId#3395776, orderProposalItemGroupId#3395777, originalReplenishmentRunId#3395778L, orderProposalHorizonGroupingId#3395779L, splitIndicator#3395780L, previousOrderProposal#3395781L, clusterId#3395782L, sequenceId#3395783L, sourceOfSupplyUuid#3395784, supplierGroup#3395785, supplier#3395786, subrange#3395787, product#3395788, plant#3395789, purchasingOrg#3395790, purchasingGroup#3395791, mrpController#3395792, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, ... 22 more fields]
(21) Project
Arguments: [shardId#3394574, worklistShardItemId#3395327L, quantityAfterProdPlantOptimization#3395328, qty#3395329, orderProposalId#3395775L, originalReplenishmentRunId#3395778L, supplierGroup#3395785, supplier#3395786, supplyingPlant#3395816, productGroup#3395817, product#3395788, plant#3395789, subrange#3395787, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, nextAvailabilityDateTime#3395796, constraintValues#3395810, constraintOperators#3395808, constraintLabels#3395807, logisticUnits#3395812, orderQuantityBaseUom#3395798, orderQuantityBaseUomUuid#3395799, splitIndicator#3395780L, netPriceAmount#3395803, ... 14 more fields]
(22) Project
Arguments: [shardId#3394574, product#3395788, plant#3395789, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, qty#3395329, orderProposalId#3395775L]
(23) Project
Arguments: [shardId#3394574, product#3395788, plant#3395789, orderDateTime#3395793, deliveryDateTime#3395794, availabilityDateTime#3395795, qty#3395329 AS orderQuantityInBaseUnit#3397273, orderProposalId#3395775L]
(24) Filter
Arguments: (shardId#3394574 = 0_7_10000000532)