| 178 | } |
| 179 | |
| 180 | VectorSerde* getNamedVectorSerde(VectorSerde::Kind kind) { |
| 181 | auto& namedSerdeMap = getNamedVectorSerdeImpl(); |
| 182 | auto it = namedSerdeMap.find(kind); |
| 183 | BOLT_CHECK( |
| 184 | it != namedSerdeMap.end(), |
| 185 | "Named vector serde '{}' is not registered.", |
| 186 | kind); |
| 187 | return it->second.get(); |
| 188 | } |
| 189 | |
| 190 | void VectorStreamGroup::createStreamTree( |
| 191 | RowTypePtr type, |