| 3624 | } |
| 3625 | |
| 3626 | void flushEncoded(const RowVectorPtr& vector, OutputStream* out) { |
| 3627 | BOLT_CHECK_EQ(0, numRows_); |
| 3628 | |
| 3629 | std::vector<IndexRange> ranges{{0, vector->size()}}; |
| 3630 | Scratch scratch; |
| 3631 | append(vector, folly::Range(ranges.data(), ranges.size()), scratch); |
| 3632 | |
| 3633 | flushStreams(streams_, vector->size(), *streamArena_, *codec_, out); |
| 3634 | } |
| 3635 | |
| 3636 | void clear() override { |
| 3637 | numRows_ = 0; |
no test coverage detected