Documentation
¶
Index ¶
- func GetSchemaIndex(schema record.Schemas, oid uint32, IList []string) []int
- type IndexWriter
- type IndexWriterBuilder
- func (s *IndexWriterBuilder) BuildSkipIndexInfo() []*colstore.SkipIndexInfo
- func (s *IndexWriterBuilder) CloseSkipIndexWriters()
- func (s *IndexWriterBuilder) GetBfFirstSchemaIdx() int
- func (s *IndexWriterBuilder) GetBfIdx() int
- func (s *IndexWriterBuilder) GetFullTextIdx() int
- func (s *IndexWriterBuilder) GetSchemaIdxes() [][]int
- func (s *IndexWriterBuilder) GetSkipIndexWriters() []IndexWriter
- func (s *IndexWriterBuilder) NewIndexWriters(dir, msName, dataFilePath, lockPath string, schema record.Schemas, ...) map[string][]IndexWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type IndexWriter ¶
type IndexWriter interface {
Open()
Close() error
Files() []string
CreateAttachIndex(writeRec *record.Record, schemaIdx, rowsPerSegment []int) error
CreateDetachIndex(writeRec *record.Record, schemaIdx, rowsPerSegment []int, dataBuf [][]byte) ([][]byte, []string)
Flush() error
}
func NewIndexWriter ¶
func NewIndexWriter(dir, msName, dataFilePath, lockPath string, indexRelation influxql.IndexRelation, i int, tokens string) IndexWriter
type IndexWriterBuilder ¶
type IndexWriterBuilder struct {
// contains filtered or unexported fields
}
func NewIndexWriterBuilder ¶
func NewIndexWriterBuilder() *IndexWriterBuilder
func (*IndexWriterBuilder) BuildSkipIndexInfo ¶ added in v1.5.0
func (s *IndexWriterBuilder) BuildSkipIndexInfo() []*colstore.SkipIndexInfo
func (*IndexWriterBuilder) CloseSkipIndexWriters ¶ added in v1.5.0
func (s *IndexWriterBuilder) CloseSkipIndexWriters()
func (*IndexWriterBuilder) GetBfFirstSchemaIdx ¶
func (s *IndexWriterBuilder) GetBfFirstSchemaIdx() int
func (*IndexWriterBuilder) GetBfIdx ¶
func (s *IndexWriterBuilder) GetBfIdx() int
GetBfIdx get idx in schemaIdxes if bloom filter index exist bfIdx >= 0
func (*IndexWriterBuilder) GetFullTextIdx ¶
func (s *IndexWriterBuilder) GetFullTextIdx() int
GetFullTextIdx get idx in schemaIdxes if full text index exist fullTextIdx >= 0
func (*IndexWriterBuilder) GetSchemaIdxes ¶
func (s *IndexWriterBuilder) GetSchemaIdxes() [][]int
func (*IndexWriterBuilder) GetSkipIndexWriters ¶
func (s *IndexWriterBuilder) GetSkipIndexWriters() []IndexWriter
func (*IndexWriterBuilder) NewIndexWriters ¶
func (s *IndexWriterBuilder) NewIndexWriters(dir, msName, dataFilePath, lockPath string, schema record.Schemas, indexRelation influxql.IndexRelation) map[string][]IndexWriter
Click to show internal directories.
Click to hide internal directories.