== 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@646ded27, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002110/stream-10000002110-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#946509, worklistShardItemId#946510L, orderProposalId#946511L, orderProposalItemId#946512, orderProposalItemGroupId#946513, originalReplenishmentRunId#946514L, orderProposalHorizonGroupingId#946515L, splitIndicator#946516L, previousOrderProposal#946517L, clusterId#946518L, sequenceId#946519L, sourceOfSupplyUuid#946520, supplierGroup#946521, supplier#946522, subrange#946523, product#946524, plant#946525, purchasingOrg#946526, purchasingGroup#946527, mrpController#946528, orderDateTime#946529, deliveryDateTime#946530, availabilityDateTime#946531, nextAvailabilityDateTime#946532, isFallbackOrderOnly#946533, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#946554L, orderProposalItemId#946555, supplierGroup#946556, supplier#946557, plant#946558, deliveryDateTime#946559, subrange#946560, supplyingPlant#946561, productGroup#946562, product#946563, orderDateTime#946564, availabilityDateTime#946565, nextAvailabilityDateTime#946566, mrpController#946567, sourceOfSupplyUuid#946568, purchasingOrg#946569, purchasingGroup#946570, isFallbackOrderOnly#946571, orderProposalHorizonGroupingId#946572L, splitIndicator#946573L, previousOrderProposal#946574L, clusterId#946575L, sequenceId#946576, worklistShardItemId#946577L, orderProposalItemGroupId#946578, ... 20 more fields], false
(5) Filter
Arguments: (shardId#946598 = 0_1_10000002110)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#946577L], 25
(7) Filter
Arguments: (sequenceId#946576 = 1)
(8) Project
Arguments: [orderProposalId#946554L, orderProposalItemId#946555, supplierGroup#946556, supplier#946557, plant#946558, deliveryDateTime#946559, subrange#946560, supplyingPlant#946561, productGroup#946562, product#946563, orderDateTime#946564, availabilityDateTime#946565, nextAvailabilityDateTime#946566, mrpController#946567, sourceOfSupplyUuid#946568, purchasingOrg#946569, purchasingGroup#946570, isFallbackOrderOnly#946571, orderProposalHorizonGroupingId#946572L, splitIndicator#946573L, previousOrderProposal#946574L, clusterId#946575L, sequenceId#946576, worklistShardItemId#946577L, orderProposalItemGroupId#946578, ... 20 more fields]
(9) Project
Arguments: [shardId#946600, worklistShardItemId#946577L, orderProposalId#946554L, orderProposalItemId#946555, orderProposalItemGroupId#946578, originalReplenishmentRunId#946596L, orderProposalHorizonGroupingId#946572L, splitIndicator#946573L, previousOrderProposal#946574L, clusterId#946575L, sequenceId#946576, sourceOfSupplyUuid#946568, supplierGroup#946556, supplier#946557, subrange#946560, product#946563, plant#946558, purchasingOrg#946569, purchasingGroup#946570, mrpController#946567, orderDateTime#946564, deliveryDateTime#946559, availabilityDateTime#946565, nextAvailabilityDateTime#946566, isFallbackOrderOnly#946571, ... 20 more fields]
(10) Project
Arguments: [shardId#946600, worklistShardItemId#946577L, orderProposalId#946554L, orderProposalItemId#946555, orderProposalItemGroupId#946578, originalReplenishmentRunId#946596L, orderProposalHorizonGroupingId#946572L, splitIndicator#946573L, previousOrderProposal#946574L, clusterId#946575L, cast(sequenceId#946576 as bigint) AS sequenceId#946601L, sourceOfSupplyUuid#946568, supplierGroup#946556, supplier#946557, subrange#946560, product#946563, plant#946558, purchasingOrg#946569, purchasingGroup#946570, mrpController#946567, orderDateTime#946564, deliveryDateTime#946559, availabilityDateTime#946565, nextAvailabilityDateTime#946566, isFallbackOrderOnly#946571, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#946532) AND (nextAvailabilityDateTime#946532 > availabilityDateTime#946531))
(13) Project
Arguments: [shardId#946509, worklistShardItemId#946510L, product#946524, plant#946525, availabilityDateTime#946531, nextAvailabilityDateTime#946532]
(14) Project
Arguments: [shardId#946509, worklistShardItemId#946510L, product#946524, plant#946525, availabilityDateTime#946531, nextAvailabilityDateTime#946532, 0 AS version#948767]
(15) Project
Arguments: [shardId#946509, worklistShardItemId#946510L, product#946524, plant#946525, availabilityDateTime#946531 AS periodStart#948768, nextAvailabilityDateTime#946532, version#948767]
(16) Project
Arguments: [shardId#946509, worklistShardItemId#946510L, product#946524, plant#946525, periodStart#948768, nextAvailabilityDateTime#946532 AS periodEnd#948769, version#948767]
(17) Project
Arguments: [shardId#946509, worklistShardItemId#946510L, product#946524, plant#946525, periodStart#948768, periodEnd#948769, version#948767, cast(null as double) AS qty#948770]