== 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@6293a191, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002110/stream-10000002110-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#922933, worklistShardItemId#922934L, orderProposalId#922935L, orderProposalItemId#922936, orderProposalItemGroupId#922937, originalReplenishmentRunId#922938L, orderProposalHorizonGroupingId#922939L, splitIndicator#922940L, previousOrderProposal#922941L, clusterId#922942L, sequenceId#922943L, sourceOfSupplyUuid#922944, supplierGroup#922945, supplier#922946, subrange#922947, product#922948, plant#922949, purchasingOrg#922950, purchasingGroup#922951, mrpController#922952, orderDateTime#922953, deliveryDateTime#922954, availabilityDateTime#922955, nextAvailabilityDateTime#922956, isFallbackOrderOnly#922957, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#922978L, orderProposalItemId#922979, supplierGroup#922980, supplier#922981, plant#922982, deliveryDateTime#922983, subrange#922984, supplyingPlant#922985, productGroup#922986, product#922987, orderDateTime#922988, availabilityDateTime#922989, nextAvailabilityDateTime#922990, mrpController#922991, sourceOfSupplyUuid#922992, purchasingOrg#922993, purchasingGroup#922994, isFallbackOrderOnly#922995, orderProposalHorizonGroupingId#922996L, splitIndicator#922997L, previousOrderProposal#922998L, clusterId#922999L, sequenceId#923000, worklistShardItemId#923001L, orderProposalItemGroupId#923002, ... 20 more fields], false
(5) Filter
Arguments: (shardId#923022 = 0_1_10000002110)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#923001L], 25
(7) Filter
Arguments: (sequenceId#923000 = 0)
(8) Project
Arguments: [orderProposalId#922978L, orderProposalItemId#922979, supplierGroup#922980, supplier#922981, plant#922982, deliveryDateTime#922983, subrange#922984, supplyingPlant#922985, productGroup#922986, product#922987, orderDateTime#922988, availabilityDateTime#922989, nextAvailabilityDateTime#922990, mrpController#922991, sourceOfSupplyUuid#922992, purchasingOrg#922993, purchasingGroup#922994, isFallbackOrderOnly#922995, orderProposalHorizonGroupingId#922996L, splitIndicator#922997L, previousOrderProposal#922998L, clusterId#922999L, sequenceId#923000, worklistShardItemId#923001L, orderProposalItemGroupId#923002, ... 20 more fields]
(9) Project
Arguments: [shardId#923024, worklistShardItemId#923001L, orderProposalId#922978L, orderProposalItemId#922979, orderProposalItemGroupId#923002, originalReplenishmentRunId#923020L, orderProposalHorizonGroupingId#922996L, splitIndicator#922997L, previousOrderProposal#922998L, clusterId#922999L, sequenceId#923000, sourceOfSupplyUuid#922992, supplierGroup#922980, supplier#922981, subrange#922984, product#922987, plant#922982, purchasingOrg#922993, purchasingGroup#922994, mrpController#922991, orderDateTime#922988, deliveryDateTime#922983, availabilityDateTime#922989, nextAvailabilityDateTime#922990, isFallbackOrderOnly#922995, ... 20 more fields]
(10) Project
Arguments: [shardId#923024, worklistShardItemId#923001L, orderProposalId#922978L, orderProposalItemId#922979, orderProposalItemGroupId#923002, originalReplenishmentRunId#923020L, orderProposalHorizonGroupingId#922996L, splitIndicator#922997L, previousOrderProposal#922998L, clusterId#922999L, cast(sequenceId#923000 as bigint) AS sequenceId#923025L, sourceOfSupplyUuid#922992, supplierGroup#922980, supplier#922981, subrange#922984, product#922987, plant#922982, purchasingOrg#922993, purchasingGroup#922994, mrpController#922991, orderDateTime#922988, deliveryDateTime#922983, availabilityDateTime#922989, nextAvailabilityDateTime#922990, isFallbackOrderOnly#922995, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#922956) AND (nextAvailabilityDateTime#922956 > availabilityDateTime#922955))
(13) Project
Arguments: [shardId#922933, worklistShardItemId#922934L, product#922948, plant#922949, availabilityDateTime#922955, nextAvailabilityDateTime#922956]
(14) Project
Arguments: [shardId#922933, worklistShardItemId#922934L, product#922948, plant#922949, availabilityDateTime#922955, nextAvailabilityDateTime#922956, 0 AS version#925359]
(15) Project
Arguments: [shardId#922933, worklistShardItemId#922934L, product#922948, plant#922949, availabilityDateTime#922955 AS periodStart#925360, nextAvailabilityDateTime#922956, version#925359]
(16) Project
Arguments: [shardId#922933, worklistShardItemId#922934L, product#922948, plant#922949, periodStart#925360, nextAvailabilityDateTime#922956 AS periodEnd#925361, version#925359]
(17) Project
Arguments: [shardId#922933, worklistShardItemId#922934L, product#922948, plant#922949, periodStart#925360, periodEnd#925361, version#925359, cast(null as double) AS qty#925362]