== 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@29ac301c, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002106/stream-10000002106-1/shardId=0_1_10000002106], Append
(3) LogicalRDD
Arguments: [shardId#584004, orderProposalId#584005L, items#584006, optimizationGroups#584007, isOptimal#584008, lastModified#584009, optimizationInsights#584010], false
(4) Filter
Arguments: shardId#584004 IN (0_1_10000002106)
(5) Filter
Arguments: shardId#584004 IN (0_1_10000002106)
(6) Project
Arguments: [shardId#584004, orderProposalId#584005L, items#584006, optimizationGroups#584007, isOptimal#584008, optimizationInsights#584010]
(7) Generate
Arguments: explode(items#584006), false, [item#584515]
(8) Project
Arguments: [shardId#584004, item#584515]
(9) Project
Arguments: [shardId#584004, item#584515.worklistShardItemId AS worklistShardItemId#584516L, item#584515.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#584517, item#584515.qty AS qty#584518]
(10) LocalRelation
Arguments: <empty>, [shardId#584672, worklistShardItemId#584673L, orderProposalId#584674L, orderProposalItemId#584675, orderProposalItemGroupId#584676, originalReplenishmentRunId#584677L, orderProposalHorizonGroupingId#584678L, splitIndicator#584679L, previousOrderProposal#584680L, clusterId#584681L, sequenceId#584682L, sourceOfSupplyUuid#584683, supplierGroup#584684, supplier#584685, subrange#584686, product#584687, plant#584688, purchasingOrg#584689, purchasingGroup#584690, mrpController#584691, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, nextAvailabilityDateTime#584695, isFallbackOrderOnly#584696, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#584717L, orderProposalItemId#584718, supplierGroup#584719, supplier#584720, plant#584721, deliveryDateTime#584722, subrange#584723, supplyingPlant#584724, productGroup#584725, product#584726, orderDateTime#584727, availabilityDateTime#584728, nextAvailabilityDateTime#584729, mrpController#584730, sourceOfSupplyUuid#584731, purchasingOrg#584732, purchasingGroup#584733, isFallbackOrderOnly#584734, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, sequenceId#584739, worklistShardItemId#584740L, orderProposalItemGroupId#584741, ... 20 more fields], false
(12) Filter
Arguments: (shardId#584761 = 0_1_10000002106)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#584740L], 20
(14) Filter
Arguments: (sequenceId#584739 = 1)
(15) Project
Arguments: [orderProposalId#584717L, orderProposalItemId#584718, supplierGroup#584719, supplier#584720, plant#584721, deliveryDateTime#584722, subrange#584723, supplyingPlant#584724, productGroup#584725, product#584726, orderDateTime#584727, availabilityDateTime#584728, nextAvailabilityDateTime#584729, mrpController#584730, sourceOfSupplyUuid#584731, purchasingOrg#584732, purchasingGroup#584733, isFallbackOrderOnly#584734, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, sequenceId#584739, worklistShardItemId#584740L, orderProposalItemGroupId#584741, ... 20 more fields]
(16) Project
Arguments: [shardId#584763, worklistShardItemId#584740L, orderProposalId#584717L, orderProposalItemId#584718, orderProposalItemGroupId#584741, originalReplenishmentRunId#584759L, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, sequenceId#584739, sourceOfSupplyUuid#584731, supplierGroup#584719, supplier#584720, subrange#584723, product#584726, plant#584721, purchasingOrg#584732, purchasingGroup#584733, mrpController#584730, orderDateTime#584727, deliveryDateTime#584722, availabilityDateTime#584728, nextAvailabilityDateTime#584729, isFallbackOrderOnly#584734, ... 20 more fields]
(17) Project
Arguments: [shardId#584763, worklistShardItemId#584740L, orderProposalId#584717L, orderProposalItemId#584718, orderProposalItemGroupId#584741, originalReplenishmentRunId#584759L, orderProposalHorizonGroupingId#584735L, splitIndicator#584736L, previousOrderProposal#584737L, clusterId#584738L, cast(sequenceId#584739 as bigint) AS sequenceId#584764L, sourceOfSupplyUuid#584731, supplierGroup#584719, supplier#584720, subrange#584723, product#584726, plant#584721, purchasingOrg#584732, purchasingGroup#584733, mrpController#584730, orderDateTime#584727, deliveryDateTime#584722, availabilityDateTime#584728, nextAvailabilityDateTime#584729, isFallbackOrderOnly#584734, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#584004 = shardId#584672) AND (worklistShardItemId#584516L = worklistShardItemId#584673L))
(20) Project
Arguments: [shardId#584004, worklistShardItemId#584516L, quantityAfterProdPlantOptimization#584517, qty#584518, orderProposalId#584674L, orderProposalItemId#584675, orderProposalItemGroupId#584676, originalReplenishmentRunId#584677L, orderProposalHorizonGroupingId#584678L, splitIndicator#584679L, previousOrderProposal#584680L, clusterId#584681L, sequenceId#584682L, sourceOfSupplyUuid#584683, supplierGroup#584684, supplier#584685, subrange#584686, product#584687, plant#584688, purchasingOrg#584689, purchasingGroup#584690, mrpController#584691, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, ... 22 more fields]
(21) Project
Arguments: [shardId#584004, worklistShardItemId#584516L, quantityAfterProdPlantOptimization#584517, qty#584518, orderProposalId#584674L, originalReplenishmentRunId#584677L, supplierGroup#584684, supplier#584685, supplyingPlant#584715, productGroup#584716, product#584687, plant#584688, subrange#584686, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, nextAvailabilityDateTime#584695, constraintValues#584709, constraintOperators#584707, constraintLabels#584706, logisticUnits#584711, orderQuantityBaseUom#584697, orderQuantityBaseUomUuid#584698, splitIndicator#584679L, netPriceAmount#584702, ... 14 more fields]
(22) Project
Arguments: [shardId#584004, product#584687, plant#584688, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, qty#584518, orderProposalId#584674L]
(23) Project
Arguments: [shardId#584004, product#584687, plant#584688, orderDateTime#584692, deliveryDateTime#584693, availabilityDateTime#584694, qty#584518 AS orderQuantityInBaseUnit#585264, orderProposalId#584674L]
(24) Filter
Arguments: (shardId#584004 = 0_1_10000002106)