== 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@7a964b12, [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#3483106, orderProposalId#3483107L, items#3483108, optimizationGroups#3483109, isOptimal#3483110, lastModified#3483111, optimizationInsights#3483112], false
(4) Filter
Arguments: shardId#3483106 IN (0_5_10000000532)
(5) Filter
Arguments: shardId#3483106 IN (0_5_10000000532)
(6) Project
Arguments: [shardId#3483106, orderProposalId#3483107L, items#3483108, optimizationGroups#3483109, isOptimal#3483110, optimizationInsights#3483112]
(7) Generate
Arguments: explode(items#3483108), false, [item#3483617]
(8) Project
Arguments: [shardId#3483106, item#3483617]
(9) Project
Arguments: [shardId#3483106, item#3483617.worklistShardItemId AS worklistShardItemId#3483618L, item#3483617.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#3483619, item#3483617.qty AS qty#3483620]
(10) LocalRelation
Arguments: <empty>, [shardId#3483774, worklistShardItemId#3483775L, orderProposalId#3483776L, orderProposalItemId#3483777, orderProposalItemGroupId#3483778, originalReplenishmentRunId#3483779L, orderProposalHorizonGroupingId#3483780L, splitIndicator#3483781L, previousOrderProposal#3483782L, clusterId#3483783L, sequenceId#3483784L, sourceOfSupplyUuid#3483785, supplierGroup#3483786, supplier#3483787, subrange#3483788, product#3483789, plant#3483790, purchasingOrg#3483791, purchasingGroup#3483792, mrpController#3483793, orderDateTime#3483794, deliveryDateTime#3483795, availabilityDateTime#3483796, nextAvailabilityDateTime#3483797, isFallbackOrderOnly#3483798, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#3483819L, orderProposalItemId#3483820, supplierGroup#3483821, supplier#3483822, plant#3483823, deliveryDateTime#3483824, subrange#3483825, supplyingPlant#3483826, productGroup#3483827, product#3483828, orderDateTime#3483829, availabilityDateTime#3483830, nextAvailabilityDateTime#3483831, mrpController#3483832, sourceOfSupplyUuid#3483833, purchasingOrg#3483834, purchasingGroup#3483835, isFallbackOrderOnly#3483836, orderProposalHorizonGroupingId#3483837L, splitIndicator#3483838L, previousOrderProposal#3483839L, clusterId#3483840L, sequenceId#3483841, worklistShardItemId#3483842L, orderProposalItemGroupId#3483843, ... 20 more fields], false
(12) Filter
Arguments: (shardId#3483863 = 0_5_10000000532)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#3483842L], 30
(14) Filter
Arguments: (sequenceId#3483841 = 5)
(15) Project
Arguments: [orderProposalId#3483819L, orderProposalItemId#3483820, supplierGroup#3483821, supplier#3483822, plant#3483823, deliveryDateTime#3483824, subrange#3483825, supplyingPlant#3483826, productGroup#3483827, product#3483828, orderDateTime#3483829, availabilityDateTime#3483830, nextAvailabilityDateTime#3483831, mrpController#3483832, sourceOfSupplyUuid#3483833, purchasingOrg#3483834, purchasingGroup#3483835, isFallbackOrderOnly#3483836, orderProposalHorizonGroupingId#3483837L, splitIndicator#3483838L, previousOrderProposal#3483839L, clusterId#3483840L, sequenceId#3483841, worklistShardItemId#3483842L, orderProposalItemGroupId#3483843, ... 20 more fields]
(16) Project
Arguments: [shardId#3483865, worklistShardItemId#3483842L, orderProposalId#3483819L, orderProposalItemId#3483820, orderProposalItemGroupId#3483843, originalReplenishmentRunId#3483861L, orderProposalHorizonGroupingId#3483837L, splitIndicator#3483838L, previousOrderProposal#3483839L, clusterId#3483840L, sequenceId#3483841, sourceOfSupplyUuid#3483833, supplierGroup#3483821, supplier#3483822, subrange#3483825, product#3483828, plant#3483823, purchasingOrg#3483834, purchasingGroup#3483835, mrpController#3483832, orderDateTime#3483829, deliveryDateTime#3483824, availabilityDateTime#3483830, nextAvailabilityDateTime#3483831, isFallbackOrderOnly#3483836, ... 20 more fields]
(17) Project
Arguments: [shardId#3483865, worklistShardItemId#3483842L, orderProposalId#3483819L, orderProposalItemId#3483820, orderProposalItemGroupId#3483843, originalReplenishmentRunId#3483861L, orderProposalHorizonGroupingId#3483837L, splitIndicator#3483838L, previousOrderProposal#3483839L, clusterId#3483840L, cast(sequenceId#3483841 as bigint) AS sequenceId#3483866L, sourceOfSupplyUuid#3483833, supplierGroup#3483821, supplier#3483822, subrange#3483825, product#3483828, plant#3483823, purchasingOrg#3483834, purchasingGroup#3483835, mrpController#3483832, orderDateTime#3483829, deliveryDateTime#3483824, availabilityDateTime#3483830, nextAvailabilityDateTime#3483831, isFallbackOrderOnly#3483836, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#3483106 = shardId#3483774) AND (worklistShardItemId#3483618L = worklistShardItemId#3483775L))
(20) Project
Arguments: [shardId#3483106, worklistShardItemId#3483618L, quantityAfterProdPlantOptimization#3483619, qty#3483620, orderProposalId#3483776L, orderProposalItemId#3483777, orderProposalItemGroupId#3483778, originalReplenishmentRunId#3483779L, orderProposalHorizonGroupingId#3483780L, splitIndicator#3483781L, previousOrderProposal#3483782L, clusterId#3483783L, sequenceId#3483784L, sourceOfSupplyUuid#3483785, supplierGroup#3483786, supplier#3483787, subrange#3483788, product#3483789, plant#3483790, purchasingOrg#3483791, purchasingGroup#3483792, mrpController#3483793, orderDateTime#3483794, deliveryDateTime#3483795, availabilityDateTime#3483796, ... 22 more fields]
(21) Project
Arguments: [shardId#3483106, worklistShardItemId#3483618L, quantityAfterProdPlantOptimization#3483619, qty#3483620, orderProposalId#3483776L, originalReplenishmentRunId#3483779L, supplierGroup#3483786, supplier#3483787, supplyingPlant#3483817, productGroup#3483818, product#3483789, plant#3483790, subrange#3483788, orderDateTime#3483794, deliveryDateTime#3483795, availabilityDateTime#3483796, nextAvailabilityDateTime#3483797, constraintValues#3483811, constraintOperators#3483809, constraintLabels#3483808, logisticUnits#3483813, orderQuantityBaseUom#3483799, orderQuantityBaseUomUuid#3483800, splitIndicator#3483781L, netPriceAmount#3483804, ... 14 more fields]
(22) Project
Arguments: [shardId#3483106, product#3483789, plant#3483790, orderDateTime#3483794, deliveryDateTime#3483795, availabilityDateTime#3483796, qty#3483620, orderProposalId#3483776L]
(23) Project
Arguments: [shardId#3483106, product#3483789, plant#3483790, orderDateTime#3483794, deliveryDateTime#3483795, availabilityDateTime#3483796, qty#3483620 AS orderQuantityInBaseUnit#3484101, orderProposalId#3483776L]
(24) Filter
Arguments: (shardId#3483106 = 0_5_10000000532)