== 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@443bcdde, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002107/stream-10000002107-1/shardId=0_1_10000002107], Append
(3) LogicalRDD
Arguments: [shardId#662288, orderProposalId#662289L, items#662290, optimizationGroups#662291, isOptimal#662292, lastModified#662293, optimizationInsights#662294], false
(4) Filter
Arguments: shardId#662288 IN (0_1_10000002107)
(5) Filter
Arguments: shardId#662288 IN (0_1_10000002107)
(6) Project
Arguments: [shardId#662288, orderProposalId#662289L, items#662290, optimizationGroups#662291, isOptimal#662292, optimizationInsights#662294]
(7) Generate
Arguments: explode(items#662290), false, [item#662858]
(8) Project
Arguments: [shardId#662288, item#662858]
(9) Project
Arguments: [shardId#662288, item#662858.worklistShardItemId AS worklistShardItemId#662859L, item#662858.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#662860, item#662858.qty AS qty#662861]
(10) LocalRelation
Arguments: <empty>, [shardId#663016, worklistShardItemId#663017L, orderProposalId#663018L, orderProposalItemId#663019, orderProposalItemGroupId#663020, originalReplenishmentRunId#663021L, orderProposalHorizonGroupingId#663022L, splitIndicator#663023L, previousOrderProposal#663024L, clusterId#663025L, sequenceId#663026L, sourceOfSupplyUuid#663027, supplierGroup#663028, supplier#663029, subrange#663030, product#663031, plant#663032, purchasingOrg#663033, purchasingGroup#663034, mrpController#663035, orderDateTime#663036, deliveryDateTime#663037, availabilityDateTime#663038, nextAvailabilityDateTime#663039, isFallbackOrderOnly#663040, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#663133L, orderProposalItemId#663134, supplierGroup#663135, supplier#663136, plant#663137, deliveryDateTime#663138, subrange#663139, supplyingPlant#663140, productGroup#663141, product#663142, orderDateTime#663143, availabilityDateTime#663144, nextAvailabilityDateTime#663145, mrpController#663146, sourceOfSupplyUuid#663147, purchasingOrg#663148, purchasingGroup#663149, isFallbackOrderOnly#663150, orderProposalHorizonGroupingId#663151L, splitIndicator#663152L, previousOrderProposal#663153L, clusterId#663154L, sequenceId#663155, worklistShardItemId#663156L, orderProposalItemGroupId#663157, ... 20 more fields], false
(12) Filter
Arguments: (shardId#663177 = 0_1_10000002107)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#663156L], 20
(14) Filter
Arguments: (sequenceId#663155 = 4)
(15) Project
Arguments: [orderProposalId#663133L, orderProposalItemId#663134, supplierGroup#663135, supplier#663136, plant#663137, deliveryDateTime#663138, subrange#663139, supplyingPlant#663140, productGroup#663141, product#663142, orderDateTime#663143, availabilityDateTime#663144, nextAvailabilityDateTime#663145, mrpController#663146, sourceOfSupplyUuid#663147, purchasingOrg#663148, purchasingGroup#663149, isFallbackOrderOnly#663150, orderProposalHorizonGroupingId#663151L, splitIndicator#663152L, previousOrderProposal#663153L, clusterId#663154L, sequenceId#663155, worklistShardItemId#663156L, orderProposalItemGroupId#663157, ... 20 more fields]
(16) Project
Arguments: [shardId#663179, worklistShardItemId#663156L, orderProposalId#663133L, orderProposalItemId#663134, orderProposalItemGroupId#663157, originalReplenishmentRunId#663175L, orderProposalHorizonGroupingId#663151L, splitIndicator#663152L, previousOrderProposal#663153L, clusterId#663154L, sequenceId#663155, sourceOfSupplyUuid#663147, supplierGroup#663135, supplier#663136, subrange#663139, product#663142, plant#663137, purchasingOrg#663148, purchasingGroup#663149, mrpController#663146, orderDateTime#663143, deliveryDateTime#663138, availabilityDateTime#663144, nextAvailabilityDateTime#663145, isFallbackOrderOnly#663150, ... 20 more fields]
(17) Project
Arguments: [shardId#663179, worklistShardItemId#663156L, orderProposalId#663133L, orderProposalItemId#663134, orderProposalItemGroupId#663157, originalReplenishmentRunId#663175L, orderProposalHorizonGroupingId#663151L, splitIndicator#663152L, previousOrderProposal#663153L, clusterId#663154L, cast(sequenceId#663155 as bigint) AS sequenceId#663180L, sourceOfSupplyUuid#663147, supplierGroup#663135, supplier#663136, subrange#663139, product#663142, plant#663137, purchasingOrg#663148, purchasingGroup#663149, mrpController#663146, orderDateTime#663143, deliveryDateTime#663138, availabilityDateTime#663144, nextAvailabilityDateTime#663145, isFallbackOrderOnly#663150, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#662288 = shardId#663016) AND (worklistShardItemId#662859L = worklistShardItemId#663017L))
(20) Project
Arguments: [shardId#662288, worklistShardItemId#662859L, quantityAfterProdPlantOptimization#662860, qty#662861, orderProposalId#663018L, orderProposalItemId#663019, orderProposalItemGroupId#663020, originalReplenishmentRunId#663021L, orderProposalHorizonGroupingId#663022L, splitIndicator#663023L, previousOrderProposal#663024L, clusterId#663025L, sequenceId#663026L, sourceOfSupplyUuid#663027, supplierGroup#663028, supplier#663029, subrange#663030, product#663031, plant#663032, purchasingOrg#663033, purchasingGroup#663034, mrpController#663035, orderDateTime#663036, deliveryDateTime#663037, availabilityDateTime#663038, ... 22 more fields]
(21) Project
Arguments: [shardId#662288, worklistShardItemId#662859L, quantityAfterProdPlantOptimization#662860, qty#662861, orderProposalId#663018L, originalReplenishmentRunId#663021L, supplierGroup#663028, supplier#663029, supplyingPlant#663059, productGroup#663060, product#663031, plant#663032, subrange#663030, orderDateTime#663036, deliveryDateTime#663037, availabilityDateTime#663038, nextAvailabilityDateTime#663039, constraintValues#663053, constraintOperators#663051, constraintLabels#663050, logisticUnits#663055, orderQuantityBaseUom#663041, orderQuantityBaseUomUuid#663042, splitIndicator#663023L, netPriceAmount#663046, ... 14 more fields]
(22) Project
Arguments: [shardId#662288, product#663031, plant#663032, orderDateTime#663036, deliveryDateTime#663037, availabilityDateTime#663038, qty#662861, orderProposalId#663018L]
(23) Project
Arguments: [shardId#662288, product#663031, plant#663032, orderDateTime#663036, deliveryDateTime#663037, availabilityDateTime#663038, qty#662861 AS orderQuantityInBaseUnit#663774, orderProposalId#663018L]
(24) Filter
Arguments: (shardId#662288 = 0_1_10000002107)