== 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@66debed, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002107/stream-10000002107-1/shardId=0_1_10000002107], Append
(3) LogicalRDD
Arguments: [shardId#691888, orderProposalId#691889L, items#691890, optimizationGroups#691891, isOptimal#691892, lastModified#691893, optimizationInsights#691894], false
(4) Filter
Arguments: shardId#691888 IN (0_1_10000002107)
(5) Filter
Arguments: shardId#691888 IN (0_1_10000002107)
(6) Project
Arguments: [shardId#691888, orderProposalId#691889L, items#691890, optimizationGroups#691891, isOptimal#691892, optimizationInsights#691894]
(7) Generate
Arguments: explode(items#691890), false, [item#692399]
(8) Project
Arguments: [shardId#691888, item#692399]
(9) Project
Arguments: [shardId#691888, item#692399.worklistShardItemId AS worklistShardItemId#692400L, item#692399.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#692401, item#692399.qty AS qty#692402]
(10) LocalRelation
Arguments: <empty>, [shardId#692556, worklistShardItemId#692557L, orderProposalId#692558L, orderProposalItemId#692559, orderProposalItemGroupId#692560, originalReplenishmentRunId#692561L, orderProposalHorizonGroupingId#692562L, splitIndicator#692563L, previousOrderProposal#692564L, clusterId#692565L, sequenceId#692566L, sourceOfSupplyUuid#692567, supplierGroup#692568, supplier#692569, subrange#692570, product#692571, plant#692572, purchasingOrg#692573, purchasingGroup#692574, mrpController#692575, orderDateTime#692576, deliveryDateTime#692577, availabilityDateTime#692578, nextAvailabilityDateTime#692579, isFallbackOrderOnly#692580, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#692601L, orderProposalItemId#692602, supplierGroup#692603, supplier#692604, plant#692605, deliveryDateTime#692606, subrange#692607, supplyingPlant#692608, productGroup#692609, product#692610, orderDateTime#692611, availabilityDateTime#692612, nextAvailabilityDateTime#692613, mrpController#692614, sourceOfSupplyUuid#692615, purchasingOrg#692616, purchasingGroup#692617, isFallbackOrderOnly#692618, orderProposalHorizonGroupingId#692619L, splitIndicator#692620L, previousOrderProposal#692621L, clusterId#692622L, sequenceId#692623, worklistShardItemId#692624L, orderProposalItemGroupId#692625, ... 20 more fields], false
(12) Filter
Arguments: (shardId#692645 = 0_1_10000002107)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#692624L], 20
(14) Filter
Arguments: (sequenceId#692623 = 5)
(15) Project
Arguments: [orderProposalId#692601L, orderProposalItemId#692602, supplierGroup#692603, supplier#692604, plant#692605, deliveryDateTime#692606, subrange#692607, supplyingPlant#692608, productGroup#692609, product#692610, orderDateTime#692611, availabilityDateTime#692612, nextAvailabilityDateTime#692613, mrpController#692614, sourceOfSupplyUuid#692615, purchasingOrg#692616, purchasingGroup#692617, isFallbackOrderOnly#692618, orderProposalHorizonGroupingId#692619L, splitIndicator#692620L, previousOrderProposal#692621L, clusterId#692622L, sequenceId#692623, worklistShardItemId#692624L, orderProposalItemGroupId#692625, ... 20 more fields]
(16) Project
Arguments: [shardId#692647, worklistShardItemId#692624L, orderProposalId#692601L, orderProposalItemId#692602, orderProposalItemGroupId#692625, originalReplenishmentRunId#692643L, orderProposalHorizonGroupingId#692619L, splitIndicator#692620L, previousOrderProposal#692621L, clusterId#692622L, sequenceId#692623, sourceOfSupplyUuid#692615, supplierGroup#692603, supplier#692604, subrange#692607, product#692610, plant#692605, purchasingOrg#692616, purchasingGroup#692617, mrpController#692614, orderDateTime#692611, deliveryDateTime#692606, availabilityDateTime#692612, nextAvailabilityDateTime#692613, isFallbackOrderOnly#692618, ... 20 more fields]
(17) Project
Arguments: [shardId#692647, worklistShardItemId#692624L, orderProposalId#692601L, orderProposalItemId#692602, orderProposalItemGroupId#692625, originalReplenishmentRunId#692643L, orderProposalHorizonGroupingId#692619L, splitIndicator#692620L, previousOrderProposal#692621L, clusterId#692622L, cast(sequenceId#692623 as bigint) AS sequenceId#692648L, sourceOfSupplyUuid#692615, supplierGroup#692603, supplier#692604, subrange#692607, product#692610, plant#692605, purchasingOrg#692616, purchasingGroup#692617, mrpController#692614, orderDateTime#692611, deliveryDateTime#692606, availabilityDateTime#692612, nextAvailabilityDateTime#692613, isFallbackOrderOnly#692618, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#691888 = shardId#692556) AND (worklistShardItemId#692400L = worklistShardItemId#692557L))
(20) Project
Arguments: [shardId#691888, worklistShardItemId#692400L, quantityAfterProdPlantOptimization#692401, qty#692402, orderProposalId#692558L, orderProposalItemId#692559, orderProposalItemGroupId#692560, originalReplenishmentRunId#692561L, orderProposalHorizonGroupingId#692562L, splitIndicator#692563L, previousOrderProposal#692564L, clusterId#692565L, sequenceId#692566L, sourceOfSupplyUuid#692567, supplierGroup#692568, supplier#692569, subrange#692570, product#692571, plant#692572, purchasingOrg#692573, purchasingGroup#692574, mrpController#692575, orderDateTime#692576, deliveryDateTime#692577, availabilityDateTime#692578, ... 22 more fields]
(21) Project
Arguments: [shardId#691888, worklistShardItemId#692400L, quantityAfterProdPlantOptimization#692401, qty#692402, orderProposalId#692558L, originalReplenishmentRunId#692561L, supplierGroup#692568, supplier#692569, supplyingPlant#692599, productGroup#692600, product#692571, plant#692572, subrange#692570, orderDateTime#692576, deliveryDateTime#692577, availabilityDateTime#692578, nextAvailabilityDateTime#692579, constraintValues#692593, constraintOperators#692591, constraintLabels#692590, logisticUnits#692595, orderQuantityBaseUom#692581, orderQuantityBaseUomUuid#692582, splitIndicator#692563L, netPriceAmount#692586, ... 14 more fields]
(22) Project
Arguments: [shardId#691888, product#692571, plant#692572, orderDateTime#692576, deliveryDateTime#692577, availabilityDateTime#692578, qty#692402, orderProposalId#692558L]
(23) Project
Arguments: [shardId#691888, product#692571, plant#692572, orderDateTime#692576, deliveryDateTime#692577, availabilityDateTime#692578, qty#692402 AS orderQuantityInBaseUnit#692853, orderProposalId#692558L]
(24) Filter
Arguments: (shardId#691888 = 0_1_10000002107)