== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (17)
+- Project (16)
+- Project (15)
+- Project (14)
+- Project (13)
+- Filter (12)
+- Union (11)
:- LocalRelation (3)
+- Project (10)
+- Project (9)
+- Project (8)
+- Filter (7)
+- RepartitionByExpression (6)
+- Filter (5)
+- LogicalRelation (4)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.delta.sources.DeltaDataSource@17faa8f1, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002109/stream-10000002109-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#835462, worklistShardItemId#835463L, orderProposalId#835464L, orderProposalItemId#835465, orderProposalItemGroupId#835466, originalReplenishmentRunId#835467L, orderProposalHorizonGroupingId#835468L, splitIndicator#835469L, previousOrderProposal#835470L, clusterId#835471L, sequenceId#835472L, sourceOfSupplyUuid#835473, supplierGroup#835474, supplier#835475, subrange#835476, product#835477, plant#835478, purchasingOrg#835479, purchasingGroup#835480, mrpController#835481, orderDateTime#835482, deliveryDateTime#835483, availabilityDateTime#835484, nextAvailabilityDateTime#835485, isFallbackOrderOnly#835486, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#835507L, orderProposalItemId#835508, supplierGroup#835509, supplier#835510, plant#835511, deliveryDateTime#835512, subrange#835513, supplyingPlant#835514, productGroup#835515, product#835516, orderDateTime#835517, availabilityDateTime#835518, nextAvailabilityDateTime#835519, mrpController#835520, sourceOfSupplyUuid#835521, purchasingOrg#835522, purchasingGroup#835523, isFallbackOrderOnly#835524, orderProposalHorizonGroupingId#835525L, splitIndicator#835526L, previousOrderProposal#835527L, clusterId#835528L, sequenceId#835529, worklistShardItemId#835530L, orderProposalItemGroupId#835531, ... 20 more fields], false
(5) Filter
Arguments: (shardId#835551 = 0_1_10000002109)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#835530L], 25
(7) Filter
Arguments: (sequenceId#835529 = 0)
(8) Project
Arguments: [orderProposalId#835507L, orderProposalItemId#835508, supplierGroup#835509, supplier#835510, plant#835511, deliveryDateTime#835512, subrange#835513, supplyingPlant#835514, productGroup#835515, product#835516, orderDateTime#835517, availabilityDateTime#835518, nextAvailabilityDateTime#835519, mrpController#835520, sourceOfSupplyUuid#835521, purchasingOrg#835522, purchasingGroup#835523, isFallbackOrderOnly#835524, orderProposalHorizonGroupingId#835525L, splitIndicator#835526L, previousOrderProposal#835527L, clusterId#835528L, sequenceId#835529, worklistShardItemId#835530L, orderProposalItemGroupId#835531, ... 20 more fields]
(9) Project
Arguments: [shardId#835553, worklistShardItemId#835530L, orderProposalId#835507L, orderProposalItemId#835508, orderProposalItemGroupId#835531, originalReplenishmentRunId#835549L, orderProposalHorizonGroupingId#835525L, splitIndicator#835526L, previousOrderProposal#835527L, clusterId#835528L, sequenceId#835529, sourceOfSupplyUuid#835521, supplierGroup#835509, supplier#835510, subrange#835513, product#835516, plant#835511, purchasingOrg#835522, purchasingGroup#835523, mrpController#835520, orderDateTime#835517, deliveryDateTime#835512, availabilityDateTime#835518, nextAvailabilityDateTime#835519, isFallbackOrderOnly#835524, ... 20 more fields]
(10) Project
Arguments: [shardId#835553, worklistShardItemId#835530L, orderProposalId#835507L, orderProposalItemId#835508, orderProposalItemGroupId#835531, originalReplenishmentRunId#835549L, orderProposalHorizonGroupingId#835525L, splitIndicator#835526L, previousOrderProposal#835527L, clusterId#835528L, cast(sequenceId#835529 as bigint) AS sequenceId#835554L, sourceOfSupplyUuid#835521, supplierGroup#835509, supplier#835510, subrange#835513, product#835516, plant#835511, purchasingOrg#835522, purchasingGroup#835523, mrpController#835520, orderDateTime#835517, deliveryDateTime#835512, availabilityDateTime#835518, nextAvailabilityDateTime#835519, isFallbackOrderOnly#835524, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#835485) AND (nextAvailabilityDateTime#835485 > availabilityDateTime#835484))
(13) Project
Arguments: [shardId#835462, worklistShardItemId#835463L, product#835477, plant#835478, availabilityDateTime#835484, nextAvailabilityDateTime#835485]
(14) Project
Arguments: [shardId#835462, worklistShardItemId#835463L, product#835477, plant#835478, availabilityDateTime#835484, nextAvailabilityDateTime#835485, 0 AS version#837888]
(15) Project
Arguments: [shardId#835462, worklistShardItemId#835463L, product#835477, plant#835478, availabilityDateTime#835484 AS periodStart#837889, nextAvailabilityDateTime#835485, version#837888]
(16) Project
Arguments: [shardId#835462, worklistShardItemId#835463L, product#835477, plant#835478, periodStart#837889, nextAvailabilityDateTime#835485 AS periodEnd#837890, version#837888]
(17) Project
Arguments: [shardId#835462, worklistShardItemId#835463L, product#835477, plant#835478, periodStart#837889, periodEnd#837890, version#837888, cast(null as double) AS qty#837891]