POC for rewriting queries with Caggs, add early validations

Author: natalya-aksman

src/guc.c

@@ -149,6 +149,8 @@ TSDLLEXPORT bool ts_guc_enable_delete_after_compression = false;
 TSDLLEXPORT bool ts_guc_enable_merge_on_cagg_refresh = false;
 
 bool ts_guc_enable_partitioned_hypertables = false;
+TSDLLEXPORT bool ts_guc_enable_cagg_rewrites = false;
+TSDLLEXPORT bool ts_guc_cagg_rewrites_debug_info = false;
 
 /* default value of ts_guc_max_open_chunks_per_insert and
  * ts_guc_max_cached_chunks_per_hypertable will be set as their respective boot-value when the
@@ -760,6 +762,28 @@ _guc_init(void)
 							 NULL,
 							 NULL);
 
+	DefineCustomBoolVariable(MAKE_EXTOPTION("enable_cagg_rewrites"),
+							 "Enable rewriting queries with Caggs",
+							 "Enable rewriting queries with eligible continuous aggregates",
+							 &ts_guc_enable_cagg_rewrites,
+							 false,
+							 PGC_USERSET,
+							 0,
+							 NULL,
+							 NULL,
+							 NULL);
+
+	DefineCustomBoolVariable(MAKE_EXTOPTION("cagg_rewrites_debug_info"),
+							 "Print debug info about whether queries can be rewritten with Caggs",
+							 "Print debug info about  whether queries can be rewritten with Caggs",
+							 &ts_guc_cagg_rewrites_debug_info,
+							 false,
+							 PGC_USERSET,
+							 0,
+							 NULL,
+							 NULL,
+							 NULL);
+
 	DefineCustomBoolVariable(MAKE_EXTOPTION("enable_compression_wal_markers"),
 							 "Enable WAL markers for compression ops",
 							 "Enable the generation of markers in the WAL stream which mark the "

src/guc.h

@@ -79,6 +79,9 @@ extern TSDLLEXPORT bool ts_guc_enable_multikey_skip_scan;
 extern TSDLLEXPORT double ts_guc_skip_scan_run_cost_multiplier;
 extern TSDLLEXPORT bool ts_guc_debug_skip_scan_info;
 
+extern TSDLLEXPORT bool ts_guc_enable_cagg_rewrites;
+extern TSDLLEXPORT bool ts_guc_cagg_rewrites_debug_info;
+
 /* Only settable in debug mode for testing */
 extern TSDLLEXPORT bool ts_guc_enable_null_compression;
 extern TSDLLEXPORT bool ts_guc_enable_compression_ratio_warnings;

src/planner/CMakeLists.txt

@@ -4,6 +4,8 @@ set(SOURCES
     ${CMAKE_CURRENT_SOURCE_DIR}/agg_bookend.c
     ${CMAKE_CURRENT_SOURCE_DIR}/constify_now.c
     ${CMAKE_CURRENT_SOURCE_DIR}/constraint_cleanup.c
+    ${CMAKE_CURRENT_SOURCE_DIR}/continuous_aggs_common.c
+    ${CMAKE_CURRENT_SOURCE_DIR}/continuous_agg_rewrites.c
     ${CMAKE_CURRENT_SOURCE_DIR}/expand_hypertable.c
     ${CMAKE_CURRENT_SOURCE_DIR}/partialize.c
     ${CMAKE_CURRENT_SOURCE_DIR}/space_constraint.c)