| 2989 | } |
| 2990 | |
| 2991 | Status C_PHONE(size_t thread_index) { |
| 2992 | ThreadLocalData& tld = thread_local_data_[thread_index]; |
| 2993 | if (tld.batch[CUSTOMER::C_PHONE].kind() == Datum::NONE) { |
| 2994 | RETURN_NOT_OK(C_NATIONKEY(thread_index)); |
| 2995 | RETURN_NOT_OK(AllocateColumn(thread_index, CUSTOMER::C_PHONE)); |
| 2996 | int32_t byte_width = kTypes[CUSTOMER::C_PHONE]->byte_width(); |
| 2997 | const int32_t* c_nationkey = reinterpret_cast<const int32_t*>( |
| 2998 | tld.batch[CUSTOMER::C_NATIONKEY].array()->buffers[1]->data()); |
| 2999 | char* c_phone = reinterpret_cast<char*>( |
| 3000 | tld.batch[CUSTOMER::C_PHONE].array()->buffers[1]->mutable_data()); |
| 3001 | for (int64_t irow = 0; irow < tld.to_generate; irow++) { |
| 3002 | GeneratePhoneNumber(c_phone + irow * byte_width, tld.rng, c_nationkey[irow]); |
| 3003 | } |
| 3004 | } |
| 3005 | return Status::OK(); |
| 3006 | } |
| 3007 | |
| 3008 | Status C_ACCTBAL(size_t thread_index) { |
| 3009 | ThreadLocalData& tld = thread_local_data_[thread_index]; |
nothing calls this directly
no test coverage detected