== 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@3bf1e9a8, [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#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, lastModified#589615, optimizationInsights#589616], false
(4) Filter
Arguments: shardId#589610 IN (0_1_10000002107)
(5) Filter
Arguments: shardId#589610 IN (0_1_10000002107)
(6) Project
Arguments: [shardId#589610, orderProposalId#589611L, items#589612, optimizationGroups#589613, isOptimal#589614, optimizationInsights#589616]
(7) Generate
Arguments: explode(items#589612), false, [item#590121]
(8) Project
Arguments: [shardId#589610, item#590121]
(9) Project
Arguments: [shardId#589610, item#590121.worklistShardItemId AS worklistShardItemId#590122L, item#590121.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#590123, item#590121.qty AS qty#590124]
(10) LocalRelation
Arguments: <empty>, [shardId#590278, worklistShardItemId#590279L, orderProposalId#590280L, orderProposalItemId#590281, orderProposalItemGroupId#590282, originalReplenishmentRunId#590283L, orderProposalHorizonGroupingId#590284L, splitIndicator#590285L, previousOrderProposal#590286L, clusterId#590287L, sequenceId#590288L, sourceOfSupplyUuid#590289, supplierGroup#590290, supplier#590291, subrange#590292, product#590293, plant#590294, purchasingOrg#590295, purchasingGroup#590296, mrpController#590297, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, isFallbackOrderOnly#590302, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, mrpController#590336, sourceOfSupplyUuid#590337, purchasingOrg#590338, purchasingGroup#590339, isFallbackOrderOnly#590340, orderProposalHorizonGroupingId#590341L, splitIndicator#590342L, previousOrderProposal#590343L, clusterId#590344L, sequenceId#590345, worklistShardItemId#590346L, orderProposalItemGroupId#590347, ... 20 more fields], false
(12) Filter
Arguments: (shardId#590367 = 0_1_10000002107)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#590346L], 20
(14) Filter
Arguments: (sequenceId#590345 = 2)
(15) Project
Arguments: [orderProposalId#590323L, orderProposalItemId#590324, supplierGroup#590325, supplier#590326, plant#590327, deliveryDateTime#590328, subrange#590329, supplyingPlant#590330, productGroup#590331, product#590332, orderDateTime#590333, availabilityDateTime#590334, nextAvailabilityDateTime#590335, mrpController#590336, sourceOfSupplyUuid#590337, purchasingOrg#590338, purchasingGroup#590339, isFallbackOrderOnly#590340, orderProposalHorizonGroupingId#590341L, splitIndicator#590342L, previousOrderProposal#590343L, clusterId#590344L, sequenceId#590345, worklistShardItemId#590346L, orderProposalItemGroupId#590347, ... 20 more fields]
(16) Project
Arguments: [shardId#590369, worklistShardItemId#590346L, orderProposalId#590323L, orderProposalItemId#590324, orderProposalItemGroupId#590347, originalReplenishmentRunId#590365L, orderProposalHorizonGroupingId#590341L, splitIndicator#590342L, previousOrderProposal#590343L, clusterId#590344L, sequenceId#590345, sourceOfSupplyUuid#590337, supplierGroup#590325, supplier#590326, subrange#590329, product#590332, plant#590327, purchasingOrg#590338, purchasingGroup#590339, mrpController#590336, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, isFallbackOrderOnly#590340, ... 20 more fields]
(17) Project
Arguments: [shardId#590369, worklistShardItemId#590346L, orderProposalId#590323L, orderProposalItemId#590324, orderProposalItemGroupId#590347, originalReplenishmentRunId#590365L, orderProposalHorizonGroupingId#590341L, splitIndicator#590342L, previousOrderProposal#590343L, clusterId#590344L, cast(sequenceId#590345 as bigint) AS sequenceId#590370L, sourceOfSupplyUuid#590337, supplierGroup#590325, supplier#590326, subrange#590329, product#590332, plant#590327, purchasingOrg#590338, purchasingGroup#590339, mrpController#590336, orderDateTime#590333, deliveryDateTime#590328, availabilityDateTime#590334, nextAvailabilityDateTime#590335, isFallbackOrderOnly#590340, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#589610 = shardId#590278) AND (worklistShardItemId#590122L = worklistShardItemId#590279L))
(20) Project
Arguments: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590280L, orderProposalItemId#590281, orderProposalItemGroupId#590282, originalReplenishmentRunId#590283L, orderProposalHorizonGroupingId#590284L, splitIndicator#590285L, previousOrderProposal#590286L, clusterId#590287L, sequenceId#590288L, sourceOfSupplyUuid#590289, supplierGroup#590290, supplier#590291, subrange#590292, product#590293, plant#590294, purchasingOrg#590295, purchasingGroup#590296, mrpController#590297, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, ... 22 more fields]
(21) Project
Arguments: [shardId#589610, worklistShardItemId#590122L, quantityAfterProdPlantOptimization#590123, qty#590124, orderProposalId#590280L, originalReplenishmentRunId#590283L, supplierGroup#590290, supplier#590291, supplyingPlant#590321, productGroup#590322, product#590293, plant#590294, subrange#590292, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, nextAvailabilityDateTime#590301, constraintValues#590315, constraintOperators#590313, constraintLabels#590312, logisticUnits#590317, orderQuantityBaseUom#590303, orderQuantityBaseUomUuid#590304, splitIndicator#590285L, netPriceAmount#590308, ... 14 more fields]
(22) Project
Arguments: [shardId#589610, product#590293, plant#590294, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, qty#590124, orderProposalId#590280L]
(23) Project
Arguments: [shardId#589610, product#590293, plant#590294, orderDateTime#590298, deliveryDateTime#590299, availabilityDateTime#590300, qty#590124 AS orderQuantityInBaseUnit#593286, orderProposalId#590280L]
(24) Filter
Arguments: (shardId#589610 = 0_1_10000002107)