== 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@634707a6, [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-2], Append
(3) LocalRelation
Arguments: <empty>, [shardId#3530498, worklistShardItemId#3530499L, orderProposalId#3530500L, orderProposalItemId#3530501, orderProposalItemGroupId#3530502, originalReplenishmentRunId#3530503L, orderProposalHorizonGroupingId#3530504L, splitIndicator#3530505L, previousOrderProposal#3530506L, clusterId#3530507L, sequenceId#3530508L, sourceOfSupplyUuid#3530509, supplierGroup#3530510, supplier#3530511, subrange#3530512, product#3530513, plant#3530514, purchasingOrg#3530515, purchasingGroup#3530516, mrpController#3530517, orderDateTime#3530518, deliveryDateTime#3530519, availabilityDateTime#3530520, nextAvailabilityDateTime#3530521, isFallbackOrderOnly#3530522, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3530633L, orderProposalItemId#3530634, supplierGroup#3530635, supplier#3530636, plant#3530637, deliveryDateTime#3530638, subrange#3530639, supplyingPlant#3530640, productGroup#3530641, product#3530642, orderDateTime#3530643, availabilityDateTime#3530644, nextAvailabilityDateTime#3530645, mrpController#3530646, sourceOfSupplyUuid#3530647, purchasingOrg#3530648, purchasingGroup#3530649, isFallbackOrderOnly#3530650, orderProposalHorizonGroupingId#3530651L, splitIndicator#3530652L, previousOrderProposal#3530653L, clusterId#3530654L, sequenceId#3530655, worklistShardItemId#3530656L, orderProposalItemGroupId#3530657, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3530677 = 0_3_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3530656L], 37
(7) Filter
Arguments: (sequenceId#3530655 = 2)
(8) Project
Arguments: [orderProposalId#3530633L, orderProposalItemId#3530634, supplierGroup#3530635, supplier#3530636, plant#3530637, deliveryDateTime#3530638, subrange#3530639, supplyingPlant#3530640, productGroup#3530641, product#3530642, orderDateTime#3530643, availabilityDateTime#3530644, nextAvailabilityDateTime#3530645, mrpController#3530646, sourceOfSupplyUuid#3530647, purchasingOrg#3530648, purchasingGroup#3530649, isFallbackOrderOnly#3530650, orderProposalHorizonGroupingId#3530651L, splitIndicator#3530652L, previousOrderProposal#3530653L, clusterId#3530654L, sequenceId#3530655, worklistShardItemId#3530656L, orderProposalItemGroupId#3530657, ... 20 more fields]
(9) Project
Arguments: [shardId#3530679, worklistShardItemId#3530656L, orderProposalId#3530633L, orderProposalItemId#3530634, orderProposalItemGroupId#3530657, originalReplenishmentRunId#3530675L, orderProposalHorizonGroupingId#3530651L, splitIndicator#3530652L, previousOrderProposal#3530653L, clusterId#3530654L, sequenceId#3530655, sourceOfSupplyUuid#3530647, supplierGroup#3530635, supplier#3530636, subrange#3530639, product#3530642, plant#3530637, purchasingOrg#3530648, purchasingGroup#3530649, mrpController#3530646, orderDateTime#3530643, deliveryDateTime#3530638, availabilityDateTime#3530644, nextAvailabilityDateTime#3530645, isFallbackOrderOnly#3530650, ... 20 more fields]
(10) Project
Arguments: [shardId#3530679, worklistShardItemId#3530656L, orderProposalId#3530633L, orderProposalItemId#3530634, orderProposalItemGroupId#3530657, originalReplenishmentRunId#3530675L, orderProposalHorizonGroupingId#3530651L, splitIndicator#3530652L, previousOrderProposal#3530653L, clusterId#3530654L, cast(sequenceId#3530655 as bigint) AS sequenceId#3530680L, sourceOfSupplyUuid#3530647, supplierGroup#3530635, supplier#3530636, subrange#3530639, product#3530642, plant#3530637, purchasingOrg#3530648, purchasingGroup#3530649, mrpController#3530646, orderDateTime#3530643, deliveryDateTime#3530638, availabilityDateTime#3530644, nextAvailabilityDateTime#3530645, isFallbackOrderOnly#3530650, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3530521) AND (nextAvailabilityDateTime#3530521 > availabilityDateTime#3530520))
(13) Project
Arguments: [shardId#3530498, worklistShardItemId#3530499L, product#3530513, plant#3530514, availabilityDateTime#3530520, nextAvailabilityDateTime#3530521]
(14) Project
Arguments: [shardId#3530498, worklistShardItemId#3530499L, product#3530513, plant#3530514, availabilityDateTime#3530520, nextAvailabilityDateTime#3530521, 0 AS version#3534039]
(15) Project
Arguments: [shardId#3530498, worklistShardItemId#3530499L, product#3530513, plant#3530514, availabilityDateTime#3530520 AS periodStart#3534040, nextAvailabilityDateTime#3530521, version#3534039]
(16) Project
Arguments: [shardId#3530498, worklistShardItemId#3530499L, product#3530513, plant#3530514, periodStart#3534040, nextAvailabilityDateTime#3530521 AS periodEnd#3534041, version#3534039]
(17) Project
Arguments: [shardId#3530498, worklistShardItemId#3530499L, product#3530513, plant#3530514, periodStart#3534040, periodEnd#3534041, version#3534039, cast(null as double) AS qty#3534042]