| 914 | } |
| 915 | |
| 916 | void BufferedTupleStream::FixUpStringsForRead(const vector<SlotDescriptor*>& string_slots, |
| 917 | ReadIterator* RESTRICT read_iter, Tuple* tuple) { |
| 918 | DCHECK(tuple != nullptr); |
| 919 | for (const SlotDescriptor* slot_desc : string_slots) { |
| 920 | if (tuple->IsNull(slot_desc->null_indicator_offset())) continue; |
| 921 | |
| 922 | StringValue* sv = tuple->GetStringSlot(slot_desc->tuple_offset()); |
| 923 | if (sv->IsSmall()) continue; |
| 924 | sv->SetPtr(reinterpret_cast<char*>(read_iter->read_ptr_)); |
| 925 | read_iter->AdvanceReadPtr(sv->Len()); |
| 926 | } |
| 927 | } |
| 928 | |
| 929 | void BufferedTupleStream::FixUpCollectionsForRead( |
| 930 | const vector<SlotDescriptor*>& collection_slots, ReadIterator* RESTRICT read_iter, |
nothing calls this directly
no test coverage detected