| 1183 | } |
| 1184 | |
| 1185 | void StringColumnWriter::createDirectStreams() { |
| 1186 | std::unique_ptr<BufferedOutputStream> directLengthStream = |
| 1187 | streamsFactory.createStream(proto::Stream_Kind_LENGTH); |
| 1188 | directLengthEncoder = createRleEncoder(std::move(directLengthStream), false, rleVersion, |
| 1189 | memPool, alignedBitPacking); |
| 1190 | directDataStream.reset( |
| 1191 | new AppendOnlyBufferedStream(streamsFactory.createStream(proto::Stream_Kind_DATA))); |
| 1192 | } |
| 1193 | |
| 1194 | void StringColumnWriter::createDictStreams() { |
| 1195 | std::unique_ptr<BufferedOutputStream> dictDataStream = |
nothing calls this directly
no test coverage detected