Documentation ¶
Index ¶
- func NewImmutableIndex() *immutableIndex
- func NewMutableIndex(keyT types.Type) *nonPkMutIndex
- func NewPkMutableIndex(keyT types.Type) *mutableIndex
- func TranslateError(err error) error
- type BFWriter
- type BfReader
- type Index
- type IndexMeta
- func (meta *IndexMeta) Marshal() ([]byte, error)
- func (meta *IndexMeta) SetCompressType(typ common.CompressType)
- func (meta *IndexMeta) SetIndexType(typ IndexType)
- func (meta *IndexMeta) SetIndexedColumn(colIdx uint16)
- func (meta *IndexMeta) SetInternalIndex(idx uint16)
- func (meta *IndexMeta) SetSize(raw, exact uint32)
- func (meta *IndexMeta) Unmarshal(buf []byte) error
- type IndexType
- type IndicesMeta
- type ZMWriter
- func (writer *ZMWriter) AddValues(values containers.Vector) (err error)
- func (writer *ZMWriter) Finalize() (*IndexMeta, error)
- func (writer *ZMWriter) Init(wr objectio.Writer, block objectio.BlockObject, cType common.CompressType, ...) error
- func (writer *ZMWriter) SetMinMax(min, max any, typ types.Type) (err error)
- func (writer *ZMWriter) String() string
- type ZmReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewImmutableIndex ¶
func NewImmutableIndex() *immutableIndex
func NewMutableIndex ¶
func NewPkMutableIndex ¶ added in v0.6.0
func TranslateError ¶
Types ¶
type BFWriter ¶
type BFWriter struct {
// contains filtered or unexported fields
}
func NewBFWriter ¶
func NewBFWriter() *BFWriter
type BfReader ¶ added in v0.6.0
type BfReader struct {
// contains filtered or unexported fields
}
func (*BfReader) MayContainsAnyKeys ¶ added in v0.6.0
type Index ¶
type Index interface { io.Closer Destroy() error // Dedup returns wether the specified key is existed // If key is existed, return ErrDuplicate // If any other unknown error happens, return error // If key is not found, return nil Dedup(key any, skipfn func(row uint32) error) error BatchDedup(keys containers.Vector, skipfn func(row uint32) (err error)) (keyselects *roaring.Bitmap, err error) // BatchUpsert batch insert the specific keys // If any deduplication, it will fetch the old value first, fill the active map with new value, insert the old value into delete map // If any other unknown error hanppens, return error BatchUpsert(keysCtx *index.KeysCtx, offset int) (err error) GetActiveRow(key any) (row []uint32, err error) String() string }
type IndexMeta ¶
type IndexMeta struct { IdxType IndexType CompType common.CompressType ColIdx uint16 InternalIdx uint16 Size uint32 RawSize uint32 }
func NewEmptyIndexMeta ¶
func NewEmptyIndexMeta() *IndexMeta
func (*IndexMeta) SetCompressType ¶
func (meta *IndexMeta) SetCompressType(typ common.CompressType)
func (*IndexMeta) SetIndexType ¶
func (*IndexMeta) SetIndexedColumn ¶
func (*IndexMeta) SetInternalIndex ¶
type IndicesMeta ¶
type IndicesMeta struct {
Metas []IndexMeta
}
func NewEmptyIndicesMeta ¶
func NewEmptyIndicesMeta() *IndicesMeta
func (*IndicesMeta) AddIndex ¶
func (metas *IndicesMeta) AddIndex(meta ...IndexMeta)
func (*IndicesMeta) Marshal ¶
func (metas *IndicesMeta) Marshal() ([]byte, error)
func (*IndicesMeta) Unmarshal ¶
func (metas *IndicesMeta) Unmarshal(buf []byte) error
type ZMWriter ¶
type ZMWriter struct {
// contains filtered or unexported fields
}
func NewZMWriter ¶
func NewZMWriter() *ZMWriter
func (*ZMWriter) AddValues ¶
func (writer *ZMWriter) AddValues(values containers.Vector) (err error)
func (*ZMWriter) Init ¶
func (writer *ZMWriter) Init(wr objectio.Writer, block objectio.BlockObject, cType common.CompressType, colIdx uint16, internalIdx uint16) error
type ZmReader ¶ added in v0.6.0
type ZmReader struct {
// contains filtered or unexported fields
}
func (*ZmReader) ContainsAny ¶ added in v0.6.0
func (*ZmReader) FastContainsAny ¶ added in v0.7.0
func (r *ZmReader) FastContainsAny(keys containers.Vector) (ok bool)
Click to show internal directories.
Click to hide internal directories.