== 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@6d93af1, [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#882207, worklistShardItemId#882208L, orderProposalId#882209L, orderProposalItemId#882210, orderProposalItemGroupId#882211, originalReplenishmentRunId#882212L, orderProposalHorizonGroupingId#882213L, splitIndicator#882214L, previousOrderProposal#882215L, clusterId#882216L, sequenceId#882217L, sourceOfSupplyUuid#882218, supplierGroup#882219, supplier#882220, subrange#882221, product#882222, plant#882223, purchasingOrg#882224, purchasingGroup#882225, mrpController#882226, orderDateTime#882227, deliveryDateTime#882228, availabilityDateTime#882229, nextAvailabilityDateTime#882230, isFallbackOrderOnly#882231, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#882252L, orderProposalItemId#882253, supplierGroup#882254, supplier#882255, plant#882256, deliveryDateTime#882257, subrange#882258, supplyingPlant#882259, productGroup#882260, product#882261, orderDateTime#882262, availabilityDateTime#882263, nextAvailabilityDateTime#882264, mrpController#882265, sourceOfSupplyUuid#882266, purchasingOrg#882267, purchasingGroup#882268, isFallbackOrderOnly#882269, orderProposalHorizonGroupingId#882270L, splitIndicator#882271L, previousOrderProposal#882272L, clusterId#882273L, sequenceId#882274, worklistShardItemId#882275L, orderProposalItemGroupId#882276, ... 20 more fields], false
(5) Filter
Arguments: (shardId#882296 = 0_1_10000002109)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#882275L], 25
(7) Filter
Arguments: (sequenceId#882274 = 2)
(8) Project
Arguments: [orderProposalId#882252L, orderProposalItemId#882253, supplierGroup#882254, supplier#882255, plant#882256, deliveryDateTime#882257, subrange#882258, supplyingPlant#882259, productGroup#882260, product#882261, orderDateTime#882262, availabilityDateTime#882263, nextAvailabilityDateTime#882264, mrpController#882265, sourceOfSupplyUuid#882266, purchasingOrg#882267, purchasingGroup#882268, isFallbackOrderOnly#882269, orderProposalHorizonGroupingId#882270L, splitIndicator#882271L, previousOrderProposal#882272L, clusterId#882273L, sequenceId#882274, worklistShardItemId#882275L, orderProposalItemGroupId#882276, ... 20 more fields]
(9) Project
Arguments: [shardId#882298, worklistShardItemId#882275L, orderProposalId#882252L, orderProposalItemId#882253, orderProposalItemGroupId#882276, originalReplenishmentRunId#882294L, orderProposalHorizonGroupingId#882270L, splitIndicator#882271L, previousOrderProposal#882272L, clusterId#882273L, sequenceId#882274, sourceOfSupplyUuid#882266, supplierGroup#882254, supplier#882255, subrange#882258, product#882261, plant#882256, purchasingOrg#882267, purchasingGroup#882268, mrpController#882265, orderDateTime#882262, deliveryDateTime#882257, availabilityDateTime#882263, nextAvailabilityDateTime#882264, isFallbackOrderOnly#882269, ... 20 more fields]
(10) Project
Arguments: [shardId#882298, worklistShardItemId#882275L, orderProposalId#882252L, orderProposalItemId#882253, orderProposalItemGroupId#882276, originalReplenishmentRunId#882294L, orderProposalHorizonGroupingId#882270L, splitIndicator#882271L, previousOrderProposal#882272L, clusterId#882273L, cast(sequenceId#882274 as bigint) AS sequenceId#882299L, sourceOfSupplyUuid#882266, supplierGroup#882254, supplier#882255, subrange#882258, product#882261, plant#882256, purchasingOrg#882267, purchasingGroup#882268, mrpController#882265, orderDateTime#882262, deliveryDateTime#882257, availabilityDateTime#882263, nextAvailabilityDateTime#882264, isFallbackOrderOnly#882269, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#882230) AND (nextAvailabilityDateTime#882230 > availabilityDateTime#882229))
(13) Project
Arguments: [shardId#882207, worklistShardItemId#882208L, product#882222, plant#882223, availabilityDateTime#882229, nextAvailabilityDateTime#882230]
(14) Project
Arguments: [shardId#882207, worklistShardItemId#882208L, product#882222, plant#882223, availabilityDateTime#882229, nextAvailabilityDateTime#882230, 0 AS version#884465]
(15) Project
Arguments: [shardId#882207, worklistShardItemId#882208L, product#882222, plant#882223, availabilityDateTime#882229 AS periodStart#884466, nextAvailabilityDateTime#882230, version#884465]
(16) Project
Arguments: [shardId#882207, worklistShardItemId#882208L, product#882222, plant#882223, periodStart#884466, nextAvailabilityDateTime#882230 AS periodEnd#884467, version#884465]
(17) Project
Arguments: [shardId#882207, worklistShardItemId#882208L, product#882222, plant#882223, periodStart#884466, periodEnd#884467, version#884465, cast(null as double) AS qty#884468]