== 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@507e2464, [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#766080, worklistShardItemId#766081L, orderProposalId#766082L, orderProposalItemId#766083, orderProposalItemGroupId#766084, originalReplenishmentRunId#766085L, orderProposalHorizonGroupingId#766086L, splitIndicator#766087L, previousOrderProposal#766088L, clusterId#766089L, sequenceId#766090L, sourceOfSupplyUuid#766091, supplierGroup#766092, supplier#766093, subrange#766094, product#766095, plant#766096, purchasingOrg#766097, purchasingGroup#766098, mrpController#766099, orderDateTime#766100, deliveryDateTime#766101, availabilityDateTime#766102, nextAvailabilityDateTime#766103, isFallbackOrderOnly#766104, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#766125L, orderProposalItemId#766126, supplierGroup#766127, supplier#766128, plant#766129, deliveryDateTime#766130, subrange#766131, supplyingPlant#766132, productGroup#766133, product#766134, orderDateTime#766135, availabilityDateTime#766136, nextAvailabilityDateTime#766137, mrpController#766138, sourceOfSupplyUuid#766139, purchasingOrg#766140, purchasingGroup#766141, isFallbackOrderOnly#766142, orderProposalHorizonGroupingId#766143L, splitIndicator#766144L, previousOrderProposal#766145L, clusterId#766146L, sequenceId#766147, worklistShardItemId#766148L, orderProposalItemGroupId#766149, ... 20 more fields], false
(5) Filter
Arguments: (shardId#766169 = 0_1_10000002108)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#766148L], 25
(7) Filter
Arguments: (sequenceId#766147 = 1)
(8) Project
Arguments: [orderProposalId#766125L, orderProposalItemId#766126, supplierGroup#766127, supplier#766128, plant#766129, deliveryDateTime#766130, subrange#766131, supplyingPlant#766132, productGroup#766133, product#766134, orderDateTime#766135, availabilityDateTime#766136, nextAvailabilityDateTime#766137, mrpController#766138, sourceOfSupplyUuid#766139, purchasingOrg#766140, purchasingGroup#766141, isFallbackOrderOnly#766142, orderProposalHorizonGroupingId#766143L, splitIndicator#766144L, previousOrderProposal#766145L, clusterId#766146L, sequenceId#766147, worklistShardItemId#766148L, orderProposalItemGroupId#766149, ... 20 more fields]
(9) Project
Arguments: [shardId#766171, worklistShardItemId#766148L, orderProposalId#766125L, orderProposalItemId#766126, orderProposalItemGroupId#766149, originalReplenishmentRunId#766167L, orderProposalHorizonGroupingId#766143L, splitIndicator#766144L, previousOrderProposal#766145L, clusterId#766146L, sequenceId#766147, sourceOfSupplyUuid#766139, supplierGroup#766127, supplier#766128, subrange#766131, product#766134, plant#766129, purchasingOrg#766140, purchasingGroup#766141, mrpController#766138, orderDateTime#766135, deliveryDateTime#766130, availabilityDateTime#766136, nextAvailabilityDateTime#766137, isFallbackOrderOnly#766142, ... 20 more fields]
(10) Project
Arguments: [shardId#766171, worklistShardItemId#766148L, orderProposalId#766125L, orderProposalItemId#766126, orderProposalItemGroupId#766149, originalReplenishmentRunId#766167L, orderProposalHorizonGroupingId#766143L, splitIndicator#766144L, previousOrderProposal#766145L, clusterId#766146L, cast(sequenceId#766147 as bigint) AS sequenceId#766172L, sourceOfSupplyUuid#766139, supplierGroup#766127, supplier#766128, subrange#766131, product#766134, plant#766129, purchasingOrg#766140, purchasingGroup#766141, mrpController#766138, orderDateTime#766135, deliveryDateTime#766130, availabilityDateTime#766136, nextAvailabilityDateTime#766137, isFallbackOrderOnly#766142, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#766103) AND (nextAvailabilityDateTime#766103 > availabilityDateTime#766102))
(13) Project
Arguments: [shardId#766080, worklistShardItemId#766081L, product#766095, plant#766096, availabilityDateTime#766102, nextAvailabilityDateTime#766103]
(14) Project
Arguments: [shardId#766080, worklistShardItemId#766081L, product#766095, plant#766096, availabilityDateTime#766102, nextAvailabilityDateTime#766103, 0 AS version#768338]
(15) Project
Arguments: [shardId#766080, worklistShardItemId#766081L, product#766095, plant#766096, availabilityDateTime#766102 AS periodStart#768339, nextAvailabilityDateTime#766103, version#768338]
(16) Project
Arguments: [shardId#766080, worklistShardItemId#766081L, product#766095, plant#766096, periodStart#768339, nextAvailabilityDateTime#766103 AS periodEnd#768340, version#768338]
(17) Project
Arguments: [shardId#766080, worklistShardItemId#766081L, product#766095, plant#766096, periodStart#768339, periodEnd#768340, version#768338, cast(null as double) AS qty#768341]