== 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@44a9fd97, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002109/stream-10000002109-1/shardId=0_1_10000002109], Append
(3) LogicalRDD
Arguments: [shardId#847553, orderProposalId#847554L, items#847555, optimizationGroups#847556, isOptimal#847557, lastModified#847558, optimizationInsights#847559], false
(4) Filter
Arguments: shardId#847553 IN (0_1_10000002109)
(5) Filter
Arguments: shardId#847553 IN (0_1_10000002109)
(6) Project
Arguments: [shardId#847553, orderProposalId#847554L, items#847555, optimizationGroups#847556, isOptimal#847557, optimizationInsights#847559]
(7) Generate
Arguments: explode(items#847555), false, [item#848064]
(8) Project
Arguments: [shardId#847553, item#848064]
(9) Project
Arguments: [shardId#847553, item#848064.worklistShardItemId AS worklistShardItemId#848065L, item#848064.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#848066, item#848064.qty AS qty#848067]
(10) LocalRelation
Arguments: <empty>, [shardId#848221, worklistShardItemId#848222L, orderProposalId#848223L, orderProposalItemId#848224, orderProposalItemGroupId#848225, originalReplenishmentRunId#848226L, orderProposalHorizonGroupingId#848227L, splitIndicator#848228L, previousOrderProposal#848229L, clusterId#848230L, sequenceId#848231L, sourceOfSupplyUuid#848232, supplierGroup#848233, supplier#848234, subrange#848235, product#848236, plant#848237, purchasingOrg#848238, purchasingGroup#848239, mrpController#848240, orderDateTime#848241, deliveryDateTime#848242, availabilityDateTime#848243, nextAvailabilityDateTime#848244, isFallbackOrderOnly#848245, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#848266L, orderProposalItemId#848267, supplierGroup#848268, supplier#848269, plant#848270, deliveryDateTime#848271, subrange#848272, supplyingPlant#848273, productGroup#848274, product#848275, orderDateTime#848276, availabilityDateTime#848277, nextAvailabilityDateTime#848278, mrpController#848279, sourceOfSupplyUuid#848280, purchasingOrg#848281, purchasingGroup#848282, isFallbackOrderOnly#848283, orderProposalHorizonGroupingId#848284L, splitIndicator#848285L, previousOrderProposal#848286L, clusterId#848287L, sequenceId#848288, worklistShardItemId#848289L, orderProposalItemGroupId#848290, ... 20 more fields], false
(12) Filter
Arguments: (shardId#848310 = 0_1_10000002109)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#848289L], 20
(14) Filter
Arguments: (sequenceId#848288 = 0)
(15) Project
Arguments: [orderProposalId#848266L, orderProposalItemId#848267, supplierGroup#848268, supplier#848269, plant#848270, deliveryDateTime#848271, subrange#848272, supplyingPlant#848273, productGroup#848274, product#848275, orderDateTime#848276, availabilityDateTime#848277, nextAvailabilityDateTime#848278, mrpController#848279, sourceOfSupplyUuid#848280, purchasingOrg#848281, purchasingGroup#848282, isFallbackOrderOnly#848283, orderProposalHorizonGroupingId#848284L, splitIndicator#848285L, previousOrderProposal#848286L, clusterId#848287L, sequenceId#848288, worklistShardItemId#848289L, orderProposalItemGroupId#848290, ... 20 more fields]
(16) Project
Arguments: [shardId#848312, worklistShardItemId#848289L, orderProposalId#848266L, orderProposalItemId#848267, orderProposalItemGroupId#848290, originalReplenishmentRunId#848308L, orderProposalHorizonGroupingId#848284L, splitIndicator#848285L, previousOrderProposal#848286L, clusterId#848287L, sequenceId#848288, sourceOfSupplyUuid#848280, supplierGroup#848268, supplier#848269, subrange#848272, product#848275, plant#848270, purchasingOrg#848281, purchasingGroup#848282, mrpController#848279, orderDateTime#848276, deliveryDateTime#848271, availabilityDateTime#848277, nextAvailabilityDateTime#848278, isFallbackOrderOnly#848283, ... 20 more fields]
(17) Project
Arguments: [shardId#848312, worklistShardItemId#848289L, orderProposalId#848266L, orderProposalItemId#848267, orderProposalItemGroupId#848290, originalReplenishmentRunId#848308L, orderProposalHorizonGroupingId#848284L, splitIndicator#848285L, previousOrderProposal#848286L, clusterId#848287L, cast(sequenceId#848288 as bigint) AS sequenceId#848313L, sourceOfSupplyUuid#848280, supplierGroup#848268, supplier#848269, subrange#848272, product#848275, plant#848270, purchasingOrg#848281, purchasingGroup#848282, mrpController#848279, orderDateTime#848276, deliveryDateTime#848271, availabilityDateTime#848277, nextAvailabilityDateTime#848278, isFallbackOrderOnly#848283, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#847553 = shardId#848221) AND (worklistShardItemId#848065L = worklistShardItemId#848222L))
(20) Project
Arguments: [shardId#847553, worklistShardItemId#848065L, quantityAfterProdPlantOptimization#848066, qty#848067, orderProposalId#848223L, orderProposalItemId#848224, orderProposalItemGroupId#848225, originalReplenishmentRunId#848226L, orderProposalHorizonGroupingId#848227L, splitIndicator#848228L, previousOrderProposal#848229L, clusterId#848230L, sequenceId#848231L, sourceOfSupplyUuid#848232, supplierGroup#848233, supplier#848234, subrange#848235, product#848236, plant#848237, purchasingOrg#848238, purchasingGroup#848239, mrpController#848240, orderDateTime#848241, deliveryDateTime#848242, availabilityDateTime#848243, ... 22 more fields]
(21) Project
Arguments: [shardId#847553, worklistShardItemId#848065L, quantityAfterProdPlantOptimization#848066, qty#848067, orderProposalId#848223L, originalReplenishmentRunId#848226L, supplierGroup#848233, supplier#848234, supplyingPlant#848264, productGroup#848265, product#848236, plant#848237, subrange#848235, orderDateTime#848241, deliveryDateTime#848242, availabilityDateTime#848243, nextAvailabilityDateTime#848244, constraintValues#848258, constraintOperators#848256, constraintLabels#848255, logisticUnits#848260, orderQuantityBaseUom#848246, orderQuantityBaseUomUuid#848247, splitIndicator#848228L, netPriceAmount#848251, ... 14 more fields]
(22) Project
Arguments: [shardId#847553, product#848236, plant#848237, orderDateTime#848241, deliveryDateTime#848242, availabilityDateTime#848243, qty#848067, orderProposalId#848223L]
(23) Project
Arguments: [shardId#847553, product#848236, plant#848237, orderDateTime#848241, deliveryDateTime#848242, availabilityDateTime#848243, qty#848067 AS orderQuantityInBaseUnit#848518, orderProposalId#848223L]
(24) Filter
Arguments: (shardId#847553 = 0_1_10000002109)