add sql.dev_rtx_parallel_scan. param.

include/jogasaki/configuration.h

@@ -458,6 +458,14 @@ class configuration {
         zone_offset_ = arg;
     }
 
+    [[nodiscard]] bool rtx_parallel_scan() const noexcept {
+        return rtx_parallel_scan_;
+    }
+
+    void rtx_parallel_scan(bool arg) noexcept {
+        rtx_parallel_scan_ = arg;
+    }
+
     friend inline std::ostream& operator<<(std::ostream& out, configuration const& cfg) {
 
         //NOLINTBEGIN
@@ -510,6 +518,7 @@ class configuration {
         print_non_default(lowercase_regular_identifiers);
         print_non_default(zone_offset);
         print_non_default(scan_block_size);
+        print_non_default(rtx_parallel_scan);
 
         if(cfg.req_cancel_config()) {
             out << "req_cancel_config:" << *cfg.req_cancel_config() << " "; \
@@ -566,6 +575,7 @@ class configuration {
     bool lowercase_regular_identifiers_ = false;
     std::int32_t zone_offset_ = 0;
     std::size_t scan_block_size_ = 0;
+    bool rtx_parallel_scan_ = false;
 
 };
 

src/jogasaki/api/impl/database.cpp

@@ -176,6 +176,7 @@ void dump_public_configurations(configuration const& cfg) {
     LOGCFG << "(dev_lowercase_regular_identifiers) " << cfg.lowercase_regular_identifiers() << " : whether to lowercase regular identifiers";
     LOGCFG << "(zone_offset) " << cfg.zone_offset() << " : system time zone offset in minutes";
     LOGCFG << "(scan_block_size) " << cfg.scan_block_size() << " : max records processed by scan operator before yielding to other task";
+    LOGCFG << "(dev_rtx_parallel_scan) " << cfg.rtx_parallel_scan() << " : whether to enable parallel scan for RTX";
 }
 
 status database::start() {

src/jogasaki/api/resource/bridge.cpp

@@ -248,6 +248,9 @@ bool process_sql_config(std::shared_ptr<jogasaki::configuration>& ret, tateyama:
     if (auto v = jogasaki_config->get<std::size_t>("scan_block_size")) {
         ret->scan_block_size(v.value());
     }
+    if (auto v = jogasaki_config->get<bool>("dev_rtx_parallel_scan")) {
+        ret->rtx_parallel_scan(v.value());
+    }
     return true;
 }