mutable

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 12, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetMsInfo added in v1.2.0 

func GetMsInfo(name string, mstsInfo *sync.Map) (*meta.MeasurementInfo, bool)

func GetSidsImpl added in v1.1.0 

func GetSidsImpl(size int) []uint64

func GetSortKeys added in v1.3.0 

func GetSortKeys(schema []record.Field, primaryKeys []string) []record.PrimaryKey

func Init added in v1.3.0 

func Init(cpuNum int)

func InitMutablePool added in v1.1.0 

func InitMutablePool(size int)

func JoinWriteRec added in v1.1.0 

func JoinWriteRec(table *MemTable, msName string)

func LoadMstRowCount added in v1.1.0 

func LoadMstRowCount(countFile string) (int, error)

LoadMstRowCount is used to load the rowcount value for mst-level pre-aggregation.

func MergeSchema added in v1.1.1 

func MergeSchema(table *MemTable, msName string)

func NewTsMemTableImpl added in v1.4.0 

func NewTsMemTableImpl() *tsMemTableImpl

func PutSidsImpl added in v1.1.0 

func PutSidsImpl(sids []uint64)

func SetShelfMemRecordReader added in v1.4.0 

func SetShelfMemRecordReader(r MemRecordReader)

func SetWriteChunk added in v1.1.0 

func SetWriteChunk(msi *MsInfo, rec *record.Record)

func SplitRecordByTime added in v1.3.0 

func SplitRecordByTime(rec *record.Record, pool []record.Record, time int64) (*record.Record, *record.Record)

func StoreMstRowCount added in v1.1.0 

func StoreMstRowCount(countFile string, rowCount int) error

StoreMstRowCount is used to persist the rowcount value for mst-level pre-aggregation.

func UpdateMstRowCount added in v1.1.1 

func UpdateMstRowCount(msRowCount *sync.Map, mstName string, rowCount int64)

Types

type FlushManager added in v1.2.0 

type FlushManager interface {
	SetDBInfo(db string, rp string)
	// contains filtered or unexported methods
}

type MTable added in v1.1.0 

type MTable interface {
	FlushChunks(table *MemTable, dataPath, msName, db, rp string, lock *string, tbStore immutable.TablesStore, msRowCount int64, fileInfos chan []immutable.FileInfoExtend)
	SetClient(client metaclient.MetaClient)
	GetClient() metaclient.MetaClient
	WriteRows(table *MemTable, rowsD *dictpool.Dict, wc WriteRowsCtx) error
	WriteCols(table *MemTable, rec *record.Record, mstsInfo *sync.Map, mst string) error
	SetFlushManagerInfo(manager map[string]FlushManager, accumulateMetaIndex *sync.Map)
	Reset(table *MemTable)
	// contains filtered or unexported methods
}

type MemRecordReader added in v1.4.0 

type MemRecordReader func(shardID uint64, mst string, sid uint64, tr *util.TimeRange,
	schema record.Schemas, ascending bool) *record.Record

type MemTable 

type MemTable struct {
	MTable MTable //public method in MemTable
	// contains filtered or unexported fields
}

func NewMemTable 

func NewMemTable(engineType config.EngineType) *MemTable

func (*MemTable) AddMemSize 

func (t *MemTable) AddMemSize(size int64)

nolint

func (*MemTable) ApplyConcurrency 

func (t *MemTable) ApplyConcurrency(f func(msName string))

func (*MemTable) CreateMsInfo added in v1.1.0 

func (t *MemTable) CreateMsInfo(name string, row *influx.Row, rec *record.Record) *MsInfo

func (*MemTable) GetMemSize 

func (t *MemTable) GetMemSize() int64

func (*MemTable) GetMsInfo added in v1.1.0 

func (t *MemTable) GetMsInfo(name string) (*MsInfo, error)

func (*MemTable) NeedFlush 

func (t *MemTable) NeedFlush() bool

func (*MemTable) Ref 

func (t *MemTable) Ref()

func (*MemTable) Reset 

func (t *MemTable) Reset()

func (*MemTable) SetIdx 

func (t *MemTable) SetIdx(idx *ski.ShardKeyIndex)

func (*MemTable) SetMsInfo added in v1.1.0 

func (t *MemTable) SetMsInfo(name string, msInfo *MsInfo)

func (*MemTable) SetReleaseHook added in v1.1.1 

func (t *MemTable) SetReleaseHook(hook MemTableReleaseHook)

func (*MemTable) UnRef 

func (t *MemTable) UnRef()

type MemTablePool added in v1.1.1 

type MemTablePool struct {
	// contains filtered or unexported fields
}

func NewMemTablePool added in v1.1.1 

func NewMemTablePool() *MemTablePool

func (*MemTablePool) Expired added in v1.1.1 

func (p *MemTablePool) Expired() bool

func (*MemTablePool) Get added in v1.1.1 

func (p *MemTablePool) Get(engineType config.EngineType) *MemTable

func (*MemTablePool) Put added in v1.1.1 

func (p *MemTablePool) Put(tb *MemTable)

func (*MemTablePool) SetExpire added in v1.1.1 

func (p *MemTablePool) SetExpire(v uint64)

func (*MemTablePool) Size added in v1.1.1 

func (p *MemTablePool) Size() int

type MemTablePoolManager added in v1.1.1 

type MemTablePoolManager struct {
	// contains filtered or unexported fields
}

func NewMemTablePoolManager added in v1.1.1 

func NewMemTablePoolManager() *MemTablePoolManager

func (*MemTablePoolManager) Alloc added in v1.1.1 

func (pm *MemTablePoolManager) Alloc(key string) *MemTablePool

func (*MemTablePoolManager) Close added in v1.1.1 

func (pm *MemTablePoolManager) Close()

func (*MemTablePoolManager) Free added in v1.1.1 

func (pm *MemTablePoolManager) Free()

func (*MemTablePoolManager) Init added in v1.1.1 

func (pm *MemTablePoolManager) Init()

func (*MemTablePoolManager) Size added in v1.1.1 

func (pm *MemTablePoolManager) Size() int

type MemTableReleaseHook added in v1.1.1 

type MemTableReleaseHook func(t *MemTable)

type MemTables added in v1.0.0 

type MemTables struct {
	// contains filtered or unexported fields
}

func NewMemTables added in v1.4.0 

func NewMemTables(shardID uint64, readEnable bool) *MemTables

func (*MemTables) Init added in v1.0.0 

func (m *MemTables) Init(activeTbl, snapshotTbl *MemTable)

func (*MemTables) Ref added in v1.0.0 

func (m *MemTables) Ref()

func (*MemTables) UnRef added in v1.0.0 

func (m *MemTables) UnRef()

func (*MemTables) Values added in v1.0.0 

func (m *MemTables) Values(msName string, id uint64, tr util.TimeRange, schema record.Schemas, ascending bool) *record.Record

type MsInfo 

type MsInfo struct {
	Name   string // measurement name with version
	Schema record.Schemas
	// contains filtered or unexported fields
}

func (*MsInfo) CreateChunk added in v1.0.0 

func (msi *MsInfo) CreateChunk(sid uint64) (*WriteChunk, bool)

func (*MsInfo) CreateWriteChunkForColumnStore added in v1.1.0 

func (msi *MsInfo) CreateWriteChunkForColumnStore(sortKeys []string)

func (*MsInfo) GetAllSid added in v1.1.0 

func (msi *MsInfo) GetAllSid() []uint64

func (*MsInfo) GetFlushed added in v1.2.0 

func (msi *MsInfo) GetFlushed() *bool

func (*MsInfo) GetRowChunks added in v1.1.0 

func (msi *MsInfo) GetRowChunks() *rowChunks

func (*MsInfo) GetWriteChunk added in v1.1.0 

func (msi *MsInfo) GetWriteChunk() *WriteChunkForColumnStore

func (*MsInfo) Init added in v1.0.0 

func (msi *MsInfo) Init(row *influx.Row)

func (*MsInfo) SetWriteChunk added in v1.1.0 

func (msi *MsInfo) SetWriteChunk(writeChunk *WriteChunkForColumnStore)

type RecordIterator added in v1.4.0 

type RecordIterator interface {
	Next(dst *record.Record) (uint64, error)
}

type SidsPool added in v1.1.0 

type SidsPool struct {
	// contains filtered or unexported fields
}

type WriteChunk 

type WriteChunk struct {
	Mu       sync.Mutex
	Sid      uint64
	WriteRec WriteRec
}

func (*WriteChunk) Init 

func (chunk *WriteChunk) Init(sid uint64)

func (*WriteChunk) SortRecord added in v1.1.0 

func (chunk *WriteChunk) SortRecord(hlp *record.ColumnSortHelper)

func (*WriteChunk) SortRecordNoLock added in v1.1.0 

func (chunk *WriteChunk) SortRecordNoLock(hlp *record.ColumnSortHelper)

type WriteChunkForColumnStore added in v1.1.0 

type WriteChunkForColumnStore struct {
	Mu       sync.Mutex
	WriteRec WriteRec
	// contains filtered or unexported fields
}

func (*WriteChunkForColumnStore) SortRecord added in v1.1.0 

func (chunk *WriteChunkForColumnStore) SortRecord(tcDuration time.Duration)

func (*WriteChunkForColumnStore) TimeSorted added in v1.2.0 

func (chunk *WriteChunkForColumnStore) TimeSorted() bool

type WriteRec 

type WriteRec struct {
	// contains filtered or unexported fields
}

func (*WriteRec) GetRecord 

func (writeRec *WriteRec) GetRecord() *record.Record

func (*WriteRec) SetLastAppendTime added in v1.1.0 

func (writeRec *WriteRec) SetLastAppendTime(v int64)

func (*WriteRec) SetWriteRec added in v1.1.0 

func (writeRec *WriteRec) SetWriteRec(rec *record.Record)

func (*WriteRec) SortRecord added in v1.1.0 

func (writeRec *WriteRec) SortRecord(hlp *record.ColumnSortHelper)

type WriteRowsCtx added in v1.1.0 

type WriteRowsCtx struct {
	AddRowCountsBySid func(msName string, sid uint64, rowCounts int64)
	MstsInfo          *sync.Map
	MsRowCount        *sync.Map
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.