X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fftacmp%2Fstream_query.cc;h=9d12cb070137ceb2194db892d0ae3e7d22b578b3;hb=refs%2Fheads%2Frelease%2F0.1.0;hp=17d4293d109e2258be22be46d5dda322fb3dd13a;hpb=7210c67dde90098460d1f0922deeb810be521673;p=com%2Fgs-lite.git

diff --git a/src/ftacmp/stream_query.cc b/src/ftacmp/stream_query.cc
index 17d4293..9d12cb0 100644
--- a/src/ftacmp/stream_query.cc
+++ b/src/ftacmp/stream_query.cc
@@ -1949,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()) {