== 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@77dd05b0, [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#969678, worklistShardItemId#969679L, orderProposalId#969680L, orderProposalItemId#969681, orderProposalItemGroupId#969682, originalReplenishmentRunId#969683L, orderProposalHorizonGroupingId#969684L, splitIndicator#969685L, previousOrderProposal#969686L, clusterId#969687L, sequenceId#969688L, sourceOfSupplyUuid#969689, supplierGroup#969690, supplier#969691, subrange#969692, product#969693, plant#969694, purchasingOrg#969695, purchasingGroup#969696, mrpController#969697, orderDateTime#969698, deliveryDateTime#969699, availabilityDateTime#969700, nextAvailabilityDateTime#969701, isFallbackOrderOnly#969702, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#969723L, orderProposalItemId#969724, supplierGroup#969725, supplier#969726, plant#969727, deliveryDateTime#969728, subrange#969729, supplyingPlant#969730, productGroup#969731, product#969732, orderDateTime#969733, availabilityDateTime#969734, nextAvailabilityDateTime#969735, mrpController#969736, sourceOfSupplyUuid#969737, purchasingOrg#969738, purchasingGroup#969739, isFallbackOrderOnly#969740, orderProposalHorizonGroupingId#969741L, splitIndicator#969742L, previousOrderProposal#969743L, clusterId#969744L, sequenceId#969745, worklistShardItemId#969746L, orderProposalItemGroupId#969747, ... 20 more fields], false
(5) Filter
Arguments: (shardId#969767 = 0_1_10000002110)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#969746L], 25
(7) Filter
Arguments: (sequenceId#969745 = 2)
(8) Project
Arguments: [orderProposalId#969723L, orderProposalItemId#969724, supplierGroup#969725, supplier#969726, plant#969727, deliveryDateTime#969728, subrange#969729, supplyingPlant#969730, productGroup#969731, product#969732, orderDateTime#969733, availabilityDateTime#969734, nextAvailabilityDateTime#969735, mrpController#969736, sourceOfSupplyUuid#969737, purchasingOrg#969738, purchasingGroup#969739, isFallbackOrderOnly#969740, orderProposalHorizonGroupingId#969741L, splitIndicator#969742L, previousOrderProposal#969743L, clusterId#969744L, sequenceId#969745, worklistShardItemId#969746L, orderProposalItemGroupId#969747, ... 20 more fields]
(9) Project
Arguments: [shardId#969769, worklistShardItemId#969746L, orderProposalId#969723L, orderProposalItemId#969724, orderProposalItemGroupId#969747, originalReplenishmentRunId#969765L, orderProposalHorizonGroupingId#969741L, splitIndicator#969742L, previousOrderProposal#969743L, clusterId#969744L, sequenceId#969745, sourceOfSupplyUuid#969737, supplierGroup#969725, supplier#969726, subrange#969729, product#969732, plant#969727, purchasingOrg#969738, purchasingGroup#969739, mrpController#969736, orderDateTime#969733, deliveryDateTime#969728, availabilityDateTime#969734, nextAvailabilityDateTime#969735, isFallbackOrderOnly#969740, ... 20 more fields]
(10) Project
Arguments: [shardId#969769, worklistShardItemId#969746L, orderProposalId#969723L, orderProposalItemId#969724, orderProposalItemGroupId#969747, originalReplenishmentRunId#969765L, orderProposalHorizonGroupingId#969741L, splitIndicator#969742L, previousOrderProposal#969743L, clusterId#969744L, cast(sequenceId#969745 as bigint) AS sequenceId#969770L, sourceOfSupplyUuid#969737, supplierGroup#969725, supplier#969726, subrange#969729, product#969732, plant#969727, purchasingOrg#969738, purchasingGroup#969739, mrpController#969736, orderDateTime#969733, deliveryDateTime#969728, availabilityDateTime#969734, nextAvailabilityDateTime#969735, isFallbackOrderOnly#969740, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#969701) AND (nextAvailabilityDateTime#969701 > availabilityDateTime#969700))
(13) Project
Arguments: [shardId#969678, worklistShardItemId#969679L, product#969693, plant#969694, availabilityDateTime#969700, nextAvailabilityDateTime#969701]
(14) Project
Arguments: [shardId#969678, worklistShardItemId#969679L, product#969693, plant#969694, availabilityDateTime#969700, nextAvailabilityDateTime#969701, 0 AS version#971936]
(15) Project
Arguments: [shardId#969678, worklistShardItemId#969679L, product#969693, plant#969694, availabilityDateTime#969700 AS periodStart#971937, nextAvailabilityDateTime#969701, version#971936]
(16) Project
Arguments: [shardId#969678, worklistShardItemId#969679L, product#969693, plant#969694, periodStart#971937, nextAvailabilityDateTime#969701 AS periodEnd#971938, version#971936]
(17) Project
Arguments: [shardId#969678, worklistShardItemId#969679L, product#969693, plant#969694, periodStart#971937, periodEnd#971938, version#971936, cast(null as double) AS qty#971939]