== 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@4b2ca4f4, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/grouping-worklist/10000002108], Append
(3) LogicalRelation
Arguments: parquet, [product#724143, plant#724144, supplier#724145, sourceOfSupplyUuid#724146, orderDateTime#724147, deliveryDateTime#724148, availabilityDateTime#724149, supplierGroup#724150, nextAvailabilityDateTime#724151, supplyingPlant#724152, isFallBackOrderOnly#724153], false
(4) RepartitionByExpression
Arguments: [product#724143, plant#724144], 25
(5) Project
Arguments: [product#724143, plant#724144, supplier#724145, sourceOfSupplyUuid#724146, orderDateTime#724147, deliveryDateTime#724148, availabilityDateTime#724149, supplierGroup#724150, nextAvailabilityDateTime#724151, cast(null as string) AS supplyingPlant#724155, isFallBackOrderOnly#724153]
(6) LogicalRelation
Arguments: parquet, [systemId#723944, internalUUID#723945, plant#723946, product#723947, blockedForReplenishmentStartingFrom#723948, productionAspect#723949, salesPlant#723950, listing#723951], false
(7) Repartition
Arguments: 25, true
(8) Project
Arguments: [product#723947.internalRefUUID AS product#723952, plant#723946.internalRefUUID AS plant#723953, productionAspect#723949.productPlanningPlants.mrpController.internalRefUUID AS mrpController#723954]
(9) Join
Arguments: LeftOuter, ((plant#724144 = plant#723953) AND (product#724143 = product#723952))
(10) Project
Arguments: [plant#724144, product#724143, supplier#724145, sourceOfSupplyUuid#724146, orderDateTime#724147, deliveryDateTime#724148, availabilityDateTime#724149, supplierGroup#724150, nextAvailabilityDateTime#724151, supplyingPlant#724155, isFallBackOrderOnly#724153, mrpController#723954]
(11) LogicalRelation
Arguments: parquet, [systemId#723959, internalUUID#723960, supplier#723961, receiver#723962, product#723963, receivingPlant#723964, sourceOfSupplyType#723965, purchasingGroup#723966, purchasingOrganization#723967, productGroup#723968, validFrom#723969, validTo#723970, priority#723971, isPurchasingBlocked#723972, isConsignment#723973, isDeleted#723974, supplierSubrange#723975, plannedDeliveryTimeDays#723976, orderQuantityUnit#723977, purchasingPriceAspect#723978, orderCurrency#723979, minimumOrderQuantity#723980, logisticalRoundingProfile#723981, supplyingPlant#723982], false
(12) Repartition
Arguments: 25, true
(13) Project
Arguments: [internalUUID#723960 AS sourceOfSupplyUuid#723983, supplierSubrange#723975 AS subrange#723984, purchasingGroup#723966.internalRefUUID AS purchasingGroup#723985, purchasingOrganization#723967.internalRefUUID AS purchasingOrg#723986]
(14) Join
Arguments: LeftOuter, (sourceOfSupplyUuid#724146 = sourceOfSupplyUuid#723983)
(15) Project
Arguments: [sourceOfSupplyUuid#724146, plant#724144, product#724143, supplier#724145, orderDateTime#724147, deliveryDateTime#724148, availabilityDateTime#724149, supplierGroup#724150, nextAvailabilityDateTime#724151, supplyingPlant#724155, isFallBackOrderOnly#724153, mrpController#723954, subrange#723984, purchasingGroup#723985, purchasingOrg#723986]
(16) LogicalRelation
Arguments: parquet, [systemId#723990, internalUUID#723991, id#723992, displayId#723993, name#723994, baseUnitOfMeasure#723995, unitOfMeasures#723996, unitOfMeasureConversions#723997, productionAspect#723998, salesAspect#723999, procurementAspect#724000, productGroup#724001], false
(17) Repartition
Arguments: 25, true
(18) Project
Arguments: [systemId#723990, internalUUID#723991, id#723992, displayId#723993, name#723994, baseUnitOfMeasure#723995, unitOfMeasures#723996, unitOfMeasureConversions#723997, productionAspect#723998, salesAspect#723999, procurementAspect#724000, cast(null as struct<internalRefUUID:string,id:string>) AS productGroup#724003]
(19) Project
Arguments: [internalUUID#723991 AS product#724004, productGroup#724003.internalRefUUID AS productGroup#724005]
(20) Join
Arguments: LeftOuter, (product#724143 = product#724004)
(21) Project
Arguments: [product#724143, sourceOfSupplyUuid#724146, plant#724144, supplier#724145, orderDateTime#724147, deliveryDateTime#724148, availabilityDateTime#724149, supplierGroup#724150, nextAvailabilityDateTime#724151, supplyingPlant#724155, isFallBackOrderOnly#724153, mrpController#723954, subrange#723984, purchasingGroup#723985, purchasingOrg#723986, productGroup#724005]
(22) Project
Arguments: [supplierGroup#724150, supplier#724145, plant#724144, deliveryDateTime#724148, subrange#723984, supplyingPlant#724155, productGroup#724005, struct(product, product#724143, orderDateTime, orderDateTime#724147, availabilityDateTime, availabilityDateTime#724149, nextAvailabilityDateTime, nextAvailabilityDateTime#724151, mrpController, mrpController#723954, sourceOfSupplyUuid, sourceOfSupplyUuid#724146, purchasingOrg, purchasingOrg#723986, purchasingGroup, purchasingGroup#723985, isFallbackOrderOnly, isFallbackOrderOnly#724153) AS struct#724156]
(23) Aggregate
Arguments: [supplierGroup#724150, supplier#724145, plant#724144, deliveryDateTime#724148, subrange#723984, supplyingPlant#724155, productGroup#724005], [supplierGroup#724150, supplier#724145, plant#724144, deliveryDateTime#724148, subrange#723984, supplyingPlant#724155, productGroup#724005, collect_list(struct#724156, 0, 0) AS productOrderSchedule#724157]