== 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@aa75664, [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-3], Append
(3) LocalRelation
Arguments: <empty>, [shardId#3502912, worklistShardItemId#3502913L, orderProposalId#3502914L, orderProposalItemId#3502915, orderProposalItemGroupId#3502916, originalReplenishmentRunId#3502917L, orderProposalHorizonGroupingId#3502918L, splitIndicator#3502919L, previousOrderProposal#3502920L, clusterId#3502921L, sequenceId#3502922L, sourceOfSupplyUuid#3502923, supplierGroup#3502924, supplier#3502925, subrange#3502926, product#3502927, plant#3502928, purchasingOrg#3502929, purchasingGroup#3502930, mrpController#3502931, orderDateTime#3502932, deliveryDateTime#3502933, availabilityDateTime#3502934, nextAvailabilityDateTime#3502935, isFallbackOrderOnly#3502936, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#3503116L, orderProposalItemId#3503117, supplierGroup#3503118, supplier#3503119, plant#3503120, deliveryDateTime#3503121, subrange#3503122, supplyingPlant#3503123, productGroup#3503124, product#3503125, orderDateTime#3503126, availabilityDateTime#3503127, nextAvailabilityDateTime#3503128, mrpController#3503129, sourceOfSupplyUuid#3503130, purchasingOrg#3503131, purchasingGroup#3503132, isFallbackOrderOnly#3503133, orderProposalHorizonGroupingId#3503134L, splitIndicator#3503135L, previousOrderProposal#3503136L, clusterId#3503137L, sequenceId#3503138, worklistShardItemId#3503139L, orderProposalItemGroupId#3503140, ... 20 more fields], false
(5) Filter
Arguments: (shardId#3503160 = 0_6_10000000532)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#3503139L], 37
(7) Filter
Arguments: (sequenceId#3503138 = 6)
(8) Project
Arguments: [orderProposalId#3503116L, orderProposalItemId#3503117, supplierGroup#3503118, supplier#3503119, plant#3503120, deliveryDateTime#3503121, subrange#3503122, supplyingPlant#3503123, productGroup#3503124, product#3503125, orderDateTime#3503126, availabilityDateTime#3503127, nextAvailabilityDateTime#3503128, mrpController#3503129, sourceOfSupplyUuid#3503130, purchasingOrg#3503131, purchasingGroup#3503132, isFallbackOrderOnly#3503133, orderProposalHorizonGroupingId#3503134L, splitIndicator#3503135L, previousOrderProposal#3503136L, clusterId#3503137L, sequenceId#3503138, worklistShardItemId#3503139L, orderProposalItemGroupId#3503140, ... 20 more fields]
(9) Project
Arguments: [shardId#3503162, worklistShardItemId#3503139L, orderProposalId#3503116L, orderProposalItemId#3503117, orderProposalItemGroupId#3503140, originalReplenishmentRunId#3503158L, orderProposalHorizonGroupingId#3503134L, splitIndicator#3503135L, previousOrderProposal#3503136L, clusterId#3503137L, sequenceId#3503138, sourceOfSupplyUuid#3503130, supplierGroup#3503118, supplier#3503119, subrange#3503122, product#3503125, plant#3503120, purchasingOrg#3503131, purchasingGroup#3503132, mrpController#3503129, orderDateTime#3503126, deliveryDateTime#3503121, availabilityDateTime#3503127, nextAvailabilityDateTime#3503128, isFallbackOrderOnly#3503133, ... 20 more fields]
(10) Project
Arguments: [shardId#3503162, worklistShardItemId#3503139L, orderProposalId#3503116L, orderProposalItemId#3503117, orderProposalItemGroupId#3503140, originalReplenishmentRunId#3503158L, orderProposalHorizonGroupingId#3503134L, splitIndicator#3503135L, previousOrderProposal#3503136L, clusterId#3503137L, cast(sequenceId#3503138 as bigint) AS sequenceId#3503163L, sourceOfSupplyUuid#3503130, supplierGroup#3503118, supplier#3503119, subrange#3503122, product#3503125, plant#3503120, purchasingOrg#3503131, purchasingGroup#3503132, mrpController#3503129, orderDateTime#3503126, deliveryDateTime#3503121, availabilityDateTime#3503127, nextAvailabilityDateTime#3503128, isFallbackOrderOnly#3503133, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#3502935) AND (nextAvailabilityDateTime#3502935 > availabilityDateTime#3502934))
(13) Project
Arguments: [shardId#3502912, worklistShardItemId#3502913L, product#3502927, plant#3502928, availabilityDateTime#3502934, nextAvailabilityDateTime#3502935]
(14) Project
Arguments: [shardId#3502912, worklistShardItemId#3502913L, product#3502927, plant#3502928, availabilityDateTime#3502934, nextAvailabilityDateTime#3502935, 0 AS version#3505329]
(15) Project
Arguments: [shardId#3502912, worklistShardItemId#3502913L, product#3502927, plant#3502928, availabilityDateTime#3502934 AS periodStart#3505330, nextAvailabilityDateTime#3502935, version#3505329]
(16) Project
Arguments: [shardId#3502912, worklistShardItemId#3502913L, product#3502927, plant#3502928, periodStart#3505330, nextAvailabilityDateTime#3502935 AS periodEnd#3505331, version#3505329]
(17) Project
Arguments: [shardId#3502912, worklistShardItemId#3502913L, product#3502927, plant#3502928, periodStart#3505330, periodEnd#3505331, version#3505329, cast(null as double) AS qty#3505332]