== 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@29c95ee1, [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-3/shardId=0_1_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3392655, orderProposalId#3392656L, items#3392657, optimizationGroups#3392658, isOptimal#3392659, lastModified#3392660, optimizationInsights#3392661], false
(4) Filter
Arguments: shardId#3392655 IN (0_1_10000000532)
(5) Filter
Arguments: shardId#3392655 IN (0_1_10000000532)
(6) Project
Arguments: [shardId#3392655, orderProposalId#3392656L, items#3392657, optimizationGroups#3392658, isOptimal#3392659, optimizationInsights#3392661]
(7) Generate
Arguments: explode(items#3392657), false, [item#3393236]
(8) Project
Arguments: [shardId#3392655, item#3393236]
(9) Project
Arguments: [shardId#3392655, item#3393236.worklistShardItemId AS worklistShardItemId#3393237L, item#3393236.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3393238, item#3393236.qty AS qty#3393239]
(10) LocalRelation
Arguments: <empty>, [shardId#3393463, worklistShardItemId#3393464L, orderProposalId#3393465L, orderProposalItemId#3393466, orderProposalItemGroupId#3393467, originalReplenishmentRunId#3393468L, orderProposalHorizonGroupingId#3393469L, splitIndicator#3393470L, previousOrderProposal#3393471L, clusterId#3393472L, sequenceId#3393473L, sourceOfSupplyUuid#3393474, supplierGroup#3393475, supplier#3393476, subrange#3393477, product#3393478, plant#3393479, purchasingOrg#3393480, purchasingGroup#3393481, mrpController#3393482, orderDateTime#3393483, deliveryDateTime#3393484, availabilityDateTime#3393485, nextAvailabilityDateTime#3393486, isFallbackOrderOnly#3393487, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3393616L, orderProposalItemId#3393617, supplierGroup#3393618, supplier#3393619, plant#3393620, deliveryDateTime#3393621, subrange#3393622, supplyingPlant#3393623, productGroup#3393624, product#3393625, orderDateTime#3393626, availabilityDateTime#3393627, nextAvailabilityDateTime#3393628, mrpController#3393629, sourceOfSupplyUuid#3393630, purchasingOrg#3393631, purchasingGroup#3393632, isFallbackOrderOnly#3393633, orderProposalHorizonGroupingId#3393634L, splitIndicator#3393635L, previousOrderProposal#3393636L, clusterId#3393637L, sequenceId#3393638, worklistShardItemId#3393639L, orderProposalItemGroupId#3393640, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3393660 = 0_1_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3393639L], 30
(14) Filter
Arguments: (sequenceId#3393638 = 7)
(15) Project
Arguments: [orderProposalId#3393616L, orderProposalItemId#3393617, supplierGroup#3393618, supplier#3393619, plant#3393620, deliveryDateTime#3393621, subrange#3393622, supplyingPlant#3393623, productGroup#3393624, product#3393625, orderDateTime#3393626, availabilityDateTime#3393627, nextAvailabilityDateTime#3393628, mrpController#3393629, sourceOfSupplyUuid#3393630, purchasingOrg#3393631, purchasingGroup#3393632, isFallbackOrderOnly#3393633, orderProposalHorizonGroupingId#3393634L, splitIndicator#3393635L, previousOrderProposal#3393636L, clusterId#3393637L, sequenceId#3393638, worklistShardItemId#3393639L, orderProposalItemGroupId#3393640, ... 20 more fields]
(16) Project
Arguments: [shardId#3393662, worklistShardItemId#3393639L, orderProposalId#3393616L, orderProposalItemId#3393617, orderProposalItemGroupId#3393640, originalReplenishmentRunId#3393658L, orderProposalHorizonGroupingId#3393634L, splitIndicator#3393635L, previousOrderProposal#3393636L, clusterId#3393637L, sequenceId#3393638, sourceOfSupplyUuid#3393630, supplierGroup#3393618, supplier#3393619, subrange#3393622, product#3393625, plant#3393620, purchasingOrg#3393631, purchasingGroup#3393632, mrpController#3393629, orderDateTime#3393626, deliveryDateTime#3393621, availabilityDateTime#3393627, nextAvailabilityDateTime#3393628, isFallbackOrderOnly#3393633, ... 20 more fields]
(17) Project
Arguments: [shardId#3393662, worklistShardItemId#3393639L, orderProposalId#3393616L, orderProposalItemId#3393617, orderProposalItemGroupId#3393640, originalReplenishmentRunId#3393658L, orderProposalHorizonGroupingId#3393634L, splitIndicator#3393635L, previousOrderProposal#3393636L, clusterId#3393637L, cast(sequenceId#3393638 as bigint) AS sequenceId#3393663L, sourceOfSupplyUuid#3393630, supplierGroup#3393618, supplier#3393619, subrange#3393622, product#3393625, plant#3393620, purchasingOrg#3393631, purchasingGroup#3393632, mrpController#3393629, orderDateTime#3393626, deliveryDateTime#3393621, availabilityDateTime#3393627, nextAvailabilityDateTime#3393628, isFallbackOrderOnly#3393633, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3392655 = shardId#3393463) AND (worklistShardItemId#3393237L = worklistShardItemId#3393464L))
(20) Project
Arguments: [shardId#3392655, worklistShardItemId#3393237L, quantityAfterProdPlantOptimization#3393238, qty#3393239, orderProposalId#3393465L, orderProposalItemId#3393466, orderProposalItemGroupId#3393467, originalReplenishmentRunId#3393468L, orderProposalHorizonGroupingId#3393469L, splitIndicator#3393470L, previousOrderProposal#3393471L, clusterId#3393472L, sequenceId#3393473L, sourceOfSupplyUuid#3393474, supplierGroup#3393475, supplier#3393476, subrange#3393477, product#3393478, plant#3393479, purchasingOrg#3393480, purchasingGroup#3393481, mrpController#3393482, orderDateTime#3393483, deliveryDateTime#3393484, availabilityDateTime#3393485, ... 22 more fields]
(21) Project
Arguments: [shardId#3392655, worklistShardItemId#3393237L, quantityAfterProdPlantOptimization#3393238, qty#3393239, orderProposalId#3393465L, originalReplenishmentRunId#3393468L, supplierGroup#3393475, supplier#3393476, supplyingPlant#3393506, productGroup#3393507, product#3393478, plant#3393479, subrange#3393477, orderDateTime#3393483, deliveryDateTime#3393484, availabilityDateTime#3393485, nextAvailabilityDateTime#3393486, constraintValues#3393500, constraintOperators#3393498, constraintLabels#3393497, logisticUnits#3393502, orderQuantityBaseUom#3393488, orderQuantityBaseUomUuid#3393489, splitIndicator#3393470L, netPriceAmount#3393493, ... 14 more fields]
(22) Project
Arguments: [shardId#3392655, product#3393478, plant#3393479, orderDateTime#3393483, deliveryDateTime#3393484, availabilityDateTime#3393485, qty#3393239, orderProposalId#3393465L]
(23) Project
Arguments: [shardId#3392655, product#3393478, plant#3393479, orderDateTime#3393483, deliveryDateTime#3393484, availabilityDateTime#3393485, qty#3393239 AS orderQuantityInBaseUnit#3396585, orderProposalId#3393465L]
(24) Filter
Arguments: (shardId#3392655 = 0_1_10000000532)