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

Submitted Time: 2026/02/06 10:33:40
Duration: 0.6 s
Succeeded Jobs: 195 196 197 198 199 200 201 202 203 204

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 (2)\n \nduration: 2 ms"; 2 [labelType="html" label="HashAggregate time in aggregation build: 2 ms number of output rows: 1"]; } 3 [labelType="html" label="Exchange shuffle records written: 25 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 5 ms (0 ms, 0 ms, 0 ms (stage 371.0: task 2786)) 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: 25 local bytes read: 750.0 B fetch wait time: 0 ms remote bytes read: 1122.0 B merged fetch fallback count: 0 local blocks read: 10 remote merged chunks fetched: 0 remote blocks read: 15 data size total (min, med, max (stageId: taskId)) 400.0 B (16.0 B, 16.0 B, 16.0 B (stage 371.0: task 2793)) local merged bytes read: 0.0 B number of partitions: 1 remote reqs duration: 3 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 1872.0 B (72.0 B, 75.0 B, 75.0 B (stage 371.0: task 2791))"]; subgraph cluster4 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n8 ms (0 ms, 0 ms, 1 ms (stage 371.0: task 2789))"; 5 [labelType="html" label="HashAggregate time in aggregation build total (min, med, max (stageId: taskId)) 5 ms (0 ms, 0 ms, 1 ms (stage 371.0: task 2790)) number of output rows: 25"]; } 6 [labelType="html" label="InMemoryTableScan number of output rows: 1,196"]; 7 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n268 ms (0 ms, 8 ms, 23 ms (stage 368.0: task 2767))"; 9 [labelType="html" label=" Project "]; 10 [labelType="html" label="Generate number of output rows: 1,196"]; 11 [labelType="html" label=" Project "]; 12 [labelType="html" label=" Project "]; 13 [labelType="html" label="BroadcastHashJoin number of output rows: 179"]; } 14 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 19 ms (0 ms, 0 ms, 1 ms (stage 362.0: task 2717)) 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: 179 local bytes read total (min, med, max (stageId: taskId)) 108.9 KiB (895.0 B, 4.5 KiB, 10.8 KiB (stage 368.0: task 2778)) fetch wait time total (min, med, max (stageId: taskId)) 10 ms (0 ms, 0 ms, 4 ms (stage 368.0: task 2769)) remote bytes read total (min, med, max (stageId: taskId)) 43.9 KiB (368.0 B, 1274.0 B, 7.0 KiB (stage 368.0: task 2764)) merged fetch fallback count: 0 local blocks read: 106 remote merged chunks fetched: 0 remote blocks read: 52 data size total (min, med, max (stageId: taskId)) 304.9 KiB (7.1 KiB, 12.2 KiB, 18.1 KiB (stage 362.0: task 2723)) local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration total (min, med, max (stageId: taskId)) 63 ms (2 ms, 3 ms, 5 ms (stage 368.0: task 2769)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 152.8 KiB (4.0 KiB, 6.1 KiB, 8.9 KiB (stage 362.0: task 2717))"]; 15 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 9 ms (1 ms, 1 ms, 2 ms (stage 354.0: task 2675)) 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: 179 local bytes read total (min, med, max (stageId: taskId)) 71.2 KiB (1686.0 B, 2.9 KiB, 4.1 KiB (stage 362.0: task 2714)) fetch wait time total (min, med, max (stageId: taskId)) 1 ms (0 ms, 0 ms, 1 ms (stage 362.0: task 2746)) remote bytes read total (min, med, max (stageId: taskId)) 77.8 KiB (1798.0 B, 2.9 KiB, 4.8 KiB (stage 362.0: task 2733)) merged fetch fallback count: 0 local blocks read: 75 remote merged chunks fetched: 0 remote blocks read: 75 data size total (min, med, max (stageId: taskId)) 304.9 KiB (41.7 KiB, 52.0 KiB, 59.3 KiB (stage 354.0: task 2675)) local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration total (min, med, max (stageId: taskId)) 78 ms (2 ms, 3 ms, 4 ms (stage 362.0: task 2717)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 149.0 KiB (21.5 KiB, 25.3 KiB, 28.0 KiB (stage 354.0: task 2675))"]; subgraph cluster16 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n704 ms (94 ms, 111 ms, 186 ms (stage 354.0: task 2680))"; 17 [labelType="html" label="Filter number of output rows: 179"]; 18 [labelType="html" label="ColumnarToRow number of output rows: 179 number of input batches: 6"]; } 19 [labelType="html" label="Scan parquet number of files read: 6 scan time total (min, med, max (stageId: taskId)) 700 ms (93 ms, 110 ms, 186 ms (stage 354.0: task 2680)) metadata time: 0 ms size of files read: 91.1 KiB number of output rows: 179"]; 20 [labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 6 ms time to collect: 38 ms number of output rows: 179 data size: 2.0 MiB"]; 21 [labelType="html" label="AQEShuffleRead number of partitions: 1"]; 22 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 17 ms (0 ms, 0 ms, 0 ms (stage 360.0: task 2712)) 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: 179 local bytes read: 44.4 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 164 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 58.3 KiB (2.3 KiB, 2.3 KiB, 2.6 KiB (stage 360.0: task 2719)) local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 44.4 KiB (1536.0 B, 1861.0 B, 2029.0 B (stage 360.0: task 2712))"]; subgraph cluster23 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n98 ms (2 ms, 2 ms, 11 ms (stage 360.0: task 2712))"; 24 [labelType="html" label=" Project "]; 25 [labelType="html" label="BroadcastHashJoin number of output rows: 179"]; } 26 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time: 1 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: 179 local bytes read total (min, med, max (stageId: taskId)) 15.2 KiB (499.0 B, 621.0 B, 727.0 B (stage 360.0: task 2712)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 360.0: task 2710)) remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 25 remote merged chunks fetched: 0 remote blocks read: 0 data size: 28.9 KiB local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 15.2 KiB"]; subgraph cluster27 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: 114 ms"; 28 [labelType="html" label="ColumnarToRow number of output rows: 179 number of input batches: 1"]; } 29 [labelType="html" label="Scan parquet number of files read: 1 scan time: 113 ms metadata time: 0 ms size of files read: 3.6 KiB number of output rows: 179"]; 30 [labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 4 ms time to collect: 31 ms number of output rows: 1 data size: 2.0 MiB"]; 31 [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: 155.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: 208.0 B local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 155.0 B"]; subgraph cluster32 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 105 ms"; 33 [labelType="html" label="Filter number of output rows: 1"]; 34 [labelType="html" label="ColumnarToRow number of output rows: 1 number of input batches: 1"]; } 35 [labelType="html" label="Scan parquet number of files read: 1 scan time: 104 ms metadata time: 0 ms size of files read: 7.0 KiB number of output rows: 1"]; 2->0; 3->2; 5->3; 6->5; 7->6; 9->7; 10->9; 11->10; 12->11; 13->12; 14->13; 15->14; 17->15; 18->17; 19->18; 20->13; 21->20; 22->21; 24->22; 25->24; 26->25; 28->26; 29->28; 30->25; 31->30; 33->31; 34->33; 35->34; }

AdaptiveSparkPlan isFinalPlan=true

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

WholeStageCodegen (2)

Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=10955]

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

WholeStageCodegen (1)

InMemoryTableScan

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 (59)
+- == Final Plan ==
   * HashAggregate (55)
   +- ShuffleQueryStage (54), Statistics(sizeInBytes=400.0 B, rowCount=25)
      +- 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 (58)
   +- Exchange (57)
      +- HashAggregate (56)
         +- 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: []

(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: []
Arguments: 0

(52) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#34404L]
Results [1]: [count#34405L]

(53) Exchange
Input [1]: [count#34405L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=10955]

(54) ShuffleQueryStage
Output [1]: [count#34405L]
Arguments: 1

(55) HashAggregate [codegen id : 2]
Input [1]: [count#34405L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#34161L]
Results [1]: [count(1)#34161L AS count#34162L]

(56) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#34404L]
Results [1]: [count#34405L]

(57) Exchange
Input [1]: [count#34405L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=10582]

(58) HashAggregate
Input [1]: [count#34405L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#34161L]
Results [1]: [count(1)#34161L AS count#34162L]

(59) AdaptiveSparkPlan
Output [1]: [count#34162L]
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