== 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@487140ca, [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#1102212, worklistShardItemId#1102213L, orderProposalId#1102214L, orderProposalItemId#1102215, orderProposalItemGroupId#1102216, originalReplenishmentRunId#1102217L, orderProposalHorizonGroupingId#1102218L, splitIndicator#1102219L, previousOrderProposal#1102220L, clusterId#1102221L, sequenceId#1102222L, sourceOfSupplyUuid#1102223, supplierGroup#1102224, supplier#1102225, subrange#1102226, product#1102227, plant#1102228, purchasingOrg#1102229, purchasingGroup#1102230, mrpController#1102231, orderDateTime#1102232, deliveryDateTime#1102233, availabilityDateTime#1102234, nextAvailabilityDateTime#1102235, isFallbackOrderOnly#1102236, ... 20 more fields]
(4) LogicalRelation
Arguments: parquet, [orderProposalId#1102257L, orderProposalItemId#1102258, supplierGroup#1102259, supplier#1102260, plant#1102261, deliveryDateTime#1102262, subrange#1102263, supplyingPlant#1102264, productGroup#1102265, product#1102266, orderDateTime#1102267, availabilityDateTime#1102268, nextAvailabilityDateTime#1102269, mrpController#1102270, sourceOfSupplyUuid#1102271, purchasingOrg#1102272, purchasingGroup#1102273, isFallbackOrderOnly#1102274, orderProposalHorizonGroupingId#1102275L, splitIndicator#1102276L, previousOrderProposal#1102277L, clusterId#1102278L, sequenceId#1102279, worklistShardItemId#1102280L, orderProposalItemGroupId#1102281, ... 20 more fields], false
(5) Filter
Arguments: (shardId#1102301 = 0_1_10000002111)
(6) RepartitionByExpression
Arguments: [worklistShardItemId#1102280L], 25
(7) Filter
Arguments: (sequenceId#1102279 = 4)
(8) Project
Arguments: [orderProposalId#1102257L, orderProposalItemId#1102258, supplierGroup#1102259, supplier#1102260, plant#1102261, deliveryDateTime#1102262, subrange#1102263, supplyingPlant#1102264, productGroup#1102265, product#1102266, orderDateTime#1102267, availabilityDateTime#1102268, nextAvailabilityDateTime#1102269, mrpController#1102270, sourceOfSupplyUuid#1102271, purchasingOrg#1102272, purchasingGroup#1102273, isFallbackOrderOnly#1102274, orderProposalHorizonGroupingId#1102275L, splitIndicator#1102276L, previousOrderProposal#1102277L, clusterId#1102278L, sequenceId#1102279, worklistShardItemId#1102280L, orderProposalItemGroupId#1102281, ... 20 more fields]
(9) Project
Arguments: [shardId#1102303, worklistShardItemId#1102280L, orderProposalId#1102257L, orderProposalItemId#1102258, orderProposalItemGroupId#1102281, originalReplenishmentRunId#1102299L, orderProposalHorizonGroupingId#1102275L, splitIndicator#1102276L, previousOrderProposal#1102277L, clusterId#1102278L, sequenceId#1102279, sourceOfSupplyUuid#1102271, supplierGroup#1102259, supplier#1102260, subrange#1102263, product#1102266, plant#1102261, purchasingOrg#1102272, purchasingGroup#1102273, mrpController#1102270, orderDateTime#1102267, deliveryDateTime#1102262, availabilityDateTime#1102268, nextAvailabilityDateTime#1102269, isFallbackOrderOnly#1102274, ... 20 more fields]
(10) Project
Arguments: [shardId#1102303, worklistShardItemId#1102280L, orderProposalId#1102257L, orderProposalItemId#1102258, orderProposalItemGroupId#1102281, originalReplenishmentRunId#1102299L, orderProposalHorizonGroupingId#1102275L, splitIndicator#1102276L, previousOrderProposal#1102277L, clusterId#1102278L, cast(sequenceId#1102279 as bigint) AS sequenceId#1102304L, sourceOfSupplyUuid#1102271, supplierGroup#1102259, supplier#1102260, subrange#1102263, product#1102266, plant#1102261, purchasingOrg#1102272, purchasingGroup#1102273, mrpController#1102270, orderDateTime#1102267, deliveryDateTime#1102262, availabilityDateTime#1102268, nextAvailabilityDateTime#1102269, isFallbackOrderOnly#1102274, ... 20 more fields]
(11) Union
Arguments: false, false
(12) Filter
Arguments: (isnotnull(nextAvailabilityDateTime#1102235) AND (nextAvailabilityDateTime#1102235 > availabilityDateTime#1102234))
(13) Project
Arguments: [shardId#1102212, worklistShardItemId#1102213L, product#1102227, plant#1102228, availabilityDateTime#1102234, nextAvailabilityDateTime#1102235]
(14) Project
Arguments: [shardId#1102212, worklistShardItemId#1102213L, product#1102227, plant#1102228, availabilityDateTime#1102234, nextAvailabilityDateTime#1102235, 0 AS version#1104470]
(15) Project
Arguments: [shardId#1102212, worklistShardItemId#1102213L, product#1102227, plant#1102228, availabilityDateTime#1102234 AS periodStart#1104471, nextAvailabilityDateTime#1102235, version#1104470]
(16) Project
Arguments: [shardId#1102212, worklistShardItemId#1102213L, product#1102227, plant#1102228, periodStart#1104471, nextAvailabilityDateTime#1102235 AS periodEnd#1104472, version#1104470]
(17) Project
Arguments: [shardId#1102212, worklistShardItemId#1102213L, product#1102227, plant#1102228, periodStart#1104471, periodEnd#1104472, version#1104470, cast(null as double) AS qty#1104473]