Function BM_SimpleTableReaderAsyncMulti

src/sdk/mini_cluster_microbenchmark.cc:136–174

    return true;
}
static void BM_SimpleTableReaderAsyncMulti(benchmark::State& state) {  // NOLINT
    ::fedb::sdk::SQLRouterOptions sql_opt;
    sql_opt.zk_cluster = mc->GetZkCluster();
    sql_opt.zk_path = mc->GetZkPath();
    auto router = NewClusterSQLRouter(sql_opt);
    if (router == nullptr) {
        std::cout << "fail to init sql cluster router" << std::endl;
        return;
    }
    std::string db = "db" + GenRand();
    ::hybridse::sdk::Status status;
    router->CreateDB(db, &status);
    std::string ddl =
        "create table t1"
        "("
        "col1 string, col2 bigint,"
        "index(key=col1, ts=col2));";
    router->ExecuteDDL(db, ddl, &status);
    router->RefreshCatalog();
    int64_t st = 361;
    int64_t et = 1;
    int records = state.range(0);
    std::string key = "k1";
    for (int32_t i = 1; i < records + 361; i++) {
        std::string row = "insert into t1 values('" + key + "', " + std::to_string(i) + "L);";
        router->ExecuteInsert(db, row, &status);
    }
    auto reader = router->GetTableReader();

    ::fedb::sdk::ScanOption so;
    auto rs = reader->Scan(db, "t1", key, st, et, so, &status);
    if (!rs || rs->Size() < 300) {
        LOG(WARNING) << "result count is mismatch";
        return;
    }
    for (auto _ : state) {
        benchmark::DoNotOptimize(Async3Times(db, "t1", key, st, et, reader, &status));
    }
}

static void BM_SimpleTableReaderAsync(benchmark::State& state) {  // NOLINT
    ::fedb::sdk::SQLRouterOptions sql_opt;