== 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@47410db4, [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#5555445, worklistShardItemId#5555446L, orderProposalId#5555447L, orderProposalItemId#5555448, orderProposalItemGroupId#5555449, originalReplenishmentRunId#5555450L, orderProposalHorizonGroupingId#5555451L, splitIndicator#5555452L, previousOrderProposal#5555453L, clusterId#5555454L, sequenceId#5555455L, sourceOfSupplyUuid#5555456, supplierGroup#5555457, supplier#5555458, subrange#5555459, product#5555460, plant#5555461, purchasingOrg#5555462, purchasingGroup#5555463, mrpController#5555464, orderDateTime#5555465, deliveryDateTime#5555466, availabilityDateTime#5555467, nextAvailabilityDateTime#5555468, isFallbackOrderOnly#5555469, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#5555490L, orderProposalItemId#5555491, supplierGroup#5555492, supplier#5555493, plant#5555494, deliveryDateTime#5555495, subrange#5555496, supplyingPlant#5555497, productGroup#5555498, product#5555499, orderDateTime#5555500, availabilityDateTime#5555501, nextAvailabilityDateTime#5555502, mrpController#5555503, sourceOfSupplyUuid#5555504, purchasingOrg#5555505, purchasingGroup#5555506, isFallbackOrderOnly#5555507, orderProposalHorizonGroupingId#5555508L, splitIndicator#5555509L, previousOrderProposal#5555510L, clusterId#5555511L, sequenceId#5555512, worklistShardItemId#5555513L, orderProposalItemGroupId#5555514, ... 20 more fields], false
(5) Filter
Arguments: (shardId#5555534 = 0_1_10000001445)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#5555513L], 37
(7) Filter
Arguments: (sequenceId#5555512 = 8)
(8) Project
Arguments: [orderProposalId#5555490L, orderProposalItemId#5555491, supplierGroup#5555492, supplier#5555493, plant#5555494, deliveryDateTime#5555495, subrange#5555496, supplyingPlant#5555497, productGroup#5555498, product#5555499, orderDateTime#5555500, availabilityDateTime#5555501, nextAvailabilityDateTime#5555502, mrpController#5555503, sourceOfSupplyUuid#5555504, purchasingOrg#5555505, purchasingGroup#5555506, isFallbackOrderOnly#5555507, orderProposalHorizonGroupingId#5555508L, splitIndicator#5555509L, previousOrderProposal#5555510L, clusterId#5555511L, sequenceId#5555512, worklistShardItemId#5555513L, orderProposalItemGroupId#5555514, ... 20 more fields]
(9) Project
Arguments: [shardId#5555536, worklistShardItemId#5555513L, orderProposalId#5555490L, orderProposalItemId#5555491, orderProposalItemGroupId#5555514, originalReplenishmentRunId#5555532L, orderProposalHorizonGroupingId#5555508L, splitIndicator#5555509L, previousOrderProposal#5555510L, clusterId#5555511L, sequenceId#5555512, sourceOfSupplyUuid#5555504, supplierGroup#5555492, supplier#5555493, subrange#5555496, product#5555499, plant#5555494, purchasingOrg#5555505, purchasingGroup#5555506, mrpController#5555503, orderDateTime#5555500, deliveryDateTime#5555495, availabilityDateTime#5555501, nextAvailabilityDateTime#5555502, isFallbackOrderOnly#5555507, ... 20 more fields]
(10) Project
Arguments: [shardId#5555536, worklistShardItemId#5555513L, orderProposalId#5555490L, orderProposalItemId#5555491, orderProposalItemGroupId#5555514, originalReplenishmentRunId#5555532L, orderProposalHorizonGroupingId#5555508L, splitIndicator#5555509L, previousOrderProposal#5555510L, clusterId#5555511L, cast(sequenceId#5555512 as bigint) AS sequenceId#5555537L, sourceOfSupplyUuid#5555504, supplierGroup#5555492, supplier#5555493, subrange#5555496, product#5555499, plant#5555494, purchasingOrg#5555505, purchasingGroup#5555506, mrpController#5555503, orderDateTime#5555500, deliveryDateTime#5555495, availabilityDateTime#5555501, nextAvailabilityDateTime#5555502, isFallbackOrderOnly#5555507, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#5555468) AND (nextAvailabilityDateTime#5555468 > availabilityDateTime#5555467))
(13) Project
Arguments: [shardId#5555445, worklistShardItemId#5555446L, product#5555460, plant#5555461, availabilityDateTime#5555467, nextAvailabilityDateTime#5555468]
(14) Project
Arguments: [shardId#5555445, worklistShardItemId#5555446L, product#5555460, plant#5555461, availabilityDateTime#5555467, nextAvailabilityDateTime#5555468, 0 AS version#5557703]
(15) Project
Arguments: [shardId#5555445, worklistShardItemId#5555446L, product#5555460, plant#5555461, availabilityDateTime#5555467 AS periodStart#5557704, nextAvailabilityDateTime#5555468, version#5557703]
(16) Project
Arguments: [shardId#5555445, worklistShardItemId#5555446L, product#5555460, plant#5555461, periodStart#5557704, nextAvailabilityDateTime#5555468 AS periodEnd#5557705, version#5557703]
(17) Project
Arguments: [shardId#5555445, worklistShardItemId#5555446L, product#5555460, plant#5555461, periodStart#5557704, periodEnd#5557705, version#5557703, cast(null as double) AS qty#5557706]