== 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@77937688, [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-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#3537581, worklistShardItemId#3537582L, orderProposalId#3537583L, orderProposalItemId#3537584, orderProposalItemGroupId#3537585, originalReplenishmentRunId#3537586L, orderProposalHorizonGroupingId#3537587L, splitIndicator#3537588L, previousOrderProposal#3537589L, clusterId#3537590L, sequenceId#3537591L, sourceOfSupplyUuid#3537592, supplierGroup#3537593, supplier#3537594, subrange#3537595, product#3537596, plant#3537597, purchasingOrg#3537598, purchasingGroup#3537599, mrpController#3537600, orderDateTime#3537601, deliveryDateTime#3537602, availabilityDateTime#3537603, nextAvailabilityDateTime#3537604, isFallbackOrderOnly#3537605, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3537657L, orderProposalItemId#3537658, supplierGroup#3537659, supplier#3537660, plant#3537661, deliveryDateTime#3537662, subrange#3537663, supplyingPlant#3537664, productGroup#3537665, product#3537666, orderDateTime#3537667, availabilityDateTime#3537668, nextAvailabilityDateTime#3537669, mrpController#3537670, sourceOfSupplyUuid#3537671, purchasingOrg#3537672, purchasingGroup#3537673, isFallbackOrderOnly#3537674, orderProposalHorizonGroupingId#3537675L, splitIndicator#3537676L, previousOrderProposal#3537677L, clusterId#3537678L, sequenceId#3537679, worklistShardItemId#3537680L, orderProposalItemGroupId#3537681, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3537701 = 0_7_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3537680L], 37
(7) Filter
Arguments: (sequenceId#3537679 = 6)
(8) Project
Arguments: [orderProposalId#3537657L, orderProposalItemId#3537658, supplierGroup#3537659, supplier#3537660, plant#3537661, deliveryDateTime#3537662, subrange#3537663, supplyingPlant#3537664, productGroup#3537665, product#3537666, orderDateTime#3537667, availabilityDateTime#3537668, nextAvailabilityDateTime#3537669, mrpController#3537670, sourceOfSupplyUuid#3537671, purchasingOrg#3537672, purchasingGroup#3537673, isFallbackOrderOnly#3537674, orderProposalHorizonGroupingId#3537675L, splitIndicator#3537676L, previousOrderProposal#3537677L, clusterId#3537678L, sequenceId#3537679, worklistShardItemId#3537680L, orderProposalItemGroupId#3537681, ... 20 more fields]
(9) Project
Arguments: [shardId#3537703, worklistShardItemId#3537680L, orderProposalId#3537657L, orderProposalItemId#3537658, orderProposalItemGroupId#3537681, originalReplenishmentRunId#3537699L, orderProposalHorizonGroupingId#3537675L, splitIndicator#3537676L, previousOrderProposal#3537677L, clusterId#3537678L, sequenceId#3537679, sourceOfSupplyUuid#3537671, supplierGroup#3537659, supplier#3537660, subrange#3537663, product#3537666, plant#3537661, purchasingOrg#3537672, purchasingGroup#3537673, mrpController#3537670, orderDateTime#3537667, deliveryDateTime#3537662, availabilityDateTime#3537668, nextAvailabilityDateTime#3537669, isFallbackOrderOnly#3537674, ... 20 more fields]
(10) Project
Arguments: [shardId#3537703, worklistShardItemId#3537680L, orderProposalId#3537657L, orderProposalItemId#3537658, orderProposalItemGroupId#3537681, originalReplenishmentRunId#3537699L, orderProposalHorizonGroupingId#3537675L, splitIndicator#3537676L, previousOrderProposal#3537677L, clusterId#3537678L, cast(sequenceId#3537679 as bigint) AS sequenceId#3537704L, sourceOfSupplyUuid#3537671, supplierGroup#3537659, supplier#3537660, subrange#3537663, product#3537666, plant#3537661, purchasingOrg#3537672, purchasingGroup#3537673, mrpController#3537670, orderDateTime#3537667, deliveryDateTime#3537662, availabilityDateTime#3537668, nextAvailabilityDateTime#3537669, isFallbackOrderOnly#3537674, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3537604) AND (nextAvailabilityDateTime#3537604 > availabilityDateTime#3537603))
(13) Project
Arguments: [shardId#3537581, worklistShardItemId#3537582L, product#3537596, plant#3537597, availabilityDateTime#3537603, nextAvailabilityDateTime#3537604]
(14) Project
Arguments: [shardId#3537581, worklistShardItemId#3537582L, product#3537596, plant#3537597, availabilityDateTime#3537603, nextAvailabilityDateTime#3537604, 0 AS version#3540976]
(15) Project
Arguments: [shardId#3537581, worklistShardItemId#3537582L, product#3537596, plant#3537597, availabilityDateTime#3537603 AS periodStart#3540977, nextAvailabilityDateTime#3537604, version#3540976]
(16) Project
Arguments: [shardId#3537581, worklistShardItemId#3537582L, product#3537596, plant#3537597, periodStart#3540977, nextAvailabilityDateTime#3537604 AS periodEnd#3540978, version#3540976]
(17) Project
Arguments: [shardId#3537581, worklistShardItemId#3537582L, product#3537596, plant#3537597, periodStart#3540977, periodEnd#3540978, version#3540976, cast(null as double) AS qty#3540979]