== 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@386fe270, [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#740250, worklistShardItemId#740251L, orderProposalId#740252L, orderProposalItemId#740253, orderProposalItemGroupId#740254, originalReplenishmentRunId#740255L, orderProposalHorizonGroupingId#740256L, splitIndicator#740257L, previousOrderProposal#740258L, clusterId#740259L, sequenceId#740260L, sourceOfSupplyUuid#740261, supplierGroup#740262, supplier#740263, subrange#740264, product#740265, plant#740266, purchasingOrg#740267, purchasingGroup#740268, mrpController#740269, orderDateTime#740270, deliveryDateTime#740271, availabilityDateTime#740272, nextAvailabilityDateTime#740273, isFallbackOrderOnly#740274, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#740295L, orderProposalItemId#740296, supplierGroup#740297, supplier#740298, plant#740299, deliveryDateTime#740300, subrange#740301, supplyingPlant#740302, productGroup#740303, product#740304, orderDateTime#740305, availabilityDateTime#740306, nextAvailabilityDateTime#740307, mrpController#740308, sourceOfSupplyUuid#740309, purchasingOrg#740310, purchasingGroup#740311, isFallbackOrderOnly#740312, orderProposalHorizonGroupingId#740313L, splitIndicator#740314L, previousOrderProposal#740315L, clusterId#740316L, sequenceId#740317, worklistShardItemId#740318L, orderProposalItemGroupId#740319, ... 20 more fields], false
(5) Filter
Arguments: (shardId#740339 = 0_1_10000002108)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#740318L], 25
(7) Filter
Arguments: (sequenceId#740317 = 0)
(8) Project
Arguments: [orderProposalId#740295L, orderProposalItemId#740296, supplierGroup#740297, supplier#740298, plant#740299, deliveryDateTime#740300, subrange#740301, supplyingPlant#740302, productGroup#740303, product#740304, orderDateTime#740305, availabilityDateTime#740306, nextAvailabilityDateTime#740307, mrpController#740308, sourceOfSupplyUuid#740309, purchasingOrg#740310, purchasingGroup#740311, isFallbackOrderOnly#740312, orderProposalHorizonGroupingId#740313L, splitIndicator#740314L, previousOrderProposal#740315L, clusterId#740316L, sequenceId#740317, worklistShardItemId#740318L, orderProposalItemGroupId#740319, ... 20 more fields]
(9) Project
Arguments: [shardId#740341, worklistShardItemId#740318L, orderProposalId#740295L, orderProposalItemId#740296, orderProposalItemGroupId#740319, originalReplenishmentRunId#740337L, orderProposalHorizonGroupingId#740313L, splitIndicator#740314L, previousOrderProposal#740315L, clusterId#740316L, sequenceId#740317, sourceOfSupplyUuid#740309, supplierGroup#740297, supplier#740298, subrange#740301, product#740304, plant#740299, purchasingOrg#740310, purchasingGroup#740311, mrpController#740308, orderDateTime#740305, deliveryDateTime#740300, availabilityDateTime#740306, nextAvailabilityDateTime#740307, isFallbackOrderOnly#740312, ... 20 more fields]
(10) Project
Arguments: [shardId#740341, worklistShardItemId#740318L, orderProposalId#740295L, orderProposalItemId#740296, orderProposalItemGroupId#740319, originalReplenishmentRunId#740337L, orderProposalHorizonGroupingId#740313L, splitIndicator#740314L, previousOrderProposal#740315L, clusterId#740316L, cast(sequenceId#740317 as bigint) AS sequenceId#740342L, sourceOfSupplyUuid#740309, supplierGroup#740297, supplier#740298, subrange#740301, product#740304, plant#740299, purchasingOrg#740310, purchasingGroup#740311, mrpController#740308, orderDateTime#740305, deliveryDateTime#740300, availabilityDateTime#740306, nextAvailabilityDateTime#740307, isFallbackOrderOnly#740312, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#740273) AND (nextAvailabilityDateTime#740273 > availabilityDateTime#740272))
(13) Project
Arguments: [shardId#740250, worklistShardItemId#740251L, product#740265, plant#740266, availabilityDateTime#740272, nextAvailabilityDateTime#740273]
(14) Project
Arguments: [shardId#740250, worklistShardItemId#740251L, product#740265, plant#740266, availabilityDateTime#740272, nextAvailabilityDateTime#740273, 0 AS version#742676]
(15) Project
Arguments: [shardId#740250, worklistShardItemId#740251L, product#740265, plant#740266, availabilityDateTime#740272 AS periodStart#742677, nextAvailabilityDateTime#740273, version#742676]
(16) Project
Arguments: [shardId#740250, worklistShardItemId#740251L, product#740265, plant#740266, periodStart#742677, nextAvailabilityDateTime#740273 AS periodEnd#742678, version#742676]
(17) Project
Arguments: [shardId#740250, worklistShardItemId#740251L, product#740265, plant#740266, periodStart#742677, periodEnd#742678, version#742676, cast(null as double) AS qty#742679]