== 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@4078f5aa, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000002106/stream-10000002106-1/shardId=0_1_10000002106], Append
(3) LogicalRDD
Arguments: [shardId#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, lastModified#643173, optimizationInsights#643174], false
(4) Filter
Arguments: shardId#643168 IN (0_1_10000002106)
(5) Filter
Arguments: shardId#643168 IN (0_1_10000002106)
(6) Project
Arguments: [shardId#643168, orderProposalId#643169L, items#643170, optimizationGroups#643171, isOptimal#643172, optimizationInsights#643174]
(7) Generate
Arguments: explode(items#643170), false, [item#643815]
(8) Project
Arguments: [shardId#643168, item#643815]
(9) Project
Arguments: [shardId#643168, item#643815.worklistShardItemId AS worklistShardItemId#643816L, item#643815.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#643817, item#643815.qty AS qty#643818]
(10) LocalRelation
Arguments: <empty>, [shardId#644572, worklistShardItemId#644573L, orderProposalId#644574L, orderProposalItemId#644575, orderProposalItemGroupId#644576, originalReplenishmentRunId#644577L, orderProposalHorizonGroupingId#644578L, splitIndicator#644579L, previousOrderProposal#644580L, clusterId#644581L, sequenceId#644582L, sourceOfSupplyUuid#644583, supplierGroup#644584, supplier#644585, subrange#644586, product#644587, plant#644588, purchasingOrg#644589, purchasingGroup#644590, mrpController#644591, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, nextAvailabilityDateTime#644595, isFallbackOrderOnly#644596, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#645037L, orderProposalItemId#645038, supplierGroup#645039, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, orderDateTime#645047, availabilityDateTime#645048, nextAvailabilityDateTime#645049, mrpController#645050, sourceOfSupplyUuid#645051, purchasingOrg#645052, purchasingGroup#645053, isFallbackOrderOnly#645054, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, sequenceId#645059, worklistShardItemId#645060L, orderProposalItemGroupId#645061, ... 20 more fields], false
(12) Filter
Arguments: (shardId#645081 = 0_1_10000002106)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#645060L], 20
(14) Filter
Arguments: (sequenceId#645059 = 2)
(15) Project
Arguments: [orderProposalId#645037L, orderProposalItemId#645038, supplierGroup#645039, supplier#645040, plant#645041, deliveryDateTime#645042, subrange#645043, supplyingPlant#645044, productGroup#645045, product#645046, orderDateTime#645047, availabilityDateTime#645048, nextAvailabilityDateTime#645049, mrpController#645050, sourceOfSupplyUuid#645051, purchasingOrg#645052, purchasingGroup#645053, isFallbackOrderOnly#645054, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, sequenceId#645059, worklistShardItemId#645060L, orderProposalItemGroupId#645061, ... 20 more fields]
(16) Project
Arguments: [shardId#645083, worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemId#645038, orderProposalItemGroupId#645061, originalReplenishmentRunId#645079L, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, sequenceId#645059, sourceOfSupplyUuid#645051, supplierGroup#645039, supplier#645040, subrange#645043, product#645046, plant#645041, purchasingOrg#645052, purchasingGroup#645053, mrpController#645050, orderDateTime#645047, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, ... 20 more fields]
(17) Project
Arguments: [shardId#645083, worklistShardItemId#645060L, orderProposalId#645037L, orderProposalItemId#645038, orderProposalItemGroupId#645061, originalReplenishmentRunId#645079L, orderProposalHorizonGroupingId#645055L, splitIndicator#645056L, previousOrderProposal#645057L, clusterId#645058L, cast(sequenceId#645059 as bigint) AS sequenceId#645084L, sourceOfSupplyUuid#645051, supplierGroup#645039, supplier#645040, subrange#645043, product#645046, plant#645041, purchasingOrg#645052, purchasingGroup#645053, mrpController#645050, orderDateTime#645047, deliveryDateTime#645042, availabilityDateTime#645048, nextAvailabilityDateTime#645049, isFallbackOrderOnly#645054, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#643168 = shardId#644572) AND (worklistShardItemId#643816L = worklistShardItemId#644573L))
(20) Project
Arguments: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#644574L, orderProposalItemId#644575, orderProposalItemGroupId#644576, originalReplenishmentRunId#644577L, orderProposalHorizonGroupingId#644578L, splitIndicator#644579L, previousOrderProposal#644580L, clusterId#644581L, sequenceId#644582L, sourceOfSupplyUuid#644583, supplierGroup#644584, supplier#644585, subrange#644586, product#644587, plant#644588, purchasingOrg#644589, purchasingGroup#644590, mrpController#644591, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, ... 22 more fields]
(21) Project
Arguments: [shardId#643168, worklistShardItemId#643816L, quantityAfterProdPlantOptimization#643817, qty#643818, orderProposalId#644574L, originalReplenishmentRunId#644577L, supplierGroup#644584, supplier#644585, supplyingPlant#644615, productGroup#644616, product#644587, plant#644588, subrange#644586, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, nextAvailabilityDateTime#644595, constraintValues#644609, constraintOperators#644607, constraintLabels#644606, logisticUnits#644611, orderQuantityBaseUom#644597, orderQuantityBaseUomUuid#644598, splitIndicator#644579L, netPriceAmount#644602, ... 14 more fields]
(22) Project
Arguments: [shardId#643168, product#644587, plant#644588, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, qty#643818, orderProposalId#644574L]
(23) Project
Arguments: [shardId#643168, product#644587, plant#644588, orderDateTime#644592, deliveryDateTime#644593, availabilityDateTime#644594, qty#643818 AS orderQuantityInBaseUnit#646345, orderProposalId#644574L]
(24) Filter
Arguments: (shardId#643168 = 0_1_10000002106)