MCPcopy Create free account
hub / github.com/bytedance/bolt / flushEncoded

Method flushEncoded

bolt/serializers/PrestoSerializer.cpp:3626–3634  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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;

Callers 1

Calls 5

flushStreamsFunction · 0.85
appendFunction · 0.50
RangeClass · 0.50
sizeMethod · 0.45
dataMethod · 0.45

Tested by

no test coverage detected