mutable

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 29 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 GetPrimaryKeys added in v1.1.0 

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

func GetSidsImpl added in v1.1.0 

func GetSidsImpl(size int) []uint64

func GetSizeLimit added in v1.1.0 

func GetSizeLimit() int64

func InitConcurLimiter added in v1.1.0 

func InitConcurLimiter(limit int)

func InitMutablePool added in v1.1.0 

func InitMutablePool(size int)

func InitWriteRecPool added in v1.1.0 

func InitWriteRecPool(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 PutSidsImpl added in v1.1.0 

func PutSidsImpl(sids []uint64)

func SetSizeLimit added in v1.1.0 

func SetSizeLimit(limit int64)

func SetWriteChunk added in v1.1.0 

func SetWriteChunk(msi *MsInfo, rec *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) int64

Types

type FlushManager added in v1.2.0 

type FlushManager interface {
	// contains filtered or unexported methods
}

type MTable added in v1.1.0 

type MTable interface {
	FlushChunks(table *MemTable, dataPath, msName string, lock *string, tbStore immutable.TablesStore)
	WriteRows(table *MemTable, rowsD *dictpool.Dict, wc WriteRowsCtx) error
	WriteCols(table *MemTable, rec *record.Record, mstsInfo *sync.Map, mst string, startSeqId int64) 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) GetMaxTimeBySidNoLock 

func (t *MemTable) GetMaxTimeBySidNoLock(msName string, sid uint64) int64

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 (*MemTables) Init added in v1.0.0 

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

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 SidsPool added in v1.1.0 

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

type WriteChunk 

type WriteChunk struct {
	Mu              sync.Mutex
	Sid             uint64
	LastFlushTime   int64
	OrderWriteRec   WriteRec
	UnOrderWriteRec WriteRec
}

func (*WriteChunk) Init 

func (chunk *WriteChunk) Init(sid uint64, schema []record.Field)

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 {
	GetLastFlushTime  func(msName string, sid uint64) int64
	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.