== 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@ac3407, [path=hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001445/stream-10000001445-1/shardId=0_1_10000001445], Append
(3) LogicalRDD
Arguments: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, lastModified#5499005, optimizationInsights#5499006], false
(4) Filter
Arguments: shardId#5499000 IN (0_1_10000001445)
(5) Filter
Arguments: shardId#5499000 IN (0_1_10000001445)
(6) Project
Arguments: [shardId#5499000, orderProposalId#5499001L, items#5499002, optimizationGroups#5499003, isOptimal#5499004, optimizationInsights#5499006]
(7) Generate
Arguments: explode(items#5499002), false, [item#5499511]
(8) Project
Arguments: [shardId#5499000, item#5499511]
(9) Project
Arguments: [shardId#5499000, item#5499511.worklistShardItemId AS worklistShardItemId#5499512L, item#5499511.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5499513, item#5499511.qty AS qty#5499514]
(10) LocalRelation
Arguments: <empty>, [shardId#5499668, worklistShardItemId#5499669L, orderProposalId#5499670L, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, originalReplenishmentRunId#5499673L, orderProposalHorizonGroupingId#5499674L, splitIndicator#5499675L, previousOrderProposal#5499676L, clusterId#5499677L, sequenceId#5499678L, sourceOfSupplyUuid#5499679, supplierGroup#5499680, supplier#5499681, subrange#5499682, product#5499683, plant#5499684, purchasingOrg#5499685, purchasingGroup#5499686, mrpController#5499687, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, isFallbackOrderOnly#5499692, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, mrpController#5499726, sourceOfSupplyUuid#5499727, purchasingOrg#5499728, purchasingGroup#5499729, isFallbackOrderOnly#5499730, orderProposalHorizonGroupingId#5499731L, splitIndicator#5499732L, previousOrderProposal#5499733L, clusterId#5499734L, sequenceId#5499735, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, ... 20 more fields], false
(12) Filter
Arguments: (shardId#5499757 = 0_1_10000001445)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#5499736L], 30
(14) Filter
Arguments: (sequenceId#5499735 = 6)
(15) Project
Arguments: [orderProposalId#5499713L, orderProposalItemId#5499714, supplierGroup#5499715, supplier#5499716, plant#5499717, deliveryDateTime#5499718, subrange#5499719, supplyingPlant#5499720, productGroup#5499721, product#5499722, orderDateTime#5499723, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, mrpController#5499726, sourceOfSupplyUuid#5499727, purchasingOrg#5499728, purchasingGroup#5499729, isFallbackOrderOnly#5499730, orderProposalHorizonGroupingId#5499731L, splitIndicator#5499732L, previousOrderProposal#5499733L, clusterId#5499734L, sequenceId#5499735, worklistShardItemId#5499736L, orderProposalItemGroupId#5499737, ... 20 more fields]
(16) Project
Arguments: [shardId#5499759, worklistShardItemId#5499736L, orderProposalId#5499713L, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, originalReplenishmentRunId#5499755L, orderProposalHorizonGroupingId#5499731L, splitIndicator#5499732L, previousOrderProposal#5499733L, clusterId#5499734L, sequenceId#5499735, sourceOfSupplyUuid#5499727, supplierGroup#5499715, supplier#5499716, subrange#5499719, product#5499722, plant#5499717, purchasingOrg#5499728, purchasingGroup#5499729, mrpController#5499726, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, isFallbackOrderOnly#5499730, ... 20 more fields]
(17) Project
Arguments: [shardId#5499759, worklistShardItemId#5499736L, orderProposalId#5499713L, orderProposalItemId#5499714, orderProposalItemGroupId#5499737, originalReplenishmentRunId#5499755L, orderProposalHorizonGroupingId#5499731L, splitIndicator#5499732L, previousOrderProposal#5499733L, clusterId#5499734L, cast(sequenceId#5499735 as bigint) AS sequenceId#5499760L, sourceOfSupplyUuid#5499727, supplierGroup#5499715, supplier#5499716, subrange#5499719, product#5499722, plant#5499717, purchasingOrg#5499728, purchasingGroup#5499729, mrpController#5499726, orderDateTime#5499723, deliveryDateTime#5499718, availabilityDateTime#5499724, nextAvailabilityDateTime#5499725, isFallbackOrderOnly#5499730, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#5499000 = shardId#5499668) AND (worklistShardItemId#5499512L = worklistShardItemId#5499669L))
(20) Project
Arguments: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499670L, orderProposalItemId#5499671, orderProposalItemGroupId#5499672, originalReplenishmentRunId#5499673L, orderProposalHorizonGroupingId#5499674L, splitIndicator#5499675L, previousOrderProposal#5499676L, clusterId#5499677L, sequenceId#5499678L, sourceOfSupplyUuid#5499679, supplierGroup#5499680, supplier#5499681, subrange#5499682, product#5499683, plant#5499684, purchasingOrg#5499685, purchasingGroup#5499686, mrpController#5499687, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, ... 22 more fields]
(21) Project
Arguments: [shardId#5499000, worklistShardItemId#5499512L, quantityAfterProdPlantOptimization#5499513, qty#5499514, orderProposalId#5499670L, originalReplenishmentRunId#5499673L, supplierGroup#5499680, supplier#5499681, supplyingPlant#5499711, productGroup#5499712, product#5499683, plant#5499684, subrange#5499682, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, nextAvailabilityDateTime#5499691, constraintValues#5499705, constraintOperators#5499703, constraintLabels#5499702, logisticUnits#5499707, orderQuantityBaseUom#5499693, orderQuantityBaseUomUuid#5499694, splitIndicator#5499675L, netPriceAmount#5499698, ... 14 more fields]
(22) Project
Arguments: [shardId#5499000, product#5499683, plant#5499684, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, qty#5499514, orderProposalId#5499670L]
(23) Project
Arguments: [shardId#5499000, product#5499683, plant#5499684, orderDateTime#5499688, deliveryDateTime#5499689, availabilityDateTime#5499690, qty#5499514 AS orderQuantityInBaseUnit#5499965, orderProposalId#5499670L]
(24) Filter
Arguments: (shardId#5499000 = 0_1_10000001445)