| 46 | } |
| 47 | |
| 48 | void SetUp() override { |
| 49 | tmp_dir_ = "/tmp" / boost::filesystem::unique_path(); |
| 50 | ASSERT_OK(FileSystemUtil::RemoveAndCreateDirectory(tmp_dir_.string())); |
| 51 | |
| 52 | test_env_->SetBufferPoolArgs(1, 1024); |
| 53 | ASSERT_OK(test_env_->Init()); |
| 54 | ASSERT_OK(test_env_->CreateQueryState(0, nullptr, &runtime_state_)); |
| 55 | MemTracker* client_tracker = |
| 56 | pool_.Add(new MemTracker(-1, "client", runtime_state_->instance_mem_tracker())); |
| 57 | ASSERT_OK(test_env_->exec_env()->buffer_pool()->RegisterClient( |
| 58 | "TupleFileReadWriteTest", nullptr, runtime_state_->instance_buffer_reservation(), |
| 59 | client_tracker, std::numeric_limits<int64>::max(), |
| 60 | runtime_state_->runtime_profile(), &buffer_pool_client_)); |
| 61 | |
| 62 | // Create nullable row descriptor |
| 63 | DescriptorTblBuilder builder(fe_.get(), &pool_); |
| 64 | builder.DeclareTuple() << TYPE_INT; |
| 65 | DescriptorTbl* desc_tbl = builder.Build(); |
| 66 | |
| 67 | vector<bool> nullable_tuples = {false}; |
| 68 | vector<TTupleId> tuple_id = {static_cast<TupleId>(0)}; |
| 69 | nullable_row_desc_ = RowDescriptor{*desc_tbl, tuple_id, nullable_tuples}; |
| 70 | } |
| 71 | |
| 72 | void TearDown() override { |
| 73 | if (buffer_pool_client_.is_registered()) { |
nothing calls this directly
no test coverage detected