== 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@18a31d63, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002111/stream-10000002111-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#1009043, worklistShardItemId#1009044L, orderProposalId#1009045L, orderProposalItemId#1009046, orderProposalItemGroupId#1009047, originalReplenishmentRunId#1009048L, orderProposalHorizonGroupingId#1009049L, splitIndicator#1009050L, previousOrderProposal#1009051L, clusterId#1009052L, sequenceId#1009053L, sourceOfSupplyUuid#1009054, supplierGroup#1009055, supplier#1009056, subrange#1009057, product#1009058, plant#1009059, purchasingOrg#1009060, purchasingGroup#1009061, mrpController#1009062, orderDateTime#1009063, deliveryDateTime#1009064, availabilityDateTime#1009065, nextAvailabilityDateTime#1009066, isFallbackOrderOnly#1009067, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#1009088L, orderProposalItemId#1009089, supplierGroup#1009090, supplier#1009091, plant#1009092, deliveryDateTime#1009093, subrange#1009094, supplyingPlant#1009095, productGroup#1009096, product#1009097, orderDateTime#1009098, availabilityDateTime#1009099, nextAvailabilityDateTime#1009100, mrpController#1009101, sourceOfSupplyUuid#1009102, purchasingOrg#1009103, purchasingGroup#1009104, isFallbackOrderOnly#1009105, orderProposalHorizonGroupingId#1009106L, splitIndicator#1009107L, previousOrderProposal#1009108L, clusterId#1009109L, sequenceId#1009110, worklistShardItemId#1009111L, orderProposalItemGroupId#1009112, ... 20 more fields], false
(5) Filter
Arguments: (shardId#1009132 = 0_1_10000002111)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#1009111L], 25
(7) Filter
Arguments: (sequenceId#1009110 = 0)
(8) Project
Arguments: [orderProposalId#1009088L, orderProposalItemId#1009089, supplierGroup#1009090, supplier#1009091, plant#1009092, deliveryDateTime#1009093, subrange#1009094, supplyingPlant#1009095, productGroup#1009096, product#1009097, orderDateTime#1009098, availabilityDateTime#1009099, nextAvailabilityDateTime#1009100, mrpController#1009101, sourceOfSupplyUuid#1009102, purchasingOrg#1009103, purchasingGroup#1009104, isFallbackOrderOnly#1009105, orderProposalHorizonGroupingId#1009106L, splitIndicator#1009107L, previousOrderProposal#1009108L, clusterId#1009109L, sequenceId#1009110, worklistShardItemId#1009111L, orderProposalItemGroupId#1009112, ... 20 more fields]
(9) Project
Arguments: [shardId#1009134, worklistShardItemId#1009111L, orderProposalId#1009088L, orderProposalItemId#1009089, orderProposalItemGroupId#1009112, originalReplenishmentRunId#1009130L, orderProposalHorizonGroupingId#1009106L, splitIndicator#1009107L, previousOrderProposal#1009108L, clusterId#1009109L, sequenceId#1009110, sourceOfSupplyUuid#1009102, supplierGroup#1009090, supplier#1009091, subrange#1009094, product#1009097, plant#1009092, purchasingOrg#1009103, purchasingGroup#1009104, mrpController#1009101, orderDateTime#1009098, deliveryDateTime#1009093, availabilityDateTime#1009099, nextAvailabilityDateTime#1009100, isFallbackOrderOnly#1009105, ... 20 more fields]
(10) Project
Arguments: [shardId#1009134, worklistShardItemId#1009111L, orderProposalId#1009088L, orderProposalItemId#1009089, orderProposalItemGroupId#1009112, originalReplenishmentRunId#1009130L, orderProposalHorizonGroupingId#1009106L, splitIndicator#1009107L, previousOrderProposal#1009108L, clusterId#1009109L, cast(sequenceId#1009110 as bigint) AS sequenceId#1009135L, sourceOfSupplyUuid#1009102, supplierGroup#1009090, supplier#1009091, subrange#1009094, product#1009097, plant#1009092, purchasingOrg#1009103, purchasingGroup#1009104, mrpController#1009101, orderDateTime#1009098, deliveryDateTime#1009093, availabilityDateTime#1009099, nextAvailabilityDateTime#1009100, isFallbackOrderOnly#1009105, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#1009066) AND (nextAvailabilityDateTime#1009066 > availabilityDateTime#1009065))
(13) Project
Arguments: [shardId#1009043, worklistShardItemId#1009044L, product#1009058, plant#1009059, availabilityDateTime#1009065, nextAvailabilityDateTime#1009066]
(14) Project
Arguments: [shardId#1009043, worklistShardItemId#1009044L, product#1009058, plant#1009059, availabilityDateTime#1009065, nextAvailabilityDateTime#1009066, 0 AS version#1011469]
(15) Project
Arguments: [shardId#1009043, worklistShardItemId#1009044L, product#1009058, plant#1009059, availabilityDateTime#1009065 AS periodStart#1011470, nextAvailabilityDateTime#1009066, version#1011469]
(16) Project
Arguments: [shardId#1009043, worklistShardItemId#1009044L, product#1009058, plant#1009059, periodStart#1011470, nextAvailabilityDateTime#1009066 AS periodEnd#1011471, version#1011469]
(17) Project
Arguments: [shardId#1009043, worklistShardItemId#1009044L, product#1009058, plant#1009059, periodStart#1011470, periodEnd#1011471, version#1011469, cast(null as double) AS qty#1011472]