X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fftacmp%2Fstream_query.cc;h=9d12cb070137ceb2194db892d0ae3e7d22b578b3;hb=804ea15b01566ac0de58781ca61870b4824d0e02;hp=aacf1b6bc8e012eef6320ca65026dc54d1820939;hpb=3ff5c433efcaee8b01fbeed90ab848008f2e6278;p=com%2Fgs-lite.git

diff --git a/src/ftacmp/stream_query.cc b/src/ftacmp/stream_query.cc
index aacf1b6..9d12cb0 100644
--- a/src/ftacmp/stream_query.cc
+++ b/src/ftacmp/stream_query.cc
@@ -1850,6 +1850,10 @@ table_def *stream_query::get_output_tabledef(){
 	return( query_plan[qhead]->get_fields() );
 }
 
+vector<string> stream_query::get_tbl_keys(vector<string> &partial_keys){
+	return query_plan[qhead]->get_tbl_keys(partial_keys);
+}
+
 
 
 //////////////////////////////////////////////////////////
@@ -1945,6 +1949,14 @@ void get_prefilter_temporal_cids(std::vector<stream_query *> lfta_list, col_id_s
 			gb_tbl = sgah_node->get_gb_tbl();
 		}
 
+		if(lfta_list[s]->query_plan[0]->node_type() == "filter_join"){
+			filter_join_qpn *fj_node = (filter_join_qpn *)lfta_list[s]->query_plan[0];
+			sl_list = fj_node->get_select_se_list();
+			col_id ci;	// also get the temporal var in case not in select list
+			ci.load_from_colref(fj_node->temporal_var);
+			temp_cids.insert(ci);
+		}
+
 		for(sl=0;sl<sl_list.size();sl++){
 			data_type *sdt = sl_list[sl]->get_data_type();
 			if (sdt->is_temporal()) {