[CBRD-25447] Support parallel heap scan

cubrid/CMakeLists.txt

@@ -254,6 +254,7 @@ set(QUERY_SOURCES
   ${QUERY_DIR}/string_regex_re2.cpp
   ${QUERY_DIR}/vacuum.c  
   ${QUERY_DIR}/xasl_cache.c
+  ${QUERY_DIR}/parallel_heap_scan.cpp
   )
 set(QUERY_HEADERS
   ${QUERY_DIR}/query_aggregate.hpp

sa/CMakeLists.txt

@@ -288,6 +288,7 @@ set(QUERY_SOURCES
   ${QUERY_DIR}/vacuum.c
   ${QUERY_DIR}/xasl_cache.c
   ${QUERY_DIR}/xasl_to_stream.c
+  ${QUERY_DIR}/parallel_heap_scan.cpp
   )
 set(QUERY_HEADERS
   ${QUERY_DIR}/query_aggregate.hpp

src/parser/parse_tree.h

@@ -1741,7 +1741,8 @@ typedef enum
   PT_SPEC_FLAG_MVCC_ASSIGN_REEV = 0x800,	/* the spec is used in UPDATE assignment reevaluation */
   PT_SPEC_FLAG_DOESNT_HAVE_UNIQUE = 0x1000,	/* the spec was checked and does not have any uniques */
   PT_SPEC_FLAG_SAMPLING_SCAN = 0x2000,	/* spec for sampling scan */
-  PT_SPEC_FLAG_REFERENCED_AT_ODKU = 0x4000	/* spec for odku assignment */
+  PT_SPEC_FLAG_REFERENCED_AT_ODKU = 0x4000,	/* spec for odku assignment */
+  PT_SPEC_FLAG_NOT_FOR_PARALLEL_HEAP_SCAN = 0x8000	/* spec for not for parallel heap scan */
 } PT_SPEC_FLAG;
 
 typedef enum

src/parser/xasl_generation.c

@@ -9982,6 +9982,19 @@ pt_attribute_to_regu (PARSER_CONTEXT * parser, PT_NODE * attr)
 	      /* The attribute is correlated variable. Find it in an enclosing scope(s). Note that this subquery has
 	       * also just been determined to be a correlated subquery. */
 	      REGU_VARIABLE_SET_FLAG (regu, REGU_VARIABLE_CORRELATED);
+
+	      for (table_info = symbols->table_info; table_info != NULL; table_info = table_info->next)
+		{
+		  PT_SPEC_FLAG flag = table_info->class_spec->info.spec.flag;
+		  if (table_info->class_spec)
+		    {
+		      table_info->class_spec->info.spec.flag =
+			(PT_SPEC_FLAG) (flag | PT_SPEC_FLAG_NOT_FOR_PARALLEL_HEAP_SCAN);
+		    }
+		}
+
+	      table_info = NULL;
+
 	      if (symbols->stack == NULL)
 		{
 		  if (!pt_has_error (parser))
@@ -12204,6 +12217,7 @@ pt_to_class_spec_list (PARSER_CONTEXT * parser, PT_NODE * spec, PT_NODE * where_
   OUTPTR_LIST *output_val_list = NULL;
   REGU_VARIABLE_LIST regu_var_list = NULL;
   DB_VALUE **db_values_array_p = NULL;
+  bool is_parallel_heap_scan_callable = true;
 
   assert (parser != NULL);
 
@@ -12259,10 +12273,12 @@ pt_to_class_spec_list (PARSER_CONTEXT * parser, PT_NODE * spec, PT_NODE * where_
 	      if (PT_IS_VALUE_QUERY (spec))
 		{
 		  scan_type = TARGET_REGUVAL_LIST;
+		  is_parallel_heap_scan_callable = false;
 		}
 	      else if (spec->info.spec.meta_class == PT_META_CLASS)
 		{
 		  scan_type = TARGET_CLASS_ATTR;
+		  is_parallel_heap_scan_callable = false;
 		}
 	      else
 		{
@@ -12569,6 +12585,10 @@ pt_to_class_spec_list (PARSER_CONTEXT * parser, PT_NODE * spec, PT_NODE * where_
 		{
 		  access->flags = (ACCESS_SPEC_FLAG) (access->flags | ACCESS_SPEC_FLAG_FOR_UPDATE);
 		}
+	      if (!is_parallel_heap_scan_callable || (spec->info.spec.flag & PT_SPEC_FLAG_NOT_FOR_PARALLEL_HEAP_SCAN))
+		{
+		  access->flags = (ACCESS_SPEC_FLAG) (access->flags | ACCESS_SPEC_FLAG_NOT_FOR_PARALLEL_HEAP_SCAN);
+		}
 
 	      access->next = access_list;
 	      access_list = access;
@@ -14279,6 +14299,7 @@ ptqo_to_scan_proc (PARSER_CONTEXT * parser, QO_PLAN * plan, XASL_NODE * xasl, PT
 
   if (spec != NULL)
     {
+      spec->info.spec.flag = (PT_SPEC_FLAG) (spec->info.spec.flag | PT_SPEC_FLAG_NOT_FOR_PARALLEL_HEAP_SCAN);
       xasl->spec_list = pt_to_spec_list (parser, spec, where_key_part, where_part, plan, info, NULL, where_hash_part);
       if (xasl->spec_list == NULL)
 	{