== 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@9dd13d5, [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#3452112, worklistShardItemId#3452113L, orderProposalId#3452114L, orderProposalItemId#3452115, orderProposalItemGroupId#3452116, originalReplenishmentRunId#3452117L, orderProposalHorizonGroupingId#3452118L, splitIndicator#3452119L, previousOrderProposal#3452120L, clusterId#3452121L, sequenceId#3452122L, sourceOfSupplyUuid#3452123, supplierGroup#3452124, supplier#3452125, subrange#3452126, product#3452127, plant#3452128, purchasingOrg#3452129, purchasingGroup#3452130, mrpController#3452131, orderDateTime#3452132, deliveryDateTime#3452133, availabilityDateTime#3452134, nextAvailabilityDateTime#3452135, isFallbackOrderOnly#3452136, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3452157L, orderProposalItemId#3452158, supplierGroup#3452159, supplier#3452160, plant#3452161, deliveryDateTime#3452162, subrange#3452163, supplyingPlant#3452164, productGroup#3452165, product#3452166, orderDateTime#3452167, availabilityDateTime#3452168, nextAvailabilityDateTime#3452169, mrpController#3452170, sourceOfSupplyUuid#3452171, purchasingOrg#3452172, purchasingGroup#3452173, isFallbackOrderOnly#3452174, orderProposalHorizonGroupingId#3452175L, splitIndicator#3452176L, previousOrderProposal#3452177L, clusterId#3452178L, sequenceId#3452179, worklistShardItemId#3452180L, orderProposalItemGroupId#3452181, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3452201 = 0_5_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3452180L], 37
(7) Filter
Arguments: (sequenceId#3452179 = 4)
(8) Project
Arguments: [orderProposalId#3452157L, orderProposalItemId#3452158, supplierGroup#3452159, supplier#3452160, plant#3452161, deliveryDateTime#3452162, subrange#3452163, supplyingPlant#3452164, productGroup#3452165, product#3452166, orderDateTime#3452167, availabilityDateTime#3452168, nextAvailabilityDateTime#3452169, mrpController#3452170, sourceOfSupplyUuid#3452171, purchasingOrg#3452172, purchasingGroup#3452173, isFallbackOrderOnly#3452174, orderProposalHorizonGroupingId#3452175L, splitIndicator#3452176L, previousOrderProposal#3452177L, clusterId#3452178L, sequenceId#3452179, worklistShardItemId#3452180L, orderProposalItemGroupId#3452181, ... 20 more fields]
(9) Project
Arguments: [shardId#3452203, worklistShardItemId#3452180L, orderProposalId#3452157L, orderProposalItemId#3452158, orderProposalItemGroupId#3452181, originalReplenishmentRunId#3452199L, orderProposalHorizonGroupingId#3452175L, splitIndicator#3452176L, previousOrderProposal#3452177L, clusterId#3452178L, sequenceId#3452179, sourceOfSupplyUuid#3452171, supplierGroup#3452159, supplier#3452160, subrange#3452163, product#3452166, plant#3452161, purchasingOrg#3452172, purchasingGroup#3452173, mrpController#3452170, orderDateTime#3452167, deliveryDateTime#3452162, availabilityDateTime#3452168, nextAvailabilityDateTime#3452169, isFallbackOrderOnly#3452174, ... 20 more fields]
(10) Project
Arguments: [shardId#3452203, worklistShardItemId#3452180L, orderProposalId#3452157L, orderProposalItemId#3452158, orderProposalItemGroupId#3452181, originalReplenishmentRunId#3452199L, orderProposalHorizonGroupingId#3452175L, splitIndicator#3452176L, previousOrderProposal#3452177L, clusterId#3452178L, cast(sequenceId#3452179 as bigint) AS sequenceId#3452204L, sourceOfSupplyUuid#3452171, supplierGroup#3452159, supplier#3452160, subrange#3452163, product#3452166, plant#3452161, purchasingOrg#3452172, purchasingGroup#3452173, mrpController#3452170, orderDateTime#3452167, deliveryDateTime#3452162, availabilityDateTime#3452168, nextAvailabilityDateTime#3452169, isFallbackOrderOnly#3452174, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3452135) AND (nextAvailabilityDateTime#3452135 > availabilityDateTime#3452134))
(13) Project
Arguments: [shardId#3452112, worklistShardItemId#3452113L, product#3452127, plant#3452128, availabilityDateTime#3452134, nextAvailabilityDateTime#3452135]
(14) Project
Arguments: [shardId#3452112, worklistShardItemId#3452113L, product#3452127, plant#3452128, availabilityDateTime#3452134, nextAvailabilityDateTime#3452135, 0 AS version#3454370]
(15) Project
Arguments: [shardId#3452112, worklistShardItemId#3452113L, product#3452127, plant#3452128, availabilityDateTime#3452134 AS periodStart#3454371, nextAvailabilityDateTime#3452135, version#3454370]
(16) Project
Arguments: [shardId#3452112, worklistShardItemId#3452113L, product#3452127, plant#3452128, periodStart#3454371, nextAvailabilityDateTime#3452135 AS periodEnd#3454372, version#3454370]
(17) Project
Arguments: [shardId#3452112, worklistShardItemId#3452113L, product#3452127, plant#3452128, periodStart#3454371, periodEnd#3454372, version#3454370, cast(null as double) AS qty#3454373]