== 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@8a2a23f, [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_3_10000000532], Append
(3) LogicalRDD
Arguments: [shardId#3580449, orderProposalId#3580450L, items#3580451, optimizationGroups#3580452, isOptimal#3580453, lastModified#3580454, optimizationInsights#3580455], false
(4) Filter
Arguments: shardId#3580449 IN (0_3_10000000532)
(5) Filter
Arguments: shardId#3580449 IN (0_3_10000000532)
(6) Project
Arguments: [shardId#3580449, orderProposalId#3580450L, items#3580451, optimizationGroups#3580452, isOptimal#3580453, optimizationInsights#3580455]
(7) Generate
Arguments: explode(items#3580451), false, [item#3581970]
(8) Project
Arguments: [shardId#3580449, item#3581970]
(9) Project
Arguments: [shardId#3580449, item#3581970.worklistShardItemId AS worklistShardItemId#3581971L, item#3581970.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3581972, item#3581970.qty AS qty#3581973]
(10) LocalRelation
Arguments: <empty>, [shardId#3582197, worklistShardItemId#3582198L, orderProposalId#3582199L, orderProposalItemId#3582200, orderProposalItemGroupId#3582201, originalReplenishmentRunId#3582202L, orderProposalHorizonGroupingId#3582203L, splitIndicator#3582204L, previousOrderProposal#3582205L, clusterId#3582206L, sequenceId#3582207L, sourceOfSupplyUuid#3582208, supplierGroup#3582209, supplier#3582210, subrange#3582211, product#3582212, plant#3582213, purchasingOrg#3582214, purchasingGroup#3582215, mrpController#3582216, orderDateTime#3582217, deliveryDateTime#3582218, availabilityDateTime#3582219, nextAvailabilityDateTime#3582220, isFallbackOrderOnly#3582221, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3582422L, orderProposalItemId#3582423, supplierGroup#3582424, supplier#3582425, plant#3582426, deliveryDateTime#3582427, subrange#3582428, supplyingPlant#3582429, productGroup#3582430, product#3582431, orderDateTime#3582432, availabilityDateTime#3582433, nextAvailabilityDateTime#3582434, mrpController#3582435, sourceOfSupplyUuid#3582436, purchasingOrg#3582437, purchasingGroup#3582438, isFallbackOrderOnly#3582439, orderProposalHorizonGroupingId#3582440L, splitIndicator#3582441L, previousOrderProposal#3582442L, clusterId#3582443L, sequenceId#3582444, worklistShardItemId#3582445L, orderProposalItemGroupId#3582446, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3582466 = 0_3_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3582445L], 30
(14) Filter
Arguments: (sequenceId#3582444 = 2)
(15) Project
Arguments: [orderProposalId#3582422L, orderProposalItemId#3582423, supplierGroup#3582424, supplier#3582425, plant#3582426, deliveryDateTime#3582427, subrange#3582428, supplyingPlant#3582429, productGroup#3582430, product#3582431, orderDateTime#3582432, availabilityDateTime#3582433, nextAvailabilityDateTime#3582434, mrpController#3582435, sourceOfSupplyUuid#3582436, purchasingOrg#3582437, purchasingGroup#3582438, isFallbackOrderOnly#3582439, orderProposalHorizonGroupingId#3582440L, splitIndicator#3582441L, previousOrderProposal#3582442L, clusterId#3582443L, sequenceId#3582444, worklistShardItemId#3582445L, orderProposalItemGroupId#3582446, ... 20 more fields]
(16) Project
Arguments: [shardId#3582468, worklistShardItemId#3582445L, orderProposalId#3582422L, orderProposalItemId#3582423, orderProposalItemGroupId#3582446, originalReplenishmentRunId#3582464L, orderProposalHorizonGroupingId#3582440L, splitIndicator#3582441L, previousOrderProposal#3582442L, clusterId#3582443L, sequenceId#3582444, sourceOfSupplyUuid#3582436, supplierGroup#3582424, supplier#3582425, subrange#3582428, product#3582431, plant#3582426, purchasingOrg#3582437, purchasingGroup#3582438, mrpController#3582435, orderDateTime#3582432, deliveryDateTime#3582427, availabilityDateTime#3582433, nextAvailabilityDateTime#3582434, isFallbackOrderOnly#3582439, ... 20 more fields]
(17) Project
Arguments: [shardId#3582468, worklistShardItemId#3582445L, orderProposalId#3582422L, orderProposalItemId#3582423, orderProposalItemGroupId#3582446, originalReplenishmentRunId#3582464L, orderProposalHorizonGroupingId#3582440L, splitIndicator#3582441L, previousOrderProposal#3582442L, clusterId#3582443L, cast(sequenceId#3582444 as bigint) AS sequenceId#3582469L, sourceOfSupplyUuid#3582436, supplierGroup#3582424, supplier#3582425, subrange#3582428, product#3582431, plant#3582426, purchasingOrg#3582437, purchasingGroup#3582438, mrpController#3582435, orderDateTime#3582432, deliveryDateTime#3582427, availabilityDateTime#3582433, nextAvailabilityDateTime#3582434, isFallbackOrderOnly#3582439, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3580449 = shardId#3582197) AND (worklistShardItemId#3581971L = worklistShardItemId#3582198L))
(20) Project
Arguments: [shardId#3580449, worklistShardItemId#3581971L, quantityAfterProdPlantOptimization#3581972, qty#3581973, orderProposalId#3582199L, orderProposalItemId#3582200, orderProposalItemGroupId#3582201, originalReplenishmentRunId#3582202L, orderProposalHorizonGroupingId#3582203L, splitIndicator#3582204L, previousOrderProposal#3582205L, clusterId#3582206L, sequenceId#3582207L, sourceOfSupplyUuid#3582208, supplierGroup#3582209, supplier#3582210, subrange#3582211, product#3582212, plant#3582213, purchasingOrg#3582214, purchasingGroup#3582215, mrpController#3582216, orderDateTime#3582217, deliveryDateTime#3582218, availabilityDateTime#3582219, ... 22 more fields]
(21) Project
Arguments: [shardId#3580449, worklistShardItemId#3581971L, quantityAfterProdPlantOptimization#3581972, qty#3581973, orderProposalId#3582199L, originalReplenishmentRunId#3582202L, supplierGroup#3582209, supplier#3582210, supplyingPlant#3582240, productGroup#3582241, product#3582212, plant#3582213, subrange#3582211, orderDateTime#3582217, deliveryDateTime#3582218, availabilityDateTime#3582219, nextAvailabilityDateTime#3582220, constraintValues#3582234, constraintOperators#3582232, constraintLabels#3582231, logisticUnits#3582236, orderQuantityBaseUom#3582222, orderQuantityBaseUomUuid#3582223, splitIndicator#3582204L, netPriceAmount#3582227, ... 14 more fields]
(22) Project
Arguments: [shardId#3580449, product#3582212, plant#3582213, orderDateTime#3582217, deliveryDateTime#3582218, availabilityDateTime#3582219, qty#3581973, orderProposalId#3582199L]
(23) Project
Arguments: [shardId#3580449, product#3582212, plant#3582213, orderDateTime#3582217, deliveryDateTime#3582218, availabilityDateTime#3582219, qty#3581973 AS orderQuantityInBaseUnit#3582704, orderProposalId#3582199L]
(24) Filter
Arguments: (shardId#3580449 = 0_3_10000000532)