== 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@50fb19ae, [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#621088, worklistShardItemId#621089L, orderProposalId#621090L, orderProposalItemId#621091, orderProposalItemGroupId#621092, originalReplenishmentRunId#621093L, orderProposalHorizonGroupingId#621094L, splitIndicator#621095L, previousOrderProposal#621096L, clusterId#621097L, sequenceId#621098L, sourceOfSupplyUuid#621099, supplierGroup#621100, supplier#621101, subrange#621102, product#621103, plant#621104, purchasingOrg#621105, purchasingGroup#621106, mrpController#621107, orderDateTime#621108, deliveryDateTime#621109, availabilityDateTime#621110, nextAvailabilityDateTime#621111, isFallbackOrderOnly#621112, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#621133L, orderProposalItemId#621134, supplierGroup#621135, supplier#621136, plant#621137, deliveryDateTime#621138, subrange#621139, supplyingPlant#621140, productGroup#621141, product#621142, orderDateTime#621143, availabilityDateTime#621144, nextAvailabilityDateTime#621145, mrpController#621146, sourceOfSupplyUuid#621147, purchasingOrg#621148, purchasingGroup#621149, isFallbackOrderOnly#621150, orderProposalHorizonGroupingId#621151L, splitIndicator#621152L, previousOrderProposal#621153L, clusterId#621154L, sequenceId#621155, worklistShardItemId#621156L, orderProposalItemGroupId#621157, ... 20 more fields], false
(5) Filter
Arguments: (shardId#621177 = 0_1_10000002107)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#621156L], 25
(7) Filter
Arguments: (sequenceId#621155 = 3)
(8) Project
Arguments: [orderProposalId#621133L, orderProposalItemId#621134, supplierGroup#621135, supplier#621136, plant#621137, deliveryDateTime#621138, subrange#621139, supplyingPlant#621140, productGroup#621141, product#621142, orderDateTime#621143, availabilityDateTime#621144, nextAvailabilityDateTime#621145, mrpController#621146, sourceOfSupplyUuid#621147, purchasingOrg#621148, purchasingGroup#621149, isFallbackOrderOnly#621150, orderProposalHorizonGroupingId#621151L, splitIndicator#621152L, previousOrderProposal#621153L, clusterId#621154L, sequenceId#621155, worklistShardItemId#621156L, orderProposalItemGroupId#621157, ... 20 more fields]
(9) Project
Arguments: [shardId#621179, worklistShardItemId#621156L, orderProposalId#621133L, orderProposalItemId#621134, orderProposalItemGroupId#621157, originalReplenishmentRunId#621175L, orderProposalHorizonGroupingId#621151L, splitIndicator#621152L, previousOrderProposal#621153L, clusterId#621154L, sequenceId#621155, sourceOfSupplyUuid#621147, supplierGroup#621135, supplier#621136, subrange#621139, product#621142, plant#621137, purchasingOrg#621148, purchasingGroup#621149, mrpController#621146, orderDateTime#621143, deliveryDateTime#621138, availabilityDateTime#621144, nextAvailabilityDateTime#621145, isFallbackOrderOnly#621150, ... 20 more fields]
(10) Project
Arguments: [shardId#621179, worklistShardItemId#621156L, orderProposalId#621133L, orderProposalItemId#621134, orderProposalItemGroupId#621157, originalReplenishmentRunId#621175L, orderProposalHorizonGroupingId#621151L, splitIndicator#621152L, previousOrderProposal#621153L, clusterId#621154L, cast(sequenceId#621155 as bigint) AS sequenceId#621180L, sourceOfSupplyUuid#621147, supplierGroup#621135, supplier#621136, subrange#621139, product#621142, plant#621137, purchasingOrg#621148, purchasingGroup#621149, mrpController#621146, orderDateTime#621143, deliveryDateTime#621138, availabilityDateTime#621144, nextAvailabilityDateTime#621145, isFallbackOrderOnly#621150, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#621111) AND (nextAvailabilityDateTime#621111 > availabilityDateTime#621110))
(13) Project
Arguments: [shardId#621088, worklistShardItemId#621089L, product#621103, plant#621104, availabilityDateTime#621110, nextAvailabilityDateTime#621111]
(14) Project
Arguments: [shardId#621088, worklistShardItemId#621089L, product#621103, plant#621104, availabilityDateTime#621110, nextAvailabilityDateTime#621111, 0 AS version#623346]
(15) Project
Arguments: [shardId#621088, worklistShardItemId#621089L, product#621103, plant#621104, availabilityDateTime#621110 AS periodStart#623347, nextAvailabilityDateTime#621111, version#623346]
(16) Project
Arguments: [shardId#621088, worklistShardItemId#621089L, product#621103, plant#621104, periodStart#623347, nextAvailabilityDateTime#621111 AS periodEnd#623348, version#623346]
(17) Project
Arguments: [shardId#621088, worklistShardItemId#621089L, product#621103, plant#621104, periodStart#623347, periodEnd#623348, version#623346, cast(null as double) AS qty#623349]