== 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@66dcd2ce, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000002111/stream-10000002111-1], Append
(3) LocalRelation
Arguments: <empty>, [shardId#1032635, worklistShardItemId#1032636L, orderProposalId#1032637L, orderProposalItemId#1032638, orderProposalItemGroupId#1032639, originalReplenishmentRunId#1032640L, orderProposalHorizonGroupingId#1032641L, splitIndicator#1032642L, previousOrderProposal#1032643L, clusterId#1032644L, sequenceId#1032645L, sourceOfSupplyUuid#1032646, supplierGroup#1032647, supplier#1032648, subrange#1032649, product#1032650, plant#1032651, purchasingOrg#1032652, purchasingGroup#1032653, mrpController#1032654, orderDateTime#1032655, deliveryDateTime#1032656, availabilityDateTime#1032657, nextAvailabilityDateTime#1032658, isFallbackOrderOnly#1032659, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#1032680L, orderProposalItemId#1032681, supplierGroup#1032682, supplier#1032683, plant#1032684, deliveryDateTime#1032685, subrange#1032686, supplyingPlant#1032687, productGroup#1032688, product#1032689, orderDateTime#1032690, availabilityDateTime#1032691, nextAvailabilityDateTime#1032692, mrpController#1032693, sourceOfSupplyUuid#1032694, purchasingOrg#1032695, purchasingGroup#1032696, isFallbackOrderOnly#1032697, orderProposalHorizonGroupingId#1032698L, splitIndicator#1032699L, previousOrderProposal#1032700L, clusterId#1032701L, sequenceId#1032702, worklistShardItemId#1032703L, orderProposalItemGroupId#1032704, ... 20 more fields], false
(5) Filter
Arguments: (shardId#1032724 = 0_1_10000002111)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#1032703L], 25
(7) Filter
Arguments: (sequenceId#1032702 = 1)
(8) Project
Arguments: [orderProposalId#1032680L, orderProposalItemId#1032681, supplierGroup#1032682, supplier#1032683, plant#1032684, deliveryDateTime#1032685, subrange#1032686, supplyingPlant#1032687, productGroup#1032688, product#1032689, orderDateTime#1032690, availabilityDateTime#1032691, nextAvailabilityDateTime#1032692, mrpController#1032693, sourceOfSupplyUuid#1032694, purchasingOrg#1032695, purchasingGroup#1032696, isFallbackOrderOnly#1032697, orderProposalHorizonGroupingId#1032698L, splitIndicator#1032699L, previousOrderProposal#1032700L, clusterId#1032701L, sequenceId#1032702, worklistShardItemId#1032703L, orderProposalItemGroupId#1032704, ... 20 more fields]
(9) Project
Arguments: [shardId#1032726, worklistShardItemId#1032703L, orderProposalId#1032680L, orderProposalItemId#1032681, orderProposalItemGroupId#1032704, originalReplenishmentRunId#1032722L, orderProposalHorizonGroupingId#1032698L, splitIndicator#1032699L, previousOrderProposal#1032700L, clusterId#1032701L, sequenceId#1032702, sourceOfSupplyUuid#1032694, supplierGroup#1032682, supplier#1032683, subrange#1032686, product#1032689, plant#1032684, purchasingOrg#1032695, purchasingGroup#1032696, mrpController#1032693, orderDateTime#1032690, deliveryDateTime#1032685, availabilityDateTime#1032691, nextAvailabilityDateTime#1032692, isFallbackOrderOnly#1032697, ... 20 more fields]
(10) Project
Arguments: [shardId#1032726, worklistShardItemId#1032703L, orderProposalId#1032680L, orderProposalItemId#1032681, orderProposalItemGroupId#1032704, originalReplenishmentRunId#1032722L, orderProposalHorizonGroupingId#1032698L, splitIndicator#1032699L, previousOrderProposal#1032700L, clusterId#1032701L, cast(sequenceId#1032702 as bigint) AS sequenceId#1032727L, sourceOfSupplyUuid#1032694, supplierGroup#1032682, supplier#1032683, subrange#1032686, product#1032689, plant#1032684, purchasingOrg#1032695, purchasingGroup#1032696, mrpController#1032693, orderDateTime#1032690, deliveryDateTime#1032685, availabilityDateTime#1032691, nextAvailabilityDateTime#1032692, isFallbackOrderOnly#1032697, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#1032658) AND (nextAvailabilityDateTime#1032658 > availabilityDateTime#1032657))
(13) Project
Arguments: [shardId#1032635, worklistShardItemId#1032636L, product#1032650, plant#1032651, availabilityDateTime#1032657, nextAvailabilityDateTime#1032658]
(14) Project
Arguments: [shardId#1032635, worklistShardItemId#1032636L, product#1032650, plant#1032651, availabilityDateTime#1032657, nextAvailabilityDateTime#1032658, 0 AS version#1034893]
(15) Project
Arguments: [shardId#1032635, worklistShardItemId#1032636L, product#1032650, plant#1032651, availabilityDateTime#1032657 AS periodStart#1034894, nextAvailabilityDateTime#1032658, version#1034893]
(16) Project
Arguments: [shardId#1032635, worklistShardItemId#1032636L, product#1032650, plant#1032651, periodStart#1034894, nextAvailabilityDateTime#1032658 AS periodEnd#1034895, version#1034893]
(17) Project
Arguments: [shardId#1032635, worklistShardItemId#1032636L, product#1032650, plant#1032651, periodStart#1034894, periodEnd#1034895, version#1034893, cast(null as double) AS qty#1034896]