X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fftacmp%2Fquery_plan.h;h=c1001d6754294277baad5390f64d44b07b70d16c;hb=52bf6cf53a585197f998187399ebfd88681d4490;hp=ec782e0318cdcecd80372efba8cf080700d26e39;hpb=eb761d89890df8d74532dd4faad118db18fd3b7d;p=com%2Fgs-lite.git

diff --git a/src/ftacmp/query_plan.h b/src/ftacmp/query_plan.h
index ec782e0..c1001d6 100644
--- a/src/ftacmp/query_plan.h
+++ b/src/ftacmp/query_plan.h
@@ -492,6 +492,7 @@ public:
 
 	int lfta_disorder;		// maximum disorder in the steam between lfta, hfta
 	int hfta_disorder;		// maximum disorder in the  hfta
+	int hfta_slow_flush;	// outputs per input, 0 means no slow flush
 
 //		rollup, cube, and grouping_sets cannot be readily reconstructed by
 //		analyzing the patterns, so explicitly record them here.
@@ -517,11 +518,15 @@ public:
 
 	std::string generate_operator(int i, std::string params);
   	std::string get_include_file(){
-			if(hfta_disorder <= 1){
-				return("#include <groupby_operator.h>\n");
+		if(hfta_disorder <= 1){
+			if(hfta_slow_flush>0){
+				return("#include <groupby_slowflush_operator.h>\n");
 			}else{
-				return("#include <groupby_operator_oop.h>\n");
+				return("#include <groupby_operator.h>\n");
 			}
+		}else{
+			return("#include <groupby_operator_oop.h>\n");
+		}
 	};
 
     std::vector<select_element *> get_select_list(){return select_list;};
@@ -554,10 +559,12 @@ public:
 	sgah_qpn(){
 		lfta_disorder = 1;
 		hfta_disorder = 1;
+		hfta_slow_flush = 0;
 	};
 	sgah_qpn(query_summary_class *qs,table_list *Schema){
 		lfta_disorder = 1;
 		hfta_disorder = 1;
+		hfta_slow_flush = 0;
 
 //				Get the table name.
 //				NOTE the colrefs have the tablevar ref (an int)
@@ -640,6 +647,7 @@ public:
 							param_tbl->handle_access(param_names[pi]));
 		}
 		ret->definitions = definitions;
+		ret->hfta_slow_flush = hfta_slow_flush;
 
 		ret->node_name = node_name + suffix;