== 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@560191e8, [path=hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000532/stream-10000000532-2/shardId=0_5_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3515802, orderProposalId#3515803L, items#3515804, optimizationGroups#3515805, isOptimal#3515806, lastModified#3515807, optimizationInsights#3515808], false
(4) Filter
Arguments: shardId#3515802 IN (0_5_10000000532)
(5) Filter
Arguments: shardId#3515802 IN (0_5_10000000532)
(6) Project
Arguments: [shardId#3515802, orderProposalId#3515803L, items#3515804, optimizationGroups#3515805, isOptimal#3515806, optimizationInsights#3515808]
(7) Generate
Arguments: explode(items#3515804), false, [item#3516313]
(8) Project
Arguments: [shardId#3515802, item#3516313]
(9) Project
Arguments: [shardId#3515802, item#3516313.worklistShardItemId AS worklistShardItemId#3516314L, item#3516313.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3516315, item#3516313.qty AS qty#3516316]
(10) LocalRelation
Arguments: <empty>, [shardId#3516470, worklistShardItemId#3516471L, orderProposalId#3516472L, orderProposalItemId#3516473, orderProposalItemGroupId#3516474, originalReplenishmentRunId#3516475L, orderProposalHorizonGroupingId#3516476L, splitIndicator#3516477L, previousOrderProposal#3516478L, clusterId#3516479L, sequenceId#3516480L, sourceOfSupplyUuid#3516481, supplierGroup#3516482, supplier#3516483, subrange#3516484, product#3516485, plant#3516486, purchasingOrg#3516487, purchasingGroup#3516488, mrpController#3516489, orderDateTime#3516490, deliveryDateTime#3516491, availabilityDateTime#3516492, nextAvailabilityDateTime#3516493, isFallbackOrderOnly#3516494, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3516515L, orderProposalItemId#3516516, supplierGroup#3516517, supplier#3516518, plant#3516519, deliveryDateTime#3516520, subrange#3516521, supplyingPlant#3516522, productGroup#3516523, product#3516524, orderDateTime#3516525, availabilityDateTime#3516526, nextAvailabilityDateTime#3516527, mrpController#3516528, sourceOfSupplyUuid#3516529, purchasingOrg#3516530, purchasingGroup#3516531, isFallbackOrderOnly#3516532, orderProposalHorizonGroupingId#3516533L, splitIndicator#3516534L, previousOrderProposal#3516535L, clusterId#3516536L, sequenceId#3516537, worklistShardItemId#3516538L, orderProposalItemGroupId#3516539, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3516559 = 0_5_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3516538L], 30
(14) Filter
Arguments: (sequenceId#3516537 = 6)
(15) Project
Arguments: [orderProposalId#3516515L, orderProposalItemId#3516516, supplierGroup#3516517, supplier#3516518, plant#3516519, deliveryDateTime#3516520, subrange#3516521, supplyingPlant#3516522, productGroup#3516523, product#3516524, orderDateTime#3516525, availabilityDateTime#3516526, nextAvailabilityDateTime#3516527, mrpController#3516528, sourceOfSupplyUuid#3516529, purchasingOrg#3516530, purchasingGroup#3516531, isFallbackOrderOnly#3516532, orderProposalHorizonGroupingId#3516533L, splitIndicator#3516534L, previousOrderProposal#3516535L, clusterId#3516536L, sequenceId#3516537, worklistShardItemId#3516538L, orderProposalItemGroupId#3516539, ... 20 more fields]
(16) Project
Arguments: [shardId#3516561, worklistShardItemId#3516538L, orderProposalId#3516515L, orderProposalItemId#3516516, orderProposalItemGroupId#3516539, originalReplenishmentRunId#3516557L, orderProposalHorizonGroupingId#3516533L, splitIndicator#3516534L, previousOrderProposal#3516535L, clusterId#3516536L, sequenceId#3516537, sourceOfSupplyUuid#3516529, supplierGroup#3516517, supplier#3516518, subrange#3516521, product#3516524, plant#3516519, purchasingOrg#3516530, purchasingGroup#3516531, mrpController#3516528, orderDateTime#3516525, deliveryDateTime#3516520, availabilityDateTime#3516526, nextAvailabilityDateTime#3516527, isFallbackOrderOnly#3516532, ... 20 more fields]
(17) Project
Arguments: [shardId#3516561, worklistShardItemId#3516538L, orderProposalId#3516515L, orderProposalItemId#3516516, orderProposalItemGroupId#3516539, originalReplenishmentRunId#3516557L, orderProposalHorizonGroupingId#3516533L, splitIndicator#3516534L, previousOrderProposal#3516535L, clusterId#3516536L, cast(sequenceId#3516537 as bigint) AS sequenceId#3516562L, sourceOfSupplyUuid#3516529, supplierGroup#3516517, supplier#3516518, subrange#3516521, product#3516524, plant#3516519, purchasingOrg#3516530, purchasingGroup#3516531, mrpController#3516528, orderDateTime#3516525, deliveryDateTime#3516520, availabilityDateTime#3516526, nextAvailabilityDateTime#3516527, isFallbackOrderOnly#3516532, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3515802 = shardId#3516470) AND (worklistShardItemId#3516314L = worklistShardItemId#3516471L))
(20) Project
Arguments: [shardId#3515802, worklistShardItemId#3516314L, quantityAfterProdPlantOptimization#3516315, qty#3516316, orderProposalId#3516472L, orderProposalItemId#3516473, orderProposalItemGroupId#3516474, originalReplenishmentRunId#3516475L, orderProposalHorizonGroupingId#3516476L, splitIndicator#3516477L, previousOrderProposal#3516478L, clusterId#3516479L, sequenceId#3516480L, sourceOfSupplyUuid#3516481, supplierGroup#3516482, supplier#3516483, subrange#3516484, product#3516485, plant#3516486, purchasingOrg#3516487, purchasingGroup#3516488, mrpController#3516489, orderDateTime#3516490, deliveryDateTime#3516491, availabilityDateTime#3516492, ... 22 more fields]
(21) Project
Arguments: [shardId#3515802, worklistShardItemId#3516314L, quantityAfterProdPlantOptimization#3516315, qty#3516316, orderProposalId#3516472L, originalReplenishmentRunId#3516475L, supplierGroup#3516482, supplier#3516483, supplyingPlant#3516513, productGroup#3516514, product#3516485, plant#3516486, subrange#3516484, orderDateTime#3516490, deliveryDateTime#3516491, availabilityDateTime#3516492, nextAvailabilityDateTime#3516493, constraintValues#3516507, constraintOperators#3516505, constraintLabels#3516504, logisticUnits#3516509, orderQuantityBaseUom#3516495, orderQuantityBaseUomUuid#3516496, splitIndicator#3516477L, netPriceAmount#3516500, ... 14 more fields]
(22) Project
Arguments: [shardId#3515802, product#3516485, plant#3516486, orderDateTime#3516490, deliveryDateTime#3516491, availabilityDateTime#3516492, qty#3516316, orderProposalId#3516472L]
(23) Project
Arguments: [shardId#3515802, product#3516485, plant#3516486, orderDateTime#3516490, deliveryDateTime#3516491, availabilityDateTime#3516492, qty#3516316 AS orderQuantityInBaseUnit#3517283, orderProposalId#3516472L]
(24) Filter
Arguments: (shardId#3515802 = 0_5_10000000532)