== 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@1cd1f867, [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#3430445, worklistShardItemId#3430446L, orderProposalId#3430447L, orderProposalItemId#3430448, orderProposalItemGroupId#3430449, originalReplenishmentRunId#3430450L, orderProposalHorizonGroupingId#3430451L, splitIndicator#3430452L, previousOrderProposal#3430453L, clusterId#3430454L, sequenceId#3430455L, sourceOfSupplyUuid#3430456, supplierGroup#3430457, supplier#3430458, subrange#3430459, product#3430460, plant#3430461, purchasingOrg#3430462, purchasingGroup#3430463, mrpController#3430464, orderDateTime#3430465, deliveryDateTime#3430466, availabilityDateTime#3430467, nextAvailabilityDateTime#3430468, isFallbackOrderOnly#3430469, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3430490L, orderProposalItemId#3430491, supplierGroup#3430492, supplier#3430493, plant#3430494, deliveryDateTime#3430495, subrange#3430496, supplyingPlant#3430497, productGroup#3430498, product#3430499, orderDateTime#3430500, availabilityDateTime#3430501, nextAvailabilityDateTime#3430502, mrpController#3430503, sourceOfSupplyUuid#3430504, purchasingOrg#3430505, purchasingGroup#3430506, isFallbackOrderOnly#3430507, orderProposalHorizonGroupingId#3430508L, splitIndicator#3430509L, previousOrderProposal#3430510L, clusterId#3430511L, sequenceId#3430512, worklistShardItemId#3430513L, orderProposalItemGroupId#3430514, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3430534 = 0_5_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3430513L], 37
(7) Filter
Arguments: (sequenceId#3430512 = 3)
(8) Project
Arguments: [orderProposalId#3430490L, orderProposalItemId#3430491, supplierGroup#3430492, supplier#3430493, plant#3430494, deliveryDateTime#3430495, subrange#3430496, supplyingPlant#3430497, productGroup#3430498, product#3430499, orderDateTime#3430500, availabilityDateTime#3430501, nextAvailabilityDateTime#3430502, mrpController#3430503, sourceOfSupplyUuid#3430504, purchasingOrg#3430505, purchasingGroup#3430506, isFallbackOrderOnly#3430507, orderProposalHorizonGroupingId#3430508L, splitIndicator#3430509L, previousOrderProposal#3430510L, clusterId#3430511L, sequenceId#3430512, worklistShardItemId#3430513L, orderProposalItemGroupId#3430514, ... 20 more fields]
(9) Project
Arguments: [shardId#3430536, worklistShardItemId#3430513L, orderProposalId#3430490L, orderProposalItemId#3430491, orderProposalItemGroupId#3430514, originalReplenishmentRunId#3430532L, orderProposalHorizonGroupingId#3430508L, splitIndicator#3430509L, previousOrderProposal#3430510L, clusterId#3430511L, sequenceId#3430512, sourceOfSupplyUuid#3430504, supplierGroup#3430492, supplier#3430493, subrange#3430496, product#3430499, plant#3430494, purchasingOrg#3430505, purchasingGroup#3430506, mrpController#3430503, orderDateTime#3430500, deliveryDateTime#3430495, availabilityDateTime#3430501, nextAvailabilityDateTime#3430502, isFallbackOrderOnly#3430507, ... 20 more fields]
(10) Project
Arguments: [shardId#3430536, worklistShardItemId#3430513L, orderProposalId#3430490L, orderProposalItemId#3430491, orderProposalItemGroupId#3430514, originalReplenishmentRunId#3430532L, orderProposalHorizonGroupingId#3430508L, splitIndicator#3430509L, previousOrderProposal#3430510L, clusterId#3430511L, cast(sequenceId#3430512 as bigint) AS sequenceId#3430537L, sourceOfSupplyUuid#3430504, supplierGroup#3430492, supplier#3430493, subrange#3430496, product#3430499, plant#3430494, purchasingOrg#3430505, purchasingGroup#3430506, mrpController#3430503, orderDateTime#3430500, deliveryDateTime#3430495, availabilityDateTime#3430501, nextAvailabilityDateTime#3430502, isFallbackOrderOnly#3430507, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3430468) AND (nextAvailabilityDateTime#3430468 > availabilityDateTime#3430467))
(13) Project
Arguments: [shardId#3430445, worklistShardItemId#3430446L, product#3430460, plant#3430461, availabilityDateTime#3430467, nextAvailabilityDateTime#3430468]
(14) Project
Arguments: [shardId#3430445, worklistShardItemId#3430446L, product#3430460, plant#3430461, availabilityDateTime#3430467, nextAvailabilityDateTime#3430468, 0 AS version#3432703]
(15) Project
Arguments: [shardId#3430445, worklistShardItemId#3430446L, product#3430460, plant#3430461, availabilityDateTime#3430467 AS periodStart#3432704, nextAvailabilityDateTime#3430468, version#3432703]
(16) Project
Arguments: [shardId#3430445, worklistShardItemId#3430446L, product#3430460, plant#3430461, periodStart#3432704, nextAvailabilityDateTime#3430468 AS periodEnd#3432705, version#3432703]
(17) Project
Arguments: [shardId#3430445, worklistShardItemId#3430446L, product#3430460, plant#3430461, periodStart#3432704, periodEnd#3432705, version#3432703, cast(null as double) AS qty#3432706]