== 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@306f2743, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/grouping-worklist/10000002110], Append
(3) LogicalRelation
Arguments: parquet, [product#905365, plant#905366, supplier#905367, sourceOfSupplyUuid#905368, orderDateTime#905369, deliveryDateTime#905370, availabilityDateTime#905371, supplierGroup#905372, nextAvailabilityDateTime#905373, supplyingPlant#905374, isFallBackOrderOnly#905375], false
(4) RepartitionByExpression
Arguments: [product#905365, plant#905366], 25
(5) Project
Arguments: [product#905365, plant#905366, supplier#905367, sourceOfSupplyUuid#905368, orderDateTime#905369, deliveryDateTime#905370, availabilityDateTime#905371, supplierGroup#905372, nextAvailabilityDateTime#905373, cast(null as string) AS supplyingPlant#905377, isFallBackOrderOnly#905375]
(6) LogicalRelation
Arguments: parquet, [systemId#905166, internalUUID#905167, plant#905168, product#905169, blockedForReplenishmentStartingFrom#905170, productionAspect#905171, salesPlant#905172, listing#905173], false
(7) Repartition
Arguments: 25, true
(8) Project
Arguments: [product#905169.internalRefUUID AS product#905174, plant#905168.internalRefUUID AS plant#905175, productionAspect#905171.productPlanningPlants.mrpController.internalRefUUID AS mrpController#905176]
(9) Join
Arguments: LeftOuter, ((plant#905366 = plant#905175) AND (product#905365 = product#905174))
(10) Project
Arguments: [plant#905366, product#905365, supplier#905367, sourceOfSupplyUuid#905368, orderDateTime#905369, deliveryDateTime#905370, availabilityDateTime#905371, supplierGroup#905372, nextAvailabilityDateTime#905373, supplyingPlant#905377, isFallBackOrderOnly#905375, mrpController#905176]
(11) LogicalRelation
Arguments: parquet, [systemId#905181, internalUUID#905182, supplier#905183, receiver#905184, product#905185, receivingPlant#905186, sourceOfSupplyType#905187, purchasingGroup#905188, purchasingOrganization#905189, productGroup#905190, validFrom#905191, validTo#905192, priority#905193, isPurchasingBlocked#905194, isConsignment#905195, isDeleted#905196, supplierSubrange#905197, plannedDeliveryTimeDays#905198, orderQuantityUnit#905199, purchasingPriceAspect#905200, orderCurrency#905201, minimumOrderQuantity#905202, logisticalRoundingProfile#905203, supplyingPlant#905204], false
(12) Repartition
Arguments: 25, true
(13) Project
Arguments: [internalUUID#905182 AS sourceOfSupplyUuid#905205, supplierSubrange#905197 AS subrange#905206, purchasingGroup#905188.internalRefUUID AS purchasingGroup#905207, purchasingOrganization#905189.internalRefUUID AS purchasingOrg#905208]
(14) Join
Arguments: LeftOuter, (sourceOfSupplyUuid#905368 = sourceOfSupplyUuid#905205)
(15) Project
Arguments: [sourceOfSupplyUuid#905368, plant#905366, product#905365, supplier#905367, orderDateTime#905369, deliveryDateTime#905370, availabilityDateTime#905371, supplierGroup#905372, nextAvailabilityDateTime#905373, supplyingPlant#905377, isFallBackOrderOnly#905375, mrpController#905176, subrange#905206, purchasingGroup#905207, purchasingOrg#905208]
(16) LogicalRelation
Arguments: parquet, [systemId#905212, internalUUID#905213, id#905214, displayId#905215, name#905216, baseUnitOfMeasure#905217, unitOfMeasures#905218, unitOfMeasureConversions#905219, productionAspect#905220, salesAspect#905221, procurementAspect#905222, productGroup#905223], false
(17) Repartition
Arguments: 25, true
(18) Project
Arguments: [systemId#905212, internalUUID#905213, id#905214, displayId#905215, name#905216, baseUnitOfMeasure#905217, unitOfMeasures#905218, unitOfMeasureConversions#905219, productionAspect#905220, salesAspect#905221, procurementAspect#905222, cast(null as struct<internalRefUUID:string,id:string>) AS productGroup#905225]
(19) Project
Arguments: [internalUUID#905213 AS product#905226, productGroup#905225.internalRefUUID AS productGroup#905227]
(20) Join
Arguments: LeftOuter, (product#905365 = product#905226)
(21) Project
Arguments: [product#905365, sourceOfSupplyUuid#905368, plant#905366, supplier#905367, orderDateTime#905369, deliveryDateTime#905370, availabilityDateTime#905371, supplierGroup#905372, nextAvailabilityDateTime#905373, supplyingPlant#905377, isFallBackOrderOnly#905375, mrpController#905176, subrange#905206, purchasingGroup#905207, purchasingOrg#905208, productGroup#905227]
(22) Project
Arguments: [supplierGroup#905372, supplier#905367, plant#905366, deliveryDateTime#905370, subrange#905206, supplyingPlant#905377, productGroup#905227, struct(product, product#905365, orderDateTime, orderDateTime#905369, availabilityDateTime, availabilityDateTime#905371, nextAvailabilityDateTime, nextAvailabilityDateTime#905373, mrpController, mrpController#905176, sourceOfSupplyUuid, sourceOfSupplyUuid#905368, purchasingOrg, purchasingOrg#905208, purchasingGroup, purchasingGroup#905207, isFallbackOrderOnly, isFallbackOrderOnly#905375) AS struct#905378]
(23) Aggregate
Arguments: [supplierGroup#905372, supplier#905367, plant#905366, deliveryDateTime#905370, subrange#905206, supplyingPlant#905377, productGroup#905227], [supplierGroup#905372, supplier#905367, plant#905366, deliveryDateTime#905370, subrange#905206, supplyingPlant#905377, productGroup#905227, collect_list(struct#905378, 0, 0) AS productOrderSchedule#905379]