== 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@58ebcf0d, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002106/stream-10000002106-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#670195, worklistShardItemId#670196L, orderProposalId#670197L, orderProposalItemId#670198, orderProposalItemGroupId#670199, originalReplenishmentRunId#670200L, orderProposalHorizonGroupingId#670201L, splitIndicator#670202L, previousOrderProposal#670203L, clusterId#670204L, sequenceId#670205L, sourceOfSupplyUuid#670206, supplierGroup#670207, supplier#670208, subrange#670209, product#670210, plant#670211, purchasingOrg#670212, purchasingGroup#670213, mrpController#670214, orderDateTime#670215, deliveryDateTime#670216, availabilityDateTime#670217, nextAvailabilityDateTime#670218, isFallbackOrderOnly#670219, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#670240L, orderProposalItemId#670241, supplierGroup#670242, supplier#670243, plant#670244, deliveryDateTime#670245, subrange#670246, supplyingPlant#670247, productGroup#670248, product#670249, orderDateTime#670250, availabilityDateTime#670251, nextAvailabilityDateTime#670252, mrpController#670253, sourceOfSupplyUuid#670254, purchasingOrg#670255, purchasingGroup#670256, isFallbackOrderOnly#670257, orderProposalHorizonGroupingId#670258L, splitIndicator#670259L, previousOrderProposal#670260L, clusterId#670261L, sequenceId#670262, worklistShardItemId#670263L, orderProposalItemGroupId#670264, ... 20 more fields], false
(5) Filter
Arguments: (shardId#670284 = 0_1_10000002106)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#670263L], 25
(7) Filter
Arguments: (sequenceId#670262 = 3)
(8) Project
Arguments: [orderProposalId#670240L, orderProposalItemId#670241, supplierGroup#670242, supplier#670243, plant#670244, deliveryDateTime#670245, subrange#670246, supplyingPlant#670247, productGroup#670248, product#670249, orderDateTime#670250, availabilityDateTime#670251, nextAvailabilityDateTime#670252, mrpController#670253, sourceOfSupplyUuid#670254, purchasingOrg#670255, purchasingGroup#670256, isFallbackOrderOnly#670257, orderProposalHorizonGroupingId#670258L, splitIndicator#670259L, previousOrderProposal#670260L, clusterId#670261L, sequenceId#670262, worklistShardItemId#670263L, orderProposalItemGroupId#670264, ... 20 more fields]
(9) Project
Arguments: [shardId#670286, worklistShardItemId#670263L, orderProposalId#670240L, orderProposalItemId#670241, orderProposalItemGroupId#670264, originalReplenishmentRunId#670282L, orderProposalHorizonGroupingId#670258L, splitIndicator#670259L, previousOrderProposal#670260L, clusterId#670261L, sequenceId#670262, sourceOfSupplyUuid#670254, supplierGroup#670242, supplier#670243, subrange#670246, product#670249, plant#670244, purchasingOrg#670255, purchasingGroup#670256, mrpController#670253, orderDateTime#670250, deliveryDateTime#670245, availabilityDateTime#670251, nextAvailabilityDateTime#670252, isFallbackOrderOnly#670257, ... 20 more fields]
(10) Project
Arguments: [shardId#670286, worklistShardItemId#670263L, orderProposalId#670240L, orderProposalItemId#670241, orderProposalItemGroupId#670264, originalReplenishmentRunId#670282L, orderProposalHorizonGroupingId#670258L, splitIndicator#670259L, previousOrderProposal#670260L, clusterId#670261L, cast(sequenceId#670262 as bigint) AS sequenceId#670287L, sourceOfSupplyUuid#670254, supplierGroup#670242, supplier#670243, subrange#670246, product#670249, plant#670244, purchasingOrg#670255, purchasingGroup#670256, mrpController#670253, orderDateTime#670250, deliveryDateTime#670245, availabilityDateTime#670251, nextAvailabilityDateTime#670252, isFallbackOrderOnly#670257, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#670218) AND (nextAvailabilityDateTime#670218 > availabilityDateTime#670217))
(13) Project
Arguments: [shardId#670195, worklistShardItemId#670196L, product#670210, plant#670211, availabilityDateTime#670217, nextAvailabilityDateTime#670218]
(14) Project
Arguments: [shardId#670195, worklistShardItemId#670196L, product#670210, plant#670211, availabilityDateTime#670217, nextAvailabilityDateTime#670218, 0 AS version#672453]
(15) Project
Arguments: [shardId#670195, worklistShardItemId#670196L, product#670210, plant#670211, availabilityDateTime#670217 AS periodStart#672454, nextAvailabilityDateTime#670218, version#672453]
(16) Project
Arguments: [shardId#670195, worklistShardItemId#670196L, product#670210, plant#670211, periodStart#672454, nextAvailabilityDateTime#670218 AS periodEnd#672455, version#672453]
(17) Project
Arguments: [shardId#670195, worklistShardItemId#670196L, product#670210, plant#670211, periodStart#672454, periodEnd#672455, version#672453, cast(null as double) AS qty#672456]