== 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@746c8bda, [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#3461394, orderProposalId#3461395L, items#3461396, optimizationGroups#3461397, isOptimal#3461398, lastModified#3461399, optimizationInsights#3461400], false
(4) Filter
Arguments: shardId#3461394 IN (0_5_10000000532)
(5) Filter
Arguments: shardId#3461394 IN (0_5_10000000532)
(6) Project
Arguments: [shardId#3461394, orderProposalId#3461395L, items#3461396, optimizationGroups#3461397, isOptimal#3461398, optimizationInsights#3461400]
(7) Generate
Arguments: explode(items#3461396), false, [item#3461905]
(8) Project
Arguments: [shardId#3461394, item#3461905]
(9) Project
Arguments: [shardId#3461394, item#3461905.worklistShardItemId AS worklistShardItemId#3461906L, item#3461905.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3461907, item#3461905.qty AS qty#3461908]
(10) LocalRelation
Arguments: <empty>, [shardId#3462062, worklistShardItemId#3462063L, orderProposalId#3462064L, orderProposalItemId#3462065, orderProposalItemGroupId#3462066, originalReplenishmentRunId#3462067L, orderProposalHorizonGroupingId#3462068L, splitIndicator#3462069L, previousOrderProposal#3462070L, clusterId#3462071L, sequenceId#3462072L, sourceOfSupplyUuid#3462073, supplierGroup#3462074, supplier#3462075, subrange#3462076, product#3462077, plant#3462078, purchasingOrg#3462079, purchasingGroup#3462080, mrpController#3462081, orderDateTime#3462082, deliveryDateTime#3462083, availabilityDateTime#3462084, nextAvailabilityDateTime#3462085, isFallbackOrderOnly#3462086, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3462107L, orderProposalItemId#3462108, supplierGroup#3462109, supplier#3462110, plant#3462111, deliveryDateTime#3462112, subrange#3462113, supplyingPlant#3462114, productGroup#3462115, product#3462116, orderDateTime#3462117, availabilityDateTime#3462118, nextAvailabilityDateTime#3462119, mrpController#3462120, sourceOfSupplyUuid#3462121, purchasingOrg#3462122, purchasingGroup#3462123, isFallbackOrderOnly#3462124, orderProposalHorizonGroupingId#3462125L, splitIndicator#3462126L, previousOrderProposal#3462127L, clusterId#3462128L, sequenceId#3462129, worklistShardItemId#3462130L, orderProposalItemGroupId#3462131, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3462151 = 0_5_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3462130L], 30
(14) Filter
Arguments: (sequenceId#3462129 = 4)
(15) Project
Arguments: [orderProposalId#3462107L, orderProposalItemId#3462108, supplierGroup#3462109, supplier#3462110, plant#3462111, deliveryDateTime#3462112, subrange#3462113, supplyingPlant#3462114, productGroup#3462115, product#3462116, orderDateTime#3462117, availabilityDateTime#3462118, nextAvailabilityDateTime#3462119, mrpController#3462120, sourceOfSupplyUuid#3462121, purchasingOrg#3462122, purchasingGroup#3462123, isFallbackOrderOnly#3462124, orderProposalHorizonGroupingId#3462125L, splitIndicator#3462126L, previousOrderProposal#3462127L, clusterId#3462128L, sequenceId#3462129, worklistShardItemId#3462130L, orderProposalItemGroupId#3462131, ... 20 more fields]
(16) Project
Arguments: [shardId#3462153, worklistShardItemId#3462130L, orderProposalId#3462107L, orderProposalItemId#3462108, orderProposalItemGroupId#3462131, originalReplenishmentRunId#3462149L, orderProposalHorizonGroupingId#3462125L, splitIndicator#3462126L, previousOrderProposal#3462127L, clusterId#3462128L, sequenceId#3462129, sourceOfSupplyUuid#3462121, supplierGroup#3462109, supplier#3462110, subrange#3462113, product#3462116, plant#3462111, purchasingOrg#3462122, purchasingGroup#3462123, mrpController#3462120, orderDateTime#3462117, deliveryDateTime#3462112, availabilityDateTime#3462118, nextAvailabilityDateTime#3462119, isFallbackOrderOnly#3462124, ... 20 more fields]
(17) Project
Arguments: [shardId#3462153, worklistShardItemId#3462130L, orderProposalId#3462107L, orderProposalItemId#3462108, orderProposalItemGroupId#3462131, originalReplenishmentRunId#3462149L, orderProposalHorizonGroupingId#3462125L, splitIndicator#3462126L, previousOrderProposal#3462127L, clusterId#3462128L, cast(sequenceId#3462129 as bigint) AS sequenceId#3462154L, sourceOfSupplyUuid#3462121, supplierGroup#3462109, supplier#3462110, subrange#3462113, product#3462116, plant#3462111, purchasingOrg#3462122, purchasingGroup#3462123, mrpController#3462120, orderDateTime#3462117, deliveryDateTime#3462112, availabilityDateTime#3462118, nextAvailabilityDateTime#3462119, isFallbackOrderOnly#3462124, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3461394 = shardId#3462062) AND (worklistShardItemId#3461906L = worklistShardItemId#3462063L))
(20) Project
Arguments: [shardId#3461394, worklistShardItemId#3461906L, quantityAfterProdPlantOptimization#3461907, qty#3461908, orderProposalId#3462064L, orderProposalItemId#3462065, orderProposalItemGroupId#3462066, originalReplenishmentRunId#3462067L, orderProposalHorizonGroupingId#3462068L, splitIndicator#3462069L, previousOrderProposal#3462070L, clusterId#3462071L, sequenceId#3462072L, sourceOfSupplyUuid#3462073, supplierGroup#3462074, supplier#3462075, subrange#3462076, product#3462077, plant#3462078, purchasingOrg#3462079, purchasingGroup#3462080, mrpController#3462081, orderDateTime#3462082, deliveryDateTime#3462083, availabilityDateTime#3462084, ... 22 more fields]
(21) Project
Arguments: [shardId#3461394, worklistShardItemId#3461906L, quantityAfterProdPlantOptimization#3461907, qty#3461908, orderProposalId#3462064L, originalReplenishmentRunId#3462067L, supplierGroup#3462074, supplier#3462075, supplyingPlant#3462105, productGroup#3462106, product#3462077, plant#3462078, subrange#3462076, orderDateTime#3462082, deliveryDateTime#3462083, availabilityDateTime#3462084, nextAvailabilityDateTime#3462085, constraintValues#3462099, constraintOperators#3462097, constraintLabels#3462096, logisticUnits#3462101, orderQuantityBaseUom#3462087, orderQuantityBaseUomUuid#3462088, splitIndicator#3462069L, netPriceAmount#3462092, ... 14 more fields]
(22) Project
Arguments: [shardId#3461394, product#3462077, plant#3462078, orderDateTime#3462082, deliveryDateTime#3462083, availabilityDateTime#3462084, qty#3461908, orderProposalId#3462064L]
(23) Project
Arguments: [shardId#3461394, product#3462077, plant#3462078, orderDateTime#3462082, deliveryDateTime#3462083, availabilityDateTime#3462084, qty#3461908 AS orderQuantityInBaseUnit#3462389, orderProposalId#3462064L]
(24) Filter
Arguments: (shardId#3461394 = 0_5_10000000532)