== 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@2211827b, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002108/stream-10000002108-1/shardId=0_1_10000002108], Append
(3) LogicalRDD
Arguments: [shardId#777607, orderProposalId#777608L, items#777609, optimizationGroups#777610, isOptimal#777611, lastModified#777612, optimizationInsights#777613], false
(4) Filter
Arguments: shardId#777607 IN (0_1_10000002108)
(5) Filter
Arguments: shardId#777607 IN (0_1_10000002108)
(6) Project
Arguments: [shardId#777607, orderProposalId#777608L, items#777609, optimizationGroups#777610, isOptimal#777611, optimizationInsights#777613]
(7) Generate
Arguments: explode(items#777609), false, [item#778118]
(8) Project
Arguments: [shardId#777607, item#778118]
(9) Project
Arguments: [shardId#777607, item#778118.worklistShardItemId AS worklistShardItemId#778119L, item#778118.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#778120, item#778118.qty AS qty#778121]
(10) LocalRelation
Arguments: <empty>, [shardId#778275, worklistShardItemId#778276L, orderProposalId#778277L, orderProposalItemId#778278, orderProposalItemGroupId#778279, originalReplenishmentRunId#778280L, orderProposalHorizonGroupingId#778281L, splitIndicator#778282L, previousOrderProposal#778283L, clusterId#778284L, sequenceId#778285L, sourceOfSupplyUuid#778286, supplierGroup#778287, supplier#778288, subrange#778289, product#778290, plant#778291, purchasingOrg#778292, purchasingGroup#778293, mrpController#778294, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, nextAvailabilityDateTime#778298, isFallbackOrderOnly#778299, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#778320L, orderProposalItemId#778321, supplierGroup#778322, supplier#778323, plant#778324, deliveryDateTime#778325, subrange#778326, supplyingPlant#778327, productGroup#778328, product#778329, orderDateTime#778330, availabilityDateTime#778331, nextAvailabilityDateTime#778332, mrpController#778333, sourceOfSupplyUuid#778334, purchasingOrg#778335, purchasingGroup#778336, isFallbackOrderOnly#778337, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, sequenceId#778342, worklistShardItemId#778343L, orderProposalItemGroupId#778344, ... 20 more fields], false
(12) Filter
Arguments: (shardId#778364 = 0_1_10000002108)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#778343L], 20
(14) Filter
Arguments: (sequenceId#778342 = 1)
(15) Project
Arguments: [orderProposalId#778320L, orderProposalItemId#778321, supplierGroup#778322, supplier#778323, plant#778324, deliveryDateTime#778325, subrange#778326, supplyingPlant#778327, productGroup#778328, product#778329, orderDateTime#778330, availabilityDateTime#778331, nextAvailabilityDateTime#778332, mrpController#778333, sourceOfSupplyUuid#778334, purchasingOrg#778335, purchasingGroup#778336, isFallbackOrderOnly#778337, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, sequenceId#778342, worklistShardItemId#778343L, orderProposalItemGroupId#778344, ... 20 more fields]
(16) Project
Arguments: [shardId#778366, worklistShardItemId#778343L, orderProposalId#778320L, orderProposalItemId#778321, orderProposalItemGroupId#778344, originalReplenishmentRunId#778362L, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, sequenceId#778342, sourceOfSupplyUuid#778334, supplierGroup#778322, supplier#778323, subrange#778326, product#778329, plant#778324, purchasingOrg#778335, purchasingGroup#778336, mrpController#778333, orderDateTime#778330, deliveryDateTime#778325, availabilityDateTime#778331, nextAvailabilityDateTime#778332, isFallbackOrderOnly#778337, ... 20 more fields]
(17) Project
Arguments: [shardId#778366, worklistShardItemId#778343L, orderProposalId#778320L, orderProposalItemId#778321, orderProposalItemGroupId#778344, originalReplenishmentRunId#778362L, orderProposalHorizonGroupingId#778338L, splitIndicator#778339L, previousOrderProposal#778340L, clusterId#778341L, cast(sequenceId#778342 as bigint) AS sequenceId#778367L, sourceOfSupplyUuid#778334, supplierGroup#778322, supplier#778323, subrange#778326, product#778329, plant#778324, purchasingOrg#778335, purchasingGroup#778336, mrpController#778333, orderDateTime#778330, deliveryDateTime#778325, availabilityDateTime#778331, nextAvailabilityDateTime#778332, isFallbackOrderOnly#778337, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#777607 = shardId#778275) AND (worklistShardItemId#778119L = worklistShardItemId#778276L))
(20) Project
Arguments: [shardId#777607, worklistShardItemId#778119L, quantityAfterProdPlantOptimization#778120, qty#778121, orderProposalId#778277L, orderProposalItemId#778278, orderProposalItemGroupId#778279, originalReplenishmentRunId#778280L, orderProposalHorizonGroupingId#778281L, splitIndicator#778282L, previousOrderProposal#778283L, clusterId#778284L, sequenceId#778285L, sourceOfSupplyUuid#778286, supplierGroup#778287, supplier#778288, subrange#778289, product#778290, plant#778291, purchasingOrg#778292, purchasingGroup#778293, mrpController#778294, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, ... 22 more fields]
(21) Project
Arguments: [shardId#777607, worklistShardItemId#778119L, quantityAfterProdPlantOptimization#778120, qty#778121, orderProposalId#778277L, originalReplenishmentRunId#778280L, supplierGroup#778287, supplier#778288, supplyingPlant#778318, productGroup#778319, product#778290, plant#778291, subrange#778289, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, nextAvailabilityDateTime#778298, constraintValues#778312, constraintOperators#778310, constraintLabels#778309, logisticUnits#778314, orderQuantityBaseUom#778300, orderQuantityBaseUomUuid#778301, splitIndicator#778282L, netPriceAmount#778305, ... 14 more fields]
(22) Project
Arguments: [shardId#777607, product#778290, plant#778291, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, qty#778121, orderProposalId#778277L]
(23) Project
Arguments: [shardId#777607, product#778290, plant#778291, orderDateTime#778295, deliveryDateTime#778296, availabilityDateTime#778297, qty#778121 AS orderQuantityInBaseUnit#778572, orderProposalId#778277L]
(24) Filter
Arguments: (shardId#777607 = 0_1_10000002108)