Documentation
¶
Index ¶
- func GetSchemaIndex(schema record.Schemas, oid uint32, IList []string) []int
- type IndexWriter
- type IndexWriterBuilder
- 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, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type IndexWriter ¶
type IndexWriter interface {
Open() error
Close() error
CreateAttachIndex(writeRec *record.Record, schemaIdx, rowsPerSegment []int) error
CreateDetachIndex(writeRec *record.Record, schemaIdx, rowsPerSegment []int, dataBuf [][]byte) ([][]byte, []string)
}
func NewIndexWriter ¶
func NewIndexWriter(dir, msName, dataFilePath, lockPath string, indexType indextype.IndexType, tokens string) IndexWriter
type IndexWriterBuilder ¶
type IndexWriterBuilder struct {
// contains filtered or unexported fields
}
func NewIndexWriterBuilder ¶
func NewIndexWriterBuilder() *IndexWriterBuilder
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)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.