Writes the contents to 'out' in wire format
| 3453 | |
| 3454 | // Writes the contents to 'out' in wire format |
| 3455 | void flushStreams( |
| 3456 | const std::vector<std::unique_ptr<VectorStream>>& streams, |
| 3457 | int32_t numRows, |
| 3458 | const StreamArena& arena, |
| 3459 | folly::io::Codec& codec, |
| 3460 | OutputStream* out) { |
| 3461 | auto listener = dynamic_cast<PrestoOutputStreamListener*>(out->listener()); |
| 3462 | // Reset CRC computation |
| 3463 | if (listener) { |
| 3464 | listener->reset(); |
| 3465 | } |
| 3466 | |
| 3467 | if (!needCompression(codec)) { |
| 3468 | flushUncompressed(streams, numRows, out, listener); |
| 3469 | } else { |
| 3470 | flushCompressed(streams, arena, codec, numRows, out, listener); |
| 3471 | } |
| 3472 | } |
| 3473 | |
| 3474 | class PrestoBatchVectorSerializer : public BatchVectorSerializer { |
| 3475 | public: |
no test coverage detected