== 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@21774718, [path=hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000532/stream-10000000532-2], Append
(3) LocalRelation
Arguments: <empty>, [shardId#3473824, worklistShardItemId#3473825L, orderProposalId#3473826L, orderProposalItemId#3473827, orderProposalItemGroupId#3473828, originalReplenishmentRunId#3473829L, orderProposalHorizonGroupingId#3473830L, splitIndicator#3473831L, previousOrderProposal#3473832L, clusterId#3473833L, sequenceId#3473834L, sourceOfSupplyUuid#3473835, supplierGroup#3473836, supplier#3473837, subrange#3473838, product#3473839, plant#3473840, purchasingOrg#3473841, purchasingGroup#3473842, mrpController#3473843, orderDateTime#3473844, deliveryDateTime#3473845, availabilityDateTime#3473846, nextAvailabilityDateTime#3473847, isFallbackOrderOnly#3473848, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3473869L, orderProposalItemId#3473870, supplierGroup#3473871, supplier#3473872, plant#3473873, deliveryDateTime#3473874, subrange#3473875, supplyingPlant#3473876, productGroup#3473877, product#3473878, orderDateTime#3473879, availabilityDateTime#3473880, nextAvailabilityDateTime#3473881, mrpController#3473882, sourceOfSupplyUuid#3473883, purchasingOrg#3473884, purchasingGroup#3473885, isFallbackOrderOnly#3473886, orderProposalHorizonGroupingId#3473887L, splitIndicator#3473888L, previousOrderProposal#3473889L, clusterId#3473890L, sequenceId#3473891, worklistShardItemId#3473892L, orderProposalItemGroupId#3473893, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3473913 = 0_5_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3473892L], 37
(7) Filter
Arguments: (sequenceId#3473891 = 5)
(8) Project
Arguments: [orderProposalId#3473869L, orderProposalItemId#3473870, supplierGroup#3473871, supplier#3473872, plant#3473873, deliveryDateTime#3473874, subrange#3473875, supplyingPlant#3473876, productGroup#3473877, product#3473878, orderDateTime#3473879, availabilityDateTime#3473880, nextAvailabilityDateTime#3473881, mrpController#3473882, sourceOfSupplyUuid#3473883, purchasingOrg#3473884, purchasingGroup#3473885, isFallbackOrderOnly#3473886, orderProposalHorizonGroupingId#3473887L, splitIndicator#3473888L, previousOrderProposal#3473889L, clusterId#3473890L, sequenceId#3473891, worklistShardItemId#3473892L, orderProposalItemGroupId#3473893, ... 20 more fields]
(9) Project
Arguments: [shardId#3473915, worklistShardItemId#3473892L, orderProposalId#3473869L, orderProposalItemId#3473870, orderProposalItemGroupId#3473893, originalReplenishmentRunId#3473911L, orderProposalHorizonGroupingId#3473887L, splitIndicator#3473888L, previousOrderProposal#3473889L, clusterId#3473890L, sequenceId#3473891, sourceOfSupplyUuid#3473883, supplierGroup#3473871, supplier#3473872, subrange#3473875, product#3473878, plant#3473873, purchasingOrg#3473884, purchasingGroup#3473885, mrpController#3473882, orderDateTime#3473879, deliveryDateTime#3473874, availabilityDateTime#3473880, nextAvailabilityDateTime#3473881, isFallbackOrderOnly#3473886, ... 20 more fields]
(10) Project
Arguments: [shardId#3473915, worklistShardItemId#3473892L, orderProposalId#3473869L, orderProposalItemId#3473870, orderProposalItemGroupId#3473893, originalReplenishmentRunId#3473911L, orderProposalHorizonGroupingId#3473887L, splitIndicator#3473888L, previousOrderProposal#3473889L, clusterId#3473890L, cast(sequenceId#3473891 as bigint) AS sequenceId#3473916L, sourceOfSupplyUuid#3473883, supplierGroup#3473871, supplier#3473872, subrange#3473875, product#3473878, plant#3473873, purchasingOrg#3473884, purchasingGroup#3473885, mrpController#3473882, orderDateTime#3473879, deliveryDateTime#3473874, availabilityDateTime#3473880, nextAvailabilityDateTime#3473881, isFallbackOrderOnly#3473886, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3473847) AND (nextAvailabilityDateTime#3473847 > availabilityDateTime#3473846))
(13) Project
Arguments: [shardId#3473824, worklistShardItemId#3473825L, product#3473839, plant#3473840, availabilityDateTime#3473846, nextAvailabilityDateTime#3473847]
(14) Project
Arguments: [shardId#3473824, worklistShardItemId#3473825L, product#3473839, plant#3473840, availabilityDateTime#3473846, nextAvailabilityDateTime#3473847, 0 AS version#3476082]
(15) Project
Arguments: [shardId#3473824, worklistShardItemId#3473825L, product#3473839, plant#3473840, availabilityDateTime#3473846 AS periodStart#3476083, nextAvailabilityDateTime#3473847, version#3476082]
(16) Project
Arguments: [shardId#3473824, worklistShardItemId#3473825L, product#3473839, plant#3473840, periodStart#3476083, nextAvailabilityDateTime#3473847 AS periodEnd#3476084, version#3476082]
(17) Project
Arguments: [shardId#3473824, worklistShardItemId#3473825L, product#3473839, plant#3473840, periodStart#3476083, periodEnd#3476084, version#3476082, cast(null as double) AS qty#3476085]