== 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@288a12c, [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-1/shardId=0_2_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3538856, orderProposalId#3538857L, items#3538858, optimizationGroups#3538859, isOptimal#3538860, lastModified#3538861, optimizationInsights#3538862], false
(4) Filter
Arguments: shardId#3538856 IN (0_2_10000000532)
(5) Filter
Arguments: shardId#3538856 IN (0_2_10000000532)
(6) Project
Arguments: [shardId#3538856, orderProposalId#3538857L, items#3538858, optimizationGroups#3538859, isOptimal#3538860, optimizationInsights#3538862]
(7) Generate
Arguments: explode(items#3538858), false, [item#3540267]
(8) Project
Arguments: [shardId#3538856, item#3540267]
(9) Project
Arguments: [shardId#3538856, item#3540267.worklistShardItemId AS worklistShardItemId#3540268L, item#3540267.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3540269, item#3540267.qty AS qty#3540270]
(10) LocalRelation
Arguments: <empty>, [shardId#3540424, worklistShardItemId#3540425L, orderProposalId#3540426L, orderProposalItemId#3540427, orderProposalItemGroupId#3540428, originalReplenishmentRunId#3540429L, orderProposalHorizonGroupingId#3540430L, splitIndicator#3540431L, previousOrderProposal#3540432L, clusterId#3540433L, sequenceId#3540434L, sourceOfSupplyUuid#3540435, supplierGroup#3540436, supplier#3540437, subrange#3540438, product#3540439, plant#3540440, purchasingOrg#3540441, purchasingGroup#3540442, mrpController#3540443, orderDateTime#3540444, deliveryDateTime#3540445, availabilityDateTime#3540446, nextAvailabilityDateTime#3540447, isFallbackOrderOnly#3540448, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3540469L, orderProposalItemId#3540470, supplierGroup#3540471, supplier#3540472, plant#3540473, deliveryDateTime#3540474, subrange#3540475, supplyingPlant#3540476, productGroup#3540477, product#3540478, orderDateTime#3540479, availabilityDateTime#3540480, nextAvailabilityDateTime#3540481, mrpController#3540482, sourceOfSupplyUuid#3540483, purchasingOrg#3540484, purchasingGroup#3540485, isFallbackOrderOnly#3540486, orderProposalHorizonGroupingId#3540487L, splitIndicator#3540488L, previousOrderProposal#3540489L, clusterId#3540490L, sequenceId#3540491, worklistShardItemId#3540492L, orderProposalItemGroupId#3540493, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3540513 = 0_2_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3540492L], 30
(14) Filter
Arguments: (sequenceId#3540491 = 6)
(15) Project
Arguments: [orderProposalId#3540469L, orderProposalItemId#3540470, supplierGroup#3540471, supplier#3540472, plant#3540473, deliveryDateTime#3540474, subrange#3540475, supplyingPlant#3540476, productGroup#3540477, product#3540478, orderDateTime#3540479, availabilityDateTime#3540480, nextAvailabilityDateTime#3540481, mrpController#3540482, sourceOfSupplyUuid#3540483, purchasingOrg#3540484, purchasingGroup#3540485, isFallbackOrderOnly#3540486, orderProposalHorizonGroupingId#3540487L, splitIndicator#3540488L, previousOrderProposal#3540489L, clusterId#3540490L, sequenceId#3540491, worklistShardItemId#3540492L, orderProposalItemGroupId#3540493, ... 20 more fields]
(16) Project
Arguments: [shardId#3540515, worklistShardItemId#3540492L, orderProposalId#3540469L, orderProposalItemId#3540470, orderProposalItemGroupId#3540493, originalReplenishmentRunId#3540511L, orderProposalHorizonGroupingId#3540487L, splitIndicator#3540488L, previousOrderProposal#3540489L, clusterId#3540490L, sequenceId#3540491, sourceOfSupplyUuid#3540483, supplierGroup#3540471, supplier#3540472, subrange#3540475, product#3540478, plant#3540473, purchasingOrg#3540484, purchasingGroup#3540485, mrpController#3540482, orderDateTime#3540479, deliveryDateTime#3540474, availabilityDateTime#3540480, nextAvailabilityDateTime#3540481, isFallbackOrderOnly#3540486, ... 20 more fields]
(17) Project
Arguments: [shardId#3540515, worklistShardItemId#3540492L, orderProposalId#3540469L, orderProposalItemId#3540470, orderProposalItemGroupId#3540493, originalReplenishmentRunId#3540511L, orderProposalHorizonGroupingId#3540487L, splitIndicator#3540488L, previousOrderProposal#3540489L, clusterId#3540490L, cast(sequenceId#3540491 as bigint) AS sequenceId#3540516L, sourceOfSupplyUuid#3540483, supplierGroup#3540471, supplier#3540472, subrange#3540475, product#3540478, plant#3540473, purchasingOrg#3540484, purchasingGroup#3540485, mrpController#3540482, orderDateTime#3540479, deliveryDateTime#3540474, availabilityDateTime#3540480, nextAvailabilityDateTime#3540481, isFallbackOrderOnly#3540486, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3538856 = shardId#3540424) AND (worklistShardItemId#3540268L = worklistShardItemId#3540425L))
(20) Project
Arguments: [shardId#3538856, worklistShardItemId#3540268L, quantityAfterProdPlantOptimization#3540269, qty#3540270, orderProposalId#3540426L, orderProposalItemId#3540427, orderProposalItemGroupId#3540428, originalReplenishmentRunId#3540429L, orderProposalHorizonGroupingId#3540430L, splitIndicator#3540431L, previousOrderProposal#3540432L, clusterId#3540433L, sequenceId#3540434L, sourceOfSupplyUuid#3540435, supplierGroup#3540436, supplier#3540437, subrange#3540438, product#3540439, plant#3540440, purchasingOrg#3540441, purchasingGroup#3540442, mrpController#3540443, orderDateTime#3540444, deliveryDateTime#3540445, availabilityDateTime#3540446, ... 22 more fields]
(21) Project
Arguments: [shardId#3538856, worklistShardItemId#3540268L, quantityAfterProdPlantOptimization#3540269, qty#3540270, orderProposalId#3540426L, originalReplenishmentRunId#3540429L, supplierGroup#3540436, supplier#3540437, supplyingPlant#3540467, productGroup#3540468, product#3540439, plant#3540440, subrange#3540438, orderDateTime#3540444, deliveryDateTime#3540445, availabilityDateTime#3540446, nextAvailabilityDateTime#3540447, constraintValues#3540461, constraintOperators#3540459, constraintLabels#3540458, logisticUnits#3540463, orderQuantityBaseUom#3540449, orderQuantityBaseUomUuid#3540450, splitIndicator#3540431L, netPriceAmount#3540454, ... 14 more fields]
(22) Project
Arguments: [shardId#3538856, product#3540439, plant#3540440, orderDateTime#3540444, deliveryDateTime#3540445, availabilityDateTime#3540446, qty#3540270, orderProposalId#3540426L]
(23) Project
Arguments: [shardId#3538856, product#3540439, plant#3540440, orderDateTime#3540444, deliveryDateTime#3540445, availabilityDateTime#3540446, qty#3540270 AS orderQuantityInBaseUnit#3547885, orderProposalId#3540426L]
(24) Filter
Arguments: (shardId#3538856 = 0_2_10000000532)