Versions in this module Expand all Collapse all v3 v3.58.1 Dec 14, 2024 Changes in this version + const ColInfoOffset + const ColInfoSize + const Float32Size + const Float64Size + const GroupIDOffset + const HasColumnSegmentOffset + const Int16Size + const Int32Size + const Int64Size + const Int8Size + const NumOfColsOffset + const NumOfRowsOffset + const RawBlockLengthOffset + const RawBlockVersionOffset + const UInt16Size + const UInt32Size + const UInt64Size + const UInt8Size + func BMIsNull(c byte, n int) bool + func BitPos(n int) int + func BitmapLen(n int) int + func CharOffset(n int) int + func Copy(source unsafe.Pointer, data []byte, index int, length int) + func IsVarDataType(colType uint8) bool + func ItemIsNull(pHeader unsafe.Pointer, row int) bool + func ItemRawBlock(colType uint8, pHeader, pStart unsafe.Pointer, row int, precision int, ...) driver.Value + func RawBlockGetColDataOffset(colCount int) uintptr + func RawBlockGetColInfo(rawBlock unsafe.Pointer, infos []RawBlockColInfo) + func RawBlockGetColumnLengthOffset(colCount int) uintptr + func RawBlockGetGroupID(rawBlock unsafe.Pointer) uint64 + func RawBlockGetHasColumnSegment(rawBlock unsafe.Pointer) int32 + func RawBlockGetLength(rawBlock unsafe.Pointer) int32 + func RawBlockGetNumOfCols(rawBlock unsafe.Pointer) int32 + func RawBlockGetNumOfRows(rawBlock unsafe.Pointer) int32 + func RawBlockGetVersion(rawBlock unsafe.Pointer) int32 + func ReadBlock(block unsafe.Pointer, blockSize int, colTypes []uint8, precision int) [][]driver.Value + func ReadBlockSimple(block unsafe.Pointer, precision int) [][]driver.Value + func ReadBlockWithTimeFormat(block unsafe.Pointer, blockSize int, colTypes []uint8, precision int, ...) [][]driver.Value + func ReadRow(dest []driver.Value, block unsafe.Pointer, blockSize int, row int, ...) + type FormatTimeFunc func(ts int64, precision int) driver.Value + type RawBlockColInfo struct + Bytes int32 + ColType int8 + type TMQBlockInfo struct + Precision int + RawBlock unsafe.Pointer + Schema []*TMQRawDataSchema + TableName string + type TMQRawDataParser struct + func NewTMQRawDataParser() *TMQRawDataParser + func (p *TMQRawDataParser) Parse(block unsafe.Pointer) ([]*TMQBlockInfo, error) + type TMQRawDataSchema struct + Bytes int64 + ColID int + ColType uint8 + Flag int8 + Name string
Go to main page