mutable

package
v1.5.1 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2025 License: Apache-2.0 Imports: 33 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 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 *util.SyncMap[string, *int64], mstName string, rowCount int64)

Types

type CSMemTableImpl added in v1.5.0 

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

func NewCSMemTableImpl added in v1.5.0 

func NewCSMemTableImpl(db, rp string) *CSMemTableImpl

func (*CSMemTableImpl) FlushChunks added in v1.5.0 

func (c *CSMemTableImpl) FlushChunks(table *MemTable, dataPath, msName, db, rp string, lock *string, tbStore immutable.TablesStore, msRowCount int64, fileInfos chan []immutable.FileInfoExtend)

func (*CSMemTableImpl) FlushChunksDetached added in v1.5.0 

func (c *CSMemTableImpl) FlushChunksDetached(table *MemTable, dataPath string, ident colstore.MeasurementIdent, lock *string, tbStore immutable.TablesStore, msRowCount int64, fileInfos chan []immutable.FileInfoExtend)

func (*CSMemTableImpl) Reset added in v1.5.0 

func (c *CSMemTableImpl) Reset(t *MemTable)

func (*CSMemTableImpl) SetDbRp added in v1.5.0 

func (c *CSMemTableImpl) SetDbRp(db, rp string)

func (*CSMemTableImpl) SetFlushManagerInfo added in v1.5.0 

func (c *CSMemTableImpl) SetFlushManagerInfo(manager map[string]FlushManager, accumulateMetaIndex *sync.Map)

func (*CSMemTableImpl) WriteCols added in v1.5.0 

func (c *CSMemTableImpl) WriteCols(table *MemTable, rec *record.Record, mst string) error

func (*CSMemTableImpl) WriteRows added in v1.5.0 

func (c *CSMemTableImpl) WriteRows(table *MemTable, rowsD dictmap.DictMap[string, *[]influx.Row], ctx WriteRowsCtx) error

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)
	WriteRows(table *MemTable, rowsD dictmap.DictMap[string, *[]influx.Row], wc WriteRowsCtx) error
	WriteCols(table *MemTable, rec *record.Record, mst string) error
	SetFlushManagerInfo(manager map[string]FlushManager, accumulateMetaIndex *sync.Map)
	Reset(table *MemTable)
	// contains filtered or unexported methods
}

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) SetDbRp added in v1.5.0 

func (t *MemTable) SetDbRp(db, rp string)

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(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 RecordFlusher added in v1.5.0 

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

func NewRecordFlusher added in v1.5.0 

func NewRecordFlusher(tbStore immutable.TablesStore, mst string, fileInfos chan []immutable.FileInfoExtend) *RecordFlusher

func (*RecordFlusher) Flush added in v1.5.0 

func (rf *RecordFlusher) Flush() ([]immutable.TSSPFile, []immutable.TSSPFile, error)

func (*RecordFlusher) FlushRecord added in v1.5.0 

func (rf *RecordFlusher) FlushRecord(sid uint64, rec *record.Record) error

func (*RecordFlusher) Free added in v1.5.0 

func (rf *RecordFlusher) Free()

type RecordIterator added in v1.4.0 

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

type SeriesRowCountFunc added in v1.5.0 

type SeriesRowCountFunc func(msName string, sid uint64, rowCounts int64)

type SidsPool added in v1.1.0 

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

type WriteAttached added in v1.5.0 

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

func NewWriteAttached added in v1.5.0 

func NewWriteAttached(mst *colstore.Measurement) *WriteAttached

func (*WriteAttached) FlushRecord added in v1.5.0 

func (w *WriteAttached) FlushRecord(tbStore immutable.TablesStore, rec *record.Record)

func (*WriteAttached) SetDBInfo added in v1.5.0 

func (w *WriteAttached) SetDBInfo(db string, rp string)

func (*WriteAttached) WriteRecordForFlush added in v1.5.0 

func (w *WriteAttached) WriteRecordForFlush(rec *record.Record, msb *immutable.MsBuilder, tbStore immutable.TablesStore, id uint64, order bool,
	lastFlushTime int64, schema record.Schemas, skipIndexRelation *influxql.IndexRelation) *immutable.MsBuilder

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 NewWriteChunkForColumnStore added in v1.5.0 

func NewWriteChunkForColumnStore() *WriteChunkForColumnStore

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 SeriesRowCountFunc
	MsRowCount        *util.SyncMap[string, *int64]
}

func (*WriteRowsCtx) SetMsRowCount added in v1.5.0 

func (ctx *WriteRowsCtx) SetMsRowCount(v *util.SyncMap[string, *int64])

func (*WriteRowsCtx) SetSeriesRowCountFunc added in v1.5.0 

func (ctx *WriteRowsCtx) SetSeriesRowCountFunc(fn SeriesRowCountFunc)

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.