Documentation
¶
Overview ¶
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the stream engine. It supplies stream's frame signature, wire version and role/type numbering; the byte layout is the shared base's, identical to measure's.
Index ¶
Constants ¶
const WireVersion uint8 = 1
WireVersion is the on-wire frame format version emitted by Encode. Stream starts at 1: it is a fresh engine binding, not a continuation of measure's version history.
Variables ¶
var Magic = [4]byte{data.RawFrameMagicLeadingByte, 'V', 'F', 'R'}
Magic is the 4-byte prefix every raw stream frame body begins with. The first byte is data.RawFrameMagicLeadingByte (0x00) so a flag-off proto.Unmarshal of a raw body fails loud; 'V','F','R' is the frame signature.
Functions ¶
func Decode ¶
func Decode(b []byte) (*vectorized.RecordBatch, error)
Decode parses a stream raw frame body back into a RecordBatch.
func Encode ¶
func Encode(b *vectorized.RecordBatch) ([]byte, error)
Encode serializes a stream vec columnar RecordBatch into a raw frame body.
Types ¶
This section is empty.
Source Files