== 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@3a233223, [path=hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000532/stream-10000000532-2], Append
(3) LocalRelation
Arguments: <empty>, [shardId#3617984, worklistShardItemId#3617985L, orderProposalId#3617986L, orderProposalItemId#3617987, orderProposalItemGroupId#3617988, originalReplenishmentRunId#3617989L, orderProposalHorizonGroupingId#3617990L, splitIndicator#3617991L, previousOrderProposal#3617992L, clusterId#3617993L, sequenceId#3617994L, sourceOfSupplyUuid#3617995, supplierGroup#3617996, supplier#3617997, subrange#3617998, product#3617999, plant#3618000, purchasingOrg#3618001, purchasingGroup#3618002, mrpController#3618003, orderDateTime#3618004, deliveryDateTime#3618005, availabilityDateTime#3618006, nextAvailabilityDateTime#3618007, isFallbackOrderOnly#3618008, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3618029L, orderProposalItemId#3618030, supplierGroup#3618031, supplier#3618032, plant#3618033, deliveryDateTime#3618034, subrange#3618035, supplyingPlant#3618036, productGroup#3618037, product#3618038, orderDateTime#3618039, availabilityDateTime#3618040, nextAvailabilityDateTime#3618041, mrpController#3618042, sourceOfSupplyUuid#3618043, purchasingOrg#3618044, purchasingGroup#3618045, isFallbackOrderOnly#3618046, orderProposalHorizonGroupingId#3618047L, splitIndicator#3618048L, previousOrderProposal#3618049L, clusterId#3618050L, sequenceId#3618051, worklistShardItemId#3618052L, orderProposalItemGroupId#3618053, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3618073 = 0_5_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3618052L], 37
(7) Filter
Arguments: (sequenceId#3618051 = 6)
(8) Project
Arguments: [orderProposalId#3618029L, orderProposalItemId#3618030, supplierGroup#3618031, supplier#3618032, plant#3618033, deliveryDateTime#3618034, subrange#3618035, supplyingPlant#3618036, productGroup#3618037, product#3618038, orderDateTime#3618039, availabilityDateTime#3618040, nextAvailabilityDateTime#3618041, mrpController#3618042, sourceOfSupplyUuid#3618043, purchasingOrg#3618044, purchasingGroup#3618045, isFallbackOrderOnly#3618046, orderProposalHorizonGroupingId#3618047L, splitIndicator#3618048L, previousOrderProposal#3618049L, clusterId#3618050L, sequenceId#3618051, worklistShardItemId#3618052L, orderProposalItemGroupId#3618053, ... 20 more fields]
(9) Project
Arguments: [shardId#3618075, worklistShardItemId#3618052L, orderProposalId#3618029L, orderProposalItemId#3618030, orderProposalItemGroupId#3618053, originalReplenishmentRunId#3618071L, orderProposalHorizonGroupingId#3618047L, splitIndicator#3618048L, previousOrderProposal#3618049L, clusterId#3618050L, sequenceId#3618051, sourceOfSupplyUuid#3618043, supplierGroup#3618031, supplier#3618032, subrange#3618035, product#3618038, plant#3618033, purchasingOrg#3618044, purchasingGroup#3618045, mrpController#3618042, orderDateTime#3618039, deliveryDateTime#3618034, availabilityDateTime#3618040, nextAvailabilityDateTime#3618041, isFallbackOrderOnly#3618046, ... 20 more fields]
(10) Project
Arguments: [shardId#3618075, worklistShardItemId#3618052L, orderProposalId#3618029L, orderProposalItemId#3618030, orderProposalItemGroupId#3618053, originalReplenishmentRunId#3618071L, orderProposalHorizonGroupingId#3618047L, splitIndicator#3618048L, previousOrderProposal#3618049L, clusterId#3618050L, cast(sequenceId#3618051 as bigint) AS sequenceId#3618076L, sourceOfSupplyUuid#3618043, supplierGroup#3618031, supplier#3618032, subrange#3618035, product#3618038, plant#3618033, purchasingOrg#3618044, purchasingGroup#3618045, mrpController#3618042, orderDateTime#3618039, deliveryDateTime#3618034, availabilityDateTime#3618040, nextAvailabilityDateTime#3618041, isFallbackOrderOnly#3618046, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3618007) AND (nextAvailabilityDateTime#3618007 > availabilityDateTime#3618006))
(13) Project
Arguments: [shardId#3617984, worklistShardItemId#3617985L, product#3617999, plant#3618000, availabilityDateTime#3618006, nextAvailabilityDateTime#3618007]
(14) Project
Arguments: [shardId#3617984, worklistShardItemId#3617985L, product#3617999, plant#3618000, availabilityDateTime#3618006, nextAvailabilityDateTime#3618007, 0 AS version#3620410]
(15) Project
Arguments: [shardId#3617984, worklistShardItemId#3617985L, product#3617999, plant#3618000, availabilityDateTime#3618006 AS periodStart#3620411, nextAvailabilityDateTime#3618007, version#3620410]
(16) Project
Arguments: [shardId#3617984, worklistShardItemId#3617985L, product#3617999, plant#3618000, periodStart#3620411, nextAvailabilityDateTime#3618007 AS periodEnd#3620412, version#3620410]
(17) Project
Arguments: [shardId#3617984, worklistShardItemId#3617985L, product#3617999, plant#3618000, periodStart#3620411, periodEnd#3620412, version#3620410, cast(null as double) AS qty#3620413]