== 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@28312716, [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#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, lastModified#5543993, optimizationInsights#5543994], false
(4) Filter
Arguments: shardId#5543988 IN (0_1_10000001445)
(5) Filter
Arguments: shardId#5543988 IN (0_1_10000001445)
(6) Project
Arguments: [shardId#5543988, orderProposalId#5543989L, items#5543990, optimizationGroups#5543991, isOptimal#5543992, optimizationInsights#5543994]
(7) Generate
Arguments: explode(items#5543990), false, [item#5544499]
(8) Project
Arguments: [shardId#5543988, item#5544499]
(9) Project
Arguments: [shardId#5543988, item#5544499.worklistShardItemId AS worklistShardItemId#5544500L, item#5544499.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#5544501, item#5544499.qty AS qty#5544502]
(10) LocalRelation
Arguments: <empty>, [shardId#5544656, worklistShardItemId#5544657L, orderProposalId#5544658L, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, originalReplenishmentRunId#5544661L, orderProposalHorizonGroupingId#5544662L, splitIndicator#5544663L, previousOrderProposal#5544664L, clusterId#5544665L, sequenceId#5544666L, sourceOfSupplyUuid#5544667, supplierGroup#5544668, supplier#5544669, subrange#5544670, product#5544671, plant#5544672, purchasingOrg#5544673, purchasingGroup#5544674, mrpController#5544675, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, nextAvailabilityDateTime#5544679, isFallbackOrderOnly#5544680, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, mrpController#5544714, sourceOfSupplyUuid#5544715, purchasingOrg#5544716, purchasingGroup#5544717, isFallbackOrderOnly#5544718, orderProposalHorizonGroupingId#5544719L, splitIndicator#5544720L, previousOrderProposal#5544721L, clusterId#5544722L, sequenceId#5544723, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, ... 20 more fields], false
(12) Filter
Arguments: (shardId#5544745 = 0_1_10000001445)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#5544724L], 30
(14) Filter
Arguments: (sequenceId#5544723 = 7)
(15) Project
Arguments: [orderProposalId#5544701L, orderProposalItemId#5544702, supplierGroup#5544703, supplier#5544704, plant#5544705, deliveryDateTime#5544706, subrange#5544707, supplyingPlant#5544708, productGroup#5544709, product#5544710, orderDateTime#5544711, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, mrpController#5544714, sourceOfSupplyUuid#5544715, purchasingOrg#5544716, purchasingGroup#5544717, isFallbackOrderOnly#5544718, orderProposalHorizonGroupingId#5544719L, splitIndicator#5544720L, previousOrderProposal#5544721L, clusterId#5544722L, sequenceId#5544723, worklistShardItemId#5544724L, orderProposalItemGroupId#5544725, ... 20 more fields]
(16) Project
Arguments: [shardId#5544747, worklistShardItemId#5544724L, orderProposalId#5544701L, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, originalReplenishmentRunId#5544743L, orderProposalHorizonGroupingId#5544719L, splitIndicator#5544720L, previousOrderProposal#5544721L, clusterId#5544722L, sequenceId#5544723, sourceOfSupplyUuid#5544715, supplierGroup#5544703, supplier#5544704, subrange#5544707, product#5544710, plant#5544705, purchasingOrg#5544716, purchasingGroup#5544717, mrpController#5544714, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, isFallbackOrderOnly#5544718, ... 20 more fields]
(17) Project
Arguments: [shardId#5544747, worklistShardItemId#5544724L, orderProposalId#5544701L, orderProposalItemId#5544702, orderProposalItemGroupId#5544725, originalReplenishmentRunId#5544743L, orderProposalHorizonGroupingId#5544719L, splitIndicator#5544720L, previousOrderProposal#5544721L, clusterId#5544722L, cast(sequenceId#5544723 as bigint) AS sequenceId#5544748L, sourceOfSupplyUuid#5544715, supplierGroup#5544703, supplier#5544704, subrange#5544707, product#5544710, plant#5544705, purchasingOrg#5544716, purchasingGroup#5544717, mrpController#5544714, orderDateTime#5544711, deliveryDateTime#5544706, availabilityDateTime#5544712, nextAvailabilityDateTime#5544713, isFallbackOrderOnly#5544718, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#5543988 = shardId#5544656) AND (worklistShardItemId#5544500L = worklistShardItemId#5544657L))
(20) Project
Arguments: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544658L, orderProposalItemId#5544659, orderProposalItemGroupId#5544660, originalReplenishmentRunId#5544661L, orderProposalHorizonGroupingId#5544662L, splitIndicator#5544663L, previousOrderProposal#5544664L, clusterId#5544665L, sequenceId#5544666L, sourceOfSupplyUuid#5544667, supplierGroup#5544668, supplier#5544669, subrange#5544670, product#5544671, plant#5544672, purchasingOrg#5544673, purchasingGroup#5544674, mrpController#5544675, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, ... 22 more fields]
(21) Project
Arguments: [shardId#5543988, worklistShardItemId#5544500L, quantityAfterProdPlantOptimization#5544501, qty#5544502, orderProposalId#5544658L, originalReplenishmentRunId#5544661L, supplierGroup#5544668, supplier#5544669, supplyingPlant#5544699, productGroup#5544700, product#5544671, plant#5544672, subrange#5544670, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, nextAvailabilityDateTime#5544679, constraintValues#5544693, constraintOperators#5544691, constraintLabels#5544690, logisticUnits#5544695, orderQuantityBaseUom#5544681, orderQuantityBaseUomUuid#5544682, splitIndicator#5544663L, netPriceAmount#5544686, ... 14 more fields]
(22) Project
Arguments: [shardId#5543988, product#5544671, plant#5544672, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, qty#5544502, orderProposalId#5544658L]
(23) Project
Arguments: [shardId#5543988, product#5544671, plant#5544672, orderDateTime#5544676, deliveryDateTime#5544677, availabilityDateTime#5544678, qty#5544502 AS orderQuantityInBaseUnit#5544953, orderProposalId#5544658L]
(24) Filter
Arguments: (shardId#5543988 = 0_1_10000001445)