== 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@2ce6bb3d, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002107/stream-10000002107-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#682604, worklistShardItemId#682605L, orderProposalId#682606L, orderProposalItemId#682607, orderProposalItemGroupId#682608, originalReplenishmentRunId#682609L, orderProposalHorizonGroupingId#682610L, splitIndicator#682611L, previousOrderProposal#682612L, clusterId#682613L, sequenceId#682614L, sourceOfSupplyUuid#682615, supplierGroup#682616, supplier#682617, subrange#682618, product#682619, plant#682620, purchasingOrg#682621, purchasingGroup#682622, mrpController#682623, orderDateTime#682624, deliveryDateTime#682625, availabilityDateTime#682626, nextAvailabilityDateTime#682627, isFallbackOrderOnly#682628, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#682649L, orderProposalItemId#682650, supplierGroup#682651, supplier#682652, plant#682653, deliveryDateTime#682654, subrange#682655, supplyingPlant#682656, productGroup#682657, product#682658, orderDateTime#682659, availabilityDateTime#682660, nextAvailabilityDateTime#682661, mrpController#682662, sourceOfSupplyUuid#682663, purchasingOrg#682664, purchasingGroup#682665, isFallbackOrderOnly#682666, orderProposalHorizonGroupingId#682667L, splitIndicator#682668L, previousOrderProposal#682669L, clusterId#682670L, sequenceId#682671, worklistShardItemId#682672L, orderProposalItemGroupId#682673, ... 20 more fields], false
(5) Filter
Arguments: (shardId#682693 = 0_1_10000002107)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#682672L], 25
(7) Filter
Arguments: (sequenceId#682671 = 5)
(8) Project
Arguments: [orderProposalId#682649L, orderProposalItemId#682650, supplierGroup#682651, supplier#682652, plant#682653, deliveryDateTime#682654, subrange#682655, supplyingPlant#682656, productGroup#682657, product#682658, orderDateTime#682659, availabilityDateTime#682660, nextAvailabilityDateTime#682661, mrpController#682662, sourceOfSupplyUuid#682663, purchasingOrg#682664, purchasingGroup#682665, isFallbackOrderOnly#682666, orderProposalHorizonGroupingId#682667L, splitIndicator#682668L, previousOrderProposal#682669L, clusterId#682670L, sequenceId#682671, worklistShardItemId#682672L, orderProposalItemGroupId#682673, ... 20 more fields]
(9) Project
Arguments: [shardId#682695, worklistShardItemId#682672L, orderProposalId#682649L, orderProposalItemId#682650, orderProposalItemGroupId#682673, originalReplenishmentRunId#682691L, orderProposalHorizonGroupingId#682667L, splitIndicator#682668L, previousOrderProposal#682669L, clusterId#682670L, sequenceId#682671, sourceOfSupplyUuid#682663, supplierGroup#682651, supplier#682652, subrange#682655, product#682658, plant#682653, purchasingOrg#682664, purchasingGroup#682665, mrpController#682662, orderDateTime#682659, deliveryDateTime#682654, availabilityDateTime#682660, nextAvailabilityDateTime#682661, isFallbackOrderOnly#682666, ... 20 more fields]
(10) Project
Arguments: [shardId#682695, worklistShardItemId#682672L, orderProposalId#682649L, orderProposalItemId#682650, orderProposalItemGroupId#682673, originalReplenishmentRunId#682691L, orderProposalHorizonGroupingId#682667L, splitIndicator#682668L, previousOrderProposal#682669L, clusterId#682670L, cast(sequenceId#682671 as bigint) AS sequenceId#682696L, sourceOfSupplyUuid#682663, supplierGroup#682651, supplier#682652, subrange#682655, product#682658, plant#682653, purchasingOrg#682664, purchasingGroup#682665, mrpController#682662, orderDateTime#682659, deliveryDateTime#682654, availabilityDateTime#682660, nextAvailabilityDateTime#682661, isFallbackOrderOnly#682666, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#682627) AND (nextAvailabilityDateTime#682627 > availabilityDateTime#682626))
(13) Project
Arguments: [shardId#682604, worklistShardItemId#682605L, product#682619, plant#682620, availabilityDateTime#682626, nextAvailabilityDateTime#682627]
(14) Project
Arguments: [shardId#682604, worklistShardItemId#682605L, product#682619, plant#682620, availabilityDateTime#682626, nextAvailabilityDateTime#682627, 0 AS version#684862]
(15) Project
Arguments: [shardId#682604, worklistShardItemId#682605L, product#682619, plant#682620, availabilityDateTime#682626 AS periodStart#684863, nextAvailabilityDateTime#682627, version#684862]
(16) Project
Arguments: [shardId#682604, worklistShardItemId#682605L, product#682619, plant#682620, periodStart#684863, nextAvailabilityDateTime#682627 AS periodEnd#684864, version#684862]
(17) Project
Arguments: [shardId#682604, worklistShardItemId#682605L, product#682619, plant#682620, periodStart#684863, periodEnd#684864, version#684862, cast(null as double) AS qty#684865]