== 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@3cdd0ef3, [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#1055820, worklistShardItemId#1055821L, orderProposalId#1055822L, orderProposalItemId#1055823, orderProposalItemGroupId#1055824, originalReplenishmentRunId#1055825L, orderProposalHorizonGroupingId#1055826L, splitIndicator#1055827L, previousOrderProposal#1055828L, clusterId#1055829L, sequenceId#1055830L, sourceOfSupplyUuid#1055831, supplierGroup#1055832, supplier#1055833, subrange#1055834, product#1055835, plant#1055836, purchasingOrg#1055837, purchasingGroup#1055838, mrpController#1055839, orderDateTime#1055840, deliveryDateTime#1055841, availabilityDateTime#1055842, nextAvailabilityDateTime#1055843, isFallbackOrderOnly#1055844, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#1055865L, orderProposalItemId#1055866, supplierGroup#1055867, supplier#1055868, plant#1055869, deliveryDateTime#1055870, subrange#1055871, supplyingPlant#1055872, productGroup#1055873, product#1055874, orderDateTime#1055875, availabilityDateTime#1055876, nextAvailabilityDateTime#1055877, mrpController#1055878, sourceOfSupplyUuid#1055879, purchasingOrg#1055880, purchasingGroup#1055881, isFallbackOrderOnly#1055882, orderProposalHorizonGroupingId#1055883L, splitIndicator#1055884L, previousOrderProposal#1055885L, clusterId#1055886L, sequenceId#1055887, worklistShardItemId#1055888L, orderProposalItemGroupId#1055889, ... 20 more fields], false
(5) Filter
Arguments: (shardId#1055909 = 0_1_10000002111)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#1055888L], 25
(7) Filter
Arguments: (sequenceId#1055887 = 2)
(8) Project
Arguments: [orderProposalId#1055865L, orderProposalItemId#1055866, supplierGroup#1055867, supplier#1055868, plant#1055869, deliveryDateTime#1055870, subrange#1055871, supplyingPlant#1055872, productGroup#1055873, product#1055874, orderDateTime#1055875, availabilityDateTime#1055876, nextAvailabilityDateTime#1055877, mrpController#1055878, sourceOfSupplyUuid#1055879, purchasingOrg#1055880, purchasingGroup#1055881, isFallbackOrderOnly#1055882, orderProposalHorizonGroupingId#1055883L, splitIndicator#1055884L, previousOrderProposal#1055885L, clusterId#1055886L, sequenceId#1055887, worklistShardItemId#1055888L, orderProposalItemGroupId#1055889, ... 20 more fields]
(9) Project
Arguments: [shardId#1055911, worklistShardItemId#1055888L, orderProposalId#1055865L, orderProposalItemId#1055866, orderProposalItemGroupId#1055889, originalReplenishmentRunId#1055907L, orderProposalHorizonGroupingId#1055883L, splitIndicator#1055884L, previousOrderProposal#1055885L, clusterId#1055886L, sequenceId#1055887, sourceOfSupplyUuid#1055879, supplierGroup#1055867, supplier#1055868, subrange#1055871, product#1055874, plant#1055869, purchasingOrg#1055880, purchasingGroup#1055881, mrpController#1055878, orderDateTime#1055875, deliveryDateTime#1055870, availabilityDateTime#1055876, nextAvailabilityDateTime#1055877, isFallbackOrderOnly#1055882, ... 20 more fields]
(10) Project
Arguments: [shardId#1055911, worklistShardItemId#1055888L, orderProposalId#1055865L, orderProposalItemId#1055866, orderProposalItemGroupId#1055889, originalReplenishmentRunId#1055907L, orderProposalHorizonGroupingId#1055883L, splitIndicator#1055884L, previousOrderProposal#1055885L, clusterId#1055886L, cast(sequenceId#1055887 as bigint) AS sequenceId#1055912L, sourceOfSupplyUuid#1055879, supplierGroup#1055867, supplier#1055868, subrange#1055871, product#1055874, plant#1055869, purchasingOrg#1055880, purchasingGroup#1055881, mrpController#1055878, orderDateTime#1055875, deliveryDateTime#1055870, availabilityDateTime#1055876, nextAvailabilityDateTime#1055877, isFallbackOrderOnly#1055882, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#1055843) AND (nextAvailabilityDateTime#1055843 > availabilityDateTime#1055842))
(13) Project
Arguments: [shardId#1055820, worklistShardItemId#1055821L, product#1055835, plant#1055836, availabilityDateTime#1055842, nextAvailabilityDateTime#1055843]
(14) Project
Arguments: [shardId#1055820, worklistShardItemId#1055821L, product#1055835, plant#1055836, availabilityDateTime#1055842, nextAvailabilityDateTime#1055843, 0 AS version#1058078]
(15) Project
Arguments: [shardId#1055820, worklistShardItemId#1055821L, product#1055835, plant#1055836, availabilityDateTime#1055842 AS periodStart#1058079, nextAvailabilityDateTime#1055843, version#1058078]
(16) Project
Arguments: [shardId#1055820, worklistShardItemId#1055821L, product#1055835, plant#1055836, periodStart#1058079, nextAvailabilityDateTime#1055843 AS periodEnd#1058080, version#1058078]
(17) Project
Arguments: [shardId#1055820, worklistShardItemId#1055821L, product#1055835, plant#1055836, periodStart#1058079, periodEnd#1058080, version#1058078, cast(null as double) AS qty#1058081]