== 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@486ddab3, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108], Append
(3) LogicalRDD
Arguments: [shardId#803008, orderProposalId#803009L, items#803010, optimizationGroups#803011, isOptimal#803012, lastModified#803013, optimizationInsights#803014], false
(4) Filter
Arguments: shardId#803008 IN (0_1_10000002108)
(5) Filter
Arguments: shardId#803008 IN (0_1_10000002108)
(6) Project
Arguments: [shardId#803008, orderProposalId#803009L, items#803010, optimizationGroups#803011, isOptimal#803012, optimizationInsights#803014]
(7) Generate
Arguments: explode(items#803010), false, [item#803519]
(8) Project
Arguments: [shardId#803008, item#803519]
(9) Project
Arguments: [shardId#803008, item#803519.worklistShardItemId AS worklistShardItemId#803520L, item#803519.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#803521, item#803519.qty AS qty#803522]
(10) LocalRelation
Arguments: <empty>, [shardId#803676, worklistShardItemId#803677L, orderProposalId#803678L, orderProposalItemId#803679, orderProposalItemGroupId#803680, originalReplenishmentRunId#803681L, orderProposalHorizonGroupingId#803682L, splitIndicator#803683L, previousOrderProposal#803684L, clusterId#803685L, sequenceId#803686L, sourceOfSupplyUuid#803687, supplierGroup#803688, supplier#803689, subrange#803690, product#803691, plant#803692, purchasingOrg#803693, purchasingGroup#803694, mrpController#803695, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, nextAvailabilityDateTime#803699, isFallbackOrderOnly#803700, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#803721L, orderProposalItemId#803722, supplierGroup#803723, supplier#803724, plant#803725, deliveryDateTime#803726, subrange#803727, supplyingPlant#803728, productGroup#803729, product#803730, orderDateTime#803731, availabilityDateTime#803732, nextAvailabilityDateTime#803733, mrpController#803734, sourceOfSupplyUuid#803735, purchasingOrg#803736, purchasingGroup#803737, isFallbackOrderOnly#803738, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, sequenceId#803743, worklistShardItemId#803744L, orderProposalItemGroupId#803745, ... 20 more fields], false
(12) Filter
Arguments: (shardId#803765 = 0_1_10000002108)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#803744L], 20
(14) Filter
Arguments: (sequenceId#803743 = 2)
(15) Project
Arguments: [orderProposalId#803721L, orderProposalItemId#803722, supplierGroup#803723, supplier#803724, plant#803725, deliveryDateTime#803726, subrange#803727, supplyingPlant#803728, productGroup#803729, product#803730, orderDateTime#803731, availabilityDateTime#803732, nextAvailabilityDateTime#803733, mrpController#803734, sourceOfSupplyUuid#803735, purchasingOrg#803736, purchasingGroup#803737, isFallbackOrderOnly#803738, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, sequenceId#803743, worklistShardItemId#803744L, orderProposalItemGroupId#803745, ... 20 more fields]
(16) Project
Arguments: [shardId#803767, worklistShardItemId#803744L, orderProposalId#803721L, orderProposalItemId#803722, orderProposalItemGroupId#803745, originalReplenishmentRunId#803763L, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, sequenceId#803743, sourceOfSupplyUuid#803735, supplierGroup#803723, supplier#803724, subrange#803727, product#803730, plant#803725, purchasingOrg#803736, purchasingGroup#803737, mrpController#803734, orderDateTime#803731, deliveryDateTime#803726, availabilityDateTime#803732, nextAvailabilityDateTime#803733, isFallbackOrderOnly#803738, ... 20 more fields]
(17) Project
Arguments: [shardId#803767, worklistShardItemId#803744L, orderProposalId#803721L, orderProposalItemId#803722, orderProposalItemGroupId#803745, originalReplenishmentRunId#803763L, orderProposalHorizonGroupingId#803739L, splitIndicator#803740L, previousOrderProposal#803741L, clusterId#803742L, cast(sequenceId#803743 as bigint) AS sequenceId#803768L, sourceOfSupplyUuid#803735, supplierGroup#803723, supplier#803724, subrange#803727, product#803730, plant#803725, purchasingOrg#803736, purchasingGroup#803737, mrpController#803734, orderDateTime#803731, deliveryDateTime#803726, availabilityDateTime#803732, nextAvailabilityDateTime#803733, isFallbackOrderOnly#803738, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#803008 = shardId#803676) AND (worklistShardItemId#803520L = worklistShardItemId#803677L))
(20) Project
Arguments: [shardId#803008, worklistShardItemId#803520L, quantityAfterProdPlantOptimization#803521, qty#803522, orderProposalId#803678L, orderProposalItemId#803679, orderProposalItemGroupId#803680, originalReplenishmentRunId#803681L, orderProposalHorizonGroupingId#803682L, splitIndicator#803683L, previousOrderProposal#803684L, clusterId#803685L, sequenceId#803686L, sourceOfSupplyUuid#803687, supplierGroup#803688, supplier#803689, subrange#803690, product#803691, plant#803692, purchasingOrg#803693, purchasingGroup#803694, mrpController#803695, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, ... 22 more fields]
(21) Project
Arguments: [shardId#803008, worklistShardItemId#803520L, quantityAfterProdPlantOptimization#803521, qty#803522, orderProposalId#803678L, originalReplenishmentRunId#803681L, supplierGroup#803688, supplier#803689, supplyingPlant#803719, productGroup#803720, product#803691, plant#803692, subrange#803690, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, nextAvailabilityDateTime#803699, constraintValues#803713, constraintOperators#803711, constraintLabels#803710, logisticUnits#803715, orderQuantityBaseUom#803701, orderQuantityBaseUomUuid#803702, splitIndicator#803683L, netPriceAmount#803706, ... 14 more fields]
(22) Project
Arguments: [shardId#803008, product#803691, plant#803692, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, qty#803522, orderProposalId#803678L]
(23) Project
Arguments: [shardId#803008, product#803691, plant#803692, orderDateTime#803696, deliveryDateTime#803697, availabilityDateTime#803698, qty#803522 AS orderQuantityInBaseUnit#803796, orderProposalId#803678L]
(24) Filter
Arguments: (shardId#803008 = 0_1_10000002108)