== 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@44667748, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002109/stream-10000002109-1/shardId=0_1_10000002109], Append
(3) LogicalRDD
Arguments: [shardId#870565, orderProposalId#870566L, items#870567, optimizationGroups#870568, isOptimal#870569, lastModified#870570, optimizationInsights#870571], false
(4) Filter
Arguments: shardId#870565 IN (0_1_10000002109)
(5) Filter
Arguments: shardId#870565 IN (0_1_10000002109)
(6) Project
Arguments: [shardId#870565, orderProposalId#870566L, items#870567, optimizationGroups#870568, isOptimal#870569, optimizationInsights#870571]
(7) Generate
Arguments: explode(items#870567), false, [item#871076]
(8) Project
Arguments: [shardId#870565, item#871076]
(9) Project
Arguments: [shardId#870565, item#871076.worklistShardItemId AS worklistShardItemId#871077L, item#871076.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#871078, item#871076.qty AS qty#871079]
(10) LocalRelation
Arguments: <empty>, [shardId#871233, worklistShardItemId#871234L, orderProposalId#871235L, orderProposalItemId#871236, orderProposalItemGroupId#871237, originalReplenishmentRunId#871238L, orderProposalHorizonGroupingId#871239L, splitIndicator#871240L, previousOrderProposal#871241L, clusterId#871242L, sequenceId#871243L, sourceOfSupplyUuid#871244, supplierGroup#871245, supplier#871246, subrange#871247, product#871248, plant#871249, purchasingOrg#871250, purchasingGroup#871251, mrpController#871252, orderDateTime#871253, deliveryDateTime#871254, availabilityDateTime#871255, nextAvailabilityDateTime#871256, isFallbackOrderOnly#871257, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#871278L, orderProposalItemId#871279, supplierGroup#871280, supplier#871281, plant#871282, deliveryDateTime#871283, subrange#871284, supplyingPlant#871285, productGroup#871286, product#871287, orderDateTime#871288, availabilityDateTime#871289, nextAvailabilityDateTime#871290, mrpController#871291, sourceOfSupplyUuid#871292, purchasingOrg#871293, purchasingGroup#871294, isFallbackOrderOnly#871295, orderProposalHorizonGroupingId#871296L, splitIndicator#871297L, previousOrderProposal#871298L, clusterId#871299L, sequenceId#871300, worklistShardItemId#871301L, orderProposalItemGroupId#871302, ... 20 more fields], false
(12) Filter
Arguments: (shardId#871322 = 0_1_10000002109)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#871301L], 20
(14) Filter
Arguments: (sequenceId#871300 = 1)
(15) Project
Arguments: [orderProposalId#871278L, orderProposalItemId#871279, supplierGroup#871280, supplier#871281, plant#871282, deliveryDateTime#871283, subrange#871284, supplyingPlant#871285, productGroup#871286, product#871287, orderDateTime#871288, availabilityDateTime#871289, nextAvailabilityDateTime#871290, mrpController#871291, sourceOfSupplyUuid#871292, purchasingOrg#871293, purchasingGroup#871294, isFallbackOrderOnly#871295, orderProposalHorizonGroupingId#871296L, splitIndicator#871297L, previousOrderProposal#871298L, clusterId#871299L, sequenceId#871300, worklistShardItemId#871301L, orderProposalItemGroupId#871302, ... 20 more fields]
(16) Project
Arguments: [shardId#871324, worklistShardItemId#871301L, orderProposalId#871278L, orderProposalItemId#871279, orderProposalItemGroupId#871302, originalReplenishmentRunId#871320L, orderProposalHorizonGroupingId#871296L, splitIndicator#871297L, previousOrderProposal#871298L, clusterId#871299L, sequenceId#871300, sourceOfSupplyUuid#871292, supplierGroup#871280, supplier#871281, subrange#871284, product#871287, plant#871282, purchasingOrg#871293, purchasingGroup#871294, mrpController#871291, orderDateTime#871288, deliveryDateTime#871283, availabilityDateTime#871289, nextAvailabilityDateTime#871290, isFallbackOrderOnly#871295, ... 20 more fields]
(17) Project
Arguments: [shardId#871324, worklistShardItemId#871301L, orderProposalId#871278L, orderProposalItemId#871279, orderProposalItemGroupId#871302, originalReplenishmentRunId#871320L, orderProposalHorizonGroupingId#871296L, splitIndicator#871297L, previousOrderProposal#871298L, clusterId#871299L, cast(sequenceId#871300 as bigint) AS sequenceId#871325L, sourceOfSupplyUuid#871292, supplierGroup#871280, supplier#871281, subrange#871284, product#871287, plant#871282, purchasingOrg#871293, purchasingGroup#871294, mrpController#871291, orderDateTime#871288, deliveryDateTime#871283, availabilityDateTime#871289, nextAvailabilityDateTime#871290, isFallbackOrderOnly#871295, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#870565 = shardId#871233) AND (worklistShardItemId#871077L = worklistShardItemId#871234L))
(20) Project
Arguments: [shardId#870565, worklistShardItemId#871077L, quantityAfterProdPlantOptimization#871078, qty#871079, orderProposalId#871235L, orderProposalItemId#871236, orderProposalItemGroupId#871237, originalReplenishmentRunId#871238L, orderProposalHorizonGroupingId#871239L, splitIndicator#871240L, previousOrderProposal#871241L, clusterId#871242L, sequenceId#871243L, sourceOfSupplyUuid#871244, supplierGroup#871245, supplier#871246, subrange#871247, product#871248, plant#871249, purchasingOrg#871250, purchasingGroup#871251, mrpController#871252, orderDateTime#871253, deliveryDateTime#871254, availabilityDateTime#871255, ... 22 more fields]
(21) Project
Arguments: [shardId#870565, worklistShardItemId#871077L, quantityAfterProdPlantOptimization#871078, qty#871079, orderProposalId#871235L, originalReplenishmentRunId#871238L, supplierGroup#871245, supplier#871246, supplyingPlant#871276, productGroup#871277, product#871248, plant#871249, subrange#871247, orderDateTime#871253, deliveryDateTime#871254, availabilityDateTime#871255, nextAvailabilityDateTime#871256, constraintValues#871270, constraintOperators#871268, constraintLabels#871267, logisticUnits#871272, orderQuantityBaseUom#871258, orderQuantityBaseUomUuid#871259, splitIndicator#871240L, netPriceAmount#871263, ... 14 more fields]
(22) Project
Arguments: [shardId#870565, product#871248, plant#871249, orderDateTime#871253, deliveryDateTime#871254, availabilityDateTime#871255, qty#871079, orderProposalId#871235L]
(23) Project
Arguments: [shardId#870565, product#871248, plant#871249, orderDateTime#871253, deliveryDateTime#871254, availabilityDateTime#871255, qty#871079 AS orderQuantityInBaseUnit#871530, orderProposalId#871235L]
(24) Filter
Arguments: (shardId#870565 = 0_1_10000002109)