== 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@7d340b81, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002107/stream-10000002107-1/shardId=0_1_10000002107], Append
(3) LogicalRDD
Arguments: [shardId#712663, orderProposalId#712664L, items#712665, optimizationGroups#712666, isOptimal#712667, lastModified#712668, optimizationInsights#712669], false
(4) Filter
Arguments: shardId#712663 IN (0_1_10000002107)
(5) Filter
Arguments: shardId#712663 IN (0_1_10000002107)
(6) Project
Arguments: [shardId#712663, orderProposalId#712664L, items#712665, optimizationGroups#712666, isOptimal#712667, optimizationInsights#712669]
(7) Generate
Arguments: explode(items#712665), false, [item#713174]
(8) Project
Arguments: [shardId#712663, item#713174]
(9) Project
Arguments: [shardId#712663, item#713174.worklistShardItemId AS worklistShardItemId#713175L, item#713174.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#713176, item#713174.qty AS qty#713177]
(10) LocalRelation
Arguments: <empty>, [shardId#713331, worklistShardItemId#713332L, orderProposalId#713333L, orderProposalItemId#713334, orderProposalItemGroupId#713335, originalReplenishmentRunId#713336L, orderProposalHorizonGroupingId#713337L, splitIndicator#713338L, previousOrderProposal#713339L, clusterId#713340L, sequenceId#713341L, sourceOfSupplyUuid#713342, supplierGroup#713343, supplier#713344, subrange#713345, product#713346, plant#713347, purchasingOrg#713348, purchasingGroup#713349, mrpController#713350, orderDateTime#713351, deliveryDateTime#713352, availabilityDateTime#713353, nextAvailabilityDateTime#713354, isFallbackOrderOnly#713355, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#713376L, orderProposalItemId#713377, supplierGroup#713378, supplier#713379, plant#713380, deliveryDateTime#713381, subrange#713382, supplyingPlant#713383, productGroup#713384, product#713385, orderDateTime#713386, availabilityDateTime#713387, nextAvailabilityDateTime#713388, mrpController#713389, sourceOfSupplyUuid#713390, purchasingOrg#713391, purchasingGroup#713392, isFallbackOrderOnly#713393, orderProposalHorizonGroupingId#713394L, splitIndicator#713395L, previousOrderProposal#713396L, clusterId#713397L, sequenceId#713398, worklistShardItemId#713399L, orderProposalItemGroupId#713400, ... 20 more fields], false
(12) Filter
Arguments: (shardId#713420 = 0_1_10000002107)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#713399L], 20
(14) Filter
Arguments: (sequenceId#713398 = 6)
(15) Project
Arguments: [orderProposalId#713376L, orderProposalItemId#713377, supplierGroup#713378, supplier#713379, plant#713380, deliveryDateTime#713381, subrange#713382, supplyingPlant#713383, productGroup#713384, product#713385, orderDateTime#713386, availabilityDateTime#713387, nextAvailabilityDateTime#713388, mrpController#713389, sourceOfSupplyUuid#713390, purchasingOrg#713391, purchasingGroup#713392, isFallbackOrderOnly#713393, orderProposalHorizonGroupingId#713394L, splitIndicator#713395L, previousOrderProposal#713396L, clusterId#713397L, sequenceId#713398, worklistShardItemId#713399L, orderProposalItemGroupId#713400, ... 20 more fields]
(16) Project
Arguments: [shardId#713422, worklistShardItemId#713399L, orderProposalId#713376L, orderProposalItemId#713377, orderProposalItemGroupId#713400, originalReplenishmentRunId#713418L, orderProposalHorizonGroupingId#713394L, splitIndicator#713395L, previousOrderProposal#713396L, clusterId#713397L, sequenceId#713398, sourceOfSupplyUuid#713390, supplierGroup#713378, supplier#713379, subrange#713382, product#713385, plant#713380, purchasingOrg#713391, purchasingGroup#713392, mrpController#713389, orderDateTime#713386, deliveryDateTime#713381, availabilityDateTime#713387, nextAvailabilityDateTime#713388, isFallbackOrderOnly#713393, ... 20 more fields]
(17) Project
Arguments: [shardId#713422, worklistShardItemId#713399L, orderProposalId#713376L, orderProposalItemId#713377, orderProposalItemGroupId#713400, originalReplenishmentRunId#713418L, orderProposalHorizonGroupingId#713394L, splitIndicator#713395L, previousOrderProposal#713396L, clusterId#713397L, cast(sequenceId#713398 as bigint) AS sequenceId#713423L, sourceOfSupplyUuid#713390, supplierGroup#713378, supplier#713379, subrange#713382, product#713385, plant#713380, purchasingOrg#713391, purchasingGroup#713392, mrpController#713389, orderDateTime#713386, deliveryDateTime#713381, availabilityDateTime#713387, nextAvailabilityDateTime#713388, isFallbackOrderOnly#713393, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#712663 = shardId#713331) AND (worklistShardItemId#713175L = worklistShardItemId#713332L))
(20) Project
Arguments: [shardId#712663, worklistShardItemId#713175L, quantityAfterProdPlantOptimization#713176, qty#713177, orderProposalId#713333L, orderProposalItemId#713334, orderProposalItemGroupId#713335, originalReplenishmentRunId#713336L, orderProposalHorizonGroupingId#713337L, splitIndicator#713338L, previousOrderProposal#713339L, clusterId#713340L, sequenceId#713341L, sourceOfSupplyUuid#713342, supplierGroup#713343, supplier#713344, subrange#713345, product#713346, plant#713347, purchasingOrg#713348, purchasingGroup#713349, mrpController#713350, orderDateTime#713351, deliveryDateTime#713352, availabilityDateTime#713353, ... 22 more fields]
(21) Project
Arguments: [shardId#712663, worklistShardItemId#713175L, quantityAfterProdPlantOptimization#713176, qty#713177, orderProposalId#713333L, originalReplenishmentRunId#713336L, supplierGroup#713343, supplier#713344, supplyingPlant#713374, productGroup#713375, product#713346, plant#713347, subrange#713345, orderDateTime#713351, deliveryDateTime#713352, availabilityDateTime#713353, nextAvailabilityDateTime#713354, constraintValues#713368, constraintOperators#713366, constraintLabels#713365, logisticUnits#713370, orderQuantityBaseUom#713356, orderQuantityBaseUomUuid#713357, splitIndicator#713338L, netPriceAmount#713361, ... 14 more fields]
(22) Project
Arguments: [shardId#712663, product#713346, plant#713347, orderDateTime#713351, deliveryDateTime#713352, availabilityDateTime#713353, qty#713177, orderProposalId#713333L]
(23) Project
Arguments: [shardId#712663, product#713346, plant#713347, orderDateTime#713351, deliveryDateTime#713352, availabilityDateTime#713353, qty#713177 AS orderQuantityInBaseUnit#713451, orderProposalId#713333L]
(24) Filter
Arguments: (shardId#712663 = 0_1_10000002107)