== 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@25cc483c, [path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/grouping-worklist/10000002111], Append
(3) LogicalRelation
Arguments: parquet, [product#992836, plant#992837, supplier#992838, sourceOfSupplyUuid#992839, orderDateTime#992840, deliveryDateTime#992841, availabilityDateTime#992842, supplierGroup#992843, nextAvailabilityDateTime#992844, supplyingPlant#992845, isFallBackOrderOnly#992846], false
(4) RepartitionByExpression
Arguments: [product#992836, plant#992837], 25
(5) Project
Arguments: [product#992836, plant#992837, supplier#992838, sourceOfSupplyUuid#992839, orderDateTime#992840, deliveryDateTime#992841, availabilityDateTime#992842, supplierGroup#992843, nextAvailabilityDateTime#992844, cast(null as string) AS supplyingPlant#992848, isFallBackOrderOnly#992846]
(6) LogicalRelation
Arguments: parquet, [systemId#992637, internalUUID#992638, plant#992639, product#992640, blockedForReplenishmentStartingFrom#992641, productionAspect#992642, salesPlant#992643, listing#992644], false
(7) Repartition
Arguments: 25, true
(8) Project
Arguments: [product#992640.internalRefUUID AS product#992645, plant#992639.internalRefUUID AS plant#992646, productionAspect#992642.productPlanningPlants.mrpController.internalRefUUID AS mrpController#992647]
(9) Join
Arguments: LeftOuter, ((plant#992837 = plant#992646) AND (product#992836 = product#992645))
(10) Project
Arguments: [plant#992837, product#992836, supplier#992838, sourceOfSupplyUuid#992839, orderDateTime#992840, deliveryDateTime#992841, availabilityDateTime#992842, supplierGroup#992843, nextAvailabilityDateTime#992844, supplyingPlant#992848, isFallBackOrderOnly#992846, mrpController#992647]
(11) LogicalRelation
Arguments: parquet, [systemId#992652, internalUUID#992653, supplier#992654, receiver#992655, product#992656, receivingPlant#992657, sourceOfSupplyType#992658, purchasingGroup#992659, purchasingOrganization#992660, productGroup#992661, validFrom#992662, validTo#992663, priority#992664, isPurchasingBlocked#992665, isConsignment#992666, isDeleted#992667, supplierSubrange#992668, plannedDeliveryTimeDays#992669, orderQuantityUnit#992670, purchasingPriceAspect#992671, orderCurrency#992672, minimumOrderQuantity#992673, logisticalRoundingProfile#992674, supplyingPlant#992675], false
(12) Repartition
Arguments: 25, true
(13) Project
Arguments: [internalUUID#992653 AS sourceOfSupplyUuid#992676, supplierSubrange#992668 AS subrange#992677, purchasingGroup#992659.internalRefUUID AS purchasingGroup#992678, purchasingOrganization#992660.internalRefUUID AS purchasingOrg#992679]
(14) Join
Arguments: LeftOuter, (sourceOfSupplyUuid#992839 = sourceOfSupplyUuid#992676)
(15) Project
Arguments: [sourceOfSupplyUuid#992839, plant#992837, product#992836, supplier#992838, orderDateTime#992840, deliveryDateTime#992841, availabilityDateTime#992842, supplierGroup#992843, nextAvailabilityDateTime#992844, supplyingPlant#992848, isFallBackOrderOnly#992846, mrpController#992647, subrange#992677, purchasingGroup#992678, purchasingOrg#992679]
(16) LogicalRelation
Arguments: parquet, [systemId#992683, internalUUID#992684, id#992685, displayId#992686, name#992687, baseUnitOfMeasure#992688, unitOfMeasures#992689, unitOfMeasureConversions#992690, productionAspect#992691, salesAspect#992692, procurementAspect#992693, productGroup#992694], false
(17) Repartition
Arguments: 25, true
(18) Project
Arguments: [systemId#992683, internalUUID#992684, id#992685, displayId#992686, name#992687, baseUnitOfMeasure#992688, unitOfMeasures#992689, unitOfMeasureConversions#992690, productionAspect#992691, salesAspect#992692, procurementAspect#992693, cast(null as struct<internalRefUUID:string,id:string>) AS productGroup#992696]
(19) Project
Arguments: [internalUUID#992684 AS product#992697, productGroup#992696.internalRefUUID AS productGroup#992698]
(20) Join
Arguments: LeftOuter, (product#992836 = product#992697)
(21) Project
Arguments: [product#992836, sourceOfSupplyUuid#992839, plant#992837, supplier#992838, orderDateTime#992840, deliveryDateTime#992841, availabilityDateTime#992842, supplierGroup#992843, nextAvailabilityDateTime#992844, supplyingPlant#992848, isFallBackOrderOnly#992846, mrpController#992647, subrange#992677, purchasingGroup#992678, purchasingOrg#992679, productGroup#992698]
(22) Project
Arguments: [supplierGroup#992843, supplier#992838, plant#992837, deliveryDateTime#992841, subrange#992677, supplyingPlant#992848, productGroup#992698, struct(product, product#992836, orderDateTime, orderDateTime#992840, availabilityDateTime, availabilityDateTime#992842, nextAvailabilityDateTime, nextAvailabilityDateTime#992844, mrpController, mrpController#992647, sourceOfSupplyUuid, sourceOfSupplyUuid#992839, purchasingOrg, purchasingOrg#992679, purchasingGroup, purchasingGroup#992678, isFallbackOrderOnly, isFallbackOrderOnly#992846) AS struct#992849]
(23) Aggregate
Arguments: [supplierGroup#992843, supplier#992838, plant#992837, deliveryDateTime#992841, subrange#992677, supplyingPlant#992848, productGroup#992698], [supplierGroup#992843, supplier#992838, plant#992837, deliveryDateTime#992841, subrange#992677, supplyingPlant#992848, productGroup#992698, collect_list(struct#992849, 0, 0) AS productOrderSchedule#992850]