== 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@61980c32, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002108/stream-10000002108-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#791481, worklistShardItemId#791482L, orderProposalId#791483L, orderProposalItemId#791484, orderProposalItemGroupId#791485, originalReplenishmentRunId#791486L, orderProposalHorizonGroupingId#791487L, splitIndicator#791488L, previousOrderProposal#791489L, clusterId#791490L, sequenceId#791491L, sourceOfSupplyUuid#791492, supplierGroup#791493, supplier#791494, subrange#791495, product#791496, plant#791497, purchasingOrg#791498, purchasingGroup#791499, mrpController#791500, orderDateTime#791501, deliveryDateTime#791502, availabilityDateTime#791503, nextAvailabilityDateTime#791504, isFallbackOrderOnly#791505, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#791526L, orderProposalItemId#791527, supplierGroup#791528, supplier#791529, plant#791530, deliveryDateTime#791531, subrange#791532, supplyingPlant#791533, productGroup#791534, product#791535, orderDateTime#791536, availabilityDateTime#791537, nextAvailabilityDateTime#791538, mrpController#791539, sourceOfSupplyUuid#791540, purchasingOrg#791541, purchasingGroup#791542, isFallbackOrderOnly#791543, orderProposalHorizonGroupingId#791544L, splitIndicator#791545L, previousOrderProposal#791546L, clusterId#791547L, sequenceId#791548, worklistShardItemId#791549L, orderProposalItemGroupId#791550, ... 20 more fields], false
(5) Filter
Arguments: (shardId#791570 = 0_1_10000002108)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#791549L], 25
(7) Filter
Arguments: (sequenceId#791548 = 2)
(8) Project
Arguments: [orderProposalId#791526L, orderProposalItemId#791527, supplierGroup#791528, supplier#791529, plant#791530, deliveryDateTime#791531, subrange#791532, supplyingPlant#791533, productGroup#791534, product#791535, orderDateTime#791536, availabilityDateTime#791537, nextAvailabilityDateTime#791538, mrpController#791539, sourceOfSupplyUuid#791540, purchasingOrg#791541, purchasingGroup#791542, isFallbackOrderOnly#791543, orderProposalHorizonGroupingId#791544L, splitIndicator#791545L, previousOrderProposal#791546L, clusterId#791547L, sequenceId#791548, worklistShardItemId#791549L, orderProposalItemGroupId#791550, ... 20 more fields]
(9) Project
Arguments: [shardId#791572, worklistShardItemId#791549L, orderProposalId#791526L, orderProposalItemId#791527, orderProposalItemGroupId#791550, originalReplenishmentRunId#791568L, orderProposalHorizonGroupingId#791544L, splitIndicator#791545L, previousOrderProposal#791546L, clusterId#791547L, sequenceId#791548, sourceOfSupplyUuid#791540, supplierGroup#791528, supplier#791529, subrange#791532, product#791535, plant#791530, purchasingOrg#791541, purchasingGroup#791542, mrpController#791539, orderDateTime#791536, deliveryDateTime#791531, availabilityDateTime#791537, nextAvailabilityDateTime#791538, isFallbackOrderOnly#791543, ... 20 more fields]
(10) Project
Arguments: [shardId#791572, worklistShardItemId#791549L, orderProposalId#791526L, orderProposalItemId#791527, orderProposalItemGroupId#791550, originalReplenishmentRunId#791568L, orderProposalHorizonGroupingId#791544L, splitIndicator#791545L, previousOrderProposal#791546L, clusterId#791547L, cast(sequenceId#791548 as bigint) AS sequenceId#791573L, sourceOfSupplyUuid#791540, supplierGroup#791528, supplier#791529, subrange#791532, product#791535, plant#791530, purchasingOrg#791541, purchasingGroup#791542, mrpController#791539, orderDateTime#791536, deliveryDateTime#791531, availabilityDateTime#791537, nextAvailabilityDateTime#791538, isFallbackOrderOnly#791543, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#791504) AND (nextAvailabilityDateTime#791504 > availabilityDateTime#791503))
(13) Project
Arguments: [shardId#791481, worklistShardItemId#791482L, product#791496, plant#791497, availabilityDateTime#791503, nextAvailabilityDateTime#791504]
(14) Project
Arguments: [shardId#791481, worklistShardItemId#791482L, product#791496, plant#791497, availabilityDateTime#791503, nextAvailabilityDateTime#791504, 0 AS version#793739]
(15) Project
Arguments: [shardId#791481, worklistShardItemId#791482L, product#791496, plant#791497, availabilityDateTime#791503 AS periodStart#793740, nextAvailabilityDateTime#791504, version#793739]
(16) Project
Arguments: [shardId#791481, worklistShardItemId#791482L, product#791496, plant#791497, periodStart#793740, nextAvailabilityDateTime#791504 AS periodEnd#793741, version#793739]
(17) Project
Arguments: [shardId#791481, worklistShardItemId#791482L, product#791496, plant#791497, periodStart#793740, periodEnd#793741, version#793739, cast(null as double) AS qty#793742]