== 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@43543b5e, [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#647017, worklistShardItemId#647018L, orderProposalId#647019L, orderProposalItemId#647020, orderProposalItemGroupId#647021, originalReplenishmentRunId#647022L, orderProposalHorizonGroupingId#647023L, splitIndicator#647024L, previousOrderProposal#647025L, clusterId#647026L, sequenceId#647027L, sourceOfSupplyUuid#647028, supplierGroup#647029, supplier#647030, subrange#647031, product#647032, plant#647033, purchasingOrg#647034, purchasingGroup#647035, mrpController#647036, orderDateTime#647037, deliveryDateTime#647038, availabilityDateTime#647039, nextAvailabilityDateTime#647040, isFallbackOrderOnly#647041, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#647062L, orderProposalItemId#647063, supplierGroup#647064, supplier#647065, plant#647066, deliveryDateTime#647067, subrange#647068, supplyingPlant#647069, productGroup#647070, product#647071, orderDateTime#647072, availabilityDateTime#647073, nextAvailabilityDateTime#647074, mrpController#647075, sourceOfSupplyUuid#647076, purchasingOrg#647077, purchasingGroup#647078, isFallbackOrderOnly#647079, orderProposalHorizonGroupingId#647080L, splitIndicator#647081L, previousOrderProposal#647082L, clusterId#647083L, sequenceId#647084, worklistShardItemId#647085L, orderProposalItemGroupId#647086, ... 20 more fields], false
(5) Filter
Arguments: (shardId#647106 = 0_1_10000002107)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#647085L], 25
(7) Filter
Arguments: (sequenceId#647084 = 4)
(8) Project
Arguments: [orderProposalId#647062L, orderProposalItemId#647063, supplierGroup#647064, supplier#647065, plant#647066, deliveryDateTime#647067, subrange#647068, supplyingPlant#647069, productGroup#647070, product#647071, orderDateTime#647072, availabilityDateTime#647073, nextAvailabilityDateTime#647074, mrpController#647075, sourceOfSupplyUuid#647076, purchasingOrg#647077, purchasingGroup#647078, isFallbackOrderOnly#647079, orderProposalHorizonGroupingId#647080L, splitIndicator#647081L, previousOrderProposal#647082L, clusterId#647083L, sequenceId#647084, worklistShardItemId#647085L, orderProposalItemGroupId#647086, ... 20 more fields]
(9) Project
Arguments: [shardId#647108, worklistShardItemId#647085L, orderProposalId#647062L, orderProposalItemId#647063, orderProposalItemGroupId#647086, originalReplenishmentRunId#647104L, orderProposalHorizonGroupingId#647080L, splitIndicator#647081L, previousOrderProposal#647082L, clusterId#647083L, sequenceId#647084, sourceOfSupplyUuid#647076, supplierGroup#647064, supplier#647065, subrange#647068, product#647071, plant#647066, purchasingOrg#647077, purchasingGroup#647078, mrpController#647075, orderDateTime#647072, deliveryDateTime#647067, availabilityDateTime#647073, nextAvailabilityDateTime#647074, isFallbackOrderOnly#647079, ... 20 more fields]
(10) Project
Arguments: [shardId#647108, worklistShardItemId#647085L, orderProposalId#647062L, orderProposalItemId#647063, orderProposalItemGroupId#647086, originalReplenishmentRunId#647104L, orderProposalHorizonGroupingId#647080L, splitIndicator#647081L, previousOrderProposal#647082L, clusterId#647083L, cast(sequenceId#647084 as bigint) AS sequenceId#647109L, sourceOfSupplyUuid#647076, supplierGroup#647064, supplier#647065, subrange#647068, product#647071, plant#647066, purchasingOrg#647077, purchasingGroup#647078, mrpController#647075, orderDateTime#647072, deliveryDateTime#647067, availabilityDateTime#647073, nextAvailabilityDateTime#647074, isFallbackOrderOnly#647079, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#647040) AND (nextAvailabilityDateTime#647040 > availabilityDateTime#647039))
(13) Project
Arguments: [shardId#647017, worklistShardItemId#647018L, product#647032, plant#647033, availabilityDateTime#647039, nextAvailabilityDateTime#647040]
(14) Project
Arguments: [shardId#647017, worklistShardItemId#647018L, product#647032, plant#647033, availabilityDateTime#647039, nextAvailabilityDateTime#647040, 0 AS version#651970]
(15) Project
Arguments: [shardId#647017, worklistShardItemId#647018L, product#647032, plant#647033, availabilityDateTime#647039 AS periodStart#651971, nextAvailabilityDateTime#647040, version#651970]
(16) Project
Arguments: [shardId#647017, worklistShardItemId#647018L, product#647032, plant#647033, periodStart#651971, nextAvailabilityDateTime#647040 AS periodEnd#651972, version#651970]
(17) Project
Arguments: [shardId#647017, worklistShardItemId#647018L, product#647032, plant#647033, periodStart#651971, periodEnd#651972, version#651970, cast(null as double) AS qty#651973]