== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Aggregate (23)
+- Project (22)
+- Project (21)
+- Join (20)
:- Project (15)
: +- Join (14)
: :- Project (10)
: : +- Join (9)
: : :- Project (5)
: : : +- RepartitionByExpression (4)
: : : +- LogicalRelation (3)
: : +- Project (8)
: : +- Repartition (7)
: : +- LogicalRelation (6)
: +- Project (13)
: +- Repartition (12)
: +- LogicalRelation (11)
+- Project (19)
+- Project (18)
+- Repartition (17)
+- LogicalRelation (16)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.delta.sources.DeltaDataSource@59ad0a45, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/grouping-worklist/10000002109], Append
(3) LogicalRelation
Arguments: parquet, [product#817374, plant#817375, supplier#817376, sourceOfSupplyUuid#817377, orderDateTime#817378, deliveryDateTime#817379, availabilityDateTime#817380, supplierGroup#817381, nextAvailabilityDateTime#817382, supplyingPlant#817383, isFallBackOrderOnly#817384], false
(4) RepartitionByExpression
Arguments: [product#817374, plant#817375], 25
(5) Project
Arguments: [product#817374, plant#817375, supplier#817376, sourceOfSupplyUuid#817377, orderDateTime#817378, deliveryDateTime#817379, availabilityDateTime#817380, supplierGroup#817381, nextAvailabilityDateTime#817382, cast(null as string) AS supplyingPlant#817386, isFallBackOrderOnly#817384]
(6) LogicalRelation
Arguments: parquet, [systemId#816672, internalUUID#816673, plant#816674, product#816675, blockedForReplenishmentStartingFrom#816676, productionAspect#816677, salesPlant#816678, listing#816679], false
(7) Repartition
Arguments: 25, true
(8) Project
Arguments: [product#816675.internalRefUUID AS product#816680, plant#816674.internalRefUUID AS plant#816681, productionAspect#816677.productPlanningPlants.mrpController.internalRefUUID AS mrpController#816682]
(9) Join
Arguments: LeftOuter, ((plant#817375 = plant#816681) AND (product#817374 = product#816680))
(10) Project
Arguments: [plant#817375, product#817374, supplier#817376, sourceOfSupplyUuid#817377, orderDateTime#817378, deliveryDateTime#817379, availabilityDateTime#817380, supplierGroup#817381, nextAvailabilityDateTime#817382, supplyingPlant#817386, isFallBackOrderOnly#817384, mrpController#816682]
(11) LogicalRelation
Arguments: parquet, [systemId#816687, internalUUID#816688, supplier#816689, receiver#816690, product#816691, receivingPlant#816692, sourceOfSupplyType#816693, purchasingGroup#816694, purchasingOrganization#816695, productGroup#816696, validFrom#816697, validTo#816698, priority#816699, isPurchasingBlocked#816700, isConsignment#816701, isDeleted#816702, supplierSubrange#816703, plannedDeliveryTimeDays#816704, orderQuantityUnit#816705, purchasingPriceAspect#816706, orderCurrency#816707, minimumOrderQuantity#816708, logisticalRoundingProfile#816709, supplyingPlant#816710], false
(12) Repartition
Arguments: 25, true
(13) Project
Arguments: [internalUUID#816688 AS sourceOfSupplyUuid#816711, supplierSubrange#816703 AS subrange#816712, purchasingGroup#816694.internalRefUUID AS purchasingGroup#816713, purchasingOrganization#816695.internalRefUUID AS purchasingOrg#816714]
(14) Join
Arguments: LeftOuter, (sourceOfSupplyUuid#817377 = sourceOfSupplyUuid#816711)
(15) Project
Arguments: [sourceOfSupplyUuid#817377, plant#817375, product#817374, supplier#817376, orderDateTime#817378, deliveryDateTime#817379, availabilityDateTime#817380, supplierGroup#817381, nextAvailabilityDateTime#817382, supplyingPlant#817386, isFallBackOrderOnly#817384, mrpController#816682, subrange#816712, purchasingGroup#816713, purchasingOrg#816714]
(16) LogicalRelation
Arguments: parquet, [systemId#816718, internalUUID#816719, id#816720, displayId#816721, name#816722, baseUnitOfMeasure#816723, unitOfMeasures#816724, unitOfMeasureConversions#816725, productionAspect#816726, salesAspect#816727, procurementAspect#816728, productGroup#816729], false
(17) Repartition
Arguments: 25, true
(18) Project
Arguments: [systemId#816718, internalUUID#816719, id#816720, displayId#816721, name#816722, baseUnitOfMeasure#816723, unitOfMeasures#816724, unitOfMeasureConversions#816725, productionAspect#816726, salesAspect#816727, procurementAspect#816728, cast(null as struct<internalRefUUID:string,id:string>) AS productGroup#816731]
(19) Project
Arguments: [internalUUID#816719 AS product#816732, productGroup#816731.internalRefUUID AS productGroup#816733]
(20) Join
Arguments: LeftOuter, (product#817374 = product#816732)
(21) Project
Arguments: [product#817374, sourceOfSupplyUuid#817377, plant#817375, supplier#817376, orderDateTime#817378, deliveryDateTime#817379, availabilityDateTime#817380, supplierGroup#817381, nextAvailabilityDateTime#817382, supplyingPlant#817386, isFallBackOrderOnly#817384, mrpController#816682, subrange#816712, purchasingGroup#816713, purchasingOrg#816714, productGroup#816733]
(22) Project
Arguments: [supplierGroup#817381, supplier#817376, plant#817375, deliveryDateTime#817379, subrange#816712, supplyingPlant#817386, productGroup#816733, struct(product, product#817374, orderDateTime, orderDateTime#817378, availabilityDateTime, availabilityDateTime#817380, nextAvailabilityDateTime, nextAvailabilityDateTime#817382, mrpController, mrpController#816682, sourceOfSupplyUuid, sourceOfSupplyUuid#817377, purchasingOrg, purchasingOrg#816714, purchasingGroup, purchasingGroup#816713, isFallbackOrderOnly, isFallbackOrderOnly#817384) AS struct#817387]
(23) Aggregate
Arguments: [supplierGroup#817381, supplier#817376, plant#817375, deliveryDateTime#817379, subrange#816712, supplyingPlant#817386, productGroup#816733], [supplierGroup#817381, supplier#817376, plant#817375, deliveryDateTime#817379, subrange#816712, supplyingPlant#817386, productGroup#816733, collect_list(struct#817387, 0, 0) AS productOrderSchedule#817388]