== 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@7d42e741, [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#893734, orderProposalId#893735L, items#893736, optimizationGroups#893737, isOptimal#893738, lastModified#893739, optimizationInsights#893740], false
(4) Filter
Arguments: shardId#893734 IN (0_1_10000002109)
(5) Filter
Arguments: shardId#893734 IN (0_1_10000002109)
(6) Project
Arguments: [shardId#893734, orderProposalId#893735L, items#893736, optimizationGroups#893737, isOptimal#893738, optimizationInsights#893740]
(7) Generate
Arguments: explode(items#893736), false, [item#894245]
(8) Project
Arguments: [shardId#893734, item#894245]
(9) Project
Arguments: [shardId#893734, item#894245.worklistShardItemId AS worklistShardItemId#894246L, item#894245.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#894247, item#894245.qty AS qty#894248]
(10) LocalRelation
Arguments: <empty>, [shardId#894402, worklistShardItemId#894403L, orderProposalId#894404L, orderProposalItemId#894405, orderProposalItemGroupId#894406, originalReplenishmentRunId#894407L, orderProposalHorizonGroupingId#894408L, splitIndicator#894409L, previousOrderProposal#894410L, clusterId#894411L, sequenceId#894412L, sourceOfSupplyUuid#894413, supplierGroup#894414, supplier#894415, subrange#894416, product#894417, plant#894418, purchasingOrg#894419, purchasingGroup#894420, mrpController#894421, orderDateTime#894422, deliveryDateTime#894423, availabilityDateTime#894424, nextAvailabilityDateTime#894425, isFallbackOrderOnly#894426, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#894447L, orderProposalItemId#894448, supplierGroup#894449, supplier#894450, plant#894451, deliveryDateTime#894452, subrange#894453, supplyingPlant#894454, productGroup#894455, product#894456, orderDateTime#894457, availabilityDateTime#894458, nextAvailabilityDateTime#894459, mrpController#894460, sourceOfSupplyUuid#894461, purchasingOrg#894462, purchasingGroup#894463, isFallbackOrderOnly#894464, orderProposalHorizonGroupingId#894465L, splitIndicator#894466L, previousOrderProposal#894467L, clusterId#894468L, sequenceId#894469, worklistShardItemId#894470L, orderProposalItemGroupId#894471, ... 20 more fields], false
(12) Filter
Arguments: (shardId#894491 = 0_1_10000002109)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#894470L], 20
(14) Filter
Arguments: (sequenceId#894469 = 2)
(15) Project
Arguments: [orderProposalId#894447L, orderProposalItemId#894448, supplierGroup#894449, supplier#894450, plant#894451, deliveryDateTime#894452, subrange#894453, supplyingPlant#894454, productGroup#894455, product#894456, orderDateTime#894457, availabilityDateTime#894458, nextAvailabilityDateTime#894459, mrpController#894460, sourceOfSupplyUuid#894461, purchasingOrg#894462, purchasingGroup#894463, isFallbackOrderOnly#894464, orderProposalHorizonGroupingId#894465L, splitIndicator#894466L, previousOrderProposal#894467L, clusterId#894468L, sequenceId#894469, worklistShardItemId#894470L, orderProposalItemGroupId#894471, ... 20 more fields]
(16) Project
Arguments: [shardId#894493, worklistShardItemId#894470L, orderProposalId#894447L, orderProposalItemId#894448, orderProposalItemGroupId#894471, originalReplenishmentRunId#894489L, orderProposalHorizonGroupingId#894465L, splitIndicator#894466L, previousOrderProposal#894467L, clusterId#894468L, sequenceId#894469, sourceOfSupplyUuid#894461, supplierGroup#894449, supplier#894450, subrange#894453, product#894456, plant#894451, purchasingOrg#894462, purchasingGroup#894463, mrpController#894460, orderDateTime#894457, deliveryDateTime#894452, availabilityDateTime#894458, nextAvailabilityDateTime#894459, isFallbackOrderOnly#894464, ... 20 more fields]
(17) Project
Arguments: [shardId#894493, worklistShardItemId#894470L, orderProposalId#894447L, orderProposalItemId#894448, orderProposalItemGroupId#894471, originalReplenishmentRunId#894489L, orderProposalHorizonGroupingId#894465L, splitIndicator#894466L, previousOrderProposal#894467L, clusterId#894468L, cast(sequenceId#894469 as bigint) AS sequenceId#894494L, sourceOfSupplyUuid#894461, supplierGroup#894449, supplier#894450, subrange#894453, product#894456, plant#894451, purchasingOrg#894462, purchasingGroup#894463, mrpController#894460, orderDateTime#894457, deliveryDateTime#894452, availabilityDateTime#894458, nextAvailabilityDateTime#894459, isFallbackOrderOnly#894464, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#893734 = shardId#894402) AND (worklistShardItemId#894246L = worklistShardItemId#894403L))
(20) Project
Arguments: [shardId#893734, worklistShardItemId#894246L, quantityAfterProdPlantOptimization#894247, qty#894248, orderProposalId#894404L, orderProposalItemId#894405, orderProposalItemGroupId#894406, originalReplenishmentRunId#894407L, orderProposalHorizonGroupingId#894408L, splitIndicator#894409L, previousOrderProposal#894410L, clusterId#894411L, sequenceId#894412L, sourceOfSupplyUuid#894413, supplierGroup#894414, supplier#894415, subrange#894416, product#894417, plant#894418, purchasingOrg#894419, purchasingGroup#894420, mrpController#894421, orderDateTime#894422, deliveryDateTime#894423, availabilityDateTime#894424, ... 22 more fields]
(21) Project
Arguments: [shardId#893734, worklistShardItemId#894246L, quantityAfterProdPlantOptimization#894247, qty#894248, orderProposalId#894404L, originalReplenishmentRunId#894407L, supplierGroup#894414, supplier#894415, supplyingPlant#894445, productGroup#894446, product#894417, plant#894418, subrange#894416, orderDateTime#894422, deliveryDateTime#894423, availabilityDateTime#894424, nextAvailabilityDateTime#894425, constraintValues#894439, constraintOperators#894437, constraintLabels#894436, logisticUnits#894441, orderQuantityBaseUom#894427, orderQuantityBaseUomUuid#894428, splitIndicator#894409L, netPriceAmount#894432, ... 14 more fields]
(22) Project
Arguments: [shardId#893734, product#894417, plant#894418, orderDateTime#894422, deliveryDateTime#894423, availabilityDateTime#894424, qty#894248, orderProposalId#894404L]
(23) Project
Arguments: [shardId#893734, product#894417, plant#894418, orderDateTime#894422, deliveryDateTime#894423, availabilityDateTime#894424, qty#894248 AS orderQuantityInBaseUnit#894522, orderProposalId#894404L]
(24) Filter
Arguments: (shardId#893734 = 0_1_10000002109)