== 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@3feabfa7, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002109/stream-10000002109-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#859038, worklistShardItemId#859039L, orderProposalId#859040L, orderProposalItemId#859041, orderProposalItemGroupId#859042, originalReplenishmentRunId#859043L, orderProposalHorizonGroupingId#859044L, splitIndicator#859045L, previousOrderProposal#859046L, clusterId#859047L, sequenceId#859048L, sourceOfSupplyUuid#859049, supplierGroup#859050, supplier#859051, subrange#859052, product#859053, plant#859054, purchasingOrg#859055, purchasingGroup#859056, mrpController#859057, orderDateTime#859058, deliveryDateTime#859059, availabilityDateTime#859060, nextAvailabilityDateTime#859061, isFallbackOrderOnly#859062, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#859083L, orderProposalItemId#859084, supplierGroup#859085, supplier#859086, plant#859087, deliveryDateTime#859088, subrange#859089, supplyingPlant#859090, productGroup#859091, product#859092, orderDateTime#859093, availabilityDateTime#859094, nextAvailabilityDateTime#859095, mrpController#859096, sourceOfSupplyUuid#859097, purchasingOrg#859098, purchasingGroup#859099, isFallbackOrderOnly#859100, orderProposalHorizonGroupingId#859101L, splitIndicator#859102L, previousOrderProposal#859103L, clusterId#859104L, sequenceId#859105, worklistShardItemId#859106L, orderProposalItemGroupId#859107, ... 20 more fields], false
(5) Filter
Arguments: (shardId#859127 = 0_1_10000002109)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#859106L], 25
(7) Filter
Arguments: (sequenceId#859105 = 1)
(8) Project
Arguments: [orderProposalId#859083L, orderProposalItemId#859084, supplierGroup#859085, supplier#859086, plant#859087, deliveryDateTime#859088, subrange#859089, supplyingPlant#859090, productGroup#859091, product#859092, orderDateTime#859093, availabilityDateTime#859094, nextAvailabilityDateTime#859095, mrpController#859096, sourceOfSupplyUuid#859097, purchasingOrg#859098, purchasingGroup#859099, isFallbackOrderOnly#859100, orderProposalHorizonGroupingId#859101L, splitIndicator#859102L, previousOrderProposal#859103L, clusterId#859104L, sequenceId#859105, worklistShardItemId#859106L, orderProposalItemGroupId#859107, ... 20 more fields]
(9) Project
Arguments: [shardId#859129, worklistShardItemId#859106L, orderProposalId#859083L, orderProposalItemId#859084, orderProposalItemGroupId#859107, originalReplenishmentRunId#859125L, orderProposalHorizonGroupingId#859101L, splitIndicator#859102L, previousOrderProposal#859103L, clusterId#859104L, sequenceId#859105, sourceOfSupplyUuid#859097, supplierGroup#859085, supplier#859086, subrange#859089, product#859092, plant#859087, purchasingOrg#859098, purchasingGroup#859099, mrpController#859096, orderDateTime#859093, deliveryDateTime#859088, availabilityDateTime#859094, nextAvailabilityDateTime#859095, isFallbackOrderOnly#859100, ... 20 more fields]
(10) Project
Arguments: [shardId#859129, worklistShardItemId#859106L, orderProposalId#859083L, orderProposalItemId#859084, orderProposalItemGroupId#859107, originalReplenishmentRunId#859125L, orderProposalHorizonGroupingId#859101L, splitIndicator#859102L, previousOrderProposal#859103L, clusterId#859104L, cast(sequenceId#859105 as bigint) AS sequenceId#859130L, sourceOfSupplyUuid#859097, supplierGroup#859085, supplier#859086, subrange#859089, product#859092, plant#859087, purchasingOrg#859098, purchasingGroup#859099, mrpController#859096, orderDateTime#859093, deliveryDateTime#859088, availabilityDateTime#859094, nextAvailabilityDateTime#859095, isFallbackOrderOnly#859100, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#859061) AND (nextAvailabilityDateTime#859061 > availabilityDateTime#859060))
(13) Project
Arguments: [shardId#859038, worklistShardItemId#859039L, product#859053, plant#859054, availabilityDateTime#859060, nextAvailabilityDateTime#859061]
(14) Project
Arguments: [shardId#859038, worklistShardItemId#859039L, product#859053, plant#859054, availabilityDateTime#859060, nextAvailabilityDateTime#859061, 0 AS version#861296]
(15) Project
Arguments: [shardId#859038, worklistShardItemId#859039L, product#859053, plant#859054, availabilityDateTime#859060 AS periodStart#861297, nextAvailabilityDateTime#859061, version#861296]
(16) Project
Arguments: [shardId#859038, worklistShardItemId#859039L, product#859053, plant#859054, periodStart#861297, nextAvailabilityDateTime#859061 AS periodEnd#861298, version#861296]
(17) Project
Arguments: [shardId#859038, worklistShardItemId#859039L, product#859053, plant#859054, periodStart#861297, periodEnd#861298, version#861296, cast(null as double) AS qty#861299]