Versions in this module Expand all Collapse all v0 v0.0.1 Nov 27, 2018 Changes in this version + type HostMemoryManager struct + func (_m *HostMemoryManager) GetArchiveMemoryUsageByTableShard() (map[string]map[string]*common.ColumnMemoryUsage, error) + func (_m *HostMemoryManager) ReportManagedObject(table string, shard int, batchID int, columnID int, bytes int64) + func (_m *HostMemoryManager) ReportUnmanagedSpaceUsageChange(bytes int64) + func (_m *HostMemoryManager) Start() + func (_m *HostMemoryManager) Stop() + func (_m *HostMemoryManager) TriggerEviction() + func (_m *HostMemoryManager) TriggerPreload(tableName string, columnID int, oldPreloadingDays int, newPreloadingDays int) + type LiveVectorParty struct + func (_m *LiveVectorParty) Allocate(hasCount bool) + func (_m *LiveVectorParty) Equals(other common.VectorParty) bool + func (_m *LiveVectorParty) GetBytes() int64 + func (_m *LiveVectorParty) GetDataType() common.DataType + func (_m *LiveVectorParty) GetDataValue(offset int) common.DataValue + func (_m *LiveVectorParty) GetDataValueByRow(row int) common.DataValue + func (_m *LiveVectorParty) GetLength() int + func (_m *LiveVectorParty) GetMinMaxValue() (uint32, uint32) + func (_m *LiveVectorParty) GetNonDefaultValueCount() int + func (_m *LiveVectorParty) GetValidity(offset int) bool + func (_m *LiveVectorParty) Read(reader io.Reader, serializer common.VectorPartySerializer) error + func (_m *LiveVectorParty) SafeDestruct() + func (_m *LiveVectorParty) SetDataValue(offset int, value common.DataValue, ...) + func (_m *LiveVectorParty) Slice(startRow int, numRows int) common.SlicedVector + func (_m *LiveVectorParty) Write(writer io.Writer) error + type VectorParty struct + func (_m *VectorParty) Allocate(hasCount bool) + func (_m *VectorParty) Equals(other common.VectorParty) bool + func (_m *VectorParty) GetBytes() int64 + func (_m *VectorParty) GetDataType() common.DataType + func (_m *VectorParty) GetDataValue(offset int) common.DataValue + func (_m *VectorParty) GetDataValueByRow(row int) common.DataValue + func (_m *VectorParty) GetLength() int + func (_m *VectorParty) GetNonDefaultValueCount() int + func (_m *VectorParty) GetValidity(offset int) bool + func (_m *VectorParty) Read(reader io.Reader, serializer common.VectorPartySerializer) error + func (_m *VectorParty) SafeDestruct() + func (_m *VectorParty) SetDataValue(offset int, value common.DataValue, ...) + func (_m *VectorParty) Slice(startRow int, numRows int) common.SlicedVector + func (_m *VectorParty) Write(writer io.Writer) error