== 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@6f8a0c19, [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#3509062, worklistShardItemId#3509063L, orderProposalId#3509064L, orderProposalItemId#3509065, orderProposalItemGroupId#3509066, originalReplenishmentRunId#3509067L, orderProposalHorizonGroupingId#3509068L, splitIndicator#3509069L, previousOrderProposal#3509070L, clusterId#3509071L, sequenceId#3509072L, sourceOfSupplyUuid#3509073, supplierGroup#3509074, supplier#3509075, subrange#3509076, product#3509077, plant#3509078, purchasingOrg#3509079, purchasingGroup#3509080, mrpController#3509081, orderDateTime#3509082, deliveryDateTime#3509083, availabilityDateTime#3509084, nextAvailabilityDateTime#3509085, isFallbackOrderOnly#3509086, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3509179L, orderProposalItemId#3509180, supplierGroup#3509181, supplier#3509182, plant#3509183, deliveryDateTime#3509184, subrange#3509185, supplyingPlant#3509186, productGroup#3509187, product#3509188, orderDateTime#3509189, availabilityDateTime#3509190, nextAvailabilityDateTime#3509191, mrpController#3509192, sourceOfSupplyUuid#3509193, purchasingOrg#3509194, purchasingGroup#3509195, isFallbackOrderOnly#3509196, orderProposalHorizonGroupingId#3509197L, splitIndicator#3509198L, previousOrderProposal#3509199L, clusterId#3509200L, sequenceId#3509201, worklistShardItemId#3509202L, orderProposalItemGroupId#3509203, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3509223 = 0_2_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3509202L], 37
(7) Filter
Arguments: (sequenceId#3509201 = 6)
(8) Project
Arguments: [orderProposalId#3509179L, orderProposalItemId#3509180, supplierGroup#3509181, supplier#3509182, plant#3509183, deliveryDateTime#3509184, subrange#3509185, supplyingPlant#3509186, productGroup#3509187, product#3509188, orderDateTime#3509189, availabilityDateTime#3509190, nextAvailabilityDateTime#3509191, mrpController#3509192, sourceOfSupplyUuid#3509193, purchasingOrg#3509194, purchasingGroup#3509195, isFallbackOrderOnly#3509196, orderProposalHorizonGroupingId#3509197L, splitIndicator#3509198L, previousOrderProposal#3509199L, clusterId#3509200L, sequenceId#3509201, worklistShardItemId#3509202L, orderProposalItemGroupId#3509203, ... 20 more fields]
(9) Project
Arguments: [shardId#3509225, worklistShardItemId#3509202L, orderProposalId#3509179L, orderProposalItemId#3509180, orderProposalItemGroupId#3509203, originalReplenishmentRunId#3509221L, orderProposalHorizonGroupingId#3509197L, splitIndicator#3509198L, previousOrderProposal#3509199L, clusterId#3509200L, sequenceId#3509201, sourceOfSupplyUuid#3509193, supplierGroup#3509181, supplier#3509182, subrange#3509185, product#3509188, plant#3509183, purchasingOrg#3509194, purchasingGroup#3509195, mrpController#3509192, orderDateTime#3509189, deliveryDateTime#3509184, availabilityDateTime#3509190, nextAvailabilityDateTime#3509191, isFallbackOrderOnly#3509196, ... 20 more fields]
(10) Project
Arguments: [shardId#3509225, worklistShardItemId#3509202L, orderProposalId#3509179L, orderProposalItemId#3509180, orderProposalItemGroupId#3509203, originalReplenishmentRunId#3509221L, orderProposalHorizonGroupingId#3509197L, splitIndicator#3509198L, previousOrderProposal#3509199L, clusterId#3509200L, cast(sequenceId#3509201 as bigint) AS sequenceId#3509226L, sourceOfSupplyUuid#3509193, supplierGroup#3509181, supplier#3509182, subrange#3509185, product#3509188, plant#3509183, purchasingOrg#3509194, purchasingGroup#3509195, mrpController#3509192, orderDateTime#3509189, deliveryDateTime#3509184, availabilityDateTime#3509190, nextAvailabilityDateTime#3509191, isFallbackOrderOnly#3509196, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3509085) AND (nextAvailabilityDateTime#3509085 > availabilityDateTime#3509084))
(13) Project
Arguments: [shardId#3509062, worklistShardItemId#3509063L, product#3509077, plant#3509078, availabilityDateTime#3509084, nextAvailabilityDateTime#3509085]
(14) Project
Arguments: [shardId#3509062, worklistShardItemId#3509063L, product#3509077, plant#3509078, availabilityDateTime#3509084, nextAvailabilityDateTime#3509085, 0 AS version#3511831]
(15) Project
Arguments: [shardId#3509062, worklistShardItemId#3509063L, product#3509077, plant#3509078, availabilityDateTime#3509084 AS periodStart#3511832, nextAvailabilityDateTime#3509085, version#3511831]
(16) Project
Arguments: [shardId#3509062, worklistShardItemId#3509063L, product#3509077, plant#3509078, periodStart#3511832, nextAvailabilityDateTime#3509085 AS periodEnd#3511833, version#3511831]
(17) Project
Arguments: [shardId#3509062, worklistShardItemId#3509063L, product#3509077, plant#3509078, periodStart#3511832, periodEnd#3511833, version#3511831, cast(null as double) AS qty#3511834]