| 240 | } |
| 241 | |
| 242 | void StreamWriter::WriteNullValue(ColumnWriter* writer) { |
| 243 | switch (writer->type()) { |
| 244 | case Type::BOOLEAN: |
| 245 | static_cast<BoolWriter*>(writer)->WriteBatch(kBatchSizeOne, &kDefLevelZero, |
| 246 | &kRepLevelZero, nullptr); |
| 247 | break; |
| 248 | case Type::INT32: |
| 249 | static_cast<Int32Writer*>(writer)->WriteBatch(kBatchSizeOne, &kDefLevelZero, |
| 250 | &kRepLevelZero, nullptr); |
| 251 | break; |
| 252 | case Type::INT64: |
| 253 | static_cast<Int64Writer*>(writer)->WriteBatch(kBatchSizeOne, &kDefLevelZero, |
| 254 | &kRepLevelZero, nullptr); |
| 255 | break; |
| 256 | case Type::BYTE_ARRAY: |
| 257 | static_cast<ByteArrayWriter*>(writer)->WriteBatch(kBatchSizeOne, &kDefLevelZero, |
| 258 | &kRepLevelZero, nullptr); |
| 259 | break; |
| 260 | case Type::FIXED_LEN_BYTE_ARRAY: |
| 261 | static_cast<FixedLenByteArrayWriter*>(writer)->WriteBatch( |
| 262 | kBatchSizeOne, &kDefLevelZero, &kRepLevelZero, nullptr); |
| 263 | break; |
| 264 | case Type::FLOAT: |
| 265 | static_cast<FloatWriter*>(writer)->WriteBatch(kBatchSizeOne, &kDefLevelZero, |
| 266 | &kRepLevelZero, nullptr); |
| 267 | break; |
| 268 | case Type::DOUBLE: |
| 269 | static_cast<DoubleWriter*>(writer)->WriteBatch(kBatchSizeOne, &kDefLevelZero, |
| 270 | &kRepLevelZero, nullptr); |
| 271 | break; |
| 272 | case Type::INT96: |
| 273 | case Type::UNDEFINED: |
| 274 | throw ParquetException("Unexpected type: " + TypeToString(writer->type())); |
| 275 | break; |
| 276 | } |
| 277 | } |
| 278 | |
| 279 | void StreamWriter::SkipOptionalColumn() { |
| 280 | if (SkipColumns(1) != 1) { |
nothing calls this directly
no test coverage detected