== 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@4920158b, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002110/stream-10000002110-1/shardId=0_1_10000002110], Append
(3) LogicalRDD
Arguments: [shardId#935024, orderProposalId#935025L, items#935026, optimizationGroups#935027, isOptimal#935028, lastModified#935029, optimizationInsights#935030], false
(4) Filter
Arguments: shardId#935024 IN (0_1_10000002110)
(5) Filter
Arguments: shardId#935024 IN (0_1_10000002110)
(6) Project
Arguments: [shardId#935024, orderProposalId#935025L, items#935026, optimizationGroups#935027, isOptimal#935028, optimizationInsights#935030]
(7) Generate
Arguments: explode(items#935026), false, [item#935535]
(8) Project
Arguments: [shardId#935024, item#935535]
(9) Project
Arguments: [shardId#935024, item#935535.worklistShardItemId AS worklistShardItemId#935536L, item#935535.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#935537, item#935535.qty AS qty#935538]
(10) LocalRelation
Arguments: <empty>, [shardId#935692, worklistShardItemId#935693L, orderProposalId#935694L, orderProposalItemId#935695, orderProposalItemGroupId#935696, originalReplenishmentRunId#935697L, orderProposalHorizonGroupingId#935698L, splitIndicator#935699L, previousOrderProposal#935700L, clusterId#935701L, sequenceId#935702L, sourceOfSupplyUuid#935703, supplierGroup#935704, supplier#935705, subrange#935706, product#935707, plant#935708, purchasingOrg#935709, purchasingGroup#935710, mrpController#935711, orderDateTime#935712, deliveryDateTime#935713, availabilityDateTime#935714, nextAvailabilityDateTime#935715, isFallbackOrderOnly#935716, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#935737L, orderProposalItemId#935738, supplierGroup#935739, supplier#935740, plant#935741, deliveryDateTime#935742, subrange#935743, supplyingPlant#935744, productGroup#935745, product#935746, orderDateTime#935747, availabilityDateTime#935748, nextAvailabilityDateTime#935749, mrpController#935750, sourceOfSupplyUuid#935751, purchasingOrg#935752, purchasingGroup#935753, isFallbackOrderOnly#935754, orderProposalHorizonGroupingId#935755L, splitIndicator#935756L, previousOrderProposal#935757L, clusterId#935758L, sequenceId#935759, worklistShardItemId#935760L, orderProposalItemGroupId#935761, ... 20 more fields], false
(12) Filter
Arguments: (shardId#935781 = 0_1_10000002110)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#935760L], 20
(14) Filter
Arguments: (sequenceId#935759 = 0)
(15) Project
Arguments: [orderProposalId#935737L, orderProposalItemId#935738, supplierGroup#935739, supplier#935740, plant#935741, deliveryDateTime#935742, subrange#935743, supplyingPlant#935744, productGroup#935745, product#935746, orderDateTime#935747, availabilityDateTime#935748, nextAvailabilityDateTime#935749, mrpController#935750, sourceOfSupplyUuid#935751, purchasingOrg#935752, purchasingGroup#935753, isFallbackOrderOnly#935754, orderProposalHorizonGroupingId#935755L, splitIndicator#935756L, previousOrderProposal#935757L, clusterId#935758L, sequenceId#935759, worklistShardItemId#935760L, orderProposalItemGroupId#935761, ... 20 more fields]
(16) Project
Arguments: [shardId#935783, worklistShardItemId#935760L, orderProposalId#935737L, orderProposalItemId#935738, orderProposalItemGroupId#935761, originalReplenishmentRunId#935779L, orderProposalHorizonGroupingId#935755L, splitIndicator#935756L, previousOrderProposal#935757L, clusterId#935758L, sequenceId#935759, sourceOfSupplyUuid#935751, supplierGroup#935739, supplier#935740, subrange#935743, product#935746, plant#935741, purchasingOrg#935752, purchasingGroup#935753, mrpController#935750, orderDateTime#935747, deliveryDateTime#935742, availabilityDateTime#935748, nextAvailabilityDateTime#935749, isFallbackOrderOnly#935754, ... 20 more fields]
(17) Project
Arguments: [shardId#935783, worklistShardItemId#935760L, orderProposalId#935737L, orderProposalItemId#935738, orderProposalItemGroupId#935761, originalReplenishmentRunId#935779L, orderProposalHorizonGroupingId#935755L, splitIndicator#935756L, previousOrderProposal#935757L, clusterId#935758L, cast(sequenceId#935759 as bigint) AS sequenceId#935784L, sourceOfSupplyUuid#935751, supplierGroup#935739, supplier#935740, subrange#935743, product#935746, plant#935741, purchasingOrg#935752, purchasingGroup#935753, mrpController#935750, orderDateTime#935747, deliveryDateTime#935742, availabilityDateTime#935748, nextAvailabilityDateTime#935749, isFallbackOrderOnly#935754, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#935024 = shardId#935692) AND (worklistShardItemId#935536L = worklistShardItemId#935693L))
(20) Project
Arguments: [shardId#935024, worklistShardItemId#935536L, quantityAfterProdPlantOptimization#935537, qty#935538, orderProposalId#935694L, orderProposalItemId#935695, orderProposalItemGroupId#935696, originalReplenishmentRunId#935697L, orderProposalHorizonGroupingId#935698L, splitIndicator#935699L, previousOrderProposal#935700L, clusterId#935701L, sequenceId#935702L, sourceOfSupplyUuid#935703, supplierGroup#935704, supplier#935705, subrange#935706, product#935707, plant#935708, purchasingOrg#935709, purchasingGroup#935710, mrpController#935711, orderDateTime#935712, deliveryDateTime#935713, availabilityDateTime#935714, ... 22 more fields]
(21) Project
Arguments: [shardId#935024, worklistShardItemId#935536L, quantityAfterProdPlantOptimization#935537, qty#935538, orderProposalId#935694L, originalReplenishmentRunId#935697L, supplierGroup#935704, supplier#935705, supplyingPlant#935735, productGroup#935736, product#935707, plant#935708, subrange#935706, orderDateTime#935712, deliveryDateTime#935713, availabilityDateTime#935714, nextAvailabilityDateTime#935715, constraintValues#935729, constraintOperators#935727, constraintLabels#935726, logisticUnits#935731, orderQuantityBaseUom#935717, orderQuantityBaseUomUuid#935718, splitIndicator#935699L, netPriceAmount#935722, ... 14 more fields]
(22) Project
Arguments: [shardId#935024, product#935707, plant#935708, orderDateTime#935712, deliveryDateTime#935713, availabilityDateTime#935714, qty#935538, orderProposalId#935694L]
(23) Project
Arguments: [shardId#935024, product#935707, plant#935708, orderDateTime#935712, deliveryDateTime#935713, availabilityDateTime#935714, qty#935538 AS orderQuantityInBaseUnit#935989, orderProposalId#935694L]
(24) Filter
Arguments: (shardId#935024 = 0_1_10000002110)