== 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@56d0ef09, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002107/stream-10000002107-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#703379, worklistShardItemId#703380L, orderProposalId#703381L, orderProposalItemId#703382, orderProposalItemGroupId#703383, originalReplenishmentRunId#703384L, orderProposalHorizonGroupingId#703385L, splitIndicator#703386L, previousOrderProposal#703387L, clusterId#703388L, sequenceId#703389L, sourceOfSupplyUuid#703390, supplierGroup#703391, supplier#703392, subrange#703393, product#703394, plant#703395, purchasingOrg#703396, purchasingGroup#703397, mrpController#703398, orderDateTime#703399, deliveryDateTime#703400, availabilityDateTime#703401, nextAvailabilityDateTime#703402, isFallbackOrderOnly#703403, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#703424L, orderProposalItemId#703425, supplierGroup#703426, supplier#703427, plant#703428, deliveryDateTime#703429, subrange#703430, supplyingPlant#703431, productGroup#703432, product#703433, orderDateTime#703434, availabilityDateTime#703435, nextAvailabilityDateTime#703436, mrpController#703437, sourceOfSupplyUuid#703438, purchasingOrg#703439, purchasingGroup#703440, isFallbackOrderOnly#703441, orderProposalHorizonGroupingId#703442L, splitIndicator#703443L, previousOrderProposal#703444L, clusterId#703445L, sequenceId#703446, worklistShardItemId#703447L, orderProposalItemGroupId#703448, ... 20 more fields], false
(5) Filter
Arguments: (shardId#703468 = 0_1_10000002107)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#703447L], 25
(7) Filter
Arguments: (sequenceId#703446 = 6)
(8) Project
Arguments: [orderProposalId#703424L, orderProposalItemId#703425, supplierGroup#703426, supplier#703427, plant#703428, deliveryDateTime#703429, subrange#703430, supplyingPlant#703431, productGroup#703432, product#703433, orderDateTime#703434, availabilityDateTime#703435, nextAvailabilityDateTime#703436, mrpController#703437, sourceOfSupplyUuid#703438, purchasingOrg#703439, purchasingGroup#703440, isFallbackOrderOnly#703441, orderProposalHorizonGroupingId#703442L, splitIndicator#703443L, previousOrderProposal#703444L, clusterId#703445L, sequenceId#703446, worklistShardItemId#703447L, orderProposalItemGroupId#703448, ... 20 more fields]
(9) Project
Arguments: [shardId#703470, worklistShardItemId#703447L, orderProposalId#703424L, orderProposalItemId#703425, orderProposalItemGroupId#703448, originalReplenishmentRunId#703466L, orderProposalHorizonGroupingId#703442L, splitIndicator#703443L, previousOrderProposal#703444L, clusterId#703445L, sequenceId#703446, sourceOfSupplyUuid#703438, supplierGroup#703426, supplier#703427, subrange#703430, product#703433, plant#703428, purchasingOrg#703439, purchasingGroup#703440, mrpController#703437, orderDateTime#703434, deliveryDateTime#703429, availabilityDateTime#703435, nextAvailabilityDateTime#703436, isFallbackOrderOnly#703441, ... 20 more fields]
(10) Project
Arguments: [shardId#703470, worklistShardItemId#703447L, orderProposalId#703424L, orderProposalItemId#703425, orderProposalItemGroupId#703448, originalReplenishmentRunId#703466L, orderProposalHorizonGroupingId#703442L, splitIndicator#703443L, previousOrderProposal#703444L, clusterId#703445L, cast(sequenceId#703446 as bigint) AS sequenceId#703471L, sourceOfSupplyUuid#703438, supplierGroup#703426, supplier#703427, subrange#703430, product#703433, plant#703428, purchasingOrg#703439, purchasingGroup#703440, mrpController#703437, orderDateTime#703434, deliveryDateTime#703429, availabilityDateTime#703435, nextAvailabilityDateTime#703436, isFallbackOrderOnly#703441, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#703402) AND (nextAvailabilityDateTime#703402 > availabilityDateTime#703401))
(13) Project
Arguments: [shardId#703379, worklistShardItemId#703380L, product#703394, plant#703395, availabilityDateTime#703401, nextAvailabilityDateTime#703402]
(14) Project
Arguments: [shardId#703379, worklistShardItemId#703380L, product#703394, plant#703395, availabilityDateTime#703401, nextAvailabilityDateTime#703402, 0 AS version#705637]
(15) Project
Arguments: [shardId#703379, worklistShardItemId#703380L, product#703394, plant#703395, availabilityDateTime#703401 AS periodStart#705638, nextAvailabilityDateTime#703402, version#705637]
(16) Project
Arguments: [shardId#703379, worklistShardItemId#703380L, product#703394, plant#703395, periodStart#705638, nextAvailabilityDateTime#703402 AS periodEnd#705639, version#705637]
(17) Project
Arguments: [shardId#703379, worklistShardItemId#703380L, product#703394, plant#703395, periodStart#705638, periodEnd#705639, version#705637, cast(null as double) AS qty#705640]