== 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@69564181, [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-2/shardId=0_5_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3440291, orderProposalId#3440292L, items#3440293, optimizationGroups#3440294, isOptimal#3440295, lastModified#3440296, optimizationInsights#3440297], false
(4) Filter
Arguments: shardId#3440291 IN (0_5_10000000532)
(5) Filter
Arguments: shardId#3440291 IN (0_5_10000000532)
(6) Project
Arguments: [shardId#3440291, orderProposalId#3440292L, items#3440293, optimizationGroups#3440294, isOptimal#3440295, optimizationInsights#3440297]
(7) Generate
Arguments: explode(items#3440293), false, [item#3440802]
(8) Project
Arguments: [shardId#3440291, item#3440802]
(9) Project
Arguments: [shardId#3440291, item#3440802.worklistShardItemId AS worklistShardItemId#3440803L, item#3440802.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3440804, item#3440802.qty AS qty#3440805]
(10) LocalRelation
Arguments: <empty>, [shardId#3440959, worklistShardItemId#3440960L, orderProposalId#3440961L, orderProposalItemId#3440962, orderProposalItemGroupId#3440963, originalReplenishmentRunId#3440964L, orderProposalHorizonGroupingId#3440965L, splitIndicator#3440966L, previousOrderProposal#3440967L, clusterId#3440968L, sequenceId#3440969L, sourceOfSupplyUuid#3440970, supplierGroup#3440971, supplier#3440972, subrange#3440973, product#3440974, plant#3440975, purchasingOrg#3440976, purchasingGroup#3440977, mrpController#3440978, orderDateTime#3440979, deliveryDateTime#3440980, availabilityDateTime#3440981, nextAvailabilityDateTime#3440982, isFallbackOrderOnly#3440983, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3441004L, orderProposalItemId#3441005, supplierGroup#3441006, supplier#3441007, plant#3441008, deliveryDateTime#3441009, subrange#3441010, supplyingPlant#3441011, productGroup#3441012, product#3441013, orderDateTime#3441014, availabilityDateTime#3441015, nextAvailabilityDateTime#3441016, mrpController#3441017, sourceOfSupplyUuid#3441018, purchasingOrg#3441019, purchasingGroup#3441020, isFallbackOrderOnly#3441021, orderProposalHorizonGroupingId#3441022L, splitIndicator#3441023L, previousOrderProposal#3441024L, clusterId#3441025L, sequenceId#3441026, worklistShardItemId#3441027L, orderProposalItemGroupId#3441028, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3441048 = 0_5_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3441027L], 30
(14) Filter
Arguments: (sequenceId#3441026 = 3)
(15) Project
Arguments: [orderProposalId#3441004L, orderProposalItemId#3441005, supplierGroup#3441006, supplier#3441007, plant#3441008, deliveryDateTime#3441009, subrange#3441010, supplyingPlant#3441011, productGroup#3441012, product#3441013, orderDateTime#3441014, availabilityDateTime#3441015, nextAvailabilityDateTime#3441016, mrpController#3441017, sourceOfSupplyUuid#3441018, purchasingOrg#3441019, purchasingGroup#3441020, isFallbackOrderOnly#3441021, orderProposalHorizonGroupingId#3441022L, splitIndicator#3441023L, previousOrderProposal#3441024L, clusterId#3441025L, sequenceId#3441026, worklistShardItemId#3441027L, orderProposalItemGroupId#3441028, ... 20 more fields]
(16) Project
Arguments: [shardId#3441050, worklistShardItemId#3441027L, orderProposalId#3441004L, orderProposalItemId#3441005, orderProposalItemGroupId#3441028, originalReplenishmentRunId#3441046L, orderProposalHorizonGroupingId#3441022L, splitIndicator#3441023L, previousOrderProposal#3441024L, clusterId#3441025L, sequenceId#3441026, sourceOfSupplyUuid#3441018, supplierGroup#3441006, supplier#3441007, subrange#3441010, product#3441013, plant#3441008, purchasingOrg#3441019, purchasingGroup#3441020, mrpController#3441017, orderDateTime#3441014, deliveryDateTime#3441009, availabilityDateTime#3441015, nextAvailabilityDateTime#3441016, isFallbackOrderOnly#3441021, ... 20 more fields]
(17) Project
Arguments: [shardId#3441050, worklistShardItemId#3441027L, orderProposalId#3441004L, orderProposalItemId#3441005, orderProposalItemGroupId#3441028, originalReplenishmentRunId#3441046L, orderProposalHorizonGroupingId#3441022L, splitIndicator#3441023L, previousOrderProposal#3441024L, clusterId#3441025L, cast(sequenceId#3441026 as bigint) AS sequenceId#3441051L, sourceOfSupplyUuid#3441018, supplierGroup#3441006, supplier#3441007, subrange#3441010, product#3441013, plant#3441008, purchasingOrg#3441019, purchasingGroup#3441020, mrpController#3441017, orderDateTime#3441014, deliveryDateTime#3441009, availabilityDateTime#3441015, nextAvailabilityDateTime#3441016, isFallbackOrderOnly#3441021, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3440291 = shardId#3440959) AND (worklistShardItemId#3440803L = worklistShardItemId#3440960L))
(20) Project
Arguments: [shardId#3440291, worklistShardItemId#3440803L, quantityAfterProdPlantOptimization#3440804, qty#3440805, orderProposalId#3440961L, orderProposalItemId#3440962, orderProposalItemGroupId#3440963, originalReplenishmentRunId#3440964L, orderProposalHorizonGroupingId#3440965L, splitIndicator#3440966L, previousOrderProposal#3440967L, clusterId#3440968L, sequenceId#3440969L, sourceOfSupplyUuid#3440970, supplierGroup#3440971, supplier#3440972, subrange#3440973, product#3440974, plant#3440975, purchasingOrg#3440976, purchasingGroup#3440977, mrpController#3440978, orderDateTime#3440979, deliveryDateTime#3440980, availabilityDateTime#3440981, ... 22 more fields]
(21) Project
Arguments: [shardId#3440291, worklistShardItemId#3440803L, quantityAfterProdPlantOptimization#3440804, qty#3440805, orderProposalId#3440961L, originalReplenishmentRunId#3440964L, supplierGroup#3440971, supplier#3440972, supplyingPlant#3441002, productGroup#3441003, product#3440974, plant#3440975, subrange#3440973, orderDateTime#3440979, deliveryDateTime#3440980, availabilityDateTime#3440981, nextAvailabilityDateTime#3440982, constraintValues#3440996, constraintOperators#3440994, constraintLabels#3440993, logisticUnits#3440998, orderQuantityBaseUom#3440984, orderQuantityBaseUomUuid#3440985, splitIndicator#3440966L, netPriceAmount#3440989, ... 14 more fields]
(22) Project
Arguments: [shardId#3440291, product#3440974, plant#3440975, orderDateTime#3440979, deliveryDateTime#3440980, availabilityDateTime#3440981, qty#3440805, orderProposalId#3440961L]
(23) Project
Arguments: [shardId#3440291, product#3440974, plant#3440975, orderDateTime#3440979, deliveryDateTime#3440980, availabilityDateTime#3440981, qty#3440805 AS orderQuantityInBaseUnit#3441286, orderProposalId#3440961L]
(24) Filter
Arguments: (shardId#3440291 = 0_5_10000000532)