== 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@43d191d5, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002110/stream-10000002110-1/shardId=0_1_10000002110], Append
(3) LogicalRDD
Arguments: [shardId#958036, orderProposalId#958037L, items#958038, optimizationGroups#958039, isOptimal#958040, lastModified#958041, optimizationInsights#958042], false
(4) Filter
Arguments: shardId#958036 IN (0_1_10000002110)
(5) Filter
Arguments: shardId#958036 IN (0_1_10000002110)
(6) Project
Arguments: [shardId#958036, orderProposalId#958037L, items#958038, optimizationGroups#958039, isOptimal#958040, optimizationInsights#958042]
(7) Generate
Arguments: explode(items#958038), false, [item#958547]
(8) Project
Arguments: [shardId#958036, item#958547]
(9) Project
Arguments: [shardId#958036, item#958547.worklistShardItemId AS worklistShardItemId#958548L, item#958547.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#958549, item#958547.qty AS qty#958550]
(10) LocalRelation
Arguments: <empty>, [shardId#958704, worklistShardItemId#958705L, orderProposalId#958706L, orderProposalItemId#958707, orderProposalItemGroupId#958708, originalReplenishmentRunId#958709L, orderProposalHorizonGroupingId#958710L, splitIndicator#958711L, previousOrderProposal#958712L, clusterId#958713L, sequenceId#958714L, sourceOfSupplyUuid#958715, supplierGroup#958716, supplier#958717, subrange#958718, product#958719, plant#958720, purchasingOrg#958721, purchasingGroup#958722, mrpController#958723, orderDateTime#958724, deliveryDateTime#958725, availabilityDateTime#958726, nextAvailabilityDateTime#958727, isFallbackOrderOnly#958728, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#958749L, orderProposalItemId#958750, supplierGroup#958751, supplier#958752, plant#958753, deliveryDateTime#958754, subrange#958755, supplyingPlant#958756, productGroup#958757, product#958758, orderDateTime#958759, availabilityDateTime#958760, nextAvailabilityDateTime#958761, mrpController#958762, sourceOfSupplyUuid#958763, purchasingOrg#958764, purchasingGroup#958765, isFallbackOrderOnly#958766, orderProposalHorizonGroupingId#958767L, splitIndicator#958768L, previousOrderProposal#958769L, clusterId#958770L, sequenceId#958771, worklistShardItemId#958772L, orderProposalItemGroupId#958773, ... 20 more fields], false
(12) Filter
Arguments: (shardId#958793 = 0_1_10000002110)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#958772L], 20
(14) Filter
Arguments: (sequenceId#958771 = 1)
(15) Project
Arguments: [orderProposalId#958749L, orderProposalItemId#958750, supplierGroup#958751, supplier#958752, plant#958753, deliveryDateTime#958754, subrange#958755, supplyingPlant#958756, productGroup#958757, product#958758, orderDateTime#958759, availabilityDateTime#958760, nextAvailabilityDateTime#958761, mrpController#958762, sourceOfSupplyUuid#958763, purchasingOrg#958764, purchasingGroup#958765, isFallbackOrderOnly#958766, orderProposalHorizonGroupingId#958767L, splitIndicator#958768L, previousOrderProposal#958769L, clusterId#958770L, sequenceId#958771, worklistShardItemId#958772L, orderProposalItemGroupId#958773, ... 20 more fields]
(16) Project
Arguments: [shardId#958795, worklistShardItemId#958772L, orderProposalId#958749L, orderProposalItemId#958750, orderProposalItemGroupId#958773, originalReplenishmentRunId#958791L, orderProposalHorizonGroupingId#958767L, splitIndicator#958768L, previousOrderProposal#958769L, clusterId#958770L, sequenceId#958771, sourceOfSupplyUuid#958763, supplierGroup#958751, supplier#958752, subrange#958755, product#958758, plant#958753, purchasingOrg#958764, purchasingGroup#958765, mrpController#958762, orderDateTime#958759, deliveryDateTime#958754, availabilityDateTime#958760, nextAvailabilityDateTime#958761, isFallbackOrderOnly#958766, ... 20 more fields]
(17) Project
Arguments: [shardId#958795, worklistShardItemId#958772L, orderProposalId#958749L, orderProposalItemId#958750, orderProposalItemGroupId#958773, originalReplenishmentRunId#958791L, orderProposalHorizonGroupingId#958767L, splitIndicator#958768L, previousOrderProposal#958769L, clusterId#958770L, cast(sequenceId#958771 as bigint) AS sequenceId#958796L, sourceOfSupplyUuid#958763, supplierGroup#958751, supplier#958752, subrange#958755, product#958758, plant#958753, purchasingOrg#958764, purchasingGroup#958765, mrpController#958762, orderDateTime#958759, deliveryDateTime#958754, availabilityDateTime#958760, nextAvailabilityDateTime#958761, isFallbackOrderOnly#958766, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#958036 = shardId#958704) AND (worklistShardItemId#958548L = worklistShardItemId#958705L))
(20) Project
Arguments: [shardId#958036, worklistShardItemId#958548L, quantityAfterProdPlantOptimization#958549, qty#958550, orderProposalId#958706L, orderProposalItemId#958707, orderProposalItemGroupId#958708, originalReplenishmentRunId#958709L, orderProposalHorizonGroupingId#958710L, splitIndicator#958711L, previousOrderProposal#958712L, clusterId#958713L, sequenceId#958714L, sourceOfSupplyUuid#958715, supplierGroup#958716, supplier#958717, subrange#958718, product#958719, plant#958720, purchasingOrg#958721, purchasingGroup#958722, mrpController#958723, orderDateTime#958724, deliveryDateTime#958725, availabilityDateTime#958726, ... 22 more fields]
(21) Project
Arguments: [shardId#958036, worklistShardItemId#958548L, quantityAfterProdPlantOptimization#958549, qty#958550, orderProposalId#958706L, originalReplenishmentRunId#958709L, supplierGroup#958716, supplier#958717, supplyingPlant#958747, productGroup#958748, product#958719, plant#958720, subrange#958718, orderDateTime#958724, deliveryDateTime#958725, availabilityDateTime#958726, nextAvailabilityDateTime#958727, constraintValues#958741, constraintOperators#958739, constraintLabels#958738, logisticUnits#958743, orderQuantityBaseUom#958729, orderQuantityBaseUomUuid#958730, splitIndicator#958711L, netPriceAmount#958734, ... 14 more fields]
(22) Project
Arguments: [shardId#958036, product#958719, plant#958720, orderDateTime#958724, deliveryDateTime#958725, availabilityDateTime#958726, qty#958550, orderProposalId#958706L]
(23) Project
Arguments: [shardId#958036, product#958719, plant#958720, orderDateTime#958724, deliveryDateTime#958725, availabilityDateTime#958726, qty#958550 AS orderQuantityInBaseUnit#959001, orderProposalId#958706L]
(24) Filter
Arguments: (shardId#958036 = 0_1_10000002110)