== 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@23a4ee69, [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-2/shardId=0_5_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, lastModified#3395110, optimizationInsights#3395111], false
(4) Filter
Arguments: shardId#3395105 IN (0_5_10000000532)
(5) Filter
Arguments: shardId#3395105 IN (0_5_10000000532)
(6) Project
Arguments: [shardId#3395105, orderProposalId#3395106L, items#3395107, optimizationGroups#3395108, isOptimal#3395109, optimizationInsights#3395111]
(7) Generate
Arguments: explode(items#3395107), false, [item#3395819]
(8) Project
Arguments: [shardId#3395105, item#3395819]
(9) Project
Arguments: [shardId#3395105, item#3395819.worklistShardItemId AS worklistShardItemId#3395820L, item#3395819.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3395821, item#3395819.qty AS qty#3395822]
(10) LocalRelation
Arguments: <empty>, [shardId#3396168, worklistShardItemId#3396169L, orderProposalId#3396170L, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, originalReplenishmentRunId#3396173L, orderProposalHorizonGroupingId#3396174L, splitIndicator#3396175L, previousOrderProposal#3396176L, clusterId#3396177L, sequenceId#3396178L, sourceOfSupplyUuid#3396179, supplierGroup#3396180, supplier#3396181, subrange#3396182, product#3396183, plant#3396184, purchasingOrg#3396185, purchasingGroup#3396186, mrpController#3396187, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, isFallbackOrderOnly#3396192, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, mrpController#3396316, sourceOfSupplyUuid#3396317, purchasingOrg#3396318, purchasingGroup#3396319, isFallbackOrderOnly#3396320, orderProposalHorizonGroupingId#3396321L, splitIndicator#3396322L, previousOrderProposal#3396323L, clusterId#3396324L, sequenceId#3396325, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3396347 = 0_5_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3396326L], 30
(14) Filter
Arguments: (sequenceId#3396325 = 2)
(15) Project
Arguments: [orderProposalId#3396303L, orderProposalItemId#3396304, supplierGroup#3396305, supplier#3396306, plant#3396307, deliveryDateTime#3396308, subrange#3396309, supplyingPlant#3396310, productGroup#3396311, product#3396312, orderDateTime#3396313, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, mrpController#3396316, sourceOfSupplyUuid#3396317, purchasingOrg#3396318, purchasingGroup#3396319, isFallbackOrderOnly#3396320, orderProposalHorizonGroupingId#3396321L, splitIndicator#3396322L, previousOrderProposal#3396323L, clusterId#3396324L, sequenceId#3396325, worklistShardItemId#3396326L, orderProposalItemGroupId#3396327, ... 20 more fields]
(16) Project
Arguments: [shardId#3396349, worklistShardItemId#3396326L, orderProposalId#3396303L, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, originalReplenishmentRunId#3396345L, orderProposalHorizonGroupingId#3396321L, splitIndicator#3396322L, previousOrderProposal#3396323L, clusterId#3396324L, sequenceId#3396325, sourceOfSupplyUuid#3396317, supplierGroup#3396305, supplier#3396306, subrange#3396309, product#3396312, plant#3396307, purchasingOrg#3396318, purchasingGroup#3396319, mrpController#3396316, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, isFallbackOrderOnly#3396320, ... 20 more fields]
(17) Project
Arguments: [shardId#3396349, worklistShardItemId#3396326L, orderProposalId#3396303L, orderProposalItemId#3396304, orderProposalItemGroupId#3396327, originalReplenishmentRunId#3396345L, orderProposalHorizonGroupingId#3396321L, splitIndicator#3396322L, previousOrderProposal#3396323L, clusterId#3396324L, cast(sequenceId#3396325 as bigint) AS sequenceId#3396350L, sourceOfSupplyUuid#3396317, supplierGroup#3396305, supplier#3396306, subrange#3396309, product#3396312, plant#3396307, purchasingOrg#3396318, purchasingGroup#3396319, mrpController#3396316, orderDateTime#3396313, deliveryDateTime#3396308, availabilityDateTime#3396314, nextAvailabilityDateTime#3396315, isFallbackOrderOnly#3396320, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3395105 = shardId#3396168) AND (worklistShardItemId#3395820L = worklistShardItemId#3396169L))
(20) Project
Arguments: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396170L, orderProposalItemId#3396171, orderProposalItemGroupId#3396172, originalReplenishmentRunId#3396173L, orderProposalHorizonGroupingId#3396174L, splitIndicator#3396175L, previousOrderProposal#3396176L, clusterId#3396177L, sequenceId#3396178L, sourceOfSupplyUuid#3396179, supplierGroup#3396180, supplier#3396181, subrange#3396182, product#3396183, plant#3396184, purchasingOrg#3396185, purchasingGroup#3396186, mrpController#3396187, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, ... 22 more fields]
(21) Project
Arguments: [shardId#3395105, worklistShardItemId#3395820L, quantityAfterProdPlantOptimization#3395821, qty#3395822, orderProposalId#3396170L, originalReplenishmentRunId#3396173L, supplierGroup#3396180, supplier#3396181, supplyingPlant#3396211, productGroup#3396212, product#3396183, plant#3396184, subrange#3396182, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, nextAvailabilityDateTime#3396191, constraintValues#3396205, constraintOperators#3396203, constraintLabels#3396202, logisticUnits#3396207, orderQuantityBaseUom#3396193, orderQuantityBaseUomUuid#3396194, splitIndicator#3396175L, netPriceAmount#3396198, ... 14 more fields]
(22) Project
Arguments: [shardId#3395105, product#3396183, plant#3396184, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, qty#3395822, orderProposalId#3396170L]
(23) Project
Arguments: [shardId#3395105, product#3396183, plant#3396184, orderDateTime#3396188, deliveryDateTime#3396189, availabilityDateTime#3396190, qty#3395822 AS orderQuantityInBaseUnit#3397643, orderProposalId#3396170L]
(24) Filter
Arguments: (shardId#3395105 = 0_5_10000000532)