== 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@2f02d715, [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-1/shardId=0_7_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3579932, orderProposalId#3579933L, items#3579934, optimizationGroups#3579935, isOptimal#3579936, lastModified#3579937, optimizationInsights#3579938], false
(4) Filter
Arguments: shardId#3579932 IN (0_7_10000000532)
(5) Filter
Arguments: shardId#3579932 IN (0_7_10000000532)
(6) Project
Arguments: [shardId#3579932, orderProposalId#3579933L, items#3579934, optimizationGroups#3579935, isOptimal#3579936, optimizationInsights#3579938]
(7) Generate
Arguments: explode(items#3579934), false, [item#3581118]
(8) Project
Arguments: [shardId#3579932, item#3581118]
(9) Project
Arguments: [shardId#3579932, item#3581118.worklistShardItemId AS worklistShardItemId#3581119L, item#3581118.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3581120, item#3581118.qty AS qty#3581121]
(10) LocalRelation
Arguments: <empty>, [shardId#3581320, worklistShardItemId#3581321L, orderProposalId#3581322L, orderProposalItemId#3581323, orderProposalItemGroupId#3581324, originalReplenishmentRunId#3581325L, orderProposalHorizonGroupingId#3581326L, splitIndicator#3581327L, previousOrderProposal#3581328L, clusterId#3581329L, sequenceId#3581330L, sourceOfSupplyUuid#3581331, supplierGroup#3581332, supplier#3581333, subrange#3581334, product#3581335, plant#3581336, purchasingOrg#3581337, purchasingGroup#3581338, mrpController#3581339, orderDateTime#3581340, deliveryDateTime#3581341, availabilityDateTime#3581342, nextAvailabilityDateTime#3581343, isFallbackOrderOnly#3581344, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3581487L, orderProposalItemId#3581488, supplierGroup#3581489, supplier#3581490, plant#3581491, deliveryDateTime#3581492, subrange#3581493, supplyingPlant#3581494, productGroup#3581495, product#3581496, orderDateTime#3581497, availabilityDateTime#3581498, nextAvailabilityDateTime#3581499, mrpController#3581500, sourceOfSupplyUuid#3581501, purchasingOrg#3581502, purchasingGroup#3581503, isFallbackOrderOnly#3581504, orderProposalHorizonGroupingId#3581505L, splitIndicator#3581506L, previousOrderProposal#3581507L, clusterId#3581508L, sequenceId#3581509, worklistShardItemId#3581510L, orderProposalItemGroupId#3581511, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3581531 = 0_7_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3581510L], 30
(14) Filter
Arguments: (sequenceId#3581509 = 6)
(15) Project
Arguments: [orderProposalId#3581487L, orderProposalItemId#3581488, supplierGroup#3581489, supplier#3581490, plant#3581491, deliveryDateTime#3581492, subrange#3581493, supplyingPlant#3581494, productGroup#3581495, product#3581496, orderDateTime#3581497, availabilityDateTime#3581498, nextAvailabilityDateTime#3581499, mrpController#3581500, sourceOfSupplyUuid#3581501, purchasingOrg#3581502, purchasingGroup#3581503, isFallbackOrderOnly#3581504, orderProposalHorizonGroupingId#3581505L, splitIndicator#3581506L, previousOrderProposal#3581507L, clusterId#3581508L, sequenceId#3581509, worklistShardItemId#3581510L, orderProposalItemGroupId#3581511, ... 20 more fields]
(16) Project
Arguments: [shardId#3581533, worklistShardItemId#3581510L, orderProposalId#3581487L, orderProposalItemId#3581488, orderProposalItemGroupId#3581511, originalReplenishmentRunId#3581529L, orderProposalHorizonGroupingId#3581505L, splitIndicator#3581506L, previousOrderProposal#3581507L, clusterId#3581508L, sequenceId#3581509, sourceOfSupplyUuid#3581501, supplierGroup#3581489, supplier#3581490, subrange#3581493, product#3581496, plant#3581491, purchasingOrg#3581502, purchasingGroup#3581503, mrpController#3581500, orderDateTime#3581497, deliveryDateTime#3581492, availabilityDateTime#3581498, nextAvailabilityDateTime#3581499, isFallbackOrderOnly#3581504, ... 20 more fields]
(17) Project
Arguments: [shardId#3581533, worklistShardItemId#3581510L, orderProposalId#3581487L, orderProposalItemId#3581488, orderProposalItemGroupId#3581511, originalReplenishmentRunId#3581529L, orderProposalHorizonGroupingId#3581505L, splitIndicator#3581506L, previousOrderProposal#3581507L, clusterId#3581508L, cast(sequenceId#3581509 as bigint) AS sequenceId#3581534L, sourceOfSupplyUuid#3581501, supplierGroup#3581489, supplier#3581490, subrange#3581493, product#3581496, plant#3581491, purchasingOrg#3581502, purchasingGroup#3581503, mrpController#3581500, orderDateTime#3581497, deliveryDateTime#3581492, availabilityDateTime#3581498, nextAvailabilityDateTime#3581499, isFallbackOrderOnly#3581504, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3579932 = shardId#3581320) AND (worklistShardItemId#3581119L = worklistShardItemId#3581321L))
(20) Project
Arguments: [shardId#3579932, worklistShardItemId#3581119L, quantityAfterProdPlantOptimization#3581120, qty#3581121, orderProposalId#3581322L, orderProposalItemId#3581323, orderProposalItemGroupId#3581324, originalReplenishmentRunId#3581325L, orderProposalHorizonGroupingId#3581326L, splitIndicator#3581327L, previousOrderProposal#3581328L, clusterId#3581329L, sequenceId#3581330L, sourceOfSupplyUuid#3581331, supplierGroup#3581332, supplier#3581333, subrange#3581334, product#3581335, plant#3581336, purchasingOrg#3581337, purchasingGroup#3581338, mrpController#3581339, orderDateTime#3581340, deliveryDateTime#3581341, availabilityDateTime#3581342, ... 22 more fields]
(21) Project
Arguments: [shardId#3579932, worklistShardItemId#3581119L, quantityAfterProdPlantOptimization#3581120, qty#3581121, orderProposalId#3581322L, originalReplenishmentRunId#3581325L, supplierGroup#3581332, supplier#3581333, supplyingPlant#3581363, productGroup#3581364, product#3581335, plant#3581336, subrange#3581334, orderDateTime#3581340, deliveryDateTime#3581341, availabilityDateTime#3581342, nextAvailabilityDateTime#3581343, constraintValues#3581357, constraintOperators#3581355, constraintLabels#3581354, logisticUnits#3581359, orderQuantityBaseUom#3581345, orderQuantityBaseUomUuid#3581346, splitIndicator#3581327L, netPriceAmount#3581350, ... 14 more fields]
(22) Project
Arguments: [shardId#3579932, product#3581335, plant#3581336, orderDateTime#3581340, deliveryDateTime#3581341, availabilityDateTime#3581342, qty#3581121, orderProposalId#3581322L]
(23) Project
Arguments: [shardId#3579932, product#3581335, plant#3581336, orderDateTime#3581340, deliveryDateTime#3581341, availabilityDateTime#3581342, qty#3581121 AS orderQuantityInBaseUnit#3584729, orderProposalId#3581322L]
(24) Filter
Arguments: (shardId#3579932 = 0_7_10000000532)