== 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@33c1770b, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002111/stream-10000002111-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#1079005, worklistShardItemId#1079006L, orderProposalId#1079007L, orderProposalItemId#1079008, orderProposalItemGroupId#1079009, originalReplenishmentRunId#1079010L, orderProposalHorizonGroupingId#1079011L, splitIndicator#1079012L, previousOrderProposal#1079013L, clusterId#1079014L, sequenceId#1079015L, sourceOfSupplyUuid#1079016, supplierGroup#1079017, supplier#1079018, subrange#1079019, product#1079020, plant#1079021, purchasingOrg#1079022, purchasingGroup#1079023, mrpController#1079024, orderDateTime#1079025, deliveryDateTime#1079026, availabilityDateTime#1079027, nextAvailabilityDateTime#1079028, isFallbackOrderOnly#1079029, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#1079050L, orderProposalItemId#1079051, supplierGroup#1079052, supplier#1079053, plant#1079054, deliveryDateTime#1079055, subrange#1079056, supplyingPlant#1079057, productGroup#1079058, product#1079059, orderDateTime#1079060, availabilityDateTime#1079061, nextAvailabilityDateTime#1079062, mrpController#1079063, sourceOfSupplyUuid#1079064, purchasingOrg#1079065, purchasingGroup#1079066, isFallbackOrderOnly#1079067, orderProposalHorizonGroupingId#1079068L, splitIndicator#1079069L, previousOrderProposal#1079070L, clusterId#1079071L, sequenceId#1079072, worklistShardItemId#1079073L, orderProposalItemGroupId#1079074, ... 20 more fields], false
(5) Filter
Arguments: (shardId#1079094 = 0_1_10000002111)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#1079073L], 25
(7) Filter
Arguments: (sequenceId#1079072 = 3)
(8) Project
Arguments: [orderProposalId#1079050L, orderProposalItemId#1079051, supplierGroup#1079052, supplier#1079053, plant#1079054, deliveryDateTime#1079055, subrange#1079056, supplyingPlant#1079057, productGroup#1079058, product#1079059, orderDateTime#1079060, availabilityDateTime#1079061, nextAvailabilityDateTime#1079062, mrpController#1079063, sourceOfSupplyUuid#1079064, purchasingOrg#1079065, purchasingGroup#1079066, isFallbackOrderOnly#1079067, orderProposalHorizonGroupingId#1079068L, splitIndicator#1079069L, previousOrderProposal#1079070L, clusterId#1079071L, sequenceId#1079072, worklistShardItemId#1079073L, orderProposalItemGroupId#1079074, ... 20 more fields]
(9) Project
Arguments: [shardId#1079096, worklistShardItemId#1079073L, orderProposalId#1079050L, orderProposalItemId#1079051, orderProposalItemGroupId#1079074, originalReplenishmentRunId#1079092L, orderProposalHorizonGroupingId#1079068L, splitIndicator#1079069L, previousOrderProposal#1079070L, clusterId#1079071L, sequenceId#1079072, sourceOfSupplyUuid#1079064, supplierGroup#1079052, supplier#1079053, subrange#1079056, product#1079059, plant#1079054, purchasingOrg#1079065, purchasingGroup#1079066, mrpController#1079063, orderDateTime#1079060, deliveryDateTime#1079055, availabilityDateTime#1079061, nextAvailabilityDateTime#1079062, isFallbackOrderOnly#1079067, ... 20 more fields]
(10) Project
Arguments: [shardId#1079096, worklistShardItemId#1079073L, orderProposalId#1079050L, orderProposalItemId#1079051, orderProposalItemGroupId#1079074, originalReplenishmentRunId#1079092L, orderProposalHorizonGroupingId#1079068L, splitIndicator#1079069L, previousOrderProposal#1079070L, clusterId#1079071L, cast(sequenceId#1079072 as bigint) AS sequenceId#1079097L, sourceOfSupplyUuid#1079064, supplierGroup#1079052, supplier#1079053, subrange#1079056, product#1079059, plant#1079054, purchasingOrg#1079065, purchasingGroup#1079066, mrpController#1079063, orderDateTime#1079060, deliveryDateTime#1079055, availabilityDateTime#1079061, nextAvailabilityDateTime#1079062, isFallbackOrderOnly#1079067, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#1079028) AND (nextAvailabilityDateTime#1079028 > availabilityDateTime#1079027))
(13) Project
Arguments: [shardId#1079005, worklistShardItemId#1079006L, product#1079020, plant#1079021, availabilityDateTime#1079027, nextAvailabilityDateTime#1079028]
(14) Project
Arguments: [shardId#1079005, worklistShardItemId#1079006L, product#1079020, plant#1079021, availabilityDateTime#1079027, nextAvailabilityDateTime#1079028, 0 AS version#1081263]
(15) Project
Arguments: [shardId#1079005, worklistShardItemId#1079006L, product#1079020, plant#1079021, availabilityDateTime#1079027 AS periodStart#1081264, nextAvailabilityDateTime#1079028, version#1081263]
(16) Project
Arguments: [shardId#1079005, worklistShardItemId#1079006L, product#1079020, plant#1079021, periodStart#1081264, nextAvailabilityDateTime#1079028 AS periodEnd#1081265, version#1081263]
(17) Project
Arguments: [shardId#1079005, worklistShardItemId#1079006L, product#1079020, plant#1079021, periodStart#1081264, periodEnd#1081265, version#1081263, cast(null as double) AS qty#1081266]