Versions in this module Expand all Collapse all v0 v0.0.1 Nov 27, 2018 Changes in this version + const SizeOfGeoPoint + const UpsertBatchVersion + var DataTypeName = map[DataType]string + var NullDataValue = DataValue + var StringToDataType = map[string]DataType + func ColumnHeaderSize(numCols int) int + func ColumnHeaderSizeNew(numCols int) int + func CompareBool(a, b bool) int + func CompareFloat32(a, b unsafe.Pointer) int + func CompareInt16(a, b unsafe.Pointer) int + func CompareInt32(a, b unsafe.Pointer) int + func CompareInt64(a, b unsafe.Pointer) int + func CompareInt8(a, b unsafe.Pointer) int + func CompareUint16(a, b unsafe.Pointer) int + func CompareUint32(a, b unsafe.Pointer) int + func CompareUint8(a, b unsafe.Pointer) int + func ConvertToBool(value interface{}) (bool, bool) + func ConvertToFloat32(value interface{}) (float32, bool) + func ConvertToFloat64(value interface{}) (float64, bool) + func ConvertToGeoPoint(value interface{}) ([2]float32, bool) + func ConvertToInt16(value interface{}) (int16, bool) + func ConvertToInt32(value interface{}) (int32, bool) + func ConvertToInt64(value interface{}) (int64, bool) + func ConvertToInt8(value interface{}) (int8, bool) + func ConvertToUUID(value interface{}) ([2]uint64, bool) + func ConvertToUint16(value interface{}) (uint16, bool) + func ConvertToUint32(value interface{}) (uint32, bool) + func ConvertToUint64(value interface{}) (uint64, bool) + func ConvertToUint8(value interface{}) (uint8, bool) + func DataTypeBits(dataType DataType) int + func DataTypeBytes(dataType DataType) int + func GeoPointFromString(str string) (point [2]float32, err error) + func IsGoType(dataType DataType) bool + func IsNumeric(dataType DataType) bool + type ArchiveVectorParty interface + CopyOnWrite func(batchSize int) ArchiveVectorParty + GetCount func(offset int) uint32 + LoadFromDisk func(hostMemManager HostMemoryManager, diskStore diskstore.DiskStore, table string, ...) + Pin func() + Prune func() + Release func() + SetCount func(offset int, count uint32) + SliceByValue func(lowerBoundRow, upperBoundRow int, value unsafe.Pointer) (startRow int, endRow int, startIndex int, endIndex int) + SliceIndex func(lowerBoundRow, upperBoundRow int) (startIndex, endIndex int) + WaitForDiskLoad func() + WaitForUsers func(blocking bool) (usersDone bool) + type CVectorParty interface + GetMode func() ColumnMode + JudgeMode func() ColumnMode + type ColumnMemoryUsage struct + Live uint + NonPreloaded uint + Preloaded uint + type ColumnMode int + const AllValuesDefault + const AllValuesPresent + const HasCountVector + const HasNullVector + const MaxColumnMode + type ColumnUpdateMode int + const MaxColumnUpdateMode + const UpdateForceOverwrite + const UpdateOverwriteNotNull + const UpdateWithAddition + const UpdateWithMax + const UpdateWithMin + type CompareFunc func(a, b unsafe.Pointer) int + func GetCompareFunc(dataType DataType) CompareFunc + type DataType uint32 + const BigEnum + const Bool + const Float32 + const GeoPoint + const GeoShape + const Int16 + const Int32 + const Int64 + const Int8 + const SmallEnum + const UUID + const Uint16 + const Uint32 + const Uint8 + const Unknown + func DataTypeFromString(str string) DataType + func NewDataType(value uint32) (DataType, error) + type DataValue struct + BoolVal bool + CmpFunc CompareFunc + DataType DataType + GoVal GoDataValue + IsBool bool + OtherVal unsafe.Pointer + Valid bool + func UpdateWithAdditionFunc(oldValue, newValue *DataValue) (*DataValue, bool, error) + func UpdateWithMaxFunc(oldValue, newValue *DataValue) (*DataValue, bool, error) + func UpdateWithMinFunc(oldValue, newValue *DataValue) (*DataValue, bool, error) + func ValueFromString(str string, dataType DataType) (val DataValue, err error) + func (v1 DataValue) Compare(v2 DataValue) int + func (v1 DataValue) ConvertToHumanReadable(dataType DataType) interface{} + type GeoPointGo [2]float32 + type GeoShapeGo struct + Polygons [][]GeoPointGo + func ConvertToGeoShape(value interface{}) (*GeoShapeGo, bool) + func GeoShapeFromString(str string) (GeoShapeGo, error) + func (gs *GeoShapeGo) GetBytes() int + func (gs *GeoShapeGo) GetSerBytes() int + func (gs *GeoShapeGo) Read(dataReader *utils.StreamDataReader) error + func (gs *GeoShapeGo) Write(dataWriter *utils.StreamDataWriter) error + type GoDataValue interface + GetBytes func() int + GetSerBytes func() int + Read func(reader *utils.StreamDataReader) error + Write func(writer *utils.StreamDataWriter) error + func GetGoDataValue(dataType DataType) GoDataValue + type HostMemoryManager interface + GetArchiveMemoryUsageByTableShard func() (map[string]map[string]*ColumnMemoryUsage, error) + ReportManagedObject func(table string, shard, batchID, columnID int, bytes int64) + ReportUnmanagedSpaceUsageChange func(bytes int64) + Start func() + Stop func() + TriggerEviction func() + TriggerPreload func(tableName string, columnID int, oldPreloadingDays int, newPreloadingDays int) + type HostVectorPartySlice struct + CountBytes int + CountStartIndex int + Counts unsafe.Pointer + DefaultValue DataValue + Length int + NullBytes int + NullStartIndex int + Nulls unsafe.Pointer + ValueBytes int + ValueStartIndex int + ValueType DataType + Values unsafe.Pointer + type JobType string + const ArchivingJobType + const BackfillJobType + const PurgeJobType + const SnapshotJobType + type LiveVectorParty interface + GetMinMaxValue func() (min, max uint32) + type SlicedVector struct + Counts []int + Values []interface{} + type UpsertBatchBuilder struct + NumRows int + func NewUpsertBatchBuilder() *UpsertBatchBuilder + func (u *UpsertBatchBuilder) AddColumn(columnID int, dataType DataType) error + func (u *UpsertBatchBuilder) AddColumnWithUpdateMode(columnID int, dataType DataType, updateMode ColumnUpdateMode) error + func (u *UpsertBatchBuilder) AddRow() + func (u *UpsertBatchBuilder) RemoveRow() + func (u *UpsertBatchBuilder) ResetRows() + func (u *UpsertBatchBuilder) SetValue(row int, col int, value interface{}) error + func (u UpsertBatchBuilder) ToByteArray() ([]byte, error) + func (u UpsertBatchBuilder) ToByteArrayNew() ([]byte, error) + type UpsertBatchHeader struct + func NewUpsertBatchHeader(buffer []byte, numCols int) UpsertBatchHeader + func NewUpsertBatchHeaderNew(buffer []byte, numCols int) UpsertBatchHeader + func (u *UpsertBatchHeader) WriteColumnFlag(columnMode ColumnMode, columnUpdateMode ColumnUpdateMode, col int) error + func (u *UpsertBatchHeader) WriteColumnID(value int, col int) error + func (u *UpsertBatchHeader) WriteColumnOffset(value int, col int) error + func (u *UpsertBatchHeader) WriteColumnType(value DataType, col int) error + func (u UpsertBatchHeader) ReadColumnFlag(col int) (ColumnMode, ColumnUpdateMode, error) + func (u UpsertBatchHeader) ReadColumnID(col int) (int, error) + func (u UpsertBatchHeader) ReadColumnOffset(col int) (int, error) + func (u UpsertBatchHeader) ReadColumnType(col int) (DataType, error) + type ValueCountsUpdateMode int + type VectorParty interface + Allocate func(hasCount bool) + Equals func(other VectorParty) bool + GetBytes func() int64 + GetDataType func() DataType + GetDataValue func(offset int) DataValue + GetDataValueByRow func(row int) DataValue + GetLength func() int + GetNonDefaultValueCount func() int + GetValidity func(offset int) bool + Read func(reader io.Reader, serializer VectorPartySerializer) error + SafeDestruct func() + SetDataValue func(offset int, value DataValue, countsUpdateMode ValueCountsUpdateMode, ...) + Slice func(startRow, numRows int) SlicedVector + Write func(writer io.Writer) error + type VectorPartySerializer interface + CheckVectorPartySerializable func(vp VectorParty) error + ReadVectorParty func(vp VectorParty) error + ReportVectorPartyMemoryUsage func(bytes int64) + WriteVectorParty func(vp VectorParty) error