== 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@aa449a4, [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-3/shardId=0_1_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3579691, orderProposalId#3579692L, items#3579693, optimizationGroups#3579694, isOptimal#3579695, lastModified#3579696, optimizationInsights#3579697], false
(4) Filter
Arguments: shardId#3579691 IN (0_1_10000000532)
(5) Filter
Arguments: shardId#3579691 IN (0_1_10000000532)
(6) Project
Arguments: [shardId#3579691, orderProposalId#3579692L, items#3579693, optimizationGroups#3579694, isOptimal#3579695, optimizationInsights#3579697]
(7) Generate
Arguments: explode(items#3579693), false, [item#3580960]
(8) Project
Arguments: [shardId#3579691, item#3580960]
(9) Project
Arguments: [shardId#3579691, item#3580960.worklistShardItemId AS worklistShardItemId#3580961L, item#3580960.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3580962, item#3580960.qty AS qty#3580963]
(10) LocalRelation
Arguments: <empty>, [shardId#3581275, worklistShardItemId#3581276L, orderProposalId#3581277L, orderProposalItemId#3581278, orderProposalItemGroupId#3581279, originalReplenishmentRunId#3581280L, orderProposalHorizonGroupingId#3581281L, splitIndicator#3581282L, previousOrderProposal#3581283L, clusterId#3581284L, sequenceId#3581285L, sourceOfSupplyUuid#3581286, supplierGroup#3581287, supplier#3581288, subrange#3581289, product#3581290, plant#3581291, purchasingOrg#3581292, purchasingGroup#3581293, mrpController#3581294, orderDateTime#3581295, deliveryDateTime#3581296, availabilityDateTime#3581297, nextAvailabilityDateTime#3581298, isFallbackOrderOnly#3581299, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3581365L, orderProposalItemId#3581366, supplierGroup#3581367, supplier#3581368, plant#3581369, deliveryDateTime#3581370, subrange#3581371, supplyingPlant#3581372, productGroup#3581373, product#3581374, orderDateTime#3581375, availabilityDateTime#3581376, nextAvailabilityDateTime#3581377, mrpController#3581378, sourceOfSupplyUuid#3581379, purchasingOrg#3581380, purchasingGroup#3581381, isFallbackOrderOnly#3581382, orderProposalHorizonGroupingId#3581383L, splitIndicator#3581384L, previousOrderProposal#3581385L, clusterId#3581386L, sequenceId#3581387, worklistShardItemId#3581388L, orderProposalItemGroupId#3581389, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3581409 = 0_1_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3581388L], 30
(14) Filter
Arguments: (sequenceId#3581387 = 7)
(15) Project
Arguments: [orderProposalId#3581365L, orderProposalItemId#3581366, supplierGroup#3581367, supplier#3581368, plant#3581369, deliveryDateTime#3581370, subrange#3581371, supplyingPlant#3581372, productGroup#3581373, product#3581374, orderDateTime#3581375, availabilityDateTime#3581376, nextAvailabilityDateTime#3581377, mrpController#3581378, sourceOfSupplyUuid#3581379, purchasingOrg#3581380, purchasingGroup#3581381, isFallbackOrderOnly#3581382, orderProposalHorizonGroupingId#3581383L, splitIndicator#3581384L, previousOrderProposal#3581385L, clusterId#3581386L, sequenceId#3581387, worklistShardItemId#3581388L, orderProposalItemGroupId#3581389, ... 20 more fields]
(16) Project
Arguments: [shardId#3581411, worklistShardItemId#3581388L, orderProposalId#3581365L, orderProposalItemId#3581366, orderProposalItemGroupId#3581389, originalReplenishmentRunId#3581407L, orderProposalHorizonGroupingId#3581383L, splitIndicator#3581384L, previousOrderProposal#3581385L, clusterId#3581386L, sequenceId#3581387, sourceOfSupplyUuid#3581379, supplierGroup#3581367, supplier#3581368, subrange#3581371, product#3581374, plant#3581369, purchasingOrg#3581380, purchasingGroup#3581381, mrpController#3581378, orderDateTime#3581375, deliveryDateTime#3581370, availabilityDateTime#3581376, nextAvailabilityDateTime#3581377, isFallbackOrderOnly#3581382, ... 20 more fields]
(17) Project
Arguments: [shardId#3581411, worklistShardItemId#3581388L, orderProposalId#3581365L, orderProposalItemId#3581366, orderProposalItemGroupId#3581389, originalReplenishmentRunId#3581407L, orderProposalHorizonGroupingId#3581383L, splitIndicator#3581384L, previousOrderProposal#3581385L, clusterId#3581386L, cast(sequenceId#3581387 as bigint) AS sequenceId#3581412L, sourceOfSupplyUuid#3581379, supplierGroup#3581367, supplier#3581368, subrange#3581371, product#3581374, plant#3581369, purchasingOrg#3581380, purchasingGroup#3581381, mrpController#3581378, orderDateTime#3581375, deliveryDateTime#3581370, availabilityDateTime#3581376, nextAvailabilityDateTime#3581377, isFallbackOrderOnly#3581382, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3579691 = shardId#3581275) AND (worklistShardItemId#3580961L = worklistShardItemId#3581276L))
(20) Project
Arguments: [shardId#3579691, worklistShardItemId#3580961L, quantityAfterProdPlantOptimization#3580962, qty#3580963, orderProposalId#3581277L, orderProposalItemId#3581278, orderProposalItemGroupId#3581279, originalReplenishmentRunId#3581280L, orderProposalHorizonGroupingId#3581281L, splitIndicator#3581282L, previousOrderProposal#3581283L, clusterId#3581284L, sequenceId#3581285L, sourceOfSupplyUuid#3581286, supplierGroup#3581287, supplier#3581288, subrange#3581289, product#3581290, plant#3581291, purchasingOrg#3581292, purchasingGroup#3581293, mrpController#3581294, orderDateTime#3581295, deliveryDateTime#3581296, availabilityDateTime#3581297, ... 22 more fields]
(21) Project
Arguments: [shardId#3579691, worklistShardItemId#3580961L, quantityAfterProdPlantOptimization#3580962, qty#3580963, orderProposalId#3581277L, originalReplenishmentRunId#3581280L, supplierGroup#3581287, supplier#3581288, supplyingPlant#3581318, productGroup#3581319, product#3581290, plant#3581291, subrange#3581289, orderDateTime#3581295, deliveryDateTime#3581296, availabilityDateTime#3581297, nextAvailabilityDateTime#3581298, constraintValues#3581312, constraintOperators#3581310, constraintLabels#3581309, logisticUnits#3581314, orderQuantityBaseUom#3581300, orderQuantityBaseUomUuid#3581301, splitIndicator#3581282L, netPriceAmount#3581305, ... 14 more fields]
(22) Project
Arguments: [shardId#3579691, product#3581290, plant#3581291, orderDateTime#3581295, deliveryDateTime#3581296, availabilityDateTime#3581297, qty#3580963, orderProposalId#3581277L]
(23) Project
Arguments: [shardId#3579691, product#3581290, plant#3581291, orderDateTime#3581295, deliveryDateTime#3581296, availabilityDateTime#3581297, qty#3580963 AS orderQuantityInBaseUnit#3586183, orderProposalId#3581277L]
(24) Filter
Arguments: (shardId#3579691 = 0_1_10000000532)