== 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@75d31dad, [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#632615, orderProposalId#632616L, items#632617, optimizationGroups#632618, isOptimal#632619, lastModified#632620, optimizationInsights#632621], false
(4) Filter
Arguments: shardId#632615 IN (0_1_10000002107)
(5) Filter
Arguments: shardId#632615 IN (0_1_10000002107)
(6) Project
Arguments: [shardId#632615, orderProposalId#632616L, items#632617, optimizationGroups#632618, isOptimal#632619, optimizationInsights#632621]
(7) Generate
Arguments: explode(items#632617), false, [item#633126]
(8) Project
Arguments: [shardId#632615, item#633126]
(9) Project
Arguments: [shardId#632615, item#633126.worklistShardItemId AS worklistShardItemId#633127L, item#633126.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#633128, item#633126.qty AS qty#633129]
(10) LocalRelation
Arguments: <empty>, [shardId#633283, worklistShardItemId#633284L, orderProposalId#633285L, orderProposalItemId#633286, orderProposalItemGroupId#633287, originalReplenishmentRunId#633288L, orderProposalHorizonGroupingId#633289L, splitIndicator#633290L, previousOrderProposal#633291L, clusterId#633292L, sequenceId#633293L, sourceOfSupplyUuid#633294, supplierGroup#633295, supplier#633296, subrange#633297, product#633298, plant#633299, purchasingOrg#633300, purchasingGroup#633301, mrpController#633302, orderDateTime#633303, deliveryDateTime#633304, availabilityDateTime#633305, nextAvailabilityDateTime#633306, isFallbackOrderOnly#633307, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#633328L, orderProposalItemId#633329, supplierGroup#633330, supplier#633331, plant#633332, deliveryDateTime#633333, subrange#633334, supplyingPlant#633335, productGroup#633336, product#633337, orderDateTime#633338, availabilityDateTime#633339, nextAvailabilityDateTime#633340, mrpController#633341, sourceOfSupplyUuid#633342, purchasingOrg#633343, purchasingGroup#633344, isFallbackOrderOnly#633345, orderProposalHorizonGroupingId#633346L, splitIndicator#633347L, previousOrderProposal#633348L, clusterId#633349L, sequenceId#633350, worklistShardItemId#633351L, orderProposalItemGroupId#633352, ... 20 more fields], false
(12) Filter
Arguments: (shardId#633372 = 0_1_10000002107)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#633351L], 20
(14) Filter
Arguments: (sequenceId#633350 = 3)
(15) Project
Arguments: [orderProposalId#633328L, orderProposalItemId#633329, supplierGroup#633330, supplier#633331, plant#633332, deliveryDateTime#633333, subrange#633334, supplyingPlant#633335, productGroup#633336, product#633337, orderDateTime#633338, availabilityDateTime#633339, nextAvailabilityDateTime#633340, mrpController#633341, sourceOfSupplyUuid#633342, purchasingOrg#633343, purchasingGroup#633344, isFallbackOrderOnly#633345, orderProposalHorizonGroupingId#633346L, splitIndicator#633347L, previousOrderProposal#633348L, clusterId#633349L, sequenceId#633350, worklistShardItemId#633351L, orderProposalItemGroupId#633352, ... 20 more fields]
(16) Project
Arguments: [shardId#633374, worklistShardItemId#633351L, orderProposalId#633328L, orderProposalItemId#633329, orderProposalItemGroupId#633352, originalReplenishmentRunId#633370L, orderProposalHorizonGroupingId#633346L, splitIndicator#633347L, previousOrderProposal#633348L, clusterId#633349L, sequenceId#633350, sourceOfSupplyUuid#633342, supplierGroup#633330, supplier#633331, subrange#633334, product#633337, plant#633332, purchasingOrg#633343, purchasingGroup#633344, mrpController#633341, orderDateTime#633338, deliveryDateTime#633333, availabilityDateTime#633339, nextAvailabilityDateTime#633340, isFallbackOrderOnly#633345, ... 20 more fields]
(17) Project
Arguments: [shardId#633374, worklistShardItemId#633351L, orderProposalId#633328L, orderProposalItemId#633329, orderProposalItemGroupId#633352, originalReplenishmentRunId#633370L, orderProposalHorizonGroupingId#633346L, splitIndicator#633347L, previousOrderProposal#633348L, clusterId#633349L, cast(sequenceId#633350 as bigint) AS sequenceId#633375L, sourceOfSupplyUuid#633342, supplierGroup#633330, supplier#633331, subrange#633334, product#633337, plant#633332, purchasingOrg#633343, purchasingGroup#633344, mrpController#633341, orderDateTime#633338, deliveryDateTime#633333, availabilityDateTime#633339, nextAvailabilityDateTime#633340, isFallbackOrderOnly#633345, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#632615 = shardId#633283) AND (worklistShardItemId#633127L = worklistShardItemId#633284L))
(20) Project
Arguments: [shardId#632615, worklistShardItemId#633127L, quantityAfterProdPlantOptimization#633128, qty#633129, orderProposalId#633285L, orderProposalItemId#633286, orderProposalItemGroupId#633287, originalReplenishmentRunId#633288L, orderProposalHorizonGroupingId#633289L, splitIndicator#633290L, previousOrderProposal#633291L, clusterId#633292L, sequenceId#633293L, sourceOfSupplyUuid#633294, supplierGroup#633295, supplier#633296, subrange#633297, product#633298, plant#633299, purchasingOrg#633300, purchasingGroup#633301, mrpController#633302, orderDateTime#633303, deliveryDateTime#633304, availabilityDateTime#633305, ... 22 more fields]
(21) Project
Arguments: [shardId#632615, worklistShardItemId#633127L, quantityAfterProdPlantOptimization#633128, qty#633129, orderProposalId#633285L, originalReplenishmentRunId#633288L, supplierGroup#633295, supplier#633296, supplyingPlant#633326, productGroup#633327, product#633298, plant#633299, subrange#633297, orderDateTime#633303, deliveryDateTime#633304, availabilityDateTime#633305, nextAvailabilityDateTime#633306, constraintValues#633320, constraintOperators#633318, constraintLabels#633317, logisticUnits#633322, orderQuantityBaseUom#633308, orderQuantityBaseUomUuid#633309, splitIndicator#633290L, netPriceAmount#633313, ... 14 more fields]
(22) Project
Arguments: [shardId#632615, product#633298, plant#633299, orderDateTime#633303, deliveryDateTime#633304, availabilityDateTime#633305, qty#633129, orderProposalId#633285L]
(23) Project
Arguments: [shardId#632615, product#633298, plant#633299, orderDateTime#633303, deliveryDateTime#633304, availabilityDateTime#633305, qty#633129 AS orderQuantityInBaseUnit#633580, orderProposalId#633285L]
(24) Filter
Arguments: (shardId#632615 = 0_1_10000002107)