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

Method flush

bolt/serializers/PrestoSerializer.cpp:3622–3624  ·  view source on GitHub ↗

The SerializedPage layout is: numRows(4) | codec(1) | uncompressedSize(4) | compressedSize(4) | checksum(8) | data

Source from the content-addressed store, hash-verified

3620 // numRows(4) | codec(1) | uncompressedSize(4) | compressedSize(4) |
3621 // checksum(8) | data
3622 void flush(OutputStream* out) override {
3623 flushStreams(streams_, numRows_, *streamArena_, *codec_, out);
3624 }
3625
3626 void flushEncoded(const RowVectorPtr& vector, OutputStream* out) {
3627 BOLT_CHECK_EQ(0, numRows_);

Callers

nothing calls this directly

Calls 1

flushStreamsFunction · 0.85

Tested by

no test coverage detected