== 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@75764aab, [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#3494814, worklistShardItemId#3494815L, orderProposalId#3494816L, orderProposalItemId#3494817, orderProposalItemGroupId#3494818, originalReplenishmentRunId#3494819L, orderProposalHorizonGroupingId#3494820L, splitIndicator#3494821L, previousOrderProposal#3494822L, clusterId#3494823L, sequenceId#3494824L, sourceOfSupplyUuid#3494825, supplierGroup#3494826, supplier#3494827, subrange#3494828, product#3494829, plant#3494830, purchasingOrg#3494831, purchasingGroup#3494832, mrpController#3494833, orderDateTime#3494834, deliveryDateTime#3494835, availabilityDateTime#3494836, nextAvailabilityDateTime#3494837, isFallbackOrderOnly#3494838, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3494859L, orderProposalItemId#3494860, supplierGroup#3494861, supplier#3494862, plant#3494863, deliveryDateTime#3494864, subrange#3494865, supplyingPlant#3494866, productGroup#3494867, product#3494868, orderDateTime#3494869, availabilityDateTime#3494870, nextAvailabilityDateTime#3494871, mrpController#3494872, sourceOfSupplyUuid#3494873, purchasingOrg#3494874, purchasingGroup#3494875, isFallbackOrderOnly#3494876, orderProposalHorizonGroupingId#3494877L, splitIndicator#3494878L, previousOrderProposal#3494879L, clusterId#3494880L, sequenceId#3494881, worklistShardItemId#3494882L, orderProposalItemGroupId#3494883, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3494903 = 0_5_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3494882L], 37
(7) Filter
Arguments: (sequenceId#3494881 = 6)
(8) Project
Arguments: [orderProposalId#3494859L, orderProposalItemId#3494860, supplierGroup#3494861, supplier#3494862, plant#3494863, deliveryDateTime#3494864, subrange#3494865, supplyingPlant#3494866, productGroup#3494867, product#3494868, orderDateTime#3494869, availabilityDateTime#3494870, nextAvailabilityDateTime#3494871, mrpController#3494872, sourceOfSupplyUuid#3494873, purchasingOrg#3494874, purchasingGroup#3494875, isFallbackOrderOnly#3494876, orderProposalHorizonGroupingId#3494877L, splitIndicator#3494878L, previousOrderProposal#3494879L, clusterId#3494880L, sequenceId#3494881, worklistShardItemId#3494882L, orderProposalItemGroupId#3494883, ... 20 more fields]
(9) Project
Arguments: [shardId#3494905, worklistShardItemId#3494882L, orderProposalId#3494859L, orderProposalItemId#3494860, orderProposalItemGroupId#3494883, originalReplenishmentRunId#3494901L, orderProposalHorizonGroupingId#3494877L, splitIndicator#3494878L, previousOrderProposal#3494879L, clusterId#3494880L, sequenceId#3494881, sourceOfSupplyUuid#3494873, supplierGroup#3494861, supplier#3494862, subrange#3494865, product#3494868, plant#3494863, purchasingOrg#3494874, purchasingGroup#3494875, mrpController#3494872, orderDateTime#3494869, deliveryDateTime#3494864, availabilityDateTime#3494870, nextAvailabilityDateTime#3494871, isFallbackOrderOnly#3494876, ... 20 more fields]
(10) Project
Arguments: [shardId#3494905, worklistShardItemId#3494882L, orderProposalId#3494859L, orderProposalItemId#3494860, orderProposalItemGroupId#3494883, originalReplenishmentRunId#3494901L, orderProposalHorizonGroupingId#3494877L, splitIndicator#3494878L, previousOrderProposal#3494879L, clusterId#3494880L, cast(sequenceId#3494881 as bigint) AS sequenceId#3494906L, sourceOfSupplyUuid#3494873, supplierGroup#3494861, supplier#3494862, subrange#3494865, product#3494868, plant#3494863, purchasingOrg#3494874, purchasingGroup#3494875, mrpController#3494872, orderDateTime#3494869, deliveryDateTime#3494864, availabilityDateTime#3494870, nextAvailabilityDateTime#3494871, isFallbackOrderOnly#3494876, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3494837) AND (nextAvailabilityDateTime#3494837 > availabilityDateTime#3494836))
(13) Project
Arguments: [shardId#3494814, worklistShardItemId#3494815L, product#3494829, plant#3494830, availabilityDateTime#3494836, nextAvailabilityDateTime#3494837]
(14) Project
Arguments: [shardId#3494814, worklistShardItemId#3494815L, product#3494829, plant#3494830, availabilityDateTime#3494836, nextAvailabilityDateTime#3494837, 0 AS version#3497072]
(15) Project
Arguments: [shardId#3494814, worklistShardItemId#3494815L, product#3494829, plant#3494830, availabilityDateTime#3494836 AS periodStart#3497073, nextAvailabilityDateTime#3494837, version#3497072]
(16) Project
Arguments: [shardId#3494814, worklistShardItemId#3494815L, product#3494829, plant#3494830, periodStart#3497073, nextAvailabilityDateTime#3494837 AS periodEnd#3497074, version#3497072]
(17) Project
Arguments: [shardId#3494814, worklistShardItemId#3494815L, product#3494829, plant#3494830, periodStart#3497073, periodEnd#3497074, version#3497072, cast(null as double) AS qty#3497075]