== 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@7fadc75e, [path=hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001445/stream-10000001445-1/shardId=0_1_10000001445], Append
(3) LogicalRDD
Arguments: [shardId#5594062, orderProposalId#5594063L, items#5594064, optimizationGroups#5594065, isOptimal#5594066, lastModified#5594067, optimizationInsights#5594068], false
(4) Filter
Arguments: shardId#5594062 IN (0_1_10000001445)
(5) Filter
Arguments: shardId#5594062 IN (0_1_10000001445)
(6) Project
Arguments: [shardId#5594062, orderProposalId#5594063L, items#5594064, optimizationGroups#5594065, isOptimal#5594066, optimizationInsights#5594068]
(7) Generate
Arguments: explode(items#5594064), false, [item#5594573]
(8) Project
Arguments: [shardId#5594062, item#5594573]
(9) Project
Arguments: [shardId#5594062, item#5594573.worklistShardItemId AS worklistShardItemId#5594574L, item#5594573.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5594575, item#5594573.qty AS qty#5594576]
(10) LocalRelation
Arguments: <empty>, [shardId#5594730, worklistShardItemId#5594731L, orderProposalId#5594732L, orderProposalItemId#5594733, orderProposalItemGroupId#5594734, originalReplenishmentRunId#5594735L, orderProposalHorizonGroupingId#5594736L, splitIndicator#5594737L, previousOrderProposal#5594738L, clusterId#5594739L, sequenceId#5594740L, sourceOfSupplyUuid#5594741, supplierGroup#5594742, supplier#5594743, subrange#5594744, product#5594745, plant#5594746, purchasingOrg#5594747, purchasingGroup#5594748, mrpController#5594749, orderDateTime#5594750, deliveryDateTime#5594751, availabilityDateTime#5594752, nextAvailabilityDateTime#5594753, isFallbackOrderOnly#5594754, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#5594775L, orderProposalItemId#5594776, supplierGroup#5594777, supplier#5594778, plant#5594779, deliveryDateTime#5594780, subrange#5594781, supplyingPlant#5594782, productGroup#5594783, product#5594784, orderDateTime#5594785, availabilityDateTime#5594786, nextAvailabilityDateTime#5594787, mrpController#5594788, sourceOfSupplyUuid#5594789, purchasingOrg#5594790, purchasingGroup#5594791, isFallbackOrderOnly#5594792, orderProposalHorizonGroupingId#5594793L, splitIndicator#5594794L, previousOrderProposal#5594795L, clusterId#5594796L, sequenceId#5594797, worklistShardItemId#5594798L, orderProposalItemGroupId#5594799, ... 20 more fields], false
(12) Filter
Arguments: (shardId#5594819 = 0_1_10000001445)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#5594798L], 30
(14) Filter
Arguments: (sequenceId#5594797 = 8)
(15) Project
Arguments: [orderProposalId#5594775L, orderProposalItemId#5594776, supplierGroup#5594777, supplier#5594778, plant#5594779, deliveryDateTime#5594780, subrange#5594781, supplyingPlant#5594782, productGroup#5594783, product#5594784, orderDateTime#5594785, availabilityDateTime#5594786, nextAvailabilityDateTime#5594787, mrpController#5594788, sourceOfSupplyUuid#5594789, purchasingOrg#5594790, purchasingGroup#5594791, isFallbackOrderOnly#5594792, orderProposalHorizonGroupingId#5594793L, splitIndicator#5594794L, previousOrderProposal#5594795L, clusterId#5594796L, sequenceId#5594797, worklistShardItemId#5594798L, orderProposalItemGroupId#5594799, ... 20 more fields]
(16) Project
Arguments: [shardId#5594821, worklistShardItemId#5594798L, orderProposalId#5594775L, orderProposalItemId#5594776, orderProposalItemGroupId#5594799, originalReplenishmentRunId#5594817L, orderProposalHorizonGroupingId#5594793L, splitIndicator#5594794L, previousOrderProposal#5594795L, clusterId#5594796L, sequenceId#5594797, sourceOfSupplyUuid#5594789, supplierGroup#5594777, supplier#5594778, subrange#5594781, product#5594784, plant#5594779, purchasingOrg#5594790, purchasingGroup#5594791, mrpController#5594788, orderDateTime#5594785, deliveryDateTime#5594780, availabilityDateTime#5594786, nextAvailabilityDateTime#5594787, isFallbackOrderOnly#5594792, ... 20 more fields]
(17) Project
Arguments: [shardId#5594821, worklistShardItemId#5594798L, orderProposalId#5594775L, orderProposalItemId#5594776, orderProposalItemGroupId#5594799, originalReplenishmentRunId#5594817L, orderProposalHorizonGroupingId#5594793L, splitIndicator#5594794L, previousOrderProposal#5594795L, clusterId#5594796L, cast(sequenceId#5594797 as bigint) AS sequenceId#5594822L, sourceOfSupplyUuid#5594789, supplierGroup#5594777, supplier#5594778, subrange#5594781, product#5594784, plant#5594779, purchasingOrg#5594790, purchasingGroup#5594791, mrpController#5594788, orderDateTime#5594785, deliveryDateTime#5594780, availabilityDateTime#5594786, nextAvailabilityDateTime#5594787, isFallbackOrderOnly#5594792, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#5594062 = shardId#5594730) AND (worklistShardItemId#5594574L = worklistShardItemId#5594731L))
(20) Project
Arguments: [shardId#5594062, worklistShardItemId#5594574L, quantityAfterProdPlantOptimization#5594575, qty#5594576, orderProposalId#5594732L, orderProposalItemId#5594733, orderProposalItemGroupId#5594734, originalReplenishmentRunId#5594735L, orderProposalHorizonGroupingId#5594736L, splitIndicator#5594737L, previousOrderProposal#5594738L, clusterId#5594739L, sequenceId#5594740L, sourceOfSupplyUuid#5594741, supplierGroup#5594742, supplier#5594743, subrange#5594744, product#5594745, plant#5594746, purchasingOrg#5594747, purchasingGroup#5594748, mrpController#5594749, orderDateTime#5594750, deliveryDateTime#5594751, availabilityDateTime#5594752, ... 22 more fields]
(21) Project
Arguments: [shardId#5594062, worklistShardItemId#5594574L, quantityAfterProdPlantOptimization#5594575, qty#5594576, orderProposalId#5594732L, originalReplenishmentRunId#5594735L, supplierGroup#5594742, supplier#5594743, supplyingPlant#5594773, productGroup#5594774, product#5594745, plant#5594746, subrange#5594744, orderDateTime#5594750, deliveryDateTime#5594751, availabilityDateTime#5594752, nextAvailabilityDateTime#5594753, constraintValues#5594767, constraintOperators#5594765, constraintLabels#5594764, logisticUnits#5594769, orderQuantityBaseUom#5594755, orderQuantityBaseUomUuid#5594756, splitIndicator#5594737L, netPriceAmount#5594760, ... 14 more fields]
(22) Project
Arguments: [shardId#5594062, product#5594745, plant#5594746, orderDateTime#5594750, deliveryDateTime#5594751, availabilityDateTime#5594752, qty#5594576, orderProposalId#5594732L]
(23) Project
Arguments: [shardId#5594062, product#5594745, plant#5594746, orderDateTime#5594750, deliveryDateTime#5594751, availabilityDateTime#5594752, qty#5594576 AS orderQuantityInBaseUnit#5594851, orderProposalId#5594732L]
(24) Filter
Arguments: (shardId#5594062 = 0_1_10000001445)