| 991 | }; |
| 992 | |
| 993 | StringColumnWriter::StringColumnWriter(const Type& type, const StreamsFactory& factory, |
| 994 | const WriterOptions& options) |
| 995 | : ColumnWriter(type, factory, options), |
| 996 | rleVersion(options.getRleVersion()), |
| 997 | useCompression(options.getCompression() != CompressionKind_NONE), |
| 998 | streamsFactory(factory), |
| 999 | alignedBitPacking(options.getAlignedBitpacking()), |
| 1000 | doneDictionaryCheck(false), |
| 1001 | useDictionary(options.getEnableDictionary()), |
| 1002 | dictSizeThreshold(options.getDictionaryKeySizeThreshold()) { |
| 1003 | if (type.getKind() == TypeKind::BINARY) { |
| 1004 | useDictionary = false; |
| 1005 | doneDictionaryCheck = true; |
| 1006 | } |
| 1007 | |
| 1008 | if (useDictionary) { |
| 1009 | createDictStreams(); |
| 1010 | } else { |
| 1011 | doneDictionaryCheck = true; |
| 1012 | createDirectStreams(); |
| 1013 | } |
| 1014 | |
| 1015 | if (enableIndex) { |
| 1016 | recordPosition(); |
| 1017 | } |
| 1018 | } |
| 1019 | |
| 1020 | void StringColumnWriter::add(ColumnVectorBatch& rowBatch, uint64_t offset, uint64_t numValues, |
| 1021 | const char* incomingMask) { |
nothing calls this directly
no test coverage detected