Method CreateTestEnv

be/src/benchmarks/hash-table-benchmark.cc:148–162

Initialize test_env_ and runtime_state_ with the given page size and capacity for the given number of pages. If test_env_ was already created, then re-creates it.

  /// Initialize test_env_ and runtime_state_ with the given page size and capacity
  /// for the given number of pages. If test_env_ was already created, then re-creates it.
  void CreateTestEnv(int64_t min_page_size = 64 * 1024,
      int64_t buffer_bytes_limit = 4L * 1024 * 1024 * 1024) {
    test_env_.reset(new TestEnv());
    test_env_->SetBufferPoolArgs(min_page_size, buffer_bytes_limit);
    Status status = test_env_->Init();
    CHECK(status.ok());

    TQueryOptions query_options;
    query_options.__set_default_spillable_buffer_size(min_page_size);
    query_options.__set_min_spillable_buffer_size(min_page_size);
    query_options.__set_buffer_pool_limit(buffer_bytes_limit);
    // Also initializes runtime_state_
    status = test_env_->CreateQueryState(0, &query_options, &runtime_state_);
    CHECK(status.ok());
  }
  /// Construct hash table and buffer pool client.
  /// Created objects and resources (e.g. reservations) are automatically freed
  /// in TearDown().