== 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@18a811a8, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002107/stream-10000002107-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#574859, worklistShardItemId#574860L, orderProposalId#574861L, orderProposalItemId#574862, orderProposalItemGroupId#574863, originalReplenishmentRunId#574864L, orderProposalHorizonGroupingId#574865L, splitIndicator#574866L, previousOrderProposal#574867L, clusterId#574868L, sequenceId#574869L, sourceOfSupplyUuid#574870, supplierGroup#574871, supplier#574872, subrange#574873, product#574874, plant#574875, purchasingOrg#574876, purchasingGroup#574877, mrpController#574878, orderDateTime#574879, deliveryDateTime#574880, availabilityDateTime#574881, nextAvailabilityDateTime#574882, isFallbackOrderOnly#574883, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#574904L, orderProposalItemId#574905, supplierGroup#574906, supplier#574907, plant#574908, deliveryDateTime#574909, subrange#574910, supplyingPlant#574911, productGroup#574912, product#574913, orderDateTime#574914, availabilityDateTime#574915, nextAvailabilityDateTime#574916, mrpController#574917, sourceOfSupplyUuid#574918, purchasingOrg#574919, purchasingGroup#574920, isFallbackOrderOnly#574921, orderProposalHorizonGroupingId#574922L, splitIndicator#574923L, previousOrderProposal#574924L, clusterId#574925L, sequenceId#574926, worklistShardItemId#574927L, orderProposalItemGroupId#574928, ... 20 more fields], false
(5) Filter
Arguments: (shardId#574948 = 0_1_10000002107)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#574927L], 25
(7) Filter
Arguments: (sequenceId#574926 = 2)
(8) Project
Arguments: [orderProposalId#574904L, orderProposalItemId#574905, supplierGroup#574906, supplier#574907, plant#574908, deliveryDateTime#574909, subrange#574910, supplyingPlant#574911, productGroup#574912, product#574913, orderDateTime#574914, availabilityDateTime#574915, nextAvailabilityDateTime#574916, mrpController#574917, sourceOfSupplyUuid#574918, purchasingOrg#574919, purchasingGroup#574920, isFallbackOrderOnly#574921, orderProposalHorizonGroupingId#574922L, splitIndicator#574923L, previousOrderProposal#574924L, clusterId#574925L, sequenceId#574926, worklistShardItemId#574927L, orderProposalItemGroupId#574928, ... 20 more fields]
(9) Project
Arguments: [shardId#574950, worklistShardItemId#574927L, orderProposalId#574904L, orderProposalItemId#574905, orderProposalItemGroupId#574928, originalReplenishmentRunId#574946L, orderProposalHorizonGroupingId#574922L, splitIndicator#574923L, previousOrderProposal#574924L, clusterId#574925L, sequenceId#574926, sourceOfSupplyUuid#574918, supplierGroup#574906, supplier#574907, subrange#574910, product#574913, plant#574908, purchasingOrg#574919, purchasingGroup#574920, mrpController#574917, orderDateTime#574914, deliveryDateTime#574909, availabilityDateTime#574915, nextAvailabilityDateTime#574916, isFallbackOrderOnly#574921, ... 20 more fields]
(10) Project
Arguments: [shardId#574950, worklistShardItemId#574927L, orderProposalId#574904L, orderProposalItemId#574905, orderProposalItemGroupId#574928, originalReplenishmentRunId#574946L, orderProposalHorizonGroupingId#574922L, splitIndicator#574923L, previousOrderProposal#574924L, clusterId#574925L, cast(sequenceId#574926 as bigint) AS sequenceId#574951L, sourceOfSupplyUuid#574918, supplierGroup#574906, supplier#574907, subrange#574910, product#574913, plant#574908, purchasingOrg#574919, purchasingGroup#574920, mrpController#574917, orderDateTime#574914, deliveryDateTime#574909, availabilityDateTime#574915, nextAvailabilityDateTime#574916, isFallbackOrderOnly#574921, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#574882) AND (nextAvailabilityDateTime#574882 > availabilityDateTime#574881))
(13) Project
Arguments: [shardId#574859, worklistShardItemId#574860L, product#574874, plant#574875, availabilityDateTime#574881, nextAvailabilityDateTime#574882]
(14) Project
Arguments: [shardId#574859, worklistShardItemId#574860L, product#574874, plant#574875, availabilityDateTime#574881, nextAvailabilityDateTime#574882, 0 AS version#577117]
(15) Project
Arguments: [shardId#574859, worklistShardItemId#574860L, product#574874, plant#574875, availabilityDateTime#574881 AS periodStart#577118, nextAvailabilityDateTime#574882, version#577117]
(16) Project
Arguments: [shardId#574859, worklistShardItemId#574860L, product#574874, plant#574875, periodStart#577118, nextAvailabilityDateTime#574882 AS periodEnd#577119, version#577117]
(17) Project
Arguments: [shardId#574859, worklistShardItemId#574860L, product#574874, plant#574875, periodStart#577118, periodEnd#577119, version#577117, cast(null as double) AS qty#577120]