== 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@1ed542e7, [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#3379907, worklistShardItemId#3379908L, orderProposalId#3379909L, orderProposalItemId#3379910, orderProposalItemGroupId#3379911, originalReplenishmentRunId#3379912L, orderProposalHorizonGroupingId#3379913L, splitIndicator#3379914L, previousOrderProposal#3379915L, clusterId#3379916L, sequenceId#3379917L, sourceOfSupplyUuid#3379918, supplierGroup#3379919, supplier#3379920, subrange#3379921, product#3379922, plant#3379923, purchasingOrg#3379924, purchasingGroup#3379925, mrpController#3379926, orderDateTime#3379927, deliveryDateTime#3379928, availabilityDateTime#3379929, nextAvailabilityDateTime#3379930, isFallbackOrderOnly#3379931, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3379952L, orderProposalItemId#3379953, supplierGroup#3379954, supplier#3379955, plant#3379956, deliveryDateTime#3379957, subrange#3379958, supplyingPlant#3379959, productGroup#3379960, product#3379961, orderDateTime#3379962, availabilityDateTime#3379963, nextAvailabilityDateTime#3379964, mrpController#3379965, sourceOfSupplyUuid#3379966, purchasingOrg#3379967, purchasingGroup#3379968, isFallbackOrderOnly#3379969, orderProposalHorizonGroupingId#3379970L, splitIndicator#3379971L, previousOrderProposal#3379972L, clusterId#3379973L, sequenceId#3379974, worklistShardItemId#3379975L, orderProposalItemGroupId#3379976, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3379996 = 0_5_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3379975L], 37
(7) Filter
Arguments: (sequenceId#3379974 = 2)
(8) Project
Arguments: [orderProposalId#3379952L, orderProposalItemId#3379953, supplierGroup#3379954, supplier#3379955, plant#3379956, deliveryDateTime#3379957, subrange#3379958, supplyingPlant#3379959, productGroup#3379960, product#3379961, orderDateTime#3379962, availabilityDateTime#3379963, nextAvailabilityDateTime#3379964, mrpController#3379965, sourceOfSupplyUuid#3379966, purchasingOrg#3379967, purchasingGroup#3379968, isFallbackOrderOnly#3379969, orderProposalHorizonGroupingId#3379970L, splitIndicator#3379971L, previousOrderProposal#3379972L, clusterId#3379973L, sequenceId#3379974, worklistShardItemId#3379975L, orderProposalItemGroupId#3379976, ... 20 more fields]
(9) Project
Arguments: [shardId#3379998, worklistShardItemId#3379975L, orderProposalId#3379952L, orderProposalItemId#3379953, orderProposalItemGroupId#3379976, originalReplenishmentRunId#3379994L, orderProposalHorizonGroupingId#3379970L, splitIndicator#3379971L, previousOrderProposal#3379972L, clusterId#3379973L, sequenceId#3379974, sourceOfSupplyUuid#3379966, supplierGroup#3379954, supplier#3379955, subrange#3379958, product#3379961, plant#3379956, purchasingOrg#3379967, purchasingGroup#3379968, mrpController#3379965, orderDateTime#3379962, deliveryDateTime#3379957, availabilityDateTime#3379963, nextAvailabilityDateTime#3379964, isFallbackOrderOnly#3379969, ... 20 more fields]
(10) Project
Arguments: [shardId#3379998, worklistShardItemId#3379975L, orderProposalId#3379952L, orderProposalItemId#3379953, orderProposalItemGroupId#3379976, originalReplenishmentRunId#3379994L, orderProposalHorizonGroupingId#3379970L, splitIndicator#3379971L, previousOrderProposal#3379972L, clusterId#3379973L, cast(sequenceId#3379974 as bigint) AS sequenceId#3379999L, sourceOfSupplyUuid#3379966, supplierGroup#3379954, supplier#3379955, subrange#3379958, product#3379961, plant#3379956, purchasingOrg#3379967, purchasingGroup#3379968, mrpController#3379965, orderDateTime#3379962, deliveryDateTime#3379957, availabilityDateTime#3379963, nextAvailabilityDateTime#3379964, isFallbackOrderOnly#3379969, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3379930) AND (nextAvailabilityDateTime#3379930 > availabilityDateTime#3379929))
(13) Project
Arguments: [shardId#3379907, worklistShardItemId#3379908L, product#3379922, plant#3379923, availabilityDateTime#3379929, nextAvailabilityDateTime#3379930]
(14) Project
Arguments: [shardId#3379907, worklistShardItemId#3379908L, product#3379922, plant#3379923, availabilityDateTime#3379929, nextAvailabilityDateTime#3379930, 0 AS version#3382165]
(15) Project
Arguments: [shardId#3379907, worklistShardItemId#3379908L, product#3379922, plant#3379923, availabilityDateTime#3379929 AS periodStart#3382166, nextAvailabilityDateTime#3379930, version#3382165]
(16) Project
Arguments: [shardId#3379907, worklistShardItemId#3379908L, product#3379922, plant#3379923, periodStart#3382166, nextAvailabilityDateTime#3379930 AS periodEnd#3382167, version#3382165]
(17) Project
Arguments: [shardId#3379907, worklistShardItemId#3379908L, product#3379922, plant#3379923, periodStart#3382166, periodEnd#3382167, version#3382165, cast(null as double) AS qty#3382168]