== 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@41a19968, [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#981205, orderProposalId#981206L, items#981207, optimizationGroups#981208, isOptimal#981209, lastModified#981210, optimizationInsights#981211], false
(4) Filter
Arguments: shardId#981205 IN (0_1_10000002110)
(5) Filter
Arguments: shardId#981205 IN (0_1_10000002110)
(6) Project
Arguments: [shardId#981205, orderProposalId#981206L, items#981207, optimizationGroups#981208, isOptimal#981209, optimizationInsights#981211]
(7) Generate
Arguments: explode(items#981207), false, [item#981716]
(8) Project
Arguments: [shardId#981205, item#981716]
(9) Project
Arguments: [shardId#981205, item#981716.worklistShardItemId AS worklistShardItemId#981717L, item#981716.quantityAfterProdPlantOptimization AS quantityAfterProdPlantOptimization#981718, item#981716.qty AS qty#981719]
(10) LocalRelation
Arguments: <empty>, [shardId#981873, worklistShardItemId#981874L, orderProposalId#981875L, orderProposalItemId#981876, orderProposalItemGroupId#981877, originalReplenishmentRunId#981878L, orderProposalHorizonGroupingId#981879L, splitIndicator#981880L, previousOrderProposal#981881L, clusterId#981882L, sequenceId#981883L, sourceOfSupplyUuid#981884, supplierGroup#981885, supplier#981886, subrange#981887, product#981888, plant#981889, purchasingOrg#981890, purchasingGroup#981891, mrpController#981892, orderDateTime#981893, deliveryDateTime#981894, availabilityDateTime#981895, nextAvailabilityDateTime#981896, isFallbackOrderOnly#981897, ... 20 more fields]
(11) LogicalRelation
Arguments: parquet, [orderProposalId#981918L, orderProposalItemId#981919, supplierGroup#981920, supplier#981921, plant#981922, deliveryDateTime#981923, subrange#981924, supplyingPlant#981925, productGroup#981926, product#981927, orderDateTime#981928, availabilityDateTime#981929, nextAvailabilityDateTime#981930, mrpController#981931, sourceOfSupplyUuid#981932, purchasingOrg#981933, purchasingGroup#981934, isFallbackOrderOnly#981935, orderProposalHorizonGroupingId#981936L, splitIndicator#981937L, previousOrderProposal#981938L, clusterId#981939L, sequenceId#981940, worklistShardItemId#981941L, orderProposalItemGroupId#981942, ... 20 more fields], false
(12) Filter
Arguments: (shardId#981962 = 0_1_10000002110)
(13) RepartitionByExpression
Arguments: [worklistShardItemId#981941L], 20
(14) Filter
Arguments: (sequenceId#981940 = 2)
(15) Project
Arguments: [orderProposalId#981918L, orderProposalItemId#981919, supplierGroup#981920, supplier#981921, plant#981922, deliveryDateTime#981923, subrange#981924, supplyingPlant#981925, productGroup#981926, product#981927, orderDateTime#981928, availabilityDateTime#981929, nextAvailabilityDateTime#981930, mrpController#981931, sourceOfSupplyUuid#981932, purchasingOrg#981933, purchasingGroup#981934, isFallbackOrderOnly#981935, orderProposalHorizonGroupingId#981936L, splitIndicator#981937L, previousOrderProposal#981938L, clusterId#981939L, sequenceId#981940, worklistShardItemId#981941L, orderProposalItemGroupId#981942, ... 20 more fields]
(16) Project
Arguments: [shardId#981964, worklistShardItemId#981941L, orderProposalId#981918L, orderProposalItemId#981919, orderProposalItemGroupId#981942, originalReplenishmentRunId#981960L, orderProposalHorizonGroupingId#981936L, splitIndicator#981937L, previousOrderProposal#981938L, clusterId#981939L, sequenceId#981940, sourceOfSupplyUuid#981932, supplierGroup#981920, supplier#981921, subrange#981924, product#981927, plant#981922, purchasingOrg#981933, purchasingGroup#981934, mrpController#981931, orderDateTime#981928, deliveryDateTime#981923, availabilityDateTime#981929, nextAvailabilityDateTime#981930, isFallbackOrderOnly#981935, ... 20 more fields]
(17) Project
Arguments: [shardId#981964, worklistShardItemId#981941L, orderProposalId#981918L, orderProposalItemId#981919, orderProposalItemGroupId#981942, originalReplenishmentRunId#981960L, orderProposalHorizonGroupingId#981936L, splitIndicator#981937L, previousOrderProposal#981938L, clusterId#981939L, cast(sequenceId#981940 as bigint) AS sequenceId#981965L, sourceOfSupplyUuid#981932, supplierGroup#981920, supplier#981921, subrange#981924, product#981927, plant#981922, purchasingOrg#981933, purchasingGroup#981934, mrpController#981931, orderDateTime#981928, deliveryDateTime#981923, availabilityDateTime#981929, nextAvailabilityDateTime#981930, isFallbackOrderOnly#981935, ... 20 more fields]
(18) Union
Arguments: false, false
(19) Join
Arguments: LeftOuter, ((shardId#981205 = shardId#981873) AND (worklistShardItemId#981717L = worklistShardItemId#981874L))
(20) Project
Arguments: [shardId#981205, worklistShardItemId#981717L, quantityAfterProdPlantOptimization#981718, qty#981719, orderProposalId#981875L, orderProposalItemId#981876, orderProposalItemGroupId#981877, originalReplenishmentRunId#981878L, orderProposalHorizonGroupingId#981879L, splitIndicator#981880L, previousOrderProposal#981881L, clusterId#981882L, sequenceId#981883L, sourceOfSupplyUuid#981884, supplierGroup#981885, supplier#981886, subrange#981887, product#981888, plant#981889, purchasingOrg#981890, purchasingGroup#981891, mrpController#981892, orderDateTime#981893, deliveryDateTime#981894, availabilityDateTime#981895, ... 22 more fields]
(21) Project
Arguments: [shardId#981205, worklistShardItemId#981717L, quantityAfterProdPlantOptimization#981718, qty#981719, orderProposalId#981875L, originalReplenishmentRunId#981878L, supplierGroup#981885, supplier#981886, supplyingPlant#981916, productGroup#981917, product#981888, plant#981889, subrange#981887, orderDateTime#981893, deliveryDateTime#981894, availabilityDateTime#981895, nextAvailabilityDateTime#981896, constraintValues#981910, constraintOperators#981908, constraintLabels#981907, logisticUnits#981912, orderQuantityBaseUom#981898, orderQuantityBaseUomUuid#981899, splitIndicator#981880L, netPriceAmount#981903, ... 14 more fields]
(22) Project
Arguments: [shardId#981205, product#981888, plant#981889, orderDateTime#981893, deliveryDateTime#981894, availabilityDateTime#981895, qty#981719, orderProposalId#981875L]
(23) Project
Arguments: [shardId#981205, product#981888, plant#981889, orderDateTime#981893, deliveryDateTime#981894, availabilityDateTime#981895, qty#981719 AS orderQuantityInBaseUnit#981993, orderProposalId#981875L]
(24) Filter
Arguments: (shardId#981205 = 0_1_10000002110)