== 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@8918db0, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002106/stream-10000002106-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#611914, worklistShardItemId#611915L, orderProposalId#611916L, orderProposalItemId#611917, orderProposalItemGroupId#611918, originalReplenishmentRunId#611919L, orderProposalHorizonGroupingId#611920L, splitIndicator#611921L, previousOrderProposal#611922L, clusterId#611923L, sequenceId#611924L, sourceOfSupplyUuid#611925, supplierGroup#611926, supplier#611927, subrange#611928, product#611929, plant#611930, purchasingOrg#611931, purchasingGroup#611932, mrpController#611933, orderDateTime#611934, deliveryDateTime#611935, availabilityDateTime#611936, nextAvailabilityDateTime#611937, isFallbackOrderOnly#611938, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#612095L, orderProposalItemId#612096, supplierGroup#612097, supplier#612098, plant#612099, deliveryDateTime#612100, subrange#612101, supplyingPlant#612102, productGroup#612103, product#612104, orderDateTime#612105, availabilityDateTime#612106, nextAvailabilityDateTime#612107, mrpController#612108, sourceOfSupplyUuid#612109, purchasingOrg#612110, purchasingGroup#612111, isFallbackOrderOnly#612112, orderProposalHorizonGroupingId#612113L, splitIndicator#612114L, previousOrderProposal#612115L, clusterId#612116L, sequenceId#612117, worklistShardItemId#612118L, orderProposalItemGroupId#612119, ... 20 more fields], false
(5) Filter
Arguments: (shardId#612139 = 0_1_10000002106)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#612118L], 25
(7) Filter
Arguments: (sequenceId#612117 = 2)
(8) Project
Arguments: [orderProposalId#612095L, orderProposalItemId#612096, supplierGroup#612097, supplier#612098, plant#612099, deliveryDateTime#612100, subrange#612101, supplyingPlant#612102, productGroup#612103, product#612104, orderDateTime#612105, availabilityDateTime#612106, nextAvailabilityDateTime#612107, mrpController#612108, sourceOfSupplyUuid#612109, purchasingOrg#612110, purchasingGroup#612111, isFallbackOrderOnly#612112, orderProposalHorizonGroupingId#612113L, splitIndicator#612114L, previousOrderProposal#612115L, clusterId#612116L, sequenceId#612117, worklistShardItemId#612118L, orderProposalItemGroupId#612119, ... 20 more fields]
(9) Project
Arguments: [shardId#612141, worklistShardItemId#612118L, orderProposalId#612095L, orderProposalItemId#612096, orderProposalItemGroupId#612119, originalReplenishmentRunId#612137L, orderProposalHorizonGroupingId#612113L, splitIndicator#612114L, previousOrderProposal#612115L, clusterId#612116L, sequenceId#612117, sourceOfSupplyUuid#612109, supplierGroup#612097, supplier#612098, subrange#612101, product#612104, plant#612099, purchasingOrg#612110, purchasingGroup#612111, mrpController#612108, orderDateTime#612105, deliveryDateTime#612100, availabilityDateTime#612106, nextAvailabilityDateTime#612107, isFallbackOrderOnly#612112, ... 20 more fields]
(10) Project
Arguments: [shardId#612141, worklistShardItemId#612118L, orderProposalId#612095L, orderProposalItemId#612096, orderProposalItemGroupId#612119, originalReplenishmentRunId#612137L, orderProposalHorizonGroupingId#612113L, splitIndicator#612114L, previousOrderProposal#612115L, clusterId#612116L, cast(sequenceId#612117 as bigint) AS sequenceId#612142L, sourceOfSupplyUuid#612109, supplierGroup#612097, supplier#612098, subrange#612101, product#612104, plant#612099, purchasingOrg#612110, purchasingGroup#612111, mrpController#612108, orderDateTime#612105, deliveryDateTime#612100, availabilityDateTime#612106, nextAvailabilityDateTime#612107, isFallbackOrderOnly#612112, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#611937) AND (nextAvailabilityDateTime#611937 > availabilityDateTime#611936))
(13) Project
Arguments: [shardId#611914, worklistShardItemId#611915L, product#611929, plant#611930, availabilityDateTime#611936, nextAvailabilityDateTime#611937]
(14) Project
Arguments: [shardId#611914, worklistShardItemId#611915L, product#611929, plant#611930, availabilityDateTime#611936, nextAvailabilityDateTime#611937, 0 AS version#614428]
(15) Project
Arguments: [shardId#611914, worklistShardItemId#611915L, product#611929, plant#611930, availabilityDateTime#611936 AS periodStart#614429, nextAvailabilityDateTime#611937, version#614428]
(16) Project
Arguments: [shardId#611914, worklistShardItemId#611915L, product#611929, plant#611930, periodStart#614429, nextAvailabilityDateTime#611937 AS periodEnd#614430, version#614428]
(17) Project
Arguments: [shardId#611914, worklistShardItemId#611915L, product#611929, plant#611930, periodStart#614429, periodEnd#614430, version#614428, cast(null as double) AS qty#614431]