== 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@54643e08, [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-3/shardId=0_6_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3524906, orderProposalId#3524907L, items#3524908, optimizationGroups#3524909, isOptimal#3524910, lastModified#3524911, optimizationInsights#3524912], false
(4) Filter
Arguments: shardId#3524906 IN (0_6_10000000532)
(5) Filter
Arguments: shardId#3524906 IN (0_6_10000000532)
(6) Project
Arguments: [shardId#3524906, orderProposalId#3524907L, items#3524908, optimizationGroups#3524909, isOptimal#3524910, optimizationInsights#3524912]
(7) Generate
Arguments: explode(items#3524908), false, [item#3525417]
(8) Project
Arguments: [shardId#3524906, item#3525417]
(9) Project
Arguments: [shardId#3524906, item#3525417.worklistShardItemId AS worklistShardItemId#3525418L, item#3525417.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3525419, item#3525417.qty AS qty#3525420]
(10) LocalRelation
Arguments: <empty>, [shardId#3525574, worklistShardItemId#3525575L, orderProposalId#3525576L, orderProposalItemId#3525577, orderProposalItemGroupId#3525578, originalReplenishmentRunId#3525579L, orderProposalHorizonGroupingId#3525580L, splitIndicator#3525581L, previousOrderProposal#3525582L, clusterId#3525583L, sequenceId#3525584L, sourceOfSupplyUuid#3525585, supplierGroup#3525586, supplier#3525587, subrange#3525588, product#3525589, plant#3525590, purchasingOrg#3525591, purchasingGroup#3525592, mrpController#3525593, orderDateTime#3525594, deliveryDateTime#3525595, availabilityDateTime#3525596, nextAvailabilityDateTime#3525597, isFallbackOrderOnly#3525598, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3525619L, orderProposalItemId#3525620, supplierGroup#3525621, supplier#3525622, plant#3525623, deliveryDateTime#3525624, subrange#3525625, supplyingPlant#3525626, productGroup#3525627, product#3525628, orderDateTime#3525629, availabilityDateTime#3525630, nextAvailabilityDateTime#3525631, mrpController#3525632, sourceOfSupplyUuid#3525633, purchasingOrg#3525634, purchasingGroup#3525635, isFallbackOrderOnly#3525636, orderProposalHorizonGroupingId#3525637L, splitIndicator#3525638L, previousOrderProposal#3525639L, clusterId#3525640L, sequenceId#3525641, worklistShardItemId#3525642L, orderProposalItemGroupId#3525643, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3525663 = 0_6_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3525642L], 30
(14) Filter
Arguments: (sequenceId#3525641 = 6)
(15) Project
Arguments: [orderProposalId#3525619L, orderProposalItemId#3525620, supplierGroup#3525621, supplier#3525622, plant#3525623, deliveryDateTime#3525624, subrange#3525625, supplyingPlant#3525626, productGroup#3525627, product#3525628, orderDateTime#3525629, availabilityDateTime#3525630, nextAvailabilityDateTime#3525631, mrpController#3525632, sourceOfSupplyUuid#3525633, purchasingOrg#3525634, purchasingGroup#3525635, isFallbackOrderOnly#3525636, orderProposalHorizonGroupingId#3525637L, splitIndicator#3525638L, previousOrderProposal#3525639L, clusterId#3525640L, sequenceId#3525641, worklistShardItemId#3525642L, orderProposalItemGroupId#3525643, ... 20 more fields]
(16) Project
Arguments: [shardId#3525665, worklistShardItemId#3525642L, orderProposalId#3525619L, orderProposalItemId#3525620, orderProposalItemGroupId#3525643, originalReplenishmentRunId#3525661L, orderProposalHorizonGroupingId#3525637L, splitIndicator#3525638L, previousOrderProposal#3525639L, clusterId#3525640L, sequenceId#3525641, sourceOfSupplyUuid#3525633, supplierGroup#3525621, supplier#3525622, subrange#3525625, product#3525628, plant#3525623, purchasingOrg#3525634, purchasingGroup#3525635, mrpController#3525632, orderDateTime#3525629, deliveryDateTime#3525624, availabilityDateTime#3525630, nextAvailabilityDateTime#3525631, isFallbackOrderOnly#3525636, ... 20 more fields]
(17) Project
Arguments: [shardId#3525665, worklistShardItemId#3525642L, orderProposalId#3525619L, orderProposalItemId#3525620, orderProposalItemGroupId#3525643, originalReplenishmentRunId#3525661L, orderProposalHorizonGroupingId#3525637L, splitIndicator#3525638L, previousOrderProposal#3525639L, clusterId#3525640L, cast(sequenceId#3525641 as bigint) AS sequenceId#3525666L, sourceOfSupplyUuid#3525633, supplierGroup#3525621, supplier#3525622, subrange#3525625, product#3525628, plant#3525623, purchasingOrg#3525634, purchasingGroup#3525635, mrpController#3525632, orderDateTime#3525629, deliveryDateTime#3525624, availabilityDateTime#3525630, nextAvailabilityDateTime#3525631, isFallbackOrderOnly#3525636, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3524906 = shardId#3525574) AND (worklistShardItemId#3525418L = worklistShardItemId#3525575L))
(20) Project
Arguments: [shardId#3524906, worklistShardItemId#3525418L, quantityAfterProdPlantOptimization#3525419, qty#3525420, orderProposalId#3525576L, orderProposalItemId#3525577, orderProposalItemGroupId#3525578, originalReplenishmentRunId#3525579L, orderProposalHorizonGroupingId#3525580L, splitIndicator#3525581L, previousOrderProposal#3525582L, clusterId#3525583L, sequenceId#3525584L, sourceOfSupplyUuid#3525585, supplierGroup#3525586, supplier#3525587, subrange#3525588, product#3525589, plant#3525590, purchasingOrg#3525591, purchasingGroup#3525592, mrpController#3525593, orderDateTime#3525594, deliveryDateTime#3525595, availabilityDateTime#3525596, ... 22 more fields]
(21) Project
Arguments: [shardId#3524906, worklistShardItemId#3525418L, quantityAfterProdPlantOptimization#3525419, qty#3525420, orderProposalId#3525576L, originalReplenishmentRunId#3525579L, supplierGroup#3525586, supplier#3525587, supplyingPlant#3525617, productGroup#3525618, product#3525589, plant#3525590, subrange#3525588, orderDateTime#3525594, deliveryDateTime#3525595, availabilityDateTime#3525596, nextAvailabilityDateTime#3525597, constraintValues#3525611, constraintOperators#3525609, constraintLabels#3525608, logisticUnits#3525613, orderQuantityBaseUom#3525599, orderQuantityBaseUomUuid#3525600, splitIndicator#3525581L, netPriceAmount#3525604, ... 14 more fields]
(22) Project
Arguments: [shardId#3524906, product#3525589, plant#3525590, orderDateTime#3525594, deliveryDateTime#3525595, availabilityDateTime#3525596, qty#3525420, orderProposalId#3525576L]
(23) Project
Arguments: [shardId#3524906, product#3525589, plant#3525590, orderDateTime#3525594, deliveryDateTime#3525595, availabilityDateTime#3525596, qty#3525420 AS orderQuantityInBaseUnit#3529875, orderProposalId#3525576L]
(24) Filter
Arguments: (shardId#3524906 = 0_6_10000000532)