crp-order-qty-opt-service - Details for Query 100

Submitted Time: 2026/02/06 10:33:41
Duration: 0.2 s
Succeeded Jobs: 205 206 207

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster1 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; 2 [labelType="html" label="HashAggregate time in aggregation build: 0 ms number of output rows: 1"]; } 3 [labelType="html" label="Exchange shuffle records written: 1 local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 75.0 B fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 16.0 B local merged bytes read: 0.0 B number of partitions: 1 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 75.0 B"]; subgraph cluster4 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: 12 ms"; 5 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 11 ms peak memory: 0.0 B number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 6 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 10 ms peak memory: 256.0 KiB number of output rows: 10 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 7 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 12.4 KiB number of coalesced partitions: 1"]; 8 [labelType="html" label="Exchange shuffle records written: 123 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 15 ms (0 ms, 0 ms, 0 ms (stage 378.0: task 2810)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 123 local bytes read: 5.1 KiB fetch wait time: 0 ms remote bytes read: 6.4 KiB merged fetch fallback count: 0 local blocks read: 44 remote merged chunks fetched: 0 remote blocks read: 57 data size total (min, med, max (stageId: taskId)) 5.8 KiB (96.0 B, 240.0 B, 384.0 B (stage 378.0: task 2814)) local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration: 5 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 11.5 KiB (216.0 B, 505.0 B, 729.0 B (stage 378.0: task 2814))"]; subgraph cluster9 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n78 ms (1 ms, 2 ms, 7 ms (stage 378.0: task 2814))"; 10 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 378.0: task 2819)) peak memory total (min, med, max (stageId: taskId)) 6.3 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 378.0: task 2819)) number of output rows: 123 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 11 [labelType="html" label="InMemoryTableScan number of output rows: 1,196"]; 12 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster13 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; 14 [labelType="html" label=" Project "]; 15 [labelType="html" label="Generate number of output rows: 0"]; 16 [labelType="html" label=" Project "]; 17 [labelType="html" label=" Project "]; 18 [labelType="html" label="BroadcastHashJoin number of output rows: 0"]; } 19 [labelType="html" label="Exchange shuffle records written: 0 local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B"]; 20 [labelType="html" label=" Exchange "]; subgraph cluster21 { isCluster="true"; label="WholeStageCodegen (1)"; 22 [labelType="html" label=" Filter "]; 23 [labelType="html" label=" ColumnarToRow "]; } 24 [labelType="html" label=" Scan parquet "]; 25 [labelType="html" label=" BroadcastExchange "]; 26 [labelType="html" label=" AQEShuffleRead "]; 27 [labelType="html" label=" Exchange "]; subgraph cluster28 { isCluster="true"; label="WholeStageCodegen (4)"; 29 [labelType="html" label=" Project "]; 30 [labelType="html" label=" BroadcastHashJoin "]; } 31 [labelType="html" label=" Exchange "]; subgraph cluster32 { isCluster="true"; label="WholeStageCodegen (2)"; 33 [labelType="html" label=" ColumnarToRow "]; } 34 [labelType="html" label=" Scan parquet "]; 35 [labelType="html" label=" BroadcastExchange "]; 36 [labelType="html" label=" Exchange "]; subgraph cluster37 { isCluster="true"; label="WholeStageCodegen (3)"; 38 [labelType="html" label=" Filter "]; 39 [labelType="html" label=" ColumnarToRow "]; } 40 [labelType="html" label=" Scan parquet "]; 2->0; 3->2; 5->3; 6->5; 7->6; 8->7; 10->8; 11->10; 12->11; 14->12; 15->14; 16->15; 17->16; 18->17; 19->18; 20->19; 22->20; 23->22; 24->23; 25->18; 26->25; 27->26; 29->27; 30->29; 31->30; 33->31; 34->33; 35->30; 36->35; 38->36; 39->38; 40->39; }

AdaptiveSparkPlan isFinalPlan=true

HashAggregate(keys=[], functions=[count(1)])

WholeStageCodegen (3)

Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=11068]

HashAggregate(keys=[], functions=[partial_count(1)])

HashAggregate(keys=[plant#32469], functions=[])

WholeStageCodegen (2)

AQEShuffleRead coalesced

Exchange hashpartitioning(plant#32469, 25), ENSURE_REQUIREMENTS, [plan_id=11036]

HashAggregate(keys=[plant#32469], functions=[])

WholeStageCodegen (1)

InMemoryTableScan [plant#32469]

AdaptiveSparkPlan isFinalPlan=true

Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderScheduleExploded#32769.product AS product#32783, productOrderScheduleExploded#32769.orderDateTime AS orderDateTime#32784, productOrderScheduleExploded#32769.availabilityDateTime AS availabilityDateTime#32785, productOrderScheduleExploded#32769.nextAvailabilityDateTime AS nextAvailabilityDateTime#32786, productOrderScheduleExploded#32769.mrpController AS mrpController#32787, productOrderScheduleExploded#32769.sourceOfSupplyUuid AS sourceOfSupplyUuid#32788, productOrderScheduleExploded#32769.purchasingOrg AS purchasingOrg#32789, productOrderScheduleExploded#32769.purchasingGroup AS purchasingGroup#32790, xxhash64(CASE WHEN (_extract_supplier#33643 <=> true) THEN supplierOrGroup#32676 END, CASE WHEN (_extract_deliveryDate#33644 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_orderDate#33645 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_supplierSubrange#33646 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_purchasingOrg#33647 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_mrpController#33648 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33649 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, locationOrGroup#32688, ((((((((CASE WHEN (isnull(supplierOrGroup#32676) AND (_extract_supplier#33643 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33644 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33645 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33646 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33647 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33648 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33649 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#32688) THEN 256 ELSE 0 END), 10000000096, 42) AS orderProposalId#33183L, 0 AS orderProposalHorizonGroupingId#33204L, xxhash64(CASE WHEN (_extract_purchasingOrg#33650 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_deliveryDate#33651 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_supplier#33652 <=> true) THEN supplier#32468 END, CASE WHEN (_extract_supplierSubrange#33653 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_orderDate#33654 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_mrpController#33655 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33656 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, plant#32469, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33650 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33651 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#32468) AND (_extract_supplier#33652 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33653 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33654 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33655 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33656 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#32469) THEN 256 ELSE 0 END), 10000000096, 42) AS splitIndicator#33604L]

Generate explode(productOrderSchedule#32472), [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688], false, [productOrderScheduleExploded#32769]

Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, orderGroupCriteria#32733.supplier AS _extract_supplier#33643, orderGroupCriteria#32733.deliveryDate AS _extract_deliveryDate#33644, orderGroupCriteria#32733.orderDate AS _extract_orderDate#33645, orderGroupCriteria#32733.supplierSubrange AS _extract_supplierSubrange#33646, orderGroupCriteria#32733.purchasingOrg AS _extract_purchasingOrg#33647, orderGroupCriteria#32733.mrpController AS _extract_mrpController#33648, orderGroupCriteria#32733.purchasingGroup AS _extract_purchasingGroup#33649, orderSplitCriteria#32755.purchasingOrg AS _extract_purchasingOrg#33650, orderSplitCriteria#32755.deliveryDate AS _extract_deliveryDate#33651, orderSplitCriteria#32755.supplier AS _extract_supplier#33652, orderSplitCriteria#32755.supplierSubrange AS _extract_supplierSubrange#33653, orderSplitCriteria#32755.orderDate AS _extract_orderDate#33654, orderSplitCriteria#32755.mrpController AS _extract_mrpController#33655, orderSplitCriteria#32755.purchasingGroup AS _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]

Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, CASE WHEN isnull(orderGroupCriteria#32579) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#32579 END AS orderGroupCriteria#32733, CASE WHEN isnull(orderSplitCriteria#32580) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#32580 END AS orderSplitCriteria#32755, orderGroupingProfile#32483, coalesce(supplierGroup#32467, supplier#32468) AS supplierOrGroup#32676, coalesce(locationGroup#32485, plant#32469) AS locationOrGroup#32688]

BroadcastHashJoin [coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470)], [coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482)], LeftOuter, BuildRight, false

WholeStageCodegen (5)

Exchange hashpartitioning(coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470), 25), ENSURE_REQUIREMENTS, [plan_id=10613]

Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10605]

Filter ((size(productOrderSchedule#32472, true) > 0) AND isnotnull(productOrderSchedule#32472))

ColumnarToRow

WholeStageCodegen (1)

FileScan parquet [supplierGroup#32467,supplier#32468,plant#32469,deliveryDateTime#32470,subrange#32471,productOrderSchedule#32472] Batched: true, DataFilters: [(size(productOrderSchedule#32472, true) > 0), isnotnull(productOrderSchedule#32472)], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [IsNotNull(productOrderSchedule)], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...

BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[5, string, true], ), isnull(input[5, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=10888]

AQEShuffleRead local

Exchange hashpartitioning(coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482), 25), ENSURE_REQUIREMENTS, [plan_id=10810]

Project [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]

BroadcastHashJoin [orderGroupingProfile#32483], [orderGroupingProfile#32577], LeftOuter, BuildRight, false

WholeStageCodegen (4)

Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10633]

ColumnarToRow

WholeStageCodegen (2)

FileScan parquet [supplier#32479,subrange#32480,plant#32481,deliverydatetime#32482,ordergroupingprofile#32483,supplierGroup#32484,locationGroup#32485] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofi...

BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=10654]

Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10646]

Filter isnotnull(orderGroupingProfile#32577)

ColumnarToRow

WholeStageCodegen (3)

FileScan parquet [orderGroupingProfile#32577,orderGroupCriteria#32579,orderSplitCriteria#32580] Batched: true, DataFilters: [isnotnull(orderGroupingProfile#32577)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(orderGroupingProfile)], ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:bo...

Details

== Physical Plan ==
AdaptiveSparkPlan (67)
+- == Final Plan ==
   * HashAggregate (60)
   +- ShuffleQueryStage (59), Statistics(sizeInBytes=16.0 B, rowCount=1)
      +- Exchange (58)
         +- * HashAggregate (57)
            +- * HashAggregate (56)
               +- AQEShuffleRead (55)
                  +- ShuffleQueryStage (54), Statistics(sizeInBytes=5.8 KiB, rowCount=123)
                     +- Exchange (53)
                        +- * HashAggregate (52)
                           +- TableCacheQueryStage (51), Statistics(sizeInBytes=379.1 KiB, rowCount=1.20E+3)
                              +- InMemoryTableScan (1)
                                    +- InMemoryRelation (2)
                                          +- AdaptiveSparkPlan (50)
                                          +- == Final Plan ==
                                             * Project (32)
                                             +- * Generate (31)
                                                +- * Project (30)
                                                   +- * Project (29)
                                                      +- * BroadcastHashJoin LeftOuter BuildRight (28)
                                                         :- ShuffleQueryStage (9), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                                         :  +- Exchange (8)
                                                         :     +- ShuffleQueryStage (7), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                                         :        +- Exchange (6)
                                                         :           +- * Filter (5)
                                                         :              +- * ColumnarToRow (4)
                                                         :                 +- Scan parquet  (3)
                                                         +- BroadcastQueryStage (27), Statistics(sizeInBytes=2.0 MiB, rowCount=179)
                                                            +- BroadcastExchange (26)
                                                               +- AQEShuffleRead (25)
                                                                  +- ShuffleQueryStage (24), Statistics(sizeInBytes=58.3 KiB, rowCount=179)
                                                                     +- Exchange (23)
                                                                        +- * Project (22)
                                                                           +- * BroadcastHashJoin LeftOuter BuildRight (21)
                                                                              :- ShuffleQueryStage (13), Statistics(sizeInBytes=28.9 KiB, rowCount=179)
                                                                              :  +- Exchange (12)
                                                                              :     +- * ColumnarToRow (11)
                                                                              :        +- Scan parquet  (10)
                                                                              +- BroadcastQueryStage (20), Statistics(sizeInBytes=2.0 MiB, rowCount=1)
                                                                                 +- BroadcastExchange (19)
                                                                                    +- ShuffleQueryStage (18), Statistics(sizeInBytes=208.0 B, rowCount=1)
                                                                                       +- Exchange (17)
                                                                                          +- * Filter (16)
                                                                                             +- * ColumnarToRow (15)
                                                                                                +- Scan parquet  (14)
                                          +- == Initial Plan ==
                                             Project (49)
                                             +- Generate (48)
                                                +- Project (47)
                                                   +- Project (46)
                                                      +- SortMergeJoin LeftOuter (45)
                                                         :- Sort (36)
                                                         :  +- Exchange (35)
                                                         :     +- Exchange (34)
                                                         :        +- Filter (33)
                                                         :           +- Scan parquet  (3)
                                                         +- Sort (44)
                                                            +- Exchange (43)
                                                               +- Project (42)
                                                                  +- BroadcastHashJoin LeftOuter BuildRight (41)
                                                                     :- Exchange (37)
                                                                     :  +- Scan parquet  (10)
                                                                     +- BroadcastExchange (40)
                                                                        +- Exchange (39)
                                                                           +- Filter (38)
                                                                              +- Scan parquet  (14)
+- == Initial Plan ==
   HashAggregate (66)
   +- Exchange (65)
      +- HashAggregate (64)
         +- HashAggregate (63)
            +- Exchange (62)
               +- HashAggregate (61)
                  +- InMemoryTableScan (1)
                        +- InMemoryRelation (2)
                              +- AdaptiveSparkPlan (50)
                              +- == Final Plan ==
                                 * Project (32)
                                 +- * Generate (31)
                                    +- * Project (30)
                                       +- * Project (29)
                                          +- * BroadcastHashJoin LeftOuter BuildRight (28)
                                             :- ShuffleQueryStage (9), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                             :  +- Exchange (8)
                                             :     +- ShuffleQueryStage (7), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                             :        +- Exchange (6)
                                             :           +- * Filter (5)
                                             :              +- * ColumnarToRow (4)
                                             :                 +- Scan parquet  (3)
                                             +- BroadcastQueryStage (27), Statistics(sizeInBytes=2.0 MiB, rowCount=179)
                                                +- BroadcastExchange (26)
                                                   +- AQEShuffleRead (25)
                                                      +- ShuffleQueryStage (24), Statistics(sizeInBytes=58.3 KiB, rowCount=179)
                                                         +- Exchange (23)
                                                            +- * Project (22)
                                                               +- * BroadcastHashJoin LeftOuter BuildRight (21)
                                                                  :- ShuffleQueryStage (13), Statistics(sizeInBytes=28.9 KiB, rowCount=179)
                                                                  :  +- Exchange (12)
                                                                  :     +- * ColumnarToRow (11)
                                                                  :        +- Scan parquet  (10)
                                                                  +- BroadcastQueryStage (20), Statistics(sizeInBytes=2.0 MiB, rowCount=1)
                                                                     +- BroadcastExchange (19)
                                                                        +- ShuffleQueryStage (18), Statistics(sizeInBytes=208.0 B, rowCount=1)
                                                                           +- Exchange (17)
                                                                              +- * Filter (16)
                                                                                 +- * ColumnarToRow (15)
                                                                                    +- Scan parquet  (14)
                              +- == Initial Plan ==
                                 Project (49)
                                 +- Generate (48)
                                    +- Project (47)
                                       +- Project (46)
                                          +- SortMergeJoin LeftOuter (45)
                                             :- Sort (36)
                                             :  +- Exchange (35)
                                             :     +- Exchange (34)
                                             :        +- Filter (33)
                                             :           +- Scan parquet  (3)
                                             +- Sort (44)
                                                +- Exchange (43)
                                                   +- Project (42)
                                                      +- BroadcastHashJoin LeftOuter BuildRight (41)
                                                         :- Exchange (37)
                                                         :  +- Scan parquet  (10)
                                                         +- BroadcastExchange (40)
                                                            +- Exchange (39)
                                                               +- Filter (38)
                                                                  +- Scan parquet  (14)


(1) InMemoryTableScan
Output [1]: [plant#32469]
Arguments: [plant#32469]

(2) InMemoryRelation
Arguments: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, product#32783, orderDateTime#32784, availabilityDateTime#32785, nextAvailabilityDateTime#32786, mrpController#32787, sourceOfSupplyUuid#32788, purchasingOrg#32789, purchasingGroup#32790, orderProposalId#33183L, orderProposalHorizonGroupingId#33204L, splitIndicator#33604L], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@763c116,StorageLevel(disk, memory, 2 replicas),AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
   *(5) Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderScheduleExploded#32769.product AS product#32783, productOrderScheduleExploded#32769.orderDateTime AS orderDateTime#32784, productOrderScheduleExploded#32769.availabilityDateTime AS availabilityDateTime#32785, productOrderScheduleExploded#32769.nextAvailabilityDateTime AS nextAvailabilityDateTime#32786, productOrderScheduleExploded#32769.mrpController AS mrpController#32787, productOrderScheduleExploded#32769.sourceOfSupplyUuid AS sourceOfSupplyUuid#32788, productOrderScheduleExploded#32769.purchasingOrg AS purchasingOrg#32789, productOrderScheduleExploded#32769.purchasingGroup AS purchasingGroup#32790, xxhash64(CASE WHEN (_extract_supplier#33643 <=> true) THEN supplierOrGroup#32676 END, CASE WHEN (_extract_deliveryDate#33644 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_orderDate#33645 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_supplierSubrange#33646 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_purchasingOrg#33647 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_mrpController#33648 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33649 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, locationOrGroup#32688, ((((((((CASE WHEN (isnull(supplierOrGroup#32676) AND (_extract_supplier#33643 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33644 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33645 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33646 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33647 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33648 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33649 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#32688) THEN 256 ELSE 0 END), 10000000096, 42) AS orderProposalId#33183L, 0 AS orderProposalHorizonGroupingId#33204L, xxhash64(CASE WHEN (_extract_purchasingOrg#33650 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_deliveryDate#33651 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_supplier#33652 <=> true) THEN supplier#32468 END, CASE WHEN (_extract_supplierSubrange#33653 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_orderDate#33654 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_mrpController#33655 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33656 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, plant#32469, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33650 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33651 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#32468) AND (_extract_supplier#33652 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33653 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33654 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33655 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33656 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#32469) THEN 256 ELSE 0 END), 10000000096, 42) AS splitIndicator#33604L]
   +- *(5) Generate explode(productOrderSchedule#32472), [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688], false, [productOrderScheduleExploded#32769]
      +- *(5) Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, orderGroupCriteria#32733.supplier AS _extract_supplier#33643, orderGroupCriteria#32733.deliveryDate AS _extract_deliveryDate#33644, orderGroupCriteria#32733.orderDate AS _extract_orderDate#33645, orderGroupCriteria#32733.supplierSubrange AS _extract_supplierSubrange#33646, orderGroupCriteria#32733.purchasingOrg AS _extract_purchasingOrg#33647, orderGroupCriteria#32733.mrpController AS _extract_mrpController#33648, orderGroupCriteria#32733.purchasingGroup AS _extract_purchasingGroup#33649, orderSplitCriteria#32755.purchasingOrg AS _extract_purchasingOrg#33650, orderSplitCriteria#32755.deliveryDate AS _extract_deliveryDate#33651, orderSplitCriteria#32755.supplier AS _extract_supplier#33652, orderSplitCriteria#32755.supplierSubrange AS _extract_supplierSubrange#33653, orderSplitCriteria#32755.orderDate AS _extract_orderDate#33654, orderSplitCriteria#32755.mrpController AS _extract_mrpController#33655, orderSplitCriteria#32755.purchasingGroup AS _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]
         +- *(5) Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, CASE WHEN isnull(orderGroupCriteria#32579) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#32579 END AS orderGroupCriteria#32733, CASE WHEN isnull(orderSplitCriteria#32580) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#32580 END AS orderSplitCriteria#32755, orderGroupingProfile#32483, coalesce(supplierGroup#32467, supplier#32468) AS supplierOrGroup#32676, coalesce(locationGroup#32485, plant#32469) AS locationOrGroup#32688]
            +- *(5) BroadcastHashJoin [coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470)], [coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482)], LeftOuter, BuildRight, false
               :- ShuffleQueryStage 5
               :  +- Exchange hashpartitioning(coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470), 25), ENSURE_REQUIREMENTS, [plan_id=10613]
               :     +- ShuffleQueryStage 0
               :        +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10605]
               :           +- *(1) Filter ((size(productOrderSchedule#32472, true) > 0) AND isnotnull(productOrderSchedule#32472))
               :              +- *(1) ColumnarToRow
               :                 +- FileScan parquet [supplierGroup#32467,supplier#32468,plant#32469,deliveryDateTime#32470,subrange#32471,productOrderSchedule#32472] Batched: true, DataFilters: [(size(productOrderSchedule#32472, true) > 0), isnotnull(productOrderSchedule#32472)], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [IsNotNull(productOrderSchedule)], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
               +- BroadcastQueryStage 6
                  +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[5, string, true], ), isnull(input[5, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=10888]
                     +- AQEShuffleRead local
                        +- ShuffleQueryStage 4
                           +- Exchange hashpartitioning(coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482), 25), ENSURE_REQUIREMENTS, [plan_id=10810]
                              +- *(4) Project [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
                                 +- *(4) BroadcastHashJoin [orderGroupingProfile#32483], [orderGroupingProfile#32577], LeftOuter, BuildRight, false
                                    :- ShuffleQueryStage 1
                                    :  +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10633]
                                    :     +- *(2) ColumnarToRow
                                    :        +- FileScan parquet [supplier#32479,subrange#32480,plant#32481,deliverydatetime#32482,ordergroupingprofile#32483,supplierGroup#32484,locationGroup#32485] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofi...
                                    +- BroadcastQueryStage 3
                                       +- BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=10654]
                                          +- ShuffleQueryStage 2
                                             +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10646]
                                                +- *(3) Filter isnotnull(orderGroupingProfile#32577)
                                                   +- *(3) ColumnarToRow
                                                      +- FileScan parquet [orderGroupingProfile#32577,orderGroupCriteria#32579,orderSplitCriteria#32580] Batched: true, DataFilters: [isnotnull(orderGroupingProfile#32577)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(orderGroupingProfile)], ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:bo...
+- == Initial Plan ==
   Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderScheduleExploded#32769.product AS product#32783, productOrderScheduleExploded#32769.orderDateTime AS orderDateTime#32784, productOrderScheduleExploded#32769.availabilityDateTime AS availabilityDateTime#32785, productOrderScheduleExploded#32769.nextAvailabilityDateTime AS nextAvailabilityDateTime#32786, productOrderScheduleExploded#32769.mrpController AS mrpController#32787, productOrderScheduleExploded#32769.sourceOfSupplyUuid AS sourceOfSupplyUuid#32788, productOrderScheduleExploded#32769.purchasingOrg AS purchasingOrg#32789, productOrderScheduleExploded#32769.purchasingGroup AS purchasingGroup#32790, xxhash64(CASE WHEN (_extract_supplier#33643 <=> true) THEN supplierOrGroup#32676 END, CASE WHEN (_extract_deliveryDate#33644 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_orderDate#33645 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_supplierSubrange#33646 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_purchasingOrg#33647 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_mrpController#33648 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33649 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, locationOrGroup#32688, ((((((((CASE WHEN (isnull(supplierOrGroup#32676) AND (_extract_supplier#33643 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33644 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33645 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33646 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33647 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33648 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33649 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#32688) THEN 256 ELSE 0 END), 10000000096, 42) AS orderProposalId#33183L, 0 AS orderProposalHorizonGroupingId#33204L, xxhash64(CASE WHEN (_extract_purchasingOrg#33650 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_deliveryDate#33651 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_supplier#33652 <=> true) THEN supplier#32468 END, CASE WHEN (_extract_supplierSubrange#33653 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_orderDate#33654 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_mrpController#33655 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33656 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, plant#32469, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33650 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33651 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#32468) AND (_extract_supplier#33652 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33653 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33654 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33655 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33656 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#32469) THEN 256 ELSE 0 END), 10000000096, 42) AS splitIndicator#33604L]
   +- Generate explode(productOrderSchedule#32472), [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688], false, [productOrderScheduleExploded#32769]
      +- Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, orderGroupCriteria#32733.supplier AS _extract_supplier#33643, orderGroupCriteria#32733.deliveryDate AS _extract_deliveryDate#33644, orderGroupCriteria#32733.orderDate AS _extract_orderDate#33645, orderGroupCriteria#32733.supplierSubrange AS _extract_supplierSubrange#33646, orderGroupCriteria#32733.purchasingOrg AS _extract_purchasingOrg#33647, orderGroupCriteria#32733.mrpController AS _extract_mrpController#33648, orderGroupCriteria#32733.purchasingGroup AS _extract_purchasingGroup#33649, orderSplitCriteria#32755.purchasingOrg AS _extract_purchasingOrg#33650, orderSplitCriteria#32755.deliveryDate AS _extract_deliveryDate#33651, orderSplitCriteria#32755.supplier AS _extract_supplier#33652, orderSplitCriteria#32755.supplierSubrange AS _extract_supplierSubrange#33653, orderSplitCriteria#32755.orderDate AS _extract_orderDate#33654, orderSplitCriteria#32755.mrpController AS _extract_mrpController#33655, orderSplitCriteria#32755.purchasingGroup AS _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]
         +- Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, CASE WHEN isnull(orderGroupCriteria#32579) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#32579 END AS orderGroupCriteria#32733, CASE WHEN isnull(orderSplitCriteria#32580) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#32580 END AS orderSplitCriteria#32755, orderGroupingProfile#32483, coalesce(supplierGroup#32467, supplier#32468) AS supplierOrGroup#32676, coalesce(locationGroup#32485, plant#32469) AS locationOrGroup#32688]
            +- SortMergeJoin [coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470)], [coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482)], LeftOuter
               :- Sort [coalesce(supplierGroup#32467, ) ASC NULLS FIRST, isnull(supplierGroup#32467) ASC NULLS FIRST, coalesce(supplier#32468, ) ASC NULLS FIRST, isnull(supplier#32468) ASC NULLS FIRST, coalesce(subrange#32471, ) ASC NULLS FIRST, isnull(subrange#32471) ASC NULLS FIRST, coalesce(plant#32469, ) ASC NULLS FIRST, isnull(plant#32469) ASC NULLS FIRST, coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#32470) ASC NULLS FIRST], false, 0
               :  +- Exchange hashpartitioning(coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470), 25), ENSURE_REQUIREMENTS, [plan_id=10562]
               :     +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10548]
               :        +- Filter ((size(productOrderSchedule#32472, true) > 0) AND isnotnull(productOrderSchedule#32472))
               :           +- FileScan parquet [supplierGroup#32467,supplier#32468,plant#32469,deliveryDateTime#32470,subrange#32471,productOrderSchedule#32472] Batched: true, DataFilters: [(size(productOrderSchedule#32472, true) > 0), isnotnull(productOrderSchedule#32472)], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [IsNotNull(productOrderSchedule)], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
               +- Sort [coalesce(supplierGroup#32484, ) ASC NULLS FIRST, isnull(supplierGroup#32484) ASC NULLS FIRST, coalesce(supplier#32479, ) ASC NULLS FIRST, isnull(supplier#32479) ASC NULLS FIRST, coalesce(subrange#32480, ) ASC NULLS FIRST, isnull(subrange#32480) ASC NULLS FIRST, coalesce(plant#32481, ) ASC NULLS FIRST, isnull(plant#32481) ASC NULLS FIRST, coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#32482) ASC NULLS FIRST], false, 0
                  +- Exchange hashpartitioning(coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482), 25), ENSURE_REQUIREMENTS, [plan_id=10563]
                     +- Project [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
                        +- BroadcastHashJoin [orderGroupingProfile#32483], [orderGroupingProfile#32577], LeftOuter, BuildRight, false
                           :- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10535]
                           :  +- FileScan parquet [supplier#32479,subrange#32480,plant#32481,deliverydatetime#32482,ordergroupingprofile#32483,supplierGroup#32484,locationGroup#32485] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofi...
                           +- BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=10557]
                              +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10549]
                                 +- Filter isnotnull(orderGroupingProfile#32577)
                                    +- FileScan parquet [orderGroupingProfile#32577,orderGroupCriteria#32579,orderSplitCriteria#32580] Batched: true, DataFilters: [isnotnull(orderGroupingProfile#32577)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(orderGroupingProfile)], ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:bo...
,None)

(3) Scan parquet 
Output [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/grouping-worklist/10000000096]
PushedFilters: [IsNotNull(productOrderSchedule)]
ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,productOrderSchedule:array<struct<product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,mrpController:string,sourceOfSupplyUuid:string,purchasingOrg:string,purchasingGroup:string>>>

(4) ColumnarToRow [codegen id : 1]
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]

(5) Filter [codegen id : 1]
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Condition : ((size(productOrderSchedule#32472, true) > 0) AND isnotnull(productOrderSchedule#32472))

(6) Exchange
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10605]

(7) ShuffleQueryStage
Output [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Arguments: 0

(8) Exchange
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Arguments: hashpartitioning(coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470), 25), ENSURE_REQUIREMENTS, [plan_id=10613]

(9) ShuffleQueryStage
Output [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Arguments: 5

(10) Scan parquet 
Output [7]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000000096]
ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofile:string,supplierGroup:string,locationGroup:string>

(11) ColumnarToRow [codegen id : 2]
Input [7]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485]

(12) Exchange
Input [7]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10633]

(13) ShuffleQueryStage
Output [7]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485]
Arguments: 1

(14) Scan parquet 
Output [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/order-grouping-profile]
PushedFilters: [IsNotNull(orderGroupingProfile)]
ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:boolean,receivingLocation:boolean,deliveryDate:boolean,orderDate:boolean,purchasingOrg:boolean,purchasingGroup:boolean,mrpController:boolean>,orderSplitCriteria:struct<supplier:boolean,supplierSubrange:boolean,receivingLocation:boolean,deliveryDate:boolean,multiplesOrderQuantity:boolean,orderDate:boolean,purchasingOrg:boolean,purchasingGroup:boolean,mrpController:boolean>>

(15) ColumnarToRow [codegen id : 3]
Input [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]

(16) Filter [codegen id : 3]
Input [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Condition : isnotnull(orderGroupingProfile#32577)

(17) Exchange
Input [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10646]

(18) ShuffleQueryStage
Output [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: 2

(19) BroadcastExchange
Input [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=10654]

(20) BroadcastQueryStage
Output [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: 3

(21) BroadcastHashJoin [codegen id : 4]
Left keys [1]: [orderGroupingProfile#32483]
Right keys [1]: [orderGroupingProfile#32577]
Join type: LeftOuter
Join condition: None

(22) Project [codegen id : 4]
Output [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Input [10]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]

(23) Exchange
Input [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: hashpartitioning(coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482), 25), ENSURE_REQUIREMENTS, [plan_id=10810]

(24) ShuffleQueryStage
Output [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: 4

(25) AQEShuffleRead
Input [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: local

(26) BroadcastExchange
Input [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[5, string, true], ), isnull(input[5, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=10888]

(27) BroadcastQueryStage
Output [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: 6

(28) BroadcastHashJoin [codegen id : 5]
Left keys [10]: [coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470)]
Right keys [10]: [coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482)]
Join type: LeftOuter
Join condition: None

(29) Project [codegen id : 5]
Output [11]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, CASE WHEN isnull(orderGroupCriteria#32579) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#32579 END AS orderGroupCriteria#32733, CASE WHEN isnull(orderSplitCriteria#32580) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#32580 END AS orderSplitCriteria#32755, orderGroupingProfile#32483, coalesce(supplierGroup#32467, supplier#32468) AS supplierOrGroup#32676, coalesce(locationGroup#32485, plant#32469) AS locationOrGroup#32688]
Input [15]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]

(30) Project [codegen id : 5]
Output [23]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, orderGroupCriteria#32733.supplier AS _extract_supplier#33643, orderGroupCriteria#32733.deliveryDate AS _extract_deliveryDate#33644, orderGroupCriteria#32733.orderDate AS _extract_orderDate#33645, orderGroupCriteria#32733.supplierSubrange AS _extract_supplierSubrange#33646, orderGroupCriteria#32733.purchasingOrg AS _extract_purchasingOrg#33647, orderGroupCriteria#32733.mrpController AS _extract_mrpController#33648, orderGroupCriteria#32733.purchasingGroup AS _extract_purchasingGroup#33649, orderSplitCriteria#32755.purchasingOrg AS _extract_purchasingOrg#33650, orderSplitCriteria#32755.deliveryDate AS _extract_deliveryDate#33651, orderSplitCriteria#32755.supplier AS _extract_supplier#33652, orderSplitCriteria#32755.supplierSubrange AS _extract_supplierSubrange#33653, orderSplitCriteria#32755.orderDate AS _extract_orderDate#33654, orderSplitCriteria#32755.mrpController AS _extract_mrpController#33655, orderSplitCriteria#32755.purchasingGroup AS _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]
Input [11]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, orderGroupCriteria#32733, orderSplitCriteria#32755, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]

(31) Generate [codegen id : 5]
Input [23]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]
Arguments: explode(productOrderSchedule#32472), [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688], false, [productOrderScheduleExploded#32769]

(32) Project [codegen id : 5]
Output [16]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderScheduleExploded#32769.product AS product#32783, productOrderScheduleExploded#32769.orderDateTime AS orderDateTime#32784, productOrderScheduleExploded#32769.availabilityDateTime AS availabilityDateTime#32785, productOrderScheduleExploded#32769.nextAvailabilityDateTime AS nextAvailabilityDateTime#32786, productOrderScheduleExploded#32769.mrpController AS mrpController#32787, productOrderScheduleExploded#32769.sourceOfSupplyUuid AS sourceOfSupplyUuid#32788, productOrderScheduleExploded#32769.purchasingOrg AS purchasingOrg#32789, productOrderScheduleExploded#32769.purchasingGroup AS purchasingGroup#32790, xxhash64(CASE WHEN (_extract_supplier#33643 <=> true) THEN supplierOrGroup#32676 END, CASE WHEN (_extract_deliveryDate#33644 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_orderDate#33645 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_supplierSubrange#33646 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_purchasingOrg#33647 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_mrpController#33648 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33649 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, locationOrGroup#32688, ((((((((CASE WHEN (isnull(supplierOrGroup#32676) AND (_extract_supplier#33643 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33644 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33645 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33646 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33647 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33648 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33649 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#32688) THEN 256 ELSE 0 END), 10000000096, 42) AS orderProposalId#33183L, 0 AS orderProposalHorizonGroupingId#33204L, xxhash64(CASE WHEN (_extract_purchasingOrg#33650 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_deliveryDate#33651 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_supplier#33652 <=> true) THEN supplier#32468 END, CASE WHEN (_extract_supplierSubrange#33653 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_orderDate#33654 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_mrpController#33655 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33656 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, plant#32469, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33650 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33651 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#32468) AND (_extract_supplier#33652 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33653 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33654 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33655 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33656 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#32469) THEN 256 ELSE 0 END), 10000000096, 42) AS splitIndicator#33604L]
Input [23]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688, productOrderScheduleExploded#32769]

(33) Filter
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Condition : ((size(productOrderSchedule#32472, true) > 0) AND isnotnull(productOrderSchedule#32472))

(34) Exchange
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10548]

(35) Exchange
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Arguments: hashpartitioning(coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470), 25), ENSURE_REQUIREMENTS, [plan_id=10562]

(36) Sort
Input [6]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472]
Arguments: [coalesce(supplierGroup#32467, ) ASC NULLS FIRST, isnull(supplierGroup#32467) ASC NULLS FIRST, coalesce(supplier#32468, ) ASC NULLS FIRST, isnull(supplier#32468) ASC NULLS FIRST, coalesce(subrange#32471, ) ASC NULLS FIRST, isnull(subrange#32471) ASC NULLS FIRST, coalesce(plant#32469, ) ASC NULLS FIRST, isnull(plant#32469) ASC NULLS FIRST, coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#32470) ASC NULLS FIRST], false, 0

(37) Exchange
Input [7]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10535]

(38) Filter
Input [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Condition : isnotnull(orderGroupingProfile#32577)

(39) Exchange
Input [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=10549]

(40) BroadcastExchange
Input [3]: [orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=10557]

(41) BroadcastHashJoin
Left keys [1]: [orderGroupingProfile#32483]
Right keys [1]: [orderGroupingProfile#32577]
Join type: LeftOuter
Join condition: None

(42) Project
Output [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Input [10]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupingProfile#32577, orderGroupCriteria#32579, orderSplitCriteria#32580]

(43) Exchange
Input [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: hashpartitioning(coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482), 25), ENSURE_REQUIREMENTS, [plan_id=10563]

(44) Sort
Input [9]: [supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]
Arguments: [coalesce(supplierGroup#32484, ) ASC NULLS FIRST, isnull(supplierGroup#32484) ASC NULLS FIRST, coalesce(supplier#32479, ) ASC NULLS FIRST, isnull(supplier#32479) ASC NULLS FIRST, coalesce(subrange#32480, ) ASC NULLS FIRST, isnull(subrange#32480) ASC NULLS FIRST, coalesce(plant#32481, ) ASC NULLS FIRST, isnull(plant#32481) ASC NULLS FIRST, coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#32482) ASC NULLS FIRST], false, 0

(45) SortMergeJoin
Left keys [10]: [coalesce(supplierGroup#32467, ), isnull(supplierGroup#32467), coalesce(supplier#32468, ), isnull(supplier#32468), coalesce(subrange#32471, ), isnull(subrange#32471), coalesce(plant#32469, ), isnull(plant#32469), coalesce(deliveryDateTime#32470, 1970-01-01 00:00:00), isnull(deliveryDateTime#32470)]
Right keys [10]: [coalesce(supplierGroup#32484, ), isnull(supplierGroup#32484), coalesce(supplier#32479, ), isnull(supplier#32479), coalesce(subrange#32480, ), isnull(subrange#32480), coalesce(plant#32481, ), isnull(plant#32481), coalesce(deliveryDateTime#32482, 1970-01-01 00:00:00), isnull(deliveryDateTime#32482)]
Join type: LeftOuter
Join condition: None

(46) Project
Output [11]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, CASE WHEN isnull(orderGroupCriteria#32579) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#32579 END AS orderGroupCriteria#32733, CASE WHEN isnull(orderSplitCriteria#32580) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#32580 END AS orderSplitCriteria#32755, orderGroupingProfile#32483, coalesce(supplierGroup#32467, supplier#32468) AS supplierOrGroup#32676, coalesce(locationGroup#32485, plant#32469) AS locationOrGroup#32688]
Input [15]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, supplier#32479, subrange#32480, plant#32481, deliverydatetime#32482, ordergroupingprofile#32483, supplierGroup#32484, locationGroup#32485, orderGroupCriteria#32579, orderSplitCriteria#32580]

(47) Project
Output [23]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, orderGroupCriteria#32733.supplier AS _extract_supplier#33643, orderGroupCriteria#32733.deliveryDate AS _extract_deliveryDate#33644, orderGroupCriteria#32733.orderDate AS _extract_orderDate#33645, orderGroupCriteria#32733.supplierSubrange AS _extract_supplierSubrange#33646, orderGroupCriteria#32733.purchasingOrg AS _extract_purchasingOrg#33647, orderGroupCriteria#32733.mrpController AS _extract_mrpController#33648, orderGroupCriteria#32733.purchasingGroup AS _extract_purchasingGroup#33649, orderSplitCriteria#32755.purchasingOrg AS _extract_purchasingOrg#33650, orderSplitCriteria#32755.deliveryDate AS _extract_deliveryDate#33651, orderSplitCriteria#32755.supplier AS _extract_supplier#33652, orderSplitCriteria#32755.supplierSubrange AS _extract_supplierSubrange#33653, orderSplitCriteria#32755.orderDate AS _extract_orderDate#33654, orderSplitCriteria#32755.mrpController AS _extract_mrpController#33655, orderSplitCriteria#32755.purchasingGroup AS _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]
Input [11]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, orderGroupCriteria#32733, orderSplitCriteria#32755, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]

(48) Generate
Input [23]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderSchedule#32472, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688]
Arguments: explode(productOrderSchedule#32472), [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688], false, [productOrderScheduleExploded#32769]

(49) Project
Output [16]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderScheduleExploded#32769.product AS product#32783, productOrderScheduleExploded#32769.orderDateTime AS orderDateTime#32784, productOrderScheduleExploded#32769.availabilityDateTime AS availabilityDateTime#32785, productOrderScheduleExploded#32769.nextAvailabilityDateTime AS nextAvailabilityDateTime#32786, productOrderScheduleExploded#32769.mrpController AS mrpController#32787, productOrderScheduleExploded#32769.sourceOfSupplyUuid AS sourceOfSupplyUuid#32788, productOrderScheduleExploded#32769.purchasingOrg AS purchasingOrg#32789, productOrderScheduleExploded#32769.purchasingGroup AS purchasingGroup#32790, xxhash64(CASE WHEN (_extract_supplier#33643 <=> true) THEN supplierOrGroup#32676 END, CASE WHEN (_extract_deliveryDate#33644 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_orderDate#33645 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_supplierSubrange#33646 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_purchasingOrg#33647 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_mrpController#33648 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33649 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, locationOrGroup#32688, ((((((((CASE WHEN (isnull(supplierOrGroup#32676) AND (_extract_supplier#33643 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33644 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33645 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33646 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33647 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33648 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33649 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#32688) THEN 256 ELSE 0 END), 10000000096, 42) AS orderProposalId#33183L, 0 AS orderProposalHorizonGroupingId#33204L, xxhash64(CASE WHEN (_extract_purchasingOrg#33650 <=> true) THEN productOrderScheduleExploded#32769.purchasingOrg END, CASE WHEN (_extract_deliveryDate#33651 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_supplier#33652 <=> true) THEN supplier#32468 END, CASE WHEN (_extract_supplierSubrange#33653 <=> true) THEN subrange#32471 END, CASE WHEN (_extract_orderDate#33654 <=> true) THEN productOrderScheduleExploded#32769.orderDateTime END, CASE WHEN (_extract_mrpController#33655 <=> true) THEN productOrderScheduleExploded#32769.mrpController END, orderGroupingProfile#32483, CASE WHEN (_extract_purchasingGroup#33656 <=> true) THEN productOrderScheduleExploded#32769.purchasingGroup END, plant#32469, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingOrg) AND (_extract_purchasingOrg#33650 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#32470) AND (_extract_deliveryDate#33651 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#32468) AND (_extract_supplier#33652 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#32471) AND (_extract_supplierSubrange#33653 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.orderDateTime) AND (_extract_orderDate#33654 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.mrpController) AND (_extract_mrpController#33655 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#32483) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#32769.purchasingGroup) AND (_extract_purchasingGroup#33656 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#32469) THEN 256 ELSE 0 END), 10000000096, 42) AS splitIndicator#33604L]
Input [23]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, _extract_supplier#33643, _extract_deliveryDate#33644, _extract_orderDate#33645, _extract_supplierSubrange#33646, _extract_purchasingOrg#33647, _extract_mrpController#33648, _extract_purchasingGroup#33649, _extract_purchasingOrg#33650, _extract_deliveryDate#33651, _extract_supplier#33652, _extract_supplierSubrange#33653, _extract_orderDate#33654, _extract_mrpController#33655, _extract_purchasingGroup#33656, orderGroupingProfile#32483, supplierOrGroup#32676, locationOrGroup#32688, productOrderScheduleExploded#32769]

(50) AdaptiveSparkPlan
Output [16]: [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, product#32783, orderDateTime#32784, availabilityDateTime#32785, nextAvailabilityDateTime#32786, mrpController#32787, sourceOfSupplyUuid#32788, purchasingOrg#32789, purchasingGroup#32790, orderProposalId#33183L, orderProposalHorizonGroupingId#33204L, splitIndicator#33604L]
Arguments: isFinalPlan=true

(51) TableCacheQueryStage
Output [1]: [plant#32469]
Arguments: 0

(52) HashAggregate [codegen id : 1]
Input [1]: [plant#32469]
Keys [1]: [plant#32469]
Functions: []
Aggregate Attributes: []
Results [1]: [plant#32469]

(53) Exchange
Input [1]: [plant#32469]
Arguments: hashpartitioning(plant#32469, 25), ENSURE_REQUIREMENTS, [plan_id=11036]

(54) ShuffleQueryStage
Output [1]: [plant#32469]
Arguments: 1

(55) AQEShuffleRead
Input [1]: [plant#32469]
Arguments: coalesced

(56) HashAggregate [codegen id : 2]
Input [1]: [plant#32469]
Keys [1]: [plant#32469]
Functions: []
Aggregate Attributes: []
Results: []

(57) HashAggregate [codegen id : 2]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#34811L]
Results [1]: [count#34812L]

(58) Exchange
Input [1]: [count#34812L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=11068]

(59) ShuffleQueryStage
Output [1]: [count#34812L]
Arguments: 2

(60) HashAggregate [codegen id : 3]
Input [1]: [count#34812L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#34568L]
Results [1]: [count(1)#34568L AS count#34569L]

(61) HashAggregate
Input [1]: [plant#32469]
Keys [1]: [plant#32469]
Functions: []
Aggregate Attributes: []
Results [1]: [plant#32469]

(62) Exchange
Input [1]: [plant#32469]
Arguments: hashpartitioning(plant#32469, 25), ENSURE_REQUIREMENTS, [plan_id=10984]

(63) HashAggregate
Input [1]: [plant#32469]
Keys [1]: [plant#32469]
Functions: []
Aggregate Attributes: []
Results: []

(64) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#34811L]
Results [1]: [count#34812L]

(65) Exchange
Input [1]: [count#34812L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=10988]

(66) HashAggregate
Input [1]: [count#34812L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#34568L]
Results [1]: [count(1)#34568L AS count#34569L]

(67) AdaptiveSparkPlan
Output [1]: [count#34569L]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
temporal.activity.id	716699f2-34fb-38b0-856a-57fc6af8628a
temporal.activity.type	CreateOrderProposalShards