== 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@4317e25e, [path=hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000532/stream-10000000532-3], Append
(3) LocalRelation
Arguments: <empty>, [shardId#3565255, worklistShardItemId#3565256L, orderProposalId#3565257L, orderProposalItemId#3565258, orderProposalItemGroupId#3565259, originalReplenishmentRunId#3565260L, orderProposalHorizonGroupingId#3565261L, splitIndicator#3565262L, previousOrderProposal#3565263L, clusterId#3565264L, sequenceId#3565265L, sourceOfSupplyUuid#3565266, supplierGroup#3565267, supplier#3565268, subrange#3565269, product#3565270, plant#3565271, purchasingOrg#3565272, purchasingGroup#3565273, mrpController#3565274, orderDateTime#3565275, deliveryDateTime#3565276, availabilityDateTime#3565277, nextAvailabilityDateTime#3565278, isFallbackOrderOnly#3565279, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3565404L, orderProposalItemId#3565405, supplierGroup#3565406, supplier#3565407, plant#3565408, deliveryDateTime#3565409, subrange#3565410, supplyingPlant#3565411, productGroup#3565412, product#3565413, orderDateTime#3565414, availabilityDateTime#3565415, nextAvailabilityDateTime#3565416, mrpController#3565417, sourceOfSupplyUuid#3565418, purchasingOrg#3565419, purchasingGroup#3565420, isFallbackOrderOnly#3565421, orderProposalHorizonGroupingId#3565422L, splitIndicator#3565423L, previousOrderProposal#3565424L, clusterId#3565425L, sequenceId#3565426, worklistShardItemId#3565427L, orderProposalItemGroupId#3565428, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3565448 = 0_1_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3565427L], 37
(7) Filter
Arguments: (sequenceId#3565426 = 7)
(8) Project
Arguments: [orderProposalId#3565404L, orderProposalItemId#3565405, supplierGroup#3565406, supplier#3565407, plant#3565408, deliveryDateTime#3565409, subrange#3565410, supplyingPlant#3565411, productGroup#3565412, product#3565413, orderDateTime#3565414, availabilityDateTime#3565415, nextAvailabilityDateTime#3565416, mrpController#3565417, sourceOfSupplyUuid#3565418, purchasingOrg#3565419, purchasingGroup#3565420, isFallbackOrderOnly#3565421, orderProposalHorizonGroupingId#3565422L, splitIndicator#3565423L, previousOrderProposal#3565424L, clusterId#3565425L, sequenceId#3565426, worklistShardItemId#3565427L, orderProposalItemGroupId#3565428, ... 20 more fields]
(9) Project
Arguments: [shardId#3565450, worklistShardItemId#3565427L, orderProposalId#3565404L, orderProposalItemId#3565405, orderProposalItemGroupId#3565428, originalReplenishmentRunId#3565446L, orderProposalHorizonGroupingId#3565422L, splitIndicator#3565423L, previousOrderProposal#3565424L, clusterId#3565425L, sequenceId#3565426, sourceOfSupplyUuid#3565418, supplierGroup#3565406, supplier#3565407, subrange#3565410, product#3565413, plant#3565408, purchasingOrg#3565419, purchasingGroup#3565420, mrpController#3565417, orderDateTime#3565414, deliveryDateTime#3565409, availabilityDateTime#3565415, nextAvailabilityDateTime#3565416, isFallbackOrderOnly#3565421, ... 20 more fields]
(10) Project
Arguments: [shardId#3565450, worklistShardItemId#3565427L, orderProposalId#3565404L, orderProposalItemId#3565405, orderProposalItemGroupId#3565428, originalReplenishmentRunId#3565446L, orderProposalHorizonGroupingId#3565422L, splitIndicator#3565423L, previousOrderProposal#3565424L, clusterId#3565425L, cast(sequenceId#3565426 as bigint) AS sequenceId#3565451L, sourceOfSupplyUuid#3565418, supplierGroup#3565406, supplier#3565407, subrange#3565410, product#3565413, plant#3565408, purchasingOrg#3565419, purchasingGroup#3565420, mrpController#3565417, orderDateTime#3565414, deliveryDateTime#3565409, availabilityDateTime#3565415, nextAvailabilityDateTime#3565416, isFallbackOrderOnly#3565421, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3565278) AND (nextAvailabilityDateTime#3565278 > availabilityDateTime#3565277))
(13) Project
Arguments: [shardId#3565255, worklistShardItemId#3565256L, product#3565270, plant#3565271, availabilityDateTime#3565277, nextAvailabilityDateTime#3565278]
(14) Project
Arguments: [shardId#3565255, worklistShardItemId#3565256L, product#3565270, plant#3565271, availabilityDateTime#3565277, nextAvailabilityDateTime#3565278, 0 AS version#3568203]
(15) Project
Arguments: [shardId#3565255, worklistShardItemId#3565256L, product#3565270, plant#3565271, availabilityDateTime#3565277 AS periodStart#3568204, nextAvailabilityDateTime#3565278, version#3568203]
(16) Project
Arguments: [shardId#3565255, worklistShardItemId#3565256L, product#3565270, plant#3565271, periodStart#3568204, nextAvailabilityDateTime#3565278 AS periodEnd#3568205, version#3568203]
(17) Project
Arguments: [shardId#3565255, worklistShardItemId#3565256L, product#3565270, plant#3565271, periodStart#3568204, periodEnd#3568205, version#3568203, cast(null as double) AS qty#3568206]