== 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@66e09348, [path=hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000001445/stream-10000001445-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#5510457, worklistShardItemId#5510458L, orderProposalId#5510459L, orderProposalItemId#5510460, orderProposalItemGroupId#5510461, originalReplenishmentRunId#5510462L, orderProposalHorizonGroupingId#5510463L, splitIndicator#5510464L, previousOrderProposal#5510465L, clusterId#5510466L, sequenceId#5510467L, sourceOfSupplyUuid#5510468, supplierGroup#5510469, supplier#5510470, subrange#5510471, product#5510472, plant#5510473, purchasingOrg#5510474, purchasingGroup#5510475, mrpController#5510476, orderDateTime#5510477, deliveryDateTime#5510478, availabilityDateTime#5510479, nextAvailabilityDateTime#5510480, isFallbackOrderOnly#5510481, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#5510502L, orderProposalItemId#5510503, supplierGroup#5510504, supplier#5510505, plant#5510506, deliveryDateTime#5510507, subrange#5510508, supplyingPlant#5510509, productGroup#5510510, product#5510511, orderDateTime#5510512, availabilityDateTime#5510513, nextAvailabilityDateTime#5510514, mrpController#5510515, sourceOfSupplyUuid#5510516, purchasingOrg#5510517, purchasingGroup#5510518, isFallbackOrderOnly#5510519, orderProposalHorizonGroupingId#5510520L, splitIndicator#5510521L, previousOrderProposal#5510522L, clusterId#5510523L, sequenceId#5510524, worklistShardItemId#5510525L, orderProposalItemGroupId#5510526, ... 20 more fields], false
(5) Filter
Arguments: (shardId#5510546 = 0_1_10000001445)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#5510525L], 37
(7) Filter
Arguments: (sequenceId#5510524 = 7)
(8) Project
Arguments: [orderProposalId#5510502L, orderProposalItemId#5510503, supplierGroup#5510504, supplier#5510505, plant#5510506, deliveryDateTime#5510507, subrange#5510508, supplyingPlant#5510509, productGroup#5510510, product#5510511, orderDateTime#5510512, availabilityDateTime#5510513, nextAvailabilityDateTime#5510514, mrpController#5510515, sourceOfSupplyUuid#5510516, purchasingOrg#5510517, purchasingGroup#5510518, isFallbackOrderOnly#5510519, orderProposalHorizonGroupingId#5510520L, splitIndicator#5510521L, previousOrderProposal#5510522L, clusterId#5510523L, sequenceId#5510524, worklistShardItemId#5510525L, orderProposalItemGroupId#5510526, ... 20 more fields]
(9) Project
Arguments: [shardId#5510548, worklistShardItemId#5510525L, orderProposalId#5510502L, orderProposalItemId#5510503, orderProposalItemGroupId#5510526, originalReplenishmentRunId#5510544L, orderProposalHorizonGroupingId#5510520L, splitIndicator#5510521L, previousOrderProposal#5510522L, clusterId#5510523L, sequenceId#5510524, sourceOfSupplyUuid#5510516, supplierGroup#5510504, supplier#5510505, subrange#5510508, product#5510511, plant#5510506, purchasingOrg#5510517, purchasingGroup#5510518, mrpController#5510515, orderDateTime#5510512, deliveryDateTime#5510507, availabilityDateTime#5510513, nextAvailabilityDateTime#5510514, isFallbackOrderOnly#5510519, ... 20 more fields]
(10) Project
Arguments: [shardId#5510548, worklistShardItemId#5510525L, orderProposalId#5510502L, orderProposalItemId#5510503, orderProposalItemGroupId#5510526, originalReplenishmentRunId#5510544L, orderProposalHorizonGroupingId#5510520L, splitIndicator#5510521L, previousOrderProposal#5510522L, clusterId#5510523L, cast(sequenceId#5510524 as bigint) AS sequenceId#5510549L, sourceOfSupplyUuid#5510516, supplierGroup#5510504, supplier#5510505, subrange#5510508, product#5510511, plant#5510506, purchasingOrg#5510517, purchasingGroup#5510518, mrpController#5510515, orderDateTime#5510512, deliveryDateTime#5510507, availabilityDateTime#5510513, nextAvailabilityDateTime#5510514, isFallbackOrderOnly#5510519, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#5510480) AND (nextAvailabilityDateTime#5510480 > availabilityDateTime#5510479))
(13) Project
Arguments: [shardId#5510457, worklistShardItemId#5510458L, product#5510472, plant#5510473, availabilityDateTime#5510479, nextAvailabilityDateTime#5510480]
(14) Project
Arguments: [shardId#5510457, worklistShardItemId#5510458L, product#5510472, plant#5510473, availabilityDateTime#5510479, nextAvailabilityDateTime#5510480, 0 AS version#5512715]
(15) Project
Arguments: [shardId#5510457, worklistShardItemId#5510458L, product#5510472, plant#5510473, availabilityDateTime#5510479 AS periodStart#5512716, nextAvailabilityDateTime#5510480, version#5512715]
(16) Project
Arguments: [shardId#5510457, worklistShardItemId#5510458L, product#5510472, plant#5510473, periodStart#5512716, nextAvailabilityDateTime#5510480 AS periodEnd#5512717, version#5512715]
(17) Project
Arguments: [shardId#5510457, worklistShardItemId#5510458L, product#5510472, plant#5510473, periodStart#5512716, periodEnd#5512717, version#5512715, cast(null as double) AS qty#5512718]